o Adding a 'core' domain module.

o Adding a table scanner and a job that converts jenkins builds to builds.

1 files changed, 53 insertions, 0 deletions

diff --git a/src/main/java/io/trygvis/esper/testing/core/JenkinsBuildPoller.java b/src/main/java/io/trygvis/esper/testing/core/JenkinsBuildPoller.java
new file mode 100644
index 0000000..cb9157c
--- /dev/null
+++ b/src/main/java/io/trygvis/esper/testing/core/JenkinsBuildPoller.java
@@ -0,0 +1,53 @@
+package io.trygvis.esper.testing.core;
+
+import com.jolbox.bonecp.*;
+import io.trygvis.esper.testing.*;
+import io.trygvis.esper.testing.jenkins.*;
+import io.trygvis.esper.testing.sql.*;
+import org.slf4j.*;
+
+import java.sql.*;
+import java.util.*;
+
+import static fj.data.Option.some;
+import static io.trygvis.esper.testing.Config.*;
+import static io.trygvis.esper.testing.EntityRef.jenkinsRef;
+
+public class JenkinsBuildPoller implements TablePoller.NewRowCallback<JenkinsBuildDto> {
+    Logger logger = LoggerFactory.getLogger(getClass());
+
+    public static void main(String[] args) throws Exception {
+        String pollerName = "jenkins_build";
+        String tableName = "jenkins_build";
+        String columnNames = JenkinsDao.JENKINS_BUILD;
+        SqlF<ResultSet, JenkinsBuildDto> f = JenkinsDao.jenkinsBuild;
+        TablePoller.NewRowCallback<JenkinsBuildDto> callback = new JenkinsBuildPoller();
+
+        Config config = loadFromDisk();
+
+        BoneCPDataSource dataSource = config.createBoneCp();
+
+        new TablePoller<>(pollerName, tableName, columnNames, some("array_length(users, 1) > 0"), f, callback).work(dataSource);
+    }
+
+    public void process(Connection c, JenkinsBuildDto jenkinsBuild) throws SQLException {
+        Daos daos = new Daos(c);
+        CoreDao coreDao = daos.coreDao;
+
+        UUID uuid = coreDao.insertBuild(jenkinsBuild.timestamp, "SUCCESS".equals(jenkinsBuild.result), jenkinsRef(jenkinsBuild.uuid));
+        logger.info("Created build uuid={}", uuid);
+
+        for (UUID user : jenkinsBuild.users) {
+            SqlOption<PersonDto> personO = coreDao.selectPersonByJenkinsUuid(user);
+
+            // This happens if no one has claimed the user id.
+            if(personO.isNone()) {
+                continue;
+            }
+
+            UUID person = personO.get().uuid;
+            logger.info("Created build participant, person={}", person);
+            coreDao.insertBuildParticipant(uuid, person);
+        }
+    }
+}