feat(cli): update version and enhance server configuration with code execution support

Author: yaonyan

deno.lock

@@ -1,6 +1,6 @@
 {
   "name": "@mcpc/cli",
-  "version": "0.1.18",
+  "version": "0.1.19",
   "repository": {
     "type": "git",
     "url": "git+https://github.com/mcpc-tech/mcpc.git"
@@ -13,7 +13,7 @@
   },
   "imports": {
     "@mcpc-tech/plugin-code-execution": "npm:@mcpc-tech/plugin-code-execution@^0.0.6",
-    "@mcpc/core": "jsr:@mcpc/core@^0.3.6",
+    "@mcpc/core": "jsr:@mcpc/core@^0.3.7",
     "@mcpc/utils": "jsr:@mcpc/utils@^0.2.2",
     "@modelcontextprotocol/sdk": "npm:@modelcontextprotocol/sdk@^1.8.0",
     "@mcpc-tech/ripgrep-napi": "npm:@mcpc-tech/ripgrep-napi@^0.0.4",

packages/cli/deno.json

@@ -4,19 +4,23 @@ import { mcpc } from "@mcpc/core";
 import { createLargeResultPlugin } from "@mcpc/core/plugins/large-result";
 import type { ComposableMCPServer, ComposeDefinition } from "@mcpc/core";
 import type { MCPCConfig } from "./config/loader.ts";
+import { codeExecutionPlugin } from "@mcpc-tech/plugin-code-execution";
 
 export const createServer = async (
   config?: MCPCConfig,
 ): Promise<ComposableMCPServer> => {
   // Use provided config or fall back to default example config
   const serverConfig = config || {
-    name: "large-result-plugin-example",
+    name: "mcpc-server",
     version: "0.1.0",
     agents: [
       {
         name: null,
         description: "",
-        plugins: [createLargeResultPlugin({})],
+        plugins: [createLargeResultPlugin({}), codeExecutionPlugin()],
+        options: {
+          mode: "code_execution",
+        },
       },
     ] as ComposeDefinition[],
   };
@@ -39,11 +43,11 @@ export const createServer = async (
   );
 };
 
-export const createApp = (): OpenAPIHono => {
+export const createApp = (config?: MCPCConfig): OpenAPIHono => {
   const app = new OpenAPIHono();
 
-  // Register routes
-  registerAgent(app);
+  // Register routes with config
+  registerAgent(app, config);
 
   return app;
 };

packages/cli/src/app.ts

@@ -2,9 +2,12 @@ import type { OpenAPIHono } from "@hono/zod-openapi";
 import { messageHandler } from "./messages.controller.ts";
 import { sseHandler } from "./sse.controller.ts";
 import { coreHandler } from "./core.controller.ts";
+import { streamableHttpHandler } from "./streamable-http.controller.ts";
+import type { MCPCConfig } from "../config/loader.ts";
 
-export const registerAgent = (app: OpenAPIHono) => {
+export const registerAgent = (app: OpenAPIHono, config?: MCPCConfig) => {
   messageHandler(app);
   sseHandler(app);
   coreHandler(app);
+  streamableHttpHandler(app, config);
 };

packages/cli/src/controllers/register.ts

@@ -0,0 +1,79 @@
+import type { OpenAPIHono } from "@hono/zod-openapi";
+import { StreamableHTTPServerTransport } from "@modelcontextprotocol/sdk/server/streamableHttp.js";
+import { createServer } from "../app.ts";
+import { loadConfig } from "../config/loader.ts";
+import type { MCPCConfig } from "../config/loader.ts";
+
+export const streamableHttpHandler = (
+  app: OpenAPIHono,
+  providedConfig?: MCPCConfig,
+) => {
+  app.post("/mcp", async (c) => {
+    try {
+      // Use provided config or load from environment/file
+      const config = providedConfig || await loadConfig();
+      const server = await createServer(config ?? undefined);
+
+      const body = await c.req.json();
+
+      // Create a new transport for each request (stateless mode)
+      const transport = new StreamableHTTPServerTransport({
+        sessionIdGenerator: undefined,
+        enableJsonResponse: true,
+      });
+
+      // Handle cleanup on request close
+      c.req.raw.signal?.addEventListener("abort", () => {
+        transport.close();
+      });
+
+      // Connect server to transport
+      await server.connect(transport);
+
+      // Create adapter for Web API Request/Response
+      const request = c.req.raw;
+      const { writable } = new TransformStream();
+      const writer = writable.getWriter();
+
+      // Capture response
+      let captured: any = null;
+      const mockResponse = {
+        statusCode: 200,
+        setHeader: () => {},
+        writeHead: () => {},
+        write: (chunk: any) => {
+          try {
+            const text = typeof chunk === "string" ? chunk : chunk.toString();
+            captured = JSON.parse(text);
+          } catch {
+            // ignore parse errors
+          }
+        },
+        end: () => {
+          writer.close();
+        },
+      } as any;
+
+      // Handle the request through transport
+      await transport.handleRequest(request as any, mockResponse, body);
+
+      // Close transport after handling
+      transport.close();
+
+      // Return captured response
+      if (captured) {
+        return c.json(captured);
+      }
+
+      return c.json({ error: "No response captured" }, 500);
+    } catch (error) {
+      console.error("Streamable HTTP error:", error);
+      return c.json(
+        {
+          error: error instanceof Error ? error.message : String(error),
+        },
+        500,
+      );
+    }
+  });
+};

packages/cli/src/controllers/streamable-http.controller.ts

@@ -32,7 +32,7 @@ import { loadConfig } from "./config/loader.ts";
 import process from "node:process";
 import { createCodeExecutionPlugin } from "@mcpc-tech/plugin-code-execution";
 
-const port = Number(process.env.PORT || "9000");
+const port = Number(process.env.PORT || "3002");
 const hostname = "0.0.0.0";
 
 // Load configuration from environment or file
@@ -43,7 +43,13 @@ config?.agents.forEach((agent) => {
   if (agent.plugins?.length ?? 0 === 0) {
     agent.plugins = [];
   }
-  agent.plugins?.push(createCodeExecutionPlugin());
+  agent.plugins?.push(
+    createCodeExecutionPlugin({
+      sandbox: {
+        timeout: 300_000,
+      },
+    }),
+  );
 });
 
 if (config) {
@@ -54,7 +60,7 @@ if (config) {
 
 const app = new OpenAPIHono();
 
-app.route("core", createApp());
+app.route("mcp", createApp(config || undefined));
 
 Deno.serve(
   {