tweak events

data-audit/kogito-addons-data-audit-common-kafka/pom.xml

@@ -0,0 +1,40 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	<parent>
+		<artifactId>data-audit</artifactId>
+		<groupId>org.kie.kogito</groupId>
+		<version>2.0.0-SNAPSHOT</version>
+	</parent>
+
+	<artifactId>kogito-addons-data-audit-common-kafka</artifactId>
+
+	<name>Kogito Apps :: Data Audit :: Data Audit Service Common Kafka Utils</name>
+
+	<properties>
+		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+	</properties>
+
+	<dependencies>
+		<dependency>
+			<groupId>org.kie.kogito</groupId>
+			<artifactId>kogito-events-core</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.kie.kogito</groupId>
+			<artifactId>jobs-service-api</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.slf4j</groupId>
+			<artifactId>slf4j-api</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.kafka</groupId>
+			<artifactId>kafka-clients</artifactId>
+		</dependency>
+	</dependencies>
+
+
+</project>

data-audit/kogito-addons-data-audit-common/src/main/java/org/kie/kogito/app/audit/json/JsonJobDataEventDeserializer.java → data-audit/kogito-addons-data-audit-common-kafka/src/main/java/org/kie/kogito/app/audit/json/JsonJobDataEventDeserializer.java

@@ -34,7 +34,6 @@
 
 public class JsonJobDataEventDeserializer extends StdDeserializer<JobCloudEvent<?>> {
 
-
     private static final Logger LOGGER = LoggerFactory.getLogger(JsonJobDataEventDeserializer.class);
 
     private static final long serialVersionUID = 6152014726577574241L;
@@ -52,9 +51,7 @@ public JobCloudEvent<?> deserialize(JsonParser jp, DeserializationContext ctxt)
             throws IOException, JsonProcessingException {
         JsonNode node = jp.getCodec().readTree(jp);
         LOGGER.debug("Deserialize process instance data event: {}", node);
-
-
-
+
         String type = node.get("type").asText();
 
         switch (type) {

data-audit/kogito-addons-data-audit-common-kafka/src/main/java/org/kogito/addons/data/audit/common/kafka/App.java

@@ -0,0 +1,11 @@
+package org.kogito.addons.data.audit.common.kafka;
+
+/**
+ * Hello world!
+ *
+ */
+public class App {
+    public static void main(String[] args) {
+        System.out.println("Hello World!");
+    }
+}

data-audit/kogito-addons-data-audit-common/src/main/java/org/kie/kogito/app/audit/api/DataAuditContext.java

@@ -21,18 +21,18 @@
 public class DataAuditContext {
 
     private Object context;
-    
+
     public DataAuditContext(Object context) {
         this.context = context;
     }
 
     public static DataAuditContext newDataAuditContext(Object context) {
         return new DataAuditContext(context);
     }
-    
+
     @SuppressWarnings("unchecked")
     public <T> T getContext() {
         return (T) context;
     }
-    
+
 }

data-audit/kogito-addons-data-audit-common/src/main/java/org/kie/kogito/app/audit/api/DataAuditEventPublisher.java

@@ -23,7 +23,7 @@
 import org.kie.kogito.jobs.service.api.event.JobCloudEvent;
 
 public interface DataAuditEventPublisher extends EventPublisher {
-    
+
     void publish(JobCloudEvent<Job> event);
-    
+
 }

data-audit/kogito-addons-data-audit-common/src/main/java/org/kie/kogito/app/audit/api/DataAuditQueryService.java

@@ -22,14 +22,14 @@
 
 import org.kie.kogito.app.audit.graphql.GraphQLSchemaManager;
 
-import static java.util.Collections.emptyMap;
-import static org.kie.kogito.app.audit.graphql.GraphQLSchemaManager.graphQLSchemaManagerInstance;
-
 import graphql.ExecutionInput;
 import graphql.ExecutionResult;
 import graphql.GraphQL;
 import graphql.schema.GraphQLSchema;
 
+import static java.util.Collections.emptyMap;
+import static org.kie.kogito.app.audit.graphql.GraphQLSchemaManager.graphQLSchemaManagerInstance;
+
 public class DataAuditQueryService {
 
     private GraphQLSchemaManager graphQLManager;
@@ -51,14 +51,14 @@ public ExecutionResult executeQuery(DataAuditContext context, String query) {
     public ExecutionResult executeQuery(String query) {
         return executeQuery(null, query, emptyMap());
     }
-    
+
     public ExecutionResult executeQuery(DataAuditContext context, String query, Map<String, Object> variables) {
         ExecutionInput executionInput = ExecutionInput.newExecutionInput()
                 .localContext(context)
                 .query(query)
                 .variables(variables)
                 .build();
-        
+
         return graphQL.execute(executionInput);
     }
 

data-audit/kogito-addons-data-audit-common/src/main/java/org/kie/kogito/app/audit/api/SubsystemConstants.java

@@ -20,10 +20,10 @@
 
 public final class SubsystemConstants {
 
-
     private SubsystemConstants() {
         // do nothing
     }
+
     public static final String DATA_AUDIT_PATH = "/data-audit";
 
     public static final String KOGITO_PROCESSINSTANCES_EVENTS = "kogito-processinstances-events";

data-audit/kogito-addons-data-audit-common/src/main/java/org/kie/kogito/app/audit/graphql/type/UserTaskInstanceAttachmentTO.java

@@ -29,7 +29,7 @@ public class UserTaskInstanceAttachmentTO {
     private String eventId;
 
     private OffsetDateTime eventDate;
-    
+
     private String eventUser;
 
     private String userTaskDefinitionId;
@@ -143,11 +143,10 @@ public void setEventType(int eventType) {
         this.eventType = eventType;
     }
 
-
     public String getEventUser() {
         return eventUser;
     }
-    
+
     public void setEventUser(String eventUser) {
         this.eventUser = eventUser;
     }

data-audit/kogito-addons-data-audit-common/src/main/java/org/kie/kogito/app/audit/graphql/type/UserTaskInstanceDeadlineTO.java

@@ -37,11 +37,11 @@ public class UserTaskInstanceDeadlineTO {
     private String processInstanceId;
 
     private String businessKey;
-    
+
     private Map<String, Object> notification;
 
     private String eventType;
-    
+
     public UserTaskInstanceDeadlineTO(String eventId, Date eventDate, String userTaskDefinitionId, String userTaskInstanceId, String processInstanceId, String businessKey, String eventType) {
         this.eventId = eventId;
         this.eventDate = OffsetDateTime.ofInstant(eventDate.toInstant(), ZoneId.of("UTC"));
@@ -52,82 +52,66 @@ public UserTaskInstanceDeadlineTO(String eventId, Date eventDate, String userTas
         this.eventType = eventType;
     }
 
-
     public String getEventId() {
         return eventId;
     }
 
-
     public void setEventId(String eventId) {
         this.eventId = eventId;
     }
 
-
     public OffsetDateTime getEventDate() {
         return eventDate;
     }
 
-
     public void setEventDate(OffsetDateTime eventDate) {
         this.eventDate = eventDate;
     }
 
-
     public String getUserTaskDefinitionId() {
         return userTaskDefinitionId;
     }
 
-
     public void setUserTaskDefinitionId(String userTaskDefinitionId) {
         this.userTaskDefinitionId = userTaskDefinitionId;
     }
 
-
     public String getUserTaskInstanceId() {
         return userTaskInstanceId;
     }
 
-
     public void setUserTaskInstanceId(String userTaskInstanceId) {
         this.userTaskInstanceId = userTaskInstanceId;
     }
 
-
     public String getProcessInstanceId() {
         return processInstanceId;
     }
 
-
     public void setProcessInstanceId(String processInstanceId) {
         this.processInstanceId = processInstanceId;
     }
 
-
     public String getBusinessKey() {
         return businessKey;
     }
 
-
     public void setBusinessKey(String businessKey) {
         this.businessKey = businessKey;
     }
 
-
     public Map<String, Object> getNotification() {
         return notification;
     }
 
-
     public void setNotification(Map<String, Object> notification) {
         this.notification = notification;
     }
 
-
     public String getEventType() {
         return eventType;
     }
 
-
     public void setEventType(String eventType) {
         this.eventType = eventType;
     }