Andreas/LibreChat
1
0
Fork 0
mirror of https://github.com/danny-avila/LibreChat.git synced 2025-12-17 00:40:14 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions 6

🛰️ fix: MCP SSE & Ping Error Handling (#10635)

Browse source 
Co-authored-by: Peter Rothlaender <peter.rothlaender@ginkgo.com>
This commit is contained in:
Peter 2025-11-24 19:57:29 +01:00 • committed by GitHub
parent 35319c1354
commit 3628619297
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 15 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

18
packages/api/src/mcp/connection.ts
View file

@ -595,17 +595,27 @@ export class MCPConnection extends EventEmitter {
private setupTransportErrorHandlers(transport: Transport): void { private setupTransportErrorHandlers(transport: Transport): void {
transport.onerror = (error) => { transport.onerror = (error) => {
logger.error(`${this.getLogPrefix()} Transport error:`, error);
// Check if it's an OAuth authentication error
if (error && typeof error === 'object' && 'code' in error) { if (error && typeof error === 'object' && 'code' in error) {
const errorCode = (error as unknown as { code?: number }).code; const errorCode = (error as unknown as { code?: number }).code;
// Ignore SSE 404 errors for servers that don't support SSE
if (
errorCode === 404 &&
String(error?.message).toLowerCase().includes('failed to open sse stream')
) {
logger.warn(`${this.getLogPrefix()} SSE stream not available (404). Ignoring.`);
return;
}
// Check if it's an OAuth authentication error
if (errorCode === 401 || errorCode === 403) { if (errorCode === 401 || errorCode === 403) {
logger.warn(`${this.getLogPrefix()} OAuth authentication error detected`); logger.warn(`${this.getLogPrefix()} OAuth authentication error detected`);
this.emit('oauthError', error); this.emit('oauthError', error);
} }
} }
logger.error(`${this.getLogPrefix()} Transport error:`, error);
this.emit('connectionChange', 'error'); this.emit('connectionChange', 'error');
}; };
} }
@ -678,7 +688,9 @@ export class MCPConnection extends EventEmitter {
const pingUnsupported = const pingUnsupported =
error instanceof Error && error instanceof Error &&
((error as Error)?.message.includes('-32601') || ((error as Error)?.message.includes('-32601') ||
(error as Error)?.message.includes('-32602') ||
(error as Error)?.message.includes('invalid method ping') || (error as Error)?.message.includes('invalid method ping') ||
(error as Error)?.message.includes('Unsupported method: ping') ||
(error as Error)?.message.includes('method not found')); (error as Error)?.message.includes('method not found'));
if (!pingUnsupported) { if (!pingUnsupported) {