Merge pull request #16 from metatool-ai/oauth

OAuth

Author: zhjch05

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@metamcp/mcp-server-metamcp",
-  "version": "0.4.5",
+  "version": "0.4.6",
   "description": "MCP Server MetaMCP manages all your other MCPs in one MCP.",
   "scripts": {
     "build": "tsc && shx chmod +x dist/*.js",

package.json

@@ -30,7 +30,22 @@ export const createMetaMcpClient = (
     };
     transport = new StdioClientTransport(stdioParams);
   } else if (serverParams.type === "SSE" && serverParams.url) {
-    transport = new SSEClientTransport(new URL(serverParams.url));
+    if (!serverParams.oauth_tokens) {
+      transport = new SSEClientTransport(new URL(serverParams.url));
+    } else {
+      const headers: HeadersInit = {};
+      headers[
+        "Authorization"
+      ] = `Bearer ${serverParams.oauth_tokens.access_token}`;
+      transport = new SSEClientTransport(new URL(serverParams.url), {
+        requestInit: {
+          headers,
+        },
+        eventSourceInit: {
+          fetch: (url, init) => fetch(url, { ...init, headers }),
+        },
+      });
+    }
   } else {
     console.error(`Unsupported server type: ${serverParams.type}`);
     return { client: undefined, transport: undefined };
@@ -39,7 +54,7 @@ export const createMetaMcpClient = (
   const client = new Client(
     {
       name: "MetaMCP",
-      version: "0.4.5",
+      version: "0.4.6",
     },
     {
       capabilities: {

src/client.ts

@@ -18,6 +18,13 @@ export interface ServerParameters {
   created_at: string;
   profile_uuid: string;
   status: string;
+  oauth_tokens?: {
+    access_token: string;
+    token_type: string;
+    expires_in?: number | undefined;
+    scope?: string | undefined;
+    refresh_token?: string | undefined;
+  } | null;
 }
 
 let _mcpServersCache: Record<string, ServerParameters> | null = null;

src/fetch-metamcp.ts

@@ -40,7 +40,7 @@ export const createServer = async () => {
   const server = new Server(
     {
       name: "MetaMCP",
-      version: "0.4.5",
+      version: "0.4.6",
     },
     {
       capabilities: {