[Fix #3721] Adding addons

Author: fjtirado

api/kogito-events-core/src/main/java/org/kie/kogito/event/serializer/KogitoDataEventSerializationHelper.java

@@ -65,6 +65,7 @@ static void populateCloudEvent(ProcessInstanceDataEvent<?> event, ProcessInstanc
         event.setKogitoRootProcessInstanceId(info.getRootInstanceId());
         event.setKogitoIdentity(info.getIdentity());
         event.setSource(info.getSource());
+        event.setKogitoAddons(info.getAddons());
     }
 
 }

api/kogito-events-core/src/main/java/org/kie/kogito/event/serializer/ProcessInstanceDataEventExtensionRecord.java

@@ -31,7 +31,7 @@
 
 class ProcessInstanceDataEventExtensionRecord implements KogitoMarshallEventSupport {
 
-    // addons, referenceId, and starFromNode are not used by process instance events
+    // referenceId and startFromNode are not used by process instance events
     private String id;
     private String instanceId;
     private String version;
@@ -44,6 +44,7 @@ class ProcessInstanceDataEventExtensionRecord implements KogitoMarshallEventSupp
     private String identity;
     private URI source;
     private OffsetDateTime time;
+    private String addons;
     private transient int ordinal;
 
     public ProcessInstanceDataEventExtensionRecord() {
@@ -63,6 +64,7 @@ public ProcessInstanceDataEventExtensionRecord(int ordinal, ProcessInstanceDataE
         identity = dataEvent.getKogitoIdentity();
         time = dataEvent.getTime();
         source = dataEvent.getSource();
+        addons = dataEvent.getKogitoAddons();
     }
 
     public int getOrdinal() {
@@ -117,6 +119,10 @@ public URI getSource() {
         return source;
     }
 
+    public String getAddons() {
+        return addons;
+    }
+
     @Override
     public void writeEvent(DataOutput out) throws IOException {
         out.writeUTF(id);
@@ -131,6 +137,7 @@ public void writeEvent(DataOutput out) throws IOException {
         writeUTF(out, identity);
         writeTime(out, time);
         out.writeUTF(source.toString());
+        writeUTF(out, addons);
     }
 
     @Override
@@ -147,5 +154,6 @@ public void readEvent(DataInput in) throws IOException {
         identity = readUTF(in);
         time = readTime(in);
         source = URI.create(in.readUTF());
+        addons = readUTF(in);
     }
 }

api/kogito-events-core/src/test/java/org/kie/kogito/event/process/ProcessEventsTest.java

@@ -58,6 +58,7 @@ class ProcessEventsTest {
             CloudEventExtensionConstants.PROCESS_ROOT_PROCESS_INSTANCE_ID,
             CloudEventExtensionConstants.PROCESS_ID,
             CloudEventExtensionConstants.PROCESS_ROOT_PROCESS_ID,
+            CloudEventExtensionConstants.ADDONS,
             CloudEventExtensionConstants.PROCESS_INSTANCE_VERSION,
             CloudEventExtensionConstants.PROCESS_PARENT_PROCESS_INSTANCE_ID,
             CloudEventExtensionConstants.PROCESS_INSTANCE_STATE,
@@ -86,6 +87,7 @@ class ProcessEventsTest {
     private static final String PROCESS_INSTANCE_STATE = "PROCESS_INSTANCE_STATE";
     private static final String BUSINESS_KEY = "BUSINESS_KEY";
     private static final String PROCESS_TYPE = "PROCESS_TYPE";
+    private static final String ADDONS = "ADDONS";
     private static final int PROCESS_STATE = 1;
     private static final String NODE_CONTAINER_ID = "323";
     private static final String NODE_CONTAINER_INSTANCEID = "323-3232-3232";
@@ -350,6 +352,7 @@ private static void setBaseEventValues(AbstractDataEvent<?> event, String eventT
         event.setKogitoProcessInstanceState(PROCESS_INSTANCE_STATE);
         event.setKogitoBusinessKey(BUSINESS_KEY);
         event.setKogitoProcessType(PROCESS_TYPE);
+        event.setKogitoAddons(ADDONS);
         event.setKogitoIdentity(SUBJECT);
     }
 
@@ -376,13 +379,16 @@ private static void assertBaseEventValues(AbstractDataEvent<?> deserializedEvent
         assertThat(deserializedEvent.getKogitoBusinessKey()).isEqualTo(BUSINESS_KEY);
         assertThat(deserializedEvent.getKogitoProcessType()).isEqualTo(PROCESS_TYPE);
         assertThat(deserializedEvent.getKogitoIdentity()).isEqualTo(SUBJECT);
+        assertThat(deserializedEvent.getKogitoAddons()).isEqualTo(ADDONS);
     }
 
     private static void assertExtensionNames(AbstractDataEvent<?> event, Set<String> baseNames, String... names) {
         Set<String> extensionNames = event.getExtensionNames();
         assertThat(extensionNames).hasSize(baseNames.size() + names.length)
                 .containsAll(baseNames);
-
+        if (names.length > 0) {
+            assertThat(extensionNames).contains(names);
+        }
     }
 
     private static void assertExtensionsNotDuplicated(String json, Set<String> extensionNames) {