feat: update version to 0.1.9; enhance test command permissions and refactor server creation logic

Author: yaonyan

packages/core/deno.json

@@ -1,10 +1,10 @@
 {
   "name": "@mcpc/core",
-  "version": "0.1.8",
+  "version": "0.1.9",
   "tasks": {
     "server:compile": "echo \"no need to compile\"",
-    "test": "deno test --allow-env --allow-read tests/",
-    "test:watch": "deno test --allow-env --allow-read --watch tests/"
+    "test": "deno test --allow-all tests/",
+    "test:watch": "deno test --allow-all --watch tests/"
   },
   "imports": {
     "@ai-sdk/openai": "npm:@ai-sdk/openai@^1.3.7",

packages/core/examples/01-basic-composition.ts

@@ -13,25 +13,11 @@
 import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
 import { mcpc } from "../mod.ts";
 
-export const server = await mcpc(
-  [
-    {
-      name: "basic-file-manager",
-      version: "1.0.0",
-    },
-    {
-      capabilities: {
-        tools: {
-          listChanged: true,
-        },
-      },
-    },
-  ],
-  [
-    {
-      name: "file-organizer",
-      description:
-        `I am a smart file organizer that helps users manage their files efficiently.
+export const toolDefinitions = [
+  {
+    name: "file-organizer",
+    description:
+      `I am a smart file organizer that helps users manage their files efficiently.
 
 Available tools:
 <tool name="@wonderwhy-er/desktop-commander.list_directory"/>
@@ -50,17 +36,33 @@ I can:
 
 I always ask for confirmation before making destructive changes and provide clear explanations of what I'm doing.`,
 
-      deps: {
-        mcpServers: {
-          "@wonderwhy-er/desktop-commander": {
-            command: "npx",
-            args: ["-y", "@wonderwhy-er/desktop-commander@latest"],
-            transportType: "stdio",
-          },
+    deps: {
+      mcpServers: {
+        "@wonderwhy-er/desktop-commander": {
+          command: "npx",
+          args: ["-y", "@wonderwhy-er/desktop-commander@latest"],
+          transportType: "stdio",
+        },
+      },
+    },
+  },
+];
+
+export const server = await mcpc(
+  [
+    {
+      name: "basic-file-manager",
+      version: "1.0.0",
+    },
+    {
+      capabilities: {
+        tools: {
+          listChanged: true,
         },
       },
     },
   ],
+  toolDefinitions,
 );
 
 const transport = new StdioServerTransport();

packages/core/src/app.ts

@@ -1,15 +1,19 @@
 import { OpenAPIHono } from "@hono/zod-openapi";
 import { registerAgent } from "./controllers/register.ts";
 import { mcpc } from "./set-up-mcp-compose.ts";
-import { toolDefinitions } from "../examples/sampling/01-basic-composition.ts";
+import { toolDefinitions } from "../examples/01-basic-composition.ts";
 
-export const server = await mcpc([
-  {
-    name: "capi-mcp",
-    version: "0.1.0",
-  },
-  { capabilities: { tools: {}, sampling: {} } },
-], toolDefinitions);
+export const createServer = async () =>
+  await mcpc(
+    [
+      {
+        name: "capi-mcp",
+        version: "0.1.0",
+      },
+      { capabilities: { tools: {}, sampling: {} } },
+    ],
+    toolDefinitions,
+  );
 
 export const createApp = () => {
   const app = new OpenAPIHono();

packages/core/src/controllers/sse.controller.ts

@@ -1,6 +1,6 @@
 import { createRoute, type OpenAPIHono, z } from "@hono/zod-openapi";
 import type { ErrorSchema as _ErrorSchema } from "../schemas/error.ts";
-import { server } from "../app.ts";
+import { createServer } from "../app.ts";
 import { INCOMING_MSG_ROUTE_PATH } from "../set-up-mcp-compose.ts";
 import { handleConnecting } from "../transport/sse.ts";
 
@@ -32,7 +32,7 @@ export const sseHandler = (app: OpenAPIHono) =>
     async (c) => {
       const response = await handleConnecting(
         c.req.raw,
-        server,
+        createServer,
         INCOMING_MSG_ROUTE_PATH,
       );
       return response;

packages/core/src/transport/sse.ts

@@ -22,9 +22,9 @@ import type { ComposableMCPServer } from "../../mod.ts";
  */
 const transports = new Map<string, SSEServerTransport>();
 
-export function handleConnecting(
+export async function handleConnecting(
   request: Request,
-  server: McpServer | ComposableMCPServer,
+  createServer: () => Promise<McpServer | ComposableMCPServer>,
   incomingMsgRoutePath: string,
 ): Promise<Response> {
   // Check if a session ID is provided in the request
@@ -48,6 +48,8 @@ export function handleConnecting(
     }
   }
 
+  const server = await createServer();
+
   // Create a new transport with the endpoint if no session ID was provided
   const transport = new SSEServerTransport(endpoint);
   const newSessionId = transport.sessionId;