use proxy function

This commit is contained in:
Ashwin Bhat
2024-10-10 09:13:19 -07:00
parent 4b82553046
commit df8051b975
2 changed files with 40 additions and 71 deletions

30
server/src/mcpProxy.ts Normal file
View File

@@ -0,0 +1,30 @@
import { Transport } from "mcp-typescript/shared/transport.js";
export default function mcpProxy({
transportToClient,
transportToServer,
onerror,
}: {
transportToClient: Transport;
transportToServer: Transport;
onerror: (error: Error) => void;
}) {
transportToClient.onmessage = (message) => {
transportToServer.send(message).catch(onerror);
};
transportToServer.onmessage = (message) => {
transportToClient.send(message).catch(onerror);
};
transportToClient.onclose = () => {
transportToServer.close().catch(onerror);
};
transportToServer.onclose = () => {
transportToClient.close().catch(onerror);
};
transportToClient.onerror = onerror;
transportToServer.onerror = onerror;
}