kie-issues#1669: jBPM Quarkus DevUI seems to not update the # of items

packages/jbpm-quarkus-devui/jbpm-quarkus-devui-deployment/src/main/java/org/jbpm/quarkus/devui/deployment/DevConsoleProcessor.java

@@ -135,21 +135,21 @@ public CardPageBuildItem pages(
                 .metadata("page", "Processes")
                 .title("Process Instances")
                 .icon("font-awesome-solid:diagram-project")
-                .dynamicLabelJsonRPCMethodName("queryProcessInstancesCount"));
+                .streamingLabelJsonRPCMethodName("queryProcessInstancesCount"));
 
         cardPageBuildItem.addPage(Page.webComponentPageBuilder()
                 .componentLink("qwc-jbpm-quarkus-devui.js")
                 .metadata("page", "Tasks")
                 .title("Tasks")
                 .icon("font-awesome-solid:bars-progress")
-                .dynamicLabelJsonRPCMethodName("queryTasksCount"));
+                .streamingLabelJsonRPCMethodName("queryTasksCount"));
 
         cardPageBuildItem.addPage(Page.webComponentPageBuilder()
                 .componentLink("qwc-jbpm-quarkus-devui.js")
                 .metadata("page", "Jobs")
                 .title("Jobs")
                 .icon("font-awesome-solid:clock")
-                .dynamicLabelJsonRPCMethodName("queryJobsCount"));
+                .streamingLabelJsonRPCMethodName("queryJobsCount"));
 
         cardPageBuildItem.addPage(Page.webComponentPageBuilder()
                 .componentLink("qwc-jbpm-quarkus-devui.js")

packages/jbpm-quarkus-devui/jbpm-quarkus-devui-runtime/pom.xml

@@ -95,6 +95,11 @@
       <artifactId>vertx-web-client</artifactId>
     </dependency>
 
+    <dependency>
+      <groupId>org.kie.kogito</groupId>
+      <artifactId>kogito-api</artifactId>
+    </dependency>
+
     <dependency>
       <groupId>org.junit.jupiter</groupId>
       <artifactId>junit-jupiter-engine</artifactId>

packages/jbpm-quarkus-devui/jbpm-quarkus-devui-runtime/src/main/java/org/jbpm/quarkus/devui/runtime/rpc/DataIndexCounter.java

@@ -0,0 +1,78 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.jbpm.quarkus.devui.runtime.rpc;
+
+import io.smallrye.mutiny.Multi;
+import io.smallrye.mutiny.operators.multi.processors.BroadcastProcessor;
+import io.vertx.core.Future;
+import io.vertx.core.Vertx;
+import io.vertx.core.json.JsonObject;
+import io.vertx.ext.web.client.WebClient;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class DataIndexCounter {
+    private static final String DATA_INDEX_URL = "kogito.data-index.url";
+    private static final Logger LOGGER = LoggerFactory.getLogger(DataIndexCounter.class);
+
+    private Multi<String> multi;
+    private WebClient dataIndexWebClient;
+
+    public DataIndexCounter(String query, String graphname, BroadcastProcessor<String> stream,WebClient dataIndexWebClient, JBPMDevUIEventPublisher eventPublisher) {
+        this.dataIndexWebClient = dataIndexWebClient;
+
+        Vertx vertx = Vertx.vertx();
+        this.multi = Multi.createFrom().emitter(emitter -> {
+            vertx.setPeriodic(1000, id -> emitter.emit("Initial data emitted"));
+        });
+
+
+        vertx.setPeriodic(1000, id -> refreshData(stream,query,graphname)); 
+    }
+
+    private void refreshData(BroadcastProcessor<String> stream, String query, String graphname ) {
+        LOGGER.info("Refreshing data for query: {}", query);
+
+        doQuery(query, graphname).toCompletionStage()
+                 .thenAccept(result -> {
+            stream.onNext(result);
+                 });
+    }
+
+       private Future<String> doQuery(String query, String graphModelName) {
+        if(dataIndexWebClient == null) {
+            LOGGER.warn("Cannot perform '{}' query, dataIndexWebClient couldn't be set. Is DataIndex correctly? Please verify '{}' value", graphModelName, DATA_INDEX_URL);
+             return Future.succeededFuture("-");
+         }
+         return this.dataIndexWebClient.post("/graphql")
+                 .putHeader("content-type", "application/json")
+                 .sendJson(new JsonObject(query))
+                 .map(response -> {
+                    if(response.statusCode() == 200) {
+                         JsonObject responseData = response.bodyAsJsonObject().getJsonObject("data");
+                         return String.valueOf(responseData.getJsonArray(graphModelName).size());
+                     }
+                     return "-";
+                 });
+     }
+
+    public Multi<String> getMulti() {
+        return multi;
+    }
+}

packages/jbpm-quarkus-devui/jbpm-quarkus-devui-runtime/src/main/java/org/jbpm/quarkus/devui/runtime/rpc/JBPMDevUIEventPublisher.java

@@ -0,0 +1,80 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+ package org.jbpm.quarkus.devui.runtime.rpc;
+ import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.enterprise.inject.Default;
+
+import org.kie.kogito.event.DataEvent;
+ import org.kie.kogito.event.EventPublisher;
+ import org.slf4j.Logger;
+ import org.slf4j.LoggerFactory;
+
+ import java.util.Collection;
+ import java.util.Objects;
+
+@Default
+@ApplicationScoped
+ public class JBPMDevUIEventPublisher implements EventPublisher {
+
+     private static final Logger LOGGER = LoggerFactory.getLogger(JBPMDevUIEventPublisher.class);
+     private Runnable onProcessEvent;
+     private Runnable onTaskEvent;
+     private Runnable onJobEvent;
+
+     @Override
+     public void publish(DataEvent<?> event) {
+         switch (event.getType()) {
+             case "ProcessInstanceStateDataEvent":
+                 maybeRun(onProcessEvent);
+                 break;
+             case "UserTaskInstanceStateDataEvent":
+                 maybeRun(onTaskEvent);
+                 break;
+             case "JobEvent":
+                 maybeRun(onJobEvent);
+                 break;
+             default:
+                 LOGGER.debug("Unknown type of event '{}', ignoring for this publisher", event.getType());
+         }
+     }
+
+     @Override
+     public void publish(Collection<DataEvent<?>> events) {
+         events.forEach(this::publish);
+     }
+
+     private void maybeRun(Runnable runnable) {
+         if(Objects.nonNull(runnable)) {
+             runnable.run();
+         }
+     }
+
+     public void setOnProcessEventListener(Runnable onProcessEvent) {
+         this.onProcessEvent = onProcessEvent;
+     }
+
+     public void setOnTaskEventListener(Runnable onTaskEvent) {
+         this.onTaskEvent = onTaskEvent;
+     }
+
+     public void setOnJobEventListener(Runnable onJobEvent) {
+         this.onJobEvent = onJobEvent;
+     }
+ }