Replace SSEClientTransport with StreamableHTTPClientTransport in GitMcpRouter
This commit is contained in:
Vendored
+2
-2
@@ -1,5 +1,5 @@
|
|||||||
import { Client } from "@modelcontextprotocol/sdk/client/index.js";
|
import { Client } from "@modelcontextprotocol/sdk/client/index.js";
|
||||||
import { SSEClientTransport } from "@modelcontextprotocol/sdk/client/sse.js";
|
import { StreamableHTTPClientTransport } from "@modelcontextprotocol/sdk/client/streamableHttp.js";
|
||||||
import { Server } from "@modelcontextprotocol/sdk/server/index.js";
|
import { Server } from "@modelcontextprotocol/sdk/server/index.js";
|
||||||
import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
|
import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
|
||||||
import { ListToolsRequestSchema, CallToolRequestSchema, ListResourcesRequestSchema, ReadResourceRequestSchema } from "@modelcontextprotocol/sdk/types.js";
|
import { ListToolsRequestSchema, CallToolRequestSchema, ListResourcesRequestSchema, ReadResourceRequestSchema } from "@modelcontextprotocol/sdk/types.js";
|
||||||
@@ -200,7 +200,7 @@ class GitMcpRouter {
|
|||||||
}
|
}
|
||||||
catch { }
|
catch { }
|
||||||
}
|
}
|
||||||
const transport = new SSEClientTransport(new URL(gitMcpUrl));
|
const transport = new StreamableHTTPClientTransport(new URL(gitMcpUrl));
|
||||||
this.downstream = new Client({ name: "gitmcp-router-client", version: "0.1.0" });
|
this.downstream = new Client({ name: "gitmcp-router-client", version: "0.1.0" });
|
||||||
await this.downstream.connect(transport);
|
await this.downstream.connect(transport);
|
||||||
this.currentRepo = githubUrl;
|
this.currentRepo = githubUrl;
|
||||||
|
|||||||
+2
-2
@@ -1,5 +1,5 @@
|
|||||||
import { Client } from "@modelcontextprotocol/sdk/client/index.js";
|
import { Client } from "@modelcontextprotocol/sdk/client/index.js";
|
||||||
import { SSEClientTransport } from "@modelcontextprotocol/sdk/client/sse.js";
|
import { StreamableHTTPClientTransport } from "@modelcontextprotocol/sdk/client/streamableHttp.js";
|
||||||
import { Server } from "@modelcontextprotocol/sdk/server/index.js";
|
import { Server } from "@modelcontextprotocol/sdk/server/index.js";
|
||||||
import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
|
import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
|
||||||
import {
|
import {
|
||||||
@@ -234,7 +234,7 @@ class GitMcpRouter {
|
|||||||
try { await this.downstream.close(); } catch { }
|
try { await this.downstream.close(); } catch { }
|
||||||
}
|
}
|
||||||
|
|
||||||
const transport = new SSEClientTransport(new URL(gitMcpUrl));
|
const transport = new StreamableHTTPClientTransport(new URL(gitMcpUrl));
|
||||||
this.downstream = new Client({ name: "gitmcp-router-client", version: "0.1.0" });
|
this.downstream = new Client({ name: "gitmcp-router-client", version: "0.1.0" });
|
||||||
await this.downstream.connect(transport);
|
await this.downstream.connect(transport);
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user