Function useAssistantBootstrap

src/web-ui/src/app/hooks/useAssistantBootstrap.ts:22–206

()

}

export function useAssistantBootstrap() {
  const { t } = useI18n('notifications');
  const activeAttemptRef = useRef<ActiveBootstrapAttempt | null>(null);
  const pendingRequestRef = useRef<BootstrapRequest | null>(null);
  const latestWorkspacePathRef = useRef<string | null>(null);
  const inFlightWorkspacePathRef = useRef<string | null>(null);
  const blockedNoticeShownRef = useRef<Set<string>>(new Set());
  const requestBootstrapRef = useRef<(request: BootstrapRequest) => void>(() => {});

  const drainPendingRequest = useCallback(() => {
    const pending = pendingRequestRef.current;
    if (!pending) {
      return;
    }

    if (latestWorkspacePathRef.current !== pending.workspacePath) {
      pendingRequestRef.current = null;
      return;
    }

    pendingRequestRef.current = null;
    requestBootstrapRef.current(pending);
  }, []);

  const clearActiveAttempt = useCallback(
    (event: { sessionId?: string; turnId?: string }) => {
      const activeAttempt = activeAttemptRef.current;
      if (!activeAttempt) {
        return;
      }

      if (event.sessionId !== activeAttempt.sessionId || event.turnId !== activeAttempt.turnId) {
        return;
      }

      activeAttemptRef.current = null;
      drainPendingRequest();
    },
    [drainPendingRequest]
  );

  useEffect(() => {
    const unlistenCompleted = agentAPI.onDialogTurnCompleted(clearActiveAttempt);
    const unlistenFailed = agentAPI.onDialogTurnFailed(clearActiveAttempt);
    const unlistenCancelled = agentAPI.onDialogTurnCancelled(clearActiveAttempt);

    return () => {
      unlistenCompleted();
      unlistenFailed();
      unlistenCancelled();
    };
  }, [clearActiveAttempt]);

  const handleEnsureResponse = useCallback(
    (request: BootstrapRequest, response: EnsureAssistantBootstrapResponse): void => {
      switch (response.status) {
        case 'started':
          if (!response.turnId) {