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

Use new SseError class from SDK

Browse Source
This commit is contained in:
Justin Spahr-Summers
2025-01-24 11:27:40 +00:00
parent 8bb5308797
commit 8a20f7711a
2 changed files with 2 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
server/src/errors.ts
View File

@@ -1,11 +0,0 @@
export interface SseError extends Error {
code: number;
}
export function isSseError(error: unknown): error is SseError {
if (!(error instanceof Error)) {
return false;
}
return "code" in error && typeof error.code === "number";
}

5
server/src/index.ts
View File

@@ -4,7 +4,7 @@ import cors from "cors";
import { parseArgs } from "node:util"; import { parseArgs } from "node:util";
import { parse as shellParseArgs } from "shell-quote"; import { parse as shellParseArgs } from "shell-quote";
import { SSEClientTransport } from "@modelcontextprotocol/sdk/client/sse.js"; import { SSEClientTransport, SseError } from "@modelcontextprotocol/sdk/client/sse.js";
import { import {
StdioClientTransport, StdioClientTransport,
getDefaultEnvironment, getDefaultEnvironment,
@@ -12,7 +12,6 @@ import {
import { SSEServerTransport } from "@modelcontextprotocol/sdk/server/sse.js"; import { SSEServerTransport } from "@modelcontextprotocol/sdk/server/sse.js";
import express from "express"; import express from "express";
import { findActualExecutable } from "spawn-rx"; import { findActualExecutable } from "spawn-rx";
import { isSseError } from "./errors.js";
import mcpProxy from "./mcpProxy.js"; import mcpProxy from "./mcpProxy.js";
const SSE_HEADERS_PASSTHROUGH = ['Authorization']; const SSE_HEADERS_PASSTHROUGH = ['Authorization'];
@@ -103,7 +102,7 @@ app.get("/sse", async (req, res) => {
try { try {
backingServerTransport = await createTransport(req); backingServerTransport = await createTransport(req);
} catch (error) { } catch (error) {
if (isSseError(error) && error.code === 401) { if (error instanceof SseError && error.code === 401) {
console.error("Received 401 Unauthorized from MCP server:", error.message); console.error("Received 401 Unauthorized from MCP server:", error.message);
res.status(401).json(error); res.status(401).json(error);
return; return;