Commit f9733872 authored by Anastasios Poimenidis's avatar Anastasios Poimenidis
Browse files

feat: introduce new process registryGetOrganizationCredentials.bpmn2

parent e6619124

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.4.7</version>

      <version>1.5.1</version>

    </dependency>



    <dependency>

src/main/java/constants/SonataKafkaProcessesNamesConstants.java

+8 −0
Changes for src/main/java/constants/SonataKafkaProcessesNamesConstants.java: 8 added lines, 0 removed lines.
Original line number Diff line number Diff line
@@ -27,6 +27,10 @@ public class SonataKafkaProcessesNamesConstants { 
    public static final String FABRIC_API_CONNECTION_VARIABLE = "fabricApiConnection";

    public static final String FABRIC_API_CONNECTION_RESULT_VARIABLE = "fabricApiConnectionResult";



    public static final String ORGANIZATION_INFO = "organizationInfo";

    public static final String REGISTRY_STORE_KUBERNETES_INFO_MESSAGE =

            "registryStoreKubernetesInfoMessage";



    public static final String SERVICE_TELEMETRY_PROCESS = "serviceTelemetryProcess";

    public static final String SERVICE_TELEMETRY_DELETE_PROCESS = "serviceTelemetryDeleteProcess";

    public static final String SERVICE_TELEMETRY_PLATFORM_SERVICE = "serviceTelemetryPlatformService";
@@ -59,9 +63,13 @@ public class SonataKafkaProcessesNamesConstants { 


    public static final String HELM_ENGINE_PARSE_HANDLER = "helmEngineParseHandler";

    public static final String HELM_ENGINE_PARSE_UPDATE_HANDLER = "helmEngineParseUpdateHandler";



    public static final String REGISTRY_STORE_KUBERNETES_INFO_PROCESS =

            "registryStoreKubernetesInfoProcess";



    public static final String REGISTRY_GET_ORGANIZATION_CREDENTIALS =

            "registryGetOrganizationCredentials";



    public static final String SERVICE_ORDER_PROCESS = "serviceOrderProcess";

    public static final String SERVICE_UPDATE_PROCESS = "serviceUpdateProcess";

}

src/main/resources/application.properties

+10 −1
Changes for src/main/resources/application.properties: 10 added lines, 1 removed line.
Original line number Diff line number Diff line
@@ -272,7 +272,6 @@ mp.messaging.incoming.fabric-api-connection-teardown-result.connector=smallrye-k 
mp.messaging.incoming.fabric-api-connection-teardown-result.topic=fabric-api-connection-teardown-result

mp.messaging.incoming.fabric-api-connection-teardown-result.value.deserializer=org.apache.kafka.common.serialization.StringDeserializer





# Configuring the incoming channel for storing the kube config result via registry

mp.messaging.incoming.registry-store-kubernetes-config-result.connector=smallrye-kafka

mp.messaging.incoming.registry-store-kubernetes-config-result.topic=registry-store-kubernetes-config-result
@@ -283,6 +282,16 @@ mp.messaging.outgoing.registry-store-kubernetes-config.connector=smallrye-kafka 
mp.messaging.outgoing.registry-store-kubernetes-config.topic=registry-store-kubernetes-config

mp.messaging.outgoing.registry-store-kubernetes-config.value.serializer=org.apache.kafka.common.serialization.StringSerializer



# incoming channel GET TMF Organization Credentials Secret

mp.messaging.incoming.registry-organization-get-credentials-result.connector=smallrye-kafka

mp.messaging.incoming.registry-organization-get-credentials-result.topic=registry-organization-get-credentials-result

mp.messaging.incoming.registry-organization-get-credentials-result.value.deserializer=org.apache.kafka.common.serialization.StringDeserializer



# outgoing channel GET TMF Organization Credentials Secret result

mp.messaging.outgoing.registry-organization-get-credentials.connector=smallrye-kafka

mp.messaging.outgoing.registry-organization-get-credentials.topic=registry-organization-get-credentials

mp.messaging.outgoing.registry-organization-get-credentials.value.serializer=org.apache.kafka.common.serialization.StringSerializer



# Disable Kogito background event publishing

kogito.events.processinstances.enabled=false

kogito.events.processdefinitions.enabled=false

src/main/resources/diagrams/registry/registryGetOrganizationCredentials.bpmn2

0 → 100644
+121 −0
Changes for src/main/resources/diagrams/registry/registryGetOrganizationCredentials.bpmn2: 121 added lines, 0 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="_w0RsQFK5ED-WOf6dXKnpgg" 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="_organizationInfoItem" structureRef="org.etsi.osl.hypo.core.common.registry.OrganizationInfo"/>

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

  <bpmn2:itemDefinition id="__7BE4745C-F772-49AA-8688-B82E5CA97A2F_organizationInfoInputXItem" structureRef="org.etsi.osl.hypo.core.common.registry.OrganizationInfo"/>

  <bpmn2:itemDefinition id="registry-organization-get-credentialsType" structureRef="org.etsi.osl.hypo.core.common.registry.OrganizationInfo"/>

  <bpmn2:itemDefinition id="__4950AA05-8832-4305-AC86-CF875DAAF775_registryOrganizationCredentialsOutputXItem" structureRef="org.etsi.osl.hypo.core.common.registry.RegistryOrganizationCredentials"/>

  <bpmn2:itemDefinition id="registry-organization-get-credentials-resultType" structureRef="org.etsi.osl.hypo.core.common.registry.RegistryOrganizationCredentials"/>

  <bpmn2:itemDefinition id="_91DBD031-3AF2-4180-92F0-2DE53478BD0B" structureRef=""/>

  <bpmn2:itemDefinition id="_F7B9D58C-28D3-487F-BD0B-617F11E793BC" structureRef=""/>

  <bpmn2:message id="_w0S6YFK5ED-WOf6dXKnpgg" itemRef="registry-organization-get-credentialsType" name="registry-organization-get-credentials"/>

  <bpmn2:message id="_w0S6YVK5ED-WOf6dXKnpgg" itemRef="registry-organization-get-credentials-resultType" name="registry-organization-get-credentials-result"/>

  <bpmn2:collaboration id="_4978B402-CB4D-4BCC-90A4-F1186B87676C" name="Default Collaboration">

    <bpmn2:participant id="_652A54B6-7728-428F-9D44-466BB47B5251" name="Pool Participant" processRef="registryGetOrganizationCredentials"/>

  </bpmn2:collaboration>

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

    <bpmn2:property id="organizationInfo" itemSubjectRef="_organizationInfoItem" name="organizationInfo"/>

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

    <bpmn2:sequenceFlow id="_1C2DCE06-5B3B-4ACE-9DEC-258BA59D5744" sourceRef="_4950AA05-8832-4305-AC86-CF875DAAF775" targetRef="_96B54EFC-95BC-4085-930B-8946BD72325B"/>

    <bpmn2:sequenceFlow id="_631CB46B-FFF2-4871-BC07-028300CA86B6" sourceRef="_7BE4745C-F772-49AA-8688-B82E5CA97A2F" targetRef="_4950AA05-8832-4305-AC86-CF875DAAF775"/>

    <bpmn2:sequenceFlow id="_10095753-1F6A-4E08-AA56-B65F0112DBFE" sourceRef="_A9E21EDB-CF00-4098-A80C-5737933937F8" targetRef="_7BE4745C-F772-49AA-8688-B82E5CA97A2F"/>

    <bpmn2:endEvent id="_96B54EFC-95BC-4085-930B-8946BD72325B" name="END: Registry Get Organization Credentials">

      <bpmn2:extensionElements>

        <drools:metaData name="elementname">

          <drools:metaValue><![CDATA[END: Registry Get Organization Credentials]]></drools:metaValue>

        </drools:metaData>

      </bpmn2:extensionElements>

      <bpmn2:incoming>_1C2DCE06-5B3B-4ACE-9DEC-258BA59D5744</bpmn2:incoming>

    </bpmn2:endEvent>

    <bpmn2:intermediateCatchEvent id="_4950AA05-8832-4305-AC86-CF875DAAF775" name="Receive Registry organization credentials result">

      <bpmn2:extensionElements>

        <drools:metaData name="elementname">

          <drools:metaValue><![CDATA[Receive Registry organization credentials result]]></drools:metaValue>

        </drools:metaData>

      </bpmn2:extensionElements>

      <bpmn2:incoming>_631CB46B-FFF2-4871-BC07-028300CA86B6</bpmn2:incoming>

      <bpmn2:outgoing>_1C2DCE06-5B3B-4ACE-9DEC-258BA59D5744</bpmn2:outgoing>

      <bpmn2:dataOutput id="_4950AA05-8832-4305-AC86-CF875DAAF775_registryOrganizationCredentialsOutputX" drools:dtype="org.etsi.osl.hypo.core.common.registry.RegistryOrganizationCredentials" itemSubjectRef="__4950AA05-8832-4305-AC86-CF875DAAF775_registryOrganizationCredentialsOutputXItem" name="registryOrganizationCredentials"/>

      <bpmn2:dataOutputAssociation>

        <bpmn2:sourceRef>_4950AA05-8832-4305-AC86-CF875DAAF775_registryOrganizationCredentialsOutputX</bpmn2:sourceRef>

        <bpmn2:targetRef>registryOrganizationCredentials</bpmn2:targetRef>

      </bpmn2:dataOutputAssociation>

      <bpmn2:outputSet>

        <bpmn2:dataOutputRefs>_4950AA05-8832-4305-AC86-CF875DAAF775_registryOrganizationCredentialsOutputX</bpmn2:dataOutputRefs>

      </bpmn2:outputSet>

      <bpmn2:messageEventDefinition drools:msgref="registry-organization-get-credentials-result" messageRef="_w0S6YVK5ED-WOf6dXKnpgg"/>

    </bpmn2:intermediateCatchEvent>

    <bpmn2:intermediateThrowEvent id="_7BE4745C-F772-49AA-8688-B82E5CA97A2F" name="Send organization credentials request">

      <bpmn2:extensionElements>

        <drools:metaData name="elementname">

          <drools:metaValue><![CDATA[Send organization credentials request]]></drools:metaValue>

        </drools:metaData>

      </bpmn2:extensionElements>

      <bpmn2:incoming>_10095753-1F6A-4E08-AA56-B65F0112DBFE</bpmn2:incoming>

      <bpmn2:outgoing>_631CB46B-FFF2-4871-BC07-028300CA86B6</bpmn2:outgoing>

      <bpmn2:dataInput id="_7BE4745C-F772-49AA-8688-B82E5CA97A2F_organizationInfoInputX" drools:dtype="org.etsi.osl.hypo.core.common.registry.OrganizationInfo" itemSubjectRef="__7BE4745C-F772-49AA-8688-B82E5CA97A2F_organizationInfoInputXItem" name="organizationInfo"/>

      <bpmn2:dataInputAssociation>

        <bpmn2:sourceRef>organizationInfo</bpmn2:sourceRef>

        <bpmn2:targetRef>_7BE4745C-F772-49AA-8688-B82E5CA97A2F_organizationInfoInputX</bpmn2:targetRef>

      </bpmn2:dataInputAssociation>

      <bpmn2:inputSet>

        <bpmn2:dataInputRefs>_7BE4745C-F772-49AA-8688-B82E5CA97A2F_organizationInfoInputX</bpmn2:dataInputRefs>

      </bpmn2:inputSet>

      <bpmn2:messageEventDefinition drools:msgref="registry-organization-get-credentials" messageRef="_w0S6YFK5ED-WOf6dXKnpgg"/>

    </bpmn2:intermediateThrowEvent>

    <bpmn2:startEvent id="_A9E21EDB-CF00-4098-A80C-5737933937F8" name="START: Registry Get Organization Credentials">

      <bpmn2:extensionElements>

        <drools:metaData name="elementname">

          <drools:metaValue><![CDATA[START: Registry Get Organization Credentials]]></drools:metaValue>

        </drools:metaData>

      </bpmn2:extensionElements>

      <bpmn2:outgoing>_10095753-1F6A-4E08-AA56-B65F0112DBFE</bpmn2:outgoing>

    </bpmn2:startEvent>

  </bpmn2:process>

  <bpmndi:BPMNDiagram>

    <bpmndi:BPMNPlane bpmnElement="registryGetOrganizationCredentials">

      <bpmndi:BPMNShape id="shape__A9E21EDB-CF00-4098-A80C-5737933937F8" bpmnElement="_A9E21EDB-CF00-4098-A80C-5737933937F8">

        <dc:Bounds height="56" width="56" x="137" y="187"/>

      </bpmndi:BPMNShape>

      <bpmndi:BPMNShape id="shape__7BE4745C-F772-49AA-8688-B82E5CA97A2F" bpmnElement="_7BE4745C-F772-49AA-8688-B82E5CA97A2F">

        <dc:Bounds height="56" width="56" x="384" y="187"/>

      </bpmndi:BPMNShape>

      <bpmndi:BPMNShape id="shape__4950AA05-8832-4305-AC86-CF875DAAF775" bpmnElement="_4950AA05-8832-4305-AC86-CF875DAAF775">

        <dc:Bounds height="56" width="56" x="631" y="187"/>

      </bpmndi:BPMNShape>

      <bpmndi:BPMNShape id="shape__96B54EFC-95BC-4085-930B-8946BD72325B" bpmnElement="_96B54EFC-95BC-4085-930B-8946BD72325B">

        <dc:Bounds height="56" width="56" x="851" y="187"/>

      </bpmndi:BPMNShape>

      <bpmndi:BPMNEdge id="edge_shape__A9E21EDB-CF00-4098-A80C-5737933937F8_to_shape__7BE4745C-F772-49AA-8688-B82E5CA97A2F" bpmnElement="_10095753-1F6A-4E08-AA56-B65F0112DBFE">

        <di:waypoint x="165" y="215"/>

        <di:waypoint x="384" y="215"/>

      </bpmndi:BPMNEdge>

      <bpmndi:BPMNEdge id="edge_shape__7BE4745C-F772-49AA-8688-B82E5CA97A2F_to_shape__4950AA05-8832-4305-AC86-CF875DAAF775" bpmnElement="_631CB46B-FFF2-4871-BC07-028300CA86B6">

        <di:waypoint x="412" y="215"/>

        <di:waypoint x="631" y="215"/>

      </bpmndi:BPMNEdge>

      <bpmndi:BPMNEdge id="edge_shape__4950AA05-8832-4305-AC86-CF875DAAF775_to_shape__96B54EFC-95BC-4085-930B-8946BD72325B" bpmnElement="_1C2DCE06-5B3B-4ACE-9DEC-258BA59D5744">

        <di:waypoint x="659" y="215"/>

        <di:waypoint x="851" y="215"/>

      </bpmndi:BPMNEdge>

    </bpmndi:BPMNPlane>

  </bpmndi:BPMNDiagram>

  <bpmn2:relationship type="BPSimData">

    <bpmn2:extensionElements>

      <bpsim:BPSimData>

        <bpsim:Scenario id="default" name="Simulationscenario">

          <bpsim:ScenarioParameters/>

          <bpsim:ElementParameters elementRef="_A9E21EDB-CF00-4098-A80C-5737933937F8">

            <bpsim:TimeParameters>

              <bpsim:ProcessingTime>

                <bpsim:NormalDistribution mean="0" standardDeviation="0"/>

              </bpsim:ProcessingTime>

            </bpsim:TimeParameters>

          </bpsim:ElementParameters>

        </bpsim:Scenario>

      </bpsim:BPSimData>

    </bpmn2:extensionElements>

    <bpmn2:source>_w0RsQFK5ED-WOf6dXKnpgg</bpmn2:source>

    <bpmn2:target>_w0RsQFK5ED-WOf6dXKnpgg</bpmn2:target>

  </bpmn2:relationship>

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

src/test/java/io/sonata/kafka/InMemoryKafkaBrokerResource.java

+2 −0
Changes for src/test/java/io/sonata/kafka/InMemoryKafkaBrokerResource.java: 2 added lines, 0 removed lines.
Original line number Diff line number Diff line
@@ -33,6 +33,7 @@ public class InMemoryKafkaBrokerResource implements QuarkusTestResourceLifecycle 
                        TELEMETRY_CREATE_PROMETHEUS_JOB_AND_GRAFANA_DASHBOARD,

                        TELEMETRY_DELETE_PROMETHEUS_JOB_AND_GRAFANA_DASHBOARD,

                        REGISTRY_STORE_KUBE_CONF_CHANNEL,

                        "registry-organization-get-credentials",

                        TELEMETRY_PLATFORM_SERVICE,

                        FABRIC_API_CONNECTION,

                        FABRIC_API_CONNECTION_TEARDOWN));
@@ -60,6 +61,7 @@ public class InMemoryKafkaBrokerResource implements QuarkusTestResourceLifecycle 
                        SONATA_SERVICE_DASHBOARD_RESULT,

                        SONATA_SERVICE_DELETE_DASHBOARD_RESULT,

                        REGISTRY_STORE_KUBE_CONF_CHANNEL_RESULT,

                        "registry-organization-get-credentials-result",

                        TELEMETRY_PLATFORM_SERVICE_RESULT,

                        FABRIC_API_CONNECTION_RESULT,

                        FABRIC_API_CONNECTION_TEARDOWN_RESULT));