For story TG-1: Implemented Server StartTransaction feature.

Author: TVolden

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

@@ -103,6 +103,17 @@ public MeterValuesConfirmation handleMeterValuesRequest(int sessionIndex, MeterV
                 receivedRequest = request;
                 return new MeterValuesConfirmation();
             }
+
+            @Override
+            public StartTransactionConfirmation handleStartTransactionRequest(int sessionIndex, StartTransactionRequest request) {
+                receivedRequest = request;
+                IdTagInfo tagInfo = new IdTagInfo();
+                tagInfo.setStatus(AuthorizationStatus.Accepted);
+
+                StartTransactionConfirmation confirmation = new StartTransactionConfirmation();
+                confirmation.setIdTagInfo(tagInfo);
+                return confirmation;
+            }
         }));
         server.open("localhost", 8887, new ServerEvents() {
             @Override
@@ -246,4 +257,7 @@ public boolean hasReceivedResetConfirmation(String status) {
         return result;
     }
 
+    public boolean hasHandledStartTransactionRequest() {
+        return receivedRequest instanceof StartTransactionRequest;
+    }
 }

…e/ocpp/test/core/StartTransaction.groovy …pp/test/core/StartTransactionSpec.groovyocpp-v1_6-test/src/test/groovy/eu/chargetime/ocpp/test/core/StartTransaction.groovy renamed to ocpp-v1_6-test/src/test/groovy/eu/chargetime/ocpp/test/core/StartTransactionSpec.groovy ocpp-v1_6-test/src/test/groovy/eu/chargetime/ocpp/test/core/StartTransaction.groovy renamed to ocpp-v1_6-test/src/test/groovy/eu/chargetime/ocpp/test/core/StartTransactionSpec.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 StartTransaction extends Specification {
+class StartTransactionSpec extends Specification {
     @Shared
-    OldFakeCentralSystem centralSystem = OldFakeCentralSystem.getInstance();
+    FakeCentralSystem centralSystem = FakeCentralSystem.getInstance();
     @Shared
     FakeChargePoint chargePoint = new FakeChargePoint();
 
@@ -32,12 +32,9 @@ class StartTransaction extends Specification {
 
         then:
         conditions.eventually {
-            assert centralSystem.hasReceivedStartTransactionRequest();
+            assert centralSystem.hasHandledStartTransactionRequest();
         }
 
-        when:
-        centralSystem.sendStartTransactionConfirmation();
-
         then:
         conditions.eventually {
             assert chargePoint.hasReceivedStartTransactionConfirmation();

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

@@ -31,6 +31,7 @@ public interface ServerCoreEventHandler {
     BootNotificationConfirmation handleBootNotificationRequest(int sessionIndex, BootNotificationRequest request);
     DataTransferConfirmation handleDataTransferRequest(int sessionIndex, DataTransferRequest request);
     HeartbeatConfirmation handleHeartbeatRequest(int sessionIndex, HeartbeatRequest request);
-
     MeterValuesConfirmation handleMeterValuesRequest(int sessionIndex, MeterValuesRequest request);
+
+    StartTransactionConfirmation handleStartTransactionRequest(int sessionIndex, StartTransactionRequest request);
 }

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

@@ -52,6 +52,7 @@ public ServerCoreProfile(ServerCoreEventHandler handler) {
         features.add(new RemoteStartTransactionFeature(this));
         features.add(new RemoteStopTransactionFeature(this));
         features.add(new ResetFeature(this));
+        features.add(new StartTransactionFeature(this));
     }
 
     @Override
@@ -73,6 +74,8 @@ public Confirmation handleRequest(int sessionIndex, Request request) {
             result = handler.handleHeartbeatRequest(sessionIndex, (HeartbeatRequest) request);
         } else if (request instanceof MeterValuesRequest) {
             result = handler.handleMeterValuesRequest(sessionIndex, (MeterValuesRequest) request);
+        } else if (request instanceof StartTransactionRequest) {
+            result = handler.handleStartTransactionRequest(sessionIndex, (StartTransactionRequest) request);
         }
 
         return result;

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

@@ -224,6 +224,28 @@ public void getFeatureList_containsResetFeature() {
         assertThat(findFeature(features, "Reset"), is(instanceOf(ResetFeature.class)));
     }
 
+    @Test
+    public void getFeatureList_containsStartTransactionFeature() {
+        // When
+        Feature[] features = core.getFeatureList();
+
+        // Then
+        assertThat(findFeature(features, "StartTransaction"), is(instanceOf(StartTransactionFeature.class)));
+    }
+
+    @Test
+    public void handleRequest_aStartTransactionRequest_callsHandleStartTransactionRequest() {
+        // Given
+        StartTransactionRequest request = new StartTransactionRequest();
+        int sessionId = 42;
+
+        // When
+        core.handleRequest(sessionId, request);
+
+        // Then
+        verify(handler, times(1)).handleStartTransactionRequest(eq(sessionId), eq(request));
+    }
+
     private Feature findFeature(Feature[] features, String action) {
         Feature output = null;
         for (Feature feature : features) {