Preserve chat-only SDK deltas

bitloi · bitloi · commit f9d6199f8506 · 2026-04-30T04:42:00.000+02:00
diff --git a/packages/sdk/src/client.ts b/packages/sdk/src/client.ts
@@ -333,15 +333,14 @@ export class OpenClaw {
   ): AsyncIterable<OpenClawEvent> {
     await this.connect();
     const replayEvents = this.replaySnapshot(runId);
-    let hasAssistantRunEvent = replayEvents.some(isAssistantRunEvent);
+    let hasCanonicalAssistantRunEvent = replayEvents.some(isAssistantRunEvent);
     let hasTerminalRunEvent = replayEvents.some(isTerminalRunEvent);
     const toRunStreamEvent = (event: OpenClawEvent): OpenClawEvent | undefined => {
       const chatProjection = readChatProjection(event);
       if (chatProjection?.state === "delta") {
-        if (hasAssistantRunEvent) {
+        if (hasCanonicalAssistantRunEvent) {
           return undefined;
         }
-        hasAssistantRunEvent = true;
         return normalizeChatProjectionEvent(event, chatProjection);
       }
       if (chatProjection?.state === "final") {
@@ -352,7 +351,7 @@ export class OpenClaw {
         return normalizeChatProjectionEvent(event, chatProjection);
       }
       if (isAssistantRunEvent(event)) {
-        hasAssistantRunEvent = true;
+        hasCanonicalAssistantRunEvent = true;
       }
       if (isTerminalRunEvent(event)) {
         hasTerminalRunEvent = true;
diff --git a/packages/sdk/src/index.test.ts b/packages/sdk/src/index.test.ts
@@ -485,20 +485,34 @@ describe("OpenClaw SDK", () => {
           payload: {
             runId: "run_chat_only",
             sessionKey: "chat-only",
-            state: "final",
+            state: "delta",
             message: {
               role: "assistant",
-              content: [{ type: "text", text: "hello" }],
+              content: [{ type: "text", text: "hello again" }],
               timestamp: ts + 1,
             },
           },
         });
         fake.emit({
-          event: "custom.debug",
+          event: "chat",
           seq: 3,
           payload: {
             runId: "run_chat_only",
-            ts: ts + 2,
+            sessionKey: "chat-only",
+            state: "final",
+            message: {
+              role: "assistant",
+              content: [{ type: "text", text: "hello again" }],
+              timestamp: ts + 2,
+            },
+          },
+        });
+        fake.emit({
+          event: "custom.debug",
+          seq: 4,
+          payload: {
+            runId: "run_chat_only",
+            ts: ts + 3,
             data: { ok: true },
           },
         });
@@ -527,10 +541,20 @@ describe("OpenClaw SDK", () => {
 
       const second = await iterator.next();
       expect(second).toMatchObject({
+        done: false,
+        value: {
+          type: "assistant.delta",
+          data: { delta: "hello again" },
+          raw: { event: "chat" },
+        },
+      });
+
+      const third = await iterator.next();
+      expect(third).toMatchObject({
         done: false,
         value: {
           type: "run.completed",
-          data: { phase: "end", outputText: "hello" },
+          data: { phase: "end", outputText: "hello again" },
           raw: { event: "chat" },
         },
       });
