fix: request message chunks for reasoning stream

backend/tests/test_serialization.py

@@ -123,6 +123,25 @@ def test_serialize_messages_tuple():
     assert result == [{"key": "v2"}, {"langgraph_node": "agent"}]
 
 
+def test_serialize_messages_tuple_preserves_reasoning_only_chunk():
+    from langchain_core.messages import AIMessageChunk
+
+    from deerflow.runtime.serialization import serialize_messages_tuple
+
+    chunk = AIMessageChunk(
+        content="",
+        id="run-1",
+        additional_kwargs={"reasoning_content": "Thinking through the task."},
+    )
+    metadata = {"langgraph_node": "agent"}
+
+    result = serialize_messages_tuple((chunk, metadata))
+
+    assert result[0]["content"] == ""
+    assert result[0]["additional_kwargs"]["reasoning_content"] == "Thinking through the task."
+    assert result[1] == metadata
+
+
 def test_serialize_messages_tuple_non_dict_metadata():
     from deerflow.runtime.serialization import serialize_messages_tuple
 

frontend/src/core/threads/hooks.ts

@@ -305,7 +305,7 @@
     prevHumanMsgCountRef.current = thread.messages.filter(
       (m) => m.type === "human",
     ).length;
   }, [threadId]);
 
   // Clear optimistic when server messages arrive.
   // For messages with a human optimistic message, wait until the server's
@@ -325,7 +325,7 @@
     if (!hasHumanOptimistic || newHumanMsgArrived) {
       setOptimisticMessages([]);
     }
   }, [thread.messages.length, optimisticMessages.length]);
 
   const sendMessage = useCallback(
     async (
@@ -484,6 +484,7 @@
           },
           {
             threadId: threadId,
+            streamMode: ["messages-tuple", "values"],
             streamSubgraphs: true,
             streamResumable: true,
             config: {

frontend/tests/unit/core/messages/utils.test.ts

@@ -2,8 +2,10 @@ import type { Message } from "@langchain/langgraph-sdk";
 import { expect, test } from "vitest";
 
 import {
+  extractReasoningContentFromMessage,
   getAssistantTurnUsageMessages,
   getMessageGroups,
+  hasReasoning,
 } from "@/core/messages/utils";
 
 test("aggregates token usage messages once per assistant turn", () => {
@@ -63,3 +65,26 @@ test("aggregates token usage messages once per assistant turn", () => {
     ),
   ).toEqual([null, null, ["ai-1", "ai-2"], null, ["ai-3"]]);
 });
+
+test("recognizes reasoning-only AI messages", () => {
+  const message = {
+    id: "reasoning-1",
+    type: "ai",
+    content: "",
+    additional_kwargs: {
+      reasoning_content: "I need to compare the options first.",
+    },
+  } as Message;
+
+  expect(hasReasoning(message)).toBe(true);
+  expect(extractReasoningContentFromMessage(message)).toBe(
+    "I need to compare the options first.",
+  );
+  expect(getMessageGroups([message])).toEqual([
+    {
+      id: "reasoning-1",
+      type: "assistant:processing",
+      messages: [message],
+    },
+  ]);
+});