Commit 4a3dc13d authored by Anastasios Poimenidis's avatar Anastasios Poimenidis
Browse files

feat: introduce registry get Credentials error handling in... 

feat: introduce registry get Credentials error handling in k8sServiceOrderProcess.bpmn2, k8sServiceTerminationSubprocess.bpmn2, ossServiceOrderProcess.bpmn2, ossServiceTerminationSubprocess.bpmn2, platformServiceUpdateHandler.bpmn2
parent e1c27ef7

pom.xml

+1 −1
Changes for pom.xml: 1 added line, 1 removed line.
Original line number Diff line number Diff line
@@ -63,7 +63,7 @@ 
    <dependency>

      <groupId>org.etsi.osl.hypo.core</groupId>

      <artifactId>common</artifactId>

      <version>1.5.2</version>

      <version>1.5.4</version>

    </dependency>



    <dependency>

src/main/java/converters/AggregatedOrderDataHandler.java

+45 −38
Changes for src/main/java/converters/AggregatedOrderDataHandler.java: 45 added lines, 38 removed lines.
Original line number Diff line number Diff line
@@ -16,6 +16,7 @@ import org.etsi.osl.hypo.core.common.helm.engine.HelmEngineParseResult; 
import org.etsi.osl.hypo.core.common.helm.engine.HelmEngineTerminationResult;

import org.etsi.osl.hypo.core.common.oss.client.K8sConfiguration;

import org.etsi.osl.hypo.core.common.oss.client.SimpleServiceOrderResult;

import org.etsi.osl.hypo.core.common.registry.RegistryOrganizationCredentials;

import org.etsi.osl.hypo.core.common.registry.RegistryStoreKubernetesInfoResult;

import org.etsi.osl.hypo.core.common.service.order.status.AggregatedOrderData;

