gerrit.onap Code Review - so.git/blob

   1 /*-\r
   2  * ============LICENSE_START=======================================================\r
   3  * ONAP - SO\r
   4  * ================================================================================\r
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.\r
   6  * ================================================================================\r
   7  * Licensed under the Apache License, Version 2.0 (the "License");\r
   8  * you may not use this file except in compliance with the License.\r
   9  * You may obtain a copy of the License at\r
  10  *\r
  11  *      http://www.apache.org/licenses/LICENSE-2.0\r
  12  *\r
  13  * Unless required by applicable law or agreed to in writing, software\r
  14  * distributed under the License is distributed on an "AS IS" BASIS,\r
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
  16  * See the License for the specific language governing permissions and\r
  17  * limitations under the License.\r
  18  * ============LICENSE_END=========================================================\r
  19  */\r
  20 \r
  21 package org.openecomp.mso.bpmn.infrastructure;\r
  22 \r
  23 import static org.junit.Assert.assertEquals;\r
  24 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockDeleteServiceInstance;\r
  25 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockGetServiceInstance;\r
  26 import static org.openecomp.mso.bpmn.mock.StubResponseAAI.MockNodeQueryServiceInstanceById;\r
  27 import static org.openecomp.mso.bpmn.mock.StubResponseDatabase.mockUpdateRequestDB;\r
  28 import static org.openecomp.mso.bpmn.mock.StubResponseSDNCAdapter.mockSDNCAdapter;\r
  29 \r
  30 import java.io.IOException;\r
  31 import java.util.HashMap;\r
  32 import java.util.Map;\r
  33 import java.util.UUID;\r
  34 \r
  35 import org.camunda.bpm.engine.test.Deployment;\r
  36 import org.junit.Assert;\r
  37 import org.junit.Test;\r
  38 import org.openecomp.mso.bpmn.common.BPMNUtil;\r
  39 import org.openecomp.mso.bpmn.common.WorkflowTest;\r
  40 import org.openecomp.mso.bpmn.core.RollbackData;\r
  41 \r
  42 /**\r
  43  * Unit test cases for DoCreateServiceInstanceRollback.bpmn\r
  44  */\r
  45 public class DoCreateSIRollbackTest extends WorkflowTest {\r
  46     private static final String EOL = "\n";\r
  47     private final CallbackSet callbacks = new CallbackSet();\r
  48     private final String sdncAdapterCallback =\r
  49             "<output xmlns=\"com:att:sdnctl:l3api\">" + EOL +\r
  50                     "  <svc-request-id>((REQUEST-ID))</svc-request-id>" + EOL +\r
  51                     "  <ack-final-indicator>Y</ack-final-indicator>" + EOL +\r
  52                     "</output>" + EOL;\r
  53 \r
  54     public DoCreateSIRollbackTest() throws IOException {\r
  55         callbacks.put("deactivate", sdncAdapterCallback);\r
  56         callbacks.put("delete", sdncAdapterCallback);\r
  57     }\r
  58 \r
  59     /**\r
  60      * Sunny day VID scenario.\r
  61      *\r
  62      * @throws Exception\r
  63      */\r
  64     //@Ignore // File not found - unable to run the test.  Also, Stubs need updating..\r
  65     @Test\r
  66     @Deployment(resources = {\r
  67             "subprocess/DoCreateServiceInstanceRollback.bpmn",\r
  68             "subprocess/SDNCAdapterV1.bpmn",\r
  69             "subprocess/GenericDeleteService.bpmn",\r
  70             "subprocess/GenericGetService.bpmn",\r
  71             "subprocess/CompleteMsoProcess.bpmn",\r
  72             "subprocess/FalloutHandler.bpmn"})\r
  73     public void sunnyDay() throws Exception {\r
  74 \r
  75         logStart();\r
  76 \r
  77         //AAI\r
  78         MockDeleteServiceInstance("SDN-ETHERNET-INTERNET", "123456789", "MIS%252F1604%252F0026%252FSW_INTERNET", "");\r
  79         MockGetServiceInstance("SDN-ETHERNET-INTERNET", "123456789", "MIS%252F1604%252F0026%252FSW_INTERNET", "GenericFlows/getSINoRelations.xml");\r
  80         MockNodeQueryServiceInstanceById("MIS%252F1604%252F0026%252FSW_INTERNET", "GenericFlows/getSIUrlById.xml");\r
  81         //SDNC\r
  82         mockSDNCAdapter(200);\r
  83         //DB\r
  84         mockUpdateRequestDB(200, "DBUpdateResponse.xml");\r
  85         String businessKey = UUID.randomUUID().toString();\r
  86 \r
  87         Map<String, Object> variables = new HashMap<>();\r
  88         setupVariables(variables);\r
  89         invokeSubProcess("DoCreateServiceInstanceRollback", businessKey, variables);\r
  90         injectSDNCCallbacks(callbacks, "deactivate");\r
  91         injectSDNCCallbacks(callbacks, "delete");\r
  92         waitForProcessEnd(businessKey, 10000);\r
  93         Assert.assertTrue(isProcessEnded(businessKey));\r
  94         String workflowException = BPMNUtil.getVariable(processEngineRule, "DoCreateServiceInstanceRollback", "WorkflowException");\r
  95         System.out.println("workflowException:\n" + workflowException);\r
  96         assertEquals(null, workflowException);\r
  97 \r
  98         logEnd();\r
  99     }\r
 100 \r
 101     // Success Scenario\r
 102     private void setupVariables(Map<String, Object> variables) {\r
 103         variables.put("isDebugLogEnabled", "true");\r
 104         variables.put("msoRequestId", "RaaTestRequestId-1");\r
 105         variables.put("mso-request-id", "RaaTestRequestId-1");\r
 106         variables.put("serviceInstanceId", "MIS%252F1604%252F0026%252FSW_INTERNET");\r
 107 \r
 108         RollbackData rollbackData = new RollbackData();\r
 109 \r
 110         rollbackData.put("SERVICEINSTANCE", "serviceInstanceId", "MIS%252F1604%252F0026%252FSW_INTERNET");\r
 111         rollbackData.put("SERVICEINSTANCE", "globalCustomerId", "SDN-ETHERNET-INTERNET");\r
 112         rollbackData.put("SERVICEINSTANCE", "serviceSubscriptionType", "123456789");\r
 113         rollbackData.put("SERVICEINSTANCE", "disablerollback", "false");\r
 114         rollbackData.put("SERVICEINSTANCE", "rollbackAAI", "true");\r
 115         rollbackData.put("SERVICEINSTANCE", "rollbackSDNC", "true");\r
 116 \r
 117         String req = "<sdncadapterworkflow:SDNCAdapterWorkflowRequest xmlns:ns5=\"http://org.openecomp/mso/request/types/v1\"" + EOL +\r
 118                 "xmlns:sdncadapter=\"http://org.openecomp.mso/workflow/sdnc/adapter/schema/v1\" " + EOL +\r
 119                 "xmlns:sdncadapterworkflow=\"http://org.openecomp/mso/workflow/schema/v1\">" + EOL +\r
 120                 "<sdncadapter:RequestHeader>" + EOL +\r
 121                 "<sdncadapter:RequestId>b043d290-140d-4a38-a9b6-95d3b8bd27d4</sdncadapter:RequestId>" + EOL +\r
 122                 "<sdncadapter:SvcInstanceId>MIS%252F1604%252F0026%252FSW_INTERNET</sdncadapter:SvcInstanceId>" + EOL +\r
 123                 "<sdncadapter:SvcAction>deactivate</sdncadapter:SvcAction>" + EOL +\r
 124                 "<sdncadapter:SvcOperation>service-topology-operation</sdncadapter:SvcOperation>" + EOL +\r
 125                 "<sdncadapter:CallbackUrl>http://localhost:8080/mso/SDNCAdapterCallbackService</sdncadapter:CallbackUrl>" + EOL +\r
 126                 "</sdncadapter:RequestHeader>" + EOL +\r
 127                 "<sdncadapterworkflow:SDNCRequestData>" + EOL +\r
 128                 "<request-information>" + EOL +\r
 129                 "<request-id>RaaTestRequestId-1</request-id>" + EOL +\r
 130                 "<source>MSO</source>" + EOL +\r
 131                 "<notification-url/>" + EOL +\r
 132                 "<order-number/>" + EOL +\r
 133                 "<order-version/>" + EOL +\r
 134                 "<request-action>DeleteServiceInstance</request-action>" + EOL +\r
 135                 "</request-information>" + EOL +\r
 136                 "<service-information>" + EOL +\r
 137                 "<service-id/>" + EOL +\r
 138                 "<subscription-service-type>123456789</subscription-service-type>" + EOL +\r
 139                 "<onap-model-information>" + EOL +\r
 140                 "<model-invariant-uuid/>" + EOL +\r
 141                 "<model-uuid/>" + EOL +\r
 142                 "<model-version/>" + EOL +\r
 143                 "<model-name/>" + EOL +\r
 144                 "</onap-model-information>" + EOL +\r
 145                 "<service-instance-id>MIS%252F1604%252F0026%252FSW_INTERNET</service-instance-id>" + EOL +\r
 146                 "<subscriber-name/>" + EOL +\r
 147                 "<global-customer-id>SDN-ETHERNET-INTERNET</global-customer-id>" + EOL +\r
 148                 "</service-information>" + EOL +\r
 149                 "<service-request-input>" + EOL +\r
 150                 "<service-instance-name/>" + EOL +\r
 151                 "</service-request-input>" + EOL +\r
 152                 "</sdncadapterworkflow:SDNCRequestData>" + EOL +\r
 153                 "</sdncadapterworkflow:SDNCAdapterWorkflowRequest>";\r
 154 \r
 155         String req1 = "<sdncadapterworkflow:SDNCAdapterWorkflowRequest xmlns:ns5=\"http://org.openecomp/mso/request/types/v1\"" + EOL +\r
 156                 "xmlns:sdncadapter=\"http://org.openecomp.mso/workflow/sdnc/adapter/schema/v1\" " + EOL +\r
 157                 "xmlns:sdncadapterworkflow=\"http://org.openecomp/mso/workflow/schema/v1\">" + EOL +\r
 158                 "<sdncadapter:RequestHeader>" + EOL +\r
 159                 "<sdncadapter:RequestId>bca4fede-0804-4c13-af69-9e80b378150f</sdncadapter:RequestId>" + EOL +\r
 160                 "<sdncadapter:SvcInstanceId>MIS%252F1604%252F0026%252FSW_INTERNET</sdncadapter:SvcInstanceId>" + EOL +\r
 161                 "<sdncadapter:SvcAction>delete</sdncadapter:SvcAction>" + EOL +\r
 162                 "<sdncadapter:SvcOperation>service-topology-operation</sdncadapter:SvcOperation>" + EOL +\r
 163                 "<sdncadapter:CallbackUrl>http://localhost:8080/mso/SDNCAdapterCallbackService</sdncadapter:CallbackUrl>" + EOL +\r
 164                 "</sdncadapter:RequestHeader>" + EOL +\r
 165                 "<sdncadapterworkflow:SDNCRequestData>" + EOL +\r
 166                 "<request-information>" + EOL +\r
 167                 "<request-id>RaaTestRequestId-1</request-id>" + EOL +\r
 168                 "<source>MSO</source>" + EOL +\r
 169                 "<notification-url/>" + EOL +\r
 170                 "<order-number/>" + EOL +\r
 171                 "<order-version/>" + EOL +\r
 172                 "<request-action>DeleteServiceInstance</request-action>" + EOL +\r
 173                 "</request-information>" + EOL +\r
 174                 "<service-information>" + EOL +\r
 175                 "<service-id/>" + EOL +\r
 176                 "<subscription-service-type>123456789</subscription-service-type>" + EOL +\r
 177                 "<onap-model-information>" + EOL +\r
 178                 "<model-invariant-uuid/>" + EOL +\r
 179                 "<model-uuid/>" + EOL +\r
 180                 "<model-version/>" + EOL +\r
 181                 "<model-name/>" + EOL +\r
 182                 "</onap-model-information>" + EOL +\r
 183                 "<service-instance-id>MIS%252F1604%252F0026%252FSW_INTERNET</service-instance-id>" + EOL +\r
 184                 "<subscriber-name/>" + EOL +\r
 185                 "<global-customer-id>SDN-ETHERNET-INTERNET</global-customer-id>" + EOL +\r
 186                 "</service-information>" + EOL +\r
 187                 "<service-request-input>" + EOL +\r
 188                 "<service-instance-name/>" + EOL +\r
 189                 "</service-request-input>" + EOL +\r
 190                 "</sdncadapterworkflow:SDNCRequestData>" + EOL +\r
 191                 "</sdncadapterworkflow:SDNCAdapterWorkflowRequest>";\r
 192 \r
 193         rollbackData.put("SERVICEINSTANCE", "sdncDeactivate", req);\r
 194 \r
 195         rollbackData.put("SERVICEINSTANCE", "sdncDelete", req1);\r
 196         variables.put("rollbackData", rollbackData);\r
 197 \r
 198     }\r
 199 }\r