fix: publish transcript turn owned entries

jalehman · jalehman · commit 24a00380ff1f · 2026-06-16T13:10:41.000-07:00
diff --git a/src/config/sessions/session-accessor.test.ts b/src/config/sessions/session-accessor.test.ts
@@ -764,14 +764,17 @@ describe("session accessor file-backed seam", () => {
       storePath,
     };
     const publishOptions: Array<boolean | undefined> = [];
+    const publishedEntryBatches: unknown[][] = [];
 
     await withOwnedSessionTranscriptWrites(
       {
         sessionFile: transcriptPath,
         sessionKey: scope.sessionKey,
         withSessionWriteLock: async (run, options) => {
           publishOptions.push(options?.publishOwnedWrite);
-          return await run();
+          const result = await run();
+          publishedEntryBatches.push([...(options?.resolvePublishedEntries?.(result) ?? [])]);
+          return result;
         },
       },
       async () =>
@@ -793,6 +796,11 @@ describe("session accessor file-backed seam", () => {
     );
 
     expect(publishOptions).toEqual([true]);
+    expect(publishedEntryBatches).toHaveLength(1);
+    expect(publishedEntryBatches[0]).toEqual([
+      expect.objectContaining({ kind: "header" }),
+      expect.objectContaining({ kind: "id" }),
+    ]);
     await expect(loadTranscriptEvents(scope)).resolves.toEqual([
       expect.objectContaining({ type: "session" }),
       expect.objectContaining({
diff --git a/src/config/sessions/session-accessor.ts b/src/config/sessions/session-accessor.ts
@@ -42,6 +42,7 @@ import {
 import { resolveSessionTranscriptFile } from "./transcript-file-resolve.js";
 import { streamSessionTranscriptLines } from "./transcript-stream.js";
 import {
+  type OwnedSessionTranscriptPublishedEntry,
   resolveOwnedSessionTranscriptWriteLockRunner,
   withOwnedSessionTranscriptWrites,
 } from "./transcript-write-context.js";
@@ -511,6 +512,7 @@ async function appendTranscriptTurnMessages(
   options: SessionTranscriptTurnPersistOptions,
 ): Promise<TranscriptMessageAppendResult<unknown>[]> {
   const appendedMessages: TranscriptMessageAppendResult<unknown>[] = [];
+  const publishedEntries: OwnedSessionTranscriptPublishedEntry[] = [];
   const appendMessages = async (appendMessage: SessionTranscriptTurnAppendRunner) => {
     for (const append of options.messages) {
       const shouldAppend = append.shouldAppend
@@ -535,12 +537,18 @@ async function appendTranscriptTurnMessages(
         ...(append.prepareMessageAfterIdempotencyCheck
           ? { prepareMessageAfterIdempotencyCheck: append.prepareMessageAfterIdempotencyCheck }
           : {}),
+        onHeaderCreated: (header) => {
+          publishedEntries.push({ kind: "header", serialized: header });
+        },
         ...(append.useRawWhenLinear !== undefined
           ? { useRawWhenLinear: append.useRawWhenLinear }
           : {}),
       });
       if (result) {
         appendedMessages.push(result);
+        if (result.appended) {
+          publishedEntries.push({ kind: "id", id: result.messageId });
+        }
       }
     }
   };
@@ -560,7 +568,11 @@ async function appendTranscriptTurnMessages(
   if (activeLockRunner) {
     await activeLockRunner(
       () => withSessionTranscriptAppendQueue(target.sessionFile, runBatchWithOwnedLock),
-      { publishOwnedWrite: true },
+      {
+        publishOwnedWrite: true,
+        resolvePublishedEntries: () => publishedEntries,
+        resolvePublishedEntriesAfterFailure: () => publishedEntries,
+      },
     );
   } else {
     await withSessionTranscriptAppendQueue(target.sessionFile, async () => {
diff --git a/src/config/sessions/transcript-append.ts b/src/config/sessions/transcript-append.ts
@@ -375,6 +375,8 @@ export type AppendSessionTranscriptMessageParams<TMessage = unknown> = {
   /** Runs under the transcript write lock after idempotency replay checks and before append. */
   prepareMessageAfterIdempotencyCheck?: (message: TMessage) => TMessage | undefined;
   config?: OpenClawConfig;
+  /** Internal owned-batch hook for publishing a newly created transcript header. */
+  onHeaderCreated?: (serializedHeader: string) => void;
 };
 
 export type AppendSessionTranscriptMessageResult<TMessage> = {
@@ -521,9 +523,7 @@ async function appendSessionTranscriptEventLocked(
 }
 
 async function appendSessionTranscriptMessageLocked<TMessage>(
-  params: AppendSessionTranscriptMessageParams<TMessage> & {
-    onHeaderCreated?: (serializedHeader: string) => void;
-  },
+  params: AppendSessionTranscriptMessageParams<TMessage>,
 ): Promise<AppendSessionTranscriptMessageResult<TMessage> | undefined> {
   const now = params.now ?? Date.now();
   const serializedHeader = await ensureTranscriptHeader(params.transcriptPath, {