import org.etsi.osl.hypo.core.common.service.order.status.AggregatedOrderDataHolder;
@@ -205,6 +206,7 @@ public class AggregatedOrderDataHandler { 
            K8sConfiguration k8sConfiguration,

            FabricApiConnectionResult fabricApiConnectionResult,

            RegistryStoreKubernetesInfoResult registryStoreKubernetesInfoResult,

            RegistryOrganizationCredentials registryOrganizationCredentials,

            AggregatedOrderDataHolder aggregatedOrderDataHolder) {

        if (aggregatedOrderDataHolder == null) {

            aggregatedOrderDataHolder = new AggregatedOrderDataHolder();
@@ -221,6 +223,13 @@ public class AggregatedOrderDataHandler { 
                    .setRegistryStoreKubernetesInfoResult(registryStoreKubernetesInfoResult);

        }



        if (registryOrganizationCredentials != null

                && registryOrganizationCredentials.getRegistryStatus() != null) {

            aggregatedOrderDataHolder

                    .getExternalSystemResponsesDataHolder()

                    .setRegistryOrganizationCredentials(registryOrganizationCredentials);

        }



        if (k8sConfiguration != null && k8sConfiguration.getK8sOrderStatus() != null) {

            aggregatedOrderDataHolder

                    .getExternalSystemResponsesDataHolder()
@@ -264,9 +273,10 @@ public class AggregatedOrderDataHandler { 
        return aggregatedOrderDataHolder;

    }



    public AggregatedOrderDataHolder getAggregatedOrderDataHolderFor5GServiceOrderProcess(

    public AggregatedOrderDataHolder getAggregatedOrderDataHolderForSimpleServiceOrder(

            AggregatedOrderDataHolder aggregatedOrderDataHolder,

            SimpleServiceOrderResult simpleServiceOrderResult) {

            SimpleServiceOrderResult simpleServiceOrderResult,

            RegistryOrganizationCredentials registryOrganizationCredentials) {

        if (aggregatedOrderDataHolder == null) {

            aggregatedOrderDataHolder = new AggregatedOrderDataHolder();

            ExternalSystemResponsesDataHolder externalSystemResponsesDataHolder =
@@ -282,6 +292,13 @@ public class AggregatedOrderDataHandler { 
                    .setSimpleServiceOrderResult(simpleServiceOrderResult);

        }



        if (registryOrganizationCredentials != null

                && registryOrganizationCredentials.getRegistryStatus() != null) {

            aggregatedOrderDataHolder

                    .getExternalSystemResponsesDataHolder()

                    .setRegistryOrganizationCredentials(registryOrganizationCredentials);

        }



        calculateAggregatedStatus(aggregatedOrderDataHolder);



        logger.infof(AGGREGATED_ORDER_DATA_HOLDER_IS_S, aggregatedOrderDataHolder);
@@ -365,30 +382,48 @@ public class AggregatedOrderDataHandler { 


        FabricApiConnectionResult fabricApiConnectionResult =

                externalSystemResponsesDataHolder.getFabricApiConnectionResult();

        boolean ztcConfigurationFailure =

        boolean fabricAPIConfigurationFailure =

                fabricApiConnectionResult != null && fabricApiConnectionResult.hasStatusFailure();

        String fabricApiClientMessage =

                fabricApiConnectionResult != null

                        ? fabricApiConnectionResult.getFabricApiClientMessage()

                        : null;



        if (ztcConfigurationFailure && StringUtils.isNotBlank(fabricApiClientMessage)) {

        if (fabricAPIConfigurationFailure && StringUtils.isNotBlank(fabricApiClientMessage)) {

            failureMessage = failureMessage.concat(fabricApiClientMessage);

        }



        RegistryStoreKubernetesInfoResult registryStoreKubernetesInfoResult =

                externalSystemResponsesDataHolder.getRegistryStoreKubernetesInfoResult();

        boolean registryFailure =

        RegistryOrganizationCredentials registryOrganizationCredentials =

                externalSystemResponsesDataHolder.getRegistryOrganizationCredentials();



        boolean registryStoreK8sConfigFailure =

                registryStoreKubernetesInfoResult != null

                        && registryStoreKubernetesInfoResult.hasStatusFailure();

        boolean registryOrganizationCredentialsFailure =

                registryOrganizationCredentials != null

                        && registryOrganizationCredentials.hasStatusFailure();



        String registryMessage =

        String registryMessageK8sFailure =

                registryStoreKubernetesInfoResult != null

                        ? registryStoreKubernetesInfoResult.getRegistryMessage()

                        : null;



        if (registryFailure && StringUtils.isNotBlank(registryMessage)) {

            failureMessage = failureMessage.concat(registryMessage);

        String registryMessageCredentialsFailure =

                registryOrganizationCredentials != null

                        ? registryOrganizationCredentials.getRegistryMessage()

                        : null;



        boolean registryFailure =

                registryStoreK8sConfigFailure || registryOrganizationCredentialsFailure;



        if (StringUtils.isNotBlank(registryMessageK8sFailure)) {

            failureMessage = failureMessage.concat(registryMessageK8sFailure);

        }



        if (StringUtils.isNotBlank(registryMessageCredentialsFailure)) {

            failureMessage = failureMessage.concat(registryMessageCredentialsFailure);

        }



        boolean ossClientFailure = k8sOrderFailure || fiveGOrderFailure;
@@ -407,7 +442,7 @@ public class AggregatedOrderDataHandler { 
        boolean hasFailures =

                telemetryAPIFailure

                        || ossClientFailure

                        || ztcConfigurationFailure

                        || fabricAPIConfigurationFailure

                        || helmEngineFailure

                        || registryFailure;
@@ -416,7 +451,7 @@ public class AggregatedOrderDataHandler { 
                helmEngineFailure,

                ossClientFailure,

                telemetryAPIFailure,

                ztcConfigurationFailure,

                fabricAPIConfigurationFailure,

                registryFailure);



        if (hasFailures) {
@@ -447,34 +482,6 @@ public class AggregatedOrderDataHandler { 
        if (registryFailure) aggregatedOrderDataHolder.setSystemFailed("REGISTRY API");

    }



    private boolean helmEngineFailure(

            ExternalSystemResponsesDataHolder externalSystemResponsesDataHolder) {

        HelmEngineTerminationResult helmEngineTerminationResult =

                externalSystemResponsesDataHolder.getHelmEngineTerminationResult();

        boolean helmEngineTerminationFailure =

                helmEngineTerminationResult != null && helmEngineTerminationResult.hasStatusFailure();



        HelmEngineParseResult helmEngineParseResult =

                externalSystemResponsesDataHolder.getHelmEngineParseResult();

        boolean helmEngineParseFailure =

                helmEngineParseResult != null && helmEngineParseResult.hasStatusFailure();



        HelmEngineActivationResult helmEngineActivationResult =

                externalSystemResponsesDataHolder.getHelmEngineActivationResult();

        boolean helmEngineActivationFailure =

                helmEngineActivationResult != null && helmEngineActivationResult.hasStatusFailure();



        HelmEngineDeploymentResult helmEngineDeploymentResult =

                externalSystemResponsesDataHolder.getHelmEngineDeploymentResult();

        boolean helmEngineDeploymentResultFailure =

                helmEngineDeploymentResult != null && helmEngineDeploymentResult.hasStatusFailure();



        return helmEngineParseFailure

                || helmEngineActivationFailure

                || helmEngineDeploymentResultFailure

                || helmEngineTerminationFailure;

    }



    private AggregatedStatusMessageResult helmEngineFailureMessage(

            ExternalSystemResponsesDataHolder externalSystemResponsesDataHolder) {

src/main/java/converters/RegistryConverter.java

+2 −0
Changes for src/main/java/converters/RegistryConverter.java: 2 added lines, 0 removed lines.
Original line number Diff line number Diff line
@@ -24,6 +24,7 @@ public class RegistryConverter { 
    public <T extends ServiceBaseOrganizationObject> void populateOrganizationCredentials(

            T serviceBaseOrganizationObject,

            RegistryOrganizationCredentials registryOrganizationCredentials) {

        if (registryOrganizationCredentials.hasStatusSuccess()) {

            OrganizationCharacteristics organizationCharacteristics =

                    serviceBaseOrganizationObject.getOrganizationCharacteristics();

            Map<String, String> characteristics = organizationCharacteristics.getCharacteristics();
@@ -37,3 +38,4 @@ public class RegistryConverter { 
            characteristics.put("EXTERNAL_TMF_API_PASSWORD", password);

        }

    }

}

src/main/java/converters/ServiceUpdateHandler.java

+26 −4
Changes for src/main/java/converters/ServiceUpdateHandler.java: 26 added lines, 4 removed lines.
Original line number Diff line number Diff line
@@ -19,6 +19,7 @@ import org.etsi.osl.hypo.core.common.oss.client.K8sServiceOrderData; 
import org.etsi.osl.hypo.core.common.oss.client.ServiceTerminationDataResponse;

import org.etsi.osl.hypo.core.common.oss.client.ServiceUpdateResponse;

import org.etsi.osl.hypo.core.common.oss.client.SimpleServiceOrderData;

import org.etsi.osl.hypo.core.common.registry.RegistryOrganizationCredentials;

import org.etsi.osl.hypo.core.common.service.inventory.PlatformServiceUpdateData;

import org.etsi.osl.hypo.core.common.service.inventory.ServiceActivationData;

import org.etsi.osl.hypo.core.common.service.inventory.ServiceStateType;
@@ -127,7 +128,8 @@ public class ServiceUpdateHandler { 
    public ServiceUpdateData createServiceUpdateDataForK8sAnd5GTermination(

            ServiceTerminationDataResponse serviceTerminationDataResponse,

            FabricApiConnectionResult fabricApiConnectionResult,

            ServiceTerminationDataWithTimer serviceTerminationDataWithTimer) {

            ServiceTerminationDataWithTimer serviceTerminationDataWithTimer,

            RegistryOrganizationCredentials registryOrganizationCredentials) {



        ServiceTerminationData serviceTerminationData =

                serviceTerminationDataWithTimer.getServiceTerminationData();
@@ -138,7 +140,13 @@ public class ServiceUpdateHandler { 
                serviceTerminationDataResponse == null || serviceTerminationDataResponse.hasStatusSuccess();

        boolean successfulTerminationFromZtc =

                fabricApiConnectionResult == null || fabricApiConnectionResult.hasStatusSuccess();

        if (successfulTerminationUpdateFromOss && successfulTerminationFromZtc) {

        boolean successfulOrgCredentialsRegistry =

                registryOrganizationCredentials == null

                        || registryOrganizationCredentials.hasStatusSuccess();



        if (successfulTerminationUpdateFromOss

                && successfulTerminationFromZtc

                && successfulOrgCredentialsRegistry) {

            serviceUpdateData.setRollbackService(Boolean.FALSE);

            serviceUpdateData.setState(ServiceStateType.TERMINATED);

        } else if (serviceTerminationDataResponse != null
@@ -155,6 +163,13 @@ public class ServiceUpdateHandler { 
            if (StringUtils.isNotBlank(fabricApiClientMessage)) {

                serviceUpdateData.setFailureMessage(fabricApiClientMessage);

            }

        } else if (registryOrganizationCredentials != null

                && registryOrganizationCredentials.hasStatusFailure()) {

            serviceUpdateData.setRollbackService(Boolean.TRUE);

            String registryMessage = registryOrganizationCredentials.getRegistryMessage();

            if (StringUtils.isNotBlank(registryMessage)) {

                serviceUpdateData.setFailureMessage(registryMessage);

            }

        } else {

            serviceUpdateData.setRollbackService(Boolean.TRUE);

        }
@@ -239,13 +254,20 @@ public class ServiceUpdateHandler { 


    public ServiceUpdateData createServiceUpdateRollbackMessage(

            PlatformServiceUpdateData platformServiceUpdateData,

            ServiceUpdateResponse serviceUpdateResponse) {

            ServiceUpdateResponse serviceUpdateResponse,

            RegistryOrganizationCredentials registryOrganizationCredentials) {



        ServiceUpdateData serviceUpdateData =

                OBJECT_CONVERTERS.getServiceUpdateDataFromPlatformServiceUpdateData(

                        platformServiceUpdateData);

        serviceUpdateData.setRollbackService(Boolean.TRUE);

        serviceUpdateData.setFailureMessage(serviceUpdateResponse.getUpdateServiceMessage());

        String updateServiceMessage = "";

        if (serviceUpdateResponse != null) {

            updateServiceMessage = serviceUpdateResponse.getUpdateServiceMessage();

        } else if (registryOrganizationCredentials != null) {

            updateServiceMessage = registryOrganizationCredentials.getRegistryMessage();

        }

        serviceUpdateData.setFailureMessage(updateServiceMessage);



        logger.infof("Created Rollback Message for kubernetes update data %s", serviceUpdateData);

        return serviceUpdateData;

src/main/resources/diagrams/ossClient/clientSubprocesses/terminate/k8sAnd5GTerminationMessagesHandler.bpmn2

+16 −7
Changes for src/main/resources/diagrams/ossClient/clientSubprocesses/terminate/k8sAnd5GTerminationMessagesHandler.bpmn2: 16 added lines, 7 removed lines.
Original line number Diff line number Diff line 
<?xml version="1.0" encoding="UTF-8"?>

<bpmn2:definitions xmlns:bpmn2="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:bpsim="http://www.bpsim.org/schemas/1.0" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:drools="http://www.jboss.org/drools" xmlns:xsi="xsi" id="_oEBK4N8mED6ABscBVrEODg" xsi:schemaLocation="http://www.omg.org/spec/BPMN/20100524/MODEL BPMN20.xsd http://www.jboss.org/drools drools.xsd http://www.bpsim.org/schemas/1.0 bpsim.xsd http://www.omg.org/spec/DD/20100524/DC DC.xsd http://www.omg.org/spec/DD/20100524/DI DI.xsd " exporter="jBPM Process Modeler" exporterVersion="2.0" targetNamespace="http://www.omg.org/bpmn20">

<bpmn2:definitions xmlns:bpmn2="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:bpsim="http://www.bpsim.org/schemas/1.0" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" xmlns:drools="http://www.jboss.org/drools" xmlns:xsi="xsi" id="_HFMa8GDvED-QDp5Z2ucerA" xsi:schemaLocation="http://www.omg.org/spec/BPMN/20100524/MODEL BPMN20.xsd http://www.jboss.org/drools drools.xsd http://www.bpsim.org/schemas/1.0 bpsim.xsd http://www.omg.org/spec/DD/20100524/DC DC.xsd http://www.omg.org/spec/DD/20100524/DI DI.xsd " exporter="jBPM Process Modeler" exporterVersion="2.0" targetNamespace="http://www.omg.org/bpmn20">

  <bpmn2:itemDefinition id="_serviceUpdateDataItem" structureRef="org.etsi.osl.hypo.core.common.service.inventory.ServiceUpdateData"/>

  <bpmn2:itemDefinition id="_serviceTerminationDataWithTimerItem" structureRef="org.etsi.osl.hypo.core.common.service.inventory.ServiceTerminationDataWithTimer"/>

  <bpmn2:itemDefinition id="_serviceTerminationDataResponseItem" structureRef="org.etsi.osl.hypo.core.common.oss.client.ServiceTerminationDataResponse"/>

  <bpmn2:itemDefinition id="_fabricApiConnectionResultItem" structureRef="org.etsi.osl.hypo.core.common.fabric.management.ztc.FabricApiConnectionResult"/>

  <bpmn2:itemDefinition id="_registryOrganizationCredentialsItem" structureRef="org.etsi.osl.hypo.core.common.registry.RegistryOrganizationCredentials"/>

  <bpmn2:itemDefinition id="__45B88A5D-552F-41E8-B135-D96A256E6E9F_serviceUpdateDataInputXItem" structureRef="org.etsi.osl.hypo.core.common.service.inventory.ServiceUpdateData"/>

  <bpmn2:itemDefinition id="tmf-service-updateType" structureRef="org.etsi.osl.hypo.core.common.service.inventory.ServiceUpdateData"/>

  <bpmn2:itemDefinition id="_A2D3220F-C897-4CC3-B164-156C4AC2BAAB_InMessageType" structureRef=""/>
@@ -11,8 +12,9 @@ 
  <bpmn2:itemDefinition id="__A2D3220F-C897-4CC3-B164-156C4AC2BAAB_serviceTerminationDataResponseInputXItem" structureRef="org.etsi.osl.hypo.core.common.oss.client.ServiceTerminationDataResponse"/>

  <bpmn2:itemDefinition id="__A2D3220F-C897-4CC3-B164-156C4AC2BAAB_fabricApiConnectionResultInputXItem" structureRef="org.etsi.osl.hypo.core.common.fabric.management.ztc.FabricApiConnectionResult"/>

  <bpmn2:itemDefinition id="__A2D3220F-C897-4CC3-B164-156C4AC2BAAB_serviceTerminationDataWithTimerInputXItem" structureRef="org.etsi.osl.hypo.core.common.service.inventory.ServiceTerminationDataWithTimer"/>

  <bpmn2:itemDefinition id="__A2D3220F-C897-4CC3-B164-156C4AC2BAAB_registryOrganizationCredentialsInputXItem" structureRef="org.etsi.osl.hypo.core.common.registry.RegistryOrganizationCredentials"/>

  <bpmn2:itemDefinition id="__A2D3220F-C897-4CC3-B164-156C4AC2BAAB_serviceUpdateDataOutputXItem" structureRef="org.etsi.osl.hypo.core.common.service.inventory.ServiceUpdateData"/>

  <bpmn2:message id="_oEDnIN8mED6ABscBVrEODg" itemRef="tmf-service-updateType" name="tmf-service-update"/>

  <bpmn2:message id="_HFNpEGDvED-QDp5Z2ucerA" itemRef="tmf-service-updateType" name="tmf-service-update"/>

  <bpmn2:message id="_A2D3220F-C897-4CC3-B164-156C4AC2BAAB_InMessage" itemRef="_A2D3220F-C897-4CC3-B164-156C4AC2BAAB_InMessageType"/>

  <bpmn2:message id="_A2D3220F-C897-4CC3-B164-156C4AC2BAAB_OutMessage" itemRef="_A2D3220F-C897-4CC3-B164-156C4AC2BAAB_OutMessageType"/>

  <bpmn2:interface id="_A2D3220F-C897-4CC3-B164-156C4AC2BAAB_ServiceInterface" name="converters.ServiceUpdateHandler" implementationRef="converters.ServiceUpdateHandler">
@@ -21,8 +23,8 @@ 
      <bpmn2:outMessageRef>_A2D3220F-C897-4CC3-B164-156C4AC2BAAB_OutMessage</bpmn2:outMessageRef>

    </bpmn2:operation>

  </bpmn2:interface>

  <bpmn2:collaboration id="_38AD73CE-3174-4917-9F45-668C853BD76E" name="Default Collaboration">

    <bpmn2:participant id="_82AE6663-371A-4B3D-B956-88ACAE80698D" name="Pool Participant" processRef="k8sAnd5GTerminationMessagesHandler"/>

  <bpmn2:collaboration id="_2FC767B5-E882-4792-A9D1-97DD4AAE2DAE" name="Default Collaboration">

    <bpmn2:participant id="_09236AF2-718B-4057-88A9-7AA1458EE8D4" name="Pool Participant" processRef="k8sAnd5GTerminationMessagesHandler"/>

  </bpmn2:collaboration>

  <bpmn2:process id="k8sAnd5GTerminationMessagesHandler" drools:packageName="diagrams" drools:version="1.0" drools:adHoc="false" name="k8sAnd5GTerminationMessagesHandler" isExecutable="true" processType="Private">

    <bpmn2:documentation><![CDATA[Handler for Termination Messages towards Sonata for 5G and K8s Services]]></bpmn2:documentation>
@@ -30,6 +32,7 @@ 
    <bpmn2:property id="serviceTerminationDataWithTimer" itemSubjectRef="_serviceTerminationDataWithTimerItem" name="serviceTerminationDataWithTimer"/>

    <bpmn2:property id="serviceTerminationDataResponse" itemSubjectRef="_serviceTerminationDataResponseItem" name="serviceTerminationDataResponse"/>

    <bpmn2:property id="fabricApiConnectionResult" itemSubjectRef="_fabricApiConnectionResultItem" name="fabricApiConnectionResult"/>

    <bpmn2:property id="registryOrganizationCredentials" itemSubjectRef="_registryOrganizationCredentialsItem" name="registryOrganizationCredentials"/>

    <bpmn2:sequenceFlow id="_6C166EB9-B687-441F-BD4A-479C43E4EC1A" sourceRef="_45B88A5D-552F-41E8-B135-D96A256E6E9F" targetRef="_05964E5C-5D06-47E1-AE91-8E6914571559"/>

    <bpmn2:sequenceFlow id="_D0C23C70-33EA-45D8-9CA6-7254EFDE37F4" sourceRef="_A2D3220F-C897-4CC3-B164-156C4AC2BAAB" targetRef="_45B88A5D-552F-41E8-B135-D96A256E6E9F">

      <bpmn2:extensionElements>
@@ -51,11 +54,13 @@ 
        <bpmn2:dataInput id="_A2D3220F-C897-4CC3-B164-156C4AC2BAAB_serviceTerminationDataResponseInputX" drools:dtype="org.etsi.osl.hypo.core.common.oss.client.ServiceTerminationDataResponse" itemSubjectRef="__A2D3220F-C897-4CC3-B164-156C4AC2BAAB_serviceTerminationDataResponseInputXItem" name="serviceTerminationDataResponse"/>

        <bpmn2:dataInput id="_A2D3220F-C897-4CC3-B164-156C4AC2BAAB_fabricApiConnectionResultInputX" drools:dtype="org.etsi.osl.hypo.core.common.fabric.management.ztc.FabricApiConnectionResult" itemSubjectRef="__A2D3220F-C897-4CC3-B164-156C4AC2BAAB_fabricApiConnectionResultInputXItem" name="fabricApiConnectionResult"/>

        <bpmn2:dataInput id="_A2D3220F-C897-4CC3-B164-156C4AC2BAAB_serviceTerminationDataWithTimerInputX" drools:dtype="org.etsi.osl.hypo.core.common.service.inventory.ServiceTerminationDataWithTimer" itemSubjectRef="__A2D3220F-C897-4CC3-B164-156C4AC2BAAB_serviceTerminationDataWithTimerInputXItem" name="serviceTerminationDataWithTimer"/>

        <bpmn2:dataInput id="_A2D3220F-C897-4CC3-B164-156C4AC2BAAB_registryOrganizationCredentialsInputX" drools:dtype="org.etsi.osl.hypo.core.common.registry.RegistryOrganizationCredentials" itemSubjectRef="__A2D3220F-C897-4CC3-B164-156C4AC2BAAB_registryOrganizationCredentialsInputXItem" name="registryOrganizationCredentials"/>

        <bpmn2:dataOutput id="_A2D3220F-C897-4CC3-B164-156C4AC2BAAB_serviceUpdateDataOutputX" drools:dtype="org.etsi.osl.hypo.core.common.service.inventory.ServiceUpdateData" itemSubjectRef="__A2D3220F-C897-4CC3-B164-156C4AC2BAAB_serviceUpdateDataOutputXItem" name="serviceUpdateData"/>

        <bpmn2:inputSet>

          <bpmn2:dataInputRefs>_A2D3220F-C897-4CC3-B164-156C4AC2BAAB_serviceTerminationDataResponseInputX</bpmn2:dataInputRefs>

          <bpmn2:dataInputRefs>_A2D3220F-C897-4CC3-B164-156C4AC2BAAB_fabricApiConnectionResultInputX</bpmn2:dataInputRefs>

          <bpmn2:dataInputRefs>_A2D3220F-C897-4CC3-B164-156C4AC2BAAB_serviceTerminationDataWithTimerInputX</bpmn2:dataInputRefs>

          <bpmn2:dataInputRefs>_A2D3220F-C897-4CC3-B164-156C4AC2BAAB_registryOrganizationCredentialsInputX</bpmn2:dataInputRefs>

        </bpmn2:inputSet>

        <bpmn2:outputSet>

          <bpmn2:dataOutputRefs>_A2D3220F-C897-4CC3-B164-156C4AC2BAAB_serviceUpdateDataOutputX</bpmn2:dataOutputRefs>
@@ -73,6 +78,10 @@ 
        <bpmn2:sourceRef>serviceTerminationDataWithTimer</bpmn2:sourceRef>

        <bpmn2:targetRef>_A2D3220F-C897-4CC3-B164-156C4AC2BAAB_serviceTerminationDataWithTimerInputX</bpmn2:targetRef>

      </bpmn2:dataInputAssociation>

      <bpmn2:dataInputAssociation>

        <bpmn2:sourceRef>registryOrganizationCredentials</bpmn2:sourceRef>

        <bpmn2:targetRef>_A2D3220F-C897-4CC3-B164-156C4AC2BAAB_registryOrganizationCredentialsInputX</bpmn2:targetRef>

      </bpmn2:dataInputAssociation>

      <bpmn2:dataOutputAssociation>

        <bpmn2:sourceRef>_A2D3220F-C897-4CC3-B164-156C4AC2BAAB_serviceUpdateDataOutputX</bpmn2:sourceRef>

        <bpmn2:targetRef>serviceUpdateData</bpmn2:targetRef>
@@ -102,7 +111,7 @@ 
      <bpmn2:inputSet>

        <bpmn2:dataInputRefs>_45B88A5D-552F-41E8-B135-D96A256E6E9F_serviceUpdateDataInputX</bpmn2:dataInputRefs>

      </bpmn2:inputSet>

      <bpmn2:messageEventDefinition drools:msgref="tmf-service-update" messageRef="_oEDnIN8mED6ABscBVrEODg"/>

      <bpmn2:messageEventDefinition drools:msgref="tmf-service-update" messageRef="_HFNpEGDvED-QDp5Z2ucerA"/>

    </bpmn2:intermediateThrowEvent>

    <bpmn2:startEvent id="_4DABA446-012C-4882-85F9-ECDCF25C36A4" name="Start: 5G and K8s Termination Messages Handler">

      <bpmn2:extensionElements>
@@ -176,7 +185,7 @@ 
        </bpsim:Scenario>

      </bpsim:BPSimData>

    </bpmn2:extensionElements>

    <bpmn2:source>_oEBK4N8mED6ABscBVrEODg</bpmn2:source>

    <bpmn2:target>_oEBK4N8mED6ABscBVrEODg</bpmn2:target>

    <bpmn2:source>_HFMa8GDvED-QDp5Z2ucerA</bpmn2:source>

    <bpmn2:target>_HFMa8GDvED-QDp5Z2ucerA</bpmn2:target>

  </bpmn2:relationship>

</bpmn2:definitions>
 
 No newline at end of file