/*-
* ============LICENSE_START=======================================================
* ONAP - SO
* ================================================================================
* Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
*/
package org.openecomp.mso.bpmn.common;
import static org.junit.Assert.assertEquals;
import static org.mockito.Mockito.mock;
import java.util.HashMap;
import java.util.Map;
import java.util.UUID;
import org.camunda.bpm.engine.test.Deployment;
import org.camunda.bpm.engine.variable.impl.VariableMapImpl;
import org.jboss.resteasy.spi.AsynchronousResponse;
import org.junit.Test;
import org.openecomp.mso.bpmn.common.workflow.service.WorkflowAsyncCommonResource;
import org.openecomp.mso.bpmn.common.workflow.service.WorkflowResponse;
public class WorkflowAsyncResourceTest extends WorkflowTest {
@Test
@Deployment(resources = { "testAsyncResource.bpmn" })
public void asyncRequestSuccess() throws InterruptedException {
//it can be any request which asynchronously processed by the workflow
String request = " SDN-ETHERNET-INTERNET HI/VLXM/950604//SW_INTERNET SubName01 ";
Map variables = new HashMap();
variables.put("testAsyncRequestMsg", request);
variables.put("mso-request-id", UUID.randomUUID().toString());
variables.put("mso-service-request-timeout", "5");
WorkflowResponse workflowResponse = BPMNUtil.executeAsyncWorkflow(processEngineRule, "testAsyncProcess", variables);
assertEquals("Received the request, the process is getting executed, request message SDN-ETHERNET-INTERNET HI/VLXM/950604//SW_INTERNET SubName01 ", workflowResponse.getResponse());
assertEquals(200, workflowResponse.getMessageCode());
}
private void executeWorkflow(String request, String requestId, AsynchronousResponse asyncResponse, String processKey) {
WorkflowAsyncCommonResource workflowResource = new WorkflowAsyncCommonResource();
VariableMapImpl variableMap = new VariableMapImpl();
Map variableValueType = new HashMap();
Map requestMsg = new HashMap();
requestMsg.put("value", request);
requestMsg.put("type", "String");
Map msorequestId = new HashMap();
msorequestId.put("type", "String");
msorequestId.put("value",requestId);
Map timeout = new HashMap();
timeout.put("type", "String");
timeout.put("value","5");
variableValueType.put("testAsyncRequestMsg", requestMsg);
variableValueType.put("mso-request-id", msorequestId);
variableValueType.put("mso-service-request-timeout", timeout);
variableMap.put("variables", variableValueType);
workflowResource.setProcessEngineServices4junit(processEngineRule);
workflowResource.startProcessInstanceByKey(asyncResponse, processKey, variableMap);
}
class ProcessThread extends Thread {
public WorkflowResponse workflowResponse;
public String requestId;
public String processKey;
public AsynchronousResponse asyncResponse = mock(AsynchronousResponse.class);
public String request;
public boolean started;
public void run() {
started = true;
executeWorkflow(request, requestId, asyncResponse, processKey);
}
}
}