chore: update version to 0.2.0-beta.5 and add optional headers support in transport configurations

Author: yaonyan

packages/core/deno.json

@@ -1,6 +1,6 @@
 {
   "name": "@mcpc/core",
-  "version": "0.2.0-beta.4",
+  "version": "0.2.0-beta.5",
   "exports": {
     ".": "./mod.ts",
     "./plugins": "./plugins.ts",

packages/core/src/service/tools.ts

@@ -14,11 +14,13 @@ export const SseConfigSchema: z.ZodObject<Record<string, z.ZodTypeAny>> =
   BaseConfigSchema.extend({
     url: z.string().url(),
     transportType: z.literal("sse").optional(),
+    headers: z.record(z.string()).optional(),
   });
 
 export const StreamableHTTPSchema: z.ZodObject<Record<string, z.ZodTypeAny>> =
   BaseConfigSchema.extend({
     url: z.string().url(),
+    headers: z.record(z.string()).optional(),
   });
 
 export const StdioConfigSchema: z.ZodObject<Record<string, z.ZodTypeAny>> =

packages/core/src/utils/common/mcp.ts

@@ -57,9 +57,21 @@ async function getOrCreateMcpClient(
     typeof (def as any).transportType === "string" &&
     (def as any).transportType === "sse"
   ) {
-    transport = new SSEClientTransport(new URL((def as any).url));
+    const options: any = {};
+    if ((def as any).headers) {
+      options.requestInit = { headers: (def as any).headers };
+      options.eventSourceInit = { headers: (def as any).headers };
+    }
+    transport = new SSEClientTransport(new URL((def as any).url), options);
   } else if ("url" in (def as any) && typeof (def as any).url === "string") {
-    transport = new StreamableHTTPClientTransport(new URL((def as any).url));
+    const options: any = {};
+    if ((def as any).headers) {
+      options.requestInit = { headers: (def as any).headers };
+    }
+    transport = new StreamableHTTPClientTransport(
+      new URL((def as any).url),
+      options,
+    );
   } else if (
     (typeof (def as any).transportType === "string" &&
       (def as any).transportType === "stdio") ||