o Adding a basic web app.

2 files changed, 80 insertions, 0 deletions

diff --git a/src/main/java/io/trygvis/esper/testing/web/JenkinsResource.java b/src/main/java/io/trygvis/esper/testing/web/JenkinsResource.java
new file mode 100644
index 0000000..a1e2f51
--- /dev/null
+++ b/src/main/java/io/trygvis/esper/testing/web/JenkinsResource.java
@@ -0,0 +1,57 @@
+package io.trygvis.esper.testing.web;
+
+import fj.data.*;
+import io.trygvis.esper.testing.*;
+import io.trygvis.esper.testing.jenkins.*;
+
+import javax.ws.rs.*;
+import javax.ws.rs.core.*;
+import java.sql.*;
+import java.util.*;
+import java.util.List;
+
+@Path("/")
+public class JenkinsResource {
+
+    private final DatabaseAccess da;
+
+    public JenkinsResource(DatabaseAccess da) {
+        this.da = da;
+    }
+
+    @GET
+    @Path("/resource/jenkins/server")
+    @Produces(MediaType.APPLICATION_JSON)
+    public List<JenkinsServerDto> getServers() throws Exception {
+        System.out.println("JenkinsResource.getServers");
+        return da.inTransaction(new DatabaseAccess.DaosCallback<List<JenkinsServerDto>>() {
+            @Override
+            public List<JenkinsServerDto> run(Daos daos) throws SQLException {
+                return daos.jenkinsDao.selectServers(false);
+            }
+        });
+    }
+
+    @GET
+    @Path("/resource/jenkins/server/{uuid}")
+    @Produces(MediaType.APPLICATION_JSON)
+    public JenkinsServerDto getServer(@PathParam("uuid") String s) throws Exception {
+        try {
+            final UUID uuid = UUID.fromString(s);
+            System.out.println("JenkinsResource.getServers");
+            Option<JenkinsServerDto> server = da.inTransaction(new DatabaseAccess.DaosCallback<Option<JenkinsServerDto>>() {
+                public Option<JenkinsServerDto> run(Daos daos) throws SQLException {
+                    return daos.jenkinsDao.selectServer(uuid);
+                }
+            });
+
+            if(server.isNone()) {
+                throw new WebApplicationException(Response.Status.NOT_FOUND);
+            }
+
+            return server.some();
+        } catch (IllegalArgumentException e) {
+            throw new WebApplicationException(Response.Status.BAD_REQUEST);
+        }
+    }
+}
diff --git a/src/main/java/io/trygvis/esper/testing/web/JerseyApplication.java b/src/main/java/io/trygvis/esper/testing/web/JerseyApplication.java
new file mode 100644
index 0000000..8d071a9
--- /dev/null
+++ b/src/main/java/io/trygvis/esper/testing/web/JerseyApplication.java
@@ -0,0 +1,23 @@
+package io.trygvis.esper.testing.web;
+
+import io.trygvis.esper.testing.*;
+
+import javax.ws.rs.core.*;
+import java.util.*;
+
+public class JerseyApplication extends Application {
+
+    private final DatabaseAccess da;
+
+    public JerseyApplication() throws Exception {
+        Config config = Config.loadFromDisk();
+        this.da = new DatabaseAccess(config.createBoneCp());
+    }
+
+    @Override
+    public Set<Object> getSingletons() {
+        return new HashSet<Object>(Arrays.asList(
+                new JenkinsResource(da)
+        ));
+    }
+}