diff --git a/src/lib/utils.ts b/src/lib/utils.ts index 30688af..b53d3b0 100644 --- a/src/lib/utils.ts +++ b/src/lib/utils.ts @@ -82,7 +82,25 @@ export async function connectToRemoteServer( ): Promise { log(`[${pid}] Connecting to remote server: ${serverUrl}`) const url = new URL(serverUrl) - const transport = new SSEClientTransport(url, { authProvider, requestInit: { headers } }) + + // Create transport with eventSourceInit to pass Authorization header if present + const eventSourceInit = { + fetch: (url: string | URL, init: RequestInit | undefined) => { + return fetch(url, { + ...init, + headers: { + ...init?.headers, + ...headers, + }, + }) + }, + } + + const transport = new SSEClientTransport(url, { + authProvider, + requestInit: { headers }, + eventSourceInit, + }) try { await transport.start()