Commit e302b098 authored by Sonia Zorba's avatar Sonia Zorba
Browse files

Added test on JobService

parent 5d8899dc
Pipeline #2209 passed with stages
in 2 minutes and 21 seconds
...@@ -203,7 +203,7 @@ public class JobService { ...@@ -203,7 +203,7 @@ public class JobService {
List<String> sourceAndDestination = copyService.processCopyNodes(transfer, jobId, user); List<String> sourceAndDestination = copyService.processCopyNodes(transfer, jobId, user);
// Call file service and command copy // Call file service and command copy
try{ try{
fileServiceClient.startFileCopyJob(sourceAndDestination.get(0), sourceAndDestination.get(1), jobId, user); fileServiceClient.startFileCopyJob(sourceAndDestination.get(0), sourceAndDestination.get(1), jobId, user);
} catch (Exception e) { } catch (Exception e) {
// We decided not to purge metadata in case of failure // We decided not to purge metadata in case of failure
// just release busy nodes setting job_id = null // just release busy nodes setting job_id = null
......
...@@ -55,6 +55,12 @@ public class JobServiceTest { ...@@ -55,6 +55,12 @@ public class JobServiceTest {
@Mock @Mock
private MoveService moveService; private MoveService moveService;
@Mock
private CopyService copyService;
@Mock
private FileServiceClient fileServiceClient;
@InjectMocks @InjectMocks
private JobService jobService; private JobService jobService;
...@@ -217,6 +223,43 @@ public class JobServiceTest { ...@@ -217,6 +223,43 @@ public class JobServiceTest {
assertEquals(ExecutionPhase.COMPLETED, phases.get(2)); assertEquals(ExecutionPhase.COMPLETED, phases.get(2));
} }
@Test
public void testStartJobCopyNode() {
Transfer copyNode = new Transfer();
copyNode.setDirection("vos://example.com!vospace/myfile");
copyNode.setKeepBytes(true);
JobSummary job = new JobSummary();
setJobInfo(job, copyNode);
when(uriService.getTransfer(any())).thenReturn(copyNode);
List<ExecutionPhase> phases = new ArrayList<>();
doAnswer(invocation -> {
JobSummary j = invocation.getArgument(0);
phases.add(j.getPhase());
return null;
}).when(jobDAO).updateJob(any(), any());
when(copyService.processCopyNodes(any(), any(), any())).thenReturn(List.of("source", "dest"));
jobService.setJobPhase(job, "RUN");
verify(fileServiceClient, timeout(1000).times(1)).startFileCopyJob(eq("source"), eq("dest"), any(), any());
verify(jobDAO, timeout(1000).times(3)).updateJob(any(), any());
try {
Thread.sleep(500);
} catch (InterruptedException ex) {
}
assertEquals(ExecutionPhase.EXECUTING, phases.get(0));
assertEquals(ExecutionPhase.EXECUTING, phases.get(1));
assertEquals(ExecutionPhase.EXECUTING, phases.get(2));
}
private Transfer getPullFromVoSpaceHttpTransfer() { private Transfer getPullFromVoSpaceHttpTransfer() {
Transfer transfer = new Transfer(); Transfer transfer = new Transfer();
transfer.setTarget("vos://example.com!vospace/myfile"); transfer.setTarget("vos://example.com!vospace/myfile");
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment