vid-app-common/src/test/java/org/onap/vid/job/impl/JobAdapterTest.java

   1 package org.onap.vid.job.impl;
   2
   3 import com.google.common.collect.ImmutableMap;
   4 import org.apache.commons.lang3.RandomUtils;
   5 import org.onap.vid.job.Job;
   6 import org.onap.vid.job.JobAdapter;
   7 import org.onap.vid.job.JobType;
   8 import org.onap.vid.job.command.JobCommandFactoryTest;
   9 import org.testng.annotations.Test;
  10
  11 import java.util.UUID;
  12
  13 import static org.testng.Assert.assertEquals;
  14 import static org.testng.Assert.assertNotEquals;
  15 import static org.testng.AssertJUnit.assertNotNull;
  16
  17 public class JobAdapterTest {
  18
  19     @Test
  20     public void testCreateServiceInstantiationJob() {
  21         JobAdapter jobAdapter = new JobAdapterImpl();
  22
  23         JobType jobType = JobType.NoOp;
  24         JobAdapter.AsyncJobRequest request = new JobCommandFactoryTest.MockedRequest(42,"nothing");
  25         UUID templateId = UUID.randomUUID();
  26         String userId = "ou012t";
  27         String optimisticUniqueServiceInstanceName = "optimisticUniqueServiceInstanceName";
  28         int indexInBulk = RandomUtils.nextInt();
  29         Job job = jobAdapter.createServiceInstantiationJob(
  30                 jobType,
  31                 request,
  32                 templateId,
  33                 userId,
  34                 optimisticUniqueServiceInstanceName,
  35                 indexInBulk
  36                 );
  37
  38         assertEquals(job.getType(), jobType);
  39         assertEquals(job.getSharedData().getRequest(), request);
  40         assertEquals(job.getSharedData().getRequestType(), request.getClass());
  41         assertEquals(job.getSharedData().getUserId(), userId);
  42         assertEquals(job.getSharedData().getJobUuid(), job.getUuid());
  43         assertEquals(job.getSharedData().getRootJobId(), job.getUuid());
  44         assertNotNull(job.getUuid());
  45         assertEquals(job.getTemplateId(), templateId);
  46         assertEquals(job.getData().get("optimisticUniqueServiceInstanceName"), optimisticUniqueServiceInstanceName);
  47         assertEquals((int)job.getIndexInBulk(), indexInBulk );
  48         assertEquals(job.getStatus(), Job.JobStatus.PENDING);
  49     }
  50
  51     @Test
  52     public void testCreateChildJob() {
  53
  54         JobAdapter jobAdapter = new JobAdapterImpl();
  55
  56         UUID templateId = UUID.randomUUID();
  57         String userId = "ou012t";
  58         String optimisticUniqueServiceInstanceName = "optimisticUniqueServiceInstanceName";
  59         int indexInBulk = RandomUtils.nextInt();
  60         Job grandJob = jobAdapter.createServiceInstantiationJob(
  61                 JobType.HttpCall,
  62                 new JobCommandFactoryTest.MockedRequest(99, "anything"),
  63                 templateId,
  64                 userId,
  65                 optimisticUniqueServiceInstanceName,
  66                 indexInBulk
  67         );
  68
  69         Job.JobStatus jobStatus = Job.JobStatus.PAUSE;
  70         JobType jobType = JobType.NoOp;
  71         JobAdapter.AsyncJobRequest request = new JobCommandFactoryTest.MockedRequest(42,"nothing");
  72         Job parentJob = jobAdapter.createChildJob(jobType, jobStatus, request, grandJob.getSharedData(), ImmutableMap.of());
  73
  74         assertEquals(parentJob.getType(), jobType);
  75         assertEquals(parentJob.getSharedData().getRequest(), request);
  76         assertEquals(parentJob.getSharedData().getRequestType(), request.getClass());
  77         assertEquals(parentJob.getSharedData().getUserId(), userId);
  78         assertEquals(parentJob.getSharedData().getJobUuid(), parentJob.getUuid());
  79         assertNotNull(parentJob.getUuid());
  80         assertNotEquals(parentJob.getUuid(), grandJob.getUuid());
  81         assertEquals(parentJob.getStatus(), jobStatus);
  82         assertEquals(parentJob.getSharedData().getRootJobId(), grandJob.getUuid());
  83
  84         Job.JobStatus jobStatus2 = Job.JobStatus.IN_PROGRESS;
  85         JobType jobType2 = JobType.AggregateState;
  86         JobAdapter.AsyncJobRequest request2 = new JobCommandFactoryTest.MockedRequest(66,"abc");
  87         Job job = jobAdapter.createChildJob(jobType2, jobStatus2, request2, parentJob.getSharedData(), ImmutableMap.of());
  88
  89         assertEquals(job.getType(), jobType2);
  90         assertEquals(job.getSharedData().getRequest(), request2);
  91         assertEquals(job.getSharedData().getRequestType(), request2.getClass());
  92         assertEquals(job.getSharedData().getUserId(), userId);
  93         assertEquals(job.getSharedData().getJobUuid(), job.getUuid());
  94         assertNotNull(job.getUuid());
  95         assertNotEquals(job.getUuid(), parentJob.getUuid());
  96         assertEquals(job.getStatus(), jobStatus2);
  97         assertEquals(job.getSharedData().getRootJobId(), grandJob.getUuid());
  98
  99     }
 100 }