add "test" maven profile for integration testing

Author: goekay

pom.xml

@@ -51,12 +51,21 @@
             </activation>
             <properties>
                 <envName>prod</envName>
+                <skipTests>true</skipTests>
             </properties>
         </profile>
         <profile>
             <id>dev</id>
             <properties>
                 <envName>dev</envName>
+                <skipTests>true</skipTests>
+            </properties>
+        </profile>
+        <profile>
+            <id>test</id>
+            <properties>
+                <envName>test</envName>
+                <skipTests>false</skipTests>
             </properties>
         </profile>
     </profiles>

src/main/java/de/rwth/idsg/steve/ApplicationProfile.java

@@ -6,6 +6,7 @@
  */
 public enum ApplicationProfile {
     DEV,
+    TEST,
     PROD;
 
     public static ApplicationProfile fromName(String v) {

src/main/resources/config/test/log4j2.xml

@@ -0,0 +1,34 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<Configuration status="WARN">
+
+    <Properties>
+        <Property name="logPattern">[%-5p] %d %c (%t) - %m%n</Property>
+    </Properties>
+
+    <Appenders>
+        <Console name="CONSOLE" target="SYSTEM_OUT">
+            <PatternLayout pattern="${logPattern}"/>
+        </Console>
+    </Appenders>
+
+    <Loggers>
+        <!-- Disable the Jooq logo in logs -->
+        <!-- https://github.com/jOOQ/jOOQ/issues/4019 -->
+        <AsyncLogger name="org.jooq.Constants" level="WARN"/>
+
+        <AsyncLogger name="org.apache.cxf" level="INFO"/>
+        <AsyncLogger name="org.eclipse.jetty" level="INFO"/>
+        <AsyncLogger name="com.zaxxer.hikari" level="INFO"/>
+        <AsyncLogger name="org.springframework" level="INFO"/>
+        <AsyncLogger name="org.springframework.security" level="INFO"/>
+        <AsyncLogger name="org.springframework.web.servlet" level="INFO"/>
+
+        <AsyncLogger name="org.apache.jasper" level="WARN"/>
+        <AsyncLogger name="org.apache.tomcat.util" level="WARN"/>
+        <AsyncLogger name="jndi" level="WARN"/>
+
+        <AsyncRoot level="DEBUG">
+            <AppenderRef ref="CONSOLE"/>
+        </AsyncRoot>
+    </Loggers>
+</Configuration>

src/main/resources/config/test/main.properties

@@ -0,0 +1,46 @@
+# Just to be backwards compatible with previous versions, this is set to "steve",
+# since there might be already configured chargepoints expecting the older path.
+# Otherwise, might as well be changed to something else or be left empty.
+#
+context.path = steve
+
+# Database configuration
+#
+db.ip = localhost
+db.port = 3306
+db.schema = stevedb_test_2aa6a783d47d
+db.user = steve
+db.password = changeme
+
+# Credentials for Web interface access
+#
+auth.user = admin
+auth.password = 1234
+
+# Jetty configuration
+#
+server.host = 127.0.0.1
+server.gzip.enabled = false
+
+# Jetty HTTP configuration
+#
+http.enabled = true
+http.port = 8080
+
+# Jetty HTTPS configuration
+#
+https.enabled = false
+https.port = 8443
+keystore.path =
+keystore.password =
+
+# When the WebSocket/Json charge point opens more than one WebSocket connection,
+# we need a mechanism/strategy to select one of them for outgoing requests.
+# For allowed values see de.rwth.idsg.steve.ocpp.ws.custom.WsSessionSelectStrategyEnum.
+#
+ws.session.select.strategy = ALWAYS_LAST
+
+### DO NOT MODIFY ###
+steve.version = ${project.version}
+db.sql.logging = true
+profile = test

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

@@ -6,12 +6,13 @@
 import ocpp.cs._2010._08.AuthorizeResponse;
 import ocpp.cs._2010._08.BootNotificationRequest;
 import ocpp.cs._2010._08.BootNotificationResponse;
+import ocpp.cs._2010._08.RegistrationStatus;
 import ocpp.cs._2012._06.CentralSystemService;
 import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;
 import org.apache.cxf.ws.addressing.WSAddressingFeature;
+import org.junit.AfterClass;
 import org.junit.Assert;
 import org.junit.BeforeClass;
-import org.junit.Ignore;
 import org.junit.Test;
 
 import javax.xml.ws.soap.SOAPBinding;
@@ -23,18 +24,29 @@
  * @author Sevket Goekay <goekay@dbis.rwth-aachen.de>
  * @since 10.03.2018
  */
-@Ignore
 @Slf4j
 public class ApplicationTest {
 
+    private static final String REGISTERED_CHARGE_BOX_ID = __DatabasePreparer__.getRegisteredChargeBoxId();
+    private static final String REGISTERED_OCPP_TAG =  __DatabasePreparer__.getRegisteredOcppTag();
     private static final String path = getPath();
 
+    private static Application app;
+
     @BeforeClass
     public static void init() throws Exception {
-        Application app = new Application();
+        __DatabasePreparer__.prepare();
+
+        app = new Application();
         app.start();
     }
 
+    @AfterClass
+    public static void destroy() throws Exception {
+        app.stop();
+        __DatabasePreparer__.cleanUp();
+    }
+
     @Test
     public void testOcpp12() {
         ocpp.cs._2010._08.CentralSystemService client = getForOcpp12();
@@ -43,16 +55,16 @@ public void testOcpp12() {
                 new BootNotificationRequest()
                         .withChargePointVendor(getRandomString())
                         .withChargePointModel(getRandomString()),
-                getRandomString());
+                REGISTERED_CHARGE_BOX_ID);
         Assert.assertNotNull(boot);
-        Assert.assertEquals(ocpp.cs._2010._08.RegistrationStatus.REJECTED, boot.getStatus());
+        Assert.assertEquals(RegistrationStatus.ACCEPTED, boot.getStatus());
 
         AuthorizeResponse auth = client.authorize(
                 new AuthorizeRequest()
-                        .withIdTag(getRandomString()),
-                getRandomString());
+                        .withIdTag(REGISTERED_OCPP_TAG),
+                REGISTERED_CHARGE_BOX_ID);
         Assert.assertNotNull(auth);
-        Assert.assertEquals(AuthorizationStatus.INVALID, auth.getIdTagInfo().getStatus());
+        Assert.assertEquals(AuthorizationStatus.ACCEPTED, auth.getIdTagInfo().getStatus());
     }
 
     @Test
@@ -63,16 +75,16 @@ public void testOcpp15() {
                 new ocpp.cs._2012._06.BootNotificationRequest()
                         .withChargePointVendor(getRandomString())
                         .withChargePointModel(getRandomString()),
-                getRandomString());
+                REGISTERED_CHARGE_BOX_ID);
         Assert.assertNotNull(boot);
-        Assert.assertEquals(ocpp.cs._2012._06.RegistrationStatus.REJECTED, boot.getStatus());
+        Assert.assertEquals(ocpp.cs._2012._06.RegistrationStatus.ACCEPTED, boot.getStatus());
 
         ocpp.cs._2012._06.AuthorizeResponse auth = client.authorize(
                 new ocpp.cs._2012._06.AuthorizeRequest()
-                        .withIdTag(getRandomString()),
-                getRandomString());
+                        .withIdTag(REGISTERED_OCPP_TAG),
+                REGISTERED_CHARGE_BOX_ID);
         Assert.assertNotNull(auth);
-        Assert.assertEquals(ocpp.cs._2012._06.AuthorizationStatus.INVALID, auth.getIdTagInfo().getStatus());
+        Assert.assertEquals(ocpp.cs._2012._06.AuthorizationStatus.ACCEPTED, auth.getIdTagInfo().getStatus());
     }
 
 

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

@@ -0,0 +1,91 @@
+package de.rwth.idsg.steve;
+
+import com.google.common.collect.Sets;
+import de.rwth.idsg.steve.config.BeanConfiguration;
+import jooq.steve.db.DefaultCatalog;
+import jooq.steve.db.tables.SchemaVersion;
+import jooq.steve.db.tables.Settings;
+import org.jooq.DSLContext;
+import org.jooq.Table;
+import org.jooq.impl.DSL;
+
+import java.util.Set;
+import java.util.function.Consumer;
+
+import static jooq.steve.db.tables.ChargeBox.CHARGE_BOX;
+import static jooq.steve.db.tables.OcppTag.OCPP_TAG;
+
+/**
+ * This is a dangerous class. It performs database operations no class should do, like truncating all tables and
+ * inserting data while bypassing normal mechanisms of SteVe. However, for integration testing with reproducible
+ * results we need a clean and isolated database.
+ *
+ * @author Sevket Goekay <goekay@dbis.rwth-aachen.de>
+ * @since 21.03.2018
+ */
+public class __DatabasePreparer__ {
+
+    private static final String SCHEMA_TO_TRUNCATE = "stevedb_test_2aa6a783d47d";
+    private static final String REGISTERED_CHARGE_BOX_ID = "charge_box_2aa6a783d47d";
+    private static final String REGISTERED_OCPP_TAG = "id_tag_2aa6a783d47d";
+
+    public static void prepare() {
+        runOperation(ctx -> {
+            truncateTables(ctx);
+            insertChargeBox(ctx);
+            insertOcppIdTag(ctx);
+        });
+    }
+
+    public static void cleanUp() {
+        runOperation(__DatabasePreparer__::truncateTables);
+    }
+
+    public static String getRegisteredChargeBoxId() {
+        return REGISTERED_CHARGE_BOX_ID;
+    }
+
+    public static String getRegisteredOcppTag() {
+        return REGISTERED_OCPP_TAG;
+    }
+
+    private static void runOperation(Consumer<DSLContext> consumer) {
+        BeanConfiguration beanConfiguration = new BeanConfiguration();
+        DSLContext ctx = beanConfiguration.dslContext();
+        try {
+            consumer.accept(ctx);
+        } finally {
+            beanConfiguration.shutDown();
+        }
+    }
+
+    private static void truncateTables(DSLContext ctx) {
+        Set<Table<?>> skipList = Sets.newHashSet(SchemaVersion.SCHEMA_VERSION, Settings.SETTINGS);
+        ctx.transaction(configuration -> {
+            DSLContext internalCtx = DSL.using(configuration);
+            internalCtx.execute("SET FOREIGN_KEY_CHECKS=0");
+            DefaultCatalog.DEFAULT_CATALOG.getSchemas()
+                                          .stream()
+                                          .filter(schema -> SCHEMA_TO_TRUNCATE.equals(schema.getName()))
+                                          .forEach(schema -> schema.getTables()
+                                                                   .stream()
+                                                                   .filter(t -> !skipList.contains(t))
+                                                                   .forEach(t -> internalCtx.truncate(t).execute()));
+            internalCtx.execute("SET FOREIGN_KEY_CHECKS=1");
+        });
+    }
+
+    private static void insertChargeBox(DSLContext ctx) {
+        ctx.insertInto(CHARGE_BOX)
+           .set(CHARGE_BOX.CHARGE_BOX_ID, getRegisteredChargeBoxId())
+           .execute();
+    }
+
+    private static void insertOcppIdTag(DSLContext ctx) {
+        ctx.insertInto(OCPP_TAG)
+           .set(OCPP_TAG.ID_TAG, getRegisteredOcppTag())
+           .set(OCPP_TAG.BLOCKED, false)
+           .set(OCPP_TAG.IN_TRANSACTION, false)
+           .execute();
+    }
+}