2 * © 2014 AT&T Intellectual Property. All rights reserved. Used under license from AT&T Intellectual Property.
5 * ============LICENSE_START=======================================================
7 * ================================================================================
8 * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
9 * ================================================================================
10 * Licensed under the Apache License, Version 2.0 (the "License");
11 * you may not use this file except in compliance with the License.
12 * You may obtain a copy of the License at
14 * http://www.apache.org/licenses/LICENSE-2.0
16 * Unless required by applicable law or agreed to in writing, software
17 * distributed under the License is distributed on an "AS IS" BASIS,
18 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
19 * See the License for the specific language governing permissions and
20 * limitations under the License.
21 * ============LICENSE_END=========================================================
24 package org.openecomp.mso.bpmn.infrastructure;
26 import static com.github.tomakehurst.wiremock.client.WireMock.aResponse;
27 import static com.github.tomakehurst.wiremock.client.WireMock.get;
28 import static com.github.tomakehurst.wiremock.client.WireMock.stubFor;
29 import static com.github.tomakehurst.wiremock.client.WireMock.urlMatching;
30 import static org.junit.Assert.assertEquals;
31 import static org.openecomp.mso.bpmn.common.BPMNUtil.executeWorkFlow;
32 import static org.openecomp.mso.bpmn.common.BPMNUtil.waitForWorkflowToFinish;
33 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockGetGenericVnfByName_404;
34 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockGetServiceInstance;
35 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockNodeQueryServiceInstanceById;
36 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockNodeQueryServiceInstanceById_404;
37 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockPutGenericVnf;
38 import static org.openecomp.mso.bpmn.mock.StubResponseDatabase.mockUpdateRequestDB;
39 import static org.openecomp.mso.bpmn.mock.StubResponseSDNCAdapter.mockSDNCAdapter;
41 import java.io.IOException;
42 import java.util.HashMap;
44 import java.util.UUID;
46 import org.camunda.bpm.engine.test.Deployment;
47 import org.junit.Test;
48 import org.openecomp.mso.bpmn.common.BPMNUtil;
49 import org.openecomp.mso.bpmn.common.WorkflowTest;
50 import org.openecomp.mso.bpmn.common.workflow.service.WorkflowResponse;
51 import org.openecomp.mso.bpmn.mock.FileUtil;
54 * Unit Test for the CreateVnfInfra Flow
56 public class CreateVnfInfraTest extends WorkflowTest {
58 private String createVnfInfraRequest;
59 private final CallbackSet callbacks = new CallbackSet();
62 public CreateVnfInfraTest() throws IOException {
63 createVnfInfraRequest = FileUtil.readResourceFile("__files/InfrastructureFlows/CreateVnfInfraRequest.json");
64 callbacks.put("assign", FileUtil.readResourceFile(
65 "__files/VfModularity/SDNCTopologyAssignCallback.xml"));
66 callbacks.put("activate", FileUtil.readResourceFile(
67 "__files/VfModularity/SDNCTopologyActivateCallback.xml"));
71 @Deployment(resources = {"subprocess/DoCreateVnf.bpmn",
72 "subprocess/GenericGetService.bpmn",
73 "subprocess/GenericGetVnf.bpmn",
74 "subprocess/GenericPutVnf.bpmn",
75 "subprocess/SDNCAdapterV1.bpmn",
76 "process/CreateVnfInfra.bpmn",
77 "subprocess/FalloutHandler.bpmn",
78 "subprocess/CompleteMsoProcess.bpmn"})
79 public void testCreateVnfInfra_success() throws Exception{
81 MockNodeQueryServiceInstanceById("MIS%2F1604%2F0026%2FSW_INTERNET", "GenericFlows/getSIUrlById.xml");
82 MockGetServiceInstance("SDN-ETHERNET-INTERNET", "123456789", "MIS%252F1604%252F0026%252FSW_INTERNET", "GenericFlows/getServiceInstance.xml");
83 MockGetGenericVnfByName_404();
85 mockSDNCAdapter("/SDNCAdapter", "vnf-type>STMTN", 200, "VfModularity/StandardSDNCSynchResponse.xml");
86 mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");
88 String businessKey = UUID.randomUUID().toString();
89 Map<String, Object> variables = new HashMap<String, Object>();
90 setVariablesSuccess(variables, createVnfInfraRequest, "testRequestId123", "MIS%2F1604%2F0026%2FSW_INTERNET");
91 TestAsyncResponse asyncResponse = invokeAsyncProcess("CreateVnfInfra",
92 "v1", businessKey, createVnfInfraRequest, variables);
94 WorkflowResponse response = receiveResponse(businessKey, asyncResponse, 10000);
96 String responseBody = response.getResponse();
97 System.out.println("Workflow (Synch) Response:\n" + responseBody);
99 //injectSDNCCallbacks(callbacks, "assign, query");
100 //injectSDNCCallbacks(callbacks, "activate");
102 // TODO add appropriate assertions
104 waitForProcessEnd(businessKey, 10000);
105 String status = BPMNUtil.getVariable(processEngineRule, "CreateVnfInfra", "CreateVnfInfraStatus");
106 assertEquals("Success", status);
110 //WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "CreateVnfInfra", variables);
111 // injectSDNCCallbacks(callbacks, "assign");
112 // injectSDNCCallbacks(callbacks, "activate");
113 //waitForProcessEnd(businessKey, 10000);
114 //waitForWorkflowToFinish(processEngineRule, workflowResponse.getProcessInstanceID());
116 //assertVariables("true", "true", "false", "true", "Success", null);
121 @Deployment(resources = {"subprocess/GenericGetService.bpmn", "subprocess/GenericGetVnf.bpmn", "subprocess/GenericPutVnf.bpmn", "process/CreateVnfInfra.bpmn", "subprocess/FalloutHandler.bpmn", "subprocess/CompleteMsoProcess.bpmn"})
122 public void testCreateVnfInfra_error_badRequest() throws Exception{
124 mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");
126 Map<String, String> variables = new HashMap<String, String>();
127 setVariables(variables, null, "testRequestId123", "MIS%2F1604%2F0026%2FSW_INTERNET");
129 WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "CreateVnfInfra", variables);
130 waitForWorkflowToFinish(processEngineRule, workflowResponse.getProcessInstanceID());
132 assertVariables(null, null, null, null, null, "WorkflowException[processKey=CreateVnfInfra,errorCode=2500,errorMessage=Internal Error - WorkflowException Object and/or RequestInfo is null! CreateVnfInfra]");
137 @Deployment(resources = {"subprocess/DoCreateVnf.bpmn", "subprocess/GenericGetService.bpmn", "subprocess/GenericGetVnf.bpmn", "subprocess/GenericPutVnf.bpmn", "process/CreateVnfInfra.bpmn", "subprocess/FalloutHandler.bpmn", "subprocess/CompleteMsoProcess.bpmn"})
138 public void testCreateVnfInfra_error_siNotFound() throws Exception{
140 MockNodeQueryServiceInstanceById_404("MIS%2F1604%2F0026%2FSW_INTERNET");
141 mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");
143 Map<String, String> variables = new HashMap<String, String>();
144 setVariables(variables, createVnfInfraRequest, "testRequestId123", "MIS%2F1604%2F0026%2FSW_INTERNET");
146 WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "CreateVnfInfra", variables);
147 waitForWorkflowToFinish(processEngineRule, workflowResponse.getProcessInstanceID());
149 assertVariables(null, null, null, null, null, "WorkflowException[processKey=DoCreateVnf,errorCode=404,errorMessage=Service Instance Not Found]");
154 @Deployment(resources = {"subprocess/DoCreateVnf.bpmn",
155 "subprocess/GenericGetService.bpmn",
156 "subprocess/GenericGetVnf.bpmn",
157 "subprocess/GenericPutVnf.bpmn",
158 "process/CreateVnfInfra.bpmn",
159 "subprocess/FalloutHandler.bpmn",
160 "subprocess/CompleteMsoProcess.bpmn"})
161 public void testCreateVnfInfra_error_vnfExist() throws Exception{
162 MockNodeQueryServiceInstanceById("MIS%2F1604%2F0026%2FSW_INTERNET", "GenericFlows/getSIUrlById.xml");
163 MockGetServiceInstance("SDN-ETHERNET-INTERNET", "123456789", "MIS%252F1604%252F0026%252FSW_INTERNET", "GenericFlows/getServiceInstance.xml");
165 stubFor(get(urlMatching("/aai/v[0-9]+/network/generic-vnfs/generic-vnf[?]vnf-name=testVnfName123&depth=1"))
166 .willReturn(aResponse()
168 .withHeader("Content-Type", "text/xml")
169 .withBodyFile("GenericFlows/getGenericVnfResponse.xml")));
172 mockUpdateRequestDB(200, "Database/DBUpdateResponse.xml");
174 Map<String, String> variables = new HashMap<String, String>();
175 setVariables(variables, createVnfInfraRequest, "testRequestId123", "MIS%2F1604%2F0026%2FSW_INTERNET");
177 WorkflowResponse workflowResponse = executeWorkFlow(processEngineRule, "CreateVnfInfra", variables);
178 waitForWorkflowToFinish(processEngineRule, workflowResponse.getProcessInstanceID());
180 assertVariables(null, null, null, null, null, "WorkflowException[processKey=DoCreateVnf,errorCode=5000,errorMessage=Generic Vnf Already Exist.]");
184 private void assertVariables(String exSIFound, String exSISucc, String exVnfFound, String exVnfSucc, String exResponse, String exWorkflowException) {
186 String siFound = BPMNUtil.getVariable(processEngineRule, "CreateVnfInfra", "GENGS_FoundIndicator");
187 String siSucc = BPMNUtil.getVariable(processEngineRule, "CreateVnfInfra", "GENGS_SuccessIndicator");
188 String vnfFound = BPMNUtil.getVariable(processEngineRule, "CreateVnfInfra", "GENGV_FoundIndicator");
189 String vnfSucc = BPMNUtil.getVariable(processEngineRule, "CreateVnfInfra", "GENGV_SuccessIndicator");
190 String response = BPMNUtil.getVariable(processEngineRule, "CreateVnfInfra", "WorkflowResponse");
191 String workflowException = BPMNUtil.getVariable(processEngineRule, "CreateVnfInfra", "SavedWorkflowException1");
193 assertEquals(exSIFound, siFound);
194 assertEquals(exSISucc, siSucc);
195 assertEquals(exVnfFound, vnfFound);
196 assertEquals(exVnfSucc, vnfSucc);
197 assertEquals(exResponse, response);
198 assertEquals(exWorkflowException, workflowException);
201 private void setVariables(Map<String, String> variables, String request, String requestId, String siId) {
202 variables.put("isDebugLogEnabled", "true");
203 variables.put("bpmnRequest", request);
204 variables.put("mso-request-id", requestId);
205 variables.put("serviceInstanceId",siId);
206 variables.put("testVnfId","testVnfId123");
207 variables.put("vnfType", "STMTN");
210 private void setVariablesSuccess(Map<String, Object> variables, String request, String requestId, String siId) {
211 variables.put("isDebugLogEnabled", "true");
212 //variables.put("bpmnRequest", request);
213 //variables.put("mso-request-id", requestId);
214 variables.put("serviceInstanceId",siId);
215 variables.put("requestId", requestId);
216 variables.put("testVnfId","testVnfId123");
217 variables.put("vnfType", "STMTN");