Function useChatStream

frontend/src/hooks/useChatStream.ts:23–179

({
  chatId,
  input,
  setInput,
  setMessages,
  setThinkingProcess,
  selectedModel,
  setIsTPUpdating,
}: UseChatStreamProps)

export const useChatStream = ({
  chatId,
  input,
  setInput,
  setMessages,
  selectedModel,
}: UseChatStreamProps) => {
  const [loadingSubmit, setLoadingSubmit] = useState(false);
  /** What the agent is doing right now, surfaced while the turn streams. */
  const [activity, setActivity] = useState<{
    tool?: string;
    file?: string;
  } | null>(null);
  /** What the last turn's page got wrong. Replaced per turn, not appended:
   *  the agent may well have fixed the previous set, and a stale finding is
   *  worse than none. */
  const [lint, setLint] = useState<LintFinding[]>([]);
  // A restyle rewrites the page, so the findings on screen are about a page
  // the user is no longer looking at. Both restyle paths announce; this is the
  // only place the list lives.
  useEffect(() => {
    const clear = () => setLint([]);
    window.addEventListener(PROJECT_RESTYLED, clear);
    return () => window.removeEventListener(PROJECT_RESTYLED, clear);
  }, []);
  const abortRef = useRef<AbortController | null>(null);
  /** Attachments for the turn being submitted. A ref because the first turn of
   *  a new chat is dispatched from createChat's onCompleted, outside the
   *  handleSubmit closure. */
  const pendingImagesRef = useRef<string[] | undefined>(undefined);
  const [currentChatId, setCurrentChatId] = useState<string>(chatId);
  const { token } = useAuthContext();
  const { curProject, refreshProjects, setFilePath, editorRef, turnFinished } =
    useContext(ProjectContext);
  const [curProjectPath, setCurProjectPath] = useState('');

  useEffect(() => {
    if (curProject) {
      setCurProjectPath(curProject.projectPath);
    }
  }, [curProject]);

  useEffect(() => {
    const updateChatId = () => {
      setCurrentChatId('');
      setMessages([]); // Clear messages for new chat
    };

    // Only add event listener when we want to create a new chat
    if (!chatId) {
      window.addEventListener('newchat', updateChatId);
    }

    // Cleanup
    return () => {
      window.removeEventListener('newchat', updateChatId);
    };
  }, [chatId, setMessages]);

  // Update currentChatId when chatId prop changes