Changes that allows Mcp usage from Chappie

Signed-off-by: Phillip Kruger <[email protected]>

Author: phillip-kruger

bom/application/pom.xml

@@ -680,6 +680,11 @@
                 <artifactId>quarkus-devui</artifactId>
                 <version>${project.version}</version>
             </dependency>
+            <dependency>
+                <groupId>io.quarkus</groupId>
+                <artifactId>quarkus-devui-spi</artifactId>
+                <version>${project.version}</version>
+            </dependency>
             <dependency>
                 <groupId>io.quarkus</groupId>
                 <artifactId>quarkus-devui-deployment</artifactId>

extensions/devui/deployment/src/main/java/io/quarkus/devui/deployment/menu/MCPProcessor.java

@@ -61,7 +61,7 @@ void createMCPPage(BuildProducer<SettingPageBuildItem> settingPageProducer,
 
     @BuildStep(onlyIf = IsDevelopment.class)
     @io.quarkus.deployment.annotations.Record(ExecutionTime.STATIC_INIT)
-    void registerDevUiHandlers(
+    void registerStreamableHTTPHandlers(
             BuildProducer<RouteBuildItem> routeProducer,
             DevUIRecorder recorder,
             LaunchModeBuildItem launchModeBuildItem,

extensions/devui/pom.xml

@@ -19,5 +19,6 @@
         <module>deployment</module>
         <module>test-spi</module>
         <module>deployment-spi</module>
+        <module>runtime-spi</module>
     </modules>
 </project>

extensions/devui/runtime-spi/pom.xml

@@ -0,0 +1,14 @@
+<?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>quarkus-devui-parent</artifactId>
+        <groupId>io.quarkus</groupId>
+        <version>999-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>quarkus-devui-spi</artifactId>
+    <name>Quarkus - Dev UI - Runtime SPI</name>
+    <description>Quarkus Dev UI SPI</description>
+    
+</project>

extensions/devui/runtime-spi/src/main/java/io/quarkus/devui/runtime/spi/McpEvent.java

@@ -0,0 +1,4 @@
+package io.quarkus.devui.runtime.spi;
+
+public record McpEvent(boolean enabled) {
+}

extensions/devui/runtime/src/main/java/io/quarkus/devui/runtime/mcp/McpServerConfiguration.java renamed to extensions/devui/runtime-spi/src/main/java/io/quarkus/devui/runtime/spi/McpServerConfiguration.java

@@ -1,4 +1,4 @@
-package io.quarkus.devui.runtime.mcp;
+package io.quarkus.devui.runtime.spi;
 
 import java.util.HashMap;
 import java.util.Map;

extensions/devui/runtime/pom.xml

@@ -22,6 +22,10 @@
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-assistant-dev</artifactId>
         </dependency>
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-devui-spi</artifactId>
+        </dependency>
     </dependencies>
 
     <build>

extensions/devui/runtime/src/main/java/io/quarkus/devui/runtime/mcp/McpDevUIJsonRpcService.java

@@ -14,6 +14,8 @@
 import jakarta.enterprise.context.ApplicationScoped;
 import jakarta.enterprise.inject.Produces;
 
+import io.quarkus.devui.runtime.spi.McpEvent;
+import io.quarkus.devui.runtime.spi.McpServerConfiguration;
 import io.smallrye.mutiny.Multi;
 import io.smallrye.mutiny.operators.multi.processors.BroadcastProcessor;
 
@@ -22,10 +24,10 @@
  */
 @ApplicationScoped
 public class McpDevUIJsonRpcService {
-
     private final BroadcastProcessor<McpClientInfo> connectedClientStream = BroadcastProcessor.create();
+    private final BroadcastProcessor<McpEvent> mcpEventStream = BroadcastProcessor.create();
 
-    // TODO: We need to be able to deregister a client if the connection drops. Mayby ping it ?
+    // TODO: We need to be able to deregister a client if the connection drops. Maybe ping it ?
 
     private final Set<McpClientInfo> connectedClients = new HashSet<>();
     private McpServerConfiguration mcpServerConfiguration;
@@ -43,7 +45,12 @@ public Set<McpClientInfo> getConnectedClients() {
     }
 
     public Multi<McpClientInfo> getConnectedClientStream() {
-        return connectedClientStream;
+        return this.connectedClientStream;
+    }
+
+    @Produces
+    public Multi<McpEvent> getEventStream() {
+        return this.mcpEventStream;
     }
 
     public void addClientInfo(McpClientInfo clientInfo) {
@@ -59,12 +66,14 @@ public McpServerConfiguration getMcpServerConfiguration() {
     public McpServerConfiguration enable() {
         this.mcpServerConfiguration.enable();
         storeConfiguration(this.mcpServerConfiguration.toProperties());
+        mcpEventStream.onNext(new McpEvent(true));
         return this.mcpServerConfiguration;
     }
 
     public McpServerConfiguration disable() {
         this.mcpServerConfiguration.disable();
         storeConfiguration(this.mcpServerConfiguration.toProperties());
+        mcpEventStream.onNext(new McpEvent(false));
         return this.mcpServerConfiguration;
     }
 

extensions/devui/runtime/src/main/java/io/quarkus/devui/runtime/mcp/McpHttpHandler.java

@@ -12,6 +12,7 @@
 import io.quarkus.devui.runtime.jsonrpc.JsonRpcRequest;
 import io.quarkus.devui.runtime.jsonrpc.json.JsonMapper;
 import io.quarkus.devui.runtime.mcp.model.InitializeResponse;
+import io.quarkus.devui.runtime.spi.McpServerConfiguration;
 import io.vertx.core.Handler;
 import io.vertx.core.http.HttpMethod;
 import io.vertx.ext.web.RoutingContext;