Function useConnection

client/src/lib/hooks/useConnection.ts:107–1226

({
  transportType,
  command,
  args,
  sseUrl,
  env,
  customHeaders,
  oauthClientId,
  oauthClientSecret,
  oauthScope,
  config,
  connectionType = "proxy",
  onNotification,
  onPendingRequest,
  onElicitationRequest,
  getRoots,
  defaultLoggingLevel,
  metadata = {},
}: UseConnectionOptions)

}

export function useConnection({
  transportType,
  command,
  args,
  sseUrl,
  env,
  customHeaders,
  oauthClientId,
  oauthClientSecret,
  oauthScope,
  config,
  connectionType = "proxy",
  onNotification,
  onPendingRequest,
  onElicitationRequest,
  getRoots,
  defaultLoggingLevel,
  metadata = {},
}: UseConnectionOptions) {
  const [connectionStatus, setConnectionStatus] =
    useState<ConnectionStatus>("disconnected");
  const { toast } = useToast();
  const [serverCapabilities, setServerCapabilities] =
    useState<ServerCapabilities | null>(null);
  const [mcpClient, setMcpClient] = useState<Client | null>(null);
  const [clientTransport, setClientTransport] = useState<Transport | null>(
    null,
  );
  const [requestHistory, setRequestHistory] = useState<
    { request: string; response?: string }[]
  >([]);
  const [completionsSupported, setCompletionsSupported] = useState(false);
  const [mcpSessionId, setMcpSessionId] = useState<string | null>(null);
  const [mcpProtocolVersion, setMcpProtocolVersion] = useState<string | null>(
    null,
  );
  const [serverImplementation, setServerImplementation] =
    useState<Implementation | null>(null);

  type ReceiverTaskRecord = {
    task: Task;
    payloadPromise: Promise<ClientResult>;
    resolvePayload: (payload: ClientResult) => void;
    rejectPayload: (reason?: unknown) => void;
    cleanupTimeoutId?: ReturnType<typeof setTimeout>;
  };

  // Tasks created locally in response to *incoming* task-augmented requests
  // (e.g. `sampling/createMessage` and `elicitation/create` with `params.task`).
  const receiverTasksRef = useRef<Map<string, ReceiverTaskRecord>>(new Map());

  useEffect(() => {
    if (!oauthClientId) {
      clearClientInformationFromSessionStorage({
        serverUrl: sseUrl,
        isPreregistered: true,
      });
      return;