add operational test to check "in transaction status" of id tags

Author: goekay

src/main/java/de/rwth/idsg/steve/repository/impl/OcppTagRepositoryImpl.java

@@ -37,7 +37,12 @@
 @Repository
 public class OcppTagRepositoryImpl implements OcppTagRepository {
 
-    @Autowired private DSLContext ctx;
+    private final DSLContext ctx;
+
+    @Autowired
+    public OcppTagRepositoryImpl(DSLContext ctx) {
+        this.ctx = ctx;
+    }
 
     @Override
     @SuppressWarnings("unchecked")

src/test/java/de/rwth/idsg/steve/OperationalTestSoapOCPP16.java

@@ -126,6 +126,36 @@ public void testUnregisteredIdTag() {
         Assert.assertEquals(AuthorizationStatus.INVALID, auth.getIdTagInfo().getStatus());
     }
 
+    @Test
+    public void testInTransactionStatusOfIdTag() {
+        CentralSystemService client = getForOcpp16(path);
+
+        StartTransactionResponse start = client.startTransaction(
+                new StartTransactionRequest()
+                        .withConnectorId(2)
+                        .withIdTag(REGISTERED_OCPP_TAG)
+                        .withTimestamp(DateTime.now())
+                        .withMeterStart(0),
+                REGISTERED_CHARGE_BOX_ID
+        );
+
+        Assert.assertNotNull(start);
+        Assert.assertTrue(start.getTransactionId() > 0);
+        Assert.assertTrue(__DatabasePreparer__.getOcppTagRecord(REGISTERED_OCPP_TAG).getInTransaction());
+
+        StopTransactionResponse stop = client.stopTransaction(
+                new StopTransactionRequest()
+                        .withTransactionId(start.getTransactionId())
+                        .withTimestamp(DateTime.now())
+                        .withIdTag(REGISTERED_OCPP_TAG)
+                        .withMeterStop(30),
+                REGISTERED_CHARGE_BOX_ID
+        );
+
+        Assert.assertNotNull(stop);
+        Assert.assertFalse(__DatabasePreparer__.getOcppTagRecord(REGISTERED_OCPP_TAG).getInTransaction());
+    }
+
     @Test
     public void testStatusNotification() {
         CentralSystemService client = getForOcpp16(path);

src/test/java/de/rwth/idsg/steve/__DatabasePreparer__.java

@@ -10,13 +10,15 @@
 import de.rwth.idsg.steve.repository.dto.TransactionDetails;
 import de.rwth.idsg.steve.repository.impl.AddressRepositoryImpl;
 import de.rwth.idsg.steve.repository.impl.ChargePointRepositoryImpl;
+import de.rwth.idsg.steve.repository.impl.OcppTagRepositoryImpl;
 import de.rwth.idsg.steve.repository.impl.ReservationRepositoryImpl;
 import de.rwth.idsg.steve.repository.impl.TransactionRepositoryImpl;
 import de.rwth.idsg.steve.web.dto.ReservationQueryForm;
 import de.rwth.idsg.steve.web.dto.TransactionQueryForm;
 import jooq.steve.db.DefaultCatalog;
 import jooq.steve.db.tables.SchemaVersion;
 import jooq.steve.db.tables.Settings;
+import jooq.steve.db.tables.records.OcppTagRecord;
 import jooq.steve.db.tables.records.TransactionRecord;
 import org.joda.time.DateTime;
 import org.jooq.DSLContext;
@@ -106,6 +108,11 @@ public static TransactionDetails getDetails(int transactionPk) {
         return impl.getDetails(transactionPk);
     }
 
+    public static OcppTagRecord getOcppTagRecord(String idTag) {
+        OcppTagRepositoryImpl impl = new OcppTagRepositoryImpl(dslContext);
+        return impl.getRecord(idTag);
+    }
+
     public static ChargePoint.Details getCBDetails(String chargeboxID) {
         ChargePointRepositoryImpl impl = new ChargePointRepositoryImpl(dslContext, new AddressRepositoryImpl());
         Map<String, Integer> pkMap = impl.getChargeBoxIdPkPair(Arrays.asList(chargeboxID));