save commit

Author: KKonstantinov

packages/client/src/client/sse.ts

@@ -114,7 +114,7 @@ export class SSEClientTransport implements Transport {
     }
 
     private async _commonHeaders(): Promise<Headers> {
-        const headers: Record<string, string> = {};
+        const headers: RequestInit['headers'] & Record<string, string> = {};
         if (this._authProvider) {
             const tokens = await this._authProvider.tokens();
             if (tokens) {

packages/client/src/client/streamableHttp.ts

@@ -187,7 +187,7 @@ export class StreamableHTTPClientTransport implements Transport {
     }
 
     private async _commonHeaders(): Promise<Headers> {
-        const headers: Record<string, string> = {};
+        const headers: RequestInit['headers'] & Record<string, string> = {};
         if (this._authProvider) {
             const tokens = await this._authProvider.tokens();
             if (tokens) {

packages/core/src/shared/transport.ts

@@ -1,13 +1,12 @@
 import { JSONRPCMessage, MessageExtraInfo, RequestId } from '../types/types.js';
-import type { HeadersInit } from 'undici-types';
 
 export type FetchLike = (url: string | URL, init?: RequestInit) => Promise<Response>;
 
 /**
  * Normalizes HeadersInit to a plain Record<string, string> for manipulation.
  * Handles Headers objects, arrays of tuples, and plain objects.
  */
-export function normalizeHeaders(headers: HeadersInit | undefined): Record<string, string> {
+export function normalizeHeaders(headers: RequestInit['headers'] | undefined): Record<string, string> {
     if (!headers) return {};
 
     if (headers instanceof Headers) {