For story TG-1: Implemented Server Reset feature.

Author: TVolden

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

@@ -232,4 +232,18 @@ public boolean hasReceivedRemoteStopTransactionConfirmation(String status) {
             result &= ((RemoteStopTransactionConfirmation) receivedConfirmation).getStatus().equals(status);
         return result;
     }
+
+    public void sendResetRequest(ResetType type) throws Exception {
+        ResetRequest request = new ResetRequest();
+        request.setType(type);
+        server.send(sessionIndex, request).whenComplete((confirmation, throwable) -> receivedConfirmation = confirmation);
+    }
+
+    public boolean hasReceivedResetConfirmation(String status) {
+        boolean result = receivedConfirmation instanceof ResetConfirmation;
+        if (result)
+            result &= ((ResetConfirmation) receivedConfirmation).getStatus().equals(status);
+        return result;
+    }
+
 }

…u/chargetime/ocpp/test/core/Reset.groovy …argetime/ocpp/test/core/ResetSpec.groovyocpp-v1_6-test/src/test/groovy/eu/chargetime/ocpp/test/core/Reset.groovy renamed to ocpp-v1_6-test/src/test/groovy/eu/chargetime/ocpp/test/core/ResetSpec.groovy ocpp-v1_6-test/src/test/groovy/eu/chargetime/ocpp/test/core/Reset.groovy renamed to ocpp-v1_6-test/src/test/groovy/eu/chargetime/ocpp/test/core/ResetSpec.groovy

@@ -1,14 +1,15 @@
 package eu.chargetime.ocpp.test.core
 
+import eu.chargetime.ocpp.model.core.ResetType
+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 Reset extends Specification {
+class ResetSpec extends Specification {
     @Shared
-    OldFakeCentralSystem centralSystem = OldFakeCentralSystem.getInstance();
+    FakeCentralSystem centralSystem = FakeCentralSystem.getInstance();
     @Shared
     FakeChargePoint chargePoint = new FakeChargePoint();
 
@@ -28,7 +29,7 @@ class Reset extends Specification {
     def "Central System sends a Reset request and receives a response"() {
         def conditions = new PollingConditions(timeout: 1)
         when:
-        centralSystem.sendResetRequest("Soft");
+        centralSystem.sendResetRequest(ResetType.Hard);
 
         then:
         conditions.eventually {

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

@@ -51,6 +51,7 @@ public ServerCoreProfile(ServerCoreEventHandler handler) {
         features.add(new MeterValuesFeature(this));
         features.add(new RemoteStartTransactionFeature(this));
         features.add(new RemoteStopTransactionFeature(this));
+        features.add(new ResetFeature(this));
     }
 
     @Override

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

@@ -215,6 +215,15 @@ public void getFeatureList_containsRemoteStopTransactionFeature() {
         assertThat(findFeature(features, "RemoteStopTransaction"), is(instanceOf(RemoteStopTransactionFeature.class)));
     }
 
+    @Test
+    public void getFeatureList_containsResetFeature() {
+        // When
+        Feature[] features = core.getFeatureList();
+
+        // Then
+        assertThat(findFeature(features, "Reset"), is(instanceOf(ResetFeature.class)));
+    }
+
     private Feature findFeature(Feature[] features, String action) {
         Feature output = null;
         for (Feature feature : features) {