Feature/toggle service interface

CHANGELOG.md

@@ -47,7 +47,7 @@ Includes initial hubclientinfo OCPI module implementation.
 - Optional "Planned Party" search scans registry for newly planned parties at regular intervals.
 - New configuration properties under `ocn.node`: `stillAliveEnabled`, `stillAliveRate`,
   `plannedPartySearchEnabled`, `plannedPartySearchRate`.
-
+  
 ## 1.0.0
 ### Mar 03, 2020
 

src/main/kotlin/snc/openchargingnetwork/node/controllers/ocpi/v2_2/CredentialsController.kt

@@ -31,7 +31,6 @@ import snc.openchargingnetwork.node.services.HttpService
 import snc.openchargingnetwork.node.services.RegistryService
 import snc.openchargingnetwork.node.tools.*
 
-
 @RestController
 @RequestMapping("/ocpi/2.2/credentials")
 class CredentialsController(private val platformRepo: PlatformRepository,

src/test/kotlin/snc/openchargingnetwork/node/integration/AppInterfaceTest.kt

@@ -0,0 +1,65 @@
+package snc.openchargingnetwork.node.integration
+
+import org.awaitility.kotlin.await
+import org.junit.jupiter.api.AfterEach
+import org.junit.jupiter.api.BeforeEach
+import org.junit.jupiter.api.Test
+import org.springframework.http.HttpMethod
+import snc.openchargingnetwork.node.integration.utils.*
+import snc.openchargingnetwork.node.models.OcnServicePermission
+import snc.openchargingnetwork.node.models.ocpi.InterfaceRole
+import snc.openchargingnetwork.node.models.ocpi.ModuleID
+import java.util.concurrent.TimeUnit
+
+class ServiceInterfaceTest {
+
+    // TODO: integration test setup could be in an inheritable class
+    private lateinit var networkComponents: NetworkComponents
+    private lateinit var cpo1: TestCpo
+    private lateinit var cpo2: TestCpo
+    private lateinit var msp: TestMsp
+
+
+    @BeforeEach
+    fun bootStrap() {
+        networkComponents = setupNetwork(HubClientInfoParams())
+        cpo1 = networkComponents.cpos[0]
+        cpo2 = networkComponents.cpos[1]
+        msp = networkComponents.msps.first()
+    }
+
+    @AfterEach
+    fun stopTestParties() {
+        stopPartyServers(networkComponents)
+    }
+
+    private fun seenByBothCpos(): Boolean {
+        val message = ReceivedMessage(
+                module = ModuleID.LOCATIONS,
+                interfaceRole = InterfaceRole.SENDER,
+                method = HttpMethod.GET,
+                sender = msp.party)
+        val cpo1Seen = cpo1.server.messageStore.contains(message)
+        val cpo2Seen = cpo2.server.messageStore.contains(message)
+        return cpo1Seen && cpo2Seen
+    }
+
+    private fun testForwarding(recipient: TestCpo, service: TestCpo) {
+        service.server.setServicePermissions(listOf(OcnServicePermission.FORWARD_ALL))
+        msp.server.agreeToServicePermissions(service.address)
+        msp.server.getLocation(recipient.party)
+        await.atMost(2L, TimeUnit.SECONDS).until { seenByBothCpos() }
+    }
+
+    @Test
+    fun fowardsRequestToService_Local() {
+        testForwarding(recipient = cpo2, service = cpo1)
+
+    }
+
+    @Test
+    fun fowardsRequestToService_Remote() {
+        testForwarding(recipient = cpo1, service = cpo2)
+    }
+
+}