-package org.openecomp.mso.bpmn.infrastructure.scripts\r
-\r
-import static org.mockito.Mockito.*\r
-\r
-import org.camunda.bpm.engine.delegate.BpmnError\r
-import org.camunda.bpm.engine.ProcessEngineServices\r
-import org.camunda.bpm.engine.RepositoryService\r
-import org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity\r
-import org.camunda.bpm.engine.impl.pvm.process.ProcessDefinitionImpl\r
-import org.camunda.bpm.engine.repository.ProcessDefinition\r
-import org.camunda.bpm.engine.runtime.Execution;\r
-import org.mockito.MockitoAnnotations\r
-import org.mockito.runners.MockitoJUnitRunner\r
-import org.mockito.internal.debugging.MockitoDebuggerImpl\r
-import org.openecomp.mso.bpmn.common.scripts.MsoUtils\r
-import org.openecomp.mso.bpmn.core.WorkflowException\r
-import org.junit.Before\r
-import org.junit.Rule;\r
-import org.junit.Test\r
-import org.junit.Ignore\r
-import org.junit.runner.RunWith\r
-\r
-import static org.junit.Assert.*;\r
-\r
-import com.github.tomakehurst.wiremock.client.WireMock;\r
-import com.github.tomakehurst.wiremock.junit.WireMockRule;\r
-\r
-import java.util.HashMap;\r
-import java.util.Map;\r
-import java.util.UUID;\r
-\r
-import org.apache.commons.lang3.*\r
-\r
-\r
-@RunWith(MockitoJUnitRunner.class)\r
-class DoDeleteNetworkInstanceRollbackTest {\r
- \r
- @Rule\r
- public WireMockRule wireMockRule = new WireMockRule(8090);\r
- \r
- def utils = new MsoUtils()\r
- String Prefix="DELNWKIR_"\r
-\r
-\r
- String rollbackNetworkRequest =\r
- """<NetworkAdapter:rollbackNetwork xmlns:NetworkAdapter="http://org.openecomp.mso/network">\r
- <rollback>\r
- <networkId>MNS-25180-L-01-dmz_direct_net_1/2c88a3a9-69b9-43a7-ada6-1aca577c3641</networkId>\r
- <neutronNetworkId>c4f4e878-cde0-4b15-ae9a-bda857759cea</neutronNetworkId>\r
- <networkStackId/>\r
- <networkType>CONTRAIL_EXTERNAL</networkType>\r
- <networkCreated>true</networkCreated>\r
- <tenantId>7dd5365547234ee8937416c65507d266</tenantId>\r
- <cloudSiteId>RDM2WAGPLCP</cloudSiteId>\r
- <msoRequest>\r
- <requestId>1ef47428-cade-45bd-a103-0751e8b2deb0</requestId>\r
- <serviceInstanceId/>\r
- </msoRequest>\r
- </rollback>\r
-</NetworkAdapter:rollbackNetwork>""" \r
- \r
- String rollbackDeActivateSDNCRequest =\r
- """<aetgt:SDNCAdapterWorkflowRequest xmlns:aetgt="http://org.openecomp/mso/workflow/schema/v1"\r
- xmlns:ns5="http://org.openecomp/mso/request/types/v1"\r
- xmlns:sdncadapter="http://org.openecomp.mso/workflow/sdnc/adapter/schema/v1">\r
- <sdncadapter:RequestHeader>\r
- <sdncadapter:RequestId>88f65519-9a38-4c4b-8445-9eb4a5a5af56</sdncadapter:RequestId>\r
- <sdncadapter:SvcInstanceId>f70e927b-6087-4974-9ef8-c5e4d5847ca4</sdncadapter:SvcInstanceId>\r
- <sdncadapter:SvcAction>activate</sdncadapter:SvcAction>\r
- <sdncadapter:SvcOperation>network-topology-operation</sdncadapter:SvcOperation>\r
- <sdncadapter:CallbackUrl>sdncCallback</sdncadapter:CallbackUrl>\r
- <sdncadapter:MsoAction>generic-resource</sdncadapter:MsoAction>\r
- </sdncadapter:RequestHeader>\r
- <aetgt:SDNCRequestData>\r
- <request-information>\r
- <request-id>88f65519-9a38-4c4b-8445-9eb4a5a5af56</request-id>\r
- <request-action>CreateNetworkInstance</request-action>\r
- <source>VID</source>\r
- <notification-url/>\r
- <order-number/>\r
- <order-version/>\r
- </request-information>\r
- <service-information>\r
- <service-id>a9a77d5a-123e-4ca2-9eb9-0b015d2ee0fb</service-id>\r
- <service-type>MSO-dev-service-type</service-type>\r
- <service-instance-id>f70e927b-6087-4974-9ef8-c5e4d5847ca4</service-instance-id>\r
- <subscriber-name>MSO_1610_dev</subscriber-name>\r
- </service-information>\r
- <network-information>\r
- <network-id>8abc633a-810b-4ca5-8b3a-09511d13a2ce</network-id>\r
- <network-type>CONTRAIL_EXTERNAL</network-type>\r
- <onap-model-information>\r
- <model-invariant-uuid>invariant-uuid</model-invariant-uuid>\r
- <model-customization-uuid>customization-uuid</model-customization-uuid>\r
- <model-uuid>uuid</model-uuid>\r
- <model-version>version</model-version>\r
- <model-name>CONTRAIL_EXTERNAL</model-name>\r
- </onap-model-information>\r
- </network-information>\r
- <network-request-information>\r
- <network-id>8abc633a-810b-4ca5-8b3a-09511d13a2ce</network-id>\r
- <network-type>CONTRAIL_EXTERNAL</network-type>\r
- <network-name>MNS-25180-L-01-dmz_direct_net_1</network-name>\r
- <tenant>7dd5365547234ee8937416c65507d266</tenant>\r
- <aic-cloud-region>RDM2WAGPLCP</aic-cloud-region>\r
- </network-request-information>\r
- </aetgt:SDNCRequestData>\r
-</aetgt:SDNCAdapterWorkflowRequest>""" \r
- \r
- String rollbackSDNCRequest =\r
- """<aetgt:SDNCAdapterWorkflowRequest xmlns:aetgt="http://org.openecomp/mso/workflow/schema/v1"\r
- xmlns:ns5="http://org.openecomp/mso/request/types/v1"\r
- xmlns:sdncadapter="http://org.openecomp.mso/workflow/sdnc/adapter/schema/v1">\r
- <sdncadapter:RequestHeader>\r
- <sdncadapter:RequestId>88f65519-9a38-4c4b-8445-9eb4a5a5af56</sdncadapter:RequestId>\r
- <sdncadapter:SvcInstanceId>f70e927b-6087-4974-9ef8-c5e4d5847ca4</sdncadapter:SvcInstanceId>\r
- <sdncadapter:SvcAction>rollback</sdncadapter:SvcAction>\r
- <sdncadapter:SvcOperation>network-topology-operation</sdncadapter:SvcOperation>\r
- <sdncadapter:CallbackUrl>sdncCallback</sdncadapter:CallbackUrl>\r
- </sdncadapter:RequestHeader>\r
- <aetgt:SDNCRequestData>\r
- <request-information>\r
- <request-id>88f65519-9a38-4c4b-8445-9eb4a5a5af56</request-id>\r
- <request-action>CreateNetworkInstance</request-action>\r
- <source>VID</source>\r
- <notification-url/>\r
- <order-number/>\r
- <order-version/>\r
- </request-information>\r
- <service-information>\r
- <service-id>a9a77d5a-123e-4ca2-9eb9-0b015d2ee0fb</service-id>\r
- <service-type>MSO-dev-service-type</service-type>\r
- <service-instance-id>f70e927b-6087-4974-9ef8-c5e4d5847ca4</service-instance-id>\r
- <subscriber-name>MSO_1610_dev</subscriber-name>\r
- </service-information>\r
- <network-information>\r
- <network-id>8abc633a-810b-4ca5-8b3a-09511d13a2ce</network-id>\r
- <network-type>CONTRAIL_EXTERNAL</network-type>\r
- <onap-model-information>\r
- <model-invariant-uuid>invariant-uuid</model-invariant-uuid>\r
- <model-customization-uuid>customization-uuid</model-customization-uuid>\r
- <model-uuid>uuid</model-uuid>\r
- <model-version>version</model-version>\r
- <model-name>CONTRAIL_EXTERNAL</model-name>\r
- </onap-model-information>\r
- </network-information>\r
- <network-request-information>\r
- <network-id>8abc633a-810b-4ca5-8b3a-09511d13a2ce</network-id>\r
- <network-type>CONTRAIL_EXTERNAL</network-type>\r
- <network-name>MNS-25180-L-01-dmz_direct_net_1</network-name>\r
- <tenant>7dd5365547234ee8937416c65507d266</tenant>\r
- <aic-cloud-region>RDM2WAGPLCP</aic-cloud-region>\r
- </network-request-information>\r
- </aetgt:SDNCRequestData>\r
-</aetgt:SDNCAdapterWorkflowRequest>""" \r
- \r
-// - - - - - - - -\r
-\r
-\r
- @Before\r
- public void init()\r
- {\r
- MockitoAnnotations.initMocks(this)\r
- \r
- }\r
- \r
- public void initializeVariables (Execution mockExecution) {\r
-\r
- verify(mockExecution).setVariable(Prefix + "WorkflowException", null)\r
- \r
- verify(mockExecution).setVariable(Prefix + "rollbackDeactivateSDNCRequest", null)\r
- verify(mockExecution).setVariable(Prefix + "rollbackDeactivateSDNCResponse", "")\r
- verify(mockExecution).setVariable(Prefix + "rollbackDeactivateSDNCReturnCode", "")\r
- \r
- verify(mockExecution).setVariable(Prefix + "rollbackNetworkRequest", null)\r
- verify(mockExecution).setVariable(Prefix + "rollbackNetworkResponse", "")\r
- verify(mockExecution).setVariable(Prefix + "rollbackNetworkReturnCode", "")\r
- \r
- verify(mockExecution).setVariable(Prefix + "Success", false)\r
- verify(mockExecution).setVariable(Prefix + "fullRollback", false)\r
- \r
- }\r
- \r
- @Test\r
- //@Ignore \r
- public void preProcessRequest() {\r
- \r
- println "************ preProcessRequest ************* " \r
- \r
- WorkflowException workflowException = new WorkflowException("DoCreateNetworkInstance", 2500, "Received error from Network Adapter: JBWEB000065: HTTP Status 500.")\r
- Map<String, String> rollbackData = new HashMap<String, String>();\r
- rollbackData.put("rollbackDeactivateSDNCRequest", rollbackDeActivateSDNCRequest)\r
- rollbackData.put("rollbackNetworkRequest", rollbackNetworkRequest)\r
- rollbackData.put("rollbackSDNCRequest", rollbackSDNCRequest)\r
- \r
- ExecutionEntity mockExecution = setupMock()\r
- // Initialize prerequisite variables\r
- when(mockExecution.getVariable("isDebugLogEnabled")).thenReturn("true")\r
- when(mockExecution.getVariable("prefix")).thenReturn(Prefix + "")\r
- when(mockExecution.getVariable("WorkflowException")).thenReturn(workflowException)\r
- when(mockExecution.getVariable("rollbackData")).thenReturn(rollbackData)\r
- when(mockExecution.getVariable("sdncVersion")).thenReturn("1702")\r
- \r
- when(mockExecution.getVariable("URN_mso_adapters_po_auth")).thenReturn("3141634BF7E070AA289CF2892C986C0B")\r
- when(mockExecution.getVariable("URN_mso_msoKey")).thenReturn("07a7159d3bf51a0e53be7a8f89699be7")\r
- \r
- when(mockExecution.getVariable("URN_mso_adapters_sdnc_endpoint")).thenReturn("http://localhost:8090/SDNCAdapter")\r
- when(mockExecution.getVariable("URN_mso_adapters_network_rest_endpoint")).thenReturn("http://localhost:8090/networks/NetworkAdapter")\r
- when(mockExecution.getVariable("URN_mso_adapters_sdnc_resource_endpoint")).thenReturn("http://localhost:8090/SDNCAdapterRpc")\r
- \r
- \r
- // preProcessRequest(Execution execution) \r
- DoDeleteNetworkInstanceRollback DoDeleteNetworkInstanceRollback = new DoDeleteNetworkInstanceRollback()\r
- DoDeleteNetworkInstanceRollback.preProcessRequest(mockExecution)\r
-\r
- //verify variable initialization\r
- initializeVariables(mockExecution)\r
- \r
- verify(mockExecution).getVariable("isDebugLogEnabled")\r
- verify(mockExecution).setVariable("prefix", Prefix)\r
- \r
- }\r
- \r
-\r
- @Test\r
- //@Ignore\r
- public void validateRollbackResponses_Good() {\r
- \r
- WorkflowException workflowException = new WorkflowException("DoDeleteNetworkInstanceRollback", 2500, "AAI Update Contrail Failed. Error 404.")\r
- WorkflowException expectedWorkflowException = new WorkflowException("DoDeleteNetworkInstanceRollback", 2500, "AAI Update Contrail Failed. Error 404. + SNDC deactivate rollback completed. + PO Network rollback completed. + SNDC unassign rollback completed.")\r
- \r
- println "************ validateRollbackResponses_Good() ************* "\r
- ExecutionEntity mockExecution = setupMock()\r
- // Initialize prerequisite variables\r
- when(mockExecution.getVariable("isDebugLogEnabled")).thenReturn("true")\r
- when(mockExecution.getVariable("prefix")).thenReturn(Prefix + "")\r
-\r
- when(mockExecution.getVariable(Prefix + "rollbackDeactivateSDNCRequest")).thenReturn("Good")\r
- when(mockExecution.getVariable(Prefix + "rollbackDeactivateSDNCReturnCode")).thenReturn("200")\r
- when(mockExecution.getVariable(Prefix + "rollbackDeactivateSDNCResponse")).thenReturn("GoodResponse")\r
- when(mockExecution.getVariable(Prefix + "rollbackNetworkRequest")).thenReturn("Good")\r
- when(mockExecution.getVariable(Prefix + "rollbackNetworkReturnCode")).thenReturn("200")\r
- when(mockExecution.getVariable(Prefix + "rollbackNetworkResponse")).thenReturn("GoodResponse")\r
- when(mockExecution.getVariable(Prefix + "rollbackSDNCRequest")).thenReturn("Good")\r
- when(mockExecution.getVariable(Prefix + "rollbackSDNCReturnCode")).thenReturn("200")\r
- when(mockExecution.getVariable(Prefix + "rollbackSDNCResponse")).thenReturn("GoodResponse")\r
- when(mockExecution.getVariable(Prefix + "WorkflowException")).thenReturn(workflowException)\r
- when(mockExecution.getVariable(Prefix + "fullRollback")).thenReturn(false)\r
- \r
- DoDeleteNetworkInstanceRollback DoDeleteNetworkInstanceRollback = new DoDeleteNetworkInstanceRollback()\r
- DoDeleteNetworkInstanceRollback.validateRollbackResponses(mockExecution)\r
- \r
- // verify set prefix = Prefix + ""\r
- verify(mockExecution, atLeast(1)).setVariable("prefix", Prefix)\r
- verify(mockExecution, atLeast(1)).setVariable("rolledBack", true)\r
- verify(mockExecution, atLeast(1)).setVariable("wasDeleted", true)\r
- verify(mockExecution).setVariable("WorkflowException", refEq(expectedWorkflowException, any(WorkflowException.class)))\r
- //verify(mockExecution).setVariable("WorkflowException", expectedWorkflowException)\r
- }\r
- \r
- @Test\r
- //@Ignore\r
- public void validateRollbackResponses_FullRollback() {\r
- \r
- Map<String, String> rollbackData = new HashMap<String, String>();\r
- rollbackData.put("rollbackDeactivateSDNCRequest", rollbackDeActivateSDNCRequest)\r
- rollbackData.put("rollbackNetworkRequest", rollbackNetworkRequest)\r
- rollbackData.put("rollbackSDNCRequest", rollbackSDNCRequest)\r
- \r
- println "************ validateRollbackResponses_FullRollback() ************* "\r
- ExecutionEntity mockExecution = setupMock()\r
- // Initialize prerequisite variables\r
- when(mockExecution.getVariable("isDebugLogEnabled")).thenReturn("true")\r
- when(mockExecution.getVariable("prefix")).thenReturn(Prefix + "")\r
-\r
- when(mockExecution.getVariable(Prefix + "rollbackDeactivateSDNCRequest")).thenReturn("Good")\r
- when(mockExecution.getVariable(Prefix + "rollbackDeactivateSDNCReturnCode")).thenReturn("200")\r
- when(mockExecution.getVariable(Prefix + "rollbackDeactivateSDNCResponse")).thenReturn("GoodResponse")\r
- when(mockExecution.getVariable(Prefix + "rollbackNetworkRequest")).thenReturn("Good")\r
- when(mockExecution.getVariable(Prefix + "rollbackNetworkReturnCode")).thenReturn("200")\r
- when(mockExecution.getVariable(Prefix + "rollbackNetworkResponse")).thenReturn("GoodResponse")\r
- when(mockExecution.getVariable(Prefix + "rollbackSDNCRequest")).thenReturn("Good")\r
- when(mockExecution.getVariable(Prefix + "rollbackSDNCReturnCode")).thenReturn("200")\r
- when(mockExecution.getVariable(Prefix + "rollbackSDNCResponse")).thenReturn("GoodResponse")\r
- when(mockExecution.getVariable(Prefix + "WorkflowException")).thenReturn(null)\r
- when(mockExecution.getVariable(Prefix + "fullRollback")).thenReturn(true)\r
- when(mockExecution.getVariable("rollbackData")).thenReturn(rollbackData)\r
- \r
- DoDeleteNetworkInstanceRollback DoDeleteNetworkInstanceRollback = new DoDeleteNetworkInstanceRollback()\r
- DoDeleteNetworkInstanceRollback.validateRollbackResponses(mockExecution)\r
- \r
- // verify set prefix = Prefix + ""\r
- verify(mockExecution, atLeast(1)).setVariable("prefix", Prefix)\r
- verify(mockExecution, atLeast(1)).setVariable("rollbackSuccessful", true)\r
- verify(mockExecution, atLeast(1)).setVariable("rollbackError", false)\r
- \r
- }\r
- \r
- \r
- private ExecutionEntity setupMock() {\r
- \r
- ProcessDefinition mockProcessDefinition = mock(ProcessDefinition.class)\r
- when(mockProcessDefinition.getKey()).thenReturn("DoDeleteNetworkInstanceRollback")\r
- RepositoryService mockRepositoryService = mock(RepositoryService.class)\r
- when(mockRepositoryService.getProcessDefinition()).thenReturn(mockProcessDefinition)\r
- when(mockRepositoryService.getProcessDefinition().getKey()).thenReturn("DoDeleteNetworkInstanceRollback")\r
- when(mockRepositoryService.getProcessDefinition().getId()).thenReturn("100")\r
- ProcessEngineServices mockProcessEngineServices = mock(ProcessEngineServices.class)\r
- when(mockProcessEngineServices.getRepositoryService()).thenReturn(mockRepositoryService)\r
- \r
- ExecutionEntity mockExecution = mock(ExecutionEntity.class)\r
- // Initialize prerequisite variables\r
- \r
- when(mockExecution.getId()).thenReturn("100")\r
- when(mockExecution.getProcessDefinitionId()).thenReturn("DoDeleteNetworkInstanceRollback")\r
- when(mockExecution.getProcessInstanceId()).thenReturn("DoDeleteNetworkInstanceRollback")\r
- when(mockExecution.getProcessEngineServices()).thenReturn(mockProcessEngineServices)\r
- when(mockExecution.getProcessEngineServices().getRepositoryService().getProcessDefinition(mockExecution.getProcessDefinitionId())).thenReturn(mockProcessDefinition)\r
- \r
- return mockExecution\r
- }\r
- \r
-}\r
+package org.openecomp.mso.bpmn.infrastructure.scripts
+
+import static org.mockito.Mockito.*
+
+import org.camunda.bpm.engine.delegate.BpmnError
+import org.camunda.bpm.engine.ProcessEngineServices
+import org.camunda.bpm.engine.RepositoryService
+import org.camunda.bpm.engine.impl.persistence.entity.ExecutionEntity
+import org.camunda.bpm.engine.impl.pvm.process.ProcessDefinitionImpl
+import org.camunda.bpm.engine.repository.ProcessDefinition
+import org.camunda.bpm.engine.delegate.DelegateExecution;
+import org.mockito.MockitoAnnotations
+import org.mockito.runners.MockitoJUnitRunner
+import org.mockito.internal.debugging.MockitoDebuggerImpl
+import org.openecomp.mso.bpmn.common.scripts.MsoUtils
+import org.openecomp.mso.bpmn.core.WorkflowException
+import org.junit.Before
+import org.junit.Rule;
+import org.junit.Test
+import org.junit.Ignore
+import org.junit.runner.RunWith
+
+import static org.junit.Assert.*;
+
+import com.github.tomakehurst.wiremock.client.WireMock;
+import com.github.tomakehurst.wiremock.junit.WireMockRule;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.UUID;
+
+import org.apache.commons.lang3.*
+
+
+@RunWith(MockitoJUnitRunner.class)
+class DoDeleteNetworkInstanceRollbackTest {
+
+ @Rule
+ public WireMockRule wireMockRule = new WireMockRule(8090);
+
+ def utils = new MsoUtils()
+ String Prefix="DELNWKIR_"
+
+
+ String rollbackNetworkRequest =
+ """<NetworkAdapter:rollbackNetwork xmlns:NetworkAdapter="http://org.openecomp.mso/network">
+ <rollback>
+ <networkId>MNS-25180-L-01-dmz_direct_net_1/2c88a3a9-69b9-43a7-ada6-1aca577c3641</networkId>
+ <neutronNetworkId>c4f4e878-cde0-4b15-ae9a-bda857759cea</neutronNetworkId>
+ <networkStackId/>
+ <networkType>CONTRAIL_EXTERNAL</networkType>
+ <networkCreated>true</networkCreated>
+ <tenantId>7dd5365547234ee8937416c65507d266</tenantId>
+ <cloudSiteId>RDM2WAGPLCP</cloudSiteId>
+ <msoRequest>
+ <requestId>1ef47428-cade-45bd-a103-0751e8b2deb0</requestId>
+ <serviceInstanceId/>
+ </msoRequest>
+ </rollback>
+</NetworkAdapter:rollbackNetwork>"""
+
+ String rollbackDeActivateSDNCRequest =
+ """<aetgt:SDNCAdapterWorkflowRequest xmlns:aetgt="http://org.openecomp/mso/workflow/schema/v1"
+ xmlns:ns5="http://org.openecomp/mso/request/types/v1"
+ xmlns:sdncadapter="http://org.openecomp.mso/workflow/sdnc/adapter/schema/v1">
+ <sdncadapter:RequestHeader>
+ <sdncadapter:RequestId>88f65519-9a38-4c4b-8445-9eb4a5a5af56</sdncadapter:RequestId>
+ <sdncadapter:SvcInstanceId>f70e927b-6087-4974-9ef8-c5e4d5847ca4</sdncadapter:SvcInstanceId>
+ <sdncadapter:SvcAction>activate</sdncadapter:SvcAction>
+ <sdncadapter:SvcOperation>network-topology-operation</sdncadapter:SvcOperation>
+ <sdncadapter:CallbackUrl>sdncCallback</sdncadapter:CallbackUrl>
+ <sdncadapter:MsoAction>generic-resource</sdncadapter:MsoAction>
+ </sdncadapter:RequestHeader>
+ <aetgt:SDNCRequestData>
+ <request-information>
+ <request-id>88f65519-9a38-4c4b-8445-9eb4a5a5af56</request-id>
+ <request-action>CreateNetworkInstance</request-action>
+ <source>VID</source>
+ <notification-url/>
+ <order-number/>
+ <order-version/>
+ </request-information>
+ <service-information>
+ <service-id>a9a77d5a-123e-4ca2-9eb9-0b015d2ee0fb</service-id>
+ <service-type>MSO-dev-service-type</service-type>
+ <service-instance-id>f70e927b-6087-4974-9ef8-c5e4d5847ca4</service-instance-id>
+ <subscriber-name>MSO_1610_dev</subscriber-name>
+ </service-information>
+ <network-information>
+ <network-id>8abc633a-810b-4ca5-8b3a-09511d13a2ce</network-id>
+ <network-type>CONTRAIL_EXTERNAL</network-type>
+ <ecomp-model-information>
+ <model-invariant-uuid>invariant-uuid</model-invariant-uuid>
+ <model-customization-uuid>customization-uuid</model-customization-uuid>
+ <model-uuid>uuid</model-uuid>
+ <model-version>version</model-version>
+ <model-name>CONTRAIL_EXTERNAL</model-name>
+ </ecomp-model-information>
+ </network-information>
+ <network-request-information>
+ <network-id>8abc633a-810b-4ca5-8b3a-09511d13a2ce</network-id>
+ <network-type>CONTRAIL_EXTERNAL</network-type>
+ <network-name>MNS-25180-L-01-dmz_direct_net_1</network-name>
+ <tenant>7dd5365547234ee8937416c65507d266</tenant>
+ <aic-cloud-region>RDM2WAGPLCP</aic-cloud-region>
+ </network-request-information>
+ </aetgt:SDNCRequestData>
+</aetgt:SDNCAdapterWorkflowRequest>"""
+
+ String rollbackSDNCRequest =
+ """<aetgt:SDNCAdapterWorkflowRequest xmlns:aetgt="http://org.openecomp/mso/workflow/schema/v1"
+ xmlns:ns5="http://org.openecomp/mso/request/types/v1"
+ xmlns:sdncadapter="http://org.openecomp.mso/workflow/sdnc/adapter/schema/v1">
+ <sdncadapter:RequestHeader>
+ <sdncadapter:RequestId>88f65519-9a38-4c4b-8445-9eb4a5a5af56</sdncadapter:RequestId>
+ <sdncadapter:SvcInstanceId>f70e927b-6087-4974-9ef8-c5e4d5847ca4</sdncadapter:SvcInstanceId>
+ <sdncadapter:SvcAction>rollback</sdncadapter:SvcAction>
+ <sdncadapter:SvcOperation>network-topology-operation</sdncadapter:SvcOperation>
+ <sdncadapter:CallbackUrl>sdncCallback</sdncadapter:CallbackUrl>
+ </sdncadapter:RequestHeader>
+ <aetgt:SDNCRequestData>
+ <request-information>
+ <request-id>88f65519-9a38-4c4b-8445-9eb4a5a5af56</request-id>
+ <request-action>CreateNetworkInstance</request-action>
+ <source>VID</source>
+ <notification-url/>
+ <order-number/>
+ <order-version/>
+ </request-information>
+ <service-information>
+ <service-id>a9a77d5a-123e-4ca2-9eb9-0b015d2ee0fb</service-id>
+ <service-type>MSO-dev-service-type</service-type>
+ <service-instance-id>f70e927b-6087-4974-9ef8-c5e4d5847ca4</service-instance-id>
+ <subscriber-name>MSO_1610_dev</subscriber-name>
+ </service-information>
+ <network-information>
+ <network-id>8abc633a-810b-4ca5-8b3a-09511d13a2ce</network-id>
+ <network-type>CONTRAIL_EXTERNAL</network-type>
+ <ecomp-model-information>
+ <model-invariant-uuid>invariant-uuid</model-invariant-uuid>
+ <model-customization-uuid>customization-uuid</model-customization-uuid>
+ <model-uuid>uuid</model-uuid>
+ <model-version>version</model-version>
+ <model-name>CONTRAIL_EXTERNAL</model-name>
+ </ecomp-model-information>
+ </network-information>
+ <network-request-information>
+ <network-id>8abc633a-810b-4ca5-8b3a-09511d13a2ce</network-id>
+ <network-type>CONTRAIL_EXTERNAL</network-type>
+ <network-name>MNS-25180-L-01-dmz_direct_net_1</network-name>
+ <tenant>7dd5365547234ee8937416c65507d266</tenant>
+ <aic-cloud-region>RDM2WAGPLCP</aic-cloud-region>
+ </network-request-information>
+ </aetgt:SDNCRequestData>
+</aetgt:SDNCAdapterWorkflowRequest>"""
+
+// - - - - - - - -
+
+
+ @Before
+ public void init()
+ {
+ MockitoAnnotations.initMocks(this)
+
+ }
+
+ public void initializeVariables (DelegateExecution mockExecution) {
+
+ verify(mockExecution).setVariable(Prefix + "WorkflowException", null)
+
+ verify(mockExecution).setVariable(Prefix + "rollbackDeactivateSDNCRequest", null)
+ verify(mockExecution).setVariable(Prefix + "rollbackDeactivateSDNCResponse", "")
+ verify(mockExecution).setVariable(Prefix + "rollbackDeactivateSDNCReturnCode", "")
+
+ verify(mockExecution).setVariable(Prefix + "rollbackNetworkRequest", null)
+ verify(mockExecution).setVariable(Prefix + "rollbackNetworkResponse", "")
+ verify(mockExecution).setVariable(Prefix + "rollbackNetworkReturnCode", "")
+
+ verify(mockExecution).setVariable(Prefix + "Success", false)
+ verify(mockExecution).setVariable(Prefix + "fullRollback", false)
+
+ }
+
+ @Test
+ //@Ignore
+ public void preProcessRequest() {
+
+ println "************ preProcessRequest ************* "
+
+ WorkflowException workflowException = new WorkflowException("DoCreateNetworkInstance", 2500, "Received error from Network Adapter: JBWEB000065: HTTP Status 500.")
+ Map<String, String> rollbackData = new HashMap<String, String>();
+ rollbackData.put("rollbackDeactivateSDNCRequest", rollbackDeActivateSDNCRequest)
+ rollbackData.put("rollbackNetworkRequest", rollbackNetworkRequest)
+ rollbackData.put("rollbackSDNCRequest", rollbackSDNCRequest)
+
+ ExecutionEntity mockExecution = setupMock()
+ // Initialize prerequisite variables
+ when(mockExecution.getVariable("isDebugLogEnabled")).thenReturn("true")
+ when(mockExecution.getVariable("prefix")).thenReturn(Prefix + "")
+ when(mockExecution.getVariable("WorkflowException")).thenReturn(workflowException)
+ when(mockExecution.getVariable("rollbackData")).thenReturn(rollbackData)
+ when(mockExecution.getVariable("sdncVersion")).thenReturn("1702")
+
+ when(mockExecution.getVariable("URN_mso_adapters_po_auth")).thenReturn("3141634BF7E070AA289CF2892C986C0B")
+ when(mockExecution.getVariable("URN_mso_msoKey")).thenReturn("07a7159d3bf51a0e53be7a8f89699be7")
+
+ when(mockExecution.getVariable("URN_mso_adapters_sdnc_endpoint")).thenReturn("http://localhost:8090/SDNCAdapter")
+ when(mockExecution.getVariable("URN_mso_adapters_network_rest_endpoint")).thenReturn("http://localhost:8090/networks/NetworkAdapter")
+ when(mockExecution.getVariable("URN_mso_adapters_sdnc_resource_endpoint")).thenReturn("http://localhost:8090/SDNCAdapterRpc")
+
+
+ // preProcessRequest(DelegateExecution execution)
+ DoDeleteNetworkInstanceRollback DoDeleteNetworkInstanceRollback = new DoDeleteNetworkInstanceRollback()
+ DoDeleteNetworkInstanceRollback.preProcessRequest(mockExecution)
+
+ //verify variable initialization
+ initializeVariables(mockExecution)
+
+ verify(mockExecution).getVariable("isDebugLogEnabled")
+ verify(mockExecution).setVariable("prefix", Prefix)
+
+ }
+
+
+ @Test
+ //@Ignore
+ public void validateRollbackResponses_Good() {
+
+ WorkflowException workflowException = new WorkflowException("DoDeleteNetworkInstanceRollback", 2500, "AAI Update Contrail Failed. Error 404.")
+ WorkflowException expectedWorkflowException = new WorkflowException("DoDeleteNetworkInstanceRollback", 2500, "AAI Update Contrail Failed. Error 404. + SNDC deactivate rollback completed. + PO Network rollback completed. + SNDC unassign rollback completed.")
+
+ println "************ validateRollbackResponses_Good() ************* "
+ ExecutionEntity mockExecution = setupMock()
+ // Initialize prerequisite variables
+ when(mockExecution.getVariable("isDebugLogEnabled")).thenReturn("true")
+ when(mockExecution.getVariable("prefix")).thenReturn(Prefix + "")
+
+ when(mockExecution.getVariable(Prefix + "rollbackDeactivateSDNCRequest")).thenReturn("Good")
+ when(mockExecution.getVariable(Prefix + "rollbackDeactivateSDNCReturnCode")).thenReturn("200")
+ when(mockExecution.getVariable(Prefix + "rollbackDeactivateSDNCResponse")).thenReturn("GoodResponse")
+ when(mockExecution.getVariable(Prefix + "rollbackNetworkRequest")).thenReturn("Good")
+ when(mockExecution.getVariable(Prefix + "rollbackNetworkReturnCode")).thenReturn("200")
+ when(mockExecution.getVariable(Prefix + "rollbackNetworkResponse")).thenReturn("GoodResponse")
+ when(mockExecution.getVariable(Prefix + "rollbackSDNCRequest")).thenReturn("Good")
+ when(mockExecution.getVariable(Prefix + "rollbackSDNCReturnCode")).thenReturn("200")
+ when(mockExecution.getVariable(Prefix + "rollbackSDNCResponse")).thenReturn("GoodResponse")
+ when(mockExecution.getVariable(Prefix + "WorkflowException")).thenReturn(workflowException)
+ when(mockExecution.getVariable(Prefix + "fullRollback")).thenReturn(false)
+
+ DoDeleteNetworkInstanceRollback DoDeleteNetworkInstanceRollback = new DoDeleteNetworkInstanceRollback()
+ DoDeleteNetworkInstanceRollback.validateRollbackResponses(mockExecution)
+
+ // verify set prefix = Prefix + ""
+ verify(mockExecution, atLeast(1)).setVariable("prefix", Prefix)
+ verify(mockExecution, atLeast(1)).setVariable("rolledBack", true)
+ verify(mockExecution, atLeast(1)).setVariable("wasDeleted", true)
+ verify(mockExecution).setVariable("WorkflowException", refEq(expectedWorkflowException, any(WorkflowException.class)))
+ //verify(mockExecution).setVariable("WorkflowException", expectedWorkflowException)
+ }
+
+ @Test
+ //@Ignore
+ public void validateRollbackResponses_FullRollback() {
+
+ Map<String, String> rollbackData = new HashMap<String, String>();
+ rollbackData.put("rollbackDeactivateSDNCRequest", rollbackDeActivateSDNCRequest)
+ rollbackData.put("rollbackNetworkRequest", rollbackNetworkRequest)
+ rollbackData.put("rollbackSDNCRequest", rollbackSDNCRequest)
+
+ println "************ validateRollbackResponses_FullRollback() ************* "
+ ExecutionEntity mockExecution = setupMock()
+ // Initialize prerequisite variables
+ when(mockExecution.getVariable("isDebugLogEnabled")).thenReturn("true")
+ when(mockExecution.getVariable("prefix")).thenReturn(Prefix + "")
+
+ when(mockExecution.getVariable(Prefix + "rollbackDeactivateSDNCRequest")).thenReturn("Good")
+ when(mockExecution.getVariable(Prefix + "rollbackDeactivateSDNCReturnCode")).thenReturn("200")
+ when(mockExecution.getVariable(Prefix + "rollbackDeactivateSDNCResponse")).thenReturn("GoodResponse")
+ when(mockExecution.getVariable(Prefix + "rollbackNetworkRequest")).thenReturn("Good")
+ when(mockExecution.getVariable(Prefix + "rollbackNetworkReturnCode")).thenReturn("200")
+ when(mockExecution.getVariable(Prefix + "rollbackNetworkResponse")).thenReturn("GoodResponse")
+ when(mockExecution.getVariable(Prefix + "rollbackSDNCRequest")).thenReturn("Good")
+ when(mockExecution.getVariable(Prefix + "rollbackSDNCReturnCode")).thenReturn("200")
+ when(mockExecution.getVariable(Prefix + "rollbackSDNCResponse")).thenReturn("GoodResponse")
+ when(mockExecution.getVariable(Prefix + "WorkflowException")).thenReturn(null)
+ when(mockExecution.getVariable(Prefix + "fullRollback")).thenReturn(true)
+ when(mockExecution.getVariable("rollbackData")).thenReturn(rollbackData)
+
+ DoDeleteNetworkInstanceRollback DoDeleteNetworkInstanceRollback = new DoDeleteNetworkInstanceRollback()
+ DoDeleteNetworkInstanceRollback.validateRollbackResponses(mockExecution)
+
+ // verify set prefix = Prefix + ""
+ verify(mockExecution, atLeast(1)).setVariable("prefix", Prefix)
+ verify(mockExecution, atLeast(1)).setVariable("rollbackSuccessful", true)
+ verify(mockExecution, atLeast(1)).setVariable("rollbackError", false)
+
+ }
+
+
+ private ExecutionEntity setupMock() {
+
+ ProcessDefinition mockProcessDefinition = mock(ProcessDefinition.class)
+ when(mockProcessDefinition.getKey()).thenReturn("DoDeleteNetworkInstanceRollback")
+ RepositoryService mockRepositoryService = mock(RepositoryService.class)
+ when(mockRepositoryService.getProcessDefinition()).thenReturn(mockProcessDefinition)
+ when(mockRepositoryService.getProcessDefinition().getKey()).thenReturn("DoDeleteNetworkInstanceRollback")
+ when(mockRepositoryService.getProcessDefinition().getId()).thenReturn("100")
+ ProcessEngineServices mockProcessEngineServices = mock(ProcessEngineServices.class)
+ when(mockProcessEngineServices.getRepositoryService()).thenReturn(mockRepositoryService)
+
+ ExecutionEntity mockExecution = mock(ExecutionEntity.class)
+ // Initialize prerequisite variables
+
+ when(mockExecution.getId()).thenReturn("100")
+ when(mockExecution.getProcessDefinitionId()).thenReturn("DoDeleteNetworkInstanceRollback")
+ when(mockExecution.getProcessInstanceId()).thenReturn("DoDeleteNetworkInstanceRollback")
+ when(mockExecution.getProcessEngineServices()).thenReturn(mockProcessEngineServices)
+ when(mockExecution.getProcessEngineServices().getRepositoryService().getProcessDefinition(mockExecution.getProcessDefinitionId())).thenReturn(mockProcessDefinition)
+
+ return mockExecution
+ }
+
+}
Code Review / so.git / blobdiff