modelcontextprotocol/inspector
Watch
1
0
Fork
You've already forked inspector
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 4

fix auth conect

Browse source
This commit is contained in:
ihrpr 2025-05-19 18:29:42 +01:00
commit 13eb077329
No known key found for this signature in database
2 changed files with 37 additions and 23 deletions
Download patch file Download diff file Expand all files Collapse all files

1
client/src/App.tsx
View file

@ -234,7 +234,6 @@ const App = () => {
const onOAuthConnect = useCallback(
(serverUrl: string) => {
setSseUrl(serverUrl);
setTransportType("sse");
setIsAuthDebuggerVisible(false);
void connectMcpServer();
},

33
client/src/lib/hooks/useConnection.ts
View file

@ -250,8 +250,12 @@ export function useConnection({
};
const handleAuthError = async (error: unknown) => {
if (error instanceof SseError && error.code === 401) {
// Create a new auth provider with the current server URL
const is401Error =
(error instanceof SseError && error.code === 401) ||
(error instanceof Error && error.message.includes('401')) ||
(error instanceof Error && error.message.includes('Unauthorized'));
if (is401Error) {
const serverAuthProvider = new InspectorOAuthClientProvider(sseUrl);
const result = await auth(serverAuthProvider, { serverUrl: sseUrl });
@ -330,7 +334,6 @@ export function useConnection({
mcpProxyServerUrl = new URL(`${getMCPProxyAddress(config)}/sse`);
mcpProxyServerUrl.searchParams.append("url", sseUrl);
transportOptions = {
authProvider: serverAuthProvider,
eventSourceInit: {
fetch: (
url: string | URL | globalThis.Request,
@ -347,7 +350,6 @@ export function useConnection({
mcpProxyServerUrl = new URL(`${getMCPProxyAddress(config)}/mcp`);
mcpProxyServerUrl.searchParams.append("url", sseUrl);
transportOptions = {
authProvider: serverAuthProvider,
eventSourceInit: {
fetch: (
url: string | URL | globalThis.Request,
@ -375,9 +377,9 @@ export function useConnection({
const clientTransport =
transportType === "streamable-http"
? new StreamableHTTPClientTransport(mcpProxyServerUrl as URL, {
sessionId: undefined,
...transportOptions,
})
sessionId: undefined,
...transportOptions,
})
: new SSEClientTransport(mcpProxyServerUrl as URL, transportOptions);
if (onNotification) {
@ -425,12 +427,19 @@ export function useConnection({
`Failed to connect to MCP Server via the MCP Inspector Proxy: ${mcpProxyServerUrl}:`,
error,
);
const shouldRetry = await handleAuthError(error);
if (shouldRetry) {
return connect(undefined, retryCount + 1);
}
if (error instanceof SseError && error.code === 401) {
// Check for auth-related errors
const is401Error =
(error instanceof SseError && error.code === 401) ||
(error instanceof Error && error.message.includes('401')) ||
(error instanceof Error && error.message.includes('Unauthorized'));
if (is401Error) {
console.log("Detected 401 error, attempting OAuth flow");
const shouldRetry = await handleAuthError(error);
if (shouldRetry) {
return connect(undefined, retryCount + 1);
}
// Don't set error state if we're about to redirect for auth
return;
}