hzhang/inspector
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Clarify inspector-server error logging

Browse Source
This commit is contained in:
Justin Spahr-Summers
2025-01-23 17:19:39 +00:00
parent e7697eb5cd
commit 14db05c2a2
2 changed files with 14 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
server/src/index.ts
View File

@@ -125,9 +125,6 @@ app.get("/sse", async (req, res) => {
mcpProxy({ mcpProxy({
transportToClient: webAppTransport, transportToClient: webAppTransport,
transportToServer: backingServerTransport, transportToServer: backingServerTransport,
onerror: (error) => {
console.error(error);
},
}); });
console.log("Set up MCP proxy"); console.log("Set up MCP proxy");

23
server/src/mcpProxy.ts
View File

@@ -1,23 +1,29 @@
import { Transport } from "@modelcontextprotocol/sdk/shared/transport.js"; import { Transport } from "@modelcontextprotocol/sdk/shared/transport.js";
function onClientError(error: Error) {
console.error("Error from inspector client:", error);
}
function onServerError(error: Error) {
console.error("Error from MCP server:", error);
}
export default function mcpProxy({ export default function mcpProxy({
transportToClient, transportToClient,
transportToServer, transportToServer,
onerror,
}: { }: {
transportToClient: Transport; transportToClient: Transport;
transportToServer: Transport; transportToServer: Transport;
onerror: (error: Error) => void;
}) { }) {
let transportToClientClosed = false; let transportToClientClosed = false;
let transportToServerClosed = false; let transportToServerClosed = false;
transportToClient.onmessage = (message) => { transportToClient.onmessage = (message) => {
transportToServer.send(message).catch(onerror); transportToServer.send(message).catch(onServerError);
}; };
transportToServer.onmessage = (message) => { transportToServer.onmessage = (message) => {
transportToClient.send(message).catch(onerror); transportToClient.send(message).catch(onClientError);
}; };
transportToClient.onclose = () => { transportToClient.onclose = () => {
@@ -26,7 +32,7 @@ export default function mcpProxy({
} }
transportToClientClosed = true; transportToClientClosed = true;
transportToServer.close().catch(onerror); transportToServer.close().catch(onServerError);
}; };
transportToServer.onclose = () => { transportToServer.onclose = () => {
@@ -34,10 +40,9 @@ export default function mcpProxy({
return; return;
} }
transportToServerClosed = true; transportToServerClosed = true;
transportToClient.close().catch(onClientError);
transportToClient.close().catch(onerror);
}; };
transportToClient.onerror = onerror; transportToClient.onerror = onClientError;
transportToServer.onerror = onerror; transportToServer.onerror = onServerError;
} }