[Fix apache#3486] Add input param counter

kogito-bom/pom.xml

@@ -695,6 +695,17 @@
         <version>${project.version}</version>
         <classifier>sources</classifier>
       </dependency>
+      <dependency>
+        <groupId>org.kie</groupId>
+        <artifactId>kie-addons-quarkus-monitoring-sonataflow</artifactId>
+        <version>${project.version}</version>
+      </dependency>
+      <dependency>
+        <groupId>org.kie</groupId>
+        <artifactId>kie-addons-quarkus-monitoring-sonataflow</artifactId>
+        <version>${project.version}</version>
+        <classifier>sources</classifier>
+      </dependency>
       <dependency>
         <groupId>org.kie</groupId>
         <artifactId>kie-addons-springboot-monitoring-core</artifactId>
@@ -1886,6 +1897,18 @@
         <version>${project.version}</version>
         <classifier>sources</classifier>
       </dependency>
+      <dependency>
+        <groupId>org.kie.kogito</groupId>
+        <artifactId>kogito-serverless-workflow-monitoring</artifactId>
+        <version>${project.version}</version>
+      </dependency>
+      <dependency>
+        <groupId>org.kie.kogito</groupId>
+        <artifactId>kogito-serverless-workflow-monitoring</artifactId>
+        <version>${project.version}</version>
+        <classifier>sources</classifier>
+      </dependency>
+
       <dependency>
         <groupId>org.kie.kogito</groupId>
         <artifactId>kogito-serverless-workflow-openapi-parser</artifactId>

kogito-serverless-workflow/kogito-serverless-workflow-monitoring/pom.xml

@@ -0,0 +1,24 @@
+<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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+  <parent>
+    <groupId>org.kie.kogito</groupId>
+    <artifactId>kogito-serverless-workflow</artifactId>
+    <version>999-SNAPSHOT</version>
+  </parent>
+  <artifactId>kogito-serverless-workflow-monitoring</artifactId>
+  <name>Kogito :: Serverless Workflow :: Monitoring</name>
+   <properties>
+      <java.module.name>org.kie.kogito.serverless.workflow.monitoring</java.module.name>
+  </properties>
+
+  <dependencies>
+    <dependency>
+      <groupId>org.kie</groupId>
+      <artifactId>kie-addons-monitoring-core</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.kie.kogito</groupId>
+      <artifactId>kogito-serverless-workflow-runtime</artifactId>
+    </dependency>
+  </dependencies>
+</project>

kogito-serverless-workflow/kogito-serverless-workflow-monitoring/src/main/java/org/kie/kogito/serverless/workflow/monitoring/SonataFlowMetricProcessEventListener.java

@@ -0,0 +1,51 @@
+package org.kie.kogito.serverless.workflow.monitoring;
+
+import org.kie.api.event.process.ProcessStartedEvent;
+import org.kie.kogito.KogitoGAV;
+import org.kie.kogito.internal.process.runtime.KogitoProcessInstance;
+import org.kie.kogito.monitoring.core.common.process.MetricsProcessEventListener;
+import org.kie.kogito.serverless.workflow.SWFConstants;
+
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+
+import io.micrometer.core.instrument.MeterRegistry;
+import io.micrometer.core.instrument.Tag;
+
+public class SonataFlowMetricProcessEventListener extends MetricsProcessEventListener {
+
+    public SonataFlowMetricProcessEventListener(KogitoGAV gav, MeterRegistry meterRegistry) {
+        super("sonataflow-process-monitoring-listener", gav, meterRegistry);
+    }
+
+    @Override
+    public void afterProcessStarted(ProcessStartedEvent event) {
+        super.afterProcessStarted(event);
+        final KogitoProcessInstance processInstance = (KogitoProcessInstance) event.getProcessInstance();
+        Object node = processInstance.getVariables().get(SWFConstants.DEFAULT_WORKFLOW_VAR);
+        if (node instanceof ObjectNode) {
+            registerObject(processInstance.getProcessId(), (ObjectNode) node, null);
+        }
+
+    }
+
+    private void registerObject(String processId, ObjectNode node, String prefix) {
+        node.fields().forEachRemaining(e -> registerInputParam(processId, e.getKey(), e.getValue(), prefix));
+    }
+
+    private void registerInputParam(String processId, String key, JsonNode value, String prefix) {
+        if (value.isObject()) {
+            registerObject(processId, (ObjectNode) value, concat(prefix, key));
+        } else {
+            registerInputParam(processId, concat(prefix, key), value.toString());
+        }
+    }
+
+    private String concat(String prefix, String key) {
+        return prefix == null ? key : prefix + "." + key;
+    }
+
+    private void registerInputParam(String processId, String key, String value) {
+        buildCounter("sonataflow_input_parameters_counter", "Input parameters", processId, Tag.of("param_name", key), Tag.of("param_value", value)).increment();
+    }
+}

kogito-serverless-workflow/pom.xml

@@ -57,6 +57,7 @@
     <module>kogito-serverless-workflow-executor-tests</module>
     <module>kogito-serverless-workflow-dmn-parser</module>
     <module>kogito-serverless-workflow-dmn</module>
+    <module>kogito-serverless-workflow-monitoring</module>
   </modules>
 
   <profiles>

quarkus/addons/monitoring/pom.xml

@@ -38,6 +38,7 @@
     <module>core</module>
     <module>prometheus</module>
     <module>elastic</module>
+    <module>sonataflow</module>
   </modules>
 
 </project>

quarkus/addons/monitoring/sonataflow/pom.xml

@@ -0,0 +1,23 @@
+<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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+  <parent>
+    <groupId>org.kie</groupId>
+    <artifactId>kie-addons-quarkus-monitoring-parent</artifactId>
+    <version>999-SNAPSHOT</version>
+  </parent>
+  <artifactId>kie-addons-quarkus-monitoring-sonataflow</artifactId>
+  <name>KIE Add-On Monitoring Sonataflow</name>
+  <properties>
+    <java.module.name>org.kie.kogito.monitoring.sonataflow.quarkus</java.module.name>
+  </properties>
+  <dependencies>
+    <dependency>
+      <groupId>org.kie</groupId>
+      <artifactId>kie-addons-quarkus-monitoring-core</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.kie.kogito</groupId>
+      <artifactId>kogito-serverless-workflow-monitoring</artifactId>
+    </dependency>
+  </dependencies>
+</project>

quarkus/addons/monitoring/sonataflow/src/main/java/org/kie/sonataflow/monitoring/SonataFlowMetricEventListenerFactory.java

@@ -0,0 +1,26 @@
+package org.kie.sonataflow.monitoring;
+
+import org.kie.kogito.KogitoGAV;
+import org.kie.kogito.config.ConfigBean;
+import org.kie.kogito.internal.process.event.KogitoProcessEventListener;
+import org.kie.kogito.monitoring.core.common.Constants;
+import org.kie.kogito.monitoring.core.common.process.MetricsProcessEventListener;
+import org.kie.kogito.serverless.workflow.monitoring.SonataFlowMetricProcessEventListener;
+
+import io.micrometer.core.instrument.Metrics;
+import io.quarkus.arc.properties.IfBuildProperty;
+import jakarta.enterprise.inject.Produces;
+import jakarta.inject.Inject;
+
+public class SonataFlowMetricEventListenerFactory {
+
+	@Inject
+	ConfigBean configBean;
+
+    @Produces
+    public KogitoProcessEventListener produceProcessListener() {
+        return new SonataFlowMetricProcessEventListener(
+                configBean.getGav().orElse(KogitoGAV.EMPTY_GAV), Metrics.globalRegistry);
+    }
+}	
+

quarkus/addons/monitoring/sonataflow/src/main/resources/application.properties

@@ -0,0 +1 @@
+kogito.monitoring.process.useDefault=false