gerrit.onap Code Review - so.git/blob

   1 package org.onap.so.bpmn.common.workflow.service;
   2
   3 import static org.junit.Assert.assertEquals;
   4 import static org.mockito.Mockito.doReturn;
   5 import static org.mockito.ArgumentMatchers.anyMap;
   6 import java.util.HashMap;
   7 import java.util.Map;
   8 import javax.ws.rs.core.Response;
   9 import org.camunda.bpm.engine.variable.impl.VariableMapImpl;
  10 import org.junit.Before;
  11 import org.junit.Test;
  12 import org.junit.runner.RunWith;
  13 import org.mockito.InjectMocks;
  14 import org.mockito.Mock;
  15 import org.mockito.Spy;
  16 import org.mockito.junit.MockitoJUnitRunner;
  17 import org.onap.so.bpmn.common.workflow.context.WorkflowResponse;
  18
  19 @RunWith(MockitoJUnitRunner.class)
  20 public class WorkflowAsyncResourceTest {
  21
  22     @InjectMocks
  23     @Spy
  24     private WorkflowAsyncResource workflowAsyncResource;
  25
  26     @Mock
  27     private WorkflowProcessor processor;
  28
  29     private WorkflowResponse workflowResponse;
  30     private VariableMapImpl varMap;
  31
  32     @Before
  33     public void before() {
  34         workflowResponse = new WorkflowResponse();
  35         varMap = new VariableMapImpl();
  36         Map<String, Object> variables = new HashMap<String, Object>();
  37         Map<String, Object> requestIdMap = new HashMap<String, Object>();
  38         requestIdMap.put("value", "123");
  39         requestIdMap.put("type", "String");
  40         variables.put("mso-request-id", requestIdMap);
  41         varMap.put("variables", variables);
  42     }
  43
  44     @Test
  45     public void startProcessInstanceByKey200Test() throws Exception {
  46         workflowResponse.setMessageCode(200);
  47         doReturn(workflowResponse).when(workflowAsyncResource).waitForResponse(anyMap());
  48         Response response = workflowAsyncResource.startProcessInstanceByKey("123", varMap);
  49         assertEquals(202, response.getStatus());
  50     }
  51
  52     @Test
  53     public void startProcessInstanceByKey500Test() throws Exception {
  54         workflowResponse.setMessageCode(500);
  55         doReturn(workflowResponse).when(workflowAsyncResource).waitForResponse(anyMap());
  56         Response response = workflowAsyncResource.startProcessInstanceByKey("123", varMap);
  57         assertEquals(500, response.getStatus());
  58     }
  59 }