Repository: oodt Updated Branches: refs/heads/master 538c0d6ba -> 6c58b743a
OODT-917 tests for WM to validate XMLRPC interface Project: http://git-wip-us.apache.org/repos/asf/oodt/repo Commit: http://git-wip-us.apache.org/repos/asf/oodt/commit/6c58b743 Tree: http://git-wip-us.apache.org/repos/asf/oodt/tree/6c58b743 Diff: http://git-wip-us.apache.org/repos/asf/oodt/diff/6c58b743 Branch: refs/heads/master Commit: 6c58b743a581428410918d4d897d7ad4b91c6bc8 Parents: 538c0d6 Author: Tom Barber <[email protected]> Authored: Thu Nov 5 22:09:34 2015 +0000 Committer: Tom Barber <[email protected]> Committed: Thu Nov 5 22:09:34 2015 +0000 ---------------------------------------------------------------------- .../system/TestXmlRpcWorkflowManagerClient.java | 163 ++++++++++++++++++- 1 file changed, 161 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/oodt/blob/6c58b743/workflow/src/test/java/org/apache/oodt/cas/workflow/system/TestXmlRpcWorkflowManagerClient.java ---------------------------------------------------------------------- diff --git a/workflow/src/test/java/org/apache/oodt/cas/workflow/system/TestXmlRpcWorkflowManagerClient.java b/workflow/src/test/java/org/apache/oodt/cas/workflow/system/TestXmlRpcWorkflowManagerClient.java index a12ea19..94c3bee 100644 --- a/workflow/src/test/java/org/apache/oodt/cas/workflow/system/TestXmlRpcWorkflowManagerClient.java +++ b/workflow/src/test/java/org/apache/oodt/cas/workflow/system/TestXmlRpcWorkflowManagerClient.java @@ -283,13 +283,12 @@ public class TestXmlRpcWorkflowManagerClient { } - @Ignore @Test public void testGetNumWorkflowInstancesByStatus() throws Exception { int inst = fmc.getNumWorkflowInstancesByStatus("QUEUED"); - fail(); + assertThat(inst, equalTo(0)); } @@ -322,7 +321,167 @@ public class TestXmlRpcWorkflowManagerClient { assertNotNull(wfinstances); } + @Test + public void testGetWFMUrl(){ + + URL url = fmc.getWorkflowManagerUrl(); + + assertThat(url, is(not(nullValue()))); + + assertThat(url.toString(), equalTo("http://localhost:"+WM_PORT)); + } + + @Ignore + @Test + public void testGetNullWorkflowInstances() + throws RepositoryException, XmlRpcException, IOException, InterruptedException { + + Thread.sleep(3000); + WorkflowInstance instance = fmc.getWorkflowInstanceById("1234"); + + assertThat(instance, is(nullValue())); + + } + + @Test + public void testGetNullWorkflowInstancesByStatus() throws XmlRpcException, IOException { + List<WorkflowInstance> instances = fmc.getWorkflowInstancesByStatus("NULL"); + + assertThat(instances, is(empty())); + + } + + @Test + public void testGetWorkflowById() throws RepositoryException, XmlRpcException, IOException { + List<Workflow> workflowlist = fmc.getWorkflows(); + + assertThat(workflowlist, is(not(nullValue()))); + + assertThat(workflowlist.size(), is(not(0))); + + Workflow work = fmc.getWorkflowById(workflowlist.get(0).getId()); + + assertThat(work, is(not(nullValue()))); + + } + + @Test + public void testGetWorkflowInstanceById() throws XmlRpcException, IOException, RepositoryException { + + List<WorkflowInstance> workflowlist = fmc.getWorkflowInstances(); + + assertThat(workflowlist, is(not(nullValue()))); + + assertThat(workflowlist.size(), is(not(0))); + + WorkflowInstance instance = fmc.getWorkflowInstanceById(workflowlist.get(0).getId()); + + assertThat(instance, is(not(nullValue()))); + + } + + @Ignore + @Test + public void testUpdateMetadataForWorkflow(){ + + } + + @Test + public void testUpdateWorkflowInstanceStatus() throws XmlRpcException, IOException, RepositoryException { + + List<WorkflowInstance> workflowlist = fmc.getWorkflowInstances(); + + assertThat(workflowlist, is(not(nullValue()))); + + assertThat(workflowlist.size(), is(not(0))); + + WorkflowInstance instance = fmc.getWorkflowInstanceById(workflowlist.get(0).getId()); + + assertThat(instance, is(not(nullValue()))); + + boolean upd = fmc.updateWorkflowInstanceStatus(instance.getId(), "RUNNING"); + + assertThat(upd, equalTo(true)); + + + } + + @Ignore + @Test + public void testSetWorkflowInstanceCurrentTaskEndDateTime(){ + + } + + @Ignore + @Test + public void testResumeWorkflowInstance(){ + + } + + @Ignore + @Test + public void testPauseWorkflowInstance(){ + + } + + @Ignore + @Test + public void testStopWorkflowInstances(){ + + } + + @Test + public void testGetWorkflowWallClockMinutes() throws RepositoryException, XmlRpcException, IOException { + List<WorkflowInstance> workflowlist = fmc.getWorkflowInstances(); + + assertThat(workflowlist, is(not(nullValue()))); + + assertThat(workflowlist.size(), is(not(0))); + + WorkflowInstance instance = fmc.getWorkflowInstanceById(workflowlist.get(0).getId()); + + assertThat(instance, is(not(nullValue()))); + + double clock = fmc.getWorkflowWallClockMinutes(instance.getId()); + assertThat(clock, is(not(nullValue()))); + } + + @Ignore + @Test + public void testSetWorkflowInstanceCurrentTaskStartDateTime(){ + + } + + @Test + public void testPaginateWorkflowInstances() throws XmlRpcException, IOException { + + WorkflowInstancePage paginate = fmc.paginateWorkflowInstances(2); + + assertThat(paginate, is(not(nullValue()))); + } + + @Test + public void testPaginateWorkflowInstancesByStatus() throws XmlRpcException, IOException { + + WorkflowInstancePage paginate = fmc.paginateWorkflowInstances(2, "QUEUED"); + + assertThat(paginate, is(not(nullValue()))); + } + @Ignore + @Test + public void testExecuteDynamicWorkflow(){ + + } + + @Ignore + @Test + public void testRefreshRepository() throws XmlRpcException, IOException { + + boolean refresh = fmc.refreshRepository(); + + assertThat(refresh, equalTo(true)); + } @Test public void testGetWorkflowInstanceMetadata() {
