Implemented Server RemoteStartTransaction feature.

Author: TVolden

ocpp-v1_6-test/src/main/java/eu/chargetime/ocpp/test/FakeCentralSystem.java

@@ -203,4 +203,20 @@ public boolean hasHandledHeartbeat() {
     public boolean hasHandledMeterValuesRequest() {
         return receivedRequest instanceof MeterValuesRequest;
     }
+
+    public void sendRemoteStartTransactionRequest(int connectorId, String idTag) throws Exception {
+        RemoteStartTransactionRequest request = new RemoteStartTransactionRequest();
+        IdToken idToken = new IdToken();
+        idToken.setIdToken(idTag);
+        request.setIdTag(idToken);
+        request.setConnectorId(connectorId);
+        server.send(sessionIndex, request).whenComplete((confirmation, throwable) -> receivedConfirmation = confirmation);
+    }
+
+    public boolean hasReceivedRemoteStartTransactionConfirmation(String status) {
+        boolean result = receivedConfirmation instanceof RemoteStartTransactionConfirmation;
+        if (result)
+            result &= ((RemoteStartTransactionConfirmation) receivedConfirmation).getStatus().equals(status);
+        return result;
+    }
 }

…/test/core/RemoteStartTransaction.groovy …t/core/RemoteStartTransactionSpec.groovyocpp-v1_6-test/src/test/groovy/eu/chargetime/ocpp/test/core/RemoteStartTransaction.groovy renamed to ocpp-v1_6-test/src/test/groovy/eu/chargetime/ocpp/test/core/RemoteStartTransactionSpec.groovy ocpp-v1_6-test/src/test/groovy/eu/chargetime/ocpp/test/core/RemoteStartTransaction.groovy renamed to ocpp-v1_6-test/src/test/groovy/eu/chargetime/ocpp/test/core/RemoteStartTransactionSpec.groovy

@@ -1,14 +1,14 @@
 package eu.chargetime.ocpp.test.core
 
+import eu.chargetime.ocpp.test.FakeCentralSystem
 import eu.chargetime.ocpp.test.FakeChargePoint
-import eu.chargetime.ocpp.test.OldFakeCentralSystem
 import spock.lang.Shared
 import spock.lang.Specification
 import spock.util.concurrent.PollingConditions
 
-class RemoteStartTransaction extends Specification {
+class RemoteStartTransactionSpec extends Specification {
     @Shared
-    OldFakeCentralSystem centralSystem = OldFakeCentralSystem.getInstance();
+    FakeCentralSystem centralSystem = FakeCentralSystem.getInstance();
     @Shared
     FakeChargePoint chargePoint = new FakeChargePoint();
 
@@ -28,7 +28,7 @@ class RemoteStartTransaction extends Specification {
     def "Central System sends a RemoteStartTransaction request and receives a response"() {
         def conditions = new PollingConditions(timeout: 1)
         when:
-        centralSystem.sendRemoteStartTransactionRequest("some id");
+        centralSystem.sendRemoteStartTransactionRequest(1, "some id");
 
         then:
         conditions.eventually {

ocpp-v1_6/src/main/java/eu/chargetime/ocpp/feature/profile/ServerCoreProfile.java

@@ -49,6 +49,7 @@ public ServerCoreProfile(ServerCoreEventHandler handler) {
         features.add(new GetConfigurationFeature(this));
         features.add(new HeartbeatFeature(this));
         features.add(new MeterValuesFeature(this));
+        features.add(new RemoteStartTransactionFeature(this));
     }
 
     @Override

ocpp-v1_6/src/test/java/eu/chargetime/ocpp/feature/profile/test/ServerCoreProfileTest.java

@@ -197,6 +197,15 @@ public void handleRequest_aMeterValuesRequest_callsHandleMeterValuesRequest() {
         verify(handler, times(1)).handleMeterValuesRequest(eq(sessionId), eq(request));
     }
 
+    @Test
+    public void getFeatureList_containsRemoteStartTransactionFeature() {
+        // When
+        Feature[] features = core.getFeatureList();
+
+        // Then
+        assertThat(findFeature(features, "RemoteStartTransaction"), is(instanceOf(RemoteStartTransactionFeature.class)));
+    }
+
     private Feature findFeature(Feature[] features, String action) {
         Feature output = null;
         for (Feature feature : features) {