();
+ dbConn.put(DB_DEFAULT_DRIVER_KEY, DB_DEFAULT_DRIVER_VALUE);
+ dbConn.put(DB_DEFAULT_URL_KEY, DB_DEFAULT_URL_VALUE);
+ dbConn.put(EVOLUTION_PLUGIN_KEY, EVOLUTION_PLUGIN_VALUE);
+ dbConn.put(APPLY_EVOLUTIONS_DEFAULT_KEY, APPLY_EVOLUTIONS_DEFAULT_VALUE);
+
+ GlobalSettings gs = new GlobalSettings() {
+ @Override
+ public void onStart(Application app) {
+ logger.info("Starting FakeApplication");
+ }
+ };
+
+ fakeApp = fakeApplication(dbConn, gs);
+ }
+
+ /**
+ *
+ * Rest API - Performs search by job ID
+ *
+ * API provides information on the specific job
+ *
+ *
+ * Following assertions are made in the response json
+ *
+ *
+ *
+ *
+ */
+ @Test
+ public void testrestAppResult() {
+ running(testServer(TEST_SERVER_PORT, fakeApp), new Runnable() {
+ public void run() {
+ populateTestData();
+ final WS.Response response = WS.url(BASE_URL + REST_APP_RESULT_PATH).
+ setQueryParameter("id", TEST_JOB_ID1).
+ get().get(RESPONSE_TIMEOUT, TimeUnit.MILLISECONDS);
+ final JsonNode jsonResponse = response.asJson();
+ assertTrue("Job id did not match", TEST_JOB_ID1.equals(jsonResponse.path("id").asText()));
+ assertTrue("Job name did not match", TEST_JOB_NAME.equals(jsonResponse.path("name").asText()));
+ assertTrue("Job type did not match", TEST_JOB_TYPE.equals(jsonResponse.path("jobType").asText()));
+ }
+ });
+ }
+
+ /**
+ *
+ * Rest API - Performs search by job execution ID
+ *
+ * API returns all jobs triggered by a particular Scheduler Job
+ *
+ *
+ * Following assertions are made in the response json
+ *
+ *
+ *
+ */
+ @Test
+ public void testrestJobExecResult() {
+ running(testServer(TEST_SERVER_PORT, fakeApp), new Runnable() {
+ public void run() {
+ populateTestData();
+ final WS.Response response = WS.url(BASE_URL + REST_JOB_EXEC_RESULT_PATH).
+ setQueryParameter("id", TEST_JOB_EXEC_ID1).
+ get().get(RESPONSE_TIMEOUT, TimeUnit.MILLISECONDS);
+ final JsonNode jsonResponse = response.asJson().get(0);
+ assertTrue("Job id did not match", TEST_JOB_ID1.equals(jsonResponse.path("id").asText()));
+ assertTrue("Job execution id did not match", TEST_JOB_EXEC_ID1.equals(jsonResponse.path("jobExecId").asText()));
+ }
+ });
+ }
+
+ /**
+ *
+ * Rest API - Performs search by flow execution ID
+ *
+ * API returns all jobs under a particular flow execution
+ *
+ *
+ * Following assertions are made in the response json
+ *
+ *
+ *
+ */
+ @Test
+ public void testrestFlowExecResult() {
+ running(testServer(TEST_SERVER_PORT, fakeApp), new Runnable() {
+ public void run() {
+ populateTestData();
+ final WS.Response response = WS.url(BASE_URL + REST_FLOW_EXEC_RESULT_PATH).
+ setQueryParameter("id", TEST_FLOW_EXEC_ID1).
+ get().get(RESPONSE_TIMEOUT, TimeUnit.MILLISECONDS);
+ final JsonNode jsonResponse = response.asJson();
+ assertTrue("Job id did not match", TEST_JOB_ID1.equals(jsonResponse.findValue("id").asText()));
+ assertTrue("Flow execution id did not match",
+ TEST_FLOW_EXEC_ID1.equals(jsonResponse.findValue("flowExecId").asText()));
+ }
+ });
+ }
+
+ /**
+ *
+ * Rest API - Perform a generic search or search by filter criteria
+ *
+ * Test verifies if all available flows are returned
+ *
+ *
+ * Following assertions are made in the response json
+ *
+ *
+ *
+ */
+ @Test
+ public void testrestSearch() {
+ running(testServer(TEST_SERVER_PORT, fakeApp), new Runnable() {
+ public void run() {
+ populateTestData();
+ final WS.Response response = WS.url(BASE_URL + REST_SEARCH_PATH).
+ get().get(RESPONSE_TIMEOUT, TimeUnit.MILLISECONDS);
+ List jobList = response.asJson().findValuesAsText("id");
+ assertTrue("Job id1 missing in list", jobList.contains(TEST_JOB_ID1));
+ assertTrue("Job id2 missing in list", jobList.contains(TEST_JOB_ID2));
+ }
+ });
+ }
+
+ /**
+ *
+ * Rest API - Perform a search with additional params
+ *
+ * Test verifies if specific flow is returned
+ *
+ *
+ * Following assertions are made in the response json
+ *
+ *
+ *
+ *
+ *
+ */
+ @Test
+ public void testrestSearchWithUsernameAndJobType() {
+ running(testServer(TEST_SERVER_PORT, fakeApp), new Runnable() {
+ public void run() {
+ populateTestData();
+ final WS.Response response = WS.url(BASE_URL + REST_SEARCH_PATH).
+ setQueryParameter("username", TEST_USERNAME).
+ setQueryParameter("", TEST_JOB_TYPE).
+ get().get(RESPONSE_TIMEOUT, TimeUnit.MILLISECONDS);
+ JsonNode reponseJson = response.asJson();
+ List jobList = reponseJson.findValuesAsText("id");
+ assertTrue("More than one row returned", jobList.size() == 1);
+ assertTrue("Job id missing in response", TEST_JOB_ID1.equals(reponseJson.findValue("id").asText()));
+ assertTrue("Username incorrect", TEST_USERNAME.equals(reponseJson.findValue("username").asText()));
+ assertTrue("Job type incorrect", TEST_JOB_TYPE.equals(reponseJson.findValue("jobType").asText()));
+ }
+ });
+ }
+
+ /**
+ *
+ * Rest API - Compares two flow executions by flow execution ID
+ *
+ *
+ * Following assertions are made in the response json
+ *
+ *
+ */
+ @Test
+ public void testrestCompare() {
+ running(testServer(TEST_SERVER_PORT, fakeApp), new Runnable() {
+ public void run() {
+ populateTestData();
+ final WS.Response response = WS.url(BASE_URL + REST_COMPARE_PATH).
+ setQueryParameter("flow-exec-id1", TEST_FLOW_EXEC_ID1).
+ setQueryParameter("flow-exec-id2", TEST_FLOW_EXEC_ID2).
+ get().get(RESPONSE_TIMEOUT, TimeUnit.MILLISECONDS);
+ assertTrue("Job id did not match", TEST_JOB_ID2.equals(response.asJson().findValue("id").asText()));
+ }
+ });
+ }
+
+ /**
+ *
+ * Rest API - Provides data for plotting the flow history graph
+ *
+ *
+ * Following assertions are made in the response json
+ *
+ *
+ *
+ */
+ @Test
+ public void testrestFlowGraphData() {
+ running(testServer(TEST_SERVER_PORT, fakeApp), new Runnable() {
+ public void run() {
+ populateTestData();
+ final WS.Response response = WS.url(BASE_URL + REST_FLOW_GRAPH_DATA_PATH).
+ setQueryParameter("id", TEST_FLOW_DEF_ID1).
+ get().get(RESPONSE_TIMEOUT, TimeUnit.MILLISECONDS);
+ List jobList = response.asJson().findValuesAsText("jobexecurl");
+ assertTrue("Job exec url1 missing in list", jobList.contains(TEST_JOB_EXEC_ID1));
+ assertTrue("Job exec url2 missing in list", jobList.contains(TEST_JOB_EXEC_ID2));
+ }
+ });
+ }
+
+ /**
+ *
+ * Rest API - Provides data for plotting the job history graph
+ *
+ *
+ * Following assertions are made in the response json
+ *
+ *
+ *
+ */
+ @Test
+ public void testrestJobGraphData() {
+ running(testServer(TEST_SERVER_PORT, fakeApp), new Runnable() {
+ public void run() {
+ populateTestData();
+ final WS.Response response = WS.url(BASE_URL + REST_JOB_GRAPH_DATA_PATH).
+ setQueryParameter("id", TEST_JOB_DEF_ID1).
+ get().get(RESPONSE_TIMEOUT, TimeUnit.MILLISECONDS);
+ List jobList = response.asJson().findValuesAsText("stageid");
+ assertTrue("Job id 1 missing in list", jobList.contains(TEST_JOB_ID1));
+ assertTrue("Job id 2 missing in list", jobList.contains(TEST_JOB_ID2));
+ }
+ });
+ }
+
+ private void populateTestData() {
+ try {
+ initDB();
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+}