Function connectionFailure

packages/plugins/mcp/src/sdk/connection.ts:181–198

(
  transport: string,
  message: string,
  cause: unknown,
)

});

const connectionFailure = (
  transport: string,
  message: string,
  cause: unknown,
): McpConnectionError | McpOAuthReauthorizationRequired => {
  if (Predicate.isTagged(cause, "McpOAuthReauthorizationRequired")) {
    return new McpOAuthReauthorizationRequired({ message: "MCP OAuth re-authorization required" });
  }
  // Carry the handshake HTTP status structurally (and in the message for
  // humans) so the liveness health check can classify a rejected credential
  // as expired rather than a generic connection failure.
  const status = httpStatusFromCause(cause);
  return new McpConnectionError({
    transport,
    message: status === undefined ? message : `${message} (HTTP ${status})`,
    ...(status === undefined ? {} : { httpStatus: status }),
  });
};

const connectClient = (input: {
  transport: string;