diff options
45 files changed, 2808 insertions, 836 deletions
diff --git a/adapters/mso-catalog-db-adapter/src/main/resources/db/migration/R__MacroData.sql b/adapters/mso-catalog-db-adapter/src/main/resources/db/migration/R__MacroData.sql index 6e65ec48c7..de16fe36ce 100644 --- a/adapters/mso-catalog-db-adapter/src/main/resources/db/migration/R__MacroData.sql +++ b/adapters/mso-catalog-db-adapter/src/main/resources/db/migration/R__MacroData.sql @@ -42,6 +42,12 @@ INSERT INTO northbound_request_ref_lookup(MACRO_ACTION, ACTION, REQUEST_SCOPE, I INSERT INTO northbound_request_ref_lookup(REQUEST_SCOPE, MACRO_ACTION, ACTION, IS_ALACARTE, MIN_API_VERSION, MAX_API_VERSION, IS_TOPLEVELFLOW, CLOUD_OWNER, SERVICE_TYPE) VALUES ('Vnf', 'VNF-Macro-Modify', 'updateInstance', 0, 7, 7, 1, 'k8scloudowner4', '*'); +-- +-- northbound_request_ref_lookup for CNF healthCheck (Macro Flow) +-- +INSERT INTO northbound_request_ref_lookup(REQUEST_SCOPE, MACRO_ACTION, ACTION, IS_ALACARTE, MIN_API_VERSION, MAX_API_VERSION, IS_TOPLEVELFLOW, CLOUD_OWNER, SERVICE_TYPE) +VALUES ('Vnf', 'VNF-Macro-HealthCheck', 'healthCheck', 0, 7, 7, 1, 'DEFAULT', '*'); + INSERT INTO orchestration_flow_reference(COMPOSITE_ACTION, SEQ_NO, FLOW_NAME, FLOW_VERSION, NB_REQ_REF_LOOKUP_ID) VALUES ('Service-Create', '1', 'AssignServiceInstanceBB', 1.0,(SELECT id from northbound_request_ref_lookup WHERE MACRO_ACTION = 'Service-Create' and CLOUD_OWNER = 'DEFAULT')), @@ -260,6 +266,13 @@ values ('VNF-Macro-Modify', 1, 'ControllerExecutionBB', 1, 'vnf', 'config-assign insert into orchestration_flow_reference (COMPOSITE_ACTION, SEQ_NO, FLOW_NAME, FLOW_VERSION, SCOPE, ACTION, NB_REQ_REF_LOOKUP_ID) values ('VNF-Macro-Modify', 2, 'ControllerExecutionBB', 1, 'vnf', 'config-deploy', (SELECT id from northbound_request_ref_lookup WHERE MACRO_ACTION = 'VNF-Macro-Modify' and CLOUD_OWNER = 'k8scloudowner4')); +-- +-- orchestration_flow_reference for CNF healthCheck (Macro Flow) +-- +insert into orchestration_flow_reference (COMPOSITE_ACTION, SEQ_NO, FLOW_NAME, FLOW_VERSION, SCOPE, ACTION, NB_REQ_REF_LOOKUP_ID) +values ('VNF-Macro-HealthCheck', 1, 'HealthCheckBB', 1, 'vnf', 'status-check', (SELECT id from northbound_request_ref_lookup WHERE MACRO_ACTION = 'VNF-Macro-HealthCheck' and CLOUD_OWNER = 'DEFAULT')); +insert into orchestration_flow_reference (COMPOSITE_ACTION, SEQ_NO, FLOW_NAME, FLOW_VERSION, SCOPE, ACTION, NB_REQ_REF_LOOKUP_ID) +values ('VNF-Macro-HealthCheck', 2, 'HealthCheckBB', 1, 'vnf', 'health-check', (SELECT id from northbound_request_ref_lookup WHERE MACRO_ACTION = 'VNF-Macro-HealthCheck' and CLOUD_OWNER = 'DEFAULT')); INSERT INTO orchestration_flow_reference(COMPOSITE_ACTION, SEQ_NO, FLOW_NAME, FLOW_VERSION, NB_REQ_REF_LOOKUP_ID, SCOPE, ACTION) VALUES ('Service-Macro-Create', '10', 'ControllerExecutionBB', 1.0,(SELECT id from northbound_request_ref_lookup WHERE MACRO_ACTION = 'Service-Macro-Create' and CLOUD_OWNER = 'DEFAULT'), 'pnf', 'config-assign'); @@ -948,6 +961,12 @@ VALUES ('ConfigDeployVnfBB', 'NO_VALIDATE', 'CUSTOM'), ('ControllerExecutionBB', 'NO_VALIDATE', 'CUSTOM'); +INSERT INTO building_block_detail(BUILDING_BLOCK_NAME, RESOURCE_TYPE, TARGET_ACTION) +VALUES +('StatusCheckBB', 'NO_VALIDATE', 'CUSTOM'), +('HealthCheckBB', 'NO_VALIDATE', 'CUSTOM'); + + UPDATE rainy_day_handler_macro SET reg_ex_error_message = '*' WHERE reg_ex_error_message IS null; UPDATE rainy_day_handler_macro SET SERVICE_ROLE = '*' WHERE SERVICE_ROLE IS null; diff --git a/adapters/mso-catalog-db-adapter/src/main/resources/db/migration/V1.1__Initial_Recipe_Setup.sql b/adapters/mso-catalog-db-adapter/src/main/resources/db/migration/V1.1__Initial_Recipe_Setup.sql index c613f26c30..e4a2d6648f 100644 --- a/adapters/mso-catalog-db-adapter/src/main/resources/db/migration/V1.1__Initial_Recipe_Setup.sql +++ b/adapters/mso-catalog-db-adapter/src/main/resources/db/migration/V1.1__Initial_Recipe_Setup.sql @@ -34,7 +34,7 @@ INSERT INTO `service_recipe` (`id`, `ACTION`, `VERSION_STR`, `DESCRIPTION`, `ORC INSERT INTO `service_recipe` (`id`, `ACTION`, `VERSION_STR`, `DESCRIPTION`, `ORCHESTRATION_URI`, `SERVICE_PARAM_XSD`, `RECIPE_TIMEOUT`, `SERVICE_TIMEOUT_INTERIM`, `CREATION_TIMESTAMP`, `SERVICE_MODEL_UUID`) VALUES (3,'createInstance','1','DEFAULT recipe to create service-instance if no custom BPMN flow is found','/mso/async/services/CreateGenericALaCarteServiceInstance',NULL,180,NULL,'2017-10-05 18:52:03','48cc3acd-a9fe-11e7-8b4b-0242ac120002'); INSERT INTO `service_recipe` (`id`, `ACTION`, `VERSION_STR`, `DESCRIPTION`, `ORCHESTRATION_URI`, `SERVICE_PARAM_XSD`, `RECIPE_TIMEOUT`, `SERVICE_TIMEOUT_INTERIM`, `CREATION_TIMESTAMP`, `SERVICE_MODEL_UUID`) VALUES (4,'deleteInstance','1','DEFAULT recipe to delete service-instance if no custom BPMN flow is found','/mso/async/services/DeleteGenericALaCarteServiceInstance',NULL,180,NULL,'2017-10-05 18:52:03','48cc3acd-a9fe-11e7-8b4b-0242ac120002'); insert into `service_recipe` (`id`, `ACTION`, `VERSION_STR`, `DESCRIPTION`, `ORCHESTRATION_URI`, `SERVICE_PARAM_XSD`, `RECIPE_TIMEOUT`, `SERVICE_TIMEOUT_INTERIM`, `CREATION_TIMESTAMP`, `SERVICE_MODEL_UUID`) values (500,'updateInstance','1.0','Gr api recipe to update service-instance', '/mso/async/services/WorkflowActionBB', NULL, 180, NULL, '2017-10-05 18:52:03', 'd88da85c-d9e8-4f73-b837-3a72a431622b'); - +insert into `service_recipe` (`id`, `ACTION`, `VERSION_STR`, `DESCRIPTION`, `ORCHESTRATION_URI`, `SERVICE_PARAM_XSD`, `RECIPE_TIMEOUT`, `SERVICE_TIMEOUT_INTERIM`, `CREATION_TIMESTAMP`, `SERVICE_MODEL_UUID`) values (501,'healthCheck','1.0','Gr api recipe to do CNF health check', '/mso/async/services/WorkflowActionBB', NULL, 180, NULL, '2021-08-20 18:52:03', 'd88da85c-d9e8-4f73-b837-3a72a431622b'); -- -- Custom Reciepe for the VoLTE service added temporarily diff --git a/bpmn/MSOCommonBPMN/src/main/groovy/org/onap/so/bpmn/common/scripts/CNFAdapterAsync.groovy b/bpmn/MSOCommonBPMN/src/main/groovy/org/onap/so/bpmn/common/scripts/CNFAdapterAsync.groovy new file mode 100755 index 0000000000..9de40b4e69 --- /dev/null +++ b/bpmn/MSOCommonBPMN/src/main/groovy/org/onap/so/bpmn/common/scripts/CNFAdapterAsync.groovy @@ -0,0 +1,80 @@ +package org.onap.so.bpmn.common.scripts + +import javax.ws.rs.core.Response + +import org.camunda.bpm.engine.delegate.DelegateExecution +import org.slf4j.Logger +import org.slf4j.LoggerFactory + +import com.fasterxml.jackson.databind.ObjectMapper + +import org.onap.so.bpmn.core.UrnPropertiesReader +import org.onap.logging.filter.base.ONAPComponents +import org.onap.so.client.HttpClient +import org.onap.so.client.HttpClientFactory + +import static org.onap.so.bpmn.common.scripts.GenericUtils.isBlank + +public class CNFAdapterAsync extends AbstractServiceTaskProcessor { + private static final Logger logger = LoggerFactory.getLogger(CNFAdapterAsync.class) + + ExceptionUtil exceptionUtil = new ExceptionUtil() + ObjectMapper mapper = new ObjectMapper(); + + @Override + public void preProcessRequest(DelegateExecution execution) { + logger.debug("Start preProcessRequest"); + + String apiPath = execution.getVariable("apiPath") + if (isBlank(apiPath)) { + String msg = "Cannot process CNF adapter call : API PATH is null" + exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg) + } + + //Object cnfRequestPayloadFromExecutionVariable = execution.getVariable("cnfRequestPayload") + + String cnfRequestPayload = execution.getVariable("cnfRequestPayload") + if (isBlank(cnfRequestPayload)) { + String msg = "Cannot process CNF adapter call : cnfRequestPayload is null" + exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg) + } + + String correlator = execution.getVariable("correlator") + if (isBlank(correlator)) { + String msg = "Cannot process CNF adapter call : correlator is null" + exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg) + } + + String messageType = execution.getVariable("messageType") + if (isBlank(messageType)) { + String msg = "Cannot process CNF adapter call : messageType is null" + exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg) + } + + String timeout = UrnPropertiesReader.getVariable("mso.adapters.cnf.timeout", execution); + if (isBlank(timeout)) { + logger.debug("Setting CNF Adapter timeout to default : PT30M") + timeout = "PT30M" + } + + execution.setVariable("timeout",timeout) + + logger.debug("Enter preProcessRequest: {}",execution.getVariable("messageType")); + } + + void callCnfAdapter(DelegateExecution execution) { + logger.debug("Start callCnfAdapter") + String cnfAdapterEndpoint = execution.getVariable("apiPath") + URL requestUrl = new URL(cnfAdapterEndpoint) + String cnfRequest = execution.getVariable("cnfRequestPayload") + logger.debug("cnfRequest : " + cnfRequest) + HttpClient httpClient = new HttpClientFactory().newJsonClient(requestUrl, ONAPComponents.EXTERNAL) + Response httpResponse = httpClient.post(cnfRequest) + int responseCode = httpResponse.getStatus() + logger.debug("CNF sync response code is: " + responseCode) + if(responseCode < 200 || responseCode >= 300){ + exceptionUtil.buildAndThrowWorkflowException(execution, responseCode, "Received a Bad Sync Response from CNF.") + } + logger.debug("End callCnfAdapter") + } +} diff --git a/bpmn/MSOCommonBPMN/src/main/resources/subprocess/CNFAdapterAsyncCall.bpmn b/bpmn/MSOCommonBPMN/src/main/resources/subprocess/CNFAdapterAsyncCall.bpmn new file mode 100755 index 0000000000..39846f2d39 --- /dev/null +++ b/bpmn/MSOCommonBPMN/src/main/resources/subprocess/CNFAdapterAsyncCall.bpmn @@ -0,0 +1,106 @@ +<?xml version="1.0" encoding="UTF-8"?> +<bpmn:definitions xmlns:bpmn="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:camunda="http://camunda.org/schema/1.0/bpmn" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" id="Definitions_0xinghn" targetNamespace="http://bpmn.io/schema/bpmn" exporter="Camunda Modeler" exporterVersion="4.0.0"> + <bpmn:process id="CNFAdapterAsyncCall" name="CNFAdapterAsyncCall" isExecutable="true"> + <bpmn:startEvent id="StartEvent_1" name="CNFAdapterAsyncCall_start"> + <bpmn:outgoing>Flow_0q7kp9w</bpmn:outgoing> + </bpmn:startEvent> + <bpmn:endEvent id="Event_15f5cnf" name="CNFAdapterAsyncCall_end"> + <bpmn:incoming>Flow_0cy88g6</bpmn:incoming> + </bpmn:endEvent> + <bpmn:callActivity id="Activity_0fhymrt" name="Receive Async Callback" camunda:modelerTemplate="receiveWorkflowMessage" calledElement="ReceiveWorkflowMessage"> + <bpmn:extensionElements> + <camunda:in source="true" target="isDebugLogEnabled" /> + <camunda:out source="WorkflowException" target="WorkflowException" /> + <camunda:in source="messageType" target="RCVWFMSG_messageType" /> + <camunda:in source="correlator" target="RCVWFMSG_correlator" /> + <camunda:in source="timeout" target="RCVWFMSG_timeout" /> + <camunda:out source="WorkflowResponse" target="asyncCallbackResponse" /> + </bpmn:extensionElements> + <bpmn:incoming>Flow_0njjlbm</bpmn:incoming> + <bpmn:outgoing>Flow_0cy88g6</bpmn:outgoing> + </bpmn:callActivity> + <bpmn:sequenceFlow id="Flow_0njjlbm" sourceRef="Activity_1ttieoz" targetRef="Activity_0fhymrt" /> + <bpmn:sequenceFlow id="Flow_0q7kp9w" sourceRef="StartEvent_1" targetRef="Activity_0lttdg6" /> + <bpmn:sequenceFlow id="Flow_0cy88g6" sourceRef="Activity_0fhymrt" targetRef="Event_15f5cnf" /> + <bpmn:sequenceFlow id="Flow_04o97wl" sourceRef="Activity_0lttdg6" targetRef="Activity_1ttieoz" /> + <bpmn:scriptTask id="Activity_0lttdg6" name="Preprocess request" scriptFormat="groovy"> + <bpmn:incoming>Flow_0q7kp9w</bpmn:incoming> + <bpmn:outgoing>Flow_04o97wl</bpmn:outgoing> + <bpmn:script>import org.onap.so.bpmn.common.scripts.* +def cnf= new CNFAdapterAsync() +cnf.preProcessRequest(execution)</bpmn:script> + </bpmn:scriptTask> + <bpmn:scriptTask id="Activity_1ttieoz" name="Call CnfAdapter" scriptFormat="groovy"> + <bpmn:incoming>Flow_04o97wl</bpmn:incoming> + <bpmn:outgoing>Flow_0njjlbm</bpmn:outgoing> + <bpmn:script>import org.onap.so.bpmn.common.scripts.* +def cnf= new CNFAdapterAsync() +cnf.callCnfAdapter(execution)</bpmn:script> + </bpmn:scriptTask> + <bpmn:subProcess id="Activity_06t66qc" name="Error Handling " triggeredByEvent="true"> + <bpmn:startEvent id="Event_0ny1qj3"> + <bpmn:outgoing>Flow_0xo7st8</bpmn:outgoing> + <bpmn:errorEventDefinition id="ErrorEventDefinition_0ta0yq5" /> + </bpmn:startEvent> + <bpmn:endEvent id="Event_1t6t0h6"> + <bpmn:incoming>Flow_0xo7st8</bpmn:incoming> + <bpmn:terminateEventDefinition id="TerminateEventDefinition_1i0gtkr" /> + </bpmn:endEvent> + <bpmn:sequenceFlow id="Flow_0xo7st8" sourceRef="Event_0ny1qj3" targetRef="Event_1t6t0h6" /> + </bpmn:subProcess> + </bpmn:process> + <bpmndi:BPMNDiagram id="BPMNDiagram_1"> + <bpmndi:BPMNPlane id="BPMNPlane_1" bpmnElement="CNFAdapterAsyncCall"> + <bpmndi:BPMNEdge id="Flow_04o97wl_di" bpmnElement="Flow_04o97wl"> + <di:waypoint x="330" y="120" /> + <di:waypoint x="370" y="120" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_0cy88g6_di" bpmnElement="Flow_0cy88g6"> + <di:waypoint x="610" y="120" /> + <di:waypoint x="682" y="120" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_0q7kp9w_di" bpmnElement="Flow_0q7kp9w"> + <di:waypoint x="188" y="120" /> + <di:waypoint x="230" y="120" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_0njjlbm_di" bpmnElement="Flow_0njjlbm"> + <di:waypoint x="470" y="120" /> + <di:waypoint x="510" y="120" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNShape id="_BPMNShape_StartEvent_2" bpmnElement="StartEvent_1"> + <dc:Bounds x="152" y="102" width="36" height="36" /> + <bpmndi:BPMNLabel> + <dc:Bounds x="128" y="145" width="85" height="27" /> + </bpmndi:BPMNLabel> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Event_15f5cnf_di" bpmnElement="Event_15f5cnf"> + <dc:Bounds x="682" y="102" width="36" height="36" /> + <bpmndi:BPMNLabel> + <dc:Bounds x="658" y="145" width="85" height="27" /> + </bpmndi:BPMNLabel> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_0fhymrt_di" bpmnElement="Activity_0fhymrt"> + <dc:Bounds x="510" y="80" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_0j7hue7_di" bpmnElement="Activity_0lttdg6"> + <dc:Bounds x="230" y="80" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_0o6kxz9_di" bpmnElement="Activity_1ttieoz"> + <dc:Bounds x="370" y="80" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_06t66qc_di" bpmnElement="Activity_06t66qc" isExpanded="true"> + <dc:Bounds x="210" y="220" width="460" height="135" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNEdge id="Flow_0xo7st8_di" bpmnElement="Flow_0xo7st8"> + <di:waypoint x="328" y="294" /> + <di:waypoint x="562" y="294" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNShape id="Event_0ny1qj3_di" bpmnElement="Event_0ny1qj3"> + <dc:Bounds x="292" y="276" width="36" height="36" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Event_1t6t0h6_di" bpmnElement="Event_1t6t0h6"> + <dc:Bounds x="562" y="276" width="36" height="36" /> + </bpmndi:BPMNShape> + </bpmndi:BPMNPlane> + </bpmndi:BPMNDiagram> +</bpmn:definitions> diff --git a/bpmn/so-bpmn-building-blocks/src/main/resources/subprocess/BuildingBlock/CreateVfModuleBB.bpmn b/bpmn/so-bpmn-building-blocks/src/main/resources/subprocess/BuildingBlock/CreateVfModuleBB.bpmn index a32e9e8f62..49358c7c23 100644 --- a/bpmn/so-bpmn-building-blocks/src/main/resources/subprocess/BuildingBlock/CreateVfModuleBB.bpmn +++ b/bpmn/so-bpmn-building-blocks/src/main/resources/subprocess/BuildingBlock/CreateVfModuleBB.bpmn @@ -1,5 +1,5 @@ <?xml version="1.0" encoding="UTF-8"?> -<bpmn:definitions xmlns:bpmn="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:camunda="http://camunda.org/schema/1.0/bpmn" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" id="Definitions_1" targetNamespace="http://bpmn.io/schema/bpmn" exporter="Camunda Modeler" exporterVersion="4.1.1"> +<bpmn:definitions xmlns:bpmn="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:camunda="http://camunda.org/schema/1.0/bpmn" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" id="Definitions_1" targetNamespace="http://bpmn.io/schema/bpmn" exporter="Camunda Modeler" exporterVersion="4.0.0"> <bpmn:process id="CreateVfModuleBB" name="CreateVfModuleBB" isExecutable="true"> <bpmn:startEvent id="CreateVfModuleBB_Start"> <bpmn:outgoing>SequenceFlow_1xr6chl</bpmn:outgoing> @@ -47,7 +47,7 @@ <bpmn:sequenceFlow id="SequenceFlow_1vbwdaw" sourceRef="UpdateVfModuleStatus" targetRef="CreateVfModuleBB_End" /> <bpmn:serviceTask id="CreateNetworkPolicies" name="AAI Create (network policies)" camunda:expression="${AAICreateTasks.createNetworkPolicies(InjectExecution.execute(execution, execution.getVariable("gBuildingBlockExecution")))}"> <bpmn:incoming>Flow_10aq7a8</bpmn:incoming> - <bpmn:incoming>Flow_1il4743</bpmn:incoming> + <bpmn:incoming>Flow_1xlm2ij</bpmn:incoming> <bpmn:outgoing>SequenceFlow_0xqhep5</bpmn:outgoing> </bpmn:serviceTask> <bpmn:sequenceFlow id="SequenceFlow_0xqhep5" sourceRef="CreateNetworkPolicies" targetRef="UpdateVnfIpv4OamAddress" /> @@ -107,11 +107,31 @@ <bpmn:sequenceFlow id="Flow_03q6ty9" sourceRef="Activity_1p8hxyt" targetRef="Event_108oetk" /> </bpmn:subProcess> <bpmn:sequenceFlow id="Flow_10aq7a8" sourceRef="ServiceTask_00d84m7" targetRef="CreateNetworkPolicies" /> - <bpmn:sequenceFlow id="Flow_1il4743" sourceRef="CnfAdapter" targetRef="CreateNetworkPolicies" /> + <bpmn:sequenceFlow id="Flow_1il4743" sourceRef="CnfAdapter" targetRef="UpdateCnfAai" /> + <bpmn:sequenceFlow id="Flow_1xlm2ij" sourceRef="UpdateCnfAai" targetRef="CreateNetworkPolicies" /> + <bpmn:callActivity id="UpdateCnfAai" name="Update Cnf Data in AAI" calledElement="UpdateCnfAai"> + <bpmn:extensionElements> + <camunda:in source="gBuildingBlockExecution" target="gBuildingBlockExecution" /> + <camunda:out source="WorkflowException" target="WorkflowException" /> + <camunda:in source="heatStackId" target="heatStackId" /> + <camunda:out source="heatStackId" target="heatStackId" /> + </bpmn:extensionElements> + <bpmn:incoming>Flow_1il4743</bpmn:incoming> + <bpmn:outgoing>Flow_1xlm2ij</bpmn:outgoing> + </bpmn:callActivity> </bpmn:process> <bpmn:error id="Error_0t7oivz" name="AAIInventoryFailure" errorCode="AAIInventoryFailure" /> <bpmndi:BPMNDiagram id="BPMNDiagram_1"> <bpmndi:BPMNPlane id="BPMNPlane_1" bpmnElement="CreateVfModuleBB"> + <bpmndi:BPMNEdge id="Flow_1il4743_di" bpmnElement="Flow_1il4743"> + <di:waypoint x="646" y="250" /> + <di:waypoint x="424" y="250" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_10aq7a8_di" bpmnElement="Flow_10aq7a8"> + <di:waypoint x="646" y="366" /> + <di:waypoint x="374" y="366" /> + <di:waypoint x="374" y="428" /> + </bpmndi:BPMNEdge> <bpmndi:BPMNEdge id="SequenceFlow_0uetprw_di" bpmnElement="SequenceFlow_0uetprw"> <di:waypoint x="1009" y="146" /> <di:waypoint x="1009" y="326" /> @@ -212,15 +232,10 @@ <dc:Bounds x="156" y="91" width="0" height="0" /> </bpmndi:BPMNLabel> </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_10aq7a8_di" bpmnElement="Flow_10aq7a8"> - <di:waypoint x="646" y="366" /> - <di:waypoint x="374" y="366" /> - <di:waypoint x="374" y="428" /> - </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_1il4743_di" bpmnElement="Flow_1il4743"> - <di:waypoint x="646" y="250" /> - <di:waypoint x="200" y="250" /> - <di:waypoint x="200" y="468" /> + <bpmndi:BPMNEdge id="Flow_1xlm2ij_di" bpmnElement="Flow_1xlm2ij"> + <di:waypoint x="324" y="250" /> + <di:waypoint x="190" y="250" /> + <di:waypoint x="190" y="468" /> <di:waypoint x="324" y="468" /> </bpmndi:BPMNEdge> <bpmndi:BPMNShape id="StartEvent_0kxwniy_di" bpmnElement="CreateVfModuleBB_Start"> @@ -271,15 +286,18 @@ <bpmndi:BPMNShape id="ServiceTask_00d84m7_di" bpmnElement="ServiceTask_00d84m7"> <dc:Bounds x="646" y="326" width="100" height="80" /> </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="ServiceTask_0tag50w_di" bpmnElement="CnfAdapter"> - <dc:Bounds x="646" y="210" width="100" height="80" /> - </bpmndi:BPMNShape> <bpmndi:BPMNShape id="ExclusiveGateway_1g3vemz_di" bpmnElement="CheckIfIsHelm" isMarkerVisible="true"> <dc:Bounds x="671" y="81" width="50" height="50" /> <bpmndi:BPMNLabel> <dc:Bounds x="655" y="48" width="82" height="14" /> </bpmndi:BPMNLabel> </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="ServiceTask_0tag50w_di" bpmnElement="CnfAdapter"> + <dc:Bounds x="646" y="210" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_08npiny_di" bpmnElement="UpdateCnfAai"> + <dc:Bounds x="324" y="210" width="100" height="80" /> + </bpmndi:BPMNShape> <bpmndi:BPMNShape id="Activity_10eqhmz_di" bpmnElement="Activity_10eqhmz" isExpanded="true"> <dc:Bounds x="240" y="590" width="340" height="180" /> </bpmndi:BPMNShape> diff --git a/bpmn/so-bpmn-building-blocks/src/main/resources/subprocess/BuildingBlock/DeleteVfModuleBB.bpmn b/bpmn/so-bpmn-building-blocks/src/main/resources/subprocess/BuildingBlock/DeleteVfModuleBB.bpmn index 36d1708a45..128d2fff7f 100644 --- a/bpmn/so-bpmn-building-blocks/src/main/resources/subprocess/BuildingBlock/DeleteVfModuleBB.bpmn +++ b/bpmn/so-bpmn-building-blocks/src/main/resources/subprocess/BuildingBlock/DeleteVfModuleBB.bpmn @@ -1,5 +1,5 @@ <?xml version="1.0" encoding="UTF-8"?> -<bpmn:definitions xmlns:bpmn="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:camunda="http://camunda.org/schema/1.0/bpmn" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" id="Definitions_1" targetNamespace="http://bpmn.io/schema/bpmn" exporter="Camunda Modeler" exporterVersion="4.1.1"> +<bpmn:definitions xmlns:bpmn="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:camunda="http://camunda.org/schema/1.0/bpmn" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" id="Definitions_1" targetNamespace="http://bpmn.io/schema/bpmn" exporter="Camunda Modeler" exporterVersion="4.0.0"> <bpmn:process id="DeleteVfModuleBB" name="DeleteVfModuleBB" isExecutable="true"> <bpmn:startEvent id="DeleteVfModuleBB_Start"> <bpmn:outgoing>Flow_069drgn</bpmn:outgoing> @@ -58,7 +58,7 @@ </bpmn:serviceTask> <bpmn:intermediateThrowEvent id="aaiThrow" name="Update AAI"> <bpmn:incoming>Flow_0plbl7p</bpmn:incoming> - <bpmn:incoming>Flow_1ktykz6</bpmn:incoming> + <bpmn:incoming>Flow_1sj2wbe</bpmn:incoming> <bpmn:linkEventDefinition name="AAI" /> </bpmn:intermediateThrowEvent> <bpmn:intermediateCatchEvent id="aaiCatch" name="Update AAI"> @@ -96,7 +96,7 @@ <bpmn:incoming>Flow_10r76pp</bpmn:incoming> <bpmn:outgoing>Flow_1ktykz6</bpmn:outgoing> </bpmn:serviceTask> - <bpmn:sequenceFlow id="Flow_1ktykz6" sourceRef="Activity_1aqardy" targetRef="aaiThrow" /> + <bpmn:sequenceFlow id="Flow_1ktykz6" sourceRef="Activity_1aqardy" targetRef="UpdateCnfAai" /> <bpmn:exclusiveGateway id="CheckIfIsHelm" name="Check if is helm"> <bpmn:incoming>Flow_069drgn</bpmn:incoming> <bpmn:outgoing>Flow_10r76pp</bpmn:outgoing> @@ -108,12 +108,50 @@ <bpmn:sequenceFlow id="Flow_0yz0t7z" sourceRef="DeleteVfModuleVnfAdapter" targetRef="VnfAdapter" /> <bpmn:sequenceFlow id="Flow_069drgn" sourceRef="DeleteVfModuleBB_Start" targetRef="CheckIfIsHelm" /> <bpmn:sequenceFlow id="Flow_1c15ua4" name="No" sourceRef="CheckIfIsHelm" targetRef="DeleteVfModuleVnfAdapter" /> + <bpmn:callActivity id="UpdateCnfAai" name="Update Cnf Data in AAI" calledElement="UpdateCnfAai"> + <bpmn:extensionElements> + <camunda:in source="gBuildingBlockExecution" target="gBuildingBlockExecution" /> + <camunda:out source="WorkflowException" target="WorkflowException" /> + <camunda:in source="heatStackId" target="heatStackId" /> + <camunda:out source="heatStackId" target="heatStackId" /> + </bpmn:extensionElements> + <bpmn:incoming>Flow_1ktykz6</bpmn:incoming> + <bpmn:outgoing>Flow_1sj2wbe</bpmn:outgoing> + </bpmn:callActivity> + <bpmn:sequenceFlow id="Flow_1sj2wbe" sourceRef="UpdateCnfAai" targetRef="aaiThrow" /> </bpmn:process> <bpmn:error id="Error_0jjnve8" name="Error_3k24na6" errorCode="AAIInventoryFailure" /> <bpmn:escalation id="Escalation_130je8j" name="audit" escalationCode="audit1" /> <bpmn:error id="Error_1le3oui" name="AAIInventoryFailure" errorCode="AAIInventoryFailure" /> <bpmndi:BPMNDiagram id="BPMNDiagram_1"> <bpmndi:BPMNPlane id="BPMNPlane_1" bpmnElement="DeleteVfModuleBB"> + <bpmndi:BPMNEdge id="Flow_1c15ua4_di" bpmnElement="Flow_1c15ua4"> + <di:waypoint x="305" y="254" /> + <di:waypoint x="400" y="254" /> + <bpmndi:BPMNLabel> + <dc:Bounds x="345" y="236" width="15" height="14" /> + </bpmndi:BPMNLabel> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_069drgn_di" bpmnElement="Flow_069drgn"> + <di:waypoint x="195" y="254" /> + <di:waypoint x="255" y="254" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_0yz0t7z_di" bpmnElement="Flow_0yz0t7z"> + <di:waypoint x="500" y="254" /> + <di:waypoint x="580" y="254" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_10r76pp_di" bpmnElement="Flow_10r76pp"> + <di:waypoint x="280" y="229" /> + <di:waypoint x="280" y="120" /> + <di:waypoint x="400" y="120" /> + <bpmndi:BPMNLabel> + <dc:Bounds x="256" y="162" width="18" height="14" /> + </bpmndi:BPMNLabel> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_1ktykz6_di" bpmnElement="Flow_1ktykz6"> + <di:waypoint x="500" y="120" /> + <di:waypoint x="740" y="120" /> + </bpmndi:BPMNEdge> <bpmndi:BPMNEdge id="Flow_0hlvlw2_di" bpmnElement="Flow_0hlvlw2"> <di:waypoint x="680" y="254" /> <di:waypoint x="760" y="254" /> @@ -172,40 +210,20 @@ <dc:Bounds x="848" y="493" width="90" height="0" /> </bpmndi:BPMNLabel> </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_1ktykz6_di" bpmnElement="Flow_1ktykz6"> - <di:waypoint x="680" y="120" /> + <bpmndi:BPMNEdge id="Flow_1sj2wbe_di" bpmnElement="Flow_1sj2wbe"> + <di:waypoint x="840" y="120" /> <di:waypoint x="1080" y="120" /> <di:waypoint x="1080" y="236" /> </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_10r76pp_di" bpmnElement="Flow_10r76pp"> - <di:waypoint x="280" y="229" /> - <di:waypoint x="280" y="120" /> - <di:waypoint x="580" y="120" /> - <bpmndi:BPMNLabel> - <dc:Bounds x="256" y="162" width="18" height="14" /> - </bpmndi:BPMNLabel> - </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_0yz0t7z_di" bpmnElement="Flow_0yz0t7z"> - <di:waypoint x="500" y="254" /> - <di:waypoint x="580" y="254" /> - </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_069drgn_di" bpmnElement="Flow_069drgn"> - <di:waypoint x="195" y="254" /> - <di:waypoint x="255" y="254" /> - </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_1c15ua4_di" bpmnElement="Flow_1c15ua4"> - <di:waypoint x="305" y="254" /> - <di:waypoint x="400" y="254" /> - <bpmndi:BPMNLabel> - <dc:Bounds x="345" y="236" width="15" height="14" /> - </bpmndi:BPMNLabel> - </bpmndi:BPMNEdge> <bpmndi:BPMNShape id="_BPMNShape_StartEvent_2" bpmnElement="DeleteVfModuleBB_Start"> <dc:Bounds x="159" y="236" width="36" height="36" /> <bpmndi:BPMNLabel> <dc:Bounds x="132" y="302" width="90" height="12" /> </bpmndi:BPMNLabel> </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="ServiceTask_16798zf_di" bpmnElement="DeleteVfModuleVnfAdapter"> + <dc:Bounds x="400" y="214" width="100" height="80" /> + </bpmndi:BPMNShape> <bpmndi:BPMNShape id="ServiceTask_0pbhsub_di" bpmnElement="UpdateVfModuleDeleteStatus"> <dc:Bounds x="930" y="438" width="100" height="80" /> </bpmndi:BPMNShape> @@ -215,6 +233,9 @@ <dc:Bounds x="1241" y="530" width="90" height="0" /> </bpmndi:BPMNLabel> </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="CallActivity_0whogn3_di" bpmnElement="VnfAdapter"> + <dc:Bounds x="580" y="214" width="100" height="80" /> + </bpmndi:BPMNShape> <bpmndi:BPMNShape id="ServiceTask_0vlgqod_di" bpmnElement="UpdateVfModuleHeatStackId"> <dc:Bounds x="800" y="438" width="100" height="80" /> </bpmndi:BPMNShape> @@ -248,20 +269,8 @@ <bpmndi:BPMNShape id="ServiceTask_08ulmzc_di" bpmnElement="ServiceTask_08ulmzc"> <dc:Bounds x="760" y="214" width="100" height="80" /> </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Gateway_0s4azdf_di" bpmnElement="CheckIfIsHelm" isMarkerVisible="true"> - <dc:Bounds x="255" y="229" width="50" height="50" /> - <bpmndi:BPMNLabel> - <dc:Bounds x="240" y="289" width="79" height="14" /> - </bpmndi:BPMNLabel> - </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="ServiceTask_16798zf_di" bpmnElement="DeleteVfModuleVnfAdapter"> - <dc:Bounds x="400" y="214" width="100" height="80" /> - </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="CallActivity_0whogn3_di" bpmnElement="VnfAdapter"> - <dc:Bounds x="580" y="214" width="100" height="80" /> - </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Activity_1aqardy_di" bpmnElement="Activity_1aqardy"> - <dc:Bounds x="580" y="80" width="100" height="80" /> + <bpmndi:BPMNShape id="Activity_1wkyyas_di" bpmnElement="UpdateCnfAai"> + <dc:Bounds x="740" y="80" width="100" height="80" /> </bpmndi:BPMNShape> <bpmndi:BPMNShape id="Activity_1thbmzc_di" bpmnElement="Activity_1thbmzc" isExpanded="true"> <dc:Bounds x="280" y="620" width="340" height="180" /> @@ -283,6 +292,15 @@ <bpmndi:BPMNShape id="Activity_025387k_di" bpmnElement="Activity_025387k"> <dc:Bounds x="400" y="670" width="100" height="80" /> </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_1aqardy_di" bpmnElement="Activity_1aqardy"> + <dc:Bounds x="400" y="80" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Gateway_0s4azdf_di" bpmnElement="CheckIfIsHelm" isMarkerVisible="true"> + <dc:Bounds x="255" y="229" width="50" height="50" /> + <bpmndi:BPMNLabel> + <dc:Bounds x="240" y="289" width="79" height="14" /> + </bpmndi:BPMNLabel> + </bpmndi:BPMNShape> </bpmndi:BPMNPlane> </bpmndi:BPMNDiagram> </bpmn:definitions> diff --git a/bpmn/so-bpmn-building-blocks/src/main/resources/subprocess/BuildingBlock/HealthCheckBB.bpmn b/bpmn/so-bpmn-building-blocks/src/main/resources/subprocess/BuildingBlock/HealthCheckBB.bpmn new file mode 100755 index 0000000000..8272bd3750 --- /dev/null +++ b/bpmn/so-bpmn-building-blocks/src/main/resources/subprocess/BuildingBlock/HealthCheckBB.bpmn @@ -0,0 +1,102 @@ +<?xml version="1.0" encoding="UTF-8"?> +<bpmn:definitions xmlns:bpmn="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:camunda="http://camunda.org/schema/1.0/bpmn" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" id="Definitions_1bvx7yi" targetNamespace="http://bpmn.io/schema/bpmn" exporter="Camunda Modeler" exporterVersion="4.0.0"> + <bpmn:process id="HealthCheckBB" name="HealthCheckBB" isExecutable="true"> + <bpmn:startEvent id="StartEvent_1" name="HealthCheckBB_start"> + <bpmn:outgoing>Flow_0gd6hy6</bpmn:outgoing> + </bpmn:startEvent> + <bpmn:endEvent id="Event_1dklvvk" name="HealthCheckBB_end"> + <bpmn:incoming>Flow_0xiyno7</bpmn:incoming> + </bpmn:endEvent> + <bpmn:sequenceFlow id="Flow_0gd6hy6" sourceRef="StartEvent_1" targetRef="Activity_11hkwkn" /> + <bpmn:subProcess id="Activity_1pto2qh" name="Error Handling " triggeredByEvent="true"> + <bpmn:startEvent id="Event_0929aqj"> + <bpmn:outgoing>Flow_05rbrsm</bpmn:outgoing> + <bpmn:errorEventDefinition id="ErrorEventDefinition_0k0ly65" /> + </bpmn:startEvent> + <bpmn:endEvent id="Event_1s698ql"> + <bpmn:incoming>Flow_05rbrsm</bpmn:incoming> + <bpmn:terminateEventDefinition id="TerminateEventDefinition_0mn6xgi" /> + </bpmn:endEvent> + <bpmn:sequenceFlow id="Flow_05rbrsm" sourceRef="Event_0929aqj" targetRef="Event_1s698ql" /> + </bpmn:subProcess> + <bpmn:serviceTask id="Activity_11hkwkn" name="Prepare Cnf Adapter request" camunda:expression="${CnfHealthCheckTasks.prepareCnfAdaperRequest(InjectExecution.execute(execution, execution.getVariable("gBuildingBlockExecution")))}"> + <bpmn:incoming>Flow_0gd6hy6</bpmn:incoming> + <bpmn:outgoing>Flow_1aqdd5k</bpmn:outgoing> + </bpmn:serviceTask> + <bpmn:sequenceFlow id="Flow_1aqdd5k" sourceRef="Activity_11hkwkn" targetRef="Activity_08mgs1k" /> + <bpmn:callActivity id="Activity_08mgs1k" name="Call CNFAdapterAsyncCall" calledElement="CNFAdapterAsyncCall"> + <bpmn:extensionElements> + <camunda:in source="apiPath" target="apiPath" /> + <camunda:in source="cnfRequestPayload" target="cnfRequestPayload" /> + <camunda:in source="mso-request-id" target="correlator" /> + <camunda:in source="timeout" target="timeout" /> + <camunda:out source="WorkflowException" target="WorkflowException" /> + <camunda:out source="asyncCallbackResponse" target="asyncCallbackResponse" /> + <camunda:in source="messageType" target="messageType" /> + <camunda:in source="true" target="isDebugLogEnabled" /> + </bpmn:extensionElements> + <bpmn:incoming>Flow_1aqdd5k</bpmn:incoming> + <bpmn:outgoing>Flow_1jeui7e</bpmn:outgoing> + </bpmn:callActivity> + <bpmn:serviceTask id="Activity_0w4hy3d" name="Process Response" camunda:expression="${CnfHealthCheckTasks.processAsyncResponse(InjectExecution.execute(execution, execution.getVariable("gBuildingBlockExecution")))}"> + <bpmn:incoming>Flow_1jeui7e</bpmn:incoming> + <bpmn:outgoing>Flow_0xiyno7</bpmn:outgoing> + </bpmn:serviceTask> + <bpmn:sequenceFlow id="Flow_0xiyno7" sourceRef="Activity_0w4hy3d" targetRef="Event_1dklvvk" /> + <bpmn:sequenceFlow id="Flow_1jeui7e" sourceRef="Activity_08mgs1k" targetRef="Activity_0w4hy3d" /> + </bpmn:process> + <bpmndi:BPMNDiagram id="BPMNDiagram_1"> + <bpmndi:BPMNPlane id="BPMNPlane_1" bpmnElement="HealthCheckBB"> + <bpmndi:BPMNEdge id="Flow_1jeui7e_di" bpmnElement="Flow_1jeui7e"> + <di:waypoint x="600" y="120" /> + <di:waypoint x="680" y="120" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_0xiyno7_di" bpmnElement="Flow_0xiyno7"> + <di:waypoint x="780" y="120" /> + <di:waypoint x="842" y="120" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_1aqdd5k_di" bpmnElement="Flow_1aqdd5k"> + <di:waypoint x="400" y="120" /> + <di:waypoint x="500" y="120" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_0gd6hy6_di" bpmnElement="Flow_0gd6hy6"> + <di:waypoint x="218" y="120" /> + <di:waypoint x="300" y="120" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNShape id="Event_1dklvvk_di" bpmnElement="Event_1dklvvk"> + <dc:Bounds x="842" y="102" width="36" height="36" /> + <bpmndi:BPMNLabel> + <dc:Bounds x="820" y="145" width="85" height="27" /> + </bpmndi:BPMNLabel> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="_BPMNShape_StartEvent_2" bpmnElement="StartEvent_1"> + <dc:Bounds x="182" y="102" width="36" height="36" /> + <bpmndi:BPMNLabel> + <dc:Bounds x="156" y="145" width="90" height="27" /> + </bpmndi:BPMNLabel> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_11hkwkn_di" bpmnElement="Activity_11hkwkn"> + <dc:Bounds x="300" y="80" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_0f7poou_di" bpmnElement="Activity_08mgs1k"> + <dc:Bounds x="500" y="80" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_0w4hy3d_di" bpmnElement="Activity_0w4hy3d"> + <dc:Bounds x="680" y="80" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_1pto2qh_di" bpmnElement="Activity_1pto2qh" isExpanded="true"> + <dc:Bounds x="280" y="250" width="460" height="135" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNEdge id="Flow_05rbrsm_di" bpmnElement="Flow_05rbrsm"> + <di:waypoint x="398" y="324" /> + <di:waypoint x="632" y="324" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNShape id="Event_0929aqj_di" bpmnElement="Event_0929aqj"> + <dc:Bounds x="362" y="306" width="36" height="36" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Event_1s698ql_di" bpmnElement="Event_1s698ql"> + <dc:Bounds x="632" y="306" width="36" height="36" /> + </bpmndi:BPMNShape> + </bpmndi:BPMNPlane> + </bpmndi:BPMNDiagram> +</bpmn:definitions> diff --git a/bpmn/so-bpmn-building-blocks/src/main/resources/subprocess/BuildingBlock/UpdateCnfAai.bpmn b/bpmn/so-bpmn-building-blocks/src/main/resources/subprocess/BuildingBlock/UpdateCnfAai.bpmn new file mode 100644 index 0000000000..01187b06b0 --- /dev/null +++ b/bpmn/so-bpmn-building-blocks/src/main/resources/subprocess/BuildingBlock/UpdateCnfAai.bpmn @@ -0,0 +1,102 @@ +<?xml version="1.0" encoding="UTF-8"?> +<bpmn:definitions xmlns:bpmn="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:camunda="http://camunda.org/schema/1.0/bpmn" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" id="Definitions_0fq2csp" targetNamespace="http://bpmn.io/schema/bpmn" exporter="Camunda Modeler" exporterVersion="4.0.0"> + <bpmn:process id="UpdateCnfAai" name="UpdateCnfAai" isExecutable="true"> + <bpmn:startEvent id="UpdateCnfAai_start" name="UpdateCnfAai_start"> + <bpmn:outgoing>Flow_17d9zpo</bpmn:outgoing> + </bpmn:startEvent> + <bpmn:serviceTask id="Activity_0tu6gf2" name="Prepare for Cnf AAI Update Call" camunda:expression="${CnfAdapterCreateTasks.prepareForCnfUpdateOrDelete(InjectExecution.execute(execution, execution.getVariable("gBuildingBlockExecution")))}"> + <bpmn:incoming>Flow_17d9zpo</bpmn:incoming> + <bpmn:outgoing>Flow_01esiz5</bpmn:outgoing> + </bpmn:serviceTask> + <bpmn:callActivity id="Activity_0gpndy6" name="Call CNFAdapterAsync" calledElement="CNFAdapterAsyncCall"> + <bpmn:extensionElements> + <camunda:in source="apiPath" target="apiPath" /> + <camunda:in source="cnfRequestPayload" target="cnfRequestPayload" /> + <camunda:in source="correlator" target="correlator" /> + <camunda:in source="timeout" target="timeout" /> + <camunda:in source="messageType" target="messageType" /> + <camunda:in source="true" target="isDebugLogEnabled" /> + <camunda:out source="WorkflowException" target="WorkflowException" /> + <camunda:out source="asyncCallbackResponse" target="asyncCallbackResponse" /> + </bpmn:extensionElements> + <bpmn:incoming>Flow_01esiz5</bpmn:incoming> + <bpmn:outgoing>Flow_0tm9une</bpmn:outgoing> + </bpmn:callActivity> + <bpmn:serviceTask id="Activity_0npavuq" name="Process Response" camunda:expression="${CnfAdapterCreateTasks.processCnfUpdateOrDeleteAsyncResponse(InjectExecution.execute(execution, execution.getVariable("gBuildingBlockExecution")))}"> + <bpmn:incoming>Flow_0tm9une</bpmn:incoming> + <bpmn:outgoing>Flow_09shgs4</bpmn:outgoing> + </bpmn:serviceTask> + <bpmn:sequenceFlow id="Flow_01esiz5" sourceRef="Activity_0tu6gf2" targetRef="Activity_0gpndy6" /> + <bpmn:sequenceFlow id="Flow_0tm9une" sourceRef="Activity_0gpndy6" targetRef="Activity_0npavuq" /> + <bpmn:endEvent id="UpdateCnfAai_end" name="UpdateCnfAai_end"> + <bpmn:incoming>Flow_09shgs4</bpmn:incoming> + </bpmn:endEvent> + <bpmn:sequenceFlow id="Flow_09shgs4" sourceRef="Activity_0npavuq" targetRef="UpdateCnfAai_end" /> + <bpmn:sequenceFlow id="Flow_17d9zpo" sourceRef="UpdateCnfAai_start" targetRef="Activity_0tu6gf2" /> + <bpmn:subProcess id="Activity_09xxfqs" name="Error Handling " triggeredByEvent="true"> + <bpmn:startEvent id="Event_1t2fty4"> + <bpmn:outgoing>Flow_1js1xt1</bpmn:outgoing> + <bpmn:errorEventDefinition id="ErrorEventDefinition_1cxu4n4" /> + </bpmn:startEvent> + <bpmn:endEvent id="Event_1xa7ebu"> + <bpmn:incoming>Flow_1js1xt1</bpmn:incoming> + <bpmn:terminateEventDefinition id="TerminateEventDefinition_149n8uo" /> + </bpmn:endEvent> + <bpmn:sequenceFlow id="Flow_1js1xt1" sourceRef="Event_1t2fty4" targetRef="Event_1xa7ebu" /> + </bpmn:subProcess> + </bpmn:process> + <bpmndi:BPMNDiagram id="BPMNDiagram_1"> + <bpmndi:BPMNPlane id="BPMNPlane_1" bpmnElement="UpdateCnfAai"> + <bpmndi:BPMNEdge id="Flow_01esiz5_di" bpmnElement="Flow_01esiz5"> + <di:waypoint x="410" y="120" /> + <di:waypoint x="500" y="120" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_0tm9une_di" bpmnElement="Flow_0tm9une"> + <di:waypoint x="600" y="120" /> + <di:waypoint x="660" y="120" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_09shgs4_di" bpmnElement="Flow_09shgs4"> + <di:waypoint x="760" y="120" /> + <di:waypoint x="842" y="120" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_17d9zpo_di" bpmnElement="Flow_17d9zpo"> + <di:waypoint x="258" y="120" /> + <di:waypoint x="310" y="120" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNShape id="Activity_0tu6gf2_di" bpmnElement="Activity_0tu6gf2"> + <dc:Bounds x="310" y="80" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Event_0gv6qf0_di" bpmnElement="UpdateCnfAai_end"> + <dc:Bounds x="842" y="102" width="36" height="36" /> + <bpmndi:BPMNLabel> + <dc:Bounds x="820" y="145" width="81" height="27" /> + </bpmndi:BPMNLabel> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="_BPMNShape_StartEvent_2" bpmnElement="UpdateCnfAai_start"> + <dc:Bounds x="222" y="102" width="36" height="36" /> + <bpmndi:BPMNLabel> + <dc:Bounds x="195" y="145" width="90" height="27" /> + </bpmndi:BPMNLabel> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_0gpndy6_di" bpmnElement="Activity_0gpndy6"> + <dc:Bounds x="500" y="80" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_0npavuq_di" bpmnElement="Activity_0npavuq"> + <dc:Bounds x="660" y="80" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_09xxfqs_di" bpmnElement="Activity_09xxfqs" isExpanded="true"> + <dc:Bounds x="360" y="250" width="460" height="135" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNEdge id="Flow_1js1xt1_di" bpmnElement="Flow_1js1xt1"> + <di:waypoint x="478" y="324" /> + <di:waypoint x="712" y="324" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNShape id="Event_1t2fty4_di" bpmnElement="Event_1t2fty4"> + <dc:Bounds x="442" y="306" width="36" height="36" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Event_1xa7ebu_di" bpmnElement="Event_1xa7ebu"> + <dc:Bounds x="712" y="306" width="36" height="36" /> + </bpmndi:BPMNShape> + </bpmndi:BPMNPlane> + </bpmndi:BPMNDiagram> +</bpmn:definitions> diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/AnNssmfutils.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/AnNssmfutils.groovy index 540358fde7..a812b37879 100644 --- a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/AnNssmfutils.groovy +++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/AnNssmfutils.groovy @@ -193,7 +193,7 @@ public void createSliceProfilesInAai(DelegateExecution execution) { ANNF_sliceProfileInstance.setServiceType(serviceType) String serviceStatus = "deactivated" ANNF_sliceProfileInstance.setOrchestrationStatus(serviceStatus) - String serviceInstanceLocationid = jsonUtil.getJsonValue(execution.getVariable("ranNfSliceProfile"), "plmnIdList") + String serviceInstanceLocationid = jsonUtil.getJsonValue(execution.getVariable("ranNfSliceProfile"), "pLMNIdList") ANNF_sliceProfileInstance.setServiceInstanceLocationId(jsonUtil.StringArrayToList(serviceInstanceLocationid).get(0)) String serviceRole = "slice-profile-instance" ANNF_sliceProfileInstance.setServiceRole(serviceRole) @@ -213,7 +213,7 @@ public void createSliceProfilesInAai(DelegateExecution execution) { serviceType = jsonUtil.getJsonValue(execution.getVariable("tnFhSliceProfile"), "sST") TNFH_sliceProfileInstance.setServiceType(serviceType) TNFH_sliceProfileInstance.setOrchestrationStatus(serviceStatus) - serviceInstanceLocationid = jsonUtil.getJsonValue(execution.getVariable("tnFhSliceProfile"), "plmnIdList") + serviceInstanceLocationid = jsonUtil.getJsonValue(execution.getVariable("tnFhSliceProfile"), "pLMNIdList") TNFH_sliceProfileInstance.setServiceInstanceLocationId(jsonUtil.StringArrayToList(serviceInstanceLocationid).get(0)) TNFH_sliceProfileInstance.setServiceRole(serviceRole) TNFH_sliceProfileInstance.setEnvironmentContext(snssai) @@ -230,7 +230,7 @@ public void createSliceProfilesInAai(DelegateExecution execution) { serviceType = jsonUtil.getJsonValue(execution.getVariable("tnMhSliceProfile"), "sST") TNMH_sliceProfileInstance.setServiceType(serviceType) TNMH_sliceProfileInstance.setOrchestrationStatus(serviceStatus) - serviceInstanceLocationid = jsonUtil.getJsonValue(execution.getVariable("tnMhSliceProfile"), "plmnIdList") + serviceInstanceLocationid = jsonUtil.getJsonValue(execution.getVariable("tnMhSliceProfile"), "pLMNIdList") TNMH_sliceProfileInstance.setServiceInstanceLocationId(jsonUtil.StringArrayToList(serviceInstanceLocationid).get(0)) TNMH_sliceProfileInstance.setServiceRole(serviceRole) TNMH_sliceProfileInstance.setEnvironmentContext(snssai) diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DeAllocateSliceSubnet.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DeAllocateSliceSubnet.groovy index 7c2f53fbe4..0cb72ab9b4 100644 --- a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DeAllocateSliceSubnet.groovy +++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DeAllocateSliceSubnet.groovy @@ -139,7 +139,8 @@ class DeAllocateSliceSubnet extends AbstractServiceTaskProcessor { ResourceOperationStatus initStatus = new ResourceOperationStatus() initStatus.setServiceId(nsiId) initStatus.setOperationId(jobId) - initStatus.setResourceTemplateUUID(modelUuid) + //initStatus.setResourceTemplateUUID(modelUuid) + initStatus.setResourceInstanceID(nssiId) initStatus.setOperType("Deallocate") requestDBUtil.prepareInitResourceOperationStatus(execution, initStatus) diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateAccessNSSI.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateAccessNSSI.groovy index a4d503a86c..2564b11295 100644 --- a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateAccessNSSI.groovy +++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoAllocateAccessNSSI.groovy @@ -102,7 +102,7 @@ class DoAllocateAccessNSSI extends AbstractServiceTaskProcessor { } String sliceProfileId = jsonUtil.getJsonValue(sliceProfile, "sliceProfileId") def snssaiList = jsonUtil.StringArrayToList(jsonUtil.getJsonValue(sliceProfile, "snssaiList")) - def plmnIdList = jsonUtil.StringArrayToList(jsonUtil.getJsonValue(sliceProfile, "plmnIdList")) + def plmnIdList = jsonUtil.StringArrayToList(jsonUtil.getJsonValue(sliceProfile, "pLMNIdList")) String jsonArray = jsonUtil.getJsonValue(sliceProfile, "coverageAreaTAList") List<Integer> list = new ArrayList<>(); JSONArray arr = new JSONArray(jsonArray); @@ -121,7 +121,7 @@ class DoAllocateAccessNSSI extends AbstractServiceTaskProcessor { } else { execution.setVariable("sliceProfileId", sliceProfileId) execution.setVariable("snssaiList", snssaiList) - execution.setVariable("plmnIdList", plmnIdList) + execution.setVariable("pLMNIdList", plmnIdList) execution.setVariable("coverageAreaTAList", coverageAreaTAList) } String nsiName = jsonUtil.getJsonValue(sliceParams, "nsiInfo.nsiName") @@ -388,7 +388,7 @@ class DoAllocateAccessNSSI extends AbstractServiceTaskProcessor { serviceInfo.addProperty("nsiId", execution.getVariable("nsiId")) serviceInfo.addProperty("nssiName", execution.getVariable("servicename")) serviceInfo.addProperty("sST", execution.getVariable("sst")) - serviceInfo.addProperty("PLMNIdList", objectMapper.writeValueAsString(execution.getVariable("plmnIdList"))) + serviceInfo.addProperty("PLMNIdList", objectMapper.writeValueAsString(execution.getVariable("pLMNIdList"))) serviceInfo.addProperty("globalSubscriberId", execution.getVariable("globalSubscriberId")) serviceInfo.addProperty("subscriptionServiceType", execution.getVariable("subscriptionServiceType")) serviceInfo.addProperty("serviceInvariantUuid", execution.getVariable("modelInvariantUuid")) @@ -558,7 +558,7 @@ class DoAllocateAccessNSSI extends AbstractServiceTaskProcessor { ANServiceInstance.setServiceType(execution.getVariable("sst")) String serviceStatus = "deactivated" ANServiceInstance.setOrchestrationStatus(serviceStatus) - String serviceInstanceLocationid = jsonUtil.getJsonValue(execution.getVariable("sliceProfile"), "plmnIdList") + String serviceInstanceLocationid = jsonUtil.getJsonValue(execution.getVariable("sliceProfile"), "pLMNIdList") ANServiceInstance.setServiceInstanceLocationId(jsonUtil.StringArrayToList(serviceInstanceLocationid).get(0)) String serviceRole = "nssi" ANServiceInstance.setServiceRole(serviceRole) @@ -625,7 +625,7 @@ class DoAllocateAccessNSSI extends AbstractServiceTaskProcessor { ANServiceInstance.setServiceType(execution.getVariable("sst")) String serviceStatus = "deactivated" ANServiceInstance.setOrchestrationStatus(serviceStatus) - String serviceInstanceLocationid = jsonUtil.getJsonValue(execution.getVariable("sliceProfile"), "plmnIdList") + String serviceInstanceLocationid = jsonUtil.getJsonValue(execution.getVariable("sliceProfile"), "pLMNIdList") ANServiceInstance.setServiceInstanceLocationId(serviceInstanceLocationid) String serviceRole = "nssi" ANServiceInstance.setServiceRole(serviceRole) @@ -647,7 +647,7 @@ class DoAllocateAccessNSSI extends AbstractServiceTaskProcessor { ANNFServiceInstance.setServiceInstanceName(sliceInstanceName) ANNFServiceInstance.setServiceType(execution.getVariable("sst")) ANNFServiceInstance.setOrchestrationStatus(serviceStatus) - serviceInstanceLocationid = jsonUtil.getJsonValue(execution.getVariable("ranNfSliceProfile"), "plmnIdList") + serviceInstanceLocationid = jsonUtil.getJsonValue(execution.getVariable("ranNfSliceProfile"), "pLMNIdList") ANNFServiceInstance.setServiceInstanceLocationId(jsonUtil.StringArrayToList(serviceInstanceLocationid).get(0)) ANNFServiceInstance.setServiceRole(serviceRole) snssaiList = execution.getVariable("snssaiList") @@ -735,7 +735,7 @@ class DoAllocateAccessNSSI extends AbstractServiceTaskProcessor { JsonObject serviceInfo = new JsonObject() serviceInfo.addProperty("nsiId", execution.getVariable("nsiId")) serviceInfo.addProperty("sST", execution.getVariable("sst")) - serviceInfo.addProperty("PLMNIdList", objectMapper.writeValueAsString(execution.getVariable("plmnIdList"))) + serviceInfo.addProperty("PLMNIdList", objectMapper.writeValueAsString(execution.getVariable("pLMNIdList"))) serviceInfo.addProperty("globalSubscriberId", execution.getVariable("globalSubscriberId")) serviceInfo.addProperty("subscriptionServiceType", execution.getVariable("subscriptionServiceType")) if(domainType.equals("TN_FH")) { diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoCommonCoreNSSI.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoCommonCoreNSSI.groovy index 646861a6a0..67e4b9227d 100644 --- a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoCommonCoreNSSI.groovy +++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoCommonCoreNSSI.groovy @@ -21,6 +21,7 @@ package org.onap.so.bpmn.infrastructure.scripts import com.fasterxml.jackson.databind.ObjectMapper +import org.camunda.bpm.engine.delegate.BpmnError import org.camunda.bpm.engine.delegate.DelegateExecution import org.json.JSONArray import org.json.JSONObject @@ -42,6 +43,7 @@ import org.onap.so.serviceinstancebeans.* import org.slf4j.Logger import org.slf4j.LoggerFactory +import javax.ws.rs.NotFoundException import javax.ws.rs.core.Response import static org.apache.commons.lang3.StringUtils.isBlank @@ -50,6 +52,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { private final String PREFIX ="DoCommonCoreNSSI" + private static final String SLICE_PROFILE_TEMPLATE = "{\"sliceProfileId\": \"%s\"}" + private static final Logger LOGGER = LoggerFactory.getLogger( DoCommonCoreNSSI.class) private JsonUtils jsonUtil = new JsonUtils() @@ -58,7 +62,7 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { @Override void preProcessRequest(DelegateExecution execution) { - LOGGER.trace("${getPrefix()} Start preProcessRequest") + LOGGER.debug("${getPrefix()} Start preProcessRequest") def currentNSSI = execution.getVariable("currentNSSI") if (!currentNSSI) { @@ -89,19 +93,33 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { // Slice Profile - String sliceProfile = jsonUtil.getJsonValue(execution.getVariable("sliceParams"), "sliceProfile") - if (isBlank(sliceProfile)) { - String msg = "Slice Profile is null" - exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg) - } else { - currentNSSI['sliceProfile'] = sliceProfile + String sliceProfile = execution.getVariable("sliceParams") + + /* if(jsonUtil.jsonValueExists(execution.getVariable("sliceParams"), "sliceProfile")) { + sliceProfile = jsonUtil.getJsonValue(execution.getVariable("sliceParams"), "sliceProfile") } + else { // In case of Deallocate flow or Modify flow with deletion of Slice Profile Instance + if(jsonUtil.jsonValueExists(execution.getVariable("sliceParams"), "sliceProfileId")) { + sliceProfile = String.format(SLICE_PROFILE_TEMPLATE, jsonUtil.getJsonValue(execution.getVariable("sliceParams"), "sliceProfileId")) + } + else { + String msg = "Either Slice Profile or Slice Profile Id should be provided" + exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg) + } + } */ + + LOGGER.debug("sliceProfile=" + sliceProfile) + currentNSSI['sliceProfile'] = sliceProfile // S-NSSAI - def snssaiList = jsonUtil.StringArrayToList(jsonUtil.getJsonValue(sliceProfile, "snssaiList")) + String strList = jsonUtil.getJsonValue(sliceProfile, "snssaiList") + + if(strList != null) { + def snssaiList = jsonUtil.StringArrayToList(strList) - String sNssai = snssaiList.get(0) - currentNSSI['S-NSSAI'] = sNssai + String sNssai = snssaiList.get(0) + currentNSSI['S-NSSAI'] = sNssai + } // Slice Profile id @@ -110,8 +128,7 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { execution.setVariable("currentNSSI", currentNSSI) - - LOGGER.trace("***** ${getPrefix()} Exit preProcessRequest") + LOGGER.debug("***** ${getPrefix()} Exit preProcessRequest") } @@ -120,7 +137,7 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @param execution */ void getNetworkServiceInstance(DelegateExecution execution) { - LOGGER.trace("${getPrefix()} Start getNetworkServiceInstance") + LOGGER.debug("${getPrefix()} Start getNetworkServiceInstance") AAIResourcesClient client = getAAIClient() @@ -144,7 +161,7 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { exceptionUtil.buildAndThrowWorkflowException(execution, 2500, msg) } - LOGGER.trace("${getPrefix()} Exit getNetworkServiceInstance") + LOGGER.debug("${getPrefix()} Exit getNetworkServiceInstance") } @@ -156,6 +173,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @return Network Service Instance */ private ServiceInstance handleNetworkInstance(DelegateExecution execution, String nssiId, AAIResourceUri nssiUri, AAIResourcesClient client ) { + LOGGER.debug("${getPrefix()} Start handleNetworkInstance") + ServiceInstance networkServiceInstance = null def currentNSSI = execution.getVariable("currentNSSI") @@ -169,7 +188,7 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { if (networkServiceInstanceOpt.isPresent()) { networkServiceInstance = networkServiceInstanceOpt.get() - if (networkServiceInstance.getServiceRole() == "Network Service") { // Network Service role + if (networkServiceInstance.getServiceRole() == null /* WorkAround */ || networkServiceInstance.getServiceRole() == "Network Service") { // Network Service role currentNSSI['networkServiceInstanceUri'] = networkServiceInstanceUri break } @@ -180,6 +199,12 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { exceptionUtil.buildAndThrowWorkflowException(execution, 2500, msg) } } + + if (currentNSSI['networkServiceInstanceUri'] == null) { + String msg = String.format("Network Service Instance URI is null") + LOGGER.error(msg) + exceptionUtil.buildAndThrowWorkflowException(execution, 2500, msg) + } } else { String msg = String.format("No relationship presented for NSSI %s in AAI", nssiId) @@ -193,6 +218,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { exceptionUtil.buildAndThrowWorkflowException(execution, 2500, msg) } + LOGGER.debug("${getPrefix()} Exit handleNetworkInstance") + return networkServiceInstance } @@ -202,7 +229,7 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @param execution */ void getConstituteVNFFromNetworkServiceInst(DelegateExecution execution) { - LOGGER.trace("${getPrefix()} Start getConstituteVNFFromNetworkServiceInst") + LOGGER.debug("${getPrefix()} Start getConstituteVNFFromNetworkServiceInst") def currentNSSI = execution.getVariable("currentNSSI") @@ -211,6 +238,7 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { AAIResourceUri networkServiceInstanceUri = (AAIResourceUri)currentNSSI['networkServiceInstanceUri'] AAIResultWrapper wrapper = client.get(networkServiceInstanceUri); Optional<Relationships> relationships = wrapper.getRelationships() + if (relationships.isPresent()) { for (AAIResourceUri constituteVnfUri : relationships.get().getRelatedUris(Types.GENERIC_VNF)) { currentNSSI['constituteVnfUri'] = constituteVnfUri @@ -234,126 +262,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { exceptionUtil.buildAndThrowWorkflowException(execution, 2500, msg) } - LOGGER.trace("${getPrefix()} Exit getConstituteVNFFromNetworkServiceInst") - - } - - - /** - * Retrieves NSSI associated profiles from AAI - * @param execution - */ - void getNSSIAssociatedProfiles(DelegateExecution execution) { - LOGGER.trace("${getPrefix()} Start getNSSIAssociatedProfiles") - - List<SliceProfile> associatedProfiles = new ArrayList<>() - - AAIResourcesClient client = getAAIClient() - - def currentNSSI = execution.getVariable("currentNSSI") - - ServiceInstance nssi = (ServiceInstance)currentNSSI['nssi'] - - String nssiId = currentNSSI['nssiId'] - - // NSSI - AAIResourceUri nssiUri = AAIUriFactory.createResourceUri(Types.SERVICE_INSTANCE.getFragment(nssiId)) - AAIResultWrapper nssiWrapper = client.get(nssiUri) - Optional<Relationships> nssiRelationships = nssiWrapper.getRelationships() - - if (nssiRelationships.isPresent()) { - // Allotted Resource - for (AAIResourceUri allottedResourceUri : nssiRelationships.get().getRelatedUris(Types.ALLOTTED_RESOURCE)) { - AAIResultWrapper arWrapper = client.get(allottedResourceUri) - Optional<Relationships> arRelationships = arWrapper.getRelationships() - - boolean isFound = false - if(arRelationships.isPresent()) { - // Slice Profile Instance - for (AAIResourceUri sliceProfileInstanceUri : arRelationships.get().getRelatedUris(Types.SERVICE_INSTANCE)) { - Optional<ServiceInstance> sliceProfileInstanceOpt = client.get(ServiceInstance.class, sliceProfileInstanceUri) - - if (sliceProfileInstanceOpt.isPresent()) { - ServiceInstance sliceProfileInstance = sliceProfileInstanceOpt.get() - if(sliceProfileInstance.getServiceRole().equals("slice-profile-instance")) { // Service instance as a Slice Profile Instance - associatedProfiles = sliceProfileInstance.getSliceProfiles()?.getSliceProfile() - - currentNSSI['sliceProfileInstanceUri'] = sliceProfileInstanceUri - - isFound = true - break // Should be only one - } - } - else { - exceptionUtil.buildAndThrowWorkflowException(execution, 500, "No Slice Profile Instance found") - } - } - } - else { - exceptionUtil.buildAndThrowWorkflowException(execution, 500, "No relationships found for Allotted Resource") - } - - if(isFound) { - break - } - } - } - else { - exceptionUtil.buildAndThrowWorkflowException(execution, 500, "No relationships found for nssi id = " + nssiId) - } - - if(associatedProfiles.isEmpty()) { - String msg = String.format("No associated profiles found for NSSI %s in AAI", nssi.getServiceInstanceId()) - LOGGER.error(msg) - exceptionUtil.buildAndThrowWorkflowException(execution, 2500, msg) - } - else { - currentNSSI['associatedProfiles'] = associatedProfiles - } - - LOGGER.trace("${getPrefix()} Exit getNSSIAssociatedProfiles") - } - - - /** - * Calculates a final list of S-NSSAI - * @param execution - */ - void calculateSNSSAI(DelegateExecution execution) { - LOGGER.trace("${getPrefix()} Start calculateSNSSAI") - - def currentNSSI = execution.getVariable("currentNSSI") - - List<SliceProfile> associatedProfiles = (List<SliceProfile>)currentNSSI['associatedProfiles'] - - String currentSNSSAI = currentNSSI['S-NSSAI'] - - List<String> snssais = new ArrayList<>() - - String isCreateSliceProfileInstanceVar = execution.getVariable("isCreateSliceProfileInstance" ) // Not exist in case of Deallocate - - boolean isCreateSliceProfileInstance = Boolean.parseBoolean(isCreateSliceProfileInstanceVar) - - if(isCreateSliceProfileInstance) { // Slice Profile Instance has to be created - for (SliceProfile associatedProfile : associatedProfiles) { - snssais.add(associatedProfile.getSNssai()) - } - - snssais.add(currentSNSSAI) - } - else { // Slice profile instance has to be deleted - for (SliceProfile associatedProfile : associatedProfiles) { - if (!associatedProfile.getSNssai().equals(currentSNSSAI)) { // not current S-NSSAI - snssais.add(associatedProfile.getSNssai()) - } else { - currentNSSI['sliceProfileS-NSSAI'] = associatedProfile - } - } - } - - currentNSSI['S-NSSAIs'] = snssais + LOGGER.debug("${getPrefix()} Exit getConstituteVNFFromNetworkServiceInst") - LOGGER.trace("${getPrefix()} Exit calculateSNSSAI") } @@ -362,7 +272,7 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @param execution */ void invokePUTServiceInstance(DelegateExecution execution) { - LOGGER.trace("${getPrefix()} Start invokePUTServiceInstance") + LOGGER.debug("${getPrefix()} Start invokePUTServiceInstance") def currentNSSI = execution.getVariable("currentNSSI") @@ -372,15 +282,18 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { ServiceInstance networkServiceInstance = (ServiceInstance)currentNSSI['networkServiceInstance'] - String url = String.format("${nsmfЕndPoint}/serviceInstantiation/v7/serviceInstances/%s", networkServiceInstance.getServiceInstanceId()) + GenericVnf constituteVnf = (GenericVnf)currentNSSI['constituteVnf'] - currentNSSI['putServiceInstanceURL'] = url + // http://so.onap:8080/onap/so/infra/serviceInstantiation/v7/serviceInstances/de6a0aa2-19f2-41fe-b313-a5a9f159acd7/vnfs/3abbb373-8d33-4977-aa4b-2bfee496b6d5 + String url = String.format("${nsmfЕndPoint}/serviceInstantiation/v7/serviceInstances/%s/vnfs/%s", networkServiceInstance.getServiceInstanceId(), constituteVnf.getVnfId()) String msoKey = UrnPropertiesReader.getVariable("mso.msoKey", execution) - String basicAuth = UrnPropertiesReader.getVariable("mso.infra.endpoint.auth", execution) - def authHeader = "" - String basicAuthValue = encryptBasicAuth(basicAuth, msoKey) //utils.encrypt(basicAuth, msoKey) + String basicAuth = UrnPropertiesReader.getVariable("mso.adapters.po.auth", execution) + + def authHeader = utils.getBasicAuth(basicAuth, msoKey) // "" + /* String basicAuthValue = encryptBasicAuth(basicAuth, msoKey) //utils.encrypt(basicAuth, msoKey) + String responseAuthHeader = getAuthHeader(execution, basicAuthValue, msoKey) //utils.getBasicAuth(basicAuthValue, msoKey) String errorCode = jsonUtil.getJsonValue(responseAuthHeader, "errorCode") @@ -389,11 +302,15 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { } else { exceptionUtil.buildAndThrowWorkflowException(execution, Integer.parseInt(errorCode), jsonUtil.getJsonValue(responseAuthHeader, "errorMessage")) - } + } */ def requestDetails = "" + String prepareRequestDetailsResponse = prepareRequestDetails(execution) - errorCode = jsonUtil.getJsonValue(prepareRequestDetailsResponse, "errorCode") + LOGGER.debug("invokePUTServiceInstance: prepareRequestDetailsResponse=" + prepareRequestDetailsResponse) + + String errorCode = jsonUtil.getJsonValue(prepareRequestDetailsResponse, "errorCode") + LOGGER.debug("invokePUTServiceInstance: errorCode=" + errorCode) if(errorCode == null || errorCode.isEmpty()) { // No error requestDetails = prepareRequestDetailsResponse } @@ -402,15 +319,13 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { } String callPUTServiceInstanceResponse = callPUTServiceInstance(url, authHeader, requestDetails) - String putServiceInstanceResponse = "" - if(errorCode == null || errorCode.isEmpty()) { // No error - putServiceInstanceResponse = callPUTServiceInstanceResponse - } - else { - LOGGER.error(jsonUtil.getJsonValue(callPUTServiceInstanceResponse, "errorMessage")) - exceptionUtil.buildAndThrowWorkflowException(execution, Integer.parseInt(errorCode), jsonUtil.getJsonValue(callPUTServiceInstanceResponse, "errorMessage")) - } + String macroOperationId = jsonUtil.getJsonValue(callPUTServiceInstanceResponse, "requestReferences.requestId") + String requestSelfLink = jsonUtil.getJsonValue(callPUTServiceInstanceResponse, "requestReferences.requestSelfLink") + + execution.setVariable("macroOperationId", macroOperationId) + execution.setVariable("requestSelfLink", requestSelfLink) + currentNSSI['requestSelfLink'] = requestSelfLink } catch (any) { String msg = "Exception in ${getPrefix()}.invokePUTServiceInstance. " + any.getCause() @@ -418,29 +333,36 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg) } - LOGGER.trace("${getPrefix()} Exit invokePUTServiceInstance") + LOGGER.debug("${getPrefix()} Exit invokePUTServiceInstance") } String callPUTServiceInstance(String url, String authHeader, String requestDetailsStr) { + LOGGER.debug("${getPrefix()} Start callPUTServiceInstance") + String errorCode = "" String errorMessage = "" String response + LOGGER.debug("callPUTServiceInstance: url = " + url) + LOGGER.debug("callPUTServiceInstance: authHeader = " + authHeader) + try { - HttpClient httpClient = getHttpClientFactory().newJsonClient(new URL(url), ONAPComponents.EXTERNAL) + HttpClient httpClient = getHttpClientFactory().newJsonClient(new URL(url), ONAPComponents.SO) httpClient.addAdditionalHeader("Authorization", authHeader) httpClient.addAdditionalHeader("Accept", "application/json") - Response httpResponse = httpClient.put(requestDetailsStr) // check http code ??? - + Response httpResponse = httpClient.put(requestDetailsStr) - if (httpResponse.hasEntity()) { + int soResponseCode = httpResponse.getStatus() + if (soResponseCode >= 200 && soResponseCode < 204 && httpResponse.hasEntity()) { response = httpResponse.readEntity(String.class) + + LOGGER.debug("callPUTServiceInstance: response = " + response) } else { errorCode = 500 - errorMessage = "No response received." + errorMessage = "Response code is " + soResponseCode response = "{\n" + " \"errorCode\": \"${errorCode}\",\n" + @@ -461,6 +383,7 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { return response + LOGGER.debug("${getPrefix()} Exit callPUTServiceInstance") } @@ -471,6 +394,7 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @return ModelInfo */ ModelInfo prepareModelInfo(DelegateExecution execution) { + LOGGER.debug("${getPrefix()} Start prepareModelInfo") def currentNSSI = execution.getVariable("currentNSSI") ServiceInstance networkServiceInstance = (ServiceInstance)currentNSSI['networkServiceInstance'] @@ -491,6 +415,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { modelInfo.setModelVersion(modelVerOpt.get().getModelVersion()) } + LOGGER.debug("${getPrefix()} Exit prepareModelInfo") + return modelInfo } @@ -501,6 +427,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @return SubscriberInfo */ SubscriberInfo prepareSubscriberInfo(DelegateExecution execution) { + LOGGER.debug("${getPrefix()} Start prepareSubscriberInfo") + def currentNSSI = execution.getVariable("currentNSSI") String globalSubscriberId = execution.getVariable("globalSubscriberId") @@ -545,6 +473,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { } */ + LOGGER.debug("${getPrefix()} Exit prepareSubscriberInfo") + return subscriberInfo } @@ -555,6 +485,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @return RequestInfo */ RequestInfo prepareRequestInfo(DelegateExecution execution, ServiceInstance networkServiceInstance) { + LOGGER.debug("${getPrefix()} Start prepareRequestInfo") + def currentNSSI = execution.getVariable("currentNSSI") String productFamilyId = execution.getVariable("productFamilyId") @@ -566,6 +498,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { requestInfo.setProductFamilyId(productFamilyId) requestInfo.setRequestorId("NBI") + LOGGER.debug("${getPrefix()} Exit prepareRequestInfo") + return requestInfo } @@ -577,6 +511,7 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @return ModelInfo */ ModelInfo prepareServiceModelInfo(ServiceInstance networkServiceInstance, ModelInfo modelInfo) { + LOGGER.debug("${getPrefix()} Start prepareServiceModelInfo") ModelInfo serviceModelInfo = new ModelInfo() serviceModelInfo.setModelType(ModelType.service) @@ -586,6 +521,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { serviceModelInfo.setModelName(modelInfo.getModelName()) serviceModelInfo.setModelVersion(modelInfo.getModelVersion()) + LOGGER.debug("${getPrefix()} Exit prepareServiceModelInfo") + return serviceModelInfo } @@ -596,6 +533,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @return CloudConfiguration */ CloudConfiguration prepareCloudConfiguration(DelegateExecution execution) { + LOGGER.debug("${getPrefix()} Start prepareCloudConfiguration") + def currentNSSI = execution.getVariable("currentNSSI") CloudConfiguration cloudConfiguration = new CloudConfiguration() @@ -603,6 +542,7 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { AAIResourcesClient client = getAAIClient() AAIResourceUri constituteVnfUri = currentNSSI['constituteVnfUri'] + AAIResultWrapper wrapper = client.get(constituteVnfUri) Optional<Relationships> cloudRegionRelationshipsOps = wrapper.getRelationships() @@ -617,9 +557,29 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { if (cloudRegionrOpt.isPresent()) { cloudRegion = cloudRegionrOpt.get() cloudConfiguration.setLcpCloudRegionId(cloudRegion.getCloudRegionId()) - for (Tenant tenant : cloudRegion.getTenants().getTenant()) { - cloudConfiguration.setTenantId(tenant.getTenantId()) - break // only one is required + + if(cloudRegion.getTenants() != null && cloudRegion.getTenants().getTenant() != null) { + for (Tenant tenant : cloudRegion.getTenants().getTenant()) { + cloudConfiguration.setTenantId(tenant.getTenantId()) + cloudConfiguration.setTenantName(tenant.getTenantName()) + break // only one is required + } + } + else { + List<AAIResourceUri> tenantRelatedAAIUris = cloudRegionRelationshipsOps.get().getRelatedUris(Types.TENANT) + if (!(tenantRelatedAAIUris == null || tenantRelatedAAIUris.isEmpty())) { + Optional<Tenant> tenantOpt = client.get(Tenant.class, tenantRelatedAAIUris.get(0)) + Tenant tenant = null + if (tenantOpt.isPresent()) { + tenant = tenantOpt.get() + + LOGGER.debug("prepareCloudConfiguration: tenantId=" + tenant.getTenantId()) + LOGGER.debug("prepareCloudConfiguration: tenantName=" + tenant.getTenantName()) + + cloudConfiguration.setTenantId(tenant.getTenantId()) + cloudConfiguration.setTenantName(tenant.getTenantName()) + } + } } cloudConfiguration.setCloudOwner(cloudRegion.getCloudOwner()) @@ -627,6 +587,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { } } + LOGGER.debug("${getPrefix()} Exit prepareCloudConfiguration") + return cloudConfiguration } @@ -638,33 +600,100 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @return List<VfModules> */ List<org.onap.so.serviceinstancebeans.VfModules> prepareVfModules(DelegateExecution execution, GenericVnf constituteVnf) { + LOGGER.debug("${getPrefix()} Start prepareVfModules") AAIResourcesClient client = getAAIClient() + def currentNSSI = execution.getVariable("currentNSSI") + List<org.onap.so.serviceinstancebeans.VfModules> vfModuless = new ArrayList<>() - for (VfModule vfModule : constituteVnf.getVfModules().getVfModule()) { - org.onap.so.serviceinstancebeans.VfModules vfmodules = new org.onap.so.serviceinstancebeans.VfModules() - ModelInfo vfModuleModelInfo = new ModelInfo() - vfModuleModelInfo.setModelInvariantUuid(vfModule.getModelInvariantId()) - vfModuleModelInfo.setModelCustomizationId(vfModule.getModelCustomizationId()) + ServiceInstance networkServiceInstance = (ServiceInstance)currentNSSI['networkServiceInstance'] + + String networkServiceModelInvariantUuid = networkServiceInstance.getModelInvariantId() + + String serviceVnfs=""; + String msg="" + try{ + CatalogDbUtils catalogDbUtils = getCatalogDbUtilsFactory().create() + + String json = catalogDbUtils.getServiceResourcesByServiceModelInvariantUuidString(execution, networkServiceModelInvariantUuid) + LOGGER.debug("***** JSON IS: "+json) - AAIResourceUri vfModuleUrl = AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.serviceDesignAndCreation().model(vfModule.getModelInvariantId()).modelVer(vfModule.getModelVersionId())) + serviceVnfs = jsonUtil.getJsonValue(json, "serviceResources.serviceVnfs") ?: "" - Optional<ModelVer> vfModuleModelVerOpt = client.get(ModelVer.class, vfModuleUrl) + ObjectMapper mapper = new ObjectMapper() - if (vfModuleModelVerOpt.isPresent()) { - vfModuleModelInfo.setModelVersionId(vfModuleModelVerOpt.get().getModelVersionId()) - vfModuleModelInfo.setModelName(vfModuleModelVerOpt.get().getModelName()) - vfModuleModelInfo.setModelVersion(vfModuleModelVerOpt.get().getModelVersion()) + List<Object> vnfList = mapper.readValue(serviceVnfs, List.class) + LOGGER.debug("vnfList: "+vnfList) + + Map vnfMap = vnfList.get(0) + ModelInfo vnfModelInfo = vnfMap.get("modelInfo") + vnfModelInfo.setModelCustomizationId(vnfModelInfo.getModelCustomizationUuid()) + vnfModelInfo.setModelVersionId(vnfModelInfo.getModelId()) + LOGGER.debug("vnfModelInfo "+vnfModelInfo) + + //List of VFModules + List<Map<String, Object>> vfModuleList = vnfMap.get("vfModules") + LOGGER.debug("vfModuleList "+vfModuleList) + + //List of VfModules + List<ModelInfo> vfModelInfoList = new ArrayList<>() + + //Traverse VFModules List and add in vfModelInfoList + for (vfModule in vfModuleList) { + ModelInfo vfModelInfo = vfModule.get("modelInfo") + vfModelInfo.setModelCustomizationId(vfModelInfo.getModelCustomizationUuid()) + vfModelInfo.setModelVersionId(vfModelInfo.getModelId()) + LOGGER.debug("vfModelInfo "+vfModelInfo) + vfModelInfoList.add(vfModelInfo) } - vfmodules.setModelInfo(vfModuleModelInfo) - vfmodules.setInstanceName(vfModule.getVfModuleName()) + for (ModelInfo vfModuleModelInfo : vfModelInfoList) { + org.onap.so.serviceinstancebeans.VfModules vfModules = new org.onap.so.serviceinstancebeans.VfModules() + vfModules.setModelInfo(vfModuleModelInfo) + vfModules.setInstanceName(vfModuleModelInfo.getModelName()) + + List<Map<String, Object>> vfModuleInstanceParams = new ArrayList<>() + vfModules.setInstanceParams(vfModuleInstanceParams) + vfModuless.add(vfModules) + } - vfModuless.add(vfmodules) + } catch (Exception ex){ + msg = "Exception in prepareVfModules " + ex.getMessage() + LOGGER.error(msg) + exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg) } + /* + List<org.onap.so.serviceinstancebeans.VfModules> vfModuless = new ArrayList<>() + if(constituteVnf.getVfModules() != null && constituteVnf.getVfModules().getVfModule() != null) { + for (VfModule vfModule : constituteVnf.getVfModules().getVfModule()) { + org.onap.so.serviceinstancebeans.VfModules vfmodules = new org.onap.so.serviceinstancebeans.VfModules() + + ModelInfo vfModuleModelInfo = new ModelInfo() + vfModuleModelInfo.setModelInvariantUuid(vfModule.getModelInvariantId()) + vfModuleModelInfo.setModelCustomizationId(vfModule.getModelCustomizationId()) + + AAIResourceUri vfModuleUrl = AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.serviceDesignAndCreation().model(vfModule.getModelInvariantId()).modelVer(vfModule.getModelVersionId())) + + Optional<ModelVer> vfModuleModelVerOpt = client.get(ModelVer.class, vfModuleUrl) + + if (vfModuleModelVerOpt.isPresent()) { + vfModuleModelInfo.setModelVersionId(vfModuleModelVerOpt.get().getModelVersionId()) + vfModuleModelInfo.setModelName(vfModuleModelVerOpt.get().getModelName()) + vfModuleModelInfo.setModelVersion(vfModuleModelVerOpt.get().getModelVersion()) + } + vfmodules.setModelInfo(vfModuleModelInfo) + + vfmodules.setInstanceName(vfModule.getVfModuleName()) + + vfModuless.add(vfmodules) + } + } */ + + LOGGER.debug("${getPrefix()} Exit prepareVfModules") + return vfModuless } @@ -676,6 +705,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @return ModelInfo */ ModelInfo prepareVNFModelInfo(DelegateExecution execution, GenericVnf constituteVnf) { + LOGGER.debug("${getPrefix()} Start prepareVNFModelInfo") + ModelInfo vnfModelInfo = new ModelInfo() AAIResourcesClient client = getAAIClient() @@ -694,11 +725,15 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { vnfModelInfo.setModelVersion(vnfModelVerOpt.get().getModelVersion()) } + LOGGER.debug("${getPrefix()} Exit prepareVNFModelInfo") + return vnfModelInfo } List<Map<String, Object>> prepareInstanceParams(DelegateExecution execution) { + LOGGER.debug("${getPrefix()} Start prepareInstanceParams") + def currentNSSI = execution.getVariable("currentNSSI") List<Map<String, Object>> instanceParams = new ArrayList<>() @@ -734,6 +769,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { instanceParamsMap.put("supportedNssai", supportedNssaiDetailsStr) instanceParams.add(instanceParamsMap) + LOGGER.debug("${getPrefix()} Exit prepareInstanceParams") + return instanceParams } @@ -743,6 +780,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @return Resources */ Resources prepareResources(DelegateExecution execution) { + LOGGER.debug("${getPrefix()} Start prepareResources") + def currentNSSI = execution.getVariable("currentNSSI") Resources resources = new Resources() @@ -781,6 +820,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { vnfs.add(vnf) resources.setVnfs(vnfs) + LOGGER.debug("${getPrefix()} Exit prepareResources") + return resources } @@ -790,6 +831,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @return Service */ org.onap.so.serviceinstancebeans.Service prepareService(DelegateExecution execution, ServiceInstance networkServiceInstance, ModelInfo modelInfo) { + LOGGER.debug("${getPrefix()} Start prepareService") + org.onap.so.serviceinstancebeans.Service service = new org.onap.so.serviceinstancebeans.Service() // Model Info @@ -800,6 +843,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { // Resources service.setResources(prepareResources(execution)) + LOGGER.debug("${getPrefix()} Exit prepareService") + return service } @@ -811,6 +856,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @return RequestParameters */ RequestParameters prepareRequestParameters(DelegateExecution execution, ServiceInstance networkServiceInstance, ModelInfo modelInfo) { + LOGGER.debug("${getPrefix()} Start prepareRequestParameters") + def currentNSSI = execution.getVariable("currentNSSI") RequestParameters requestParameters = new RequestParameters() @@ -834,6 +881,10 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { userParams.add(serviceMap) requestParameters.setUserParams(userParams) + requestParameters.setaLaCarte(false) + + LOGGER.debug("${getPrefix()} Exit prepareRequestParameters") + return requestParameters } @@ -844,6 +895,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @return OwningEntity */ org.onap.so.serviceinstancebeans.OwningEntity prepareOwningEntity(DelegateExecution execution) { + LOGGER.debug("${getPrefix()} Start prepareOwningEntity") + def currentNSSI = execution.getVariable("currentNSSI") AAIResourcesClient client = getAAIClient() @@ -866,6 +919,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { } } + LOGGER.debug("${getPrefix()} Exit prepareOwningEntity") + return owningEntity } @@ -876,6 +931,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @return Project */ org.onap.so.serviceinstancebeans.Project prepareProject(DelegateExecution execution) { + LOGGER.debug("${getPrefix()} Start prepareProject") + def currentNSSI = execution.getVariable("currentNSSI") AAIResourcesClient client = getAAIClient() @@ -898,6 +955,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { } } + LOGGER.debug("${getPrefix()} Exit prepareProject") + return project } @@ -908,6 +967,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @return */ String prepareRequestDetails(DelegateExecution execution) { + LOGGER.debug("${getPrefix()} Start prepareRequestDetails") + String errorCode = "" String errorMessage = "" String response @@ -941,9 +1002,12 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { // Project requestDetails.setProject(prepareProject(execution)) + Map<String, Object> requestDetailsMap = new LinkedHashMap<>() + requestDetailsMap.put("requestDetails", requestDetails) + ObjectMapper mapper = new ObjectMapper() - response = mapper.writeValueAsString(requestDetails) + response = mapper.writeValueAsString(requestDetailsMap) } catch (any) { String msg = "Exception in ${getPrefix()}.prepareRequestDetails. " + any.getCause() @@ -956,6 +1020,8 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { } + LOGGER.debug("${getPrefix()} Exit prepareRequestDetails") + return response } @@ -990,60 +1056,145 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { /** - * Removes Slice Profile association with NSSI + * Retrieves NSSI associated profiles from AAI * @param execution */ - void removeSPAssociationWithNSSI(DelegateExecution execution) { - LOGGER.trace("${getPrefix()} Start removeSPAssociationWithNSSI") + void getNSSIAssociatedProfiles(DelegateExecution execution) { + LOGGER.debug("${getPrefix()} Start getNSSIAssociatedProfiles") + + List<SliceProfile> associatedProfiles = new ArrayList<>() AAIResourcesClient client = getAAIClient() def currentNSSI = execution.getVariable("currentNSSI") + ServiceInstance nssi = (ServiceInstance)currentNSSI['nssi'] + String nssiId = currentNSSI['nssiId'] + + String givenSliceProfileId = currentNSSI['sliceProfileId'] + + // NSSI AAIResourceUri nssiUri = AAIUriFactory.createResourceUri(Types.SERVICE_INSTANCE.getFragment(nssiId)) + AAIResultWrapper nssiWrapper = client.get(nssiUri) + Optional<Relationships> nssiRelationships = nssiWrapper.getRelationships() + + if (nssiRelationships.isPresent()) { + // Allotted Resource + for (AAIResourceUri allottedResourceUri : nssiRelationships.get().getRelatedUris(Types.ALLOTTED_RESOURCE)) { + AAIResultWrapper arWrapper = client.get(allottedResourceUri) + Optional<Relationships> arRelationships = arWrapper.getRelationships() + + if(arRelationships.isPresent()) { + // Slice Profile Instance + for (AAIResourceUri sliceProfileInstanceUri : arRelationships.get().getRelatedUris(Types.SERVICE_INSTANCE)) { + Optional<ServiceInstance> sliceProfileInstanceOpt = client.get(ServiceInstance.class, sliceProfileInstanceUri) + + if (sliceProfileInstanceOpt.isPresent()) { + ServiceInstance sliceProfileInstance = sliceProfileInstanceOpt.get() + if(sliceProfileInstance.getServiceRole().equals("slice-profile-instance")) { // Service instance as a Slice Profile Instance - AAIResourceUri sliceProfileInstanceUri = (AAIResourceUri)currentNSSI['sliceProfileInstanceUri'] + String globalSubscriberId = execution.getVariable("globalSubscriberId") + String subscriptionServiceType = execution.getVariable("subscriptionServiceType") - Optional<ServiceInstance> sliceProfileInstanceOpt = client.get(ServiceInstance.class, sliceProfileInstanceUri) - if (sliceProfileInstanceOpt.isPresent()) { - ServiceInstance sliceProfileInstance = sliceProfileInstanceOpt.get() + org.onap.aaiclient.client.generated.fluentbuilders.SliceProfiles sliceProfilesType = + AAIFluentTypeBuilder.business().customer(globalSubscriberId).serviceSubscription(subscriptionServiceType).serviceInstance(sliceProfileInstance.getServiceInstanceId()).sliceProfiles() - List<SliceProfile> associatedProfiles = sliceProfileInstance.getSliceProfiles()?.getSliceProfile() + def sliceProfilesUri = AAIUriFactory.createResourceUri(sliceProfilesType) + LOGGER.debug("client.exists(sliceProfilesUri = " + client.exists(sliceProfilesUri)) + if (!client.exists(sliceProfilesUri)) { + exceptionUtil.buildAndThrowWorkflowException(execution, 2500, "Slice Profiles URI doesn't exist") + } - String currentSNSSAI = currentNSSI['S-NSSAI'] + AAIResultWrapper sliceProfilesWrapper = client.get(sliceProfilesUri) + Optional<SliceProfiles> sliceProfilesOpt = sliceProfilesWrapper.asBean(SliceProfiles.class) + if(sliceProfilesOpt.isPresent()) { + SliceProfiles sliceProfiles = sliceProfilesOpt.get() - if(!(associatedProfiles == null || associatedProfiles.isEmpty())) { - // Removes slice profile which contains given S-NSSAI and updates Slice Profile Instance - associatedProfiles.removeIf({ associatedProfile -> (associatedProfile.getSNssai().equals(currentSNSSAI)) }) + LOGGER.debug("getNSSIAssociatedProfiles: sliceProfiles.getSliceProfile().size() = " + sliceProfiles.getSliceProfile().size()) + LOGGER.debug("getNSSIAssociatedProfiles: givenSliceProfileId = " + givenSliceProfileId) + for(SliceProfile sliceProfile: sliceProfiles.getSliceProfile()) { + LOGGER.debug("getNSSIAssociatedProfiles: sliceProfile.getProfileId() = " + sliceProfile.getProfileId()) + if(sliceProfile.getProfileId().equals(givenSliceProfileId)) { // Slice profile id equals to received slice profile id + currentNSSI['sliceProfileInstanceUri'] = sliceProfileInstanceUri + } - try { - client.update(sliceProfileInstanceUri, sliceProfileInstance) + } - currentNSSI['sliceProfileInstance'] = sliceProfileInstance - } catch (Exception e) { - exceptionUtil.buildAndThrowWorkflowException(execution, 25000, "Exception occured while Slice Profile association with NSSI update call: " + e.getMessage()) + associatedProfiles.addAll(sliceProfiles.getSliceProfile()) // Adds all slice profiles + } + + } + } + else { + exceptionUtil.buildAndThrowWorkflowException(execution, 500, "No Slice Profile Instance found") + } + } + } + else { + exceptionUtil.buildAndThrowWorkflowException(execution, 500, "No relationships found for Allotted Resource") } - } - else { - exceptionUtil.buildAndThrowWorkflowException(execution, 500, "No slice profiles found") - } + } } else { - exceptionUtil.buildAndThrowWorkflowException(execution, 500, "No slice profile instance found") + exceptionUtil.buildAndThrowWorkflowException(execution, 500, "No relationships found for nssi id = " + nssiId) } - // Removes SLice Profile Instance association with NSSI - try { - client.disconnect(nssiUri, sliceProfileInstanceUri) + checkAssociatedProfiles(execution, associatedProfiles, nssi) + + currentNSSI['associatedProfiles'] = associatedProfiles + + LOGGER.debug("${getPrefix()} Exit getNSSIAssociatedProfiles") + } + + + void checkAssociatedProfiles(DelegateExecution execution, List<SliceProfile> associatedProfiles, ServiceInstance nssi) {} + + + /** + * Removes Slice Profile association with NSSI + * @param execution + */ + void removeSPAssociationWithNSSI(DelegateExecution execution) { + LOGGER.debug("${getPrefix()} Start removeSPAssociationWithNSSI") + + AAIResourcesClient client = getAAIClient() + + def currentNSSI = execution.getVariable("currentNSSI") + + String nssiId = currentNSSI['nssiId'] + AAIResourceUri nssiUri = AAIUriFactory.createResourceUri(Types.SERVICE_INSTANCE.getFragment(nssiId)) + + String isTerminateNSSIVar = execution.getVariable("isTerminateNSSI" ) + + boolean isTerminateNSSI = Boolean.parseBoolean(isTerminateNSSIVar) + + AAIResourceUri sliceProfileInstanceUri = null + if(!isTerminateNSSI) { // In case of NSSI non-termination associated Slice Profile Instance should be presented + def spURI = currentNSSI['sliceProfileInstanceUri'] + if(spURI != null) { + sliceProfileInstanceUri = (AAIResourceUri)spURI + } + else { + String msg = "Slice Profile URI not found" + LOGGER.error(msg) + exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg) + } } - catch (Exception e) { - exceptionUtil.buildAndThrowWorkflowException(execution, 25000, "Exception occured while Slice Profile Instance association with NSSI dosconnect call: " + e.getMessage()) + + // Removes SLice Profile Instance association with NSSI + if(sliceProfileInstanceUri != null) { // NSSI should not be terminated + try { + client.disconnect(nssiUri, sliceProfileInstanceUri) + } + catch (Exception e) { + exceptionUtil.buildAndThrowWorkflowException(execution, 25000, "Exception occured while Slice Profile Instance association with NSSI dosconnect call: " + e.getMessage()) + } } - LOGGER.trace("${getPrefix()} Exit removeSPAssociationWithNSSI") + LOGGER.debug("${getPrefix()} Exit removeSPAssociationWithNSSI") } @@ -1052,21 +1203,38 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @param execution */ void deleteSliceProfileInstance(DelegateExecution execution) { - LOGGER.trace("${getPrefix()} Start deleteSliceProfileInstance") + LOGGER.debug("${getPrefix()} Start deleteSliceProfileInstance") AAIResourcesClient client = getAAIClient() def currentNSSI = execution.getVariable("currentNSSI") - AAIResourceUri sliceProfileInstanceURI = (AAIResourceUri)currentNSSI['sliceProfileInstanceUri'] + String isTerminateNSSIVar = execution.getVariable("isTerminateNSSI" ) - try { - client.delete(sliceProfileInstanceURI) - }catch(Exception e){ - exceptionUtil.buildAndThrowWorkflowException(execution, 25000, "Exception occured while Slice Profile Instance delete call: " + e.getMessage()) + boolean isTerminateNSSI = Boolean.parseBoolean(isTerminateNSSIVar) + + AAIResourceUri sliceProfileInstanceUri = null + if(!isTerminateNSSI) { // In case of NSSI non-termination associated Slice Profile Instance should be presented + def spURI = currentNSSI['sliceProfileInstanceUri'] + if(spURI != null) { + sliceProfileInstanceUri = (AAIResourceUri)spURI + } + else { + String msg = "Slice Profile URI not found" + LOGGER.error(msg) + exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg) + } } - LOGGER.trace("${getPrefix()} Exit deleteSliceProfileInstance") + if(sliceProfileInstanceUri != null) { // NSSI should not be terminated + try { + client.delete(sliceProfileInstanceUri) + } catch (Exception e) { + exceptionUtil.buildAndThrowWorkflowException(execution, 25000, "Exception occured while Slice Profile Instance delete call: " + e.getMessage()) + } + } + + LOGGER.debug("${getPrefix()} Exit deleteSliceProfileInstance") } @@ -1075,7 +1243,7 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @param execution */ void prepareUpdateResourceOperationStatus(DelegateExecution execution) { - LOGGER.trace("${getPrefix()} Start updateServiceOperationStatus") + LOGGER.debug("${getPrefix()} Start updateServiceOperationStatus") def currentNSSI = execution.getVariable("currentNSSI") @@ -1092,7 +1260,7 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { setResourceOperationStatus(execution, "finished", "100", "Core NSSI ${getAction()} successful") - LOGGER.trace("${getPrefix()} Exit updateServiceOperationStatus") + LOGGER.debug("${getPrefix()} Exit updateServiceOperationStatus") } @@ -1102,26 +1270,31 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @param operationType */ void setResourceOperationStatus(DelegateExecution execution, String status, String progress, String statusDesc) { - LOGGER.trace("${getPrefix()} Start setResourceOperationStatus") + LOGGER.debug("${getPrefix()} Start setResourceOperationStatus") def currentNSSI = execution.getVariable("currentNSSI") - String serviceId = currentNSSI['nssiId'] + String serviceId = currentNSSI['nsiId'] String jobId = execution.getVariable("jobId") String nsiId = currentNSSI['nsiId'] String operationType = execution.getVariable("operationType") + String resourceInstanceId = currentNSSI['nssiId'] + + ServiceInstance nssi = (ServiceInstance) currentNSSI['nssi'] + String modelUuid = nssi.getModelVersionId() ResourceOperationStatus resourceOperationStatus = new ResourceOperationStatus() resourceOperationStatus.setServiceId(serviceId) resourceOperationStatus.setOperationId(jobId) - resourceOperationStatus.setResourceTemplateUUID(nsiId) + resourceOperationStatus.setResourceTemplateUUID(modelUuid) resourceOperationStatus.setOperType(operationType) + resourceOperationStatus.setResourceInstanceID(resourceInstanceId) resourceOperationStatus.setStatus(status) resourceOperationStatus.setProgress(progress) resourceOperationStatus.setStatusDescription(statusDesc) requestDBUtil.prepareUpdateResourceOperationStatus(execution, resourceOperationStatus) - LOGGER.trace("${getPrefix()} Exit setResourceOperationStatus") + LOGGER.debug("${getPrefix()} Exit setResourceOperationStatus") } @@ -1130,11 +1303,11 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @param execution */ void prepareFailedOperationStatusUpdate(DelegateExecution execution) { - LOGGER.trace("${getPrefix()} Start prepareFailedOperationStatusUpdate") + LOGGER.debug("${getPrefix()} Start prepareFailedOperationStatusUpdate") setResourceOperationStatus(execution, "failed", "0", "Core NSSI ${getAction()} Failed") - LOGGER.trace("${getPrefix()} Exit prepareFailedOperationStatusUpdate") + LOGGER.debug("${getPrefix()} Exit prepareFailedOperationStatusUpdate") } @@ -1143,42 +1316,58 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @param execution */ public void getPUTServiceInstanceProgress(DelegateExecution execution) { - LOGGER.trace("${getPrefix()} Start getPUTServiceInstanceProgress") + LOGGER.debug("${getPrefix()} Start getPUTServiceInstanceProgress") def currentNSSI = execution.getVariable("currentNSSI") - String url = currentNSSI['putServiceInstanceURL'] + ServiceInstance networkServiceInstance = (ServiceInstance)currentNSSI['networkServiceInstance'] + + String url = currentNSSI['requestSelfLink'] + + String msoKey = UrnPropertiesReader.getVariable("mso.msoKey", execution) - getProgress(execution, url, "putStatus") + String basicAuth = UrnPropertiesReader.getVariable("mso.adapters.po.auth", execution) - LOGGER.trace("${getPrefix()} Exit getPUTServiceInstanceProgress") + def authHeader = "" + String basicAuthValue = utils.getBasicAuth(basicAuth, msoKey) + + getProgress(execution, url, basicAuthValue, "putStatus") + + LOGGER.debug("${getPrefix()} Exit getPUTServiceInstanceProgress") } - void getProgress(DelegateExecution execution, String url, String statusVariableName) { + void getProgress(DelegateExecution execution, String url, String authHeader, String statusVariableName) { + LOGGER.debug("${getPrefix()} Start getProgress") + + LOGGER.debug("getProgress: url = " + url) + LOGGER.debug("getProgress: authHeader = " + authHeader) + String msg="" try { - ExternalAPIUtil externalAPIUtil = getExternalAPIUtilFactory().create() - Response response = externalAPIUtil.executeExternalAPIGetCall(execution, url) + HttpClient httpClient = getHttpClientFactory().newJsonClient(new URL(url), ONAPComponents.SO) + httpClient.addAdditionalHeader("Authorization", authHeader) + httpClient.addAdditionalHeader("Accept", "application/json") + + Response response = httpClient.get() int responseCode = response.getStatus() - execution.setVariable("GetServiceOrderResponseCode", responseCode) + // execution.setVariable("GetServiceOrderResponseCode", responseCode) LOGGER.debug("Get ServiceOrder response code is: " + responseCode) - String extApiResponse = response.readEntity(String.class) - JSONObject responseObj = new JSONObject(extApiResponse) - execution.setVariable("GetServiceOrderResponse", extApiResponse) - LOGGER.debug("Create response body is: " + extApiResponse) + String soResponse = "" + if(response.hasEntity()) { + soResponse = response.readEntity(String.class) + // execution.setVariable("GetServiceOrderResponse", extApiResponse) + LOGGER.debug("Create response body is: " + soResponse) + } + //Process Response //200 OK 201 CREATED 202 ACCEPTED - if(responseCode == 200 || responseCode == 201 || responseCode == 202 ) - { + if (responseCode >= 200 && responseCode < 204) { LOGGER.debug("Get Create ServiceOrder Received a Good Response") - String orderState = responseObj.get("state") - if("REJECTED".equalsIgnoreCase(orderState)) { - prepareFailedOperationStatusUpdate(execution) - return - } + String requestState = jsonUtil.getJsonValue(soResponse, "request.requestStatus.requestState") + /* JSONArray items = responseObj.getJSONArray("orderItem") JSONObject item = items.get(0) JSONObject service = item.get("service") @@ -1190,21 +1379,25 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { execution.setVariable("networkServiceId", networkServiceId) String serviceOrderState = item.get("state") - execution.setVariable("ServiceOrderState", serviceOrderState) + execution.setVariable("ServiceOrderState", serviceOrderState) */ + // Get serviceOrder State and process progress - if("ACKNOWLEDGED".equalsIgnoreCase(serviceOrderState)) { + if("ACKNOWLEDGED".equalsIgnoreCase(requestState)) { execution.setVariable(statusVariableName, "processing") } - else if("INPROGRESS".equalsIgnoreCase(serviceOrderState)) { + else if("IN_PROGRESS".equalsIgnoreCase(requestState)) { execution.setVariable(statusVariableName, "processing") } - else if("COMPLETED".equalsIgnoreCase(serviceOrderState)) { + else if("COMPLETE".equalsIgnoreCase(requestState)) { execution.setVariable(statusVariableName, "completed") } - else if("FAILED".equalsIgnoreCase(serviceOrderState)) { + else if("FAILED".equalsIgnoreCase(requestState)) { msg = "ServiceOrder failed" exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg) } + else if("REJECTED".equalsIgnoreCase(requestState)) { + prepareFailedOperationStatusUpdate(execution) + } else { msg = "ServiceOrder failed" exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg) @@ -1219,6 +1412,7 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { exceptionUtil.buildAndThrowWorkflowException(execution, 7000, e.getMessage()) } + LOGGER.debug("${getPrefix()} Exit getProgress") } @@ -1228,7 +1422,7 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { * @param execution */ void timeDelay(DelegateExecution execution) { - LOGGER.trace("${getPrefix()} Start timeDelay") + LOGGER.debug("${getPrefix()} Start timeDelay") try { LOGGER.debug("${getPrefix()} timeDelay going to sleep for 5 sec") @@ -1240,10 +1434,20 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { LOGGER.error("${getPrefix()} ::: timeDelay exception" + e) } - LOGGER.trace("${getPrefix()} Exit timeDelay") + LOGGER.debug("${getPrefix()} Exit timeDelay") } + void postProcessRequest(DelegateExecution execution) { + LOGGER.debug("${getPrefix()} Start postProcessRequest") + + execution.removeVariable("currentNSSI") + + LOGGER.debug("***** ${getPrefix()} Exit postProcessRequest") + } + + + /** * Returns AAI client * @return AAI client @@ -1258,7 +1462,16 @@ class DoCommonCoreNSSI extends AbstractServiceTaskProcessor { } - String getPrefix() { + /** + * Returns Catalog DB Util Factory + * @return ew CatalogDbUtilsFactory() + */ + CatalogDbUtilsFactory getCatalogDbUtilsFactory() { + return new CatalogDbUtilsFactory() + } + + + private String getPrefix() { return PREFIX } diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoDeallocateCoreNSSI.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoDeallocateCoreNSSI.groovy index fe881eb888..c559845e12 100644 --- a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoDeallocateCoreNSSI.groovy +++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoDeallocateCoreNSSI.groovy @@ -20,10 +20,14 @@ package org.onap.so.bpmn.infrastructure.scripts - +import com.fasterxml.jackson.databind.ObjectMapper +import com.google.gson.JsonObject import org.camunda.bpm.engine.delegate.DelegateExecution import org.onap.aai.domain.yang.v19.AllottedResource +import org.onap.aai.domain.yang.v19.GenericVnf import org.onap.aai.domain.yang.v19.ServiceInstance +import org.onap.aai.domain.yang.v19.SliceProfile +import org.onap.aai.domain.yang.v19.SliceProfiles import org.onap.aaiclient.client.aai.AAIResourcesClient import org.onap.aaiclient.client.aai.entities.AAIResultWrapper import org.onap.aaiclient.client.aai.entities.Relationships @@ -34,16 +38,23 @@ import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder.T import org.onap.logging.filter.base.ONAPComponents import org.onap.so.bpmn.common.scripts.ExceptionUtil import org.onap.so.bpmn.common.scripts.MsoUtils +import org.onap.so.bpmn.common.scripts.OofUtils import org.onap.so.bpmn.common.scripts.RequestDBUtil import org.onap.so.bpmn.core.UrnPropertiesReader import org.onap.so.bpmn.core.json.JsonUtils import org.onap.so.client.HttpClient import org.onap.so.client.HttpClientFactory +import org.onap.so.client.oof.adapter.beans.payload.OofRequest import org.slf4j.Logger import org.slf4j.LoggerFactory import javax.ws.rs.core.Response +import static org.apache.commons.lang3.StringUtils.isBlank +import static org.apache.commons.lang3.StringUtils.isBlank +import static org.onap.so.bpmn.common.scripts.GenericUtils.isBlank +import static org.onap.so.bpmn.common.scripts.GenericUtils.isBlank + class DoDeallocateCoreNSSI extends DoCommonCoreNSSI { private final String PREFIX ="DoDeallocateCoreNSSI" private final String ACTION = "Deallocate" @@ -55,54 +66,84 @@ class DoDeallocateCoreNSSI extends DoCommonCoreNSSI { private static final Logger LOGGER = LoggerFactory.getLogger( DoDeallocateCoreNSSI.class) + + @Override + void preProcessRequest(DelegateExecution execution) { + LOGGER.debug("${getPrefix()} Start preProcessRequest") + + super.preProcessRequest(execution) + + execution.setVariable("operationType", "DEALLOCATE") + + LOGGER.debug("${getPrefix()} Exit preProcessRequest") + } + + + /** * Queries OOF for NSSI termination * @param execution */ void executeTerminateNSSIQuery(DelegateExecution execution) { - LOGGER.trace("${PREFIX} Start executeTerminateNSSIQuery") + LOGGER.debug("${PREFIX} Start executeTerminateNSSIQuery") String urlString = UrnPropertiesReader.getVariable("mso.oof.endpoint", execution) + // String urlString = UrnPropertiesReader.getVariable("mso.adapters.oof.endpoint", execution) + + //API Path + String apiPath = "/api/oof/terminate/nxi/v1" + LOGGER.debug("API path for DoAllocateCoreNSSI: "+apiPath) + + urlString = urlString + apiPath //Prepare auth for OOF def authHeader = "" String basicAuth = UrnPropertiesReader.getVariable("mso.oof.auth", execution) String msokey = UrnPropertiesReader.getVariable("mso.msoKey", execution) - String basicAuthValue = encryptBasicAuth(basicAuth, msokey) - if (basicAuthValue != null) { - String responseAuthHeader = getAuthHeader(execution, basicAuthValue, msokey) - String errorCode = jsonUtil.getJsonValue(responseAuthHeader, "errorCode") - if(errorCode == null || errorCode.isEmpty()) { // No error - authHeader = responseAuthHeader - } - else { - exceptionUtil.buildAndThrowWorkflowException(execution, Integer.parseInt(errorCode), jsonUtil.getJsonValue(responseAuthHeader, "errorMessage")) + String basicAuthValue = utils.encrypt(basicAuth, msokey) + /* if (basicAuthValue != null) { + LOGGER.debug( "Obtained BasicAuth username and password for OOF Adapter: " + basicAuthValue) + try { + authHeader = utils.getBasicAuth(basicAuthValue, msokey) + execution.setVariable("BasicAuthHeaderValue", authHeader) + } catch (Exception ex) { + LOGGER.error( "Unable to encode username and password string: " + ex) + exceptionUtil.buildAndThrowWorkflowException(execution, 401, "Internal Error - Unable to encode username and password string") } } else { LOGGER.error( "Unable to obtain BasicAuth - BasicAuth value null") - exceptionUtil.buildAndThrowWorkflowException(execution, 401, "Internal Error - BasicAuth " + - "value null") + exceptionUtil.buildAndThrowWorkflowException(execution, 401, "Internal Error - BasicAuth value null") + } */ + + + try { + authHeader = utils.getBasicAuth(basicAuthValue, msokey) + execution.setVariable("BasicAuthHeaderValue", authHeader) + } catch (Exception ex) { + LOGGER.error( "Unable to encode username and password string: " + ex) + exceptionUtil.buildAndThrowWorkflowException(execution, 401, "Internal Error - Unable to encode username and password string") } //Prepare send request to OOF String oofRequest = buildOOFRequest(execution) String callOOFResponse = callOOF(urlString, authHeader, oofRequest) + LOGGER.debug("callOOFResponse=" + callOOFResponse) + String errorCode = jsonUtil.getJsonValue(callOOFResponse, "errorCode") if(errorCode == null || errorCode.isEmpty()) { // No error - String oofResponse = callOOFResponse - String isTerminateNSSI = jsonUtil.getJsonValue(oofResponse, "terminateResponse") + String terminateNSSI = jsonUtil.getJsonValue(callOOFResponse, "terminateResponse") + LOGGER.debug("isTerminateNSSI=" + terminateNSSI) - execution.setVariable("isTerminateNSSI", Boolean.parseBoolean(isTerminateNSSI)) + execution.setVariable("isTerminateNSSI", terminateNSSI) } else { LOGGER.error(jsonUtil.getJsonValue(callOOFResponse, "errorMessage")) exceptionUtil.buildAndThrowWorkflowException(execution, Integer.parseInt(errorCode), jsonUtil.getJsonValue(callOOFResponse, "errorMessage")) } - - LOGGER.trace("${PREFIX} Exit executeTerminateNSSIQuery") + LOGGER.debug("${PREFIX} Exit executeTerminateNSSIQuery") } @@ -111,15 +152,16 @@ class DoDeallocateCoreNSSI extends DoCommonCoreNSSI { * @return OOF response */ String callOOF(String urlString, String authHeader, String oofRequest) { + LOGGER.debug("${PREFIX} Start callOOF") + String errorCode = "" String errorMessage = "" String response = "" try { - URL url = new URL(urlString + "/api/oof/terminate/nxi/v1") - HttpClient httpClient = new HttpClientFactory().newJsonClient(url, ONAPComponents.OOF) + URL url = new URL(urlString) + HttpClient httpClient = getHttpClientFactory().newJsonClient(url, ONAPComponents.OOF) httpClient.addAdditionalHeader("Authorization", authHeader) - httpClient.addAdditionalHeader("Accept", "application/json") httpClient.addAdditionalHeader("Content-Type", "application/json") Response httpResponse = httpClient.post(oofRequest) @@ -127,7 +169,7 @@ class DoDeallocateCoreNSSI extends DoCommonCoreNSSI { int responseCode = httpResponse.getStatus() LOGGER.debug("OOF sync response code is: " + responseCode) - if (responseCode != 202) { // Accepted + if(responseCode < 200 || responseCode >= 300) { // Wrong code errorCode = responseCode errorMessage = "Received a Bad Sync Response from OOF." @@ -161,6 +203,7 @@ class DoDeallocateCoreNSSI extends DoCommonCoreNSSI { "}" } + LOGGER.debug("${PREFIX} Exit callOOF") return response } @@ -172,23 +215,54 @@ class DoDeallocateCoreNSSI extends DoCommonCoreNSSI { * @return */ private String buildOOFRequest(DelegateExecution execution) { + LOGGER.debug("${PREFIX} Start buildOOFRequest") def currentNSSI = execution.getVariable("currentNSSI") String nssiId = currentNSSI['nssiId'] - String requestId = execution.getVariable("mso-request-id") - - String request = "{\n" + - " \"type\": \"NSSI\",\n" + - " \"NxIId\": \"${nssiId}\",\n" + - " \"requestInfo\": {\n" + - " \"transactionId\": \"${requestId}\",\n" + - " \"requestId\": \"${requestId}\",\n" + - " \"sourceId\": \"so\",\n" + - " }\n" + - "}" - - return request + + ServiceInstance nssi = null + + AAIResourcesClient client = getAAIClient() + + // NSSI + AAIResourceUri nssiUri = AAIUriFactory.createResourceUri(Types.SERVICE_INSTANCE.getFragment(nssiId)) + Optional<ServiceInstance> nssiOpt = client.get(ServiceInstance.class, nssiUri) + + if (nssiOpt.isPresent()) { + nssi = nssiOpt.get() + } + else { + String msg = "NSSI service instance not found in AAI for nssi id " + nssiId + LOGGER.error(msg) + exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg) + } + + //Setting correlator as requestId + String requestId = execution.getVariable("msoRequestId") + execution.setVariable("NSSI_correlator", requestId) + + //Setting messageType for all Core slice as cn + String messageType = "cn" + execution.setVariable("NSSI_messageType", messageType) + + //Prepare Callback + String timeout = execution.getVariable("timeout") + if (isBlank(timeout)) { + timeout = UrnPropertiesReader.getVariable("mso.oof.timeout", execution); + if (isBlank(timeout)) { + timeout = "PT30M" + } + } + + String nxlId = nssi.getServiceInstanceId() + String nxlType = "NSSI" + String oofRequest = getOofUtils().buildTerminateNxiRequest(requestId, nxlId, nxlType, messageType, nssi.getServiceInstanceId()) + LOGGER.debug("**** Terminate Nxi Request: "+oofRequest) + + LOGGER.debug("${PREFIX} Exit buildOOFRequest") + + return oofRequest } @@ -198,24 +272,29 @@ class DoDeallocateCoreNSSI extends DoCommonCoreNSSI { * @param execution */ void deleteServiceOrder(DelegateExecution execution) { - LOGGER.trace("${PREFIX} Start deleteServiceOrder") + LOGGER.debug("${PREFIX} Start deleteServiceOrder") def currentNSSI = execution.getVariable("currentNSSI") try { //url:/nbi/api/v4/serviceOrder/" - def nbiEndpointUrl = UrnPropertiesReader.getVariable("nbi.endpoint.url", execution) + def nsmfЕndPoint = UrnPropertiesReader.getVariable("mso.infra.endpoint.url", execution) ServiceInstance networkServiceInstance = (ServiceInstance)currentNSSI['networkServiceInstance'] - String url = String.format("${nbiEndpointUrl}/api/v4/serviceOrder/%s", networkServiceInstance.getServiceInstanceId()) + //String url = String.format("${nbiEndpointUrl}/api/v4/serviceOrder/%s", networkServiceInstance.getServiceInstanceId()) + + GenericVnf constituteVnf = (GenericVnf)currentNSSI['constituteVnf'] + + // http://so.onap:8080/onap/so/infra/serviceInstantiation/v7/serviceInstances/de6a0aa2-19f2-41fe-b313-a5a9f159acd7/vnfs/3abbb373-8d33-4977-aa4b-2bfee496b6d5 + String url = String.format("${nsmfЕndPoint}/serviceInstantiation/v7/serviceInstances/%s/vnfs/%s", networkServiceInstance.getServiceInstanceId(), constituteVnf.getVnfId()) currentNSSI['deleteServiceOrderURL'] = url String msoKey = UrnPropertiesReader.getVariable("mso.msoKey", execution) - String basicAuth = UrnPropertiesReader.getVariable("mso.infra.endpoint.auth", execution) + String basicAuth = UrnPropertiesReader.getVariable("mso.adapters.po.auth", execution) - String basicAuthValue = encryptBasicAuth(basicAuth, msoKey) + /*String basicAuthValue = encryptBasicAuth(basicAuth, msoKey) def authHeader = "" if (basicAuthValue != null) { String responseAuthHeader = getAuthHeader(execution, basicAuthValue, msoKey) @@ -230,14 +309,21 @@ class DoDeallocateCoreNSSI extends DoCommonCoreNSSI { LOGGER.error( "Unable to obtain BasicAuth - BasicAuth value null") exceptionUtil.buildAndThrowWorkflowException(execution, 401, "Internal Error - BasicAuth " + "value null") - } + } */ + + def authHeader = utils.getBasicAuth(basicAuth, msoKey) String callDeleteServiceOrderResponse = callDeleteServiceOrder(execution, url, authHeader) String errorCode = jsonUtil.getJsonValue(callDeleteServiceOrderResponse, "errorCode") - String deleteServcieResponse = "" if(errorCode == null || errorCode.isEmpty()) { // No error - deleteServcieResponse = callDeleteServiceOrderResponse // check the response ??? + String macroOperationId = jsonUtil.getJsonValue(callDeleteServiceOrderResponse, "requestReferences.requestId") + String requestSelfLink = jsonUtil.getJsonValue(callDeleteServiceOrderResponse, "requestReferences.requestSelfLink") + + execution.setVariable("macroOperationId", macroOperationId) + execution.setVariable("requestSelfLink", requestSelfLink) + + currentNSSI['requestSelfLink'] = requestSelfLink } else { LOGGER.error(jsonUtil.getJsonValue(callDeleteServiceOrderResponse, "errorMessage")) @@ -249,27 +335,34 @@ class DoDeallocateCoreNSSI extends DoCommonCoreNSSI { exceptionUtil.buildAndThrowWorkflowException(execution, 7000, msg) } - LOGGER.trace("${PREFIX} Exit deleteServiceOrder") + LOGGER.debug("${PREFIX} Exit deleteServiceOrder") } - String callDeleteServiceOrder(DelegateExecution execution, String urlString, String authHeader) { + String callDeleteServiceOrder(DelegateExecution execution, String url, String authHeader) { + LOGGER.debug("${PREFIX} Start callDeleteServiceOrder") + String errorCode = "" String errorMessage = "" String response = "" try { - HttpClient httpClient = getHttpClientFactory().newJsonClient(new URL(urlString), ONAPComponents.EXTERNAL) + HttpClient httpClient = getHttpClientFactory().newJsonClient(new URL(url), ONAPComponents.SO) httpClient.addAdditionalHeader("Authorization", authHeader) httpClient.addAdditionalHeader("Accept", "application/json") Response httpResponse = httpClient.delete() - if (httpResponse.hasEntity()) { + int soResponseCode = httpResponse.getStatus() + LOGGER.debug("callDeleteServiceInstance: soResponseCode = " + soResponseCode) + + if (soResponseCode >= 200 && soResponseCode < 204 && httpResponse.hasEntity()) { response = httpResponse.readEntity(String.class) + + LOGGER.debug("callDeleteServiceInstance: response = " + response) } else { errorCode = 500 - errorMessage = "No response received." + errorMessage = "Response code is " + soResponseCode response = "{\n" + " \"errorCode\": \"${errorCode}\",\n" + @@ -278,7 +371,7 @@ class DoDeallocateCoreNSSI extends DoCommonCoreNSSI { } } catch (any) { - String msg = "Exception in DoDeallocateCoreNSSI.deleteServiceOrder. " + any.getCause() + String msg = "Exception in DoDeallocateCoreNSSI.callDeleteServiceOrder. " + any.getCause() response = "{\n" + " \"errorCode\": \"7000\",\n" + @@ -286,6 +379,8 @@ class DoDeallocateCoreNSSI extends DoCommonCoreNSSI { "}" } + LOGGER.debug("${PREFIX} Exit callDeleteServiceOrder") + return response } @@ -295,7 +390,7 @@ class DoDeallocateCoreNSSI extends DoCommonCoreNSSI { * @param execution */ void removeNSSIAssociationWithNSI(DelegateExecution execution) { - LOGGER.trace("${PREFIX} Start removeNSSIAssociationWithNSI") + LOGGER.debug("${PREFIX} Start removeNSSIAssociationWithNSI") AAIResourcesClient client = getAAIClient() @@ -308,38 +403,54 @@ class DoDeallocateCoreNSSI extends DoCommonCoreNSSI { // NSSI AAIResourceUri nssiUri = AAIUriFactory.createResourceUri(Types.SERVICE_INSTANCE.getFragment(nssiId)) - ServiceInstance nssi = currentNSSI['nssi'] + String allottedResourceId = null - // Removes Allotted resource - List<AllottedResource> allottedResources = nssi.getAllottedResources()?.getAllottedResource() - if(allottedResources != null && allottedResources.size() == 1) { // Shouldn contain one allotted resource - allottedResourceId = allottedResources.get(0).getId() - allottedResources.remove(0) + + AAIResultWrapper nssiWrapper = client.get(nssiUri) + Optional<Relationships> nssiRelationships = nssiWrapper.getRelationships() + + if (nssiRelationships.isPresent()) { + // Allotted Resource + for (AAIResourceUri allottedResourceUri : nssiRelationships.get().getRelatedUris(Types.ALLOTTED_RESOURCE)) { + AAIResultWrapper arWrapper = client.get(allottedResourceUri) + Optional<Relationships> arRelationships = arWrapper.getRelationships() + + if(arRelationships.isPresent()) { + // NSI + for (AAIResourceUri nsiUri : arRelationships.get().getRelatedUris(Types.SERVICE_INSTANCE)) { + Optional<ServiceInstance> nsiOpt = client.get(ServiceInstance.class, nsiUri) + + if (nsiOpt.isPresent()) { + ServiceInstance nsi = nsiOpt.get() + if(nsi.getServiceRole().equals("nsi")) { // Service instance as NSI + // Removes NSSI association with NSI + try { + client.disconnect(nssiUri, nsiUri) + } + catch (Exception e) { + exceptionUtil.buildAndThrowWorkflowException(execution, 25000, "Exception occured while NSSI association with NSI dosconnect call: " + e.getMessage()) + } + } + } + else { + LOGGER.warn("No NSI found for NSSI id " + nssiId) + } + } + } + else { + LOGGER.warn("No relationships found for Allotted Resource for NSSI id " + nssiId) + } + + } } else { - exceptionUtil.buildAndThrowWorkflowException(execution, 500, "No allotted resource found for NSSI id = " + nssiId) + LOGGER.warn("No relationships found for nssi id = " + nssiId) } - try { - client.update(nssiUri, nssi) - }catch(Exception e){ - exceptionUtil.buildAndThrowWorkflowException(execution, 25000, "Exception occured while NSSI association with NSI disconnect call: " + e.getMessage()) - } - - - // Remove association between NSI and Allotted Resource - AAIResourceUri nsiUri = AAIUriFactory.createResourceUri(Types.SERVICE_INSTANCE.getFragment(nsiId)) - AAIResourceUri allottedResourceUri = AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.business().customer(globalSubscriberId).serviceSubscription(subscriptionServiceType).serviceInstance(nssiId).allottedResource(allottedResourceId)) - - try { - client.disconnect(nsiUri, allottedResourceUri) - }catch(Exception e){ - exceptionUtil.buildAndThrowWorkflowException(execution, 25000, "Exception occured while NSSI association with NSI disconnect call: " + e.getMessage()) - } - LOGGER.trace("${PREFIX} Exit removeNSSIAssociationWithNSI") + LOGGER.debug("${PREFIX} Exit removeNSSIAssociationWithNSI") } @@ -348,7 +459,7 @@ class DoDeallocateCoreNSSI extends DoCommonCoreNSSI { * @param execution */ void deleteNSSIServiceInstance(DelegateExecution execution) { - LOGGER.trace("${PREFIX} Start deleteNSSIServiceInstance") + LOGGER.debug("${PREFIX} Start deleteNSSIServiceInstance") AAIResourcesClient client = getAAIClient() @@ -358,12 +469,12 @@ class DoDeallocateCoreNSSI extends DoCommonCoreNSSI { AAIResourceUri nssiUri = AAIUriFactory.createResourceUri(Types.SERVICE_INSTANCE.getFragment(nssiId)) try { - getAAIClient().delete(nssiUri) + client.delete(nssiUri) }catch(Exception e){ exceptionUtil.buildAndThrowWorkflowException(execution, 25000, "Exception occurred while NSSI Service Instance delete call: " + e.getMessage()) } - LOGGER.trace("${PREFIX} Exit deleteNSSIServiceInstance") + LOGGER.debug("${PREFIX} Exit deleteNSSIServiceInstance") } @@ -372,19 +483,72 @@ class DoDeallocateCoreNSSI extends DoCommonCoreNSSI { * @param execution */ void getDeleteServiceOrderProgress(DelegateExecution execution) { - LOGGER.trace("${getPrefix()} Start getDeleteServiceOrderProgress") + LOGGER.debug("${getPrefix()} Start getDeleteServiceOrderProgress") def currentNSSI = execution.getVariable("currentNSSI") - String url = currentNSSI['deleteServiceOrderURL'] + String url = currentNSSI['requestSelfLink'] + + String msoKey = UrnPropertiesReader.getVariable("mso.msoKey", execution) + + String basicAuth = UrnPropertiesReader.getVariable("mso.adapters.po.auth", execution) - getProgress(execution, url, "deleteStatus") + def authHeader = "" + String basicAuthValue = utils.getBasicAuth(basicAuth, msoKey) + + getProgress(execution, url, basicAuthValue, "deleteStatus") + LOGGER.debug("${getPrefix()} Exit getDeleteServiceOrderProgress") } - @Override - String getPrefix() { + /** + * Calculates a final list of S-NSSAI + * @param execution + */ + void calculateSNSSAI(DelegateExecution execution) { + LOGGER.debug("${getPrefix()} Start calculateSNSSAI") + + def currentNSSI = execution.getVariable("currentNSSI") + + List<SliceProfile> associatedProfiles = (List<SliceProfile>)currentNSSI['associatedProfiles'] + + String givenSliceProfileId = currentNSSI['sliceProfileId'] + + List<String> snssais = new ArrayList<>() + + String isTerminateNSSIVar = execution.getVariable("isTerminateNSSI" ) + + boolean isTerminateNSSI = Boolean.parseBoolean(isTerminateNSSIVar) + + if(!isTerminateNSSI) { // NSSI should not be terminated + LOGGER.debug("calculateSNSSAI: associatedProfiles.size()" + associatedProfiles.size()) + for (SliceProfile associatedProfile : associatedProfiles) { + if (!associatedProfile.getProfileId().equals(givenSliceProfileId)) { // not given profile id + LOGGER.debug("calculateSNSSAI: associatedProfile.getSNssai()" + associatedProfile.getSNssai()) + snssais.add(associatedProfile.getSNssai()) + } else { + currentNSSI['sliceProfileS-NSSAI'] = associatedProfile + } + } + } + + currentNSSI['S-NSSAIs'] = snssais + + LOGGER.debug("${getPrefix()} Exit calculateSNSSAI") + } + + + /** + * OofUtils + * @return new OofUtils() + */ + OofUtils getOofUtils() { + return new OofUtils() + } + + + private String getPrefix() { return PREFIX } diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoDeallocateNSSI.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoDeallocateNSSI.groovy index 147e623ece..554f7a6392 100644 --- a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoDeallocateNSSI.groovy +++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoDeallocateNSSI.groovy @@ -129,7 +129,7 @@ class DoDeallocateNSSI extends AbstractServiceTaskProcessor if(serviceCategory ==~ /CN.*/){ return SubnetType.CN.getNetworkType() } - if (serviceCategory ==~ /AN.*NF.*/){ + if (serviceCategory ==~ /AN.*/){ return SubnetType.AN.getNetworkType() } if (serviceCategory ==~ /TN.*BH.*/){ @@ -166,6 +166,7 @@ class DoDeallocateNSSI extends AbstractServiceTaskProcessor deAllocateNssi.setTerminateNssiOption(0) deAllocateNssi.setSnssaiList(Arrays.asList(snssai)) deAllocateNssi.setScriptName(scriptName) + deAllocateNssi.setSliceProfileId(profileId) ServiceInfo serviceInfo = new ServiceInfo() serviceInfo.setServiceInvariantUuid(serviceInvariantUuid) diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoDeleteSliceService.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoDeleteSliceService.groovy index 5fd06fd8d4..7dc63b61ed 100644 --- a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoDeleteSliceService.groovy +++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoDeleteSliceService.groovy @@ -31,6 +31,7 @@ import org.onap.aaiclient.client.aai.entities.uri.AAIResourceUri import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder.Types +import org.onap.so.client.oof.adapter.beans.payload.OofRequest import org.onap.logging.filter.base.ONAPComponents import org.onap.so.bpmn.common.scripts.AbstractServiceTaskProcessor import org.onap.so.bpmn.common.scripts.ExceptionUtil @@ -40,6 +41,7 @@ import org.onap.so.client.HttpClient import org.onap.so.client.HttpClientFactory import org.slf4j.Logger import org.slf4j.LoggerFactory +import com.fasterxml.jackson.databind.ObjectMapper import javax.ws.rs.NotFoundException import javax.ws.rs.core.Response @@ -404,11 +406,12 @@ class DoDeleteSliceService extends AbstractServiceTaskProcessor { { LOGGER.debug("Start terminateNSIQuery") - return + //return //To test String requestId = execution.getVariable("msoRequestId") - String nxlId = currentNSSI['nsiServiceInstanceId'] + String nxlId = execution.getVariable("nsiId") + //String nxlId = currentNSSI['nsiServiceInstanceId'] String nxlType = "NSI" String messageType = "nsiTerminationResponse" String serviceInstanceId = execution.getVariable("serviceInstanceId") @@ -433,12 +436,17 @@ class DoDeleteSliceService extends AbstractServiceTaskProcessor { exceptionUtil.buildAndThrowWorkflowException(execution, 401, "Internal Error - BasicAuth " + "value null") } - - URL requestUrl = new URL(oofUrl + "/api/oof/terminate/nxi/v1") + String oofUrl = UrnPropertiesReader.getVariable("mso.adapters.oof.endpoint", execution) + URL requestUrl = new URL(oofUrl) String oofRequest = oofUtils.buildTerminateNxiRequest(requestId, nxlId, nxlType, messageType, serviceInstanceId) + OofRequest oofPayload = new OofRequest() + oofPayload.setApiPath("/api/oof/terminate/nxi/v1") + oofPayload.setRequestDetails(oofRequest) + ObjectMapper objectMapper = new ObjectMapper() + String requestJson = objectMapper.writeValueAsString(oofPayload) HttpClient httpClient = new HttpClientFactory().newJsonClient(requestUrl, ONAPComponents.OOF) httpClient.addAdditionalHeader("Authorization", authHeader) - Response httpResponse = httpClient.post(oofRequest) + Response httpResponse = httpClient.post(requestJson) int responseCode = httpResponse.getStatus() LOGGER.debug("OOF sync response code is: " + responseCode) diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoModifyAccessNSSI.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoModifyAccessNSSI.groovy index f6be861bde..3bb1c0bef5 100644 --- a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoModifyAccessNSSI.groovy +++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoModifyAccessNSSI.groovy @@ -237,7 +237,7 @@ class DoModifyAccessNSSI extends AbstractServiceTaskProcessor { ServiceInstance ranSliceProfileInstance = execution.getVariable("ranSliceProfileInstance") profileInfo.put("sST",ranSliceProfileInstance.getServiceType()) profileInfo.put("snssaiList",execution.getVariable("snssaiList")) - profileInfo.put("plmnIdList",Arrays.asList(ranSliceProfileInstance.getServiceInstanceLocationId())) + profileInfo.put("pLMNIdList",Arrays.asList(ranSliceProfileInstance.getServiceInstanceLocationId())) profileInfo.put("uEMobilityLevel",profileInfo.get("ueMobilityLevel")) profileInfo.put("cSAvailabilityTarget",profileInfo.get("csAvailabilityTarget")) profileInfo.put("maxNumberofPDUSession",profileInfo.get("maxNumberOfPDUSession")) diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoModifyCoreNSSI.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoModifyCoreNSSI.groovy index ff16184f02..8ae56a310c 100644 --- a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoModifyCoreNSSI.groovy +++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/DoModifyCoreNSSI.groovy @@ -29,6 +29,8 @@ import org.onap.aai.domain.yang.v19.SliceProfile import org.onap.aai.domain.yang.v19.SliceProfiles import org.onap.aaiclient.client.aai.AAIResourcesClient import org.onap.aaiclient.client.aai.entities.AAIEdgeLabel +import org.onap.aaiclient.client.aai.entities.AAIResultWrapper +import org.onap.aaiclient.client.aai.entities.Relationships import org.onap.aaiclient.client.aai.entities.uri.AAIResourceUri import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder @@ -56,15 +58,50 @@ class DoModifyCoreNSSI extends DoCommonCoreNSSI { private static final Logger LOGGER = LoggerFactory.getLogger( DoModifyCoreNSSI.class) + @Override + void preProcessRequest(DelegateExecution execution) { + LOGGER.debug("${getPrefix()} Start preProcessRequest") + + super.preProcessRequest(execution) + + String modifyAction = jsonUtil.getJsonValue(execution.getVariable("sliceParams"), "modifyAction") + if (isBlank(modifyAction)) { + String msg = "modifyAction is mandatory parameter" + exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg) + } + else { + String createSliceProfileInstance = "" + if(modifyAction.equals("allocate")) { // In case Slice Profile should be created + createSliceProfileInstance = "true" + } + else if(modifyAction.equals("deallocate")) { // In case Slice Profile should be created + createSliceProfileInstance = "false" + } + else { + String msg = "Value of modifyAction parameter should be either allocate or deallocate" + exceptionUtil.buildAndThrowWorkflowException(execution, 500, msg) + } + + execution.setVariable("isCreateSliceProfileInstance", createSliceProfileInstance) + } + + execution.setVariable("operationType", "MODIFY") + + LOGGER.debug("${getPrefix()} Exit preProcessRequest") + } + + /** * Prepares Slice Profile * @param execution * @return SLice Profile */ SliceProfile prepareSliceProfile(DelegateExecution execution) { + LOGGER.debug("${PREFIX} Start prepareSliceProfile") + def currentNSSI = execution.getVariable("currentNSSI") - String sliceProfileID = currentNSSI['sliceProfileId'] + String givenSliceProfileId = currentNSSI['sliceProfileId'] //UUID.randomUUID().toString() Map<String,Object> sliceProfileMap = new ObjectMapper().readValue(currentNSSI['sliceProfile'], Map.class) SliceProfile sliceProfile = new SliceProfile() @@ -77,41 +114,43 @@ class DoModifyCoreNSSI extends DoCommonCoreNSSI { sliceProfile.setConnDensity(0) sliceProfile.setSNssai(currentNSSI['S-NSSAI']) - if(!isBlank(sliceProfileMap.get("expDataRateUL"))) { + if(sliceProfileMap.get("expDataRateUL") != null) { sliceProfile.setExpDataRateUL(Integer.parseInt(sliceProfileMap.get("expDataRateUL").toString())) } - if(!isBlank(sliceProfileMap.get("expDataRateDL"))) { + if(sliceProfileMap.get("expDataRateDL") != null) { sliceProfile.setExpDataRateDL(Integer.parseInt(sliceProfileMap.get("expDataRateDL").toString())) } - if(!isBlank(sliceProfileMap.get("activityFactor"))) { + if(sliceProfileMap.get("activityFactor") != null) { sliceProfile.setActivityFactor(Integer.parseInt(sliceProfileMap.get("activityFactor").toString())) } - if(!isBlank(sliceProfileMap.get("resourceSharingLevel"))) { + if(sliceProfileMap.get("resourceSharingLevel") != null) { sliceProfile.setResourceSharingLevel(sliceProfileMap.get("resourceSharingLevel").toString()) } - if(!isBlank(sliceProfileMap.get("uEMobilityLevel"))) { + if(sliceProfileMap.get("uEMobilityLevel") != null) { sliceProfile.setUeMobilityLevel(sliceProfileMap.get("uEMobilityLevel").toString()) } - if(!isBlank(sliceProfileMap.get("coverageAreaTAList"))) { + if(sliceProfileMap.get("coverageAreaTAList") != null) { sliceProfile.setCoverageAreaTAList(sliceProfileMap.get("coverageAreaTAList").toString()) } - if(!isBlank(sliceProfileMap.get("maxNumberofUEs"))) { - sliceProfile.setMaxNumberOfUEs(Integer.parseInt(sliceProfileMap.get("maxNumberofUEs").toString())) + if(sliceProfileMap.get("maxNumberOfUEs") != null) { + sliceProfile.setMaxNumberOfUEs(Integer.parseInt(sliceProfileMap.get("maxNumberOfUEs").toString())) } - if(!isBlank(sliceProfileMap.get("latency"))) { + if(sliceProfileMap.get("latency") != null) { sliceProfile.setLatency(Integer.parseInt(sliceProfileMap.get("latency").toString())) } - sliceProfile.setProfileId(sliceProfileID) + sliceProfile.setProfileId(givenSliceProfileId) sliceProfile.setE2ELatency(0) + LOGGER.debug("${PREFIX} Exit prepareSliceProfile") + return sliceProfile } @@ -122,6 +161,7 @@ class DoModifyCoreNSSI extends DoCommonCoreNSSI { * @return Slice Profile Instance */ ServiceInstance prepareSliceProfileInstance(DelegateExecution execution) { + LOGGER.debug("${PREFIX} Start prepareSliceProfileInstance") def currentNSSI = execution.getVariable("currentNSSI") @@ -139,7 +179,7 @@ class DoModifyCoreNSSI extends DoCommonCoreNSSI { String serviceStatus = "deactivated" sliceProfileInstance.setOrchestrationStatus(serviceStatus) - String serviceInstanceLocationid = jsonUtil.getJsonValue(currentNSSI['sliceProfile'], "plmnIdList") + String serviceInstanceLocationid = jsonUtil.getJsonValue(currentNSSI['sliceProfile'], "pLMNIdList") sliceProfileInstance.setServiceInstanceLocationId(serviceInstanceLocationid) String serviceRole = "slice-profile-instance" @@ -152,6 +192,8 @@ class DoModifyCoreNSSI extends DoCommonCoreNSSI { // TO DO: Model info + LOGGER.debug("${PREFIX} Exit prepareSliceProfileInstance") + return sliceProfileInstance } @@ -162,7 +204,7 @@ class DoModifyCoreNSSI extends DoCommonCoreNSSI { * @param execution */ void createSliceProfileInstance(DelegateExecution execution) { - LOGGER.trace("${PREFIX} Start createSliceProfileInstance") + LOGGER.debug("${PREFIX} Start createSliceProfileInstance") def currentNSSI = execution.getVariable("currentNSSI") @@ -188,7 +230,7 @@ class DoModifyCoreNSSI extends DoCommonCoreNSSI { exceptionUtil.buildAndThrowWorkflowException(execution, 25000, "Exception occurred while Slice Profile create call:" + ex.getMessage()) } - LOGGER.trace("${PREFIX} Exit createSliceProfileInstance") + LOGGER.debug("${PREFIX} Exit createSliceProfileInstance") } @@ -198,6 +240,8 @@ class DoModifyCoreNSSI extends DoCommonCoreNSSI { * @return AllottedResource */ AllottedResource createAllottedResource(DelegateExecution execution) { + LOGGER.debug("${PREFIX} Start createAllottedResource") + def currentNSSI = execution.getVariable("currentNSSI") String globalSubscriberId = execution.getVariable("globalSubscriberId") @@ -223,6 +267,8 @@ class DoModifyCoreNSSI extends DoCommonCoreNSSI { exceptionUtil.buildAndThrowWorkflowException(execution, 25000, "Exception occurred while Allotted Resource create call:" + ex.getMessage()) } + LOGGER.debug("${PREFIX} Exit createAllottedResource") + return allottedResource } @@ -233,7 +279,7 @@ class DoModifyCoreNSSI extends DoCommonCoreNSSI { * @param execution */ void associateSliceProfileInstanceWithNSSI(DelegateExecution execution) { - LOGGER.trace("${PREFIX} Start associateSliceProfileInstanceWithNSSI") + LOGGER.debug("${PREFIX} Start associateSliceProfileInstanceWithNSSI") def currentNSSI = execution.getVariable("currentNSSI") @@ -247,12 +293,12 @@ class DoModifyCoreNSSI extends DoCommonCoreNSSI { AllottedResource allottedResource = createAllottedResource(execution) AAIResourceUri allottedResourceUri = (AAIResourceUri)currentNSSI['allottedResourceUri'] - // Updates Slice Profile Instance with Allotted Resource + // Associates Allotted Resource with Slice Profile Instance try { AAIResourceUri sliceProfileInstanceUri = AAIUriFactory.createResourceUri(Types.SERVICE_INSTANCE.getFragment(sliceProfileInstanceId)) Optional<ServiceInstance> sliceProfileInstanceOpt = client.get(ServiceInstance.class, sliceProfileInstanceUri) if (sliceProfileInstanceOpt.isPresent()) { - ServiceInstance sliceProfileInstance = sliceProfileInstanceOpt.get() + /* ServiceInstance sliceProfileInstance = sliceProfileInstanceOpt.get() AllottedResources allottedResources = sliceProfileInstance.getAllottedResources() if(allottedResources == null) { @@ -262,7 +308,9 @@ class DoModifyCoreNSSI extends DoCommonCoreNSSI { allottedResources.getAllottedResource().add(allottedResource) sliceProfileInstance.setAllottedResources(allottedResources) - client.update(sliceProfileInstanceUri, sliceProfileInstance) + client.update(sliceProfileInstanceUri, sliceProfileInstance) */ + + client.connect(sliceProfileInstanceUri, allottedResourceUri) } else { exceptionUtil.buildAndThrowWorkflowException(execution, 500, "No slice profile instance found with id = " + sliceProfileInstanceId) @@ -276,17 +324,83 @@ class DoModifyCoreNSSI extends DoCommonCoreNSSI { // Associates NSSI with Allotted Resource try { AAIResourceUri nssiUri = AAIUriFactory.createResourceUri(Types.SERVICE_INSTANCE.getFragment(nssiId)) - client.connect(nssiUri, allottedResourceUri, AAIEdgeLabel.USES) + client.connect(allottedResourceUri, nssiUri) } catch(Exception e){ exceptionUtil.buildAndThrowWorkflowException(execution, 25000, "Exception occured while NSSI with Allotted Resource connect call: " + e.getMessage()) } - LOGGER.trace("${PREFIX} Exit associateSliceProfileInstanceWithNSSI") + LOGGER.debug("${PREFIX} Exit associateSliceProfileInstanceWithNSSI") } @Override - String getPrefix() { + void checkAssociatedProfiles(DelegateExecution execution, List<SliceProfile> associatedProfiles, ServiceInstance nssi) { + LOGGER.debug("${PREFIX} Start checkAssociatedProfiles") + + LOGGER.debug("associatedProfiles == null = " + (associatedProfiles == null)) + if(associatedProfiles == null || associatedProfiles.isEmpty()) { + String isCreateSliceProfileInstanceVar = execution.getVariable("isCreateSliceProfileInstance" ) + boolean isCreateSliceProfileInstance = Boolean.parseBoolean(isCreateSliceProfileInstanceVar) + + if(!isCreateSliceProfileInstance) { // New Slice Profile Instance should not be created + String msg = String.format("No associated profiles found for NSSI %s in AAI", nssi.getServiceInstanceId()) + LOGGER.error(msg) + exceptionUtil.buildAndThrowWorkflowException(execution, 2500, msg) + } + } + + LOGGER.debug("${PREFIX} Exit checkAssociatedProfiles") + } + + + /** + * Calculates a final list of S-NSSAI + * @param execution + */ + void calculateSNSSAI(DelegateExecution execution) { + LOGGER.debug("${getPrefix()} Start calculateSNSSAI") + + def currentNSSI = execution.getVariable("currentNSSI") + + List<SliceProfile> associatedProfiles = (List<SliceProfile>)currentNSSI['associatedProfiles'] + + String currentSNSSAI = currentNSSI['S-NSSAI'] + + String givenSliceProfileId = currentNSSI['sliceProfileId'] + + List<String> snssais = new ArrayList<>() + + String isCreateSliceProfileInstanceVar = execution.getVariable("isCreateSliceProfileInstance" ) + + boolean isCreateSliceProfileInstance = Boolean.parseBoolean(isCreateSliceProfileInstanceVar) + + if(isCreateSliceProfileInstance) { // Slice Profile Instance has to be created + for (SliceProfile associatedProfile : associatedProfiles) { + snssais.add(associatedProfile.getSNssai()) + } + + snssais.add(currentSNSSAI) + } + else { // Slice profile instance has to be deleted + if(associatedProfiles != null) { + for (SliceProfile associatedProfile : associatedProfiles) { + if (!associatedProfile.getProfileId().equals(givenSliceProfileId)) { // not given profile id + LOGGER.debug("calculateSNSSAI: associatedProfile.getSNssai()" + associatedProfile.getSNssai()) + snssais.add(associatedProfile.getSNssai()) + } else { + currentNSSI['sliceProfileS-NSSAI'] = associatedProfile + } + } + } + } + + currentNSSI['S-NSSAIs'] = snssais + + LOGGER.debug("${getPrefix()} Exit calculateSNSSAI") + } + + + private String getPrefix() { return PREFIX } diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/ServiceIntentUtils.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/ServiceIntentUtils.groovy index f60bfa1c47..c77e6b8a75 100644 --- a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/ServiceIntentUtils.groovy +++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/ServiceIntentUtils.groovy @@ -361,7 +361,7 @@ class ServiceIntentUtils { } String getFirstPlmnIdFromSliceProfile(String sliceProfileStr) { - String plmnListStr = jsonUtil.getJsonValue(sliceProfileStr, "plmnIdList") + String plmnListStr = jsonUtil.getJsonValue(sliceProfileStr, "pLMNIdList") String res = jsonUtil.StringArrayToList(plmnListStr).get(0) return res @@ -666,4 +666,4 @@ class ServiceIntentUtils { return res } -}
\ No newline at end of file +} diff --git a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/TnNssmfUtils.groovy b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/TnNssmfUtils.groovy index fc21ed4a5e..08c03b0dbb 100644 --- a/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/TnNssmfUtils.groovy +++ b/bpmn/so-bpmn-infrastructure-common/src/main/groovy/org/onap/so/bpmn/infrastructure/scripts/TnNssmfUtils.groovy @@ -293,7 +293,7 @@ class TnNssmfUtils { } String getFirstPlmnIdFromSliceProfile(String sliceProfileStr) { - String plmnListStr = jsonUtil.getJsonValue(sliceProfileStr, "plmnIdList") + String plmnListStr = jsonUtil.getJsonValue(sliceProfileStr, "pLMNIdList") String res = jsonUtil.StringArrayToList(plmnListStr).get(0) return res @@ -598,4 +598,4 @@ class TnNssmfUtils { return res } -}
\ No newline at end of file +} diff --git a/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/DoCommonCoreNSSITest.groovy b/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/DoCommonCoreNSSITest.groovy index 9707dd2242..13edfee893 100644 --- a/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/DoCommonCoreNSSITest.groovy +++ b/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/DoCommonCoreNSSITest.groovy @@ -33,16 +33,23 @@ import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory import org.onap.aaiclient.client.aai.entities.uri.ServiceInstanceUri import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder.Types +import org.onap.logging.filter.base.ONAPComponents +import org.onap.so.bpmn.common.scripts.CatalogDbUtils +import org.onap.so.bpmn.common.scripts.CatalogDbUtilsFactory import org.onap.so.bpmn.common.scripts.ExternalAPIUtil import org.onap.so.bpmn.common.scripts.ExternalAPIUtilFactory import org.onap.so.bpmn.common.scripts.MsoGroovyTest +import org.onap.so.bpmn.common.scripts.MsoUtils import org.onap.so.bpmn.core.json.JsonUtils +import org.onap.so.client.HttpClient +import org.onap.so.client.HttpClientFactory import org.onap.so.serviceinstancebeans.RequestDetails import javax.ws.rs.core.Response import java.time.Instant import static org.junit.Assert.assertNotNull +import static org.junit.Assert.assertNull import static org.junit.Assert.assertTrue import static org.mockito.Mockito.* @@ -54,37 +61,6 @@ class DoCommonCoreNSSITest extends MsoGroovyTest { @Test - void testPreProcessRequest() { - - String nssiId = "5G-999" - when(mockExecution.getVariable("serviceInstanceID")).thenReturn(nssiId) - - String nsiId = "5G-777" - when(mockExecution.getVariable("nsiId")).thenReturn(nsiId) - - String snssai = "S-NSSAI" - String snssaiList = "[ \"${snssai}\" ]" - String sliceProfileId = "slice-profile-id" - String sliceParams = "{\n" + - "\"sliceProfile\":{\"sliceProfileId\":\"${sliceProfileId}\",\"snssaiList\":${snssaiList}}\n" + - "}" - when(mockExecution.getVariable("sliceParams")).thenReturn(sliceParams) - - DoCommonCoreNSSI dcnssi = new DoCommonCoreNSSI() - dcnssi.preProcessRequest(mockExecution) - - def currentNSSI = [:] - currentNSSI.put("nssiId", nssiId) - currentNSSI.put("nsiId", nsiId) - currentNSSI.put("sliceProfile", "{\"sliceProfileId\":\"slice-profile-id\",\"snssaiList\":[\"S-NSSAI\"]}") - currentNSSI.put("S-NSSAI", snssai) - currentNSSI.put("sliceProfileId", sliceProfileId) - Mockito.verify(mockExecution,times(1)).setVariable("currentNSSI", currentNSSI) - - } - - - @Test void testGetNetworkServiceInstance() { def currentNSSI = [:] currentNSSI.put("nssiId","5G-999") @@ -182,69 +158,6 @@ class DoCommonCoreNSSITest extends MsoGroovyTest { @Test - void testGetNSSIAssociatedProfiles() { - def currentNSSI = [:] - when(mockExecution.getVariable("currentNSSI")).thenReturn(currentNSSI) - - String nssiId = "5G-999" - ServiceInstance nssi = new ServiceInstance() - nssi.setServiceInstanceId(nssiId) - currentNSSI.put("nssiId", nssiId) - - SliceProfiles sliceProfiles = new SliceProfiles() - - List<SliceProfile> slProfiles = sliceProfiles.getSliceProfile() - slProfiles.add(new SliceProfile()) - slProfiles.add(new SliceProfile()) - - //nssi.setSliceProfiles(sliceProfiles) - currentNSSI.put("nssi", nssi) - - DoCommonCoreNSSI spy = spy(DoCommonCoreNSSI.class) - when(spy.getAAIClient()).thenReturn(client) - - AAIResourceUri nssiUri = AAIUriFactory.createResourceUri(Types.SERVICE_INSTANCE.getFragment(nssiId)) - - AAIResultWrapper wrapperMock = mock(AAIResultWrapper.class) //new AAIResultWrapper(json) - Relationships rsMock = mock(Relationships.class) - Optional<Relationships> orsMock = Optional.of(rsMock) - List<AAIResourceUri> allottedUris = new ArrayList<>() - AAIResourceUri allottedUri = AAIUriFactory.createResourceUri(Types.ALLOTTED_RESOURCE.getFragment("allotted-id")) - allottedUris.add(allottedUri) - - when(client.get(nssiUri)).thenReturn(wrapperMock) - when(wrapperMock.getRelationships()).thenReturn(orsMock) - when(rsMock.getRelatedUris(Types.ALLOTTED_RESOURCE)).thenReturn(allottedUris) - - String sliceProfileInstanceId = "slice-profile-instance-id" - ServiceInstance sliceProfileInstance = new ServiceInstance() - sliceProfileInstance.setServiceInstanceId(sliceProfileInstanceId) - sliceProfileInstance.setServiceRole("slice-profile-instance") - - List<AAIResourceUri> sliceProfileInstanceUris = new ArrayList<>() - AAIResourceUri sliceProfileInstanceUri = AAIUriFactory.createResourceUri(Types.SERVICE_INSTANCE.getFragment(sliceProfileInstance.getServiceInstanceId())) - sliceProfileInstanceUris.add(sliceProfileInstanceUri) - - Optional<ServiceInstance> sliceProfileInstanceOpt = Optional.of(sliceProfileInstance) - - when(client.get(allottedUri)).thenReturn(wrapperMock) - when(rsMock.getRelatedUris(Types.SERVICE_INSTANCE)).thenReturn(sliceProfileInstanceUris) - when(client.get(ServiceInstance.class, sliceProfileInstanceUri)).thenReturn(sliceProfileInstanceOpt) - - - SliceProfiles sps = new SliceProfiles() - sps.getSliceProfile().addAll(slProfiles) - sliceProfileInstance.setSliceProfiles(sps) - - spy.getNSSIAssociatedProfiles(mockExecution) - - List<SliceProfile> associatedProfiles = (List<SliceProfile>)currentNSSI.get("associatedProfiles") - assertTrue("sliceProfileInstanceUri not found in contect Map", currentNSSI.get("sliceProfileInstanceUri") != null) - assertTrue("Either associatedProfiles doesn't exist or size is incorrect", (associatedProfiles != null && associatedProfiles.size() == 2)) - } - - - @Test void testInvokePUTServiceInstance() { def currentNSSI = [:] @@ -263,13 +176,18 @@ class DoCommonCoreNSSITest extends MsoGroovyTest { DoCommonCoreNSSI spy = spy(DoCommonCoreNSSI.class) when(spy.getAAIClient()).thenReturn(client) - when(spy.encryptBasicAuth("mso.infra.endpoint.auth", "mso.msoKey")).thenReturn("auth-value") + GenericVnf genericVnf = new GenericVnf() + genericVnf.setServiceId("service-id") + genericVnf.setVnfName("vnf-name") + genericVnf.setModelInvariantId("model-invariant-id") + genericVnf.setModelCustomizationId("model-customization-id") + genericVnf.setVnfName("vnf-name") + genericVnf.setVnfId("vnf-id") - String authHeaderResponse = "auth-header" + currentNSSI.put("constituteVnf", genericVnf) - when(spy.getAuthHeader(mockExecution, "auth-value", "mso.msoKey")).thenReturn(authHeaderResponse) - String urlString = String.format("http://mso.onap:8088/serviceInstantiation/v7/serviceInstances/%s", networkServiceInstance.getServiceInstanceId()) + String urlString = String.format("http://mso.onap:8088/serviceInstantiation/v7/serviceInstances/%s/vnfs/%s", networkServiceInstance.getServiceInstanceId(), genericVnf.getVnfId()) String callPUTServiceInstanceResponse = "put" @@ -279,13 +197,36 @@ class DoCommonCoreNSSITest extends MsoGroovyTest { when(spy.prepareRequestDetails(mockExecution)).thenReturn(requestDetailsStr) - when(spy.callPUTServiceInstance(urlString, "auth-header", requestDetailsStr)).thenReturn(callPUTServiceInstanceResponse) + MsoUtils msoUtilsMock = mock(MsoUtils.class) + String basicAuth = "basicAuth" + when(msoUtilsMock.getBasicAuth(anyString(), anyString())).thenReturn(basicAuth) + + HttpClientFactory httpClientFactoryMock = mock(HttpClientFactory.class) + when(spy.getHttpClientFactory()).thenReturn(httpClientFactoryMock) + Response responseMock = mock(Response.class) + + HttpClient httpClientMock = mock(HttpClient.class) + + when(httpClientFactoryMock.newJsonClient(any(), any())).thenReturn(httpClientMock) + + when(httpClientMock.put(requestDetailsStr)).thenReturn(responseMock) + + when(responseMock.getStatus()).thenReturn(200) + when(responseMock.hasEntity()).thenReturn(true) + + String macroOperationId = "request-id" + String requestSelfLink = "request-self-link" + String entity = "{\"requestReferences\":{\"requestId\": \"${macroOperationId}\",\"requestSelfLink\":\"${requestSelfLink}\"}}" + when(responseMock.readEntity(String.class)).thenReturn(entity) spy.invokePUTServiceInstance(mockExecution) + + Mockito.verify(mockExecution,times(1)).setVariable("macroOperationId", macroOperationId) + Mockito.verify(mockExecution,times(1)).setVariable("requestSelfLink", requestSelfLink) } - @Test + @Test(expected = Test.None.class) void testRemoveSPAssociationWithNSSI() { def currentNSSI = [:] @@ -349,7 +290,7 @@ class DoCommonCoreNSSITest extends MsoGroovyTest { spy.removeSPAssociationWithNSSI(mockExecution) - assertTrue("Association between slice profile and NSSI wasn't removed", ((ServiceInstance)currentNSSI.get("sliceProfileInstance")).getSliceProfiles().getSliceProfile().size() == (sizeBefore - 1)) + // assertTrue("Association between slice profile and NSSI wasn't removed", ((ServiceInstance)currentNSSI.get("sliceProfileInstance")).getSliceProfiles().getSliceProfile().size() == (sizeBefore - 1)) } @@ -471,6 +412,15 @@ class DoCommonCoreNSSITest extends MsoGroovyTest { prepareProject(cloudRegionAAIUri) + CatalogDbUtilsFactory catalogDbUtilsFactoryMock = mock(CatalogDbUtilsFactory.class) + when(spy.getCatalogDbUtilsFactory()).thenReturn(catalogDbUtilsFactoryMock) + + CatalogDbUtils catalogDbUtilsMock = mock(CatalogDbUtils.class) + when(catalogDbUtilsFactoryMock.create()).thenReturn(catalogDbUtilsMock) + + String json = "{\"serviceResources\":{\"serviceVnfs\": [{\"modelInfo\": {\"modelCustomizationUuid\":\"model-customization-uuid\",\"modelId\":\"model-id\"},\"vfModules\":[{\"modelInfo\": {\"modelCustomizationUuid\":\"model-customization-uuid\",\"modelId\":\"model-id\"}}]}]}}" + when(catalogDbUtilsMock.getServiceResourcesByServiceModelInvariantUuidString(mockExecution, networkServiceInstance.getModelInvariantId())).thenReturn(json) + String prepareRequestDetailsResponse = spy.prepareRequestDetails(mockExecution) JsonUtils jsonUtil = new JsonUtils() @@ -492,11 +442,16 @@ class DoCommonCoreNSSITest extends MsoGroovyTest { String nssiId = "5G-999" String nsiId = "5G-777" + ServiceInstance nssi = new ServiceInstance() + nssi.setServiceInstanceId(nssiId) + nssi.setModelVersionId(UUID.randomUUID().toString()) + currentNSSI.put("nssiId", nssiId) currentNSSI.put("nsiId", nsiId) currentNSSI.put("e2eServiceInstanceId", "e2eServiceInstanceId") currentNSSI.put("operationId", "operationId") currentNSSI.put("operationType", "operationType") + currentNSSI.put("nssi", nssi) DoCommonCoreNSSI spy = spy(DoCommonCoreNSSI.class) @@ -515,11 +470,16 @@ class DoCommonCoreNSSITest extends MsoGroovyTest { String nssiId = "5G-999" String nsiId = "5G-777" + ServiceInstance nssi = new ServiceInstance() + nssi.setServiceInstanceId(nssiId) + nssi.setModelVersionId(UUID.randomUUID().toString()) + currentNSSI.put("nssiId", nssiId) currentNSSI.put("nsiId", nsiId) currentNSSI.put("e2eServiceInstanceId", "e2eServiceInstanceId") currentNSSI.put("operationId", "operationId") currentNSSI.put("operationType", "operationType") + currentNSSI.put("nssi", nssi) DoCommonCoreNSSI spy = spy(DoCommonCoreNSSI.class) @@ -539,7 +499,7 @@ class DoCommonCoreNSSITest extends MsoGroovyTest { @Test void testGetPUTServiceInstanceProgressInProgress() { - executePUTServiceInstanceProgress("INPROGRESS") + executePUTServiceInstanceProgress("IN_PROGRESS") Mockito.verify(mockExecution,times(1)).setVariable("putStatus", "processing") } @@ -547,7 +507,7 @@ class DoCommonCoreNSSITest extends MsoGroovyTest { @Test void testGetPUTServiceInstanceProgressCompleted() { - executePUTServiceInstanceProgress("COMPLETED") + executePUTServiceInstanceProgress("COMPLETE") Mockito.verify(mockExecution,times(1)).setVariable("putStatus", "completed") } @@ -567,6 +527,21 @@ class DoCommonCoreNSSITest extends MsoGroovyTest { } + @Test + void testPostProcessRequest() { + + def currentNSSI = [:] + mockExecution.setVariable("currentNSSI", currentNSSI) + + DoCommonCoreNSSI dcnssi = new DoCommonCoreNSSI() + dcnssi.postProcessRequest(mockExecution) + + currentNSSI = mockExecution.getVariable("currentNSSI") + assertNull("currentNSSI is not null", currentNSSI) + + } + + void executePUTServiceInstanceProgress(String state) { def currentNSSI = [:] @@ -575,23 +550,37 @@ class DoCommonCoreNSSITest extends MsoGroovyTest { String url = "http://mso.onap:8088/serviceInstantiation/v7/serviceInstances/5G-777" - currentNSSI.put("putServiceInstanceURL", url) + currentNSSI['requestSelfLink'] = url DoCommonCoreNSSI spy = spy(DoCommonCoreNSSI.class) ExternalAPIUtilFactory externalAPIUtilFactoryMock = mock(ExternalAPIUtilFactory.class) when(spy.getExternalAPIUtilFactory()).thenReturn(externalAPIUtilFactoryMock) - ExternalAPIUtil externalAPIUtilMock = mock(ExternalAPIUtil.class) + // ExternalAPIUtil externalAPIUtilMock = mock(ExternalAPIUtil.class) - when(externalAPIUtilFactoryMock.create()).thenReturn(externalAPIUtilMock) + // when(externalAPIUtilFactoryMock.create()).thenReturn(externalAPIUtilMock) + MsoUtils msoUtilsMock = mock(MsoUtils.class) + String basicAuth = "basicAuth" + when(msoUtilsMock.getBasicAuth(anyString(), anyString())).thenReturn(basicAuth) + + HttpClientFactory httpClientFactoryMock = mock(HttpClientFactory.class) + when(spy.getHttpClientFactory()).thenReturn(httpClientFactoryMock) Response responseMock = mock(Response.class) - when(externalAPIUtilMock.executeExternalAPIGetCall(mockExecution, url)).thenReturn(responseMock) + + HttpClient httpClientMock = mock(HttpClient.class) + + + when(httpClientFactoryMock.newJsonClient(any(), any())).thenReturn(httpClientMock) + + when(httpClientMock.get()).thenReturn(responseMock) +// when(externalAPIUtilMock.executeExternalAPIGetCall(mockExecution, url)).thenReturn(responseMock) when(responseMock.getStatus()).thenReturn(200) + when(responseMock.hasEntity()).thenReturn(true) - String entity = "{\"state\":\"ACCEPTED\",\"orderItem\":[{\"service\":{\"id\":\"5G-999\"},\"state\":\"${state}\"}]}" + String entity = "{\"request\":{\"requestStatus\":{\"requestState\":\"${state}\"}},\"state\":\"ACCEPTED\"}" when(responseMock.readEntity(String.class)).thenReturn(entity) spy.getPUTServiceInstanceProgress(mockExecution) @@ -750,4 +739,5 @@ class DoCommonCoreNSSITest extends MsoGroovyTest { AAIResourceUri modelVerUrl = AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.serviceDesignAndCreation().model(vfModule.getModelInvariantId()).modelVer(vfModule.getModelVersionId())) when(client.get(ModelVer.class, modelVerUrl)).thenReturn(modelVerOpt) } + } diff --git a/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/DoDeallocateCoreNSSITest.groovy b/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/DoDeallocateCoreNSSITest.groovy index 26b96a0a4a..5bf4f40e50 100644 --- a/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/DoDeallocateCoreNSSITest.groovy +++ b/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/DoDeallocateCoreNSSITest.groovy @@ -20,17 +20,26 @@ package org.onap.so.bpmn.infrastructure.scripts +import com.fasterxml.jackson.databind.ObjectMapper import org.junit.Before import org.junit.Test import org.mockito.Mockito import org.onap.aai.domain.yang.v19.* +import org.onap.aaiclient.client.aai.entities.AAIResultWrapper +import org.onap.aaiclient.client.aai.entities.Relationships import org.onap.aaiclient.client.aai.entities.uri.AAIResourceUri import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder.Types +import org.onap.logging.filter.base.ONAPComponents import org.onap.so.bpmn.common.scripts.ExternalAPIUtil import org.onap.so.bpmn.common.scripts.ExternalAPIUtilFactory import org.onap.so.bpmn.common.scripts.MsoGroovyTest +import org.onap.so.bpmn.common.scripts.MsoUtils +import org.onap.so.bpmn.common.scripts.OofUtils +import org.onap.so.client.HttpClient +import org.onap.so.client.HttpClientFactory +import org.onap.so.serviceinstancebeans.RequestDetails import javax.ws.rs.core.Response @@ -47,10 +56,44 @@ class DoDeallocateCoreNSSITest extends MsoGroovyTest { @Test + void testPreProcessRequest() { + + String nssiId = "5G-999" + when(mockExecution.getVariable("serviceInstanceID")).thenReturn(nssiId) + + String nsiId = "5G-777" + when(mockExecution.getVariable("nsiId")).thenReturn(nsiId) + + String snssai = "S-NSSAI" + String snssaiList = "[ \"${snssai}\" ]" + String sliceProfileId = "slice-profile-id" + String modifyAction = "allocate" + String sliceParams = "{\n" + + "\"sliceProfileId\":\"${sliceProfileId}\",\"snssaiList\":${snssaiList}\n" + + "}" + when(mockExecution.getVariable("sliceParams")).thenReturn(sliceParams) + + DoDeallocateCoreNSSI obj = new DoDeallocateCoreNSSI() + obj.preProcessRequest(mockExecution) + + def currentNSSI = [:] + currentNSSI.put("nssiId", nssiId) + currentNSSI.put("nsiId", nsiId) + currentNSSI.put("sliceProfile", sliceParams) + currentNSSI.put("S-NSSAI", snssai) + currentNSSI.put("sliceProfileId", sliceProfileId) + Mockito.verify(mockExecution,times(1)).setVariable("currentNSSI", currentNSSI) + + } + + + @Test void testExecuteTerminateNSSIQuery() { def currentNSSI = [:] - currentNSSI.put("nssiId","5G-999") + + String nssiId = "5G-999" + currentNSSI.put("nssiId", nssiId) when(mockExecution.getVariable("currentNSSI")).thenReturn(currentNSSI) @@ -62,6 +105,9 @@ class DoDeallocateCoreNSSITest extends MsoGroovyTest { DoDeallocateCoreNSSI spy = spy(DoDeallocateCoreNSSI.class) when(spy.getAAIClient()).thenReturn(client) + OofUtils oofUtilsMock = mock(OofUtils.class) + when(spy.getOofUtils()).thenReturn(oofUtilsMock) + when(spy.encryptBasicAuth("mso.oof.auth", "mso.msoKey")).thenReturn("auth-value") String authHeaderResponse = "auth-header" @@ -73,6 +119,14 @@ class DoDeallocateCoreNSSITest extends MsoGroovyTest { when(spy.getAuthHeader(mockExecution, "auth-value", "mso.msoKey")).thenReturn(authHeaderResponse) + AAIResourceUri nssiUri = AAIUriFactory.createResourceUri(Types.SERVICE_INSTANCE.getFragment(nssiId)) + + ServiceInstance nssi = new ServiceInstance() + nssi.setServiceInstanceId("5G-999") + Optional<ServiceInstance> nssiOpt = Optional.of(nssi) + + when(client.get(ServiceInstance.class, nssiUri)).thenReturn(nssiOpt) + String urlString = "http://oof.onap:8088" String httpRequest = "{\n" + @@ -85,7 +139,16 @@ class DoDeallocateCoreNSSITest extends MsoGroovyTest { " }\n" + "}" - boolean terminateResponse = true + String requestId = "request-id" + String nxlId = nssi.getServiceInstanceId() + String nxlType = "NSSI" + String messageType = "cn" + String serviceInstanceId = nssi.getServiceInstanceId() + + when(mockExecution.getVariable("msoRequestId")).thenReturn(requestId) + when(oofUtilsMock.buildTerminateNxiRequest(requestId, nxlId, nxlType, messageType, serviceInstanceId)).thenReturn(httpRequest) + + String terminateResponse = "false" String oofResponse = "{\n" + " \"requestId\": \"mso-request-id\",\n" + @@ -96,18 +159,28 @@ class DoDeallocateCoreNSSITest extends MsoGroovyTest { " \"reason\": \"\"\n" + " }\n" - String oofCallResponse = oofResponse + String apiPath = "/api/oof/terminate/nxi/v1" - /* String oofCallResponse = "{\n" + - " \"errorCode\": \"401\",\n" + - " \"errorMessage\": \"Exception during the call\"\n" + - "}" */ + urlString = urlString + apiPath + + HttpClientFactory httpClientFactoryMock = mock(HttpClientFactory.class) + when(spy.getHttpClientFactory()).thenReturn(httpClientFactoryMock) + Response responseMock = mock(Response.class) + + HttpClient httpClientMock = mock(HttpClient.class) + + when(httpClientFactoryMock.newJsonClient(any(), any())).thenReturn(httpClientMock) - when(spy.callOOF(urlString, "auth-header", httpRequest)).thenReturn(oofCallResponse) + when(httpClientMock.post(httpRequest)).thenReturn(responseMock) + + when(responseMock.getStatus()).thenReturn(200) + when(responseMock.hasEntity()).thenReturn(true) + + when(responseMock.readEntity(String.class)).thenReturn(oofResponse) spy.executeTerminateNSSIQuery(mockExecution) - verify(mockExecution).setVariable("isTerminateNSSI", terminateResponse) + Mockito.verify(mockExecution,times(1)).setVariable("isTerminateNSSI", terminateResponse) } @@ -125,56 +198,101 @@ class DoDeallocateCoreNSSITest extends MsoGroovyTest { currentNSSI.put("networkServiceInstance", networkServiceInstance) - when(mockExecution.getVariable("nbi.endpoint.url")).thenReturn("http://nbi.onap:8088") + when(mockExecution.getVariable("mso.infra.endpoint.url")).thenReturn("http://mso.onap:8088") when(mockExecution.getVariable("mso.msoKey")).thenReturn("mso.msoKey") when(mockExecution.getVariable("mso.infra.endpoint.auth")).thenReturn("mso.infra.endpoint.auth") DoDeallocateCoreNSSI spy = spy(DoDeallocateCoreNSSI.class) when(spy.getAAIClient()).thenReturn(client) - when(spy.encryptBasicAuth("mso.infra.endpoint.auth", "mso.msoKey")).thenReturn("auth-value") + GenericVnf genericVnf = new GenericVnf() + genericVnf.setServiceId("service-id") + genericVnf.setVnfName("vnf-name") + genericVnf.setModelInvariantId("model-invariant-id") + genericVnf.setModelCustomizationId("model-customization-id") + genericVnf.setVnfName("vnf-name") + genericVnf.setVnfId("vnf-id") - String authHeaderResponse = "auth-header" + currentNSSI.put("constituteVnf", genericVnf) - /* String authHeaderResponse = "{\n" + - " \"errorCode\": \"401\",\n" + - " \"errorMessage\": \"Bad request\"\n" + - "}" */ + String urlString = String.format("http://mso.onap:8088/serviceInstantiation/v7/serviceInstances/%s/vnfs/%s", networkServiceInstance.getServiceInstanceId(), genericVnf.getVnfId()) - when(spy.getAuthHeader(mockExecution, "auth-value", "mso.msoKey")).thenReturn(authHeaderResponse) + RequestDetails requestDetails = new RequestDetails() + ObjectMapper mapper = new ObjectMapper() + String requestDetailsStr = mapper.writeValueAsString(requestDetails) + + when(spy.prepareRequestDetails(mockExecution)).thenReturn(requestDetailsStr) + + MsoUtils msoUtilsMock = mock(MsoUtils.class) + String basicAuth = "basicAuth" + when(msoUtilsMock.getBasicAuth(anyString(), anyString())).thenReturn(basicAuth) + + HttpClientFactory httpClientFactoryMock = mock(HttpClientFactory.class) + when(spy.getHttpClientFactory()).thenReturn(httpClientFactoryMock) + Response responseMock = mock(Response.class) - String urlString = String.format("http://nbi.onap:8088/api/v4/serviceOrder/%s", networkServiceInstance.getServiceInstanceId()) + HttpClient httpClientMock = mock(HttpClient.class) - String callDeleteServiceOrderResponse = "deleted" + when(httpClientFactoryMock.newJsonClient(any(), any())).thenReturn(httpClientMock) - when(spy.callDeleteServiceOrder(mockExecution, urlString, "auth-header")).thenReturn(callDeleteServiceOrderResponse) + when(httpClientMock.delete()).thenReturn(responseMock) + + when(responseMock.getStatus()).thenReturn(200) + when(responseMock.hasEntity()).thenReturn(true) + + String macroOperationId = "request-id" + String requestSelfLink = "request-self-link" + String entity = "{\"requestReferences\":{\"requestId\": \"${macroOperationId}\",\"requestSelfLink\":\"${requestSelfLink}\"}}" + when(responseMock.readEntity(String.class)).thenReturn(entity) spy.deleteServiceOrder(mockExecution) + + Mockito.verify(mockExecution,times(1)).setVariable("macroOperationId", macroOperationId) + Mockito.verify(mockExecution,times(1)).setVariable("requestSelfLink", requestSelfLink) + + assertTrue(currentNSSI['requestSelfLink'].equals(requestSelfLink)) } @Test - void testCalculateSNSSAI() { + void testCalculateSNSSAITerminateNSSI() { + invokeCalculateSNSSAI("true") + } + + @Test + void testCalculateSNSSAINotTerminateNSSI() { + invokeCalculateSNSSAI("false") + } + + void invokeCalculateSNSSAI(String isTerminateNSSI) { def currentNSSI = [:] when(mockExecution.getVariable("currentNSSI")).thenReturn(currentNSSI) + when(mockExecution.getVariable("isTerminateNSSI")).thenReturn(isTerminateNSSI) + String theSNSSAI = "theS-NSSAI" currentNSSI.put("S-NSSAI", theSNSSAI) + String theSliceProfileId = "the-slice-profile-id" + currentNSSI['sliceProfileId'] = theSliceProfileId + List<SliceProfile> associatedProfiles = new ArrayList<>() SliceProfile sliceProfile1 = new SliceProfile() - sliceProfile1.setSNssai("snssai1") + sliceProfile1.setProfileId(theSliceProfileId) + sliceProfile1.setSNssai(theSNSSAI) SliceProfile sliceProfile2 = new SliceProfile() - sliceProfile2.setSNssai(theSNSSAI) + sliceProfile2.setSNssai("snssai2") SliceProfile sliceProfile3 = new SliceProfile() sliceProfile3.setSNssai("snssai3") - associatedProfiles.add(sliceProfile1) - associatedProfiles.add(sliceProfile2) - associatedProfiles.add(sliceProfile3) + if(isTerminateNSSI.equals("false")) { + associatedProfiles.add(sliceProfile1) + associatedProfiles.add(sliceProfile2) + associatedProfiles.add(sliceProfile3) + } int sizeBefore = associatedProfiles.size() @@ -186,9 +304,14 @@ class DoDeallocateCoreNSSITest extends MsoGroovyTest { List<SliceProfile> snssais = (List<SliceProfile>)currentNSSI.get("S-NSSAIs") SliceProfile sliceProfileContainsSNSSAI = (SliceProfile)currentNSSI.get("sliceProfileS-NSSAI") - assertTrue("Either snssais doesn't exist or size is incorrect", (snssais != null && snssais.size() == (sizeBefore - 1))) - assertNotNull("Slice Profile which contains given S-NSSAI not found", sliceProfileContainsSNSSAI) - assertTrue("Wrong Slice Profile", sliceProfileContainsSNSSAI.getSNssai().equals(theSNSSAI)) + if(isTerminateNSSI.equals("false")) { + assertTrue("Either snssais doesn't exist or size is incorrect", (snssais != null && snssais.size() == (sizeBefore - 1))) + assertNotNull("Slice Profile which contains given S-NSSAI not found", sliceProfileContainsSNSSAI) + assertTrue("Wrong Slice Profile", sliceProfileContainsSNSSAI.getSNssai().equals(theSNSSAI)) + } + else { + assertTrue("Either snssais doesn't exist or size is incorrect", (snssais != null && snssais.size() == 0)) + } } @@ -212,6 +335,10 @@ class DoDeallocateCoreNSSITest extends MsoGroovyTest { ServiceInstance nssi = new ServiceInstance() nssi.setServiceInstanceId(nssiId) + ServiceInstance nsi = new ServiceInstance() + nsi.setServiceInstanceId(nsiId) + nsi.setServiceRole("nsi") + AllottedResources allottedResources = new AllottedResources() AllottedResource allottedResource = new AllottedResource() allottedResource.setId(UUID.randomUUID().toString()) @@ -222,7 +349,26 @@ class DoDeallocateCoreNSSITest extends MsoGroovyTest { AAIResourceUri nsiUri = AAIUriFactory.createResourceUri(Types.SERVICE_INSTANCE.getFragment(nsiId)) - doNothing().when(client).update(nssiUri, nssi) + AAIResultWrapper wrapperMock = mock(AAIResultWrapper.class) + when(client.get(nssiUri)).thenReturn(wrapperMock) + Relationships rsMock = mock(Relationships.class) + Optional<Relationships> orsMock = Optional.of(rsMock) + when(wrapperMock.getRelationships()).thenReturn(orsMock) + + List<AAIResourceUri> allottedUris = new ArrayList<>() + AAIResourceUri allottedUri = AAIUriFactory.createResourceUri(Types.ALLOTTED_RESOURCE.getFragment("allotted-id")) + allottedUris.add(allottedUri) + + when(rsMock.getRelatedUris(Types.ALLOTTED_RESOURCE)).thenReturn(allottedUris) + + List<AAIResourceUri> nsiUris = new ArrayList<>() + nsiUris.add(nsiUri) + + Optional<ServiceInstance> nsiOpt = Optional.of(nsi) + + when(client.get(allottedUri)).thenReturn(wrapperMock) + when(rsMock.getRelatedUris(Types.SERVICE_INSTANCE)).thenReturn(nsiUris) + when(client.get(ServiceInstance.class, nsiUri)).thenReturn(nsiOpt) String globalSubscriberId = "globalSubscriberId" String subscriptionServiceType = "subscription-service-type" @@ -231,7 +377,7 @@ class DoDeallocateCoreNSSITest extends MsoGroovyTest { AAIResourceUri allottedResourceUri = AAIUriFactory.createResourceUri(AAIFluentTypeBuilder.business().customer(globalSubscriberId).serviceSubscription(subscriptionServiceType).serviceInstance(nssiId).allottedResource(allottedResource.getId())) - doNothing().when(client).disconnect(nsiUri, allottedResourceUri) + doNothing().when(client).disconnect(nssiUri, nsiUri) spy.removeNSSIAssociationWithNSI(mockExecution) @@ -270,7 +416,7 @@ class DoDeallocateCoreNSSITest extends MsoGroovyTest { @Test void testDeleteServiceOrderProgressInProgress() { - executeDeleteServiceOrderProgress("INPROGRESS") + executeDeleteServiceOrderProgress("IN_PROGRESS") Mockito.verify(mockExecution,times(1)).setVariable("deleteStatus", "processing") } @@ -278,7 +424,7 @@ class DoDeallocateCoreNSSITest extends MsoGroovyTest { @Test void testDeleteServiceOrderProgressCompleted() { - executeDeleteServiceOrderProgress("COMPLETED") + executeDeleteServiceOrderProgress("COMPLETE") Mockito.verify(mockExecution,times(1)).setVariable("deleteStatus", "completed") } @@ -290,23 +436,37 @@ class DoDeallocateCoreNSSITest extends MsoGroovyTest { String url = "http://nbi.onap:8088/api/v4/serviceOrder/NS-777" - currentNSSI.put("deleteServiceOrderURL", url) + currentNSSI['requestSelfLink'] = url DoDeallocateCoreNSSI spy = spy(DoDeallocateCoreNSSI.class) - ExternalAPIUtilFactory externalAPIUtilFactoryMock = mock(ExternalAPIUtilFactory.class) + /*ExternalAPIUtilFactory externalAPIUtilFactoryMock = mock(ExternalAPIUtilFactory.class) when(spy.getExternalAPIUtilFactory()).thenReturn(externalAPIUtilFactoryMock) ExternalAPIUtil externalAPIUtilMock = mock(ExternalAPIUtil.class) - when(externalAPIUtilFactoryMock.create()).thenReturn(externalAPIUtilMock) + when(externalAPIUtilFactoryMock.create()).thenReturn(externalAPIUtilMock) */ + + MsoUtils msoUtilsMock = mock(MsoUtils.class) + String basicAuth = "basicAuth" + when(msoUtilsMock.getBasicAuth(anyString(), anyString())).thenReturn(basicAuth) + HttpClientFactory httpClientFactoryMock = mock(HttpClientFactory.class) + when(spy.getHttpClientFactory()).thenReturn(httpClientFactoryMock) Response responseMock = mock(Response.class) - when(externalAPIUtilMock.executeExternalAPIGetCall(mockExecution, url)).thenReturn(responseMock) + + HttpClient httpClientMock = mock(HttpClient.class) + + + when(httpClientFactoryMock.newJsonClient(any(), any())).thenReturn(httpClientMock) + + when(httpClientMock.get()).thenReturn(responseMock) +// when(externalAPIUtilMock.executeExternalAPIGetCall(mockExecution, url)).thenReturn(responseMock) when(responseMock.getStatus()).thenReturn(200) + when(responseMock.hasEntity()).thenReturn(true) - String entity = "{\"state\":\"ACCEPTED\",\"orderItem\":[{\"service\":{\"id\":\"5G-999\"},\"state\":\"${state}\"}]}" + String entity = "{\"request\":{\"requestStatus\":{\"requestState\":\"${state}\"}},\"state\":\"ACCEPTED\"}" when(responseMock.readEntity(String.class)).thenReturn(entity) spy.getDeleteServiceOrderProgress(mockExecution) diff --git a/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/DoModifyCoreNSSITest.groovy b/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/DoModifyCoreNSSITest.groovy index ac6f897dfa..7293a2389e 100644 --- a/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/DoModifyCoreNSSITest.groovy +++ b/bpmn/so-bpmn-infrastructure-common/src/test/groovy/org/onap/so/bpmn/infrastructure/scripts/DoModifyCoreNSSITest.groovy @@ -29,11 +29,14 @@ import org.onap.aai.domain.yang.v19.ServiceInstance import org.onap.aai.domain.yang.v19.SliceProfile import org.onap.aai.domain.yang.v19.SliceProfiles import org.onap.aaiclient.client.aai.entities.AAIEdgeLabel +import org.onap.aaiclient.client.aai.entities.AAIResultWrapper +import org.onap.aaiclient.client.aai.entities.Relationships import org.onap.aaiclient.client.aai.entities.uri.AAIResourceUri import org.onap.aaiclient.client.aai.entities.uri.AAIUriFactory import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder import org.onap.aaiclient.client.generated.fluentbuilders.AAIFluentTypeBuilder.Types import org.onap.so.bpmn.common.scripts.MsoGroovyTest +import org.springframework.data.domain.Slice import static org.junit.Assert.assertNotNull import static org.junit.Assert.assertTrue @@ -48,6 +51,40 @@ class DoModifyCoreNSSITest extends MsoGroovyTest { @Test + void testPreProcessRequest() { + + String nssiId = "5G-999" + when(mockExecution.getVariable("serviceInstanceID")).thenReturn(nssiId) + + String nsiId = "5G-777" + when(mockExecution.getVariable("nsiId")).thenReturn(nsiId) + + String snssai = "S-NSSAI" + String snssaiList = "[ \"${snssai}\" ]" + String sliceProfileId = "slice-profile-id" + String modifyAction = "allocate" + String sliceParams = "{\n" + + "\"sliceProfileId\":\"${sliceProfileId}\",\"snssaiList\":${snssaiList}\n" + + ",\"modifyAction\":\"${modifyAction}\"\n" + + "}" + when(mockExecution.getVariable("sliceParams")).thenReturn(sliceParams) + + DoModifyCoreNSSI obj = new DoModifyCoreNSSI() + obj.preProcessRequest(mockExecution) + + def currentNSSI = [:] + currentNSSI.put("nssiId", nssiId) + currentNSSI.put("nsiId", nsiId) + currentNSSI.put("sliceProfile", sliceParams) + currentNSSI.put("S-NSSAI", snssai) + currentNSSI.put("sliceProfileId", sliceProfileId) + + Mockito.verify(mockExecution,times(1)).setVariable("currentNSSI", currentNSSI) + + } + + + @Test void testCalculateSNSSAISliceProfileInstanceHasToBeDeleted() { def currentNSSI = [:] when(mockExecution.getVariable("currentNSSI")).thenReturn(currentNSSI) @@ -58,31 +95,37 @@ class DoModifyCoreNSSITest extends MsoGroovyTest { currentNSSI.put("S-NSSAI", theSNSSAI) + String sliceProfileId = "the-slice-profile-id" + currentNSSI['sliceProfileId'] = sliceProfileId + List<SliceProfile> associatedProfiles = new ArrayList<>() SliceProfile sliceProfile1 = new SliceProfile() - sliceProfile1.setSNssai("snssai1") + sliceProfile1.setProfileId(sliceProfileId) + sliceProfile1.setSNssai(theSNSSAI) SliceProfile sliceProfile2 = new SliceProfile() + sliceProfile2.setProfileId("sp-2") sliceProfile2.setSNssai(theSNSSAI) SliceProfile sliceProfile3 = new SliceProfile() + sliceProfile3.setProfileId("sp-3") sliceProfile3.setSNssai("snssai2") associatedProfiles.add(sliceProfile1) associatedProfiles.add(sliceProfile2) associatedProfiles.add(sliceProfile3) - int sizeBefore = associatedProfiles.size() - currentNSSI.put("associatedProfiles", associatedProfiles) + when(mockExecution.getVariable("isCreateSliceProfileInstance" )).thenReturn(false) + DoModifyCoreNSSI obj = new DoModifyCoreNSSI() obj.calculateSNSSAI(mockExecution) List<SliceProfile> snssais = (List<SliceProfile>)currentNSSI.get("S-NSSAIs") SliceProfile sliceProfileContainsSNSSAI = (SliceProfile)currentNSSI.get("sliceProfileS-NSSAI") - assertTrue("Either snssais doesn't exist or size is incorrect", (snssais != null && snssais.size() == (sizeBefore - 1))) + assertTrue("Either snssais doesn't exist or size is incorrect", (snssais != null && snssais.size() == (associatedProfiles.size() - 1))) assertNotNull("Slice Profile which contains given S-NSSAI not found", sliceProfileContainsSNSSAI) assertTrue("Wrong Slice Profile", sliceProfileContainsSNSSAI.getSNssai().equals(theSNSSAI)) } @@ -233,4 +276,114 @@ class DoModifyCoreNSSITest extends MsoGroovyTest { } + + @Test + void testGetNSSIAssociatedProfilesCreateSLiceProfileEmptySLiceProfiles() { + invokeGetNSSIAssociatedProfiles("true", true) + } + + @Test + void testGetNSSIAssociatedProfilesCreateSLiceProfileNonEmptySliceProfiles() { + invokeGetNSSIAssociatedProfiles("true", false) + } + + @Test + void testGetNSSIAssociatedProfilesDeleteSLiceProfile() { + invokeGetNSSIAssociatedProfiles("false", false) + } + + void invokeGetNSSIAssociatedProfiles(String isCreateSliceProfileInstance, boolean isEmptySliceProfiles) { + def currentNSSI = [:] + when(mockExecution.getVariable("currentNSSI")).thenReturn(currentNSSI) + + String globalSubscriberId = "5GCustomer" + String subscriptionServiceType = "5G" + when(mockExecution.getVariable("globalSubscriberId")).thenReturn(globalSubscriberId) + when(mockExecution.getVariable("subscriptionServiceType")).thenReturn(subscriptionServiceType) + + when(mockExecution.getVariable("isCreateSliceProfileInstance")).thenReturn(isCreateSliceProfileInstance) + + String nssiId = "5G-999" + ServiceInstance nssi = new ServiceInstance() + nssi.setServiceInstanceId(nssiId) + currentNSSI.put("nssiId", nssiId) + + String theSLiceProfileId = "slice-profile-id" + currentNSSI.put("sliceProfileId", theSLiceProfileId) + + SliceProfiles sliceProfiles = new SliceProfiles() + + List<SliceProfile> slProfiles = sliceProfiles.getSliceProfile() + + if(!isEmptySliceProfiles) { + SliceProfile sp1 = new SliceProfile() + sp1.setProfileId(theSLiceProfileId) + slProfiles.add(sp1) + slProfiles.add(new SliceProfile()) + } + + //nssi.setSliceProfiles(sliceProfiles) + currentNSSI.put("nssi", nssi) + + DoModifyCoreNSSI spy = spy(DoModifyCoreNSSI.class) + when(spy.getAAIClient()).thenReturn(client) + + AAIResourceUri nssiUri = AAIUriFactory.createResourceUri(Types.SERVICE_INSTANCE.getFragment(nssiId)) + + AAIResultWrapper wrapperMock = mock(AAIResultWrapper.class) //new AAIResultWrapper(json) + Relationships rsMock = mock(Relationships.class) + Optional<Relationships> orsMock = Optional.of(rsMock) + List<AAIResourceUri> allottedUris = new ArrayList<>() + AAIResourceUri allottedUri = AAIUriFactory.createResourceUri(Types.ALLOTTED_RESOURCE.getFragment("allotted-id")) + allottedUris.add(allottedUri) + + when(client.get(nssiUri)).thenReturn(wrapperMock) + when(wrapperMock.getRelationships()).thenReturn(orsMock) + when(rsMock.getRelatedUris(Types.ALLOTTED_RESOURCE)).thenReturn(allottedUris) + + String sliceProfileInstanceId = "slice-profile-instance-id" + ServiceInstance sliceProfileInstance = new ServiceInstance() + sliceProfileInstance.setServiceInstanceId(sliceProfileInstanceId) + sliceProfileInstance.setServiceRole("slice-profile-instance") + + List<AAIResourceUri> sliceProfileInstanceUris = new ArrayList<>() + AAIResourceUri sliceProfileInstanceUri = AAIUriFactory.createResourceUri(Types.SERVICE_INSTANCE.getFragment(sliceProfileInstance.getServiceInstanceId())) + sliceProfileInstanceUris.add(sliceProfileInstanceUri) + + Optional<ServiceInstance> sliceProfileInstanceOpt = Optional.of(sliceProfileInstance) + + when(client.get(allottedUri)).thenReturn(wrapperMock) + when(rsMock.getRelatedUris(Types.SERVICE_INSTANCE)).thenReturn(sliceProfileInstanceUris) + when(client.get(ServiceInstance.class, sliceProfileInstanceUri)).thenReturn(sliceProfileInstanceOpt) + + + SliceProfiles sps = new SliceProfiles() + sps.getSliceProfile().addAll(slProfiles) + sliceProfileInstance.setSliceProfiles(sps) + + Optional<SliceProfiles> sliceProfilesOpt = Optional.of(sps) + + org.onap.aaiclient.client.generated.fluentbuilders.SliceProfiles sliceProfilesType = + AAIFluentTypeBuilder.business().customer(globalSubscriberId).serviceSubscription(subscriptionServiceType).serviceInstance(sliceProfileInstance.getServiceInstanceId()).sliceProfiles() + + def sliceProfilesUri = AAIUriFactory.createResourceUri(sliceProfilesType) + when(client.exists(sliceProfilesUri)).thenReturn(true) + + when(client.get(sliceProfilesUri)).thenReturn(wrapperMock) + + when(wrapperMock.asBean(SliceProfiles.class)).thenReturn(sliceProfilesOpt) + + spy.getNSSIAssociatedProfiles(mockExecution) + + List<SliceProfile> associatedProfiles = (List<SliceProfile>)currentNSSI.get("associatedProfiles") + int expectedSize = sps.getSliceProfile().size() + + if(!isEmptySliceProfiles) { + assertTrue("sliceProfileInstanceUri not found in contect Map", currentNSSI.get("sliceProfileInstanceUri") != null) + } + + assertTrue("Either associatedProfiles doesn't exist or size is incorrect", (associatedProfiles != null && associatedProfiles.size() == expectedSize)) + } + + } diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoDeallocateCoreNSSI.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoDeallocateCoreNSSI.bpmn index b55b7c41f0..bfc45f26b7 100644 --- a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoDeallocateCoreNSSI.bpmn +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoDeallocateCoreNSSI.bpmn @@ -1,6 +1,6 @@ <?xml version="1.0" encoding="UTF-8"?> <bpmn:definitions xmlns:bpmn="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:camunda="http://camunda.org/schema/1.0/bpmn" id="Definitions_1v4vnwb" targetNamespace="http://bpmn.io/schema/bpmn" exporter="Camunda Modeler" exporterVersion="4.1.1"> - <bpmn:process id="Process_02hqnsq" isExecutable="true"> + <bpmn:process id="DoDeallocateCoreNSSI" name="DoDeallocateCoreNSSI" isExecutable="true"> <bpmn:startEvent id="StartEvent_1" name="Deallocate Core NSSI Flow"> <bpmn:outgoing>Flow_0xxq2h8</bpmn:outgoing> </bpmn:startEvent> @@ -13,7 +13,7 @@ </bpmn:scriptTask> <bpmn:sequenceFlow id="Flow_0xxq2h8" sourceRef="StartEvent_1" targetRef="Activity_0u06qij" /> <bpmn:scriptTask id="Activity_0wswwhj" name="Get Network Service Instance" scriptFormat="groovy"> - <bpmn:incoming>Flow_189j30m</bpmn:incoming> + <bpmn:incoming>Flow_16bwdkl</bpmn:incoming> <bpmn:outgoing>Flow_16192dm</bpmn:outgoing> <bpmn:script>import org.onap.so.bpmn.infrastructure.scripts.* def dcnssi= new DoDeallocateCoreNSSI() @@ -86,9 +86,6 @@ def dcnssi= new DoDeallocateCoreNSSI() <bpmn:outgoing>Flow_12nxpx6</bpmn:outgoing> <bpmn:outgoing>Flow_1r39237</bpmn:outgoing> </bpmn:exclusiveGateway> - <bpmn:endEvent id="Event_1vgebg2" name="End"> - <bpmn:incoming>Flow_095vvrk</bpmn:incoming> - </bpmn:endEvent> <bpmn:scriptTask id="Activity_1gcmlps" name=" Delete the NSSI service instance
" scriptFormat="groovy"> <bpmn:incoming>Flow_1r39237</bpmn:incoming> <bpmn:outgoing>Flow_04hswb4</bpmn:outgoing> @@ -137,15 +134,14 @@ def dcnssi= new DoDeallocateCoreNSSI() <bpmn:sequenceFlow id="Flow_009x8vn" sourceRef="Activity_0tanqh5" targetRef="Gateway_07ygtxz" /> <bpmn:sequenceFlow id="Flow_12nxpx6" name="no" sourceRef="Gateway_07ygtxz" targetRef="Activity_0gs71qq" /> <bpmn:sequenceFlow id="Flow_15rk73d" sourceRef="Activity_0gs71qq" targetRef="Activity_1npwfvi" /> - <bpmn:scriptTask id="Activity_13qnpcn" name="Execute terminate NSSI query" scriptFormat="groovy"> + <bpmn:scriptTask id="Activity_13qnpcn" name="Execute Terminate NSSI Query" scriptFormat="groovy"> <bpmn:incoming>Flow_0g84uy5</bpmn:incoming> - <bpmn:outgoing>Flow_189j30m</bpmn:outgoing> + <bpmn:outgoing>Flow_16bwdkl</bpmn:outgoing> <bpmn:script>import org.onap.so.bpmn.infrastructure.scripts.* def dcnssi= new DoDeallocateCoreNSSI() dcnssi.executeTerminateNSSIQuery(execution)</bpmn:script> </bpmn:scriptTask> <bpmn:sequenceFlow id="Flow_0g84uy5" sourceRef="Activity_0u06qij" targetRef="Activity_13qnpcn" /> - <bpmn:sequenceFlow id="Flow_189j30m" sourceRef="Activity_13qnpcn" targetRef="Activity_0wswwhj" /> <bpmn:subProcess id="Activity_14l5j2f" name="Sub-process for FalloutHandler and Rollback" triggeredByEvent="true"> <bpmn:startEvent id="Event_1blx2tk"> <bpmn:outgoing>Flow_0z51qfz</bpmn:outgoing> @@ -215,12 +211,11 @@ dcnssi.prepareFailedOperationStatusUpdate(execution)</bpmn:script> </camunda:connector> </bpmn:extensionElements> <bpmn:incoming>Flow_15rk73d</bpmn:incoming> - <bpmn:outgoing>Flow_095vvrk</bpmn:outgoing> + <bpmn:outgoing>Flow_0pj1yb5</bpmn:outgoing> </bpmn:serviceTask> - <bpmn:sequenceFlow id="Flow_095vvrk" sourceRef="Activity_1npwfvi" targetRef="Event_1vgebg2" /> <bpmn:scriptTask id="Activity_1a5fd5v" name="Call Get Delete ServiceOrder Progress" scriptFormat="groovy"> <bpmn:incoming>Flow_1b14can</bpmn:incoming> - <bpmn:incoming>Flow_1qej57v</bpmn:incoming> + <bpmn:incoming>Flow_0zxtlgn</bpmn:incoming> <bpmn:outgoing>Flow_1h8q1h1</bpmn:outgoing> <bpmn:script>import org.onap.so.bpmn.infrastructure.scripts.* def dcnssi= new DoDeallocateCoreNSSI() @@ -235,7 +230,7 @@ dcnssi.getDeleteServiceOrderProgress(execution)</bpmn:script> <bpmn:sequenceFlow id="Flow_1mrr969" name="No" sourceRef="Gateway_13cwisg" targetRef="Event_062ulql" /> <bpmn:scriptTask id="Activity_1ym1op6" name="Time Delay" scriptFormat="groovy"> <bpmn:incoming>Flow_1j1en2h</bpmn:incoming> - <bpmn:outgoing>Flow_1qej57v</bpmn:outgoing> + <bpmn:outgoing>Flow_0zxtlgn</bpmn:outgoing> <bpmn:script>import org.onap.so.bpmn.infrastructure.scripts.* def dcnssi= new DoDeallocateCoreNSSI() dcnssi.timeDelay(execution)</bpmn:script> @@ -243,7 +238,6 @@ dcnssi.timeDelay(execution)</bpmn:script> <bpmn:sequenceFlow id="Flow_1j1en2h" name="Yes" sourceRef="Gateway_13cwisg" targetRef="Activity_1ym1op6"> <bpmn:conditionExpression xsi:type="bpmn:tFormalExpression">#{(execution.getVariable("deleteStatus" ) == "processing" )}</bpmn:conditionExpression> </bpmn:sequenceFlow> - <bpmn:sequenceFlow id="Flow_1qej57v" sourceRef="Activity_1ym1op6" targetRef="Activity_1a5fd5v" /> <bpmn:scriptTask id="Activity_07qrjro" name="Call Get PUT Service Instance Progress" scriptFormat="groovy"> <bpmn:incoming>Flow_178myd8</bpmn:incoming> <bpmn:incoming>Flow_0att74c</bpmn:incoming> @@ -274,31 +268,99 @@ dcnssi.timeDelay(execution)</bpmn:script> <bpmn:conditionExpression xsi:type="bpmn:tFormalExpression">#{(execution.getVariable("putStatus" ) == "processing" )}</bpmn:conditionExpression> </bpmn:sequenceFlow> <bpmn:sequenceFlow id="Flow_0att74c" sourceRef="Activity_1lafl76" targetRef="Activity_07qrjro" /> + <bpmn:scriptTask id="Activity_03j1rrj" name="PostProcess Incoming Request" scriptFormat="groovy"> + <bpmn:incoming>Flow_0pj1yb5</bpmn:incoming> + <bpmn:outgoing>Flow_0eigzrb</bpmn:outgoing> + <bpmn:script>import org.onap.so.bpmn.infrastructure.scripts.* + def dcnssi= new DoDeallocateCoreNSSI() + dcnssi.postProcessRequest(execution)</bpmn:script> + </bpmn:scriptTask> + <bpmn:sequenceFlow id="Flow_0pj1yb5" sourceRef="Activity_1npwfvi" targetRef="Activity_03j1rrj" /> + <bpmn:endEvent id="Event_0zbwefx" name="Done"> + <bpmn:incoming>Flow_0eigzrb</bpmn:incoming> + </bpmn:endEvent> + <bpmn:sequenceFlow id="Flow_0eigzrb" sourceRef="Activity_03j1rrj" targetRef="Event_0zbwefx" /> + <bpmn:sequenceFlow id="Flow_16bwdkl" sourceRef="Activity_13qnpcn" targetRef="Activity_0wswwhj" /> + <bpmn:sequenceFlow id="Flow_0zxtlgn" sourceRef="Activity_1ym1op6" targetRef="Activity_1a5fd5v" /> </bpmn:process> <bpmndi:BPMNDiagram id="BPMNDiagram_1"> - <bpmndi:BPMNPlane id="BPMNPlane_1" bpmnElement="Process_02hqnsq"> - <bpmndi:BPMNEdge id="Flow_189j30m_di" bpmnElement="Flow_189j30m"> - <di:waypoint x="510" y="117" /> - <di:waypoint x="580" y="117" /> + <bpmndi:BPMNPlane id="BPMNPlane_1" bpmnElement="DoDeallocateCoreNSSI"> + <bpmndi:BPMNEdge id="Flow_0eigzrb_di" bpmnElement="Flow_0eigzrb"> + <di:waypoint x="1470" y="670" /> + <di:waypoint x="1532" y="670" /> </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_0g84uy5_di" bpmnElement="Flow_0g84uy5"> - <di:waypoint x="360" y="117" /> - <di:waypoint x="410" y="117" /> + <bpmndi:BPMNEdge id="Flow_0pj1yb5_di" bpmnElement="Flow_0pj1yb5"> + <di:waypoint x="1310" y="670" /> + <di:waypoint x="1370" y="670" /> </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_15rk73d_di" bpmnElement="Flow_15rk73d"> - <di:waypoint x="1220" y="670" /> - <di:waypoint x="1270" y="670" /> + <bpmndi:BPMNEdge id="Flow_0att74c_di" bpmnElement="Flow_0att74c"> + <di:waypoint x="990" y="560" /> + <di:waypoint x="930" y="560" /> + <di:waypoint x="930" y="490" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_0afgah7_di" bpmnElement="Flow_0afgah7"> + <di:waypoint x="1040" y="475" /> + <di:waypoint x="1040" y="520" /> + <bpmndi:BPMNLabel> + <dc:Bounds x="1046" y="482" width="18" height="14" /> + </bpmndi:BPMNLabel> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_1gxcve5_di" bpmnElement="Flow_1gxcve5"> + <di:waypoint x="1065" y="450" /> + <di:waypoint x="1112" y="450" /> + <bpmndi:BPMNLabel> + <dc:Bounds x="1083" y="432" width="15" height="14" /> + </bpmndi:BPMNLabel> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_1r39237_di" bpmnElement="Flow_1r39237"> + <di:waypoint x="770" y="695" /> + <di:waypoint x="770" y="750" /> + <di:waypoint x="880" y="750" /> + <bpmndi:BPMNLabel> + <dc:Bounds x="772" y="701" width="17" height="14" /> + </bpmndi:BPMNLabel> </bpmndi:BPMNEdge> <bpmndi:BPMNEdge id="Flow_04hswb4_di" bpmnElement="Flow_04hswb4"> <di:waypoint x="980" y="750" /> - <di:waypoint x="1170" y="750" /> - <di:waypoint x="1170" y="710" /> + <di:waypoint x="1100" y="750" /> + <di:waypoint x="1100" y="710" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_0pvh1x9_di" bpmnElement="Flow_0pvh1x9"> + <di:waypoint x="980" y="450" /> + <di:waypoint x="1015" y="450" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_1j1en2h_di" bpmnElement="Flow_1j1en2h"> + <di:waypoint x="1105" y="350" /> + <di:waypoint x="1000" y="350" /> + <bpmndi:BPMNLabel> + <dc:Bounds x="1019" y="352" width="18" height="14" /> + </bpmndi:BPMNLabel> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_1mrr969_di" bpmnElement="Flow_1mrr969"> + <di:waypoint x="1130" y="375" /> + <di:waypoint x="1130" y="432" /> + <bpmndi:BPMNLabel> + <dc:Bounds x="1138" y="393" width="15" height="14" /> + </bpmndi:BPMNLabel> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_1h8q1h1_di" bpmnElement="Flow_1h8q1h1"> + <di:waypoint x="1000" y="230" /> + <di:waypoint x="1130" y="230" /> + <di:waypoint x="1130" y="325" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_0g84uy5_di" bpmnElement="Flow_0g84uy5"> + <di:waypoint x="360" y="117" /> + <di:waypoint x="440" y="117" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_15rk73d_di" bpmnElement="Flow_15rk73d"> + <di:waypoint x="1150" y="670" /> + <di:waypoint x="1210" y="670" /> </bpmndi:BPMNEdge> <bpmndi:BPMNEdge id="Flow_12nxpx6_di" bpmnElement="Flow_12nxpx6"> <di:waypoint x="795" y="670" /> - <di:waypoint x="1120" y="670" /> + <di:waypoint x="1050" y="670" /> <bpmndi:BPMNLabel> - <dc:Bounds x="814" y="663" width="13" height="14" /> + <dc:Bounds x="809" y="653" width="13" height="14" /> </bpmndi:BPMNLabel> </bpmndi:BPMNEdge> <bpmndi:BPMNEdge id="Flow_009x8vn_di" bpmnElement="Flow_009x8vn"> @@ -314,18 +376,18 @@ dcnssi.timeDelay(execution)</bpmn:script> <di:waypoint x="260" y="670" /> </bpmndi:BPMNEdge> <bpmndi:BPMNEdge id="Flow_1b14can_di" bpmnElement="Flow_1b14can"> - <di:waypoint x="800" y="240" /> - <di:waypoint x="910" y="240" /> + <di:waypoint x="820" y="230" /> + <di:waypoint x="900" y="230" /> </bpmndi:BPMNEdge> <bpmndi:BPMNEdge id="Flow_178myd8_di" bpmnElement="Flow_178myd8"> <di:waypoint x="820" y="450" /> <di:waypoint x="880" y="450" /> </bpmndi:BPMNEdge> <bpmndi:BPMNEdge id="Flow_0e3yvck_di" bpmnElement="Flow_0e3yvck"> - <di:waypoint x="775" y="117" /> - <di:waypoint x="832" y="117" /> + <di:waypoint x="795" y="117" /> + <di:waypoint x="885" y="117" /> <bpmndi:BPMNLabel> - <dc:Bounds x="787" y="95" width="13" height="14" /> + <dc:Bounds x="807" y="95" width="13" height="14" /> </bpmndi:BPMNLabel> </bpmndi:BPMNEdge> <bpmndi:BPMNEdge id="Flow_1qwi2ka_di" bpmnElement="Flow_1qwi2ka"> @@ -345,81 +407,31 @@ dcnssi.timeDelay(execution)</bpmn:script> <di:waypoint x="260" y="450" /> </bpmndi:BPMNEdge> <bpmndi:BPMNEdge id="Flow_15ew9rs_di" bpmnElement="Flow_15ew9rs"> - <di:waypoint x="750" y="142" /> - <di:waypoint x="750" y="200" /> + <di:waypoint x="770" y="142" /> + <di:waypoint x="770" y="190" /> <bpmndi:BPMNLabel> - <dc:Bounds x="731" y="150" width="17" height="14" /> + <dc:Bounds x="751" y="157" width="17" height="14" /> </bpmndi:BPMNLabel> </bpmndi:BPMNEdge> <bpmndi:BPMNEdge id="Flow_0nvtepd_di" bpmnElement="Flow_0nvtepd"> <di:waypoint x="360" y="670" /> <di:waypoint x="410" y="670" /> </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_1r39237_di" bpmnElement="Flow_1r39237"> - <di:waypoint x="770" y="695" /> - <di:waypoint x="770" y="750" /> - <di:waypoint x="880" y="750" /> - <bpmndi:BPMNLabel> - <dc:Bounds x="772" y="701" width="17" height="14" /> - </bpmndi:BPMNLabel> - </bpmndi:BPMNEdge> <bpmndi:BPMNEdge id="Flow_16192dm_di" bpmnElement="Flow_16192dm"> - <di:waypoint x="680" y="117" /> - <di:waypoint x="725" y="117" /> + <di:waypoint x="691" y="117" /> + <di:waypoint x="745" y="117" /> </bpmndi:BPMNEdge> <bpmndi:BPMNEdge id="Flow_0xxq2h8_di" bpmnElement="Flow_0xxq2h8"> <di:waypoint x="215" y="117" /> <di:waypoint x="260" y="117" /> </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_095vvrk_di" bpmnElement="Flow_095vvrk"> - <di:waypoint x="1370" y="670" /> - <di:waypoint x="1432" y="670" /> + <bpmndi:BPMNEdge id="Flow_16bwdkl_di" bpmnElement="Flow_16bwdkl"> + <di:waypoint x="540" y="117" /> + <di:waypoint x="591" y="117" /> </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_1h8q1h1_di" bpmnElement="Flow_1h8q1h1"> - <di:waypoint x="1010" y="240" /> - <di:waypoint x="1130" y="240" /> - <di:waypoint x="1130" y="325" /> - </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_1mrr969_di" bpmnElement="Flow_1mrr969"> - <di:waypoint x="1130" y="375" /> - <di:waypoint x="1130" y="432" /> - <bpmndi:BPMNLabel> - <dc:Bounds x="1138" y="393" width="15" height="14" /> - </bpmndi:BPMNLabel> - </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_1j1en2h_di" bpmnElement="Flow_1j1en2h"> - <di:waypoint x="1105" y="350" /> - <di:waypoint x="1010" y="350" /> - <bpmndi:BPMNLabel> - <dc:Bounds x="1026" y="352" width="18" height="14" /> - </bpmndi:BPMNLabel> - </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_1qej57v_di" bpmnElement="Flow_1qej57v"> - <di:waypoint x="960" y="310" /> - <di:waypoint x="960" y="280" /> - </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_0pvh1x9_di" bpmnElement="Flow_0pvh1x9"> - <di:waypoint x="980" y="450" /> - <di:waypoint x="1015" y="450" /> - </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_1gxcve5_di" bpmnElement="Flow_1gxcve5"> - <di:waypoint x="1065" y="450" /> - <di:waypoint x="1112" y="450" /> - <bpmndi:BPMNLabel> - <dc:Bounds x="1083" y="432" width="15" height="14" /> - </bpmndi:BPMNLabel> - </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_0afgah7_di" bpmnElement="Flow_0afgah7"> - <di:waypoint x="1040" y="475" /> - <di:waypoint x="1040" y="520" /> - <bpmndi:BPMNLabel> - <dc:Bounds x="1046" y="482" width="18" height="14" /> - </bpmndi:BPMNLabel> - </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_0att74c_di" bpmnElement="Flow_0att74c"> - <di:waypoint x="990" y="560" /> - <di:waypoint x="930" y="560" /> - <di:waypoint x="930" y="490" /> + <bpmndi:BPMNEdge id="Flow_0zxtlgn_di" bpmnElement="Flow_0zxtlgn"> + <di:waypoint x="950" y="310" /> + <di:waypoint x="950" y="270" /> </bpmndi:BPMNEdge> <bpmndi:BPMNShape id="_BPMNShape_StartEvent_2" bpmnElement="StartEvent_1"> <dc:Bounds x="179" y="99" width="36" height="36" /> @@ -430,33 +442,6 @@ dcnssi.timeDelay(execution)</bpmn:script> <bpmndi:BPMNShape id="Activity_0u06qij_di" bpmnElement="Activity_0u06qij"> <dc:Bounds x="260" y="77" width="100" height="80" /> </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Activity_0wswwhj_di" bpmnElement="Activity_0wswwhj"> - <dc:Bounds x="580" y="77" width="100" height="80" /> - </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Gateway_1dqw1bg_di" bpmnElement="Gateway_1dqw1bg" isMarkerVisible="true"> - <dc:Bounds x="725" y="92" width="50" height="50" /> - <bpmndi:BPMNLabel> - <dc:Bounds x="708" y="53" width="85" height="40" /> - </bpmndi:BPMNLabel> - </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Activity_1kne6ot_di" bpmnElement="Activity_1kne6ot"> - <dc:Bounds x="700" y="200" width="100" height="80" /> - </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Event_016dxue_di" bpmnElement="Event_016dxue"> - <dc:Bounds x="832" y="99" width="36" height="36" /> - <bpmndi:BPMNLabel> - <dc:Bounds x="821" y="140" width="74" height="40" /> - </bpmndi:BPMNLabel> - </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Activity_13qnpcn_di" bpmnElement="Activity_13qnpcn"> - <dc:Bounds x="410" y="77" width="100" height="80" /> - </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Event_1mk9pgp_di" bpmnElement="Event_1mk9pgp"> - <dc:Bounds x="179" y="432" width="36" height="36" /> - <bpmndi:BPMNLabel> - <dc:Bounds x="169" y="475" width="69" height="27" /> - </bpmndi:BPMNLabel> - </bpmndi:BPMNShape> <bpmndi:BPMNShape id="Activity_1anr9ry_di" bpmnElement="Activity_1anr9ry"> <dc:Bounds x="260" y="410" width="100" height="80" /> </bpmndi:BPMNShape> @@ -469,21 +454,6 @@ dcnssi.timeDelay(execution)</bpmn:script> <bpmndi:BPMNShape id="Activity_0mnkgd6_di" bpmnElement="Activity_0mnkgd6"> <dc:Bounds x="720" y="410" width="100" height="80" /> </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Activity_1a5fd5v_di" bpmnElement="Activity_1a5fd5v"> - <dc:Bounds x="910" y="200" width="100" height="80" /> - </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Activity_1ym1op6_di" bpmnElement="Activity_1ym1op6"> - <dc:Bounds x="910" y="310" width="100" height="80" /> - </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Activity_07qrjro_di" bpmnElement="Activity_07qrjro"> - <dc:Bounds x="880" y="410" width="100" height="80" /> - </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Event_027jirg_di" bpmnElement="Event_027jirg"> - <dc:Bounds x="179" y="652" width="36" height="36" /> - <bpmndi:BPMNLabel> - <dc:Bounds x="160" y="695" width="88" height="14" /> - </bpmndi:BPMNLabel> - </bpmndi:BPMNShape> <bpmndi:BPMNShape id="Activity_19z90sm_di" bpmnElement="Activity_19z90sm"> <dc:Bounds x="260" y="630" width="100" height="80" /> </bpmndi:BPMNShape> @@ -503,15 +473,12 @@ dcnssi.timeDelay(execution)</bpmn:script> <dc:Bounds x="880" y="710" width="100" height="80" /> </bpmndi:BPMNShape> <bpmndi:BPMNShape id="Activity_0gs71qq_di" bpmnElement="Activity_0gs71qq"> - <dc:Bounds x="1120" y="630" width="100" height="80" /> - </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Activity_1npwfvi_di" bpmnElement="Activity_1npwfvi"> - <dc:Bounds x="1270" y="630" width="100" height="80" /> + <dc:Bounds x="1050" y="630" width="100" height="80" /> </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Event_1vgebg2_di" bpmnElement="Event_1vgebg2"> - <dc:Bounds x="1432" y="652" width="36" height="36" /> + <bpmndi:BPMNShape id="Event_1mk9pgp_di" bpmnElement="Event_1mk9pgp"> + <dc:Bounds x="179" y="432" width="36" height="36" /> <bpmndi:BPMNLabel> - <dc:Bounds x="1440" y="698" width="20" height="14" /> + <dc:Bounds x="169" y="475" width="69" height="27" /> </bpmndi:BPMNLabel> </bpmndi:BPMNShape> <bpmndi:BPMNShape id="Event_062ulql_di" bpmnElement="Event_062ulql"> @@ -520,39 +487,57 @@ dcnssi.timeDelay(execution)</bpmn:script> <dc:Bounds x="1102" y="473" width="72" height="27" /> </bpmndi:BPMNLabel> </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Gateway_13cwisg_di" bpmnElement="Gateway_13cwisg" isMarkerVisible="true"> - <dc:Bounds x="1105" y="325" width="50" height="50" /> + <bpmndi:BPMNShape id="Event_027jirg_di" bpmnElement="Event_027jirg"> + <dc:Bounds x="179" y="652" width="36" height="36" /> <bpmndi:BPMNLabel> - <dc:Bounds x="1165" y="336" width="54" height="27" /> + <dc:Bounds x="160" y="695" width="88" height="14" /> </bpmndi:BPMNLabel> </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Gateway_1yftwt8_di" bpmnElement="Gateway_1yftwt8" isMarkerVisible="true"> - <dc:Bounds x="1015" y="425" width="50" height="50" /> + <bpmndi:BPMNShape id="Activity_13qnpcn_di" bpmnElement="Activity_13qnpcn"> + <dc:Bounds x="440" y="77" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_0wswwhj_di" bpmnElement="Activity_0wswwhj"> + <dc:Bounds x="591" y="77" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Gateway_1dqw1bg_di" bpmnElement="Gateway_1dqw1bg" isMarkerVisible="true"> + <dc:Bounds x="745" y="92" width="50" height="50" /> <bpmndi:BPMNLabel> - <dc:Bounds x="1028" y="396" width="54" height="27" /> + <dc:Bounds x="728" y="53" width="86" height="40" /> </bpmndi:BPMNLabel> </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Activity_1lafl76_di" bpmnElement="Activity_1lafl76"> - <dc:Bounds x="990" y="520" width="100" height="80" /> + <bpmndi:BPMNShape id="Event_016dxue_di" bpmnElement="Event_016dxue"> + <dc:Bounds x="885" y="99" width="36" height="36" /> + <bpmndi:BPMNLabel> + <dc:Bounds x="874" y="140" width="74" height="40" /> + </bpmndi:BPMNLabel> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_1ym1op6_di" bpmnElement="Activity_1ym1op6"> + <dc:Bounds x="900" y="310" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_1kne6ot_di" bpmnElement="Activity_1kne6ot"> + <dc:Bounds x="720" y="190" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_1a5fd5v_di" bpmnElement="Activity_1a5fd5v"> + <dc:Bounds x="900" y="190" width="100" height="80" /> </bpmndi:BPMNShape> <bpmndi:BPMNShape id="Activity_14l5j2f_di" bpmnElement="Activity_14l5j2f" isExpanded="true"> <dc:Bounds x="250" y="910" width="781" height="196" /> </bpmndi:BPMNShape> - <bpmndi:BPMNEdge id="Flow_1vq4jz8_di" bpmnElement="Flow_1vq4jz8"> - <di:waypoint x="640" y="1014" /> - <di:waypoint x="710" y="1014" /> - </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_1cl22g1_di" bpmnElement="Flow_1cl22g1"> - <di:waypoint x="480" y="1014" /> - <di:waypoint x="540" y="1014" /> + <bpmndi:BPMNEdge id="Flow_139pcs3_di" bpmnElement="Flow_139pcs3"> + <di:waypoint x="810" y="1014" /> + <di:waypoint x="918" y="1014" /> </bpmndi:BPMNEdge> <bpmndi:BPMNEdge id="Flow_0z51qfz_di" bpmnElement="Flow_0z51qfz"> <di:waypoint x="316" y="1014" /> <di:waypoint x="380" y="1014" /> </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_139pcs3_di" bpmnElement="Flow_139pcs3"> - <di:waypoint x="810" y="1014" /> - <di:waypoint x="918" y="1014" /> + <bpmndi:BPMNEdge id="Flow_1cl22g1_di" bpmnElement="Flow_1cl22g1"> + <di:waypoint x="480" y="1014" /> + <di:waypoint x="540" y="1014" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_1vq4jz8_di" bpmnElement="Flow_1vq4jz8"> + <di:waypoint x="640" y="1014" /> + <di:waypoint x="710" y="1014" /> </bpmndi:BPMNEdge> <bpmndi:BPMNShape id="Event_1blx2tk_di" bpmnElement="Event_1blx2tk"> <dc:Bounds x="280" y="996" width="36" height="36" /> @@ -569,6 +554,36 @@ dcnssi.timeDelay(execution)</bpmn:script> <bpmndi:BPMNShape id="Activity_0ckr2ke_di" bpmnElement="Activity_0ckr2ke"> <dc:Bounds x="540" y="974" width="100" height="80" /> </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_1npwfvi_di" bpmnElement="Activity_1npwfvi"> + <dc:Bounds x="1210" y="630" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Gateway_13cwisg_di" bpmnElement="Gateway_13cwisg" isMarkerVisible="true"> + <dc:Bounds x="1105" y="325" width="50" height="50" /> + <bpmndi:BPMNLabel> + <dc:Bounds x="1165" y="336" width="54" height="27" /> + </bpmndi:BPMNLabel> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_07qrjro_di" bpmnElement="Activity_07qrjro"> + <dc:Bounds x="880" y="410" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Gateway_1yftwt8_di" bpmnElement="Gateway_1yftwt8" isMarkerVisible="true"> + <dc:Bounds x="1015" y="425" width="50" height="50" /> + <bpmndi:BPMNLabel> + <dc:Bounds x="1028" y="396" width="54" height="27" /> + </bpmndi:BPMNLabel> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_1lafl76_di" bpmnElement="Activity_1lafl76"> + <dc:Bounds x="990" y="520" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_03j1rrj_di" bpmnElement="Activity_03j1rrj"> + <dc:Bounds x="1370" y="630" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Event_0zbwefx_di" bpmnElement="Event_0zbwefx"> + <dc:Bounds x="1532" y="652" width="36" height="36" /> + <bpmndi:BPMNLabel> + <dc:Bounds x="1537" y="695" width="27" height="14" /> + </bpmndi:BPMNLabel> + </bpmndi:BPMNShape> </bpmndi:BPMNPlane> </bpmndi:BPMNDiagram> </bpmn:definitions> diff --git a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoModifyCoreNSSI.bpmn b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoModifyCoreNSSI.bpmn index e0c0b9a994..80e154ca91 100644 --- a/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoModifyCoreNSSI.bpmn +++ b/bpmn/so-bpmn-infrastructure-flows/src/main/resources/subprocess/DoModifyCoreNSSI.bpmn @@ -1,6 +1,6 @@ <?xml version="1.0" encoding="UTF-8"?> <bpmn:definitions xmlns:bpmn="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:camunda="http://camunda.org/schema/1.0/bpmn" id="Definitions_1ejx57e" targetNamespace="http://bpmn.io/schema/bpmn" exporter="Camunda Modeler" exporterVersion="4.1.1"> - <bpmn:process id="Process_1nmtzzp" isExecutable="true"> + <bpmn:process id="DoModifyCoreNSSI" name="DoModifyCoreNSSI" isExecutable="true"> <bpmn:startEvent id="Event_0fbqt56" name="Modify Core NSSI Flow"> <bpmn:outgoing>Flow_0e007rx</bpmn:outgoing> </bpmn:startEvent> @@ -53,9 +53,6 @@ def mcnssi= new DoModifyCoreNSSI() def mcnssi= new DoModifyCoreNSSI() mcnssi.prepareUpdateResourceOperationStatus(execution)</bpmn:script> </bpmn:scriptTask> - <bpmn:endEvent id="Event_1p0mogo" name="End"> - <bpmn:incoming>Flow_1yphs5r</bpmn:incoming> - </bpmn:endEvent> <bpmn:sequenceFlow id="Flow_0yq24um" sourceRef="Activity_0oph5am" targetRef="Activity_0d1kk7f" /> <bpmn:intermediateCatchEvent id="Event_0z9mer1" name="Slice Profile Instance has to be created"> <bpmn:outgoing>Flow_1twqfsc</bpmn:outgoing> @@ -176,9 +173,8 @@ mcnssi.prepareFailedOperationStatusUpdate(execution)</bpmn:script> </camunda:connector> </bpmn:extensionElements> <bpmn:incoming>Flow_0yq24um</bpmn:incoming> - <bpmn:outgoing>Flow_1yphs5r</bpmn:outgoing> + <bpmn:outgoing>Flow_0yp03pi</bpmn:outgoing> </bpmn:serviceTask> - <bpmn:sequenceFlow id="Flow_1yphs5r" sourceRef="Activity_0d1kk7f" targetRef="Event_1p0mogo" /> <bpmn:scriptTask id="Activity_0wdaul0" name="Calculate S-NSSAI" scriptFormat="groovy"> <bpmn:incoming>Flow_0s31teg</bpmn:incoming> <bpmn:outgoing>Flow_0fj4doc</bpmn:outgoing> @@ -222,9 +218,57 @@ mcnssi.timeDelay(execution)</bpmn:script> <bpmn:conditionExpression xsi:type="bpmn:tFormalExpression">#{(execution.getVariable("putStatus" ) == "processing" )}</bpmn:conditionExpression> </bpmn:sequenceFlow> <bpmn:sequenceFlow id="Flow_1twqfsc" sourceRef="Event_0z9mer1" targetRef="Activity_1q02wiz" /> + <bpmn:scriptTask id="Activity_0rws6g3" name="PostProcess Incoming Request" scriptFormat="groovy"> + <bpmn:incoming>Flow_0yp03pi</bpmn:incoming> + <bpmn:outgoing>Flow_0abxsbd</bpmn:outgoing> + <bpmn:script>import org.onap.so.bpmn.infrastructure.scripts.* +def mcnssi= new DoModifyCoreNSSI() + mcnssi.postProcessRequest(execution)</bpmn:script> + </bpmn:scriptTask> + <bpmn:sequenceFlow id="Flow_0yp03pi" sourceRef="Activity_0d1kk7f" targetRef="Activity_0rws6g3" /> + <bpmn:endEvent id="Event_0m863dd" name="Done"> + <bpmn:incoming>Flow_0abxsbd</bpmn:incoming> + </bpmn:endEvent> + <bpmn:sequenceFlow id="Flow_0abxsbd" sourceRef="Activity_0rws6g3" targetRef="Event_0m863dd" /> </bpmn:process> <bpmndi:BPMNDiagram id="BPMNDiagram_1"> - <bpmndi:BPMNPlane id="BPMNPlane_1" bpmnElement="Process_1nmtzzp"> + <bpmndi:BPMNPlane id="BPMNPlane_1" bpmnElement="DoModifyCoreNSSI"> + <bpmndi:BPMNEdge id="Flow_1twqfsc_di" bpmnElement="Flow_1twqfsc"> + <di:waypoint x="248" y="430" /> + <di:waypoint x="330" y="430" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_06or8oz_di" bpmnElement="Flow_06or8oz"> + <di:waypoint x="1240" y="175" /> + <di:waypoint x="1240" y="280" /> + <di:waypoint x="1170" y="280" /> + <bpmndi:BPMNLabel> + <dc:Bounds x="1246" y="225" width="18" height="14" /> + </bpmndi:BPMNLabel> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_1jm7045_di" bpmnElement="Flow_1jm7045"> + <di:waypoint x="1120" y="240" /> + <di:waypoint x="1120" y="190" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_1hm2xps_di" bpmnElement="Flow_1hm2xps"> + <di:waypoint x="1265" y="150" /> + <di:waypoint x="1430" y="150" /> + <di:waypoint x="1430" y="185" /> + <bpmndi:BPMNLabel> + <dc:Bounds x="1273" y="130" width="15" height="14" /> + </bpmndi:BPMNLabel> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_0nxwq7b_di" bpmnElement="Flow_0nxwq7b"> + <di:waypoint x="1170" y="150" /> + <di:waypoint x="1215" y="150" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_1y0m22h_di" bpmnElement="Flow_1y0m22h"> + <di:waypoint x="1040" y="150" /> + <di:waypoint x="1070" y="150" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_0fj4doc_di" bpmnElement="Flow_0fj4doc"> + <di:waypoint x="910" y="150" /> + <di:waypoint x="940" y="150" /> + </bpmndi:BPMNEdge> <bpmndi:BPMNEdge id="Flow_06j2avj_di" bpmnElement="Flow_06j2avj"> <di:waypoint x="360" y="150" /> <di:waypoint x="400" y="150" /> @@ -285,45 +329,13 @@ mcnssi.timeDelay(execution)</bpmn:script> <di:waypoint x="500" y="150" /> <di:waypoint x="540" y="150" /> </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_1yphs5r_di" bpmnElement="Flow_1yphs5r"> + <bpmndi:BPMNEdge id="Flow_0yp03pi_di" bpmnElement="Flow_0yp03pi"> <di:waypoint x="920" y="510" /> - <di:waypoint x="962" y="510" /> + <di:waypoint x="970" y="510" /> </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_0fj4doc_di" bpmnElement="Flow_0fj4doc"> - <di:waypoint x="910" y="150" /> - <di:waypoint x="940" y="150" /> - </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_1y0m22h_di" bpmnElement="Flow_1y0m22h"> - <di:waypoint x="1040" y="150" /> - <di:waypoint x="1070" y="150" /> - </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_0nxwq7b_di" bpmnElement="Flow_0nxwq7b"> - <di:waypoint x="1170" y="150" /> - <di:waypoint x="1215" y="150" /> - </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_1hm2xps_di" bpmnElement="Flow_1hm2xps"> - <di:waypoint x="1265" y="150" /> - <di:waypoint x="1430" y="150" /> - <di:waypoint x="1430" y="185" /> - <bpmndi:BPMNLabel> - <dc:Bounds x="1273" y="130" width="15" height="14" /> - </bpmndi:BPMNLabel> - </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_1jm7045_di" bpmnElement="Flow_1jm7045"> - <di:waypoint x="1120" y="240" /> - <di:waypoint x="1120" y="190" /> - </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_06or8oz_di" bpmnElement="Flow_06or8oz"> - <di:waypoint x="1240" y="175" /> - <di:waypoint x="1240" y="280" /> - <di:waypoint x="1170" y="280" /> - <bpmndi:BPMNLabel> - <dc:Bounds x="1246" y="225" width="18" height="14" /> - </bpmndi:BPMNLabel> - </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_1twqfsc_di" bpmnElement="Flow_1twqfsc"> - <di:waypoint x="248" y="430" /> - <di:waypoint x="330" y="430" /> + <bpmndi:BPMNEdge id="Flow_0abxsbd_di" bpmnElement="Flow_0abxsbd"> + <di:waypoint x="1070" y="510" /> + <di:waypoint x="1122" y="510" /> </bpmndi:BPMNEdge> <bpmndi:BPMNShape id="Event_0fbqt56_di" bpmnElement="Event_0fbqt56"> <dc:Bounds x="182" y="132" width="36" height="36" /> @@ -331,9 +343,6 @@ mcnssi.timeDelay(execution)</bpmn:script> <dc:Bounds x="158" y="175" width="89" height="27" /> </bpmndi:BPMNLabel> </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Activity_0klj7y1_di" bpmnElement="Activity_0klj7y1"> - <dc:Bounds x="260" y="110" width="100" height="80" /> - </bpmndi:BPMNShape> <bpmndi:BPMNShape id="Activity_0tf735w_di" bpmnElement="Activity_0tf735w"> <dc:Bounds x="400" y="110" width="100" height="80" /> </bpmndi:BPMNShape> @@ -343,19 +352,10 @@ mcnssi.timeDelay(execution)</bpmn:script> <bpmndi:BPMNShape id="Activity_02skgkj_di" bpmnElement="Activity_02skgkj"> <dc:Bounds x="680" y="110" width="100" height="80" /> </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Activity_0wdaul0_di" bpmnElement="Activity_0wdaul0"> - <dc:Bounds x="810" y="110" width="100" height="80" /> - </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Activity_0rvt126_di" bpmnElement="Activity_0rvt126"> - <dc:Bounds x="940" y="110" width="100" height="80" /> - </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Activity_1gojm1c_di" bpmnElement="Activity_1gojm1c"> - <dc:Bounds x="1070" y="110" width="100" height="80" /> - </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Gateway_13w96z9_di" bpmnElement="Gateway_13w96z9" isMarkerVisible="true"> - <dc:Bounds x="1215" y="125" width="50" height="50" /> + <bpmndi:BPMNShape id="Gateway_1hadnun_di" bpmnElement="Gateway_1hadnun" isMarkerVisible="true"> + <dc:Bounds x="1405" y="185" width="50" height="50" /> <bpmndi:BPMNLabel> - <dc:Bounds x="1213" y="87" width="54" height="27" /> + <dc:Bounds x="1305" y="190" width="90" height="40" /> </bpmndi:BPMNLabel> </bpmndi:BPMNShape> <bpmndi:BPMNShape id="Event_1243wg1_di" bpmnElement="Event_1243wg1"> @@ -364,23 +364,14 @@ mcnssi.timeDelay(execution)</bpmn:script> <dc:Bounds x="1603" y="233" width="90" height="40" /> </bpmndi:BPMNLabel> </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Gateway_1hadnun_di" bpmnElement="Gateway_1hadnun" isMarkerVisible="true"> - <dc:Bounds x="1405" y="185" width="50" height="50" /> - <bpmndi:BPMNLabel> - <dc:Bounds x="1305" y="190" width="90" height="40" /> - </bpmndi:BPMNLabel> - </bpmndi:BPMNShape> <bpmndi:BPMNShape id="Event_1gjhrcq_di" bpmnElement="Event_1gjhrcq"> <dc:Bounds x="1412" y="282" width="36" height="36" /> <bpmndi:BPMNLabel> <dc:Bounds x="1393" y="323" width="90" height="40" /> </bpmndi:BPMNLabel> </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Activity_15kjs2a_di" bpmnElement="Activity_15kjs2a"> - <dc:Bounds x="1070" y="240" width="100" height="80" /> - </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Activity_1q02wiz_di" bpmnElement="Activity_1q02wiz"> - <dc:Bounds x="330" y="390" width="100" height="80" /> + <bpmndi:BPMNShape id="Activity_0oph5am_di" bpmnElement="Activity_0oph5am"> + <dc:Bounds x="660" y="470" width="100" height="80" /> </bpmndi:BPMNShape> <bpmndi:BPMNShape id="Event_0z9mer1_di" bpmnElement="Event_0z9mer1"> <dc:Bounds x="212" y="412" width="36" height="36" /> @@ -388,51 +379,54 @@ mcnssi.timeDelay(execution)</bpmn:script> <dc:Bounds x="192" y="455" width="90" height="40" /> </bpmndi:BPMNLabel> </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Activity_0oph5am_di" bpmnElement="Activity_0oph5am"> - <dc:Bounds x="660" y="470" width="100" height="80" /> - </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Activity_1iegufd_di" bpmnElement="Activity_1iegufd"> - <dc:Bounds x="330" y="570" width="100" height="80" /> - </bpmndi:BPMNShape> <bpmndi:BPMNShape id="Event_0m2jn7c_di" bpmnElement="Event_0m2jn7c"> <dc:Bounds x="212" y="592" width="36" height="36" /> <bpmndi:BPMNLabel> <dc:Bounds x="185" y="635" width="90" height="40" /> </bpmndi:BPMNLabel> </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Activity_010nkjp_di" bpmnElement="Activity_010nkjp"> - <dc:Bounds x="490" y="570" width="100" height="80" /> + <bpmndi:BPMNShape id="Activity_1q02wiz_di" bpmnElement="Activity_1q02wiz"> + <dc:Bounds x="330" y="390" width="100" height="80" /> </bpmndi:BPMNShape> <bpmndi:BPMNShape id="Activity_1josmor_di" bpmnElement="Activity_1josmor"> <dc:Bounds x="480" y="390" width="100" height="80" /> </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Activity_0d1kk7f_di" bpmnElement="Activity_0d1kk7f"> - <dc:Bounds x="820" y="470" width="100" height="80" /> + <bpmndi:BPMNShape id="Activity_1iegufd_di" bpmnElement="Activity_1iegufd"> + <dc:Bounds x="330" y="570" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_010nkjp_di" bpmnElement="Activity_010nkjp"> + <dc:Bounds x="490" y="570" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_0klj7y1_di" bpmnElement="Activity_0klj7y1"> + <dc:Bounds x="260" y="110" width="100" height="80" /> </bpmndi:BPMNShape> - <bpmndi:BPMNShape id="Event_1p0mogo_di" bpmnElement="Event_1p0mogo"> - <dc:Bounds x="962" y="492" width="36" height="36" /> + <bpmndi:BPMNShape id="Activity_0rws6g3_di" bpmnElement="Activity_0rws6g3"> + <dc:Bounds x="970" y="470" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Event_0m863dd_di" bpmnElement="Event_0m863dd"> + <dc:Bounds x="1122" y="492" width="36" height="36" /> <bpmndi:BPMNLabel> - <dc:Bounds x="970" y="538" width="20" height="14" /> + <dc:Bounds x="1127" y="535" width="27" height="14" /> </bpmndi:BPMNLabel> </bpmndi:BPMNShape> <bpmndi:BPMNShape id="Activity_1u4xfuz_di" bpmnElement="Activity_1u4xfuz" isExpanded="true"> <dc:Bounds x="190" y="790" width="781" height="196" /> </bpmndi:BPMNShape> - <bpmndi:BPMNEdge id="Flow_07ftouz_di" bpmnElement="Flow_07ftouz"> - <di:waypoint x="580" y="894" /> - <di:waypoint x="650" y="894" /> - </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_14kgrjc_di" bpmnElement="Flow_14kgrjc"> - <di:waypoint x="420" y="894" /> - <di:waypoint x="480" y="894" /> + <bpmndi:BPMNEdge id="Flow_00tfsrn_di" bpmnElement="Flow_00tfsrn"> + <di:waypoint x="750" y="894" /> + <di:waypoint x="858" y="894" /> </bpmndi:BPMNEdge> <bpmndi:BPMNEdge id="Flow_1i9kph3_di" bpmnElement="Flow_1i9kph3"> <di:waypoint x="256" y="894" /> <di:waypoint x="320" y="894" /> </bpmndi:BPMNEdge> - <bpmndi:BPMNEdge id="Flow_00tfsrn_di" bpmnElement="Flow_00tfsrn"> - <di:waypoint x="750" y="894" /> - <di:waypoint x="858" y="894" /> + <bpmndi:BPMNEdge id="Flow_14kgrjc_di" bpmnElement="Flow_14kgrjc"> + <di:waypoint x="420" y="894" /> + <di:waypoint x="480" y="894" /> + </bpmndi:BPMNEdge> + <bpmndi:BPMNEdge id="Flow_07ftouz_di" bpmnElement="Flow_07ftouz"> + <di:waypoint x="580" y="894" /> + <di:waypoint x="650" y="894" /> </bpmndi:BPMNEdge> <bpmndi:BPMNShape id="Event_0xhp6c7_di" bpmnElement="Event_0xhp6c7"> <dc:Bounds x="220" y="876" width="36" height="36" /> @@ -449,6 +443,27 @@ mcnssi.timeDelay(execution)</bpmn:script> <bpmndi:BPMNShape id="Activity_1feavwd_di" bpmnElement="Activity_1feavwd"> <dc:Bounds x="480" y="854" width="100" height="80" /> </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_0d1kk7f_di" bpmnElement="Activity_0d1kk7f"> + <dc:Bounds x="820" y="470" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_0wdaul0_di" bpmnElement="Activity_0wdaul0"> + <dc:Bounds x="810" y="110" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_0rvt126_di" bpmnElement="Activity_0rvt126"> + <dc:Bounds x="940" y="110" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_1gojm1c_di" bpmnElement="Activity_1gojm1c"> + <dc:Bounds x="1070" y="110" width="100" height="80" /> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Gateway_13w96z9_di" bpmnElement="Gateway_13w96z9" isMarkerVisible="true"> + <dc:Bounds x="1215" y="125" width="50" height="50" /> + <bpmndi:BPMNLabel> + <dc:Bounds x="1213" y="87" width="54" height="27" /> + </bpmndi:BPMNLabel> + </bpmndi:BPMNShape> + <bpmndi:BPMNShape id="Activity_15kjs2a_di" bpmnElement="Activity_15kjs2a"> + <dc:Bounds x="1070" y="240" width="100" height="80" /> + </bpmndi:BPMNShape> </bpmndi:BPMNPlane> </bpmndi:BPMNDiagram> </bpmn:definitions> diff --git a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/adapter/cnf/tasks/CnfAdapterCreateTasks.java b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/adapter/cnf/tasks/CnfAdapterCreateTasks.java index f49cf48ff5..ed01f2271f 100644 --- a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/adapter/cnf/tasks/CnfAdapterCreateTasks.java +++ b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/adapter/cnf/tasks/CnfAdapterCreateTasks.java @@ -35,6 +35,8 @@ import org.onap.so.bpmn.servicedecomposition.entities.ResourceKey; import org.onap.so.bpmn.servicedecomposition.generalobjects.RequestContext; import org.onap.so.bpmn.servicedecomposition.tasks.ExtractPojosForBB; import org.onap.so.client.adapter.cnf.CnfAdapterClient; +import org.onap.so.client.adapter.cnf.entities.CnfAaiUpdateRequest; +import org.onap.so.client.adapter.cnf.entities.CnfAaiUpdateResponse; import org.onap.so.client.adapter.cnf.entities.InstanceRequest; import org.onap.so.client.adapter.cnf.entities.InstanceResponse; import org.onap.so.client.adapter.vnf.mapper.AttributeNameValue; @@ -47,6 +49,7 @@ import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import com.fasterxml.jackson.core.JsonParseException; +import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.JsonMappingException; import com.fasterxml.jackson.databind.ObjectMapper; @@ -54,6 +57,8 @@ import com.fasterxml.jackson.databind.ObjectMapper; public class CnfAdapterCreateTasks { private static final Logger logger = LoggerFactory.getLogger(CnfAdapterCreateTasks.class); public static final String SDNCQUERY_RESPONSE = "SDNCQueryResponse_"; + private static final String CNF_ADAPTER_MESSAGE_TYPE = "CNFCallback"; + private static final String CNF_ADAPTER_CALLBACK_TIMEOUT = "PT30M"; @Autowired private ExtractPojosForBB extractPojosForBB; @@ -122,4 +127,91 @@ public class CnfAdapterCreateTasks { return request; } + public void prepareForCnfUpdateOrDelete(BuildingBlockExecution execution) { + + GeneralBuildingBlock gBBInput = execution.getGeneralBuildingBlock(); + GenericVnf genericVnfId = null; + VfModule vfModuleId = null; + try { + genericVnfId = extractPojosForBB.extractByKey(execution, ResourceKey.GENERIC_VNF_ID); + vfModuleId = extractPojosForBB.extractByKey(execution, ResourceKey.VF_MODULE_ID); + } catch (Exception ex) { + logger.error("Exception occurred", ex); + } + + String heatStackId = execution.getVariable("heatStackId"); + + logger.debug("heatStackId: {}", heatStackId); + CloudRegion cloudRegion = gBBInput.getCloudRegion(); + String requestId = execution.getVariable("mso-request-id"); + + String callbackUrl = + "http://so-bpmn-infra.onap:8081/mso/WorkflowMessage/" + CNF_ADAPTER_MESSAGE_TYPE + "/" + requestId; + + CnfAaiUpdateRequest aaiRequest = + createCnfAaiUpdateRequest(heatStackId, cloudRegion, callbackUrl, genericVnfId, vfModuleId); + + logger.debug("aaiRequest: {}", aaiRequest); + + String cnfRequestPayload = ""; + try { + cnfRequestPayload = mapper.writeValueAsString(aaiRequest); + } catch (JsonProcessingException e) { + logger.error("Exception occurred", e); + exceptionUtil.buildAndThrowWorkflowException(execution, 7000, e); + } + + // Prepare values to pass in execution variable for CNF Adapter async Handling + execution.setVariable("messageType", CNF_ADAPTER_MESSAGE_TYPE); + execution.setVariable("correlator", requestId); + execution.setVariable("timeout", CNF_ADAPTER_CALLBACK_TIMEOUT); + + String currentFlow = execution.getFlowToBeCalled(); + logger.debug("currentFlow: {}", currentFlow); + + String apiPath = "http://so-cnf-adapter:8090"; + if ("CreateVfModuleBB".equals(currentFlow)) { + apiPath = apiPath + "/api/cnf-adapter/v1/aai-update/"; + } else if ("DeleteVfModuleBB".equals(currentFlow)) { + apiPath = apiPath + "/api/cnf-adapter/v1/aai-delete/"; + } + + // Set variables in execution variable\ + execution.setVariable("apiPath", apiPath); + execution.setVariable("cnfRequestPayload", cnfRequestPayload); + } + + public void processCnfUpdateOrDeleteAsyncResponse(BuildingBlockExecution execution) { + + String asyncResponse = execution.getVariable("asyncCallbackResponse"); + + CnfAaiUpdateResponse response = new CnfAaiUpdateResponse(); + + logger.debug("asyncResponse: {}", asyncResponse); + + try { + response = mapper.readValue(asyncResponse, CnfAaiUpdateResponse.class); + } catch (JsonProcessingException e) { + logger.error("Error in parsing Cnf AAI update Response"); + exceptionUtil.buildAndThrowWorkflowException(execution, 7000, e); + } + + if (!"COMPLETED".equalsIgnoreCase(response.getStatus())) { + exceptionUtil.buildAndThrowWorkflowException(execution, 7000, new RuntimeException("Cannot update in AAI")); + } + } + + protected CnfAaiUpdateRequest createCnfAaiUpdateRequest(String heatStackId, CloudRegion cloudRegion, + String callbackUrl, GenericVnf genericVnfId, VfModule vfModuleId) { + CnfAaiUpdateRequest request = new CnfAaiUpdateRequest(); + request.setCallbackUrl(callbackUrl); + request.setCloudOwner(cloudRegion.getCloudOwner()); + request.setCloudRegion(cloudRegion.getLcpCloudRegionId()); + request.setTenantId(cloudRegion.getTenantId()); + request.setInstanceId(heatStackId); + request.setGenericVnfId(genericVnfId.getVnfId()); + request.setVfModuleId(vfModuleId.getVfModuleId()); + return request; + } + } diff --git a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/adapter/cnf/tasks/CnfHealthCheckTasks.java b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/adapter/cnf/tasks/CnfHealthCheckTasks.java new file mode 100755 index 0000000000..e6545cb800 --- /dev/null +++ b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/adapter/cnf/tasks/CnfHealthCheckTasks.java @@ -0,0 +1,185 @@ +package org.onap.so.bpmn.infrastructure.adapter.cnf.tasks; + +import java.util.ArrayList; +import java.util.List; +import java.util.Optional; +import java.util.stream.Collectors; +import org.onap.logging.filter.base.ONAPComponents; +import org.onap.so.bpmn.common.BuildingBlockExecution; +import org.onap.so.bpmn.servicedecomposition.bbobjects.GenericVnf; +import org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance; +import org.onap.so.bpmn.servicedecomposition.bbobjects.VfModule; +import org.onap.so.bpmn.servicedecomposition.entities.BuildingBlock; +import org.onap.so.bpmn.servicedecomposition.entities.ExecuteBuildingBlock; +import org.onap.so.bpmn.servicedecomposition.entities.GeneralBuildingBlock; +import org.onap.so.client.adapter.cnf.entities.HealthcheckInstance; +import org.onap.so.client.adapter.cnf.entities.HealthcheckInstanceRequest; +import org.onap.so.client.adapter.cnf.entities.HealthcheckInstanceResponse; +import org.onap.so.client.adapter.cnf.entities.HealthcheckResponse; +import org.onap.so.client.adapter.cnf.entities.StatusCheckInstanceResponse; +import org.onap.so.client.adapter.cnf.entities.StatusCheckResponse; +import org.onap.so.client.exception.ExceptionBuilder; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; +import com.fasterxml.jackson.core.JsonProcessingException; +import com.fasterxml.jackson.databind.ObjectMapper; + +@Component +public class CnfHealthCheckTasks { + private static final Logger LOGGER = LoggerFactory.getLogger(CnfHealthCheckTasks.class); + private static final String BUILDING_BLOCK = "buildingBlock"; + private static final String HEALTH_CHECK_SCOPE = "health-check"; + private static final String STATUS_CHECK_SCOPE = "status-check"; + private static final String CNF_ADAPTER_MESSAGE_TYPE = "CNFCallback"; + + @Autowired + private ExceptionBuilder exceptionUtil; + + private ObjectMapper mapper = new ObjectMapper(); + + public void prepareCnfAdaperRequest(BuildingBlockExecution execution) { + GeneralBuildingBlock gBBInput = execution.getGeneralBuildingBlock(); + ServiceInstance serviceInstance = gBBInput.getCustomer().getServiceSubscription().getServiceInstances().get(0); + GenericVnf genericVnf = serviceInstance.getVnfs().get(0); + List<VfModule> listOfVfModules = genericVnf.getVfModules(); + List<String> listOfHeatStackIds = + listOfVfModules.stream().map(x -> x.getHeatStackId()).collect(Collectors.toList()); + LOGGER.debug("listOfHeatStackIds from prepareCnfAdaperRequest: {}", listOfHeatStackIds); + + // Prepare values to pass in execution variable for CNF Adapter async Handling + String requestId = execution.getVariable("mso-request-id"); + execution.setVariable("messageType", CNF_ADAPTER_MESSAGE_TYPE); + execution.setVariable("correlator", requestId); + execution.setVariable("timeout", "PT30M"); + // Replace with environment values + String callBackUrl = + "http://so-bpmn-infra.onap:8081/mso/WorkflowMessage/" + CNF_ADAPTER_MESSAGE_TYPE + "/" + requestId; + HealthcheckInstanceRequest request = new HealthcheckInstanceRequest(); + try { + request = createStatusCheckRequest(listOfHeatStackIds, callBackUrl); + } catch (JsonProcessingException e) { + exceptionUtil.buildAndThrowWorkflowException(execution, 6822, e); + } + LOGGER.debug("request: {}", request); + + String requestPayload = ""; + try { + requestPayload = mapper.writeValueAsString(request); + } catch (JsonProcessingException e) { + LOGGER.error("Error in JSON"); + } + execution.setVariable("cnfRequestPayload", requestPayload); + + ExecuteBuildingBlock executeBuildingBlock = execution.getVariable(BUILDING_BLOCK); + BuildingBlock buildingBlock = executeBuildingBlock.getBuildingBlock(); + String action = Optional.ofNullable(buildingBlock.getBpmnAction()).orElseThrow( + () -> new NullPointerException("BPMN Action is NULL in the orchestration_flow_reference table ")); + + // Replace values with environment values + String uri = "http://so-cnf-adapter:8090"; + String apiPath = ""; + + if (STATUS_CHECK_SCOPE.equals(action)) { + apiPath = uri + "/api/cnf-adapter/v1/statuscheck/"; + } else if (HEALTH_CHECK_SCOPE.equals(action)) { + apiPath = uri + "/api/cnf-adapter/v1/healthcheck/"; + } + + LOGGER.debug("apiPath: {}", apiPath); + + execution.setVariable("apiPath", apiPath); + } + + public void processAsyncResponse(BuildingBlockExecution execution) { + // Value from CNF Async Handler activity + String asyncResponse = execution.getVariable("asyncCallbackResponse"); + + ExecuteBuildingBlock executeBuildingBlock = execution.getVariable(BUILDING_BLOCK); + BuildingBlock buildingBlock = executeBuildingBlock.getBuildingBlock(); + String action = Optional.ofNullable(buildingBlock.getBpmnAction()).orElseThrow( + () -> new NullPointerException("BPMN Action is NULL in the orchestration_flow_reference table ")); + + LOGGER.debug("action: {}", action); + + if (asyncResponse.contains("error")) { + exceptionUtil.buildAndThrowWorkflowException(execution, 500, asyncResponse, ONAPComponents.SO); + } + + if (STATUS_CHECK_SCOPE.equals(action)) { + StatusCheckResponse statusCheckResponse = new StatusCheckResponse(); + + try { + statusCheckResponse = mapper.readValue(asyncResponse, StatusCheckResponse.class); + } catch (JsonProcessingException e) { + LOGGER.error("Error in parsing JSON response"); + } + + LOGGER.debug("statusCheckResponse: {}", statusCheckResponse); + + List<StatusCheckInstanceResponse> listOfStatusInstanceResponse = statusCheckResponse.getInstanceResponse(); + + for (StatusCheckInstanceResponse statusCheckInstanceResponse : listOfStatusInstanceResponse) { + if (!statusCheckInstanceResponse.isStatus()) { + exceptionUtil.buildAndThrowWorkflowException(execution, 500, asyncResponse, ONAPComponents.SO); + } + } + + String statusCheckResponseJson = ""; + try { + statusCheckResponseJson = mapper.writeValueAsString(statusCheckResponse); + } catch (JsonProcessingException e) { + LOGGER.error("Error in PARSING statusCheckResponse"); + } + + execution.setVariable("StatusMessage", statusCheckResponseJson); + + } else if (HEALTH_CHECK_SCOPE.equals(action)) { + HealthcheckResponse healthCheckResponse = new HealthcheckResponse(); + try { + healthCheckResponse = mapper.readValue(asyncResponse, HealthcheckResponse.class); + } catch (JsonProcessingException e) { + LOGGER.error("Error in parsing JSON"); + } + + List<HealthcheckInstanceResponse> listOfHealthcheckInstanceResponses = + healthCheckResponse.getInstanceResponse(); + + for (HealthcheckInstanceResponse healthcheckInstanceResponse : listOfHealthcheckInstanceResponses) { + if ("Failed".equalsIgnoreCase(healthcheckInstanceResponse.getStatus()) + || "Unknown".equalsIgnoreCase(healthcheckInstanceResponse.getStatus())) { + exceptionUtil.buildAndThrowWorkflowException(execution, 500, asyncResponse, ONAPComponents.SO); + } + } + + String healthCheckResponseJson = ""; + try { + healthCheckResponseJson = mapper.writeValueAsString(healthCheckResponse); + } catch (JsonProcessingException e) { + LOGGER.error("Error in PARSING statusCheckResponse"); + } + + execution.setVariable("StatusMessage", healthCheckResponseJson); + + LOGGER.debug("healthCheckResponse: {}", healthCheckResponse); + } + + } + + protected HealthcheckInstanceRequest createStatusCheckRequest(List<String> listOfHeatStackIds, String callBackUrl) + throws JsonProcessingException { + HealthcheckInstanceRequest healthcheckInstanceRequest = new HealthcheckInstanceRequest(); + List<HealthcheckInstance> listOfHealthcheckInstance = new ArrayList<>(); + + listOfHeatStackIds.stream().forEach(x -> listOfHealthcheckInstance.add(new HealthcheckInstance(x))); + LOGGER.debug("listOfHealthcheckInstance: {}", listOfHealthcheckInstance); + + healthcheckInstanceRequest.setInstances(listOfHealthcheckInstance); + healthcheckInstanceRequest.setCallbackUrl(callBackUrl); + LOGGER.debug("healthcheckInstanceRequest: {}", healthcheckInstanceRequest); + + return healthcheckInstanceRequest; + } + +} diff --git a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/workflow/tasks/ExecuteBuildingBlockBuilder.java b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/workflow/tasks/ExecuteBuildingBlockBuilder.java index 2bd0f2c786..920369784e 100644..100755 --- a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/workflow/tasks/ExecuteBuildingBlockBuilder.java +++ b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/workflow/tasks/ExecuteBuildingBlockBuilder.java @@ -54,6 +54,7 @@ public class ExecuteBuildingBlockBuilder { private static final String PNF = "Pnf"; private static final String VFMODULE = "VfModule"; private static final String NETWORK = "Network"; + private static final String HEALTH_CHECK = "HealthCheckBB"; protected List<ExecuteBuildingBlock> buildExecuteBuildingBlockList(List<OrchestrationFlow> orchFlows, List<Resource> originalResourceList, String requestId, String apiVersion, String resourceId, @@ -119,6 +120,10 @@ public class ExecuteBuildingBlockBuilder { || (orchFlow.getFlowName().contains(CONTROLLER) && (VNF).equalsIgnoreCase(orchFlow.getBpmnScope()))) { addBuildingBlockToExecuteBBList(flowsToExecute, resource, WorkflowType.VNF, orchFlow, requestId, apiVersion, resourceId, requestAction, vnfType, workflowResourceIds, requestDetails, false, false); + } else if ((orchFlow.getFlowName().equalsIgnoreCase(HEALTH_CHECK)) + && (VNF).equalsIgnoreCase(orchFlow.getBpmnScope())) { + addBuildingBlockToExecuteBBList(flowsToExecute, resource, WorkflowType.VNF, orchFlow, requestId, apiVersion, + resourceId, requestAction, vnfType, workflowResourceIds, requestDetails, false, false); } else if (orchFlow.getFlowName().contains(PNF) || (orchFlow.getFlowName().contains(CONTROLLER) && (PNF).equalsIgnoreCase(orchFlow.getBpmnScope()))) { addBuildingBlockToExecuteBBList(flowsToExecute, resource, WorkflowType.PNF, orchFlow, requestId, apiVersion, diff --git a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/workflow/tasks/WorkflowAction.java b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/workflow/tasks/WorkflowAction.java index 02508b8867..f36c5a2915 100644..100755 --- a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/workflow/tasks/WorkflowAction.java +++ b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/workflow/tasks/WorkflowAction.java @@ -38,6 +38,7 @@ import static org.onap.so.bpmn.infrastructure.workflow.tasks.WorkflowActionConst import static org.onap.so.bpmn.infrastructure.workflow.tasks.WorkflowActionConstants.REPLACEINSTANCERETAINASSIGNMENTS; import static org.onap.so.bpmn.infrastructure.workflow.tasks.WorkflowActionConstants.SERVICE; import static org.onap.so.bpmn.infrastructure.workflow.tasks.WorkflowActionConstants.UPDATE_INSTANCE; +import static org.onap.so.bpmn.infrastructure.workflow.tasks.WorkflowActionConstants.HEALTH_CHECK; import static org.onap.so.bpmn.infrastructure.workflow.tasks.WorkflowActionConstants.WORKFLOW_ACTION_ERROR_MESSAGE; import java.io.IOException; import java.util.ArrayList; @@ -298,6 +299,9 @@ public class WorkflowAction { } else if (resourceType == WorkflowType.VNF && UPDATE_INSTANCE.equalsIgnoreCase(requestAction)) { vnfEBBLoader.customTraverseAAIVnf(execution, resourceList, workflowResourceIds.getServiceInstanceId(), workflowResourceIds.getVnfId(), aaiResourceIds); + } else if (resourceType == WorkflowType.VNF && HEALTH_CHECK.equalsIgnoreCase(requestAction)) { + vnfEBBLoader.customTraverseAAIVnf(execution, resourceList, workflowResourceIds.getServiceInstanceId(), + workflowResourceIds.getVnfId(), aaiResourceIds); } else { buildAndThrowException(execution, "Current Macro Request is not supported"); } diff --git a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/workflow/tasks/WorkflowActionConstants.java b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/workflow/tasks/WorkflowActionConstants.java index 8c6fb2b38b..a41613982d 100644..100755 --- a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/workflow/tasks/WorkflowActionConstants.java +++ b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/bpmn/infrastructure/workflow/tasks/WorkflowActionConstants.java @@ -50,6 +50,7 @@ public final class WorkflowActionConstants { public static final String UPDATE_INSTANCE = "updateInstance"; public static final String USER_PARAM_SERVICE = "service"; public static final String VOLUMEGROUP = "VolumeGroup"; + public static final String HEALTH_CHECK = "healthCheck"; public static final String WORKFLOW_ACTION_ERROR_MESSAGE = "WorkflowActionErrorMessage"; } diff --git a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/CnfAaiUpdateRequest.java b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/CnfAaiUpdateRequest.java new file mode 100644 index 0000000000..2847074e66 --- /dev/null +++ b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/CnfAaiUpdateRequest.java @@ -0,0 +1,96 @@ +package org.onap.so.client.adapter.cnf.entities; + +import com.fasterxml.jackson.annotation.JsonIgnoreProperties; +import com.fasterxml.jackson.annotation.JsonInclude; +import com.fasterxml.jackson.annotation.JsonProperty; + +@JsonInclude(JsonInclude.Include.NON_NULL) +@JsonIgnoreProperties(value = "true") +public class CnfAaiUpdateRequest { + + @JsonProperty("instanceId") + private String instanceId; + + @JsonProperty("cloudRegion") + private String cloudRegion; + + @JsonProperty("cloudOwner") + private String cloudOwner; + + @JsonProperty("tenantId") + private String tenantId; + + @JsonProperty("callbackUrl") + private String callbackUrl; + + @JsonProperty("genericVnfId") + private String genericVnfId; + + @JsonProperty("vfModuleId") + private String vfModuleId; + + + public String getInstanceId() { + return instanceId; + } + + public void setInstanceId(String instanceId) { + this.instanceId = instanceId; + } + + public String getCloudRegion() { + return cloudRegion; + } + + public void setCloudRegion(String cloudRegion) { + this.cloudRegion = cloudRegion; + } + + public String getCloudOwner() { + return cloudOwner; + } + + public void setCloudOwner(String cloudOwner) { + this.cloudOwner = cloudOwner; + } + + public String getTenantId() { + return tenantId; + } + + public void setTenantId(String tenantId) { + this.tenantId = tenantId; + } + + public String getCallbackUrl() { + return callbackUrl; + } + + public void setCallbackUrl(String callbackUrl) { + this.callbackUrl = callbackUrl; + } + + public String getGenericVnfId() { + return genericVnfId; + } + + public void setGenericVnfId(String genericVnfId) { + this.genericVnfId = genericVnfId; + } + + public String getVfModuleId() { + return vfModuleId; + } + + public void setVfModuleId(String vfModuleId) { + this.vfModuleId = vfModuleId; + } + + @Override + public String toString() { + return "CnfAaiUpdateRequest [instanceId=" + instanceId + ", cloudRegion=" + cloudRegion + ", cloudOwner=" + + cloudOwner + ", tenantId=" + tenantId + ", callbackUrl=" + callbackUrl + ", genericVnfId=" + + genericVnfId + ", vfModuleId=" + vfModuleId + " ]"; + } + +} diff --git a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/CnfAaiUpdateResponse.java b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/CnfAaiUpdateResponse.java new file mode 100644 index 0000000000..79d27abc35 --- /dev/null +++ b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/CnfAaiUpdateResponse.java @@ -0,0 +1,36 @@ +package org.onap.so.client.adapter.cnf.entities; + +import com.fasterxml.jackson.annotation.JsonInclude; +import com.fasterxml.jackson.annotation.JsonProperty; + +@JsonInclude(JsonInclude.Include.NON_NULL) +public class CnfAaiUpdateResponse { + + @JsonProperty("status") + private String status; + + @JsonProperty("statusMessage") + private String statusMessage; + + public String getStatus() { + return status; + } + + public void setStatus(String status) { + this.status = status; + } + + public String getStatusMessage() { + return statusMessage; + } + + public void setStatusMessage(String statusMessage) { + this.statusMessage = statusMessage; + } + + @Override + public String toString() { + return "CnfAaiUpdateResponse [status=" + status + ", statusMessage=" + statusMessage + "]"; + } + +} diff --git a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/HealthcheckInstance.java b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/HealthcheckInstance.java new file mode 100755 index 0000000000..e3fc8b80df --- /dev/null +++ b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/HealthcheckInstance.java @@ -0,0 +1,32 @@ +package org.onap.so.client.adapter.cnf.entities; + +import com.fasterxml.jackson.annotation.JsonIgnoreProperties; +import com.fasterxml.jackson.annotation.JsonInclude; +import com.fasterxml.jackson.annotation.JsonProperty; + +@JsonInclude(JsonInclude.Include.NON_NULL) +@JsonIgnoreProperties(value = "true") +public class HealthcheckInstance { + + public HealthcheckInstance() {} + + public HealthcheckInstance(String instanceId) { + this.instanceId = instanceId; + } + + @JsonProperty("instanceId") + private String instanceId; + + public String getInstanceId() { + return instanceId; + } + + public void setInstanceId(String instanceId) { + this.instanceId = instanceId; + } + + @Override + public String toString() { + return "InstanceRequest{" + "instanceId='" + instanceId + '\'' + '}'; + } +} diff --git a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/HealthcheckInstanceRequest.java b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/HealthcheckInstanceRequest.java new file mode 100755 index 0000000000..a89d18bb3d --- /dev/null +++ b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/HealthcheckInstanceRequest.java @@ -0,0 +1,38 @@ +package org.onap.so.client.adapter.cnf.entities; + +import com.fasterxml.jackson.annotation.JsonIgnoreProperties; +import com.fasterxml.jackson.annotation.JsonInclude; +import com.fasterxml.jackson.annotation.JsonProperty; +import java.util.List; + +@JsonInclude(JsonInclude.Include.NON_NULL) +@JsonIgnoreProperties(value = "true") +public class HealthcheckInstanceRequest { + + @JsonProperty("requestedInstances") + private List<HealthcheckInstance> instances; + + @JsonProperty("callbackUrl") + private String callbackUrl; + + public List<HealthcheckInstance> getInstances() { + return instances; + } + + public void setInstances(List<HealthcheckInstance> instances) { + this.instances = instances; + } + + public String getCallbackUrl() { + return callbackUrl; + } + + public void setCallbackUrl(String callbackUrl) { + this.callbackUrl = callbackUrl; + } + + @Override + public String toString() { + return "CheckInstanceRequest{" + "instances=" + instances + ", callbackUrl='" + callbackUrl + '\'' + '}'; + } +} diff --git a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/HealthcheckInstanceResponse.java b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/HealthcheckInstanceResponse.java new file mode 100755 index 0000000000..ca8a1caad5 --- /dev/null +++ b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/HealthcheckInstanceResponse.java @@ -0,0 +1,57 @@ +package org.onap.so.client.adapter.cnf.entities; + +import com.fasterxml.jackson.annotation.JsonIgnoreProperties; +import com.fasterxml.jackson.annotation.JsonInclude; +import com.fasterxml.jackson.annotation.JsonProperty; + +@JsonInclude(JsonInclude.Include.NON_NULL) +@JsonIgnoreProperties(value = "true") +public class HealthcheckInstanceResponse { + + @JsonProperty("instanceId") + private String instanceId; + + @JsonProperty("reason") + private String reason; + + @JsonProperty("status") + private String status; + + public HealthcheckInstanceResponse() {} + + public HealthcheckInstanceResponse(String instanceId, String reason, String status) { + this.instanceId = instanceId; + this.reason = reason; + this.status = status; + } + + public String getInstanceId() { + return instanceId; + } + + public void setInstanceId(String instanceId) { + this.instanceId = instanceId; + } + + public String getReason() { + return reason; + } + + public void setReason(String reason) { + this.reason = reason; + } + + public String getStatus() { + return status; + } + + public void setStatus(String status) { + this.status = status; + } + + @Override + public String toString() { + return "HealthcheckInstanceResponse{" + "instanceId='" + instanceId + '\'' + ", reason='" + reason + '\'' + + ", status=" + status + '}'; + } +} diff --git a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/HealthcheckResponse.java b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/HealthcheckResponse.java new file mode 100755 index 0000000000..175cb3a224 --- /dev/null +++ b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/HealthcheckResponse.java @@ -0,0 +1,28 @@ +package org.onap.so.client.adapter.cnf.entities; + +import com.fasterxml.jackson.annotation.JsonIgnoreProperties; +import com.fasterxml.jackson.annotation.JsonInclude; +import com.fasterxml.jackson.annotation.JsonProperty; +import java.util.List; + +@JsonInclude(JsonInclude.Include.NON_NULL) +@JsonIgnoreProperties(value = "true") +public class HealthcheckResponse { + + @JsonProperty("result") + private List<HealthcheckInstanceResponse> instanceResponse; + + public List<HealthcheckInstanceResponse> getInstanceResponse() { + return instanceResponse; + } + + public void setInstanceResponse(List<HealthcheckInstanceResponse> instanceResponse) { + this.instanceResponse = instanceResponse; + } + + @Override + public String toString() { + return "HealthcheckResponse{" + "instanceResponse=" + instanceResponse + '}'; + } + +} diff --git a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/StatusCheckInstanceResponse.java b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/StatusCheckInstanceResponse.java new file mode 100755 index 0000000000..cac589f90a --- /dev/null +++ b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/StatusCheckInstanceResponse.java @@ -0,0 +1,57 @@ +package org.onap.so.client.adapter.cnf.entities; + +import com.fasterxml.jackson.annotation.JsonIgnoreProperties; +import com.fasterxml.jackson.annotation.JsonInclude; +import com.fasterxml.jackson.annotation.JsonProperty; + +@JsonInclude(JsonInclude.Include.NON_NULL) +@JsonIgnoreProperties(value = "true") +public class StatusCheckInstanceResponse { + + @JsonProperty("instanceId") + private String instanceId; + + @JsonProperty("reason") + private String reason; + + @JsonProperty("status") + private boolean status; + + public StatusCheckInstanceResponse() {} + + public StatusCheckInstanceResponse(String instanceId, String reason, boolean status) { + this.instanceId = instanceId; + this.reason = reason; + this.status = status; + } + + public String getInstanceId() { + return instanceId; + } + + public void setInstanceId(String instanceId) { + this.instanceId = instanceId; + } + + public String getReason() { + return reason; + } + + public void setReason(String reason) { + this.reason = reason; + } + + public boolean isStatus() { + return status; + } + + public void setStatus(boolean status) { + this.status = status; + } + + @Override + public String toString() { + return "StatusCheckInstanceResponse{" + "instanceId='" + instanceId + '\'' + ", reason='" + reason + '\'' + + ", status=" + status + '}'; + } +} diff --git a/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/StatusCheckResponse.java b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/StatusCheckResponse.java new file mode 100755 index 0000000000..aec2892e22 --- /dev/null +++ b/bpmn/so-bpmn-tasks/src/main/java/org/onap/so/client/adapter/cnf/entities/StatusCheckResponse.java @@ -0,0 +1,28 @@ +package org.onap.so.client.adapter.cnf.entities; + +import com.fasterxml.jackson.annotation.JsonIgnoreProperties; +import com.fasterxml.jackson.annotation.JsonInclude; +import com.fasterxml.jackson.annotation.JsonProperty; +import java.util.List; + +@JsonInclude(JsonInclude.Include.NON_NULL) +@JsonIgnoreProperties(value = "true") +public class StatusCheckResponse { + + @JsonProperty("result") + private List<StatusCheckInstanceResponse> instanceResponse; + + public List<StatusCheckInstanceResponse> getInstanceResponse() { + return instanceResponse; + } + + public void setInstanceResponse(List<StatusCheckInstanceResponse> instanceResponse) { + this.instanceResponse = instanceResponse; + } + + @Override + public String toString() { + return "StatusCheckResponse{" + "instanceResponse=" + instanceResponse + '}'; + } + +} diff --git a/common/src/main/java/org/onap/so/beans/nsmf/AnSliceProfile.java b/common/src/main/java/org/onap/so/beans/nsmf/AnSliceProfile.java index be4833a0c6..7ad1d4e7aa 100644 --- a/common/src/main/java/org/onap/so/beans/nsmf/AnSliceProfile.java +++ b/common/src/main/java/org/onap/so/beans/nsmf/AnSliceProfile.java @@ -43,7 +43,7 @@ public class AnSliceProfile implements Serializable { @JsonProperty(value = "snssaiList", required = true) private List<String> sNSSAIList; - @JsonProperty(value = "plmnIdList", required = true) + @JsonProperty(value = "pLMNIdList", required = true) private List<String> pLMNIdList; @JsonProperty(value = "perfReq", required = true) diff --git a/common/src/main/java/org/onap/so/beans/nsmf/CnSliceProfile.java b/common/src/main/java/org/onap/so/beans/nsmf/CnSliceProfile.java index efb447bc00..bdb8420021 100644 --- a/common/src/main/java/org/onap/so/beans/nsmf/CnSliceProfile.java +++ b/common/src/main/java/org/onap/so/beans/nsmf/CnSliceProfile.java @@ -37,7 +37,7 @@ public class CnSliceProfile implements Serializable { private String sliceProfileId; - @JsonProperty(value = "plmnIdList", required = true) + @JsonProperty(value = "pLMNIdList", required = true) private List<String> pLMNIdList; @JsonProperty(value = "perfReq", required = true) diff --git a/common/src/main/java/org/onap/so/beans/nsmf/TnSliceProfile.java b/common/src/main/java/org/onap/so/beans/nsmf/TnSliceProfile.java index f5cdf1b6fc..ffce5e9a23 100644 --- a/common/src/main/java/org/onap/so/beans/nsmf/TnSliceProfile.java +++ b/common/src/main/java/org/onap/so/beans/nsmf/TnSliceProfile.java @@ -43,7 +43,7 @@ public class TnSliceProfile implements Serializable { @JsonProperty(value = "snssaiList", required = true) private List<String> sNSSAIList; - @JsonProperty(value = "plmnIdList", required = true) + @JsonProperty(value = "pLMNIdList", required = true) private List<String> pLMNIdList; @JsonProperty(value = "jitter") diff --git a/docs/release-notes.rst b/docs/release-notes.rst index 90fd8aaf68..f3b8d45d0d 100644 --- a/docs/release-notes.rst +++ b/docs/release-notes.rst @@ -14,6 +14,17 @@ The SO provides the highest level of service orchestration in the ONAP architect Release Notes ============= +Version: 9.0 +============== + +Release Purpose +---------------- +SO Istanbul Release + +**Epics** + +* `REQ-627 <https://jira.onap.org/browse/REQ-627>`_ - ONAP CNF orchestration - Istanbul Enhancements + Version: 8.0 ============== diff --git a/graph-inventory/aai-client/src/main/java/org/onap/aaiclient/client/aai/AAIVersion.java b/graph-inventory/aai-client/src/main/java/org/onap/aaiclient/client/aai/AAIVersion.java index ab214d8672..a624612f32 100644 --- a/graph-inventory/aai-client/src/main/java/org/onap/aaiclient/client/aai/AAIVersion.java +++ b/graph-inventory/aai-client/src/main/java/org/onap/aaiclient/client/aai/AAIVersion.java @@ -36,7 +36,8 @@ public enum AAIVersion implements GraphInventoryVersion { V20("v20"), V21("v21"), V22("v22"), - V23("v23"); + V23("v23"), + V24("v24"); public static final AAIVersion LATEST = AAIVersion.values()[AAIVersion.values().length - 1]; private final String value; diff --git a/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/Action.java b/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/Action.java index 2a91eaef5a..469c99eeb0 100644 --- a/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/Action.java +++ b/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/Action.java @@ -45,6 +45,7 @@ public enum Action implements Actions { deactivateAndCloudDelete, scaleOut, recreateInstance, + healthCheck, addMembers, removeMembers, forCustomWorkflow diff --git a/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/ServiceInstances.java b/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/ServiceInstances.java index 36922a878f..ed4a52ada0 100644 --- a/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/ServiceInstances.java +++ b/mso-api-handlers/mso-api-handler-infra/src/main/java/org/onap/so/apihandlerinfra/ServiceInstances.java @@ -414,6 +414,24 @@ public class ServiceInstances extends AbstractRestHandler { requestHandlerUtils.getRequestUri(requestContext, uriPrefix)); } + @POST + @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}/healthcheck") + @Consumes(MediaType.APPLICATION_JSON) + @Produces(MediaType.APPLICATION_JSON) + @Operation(description = "HealthCheck for provided VNF instance", responses = @ApiResponse( + content = @Content(array = @ArraySchema(schema = @Schema(implementation = Response.class))))) + @Transactional + public Response cnfHealthCheck(String request, @PathParam("version") String version, + @PathParam("serviceInstanceId") String serviceInstanceId, @PathParam("vnfInstanceId") String vnfInstanceId, + @Context ContainerRequestContext requestContext) throws ApiException { + String requestId = requestHandlerUtils.getRequestId(requestContext); + HashMap<String, String> instanceIdMap = new HashMap<>(); + instanceIdMap.put("serviceInstanceId", serviceInstanceId); + instanceIdMap.put("vnfInstanceId", vnfInstanceId); + return serviceInstances(request, Action.healthCheck, instanceIdMap, version, requestId, + requestHandlerUtils.getRequestUri(requestContext, uriPrefix)); + } + @PUT @Path("/{version:[vV][5-7]}/serviceInstances/{serviceInstanceId}/vnfs/{vnfInstanceId}") @Consumes(MediaType.APPLICATION_JSON) @@ -701,14 +701,17 @@ <dependency> <groupId>org.onap.logging-analytics</groupId> <artifactId>logging-slf4j</artifactId> + <version>${onap-logging-version}</version> </dependency> <dependency> <groupId>org.onap.logging-analytics</groupId> <artifactId>logging-filter-base</artifactId> + <version>${onap-logging-version}</version> </dependency> <dependency> <groupId>org.onap.logging-analytics</groupId> <artifactId>logging-filter-spring</artifactId> + <version>${onap-logging-version}</version> </dependency> <dependency> <groupId>com.fasterxml.jackson.core</groupId> @@ -962,7 +965,7 @@ <dependency> <groupId>org.onap.aai.schema-service</groupId> <artifactId>aai-schema</artifactId> - <version>1.8.1</version> + <version>1.9.1</version> </dependency> <dependency> <groupId>org.apache.cxf</groupId> |