Function handleSend

ui/node-react/client/src/components/ChatView.js:98–208

()

  }

  const handleSend = async () => {
    const query = input.trim();
    if (!query || loading) return;

    setInput('');
    setLoading(true);
    setIsNewChat(false);
    setIsStreaming(true);
    setStreamingSteps([]);
    setStreamingContent('');

    // Add user message optimistically
    const userMsg = { role: 'user', content: query, offset: messageOffset };
    setMessages((prev) => [...prev, userMsg]);
    const currentOffset = messageOffset;
    setMessageOffset((prev) => prev + 1);

    // Accumulate tokens so we can fall back if onDone never fires
    let tokenAccumulator = '';
    let streamedDocuments = null;
    let doneHandled = false;
    let doneData = null;

    try {
      await sendMessageStream(
        sessionId,
        query,
        history,
        documents,
        selectedDatasets,
        currentOffset,
        {
          onStep: (step) => {
            setStreamingSteps((prev) => [...prev, step]);
          },
          onToken: (token) => {
            tokenAccumulator += token;
            setStreamingContent(tokenAccumulator);
          },
          onDocuments: (docs) => {
            streamedDocuments = docs;
          },
          onDone: (data) => {
            doneHandled = true;
            doneData = data;
          },
          onError: (error) => {
            setMessages((prev) => [
              ...prev,
              { role: 'assistant', content: `Something went wrong: ${error}` },
            ]);
            doneHandled = true; // prevent fallback from also adding a message
          },
        }
      );
    } catch (err) {
      setMessages((prev) => [
        ...prev,