Class MCPConnection

Private_computeConnectionDelay

• _computeConnectionDelay(error: unknown, attempt: number): number

  Compute the delay before the next connection attempt. Respects Retry-After carried by MCPRateLimitError; otherwise uses exponential back-off (connectionRetryDelay * 2^(attempt - 1)).

  Parameters

  • error: unknown

    The error from the failed attempt

  • attempt: number

    Number of attempts made so far (1-indexed)

  Returns number

  Delay in milliseconds

Private_handleConnectionAttemptError

• _handleConnectionAttemptError(error: unknown): number

  Handle a single connection attempt error: re-throw immediately for non-retriable errors (e.g. session expiry), increment the attempt counter, and return the delay to wait before the next attempt. Throws when the maximum attempts have been exhausted.

  Parameters

  • error: unknown

    The error from the failed attempt

  Returns number

  Delay in milliseconds to wait before the next attempt

Private_validateGatewayResponseBody

• _validateGatewayResponseBody(contentType: string, body: string): void

  Validate a gateway response body, throwing on JSON-RPC errors.

  Parameters

  • contentType: string

    Response content-type header

  • body: string

    Raw response body text

  Returns void

Private_buildAuthorizationHeader

• _buildAuthorizationHeader(apiKey: string): string

  Build the Authorization header value for gateway requests. Keys that already contain a valid RFC 7235 scheme token followed by whitespace (e.g. "Bearer …", "Token …", "AWS4-HMAC-SHA256 …") are passed through unchanged. Otherwise the raw key is sent directly unless EP_MCP_GATEWAY_AUTH_SCHEME is set to a valid token, in which case that scheme prefix is prepended. The EP MCP gateway expects raw-token auth by default (no "Bearer " prefix).

  Parameters

  • apiKey: string

    Raw or pre-prefixed gateway API key

  Returns string

  The full Authorization header value, or empty string for empty keys

  Throws

  When the API key contains CR or LF characters (header injection risk)

Private_attemptGatewayConnection

• _attemptGatewayConnection(): Promise<void>

  Attempt a single connection via MCP Gateway (HTTP transport)

  Returns Promise<void>

Private_attemptConnection

• _attemptConnection(): Promise<void>

  Attempt a single connection via stdio (spawns server binary)

  Returns Promise<void>

Private_throwGatewayResponseError

• _throwGatewayResponseError(response: Response): never

  Throw an appropriate error for a non-OK gateway response. Extracted to keep _sendGatewayRequest within cognitive-complexity limits.

  Parameters

  • response: Response

    The non-OK fetch Response

  Returns never

Private_sendGatewayRequest

• _sendGatewayRequest(
      method: string,
      params?: Record<string, unknown>,
  ): Promise<unknown>

  Send a request via MCP Gateway (HTTP transport)

  Parameters

  • method: string

    RPC method name

  • params: Record<string, unknown> = {}

    Method parameters

  Returns Promise<unknown>

  Server response

Privatereconnect

• reconnect(): Promise<void>

  Attempt to reconnect to the MCP server with exponential back-off. Concurrent callers await the same in-flight reconnect instead of no-oping, ensuring the connection is re-established before all waiting callers continue.

  Returns Promise<void>

  Promise that resolves when reconnection succeeds or all attempts are exhausted

Private_doReconnect

• _doReconnect(): Promise<void>

  Internal reconnect helper.

  Waits for an exponential back-off delay derived from the current reconnectCount, then delegates to connect() which handles its own retry loop. This avoids composing N×N attempts.

  Returns Promise<void>

  Promise that resolves when reconnection succeeds or logs on failure

Private_handleRetryAttempt

• _handleRetryAttempt(
      lastError: Error,
      attempt: number,
      retries: number,
  ): Promise<void>

  Log a retry warning and, if disconnected, attempt to reconnect before waiting.

  Parameters

  • lastError: Error

    The error from the failed attempt

  • attempt: number

    Zero-based current attempt index

  • retries: number

    Total retry count

  Returns Promise<void>

  Promise that resolves after logging, optional reconnect, and inter-retry delay

PrivateserverPath

Privateconnected

Privateprocess

PrivaterequestId

PrivatependingRequests

PrivateconnectionAttempts

PrivatemaxConnectionAttempts

PrivateconnectionRetryDelay

PrivatemaxRetries

PrivatereconnectingPromise

PrivatetimeoutCount

PrivatereconnectCount

PrivategatewayUrl

PrivategatewayApiKey

PrivatemcpSessionId