useRawWhenLinear?: boolean;

/** Opt into transcript idempotency lookup; default append stays O(1) for fresh keyed messages. */

idempotencyLookup?: "scan" | "caller-checked";

/** Runs under the transcript write lock after idempotency replay checks and before append. */

prepareMessageAfterIdempotencyCheck?: (message: TMessage) => TMessage | undefined;

config?: OpenClawConfig;

};

);

}

export async function appendSessionTranscriptMessage<TMessage>(

params: AppendSessionTranscriptMessageParams<TMessage> & {

prepareMessageAfterIdempotencyCheck: (message: TMessage) => TMessage | undefined;

},

): Promise<AppendSessionTranscriptMessageResult<TMessage> | undefined>;

export async function appendSessionTranscriptMessage<TMessage>(

params: AppendSessionTranscriptMessageParams<TMessage>,

): Promise<AppendSessionTranscriptMessageResult<TMessage>>;

export async function appendSessionTranscriptMessage<TMessage>(

params: AppendSessionTranscriptMessageParams<TMessage>,

): Promise<AppendSessionTranscriptMessageResult<TMessage>> {

): Promise<AppendSessionTranscriptMessageResult<TMessage> | undefined> {

const activeLockRunner = resolveOwnedSessionTranscriptWriteLockRunner({

sessionFile: params.transcriptPath,

});

async function appendSessionTranscriptMessageLocked<TMessage>(

params: AppendSessionTranscriptMessageParams<TMessage>,

): Promise<AppendSessionTranscriptMessageResult<TMessage>> {

): Promise<AppendSessionTranscriptMessageResult<TMessage> | undefined> {

const now = params.now ?? Date.now();

await ensureTranscriptHeader(params.transcriptPath, {

...(params.sessionId ? { sessionId: params.sessionId } : {}),

return { ...existing, message: existing.message as TMessage, appended: false };

}

const message = params.prepareMessageAfterIdempotencyCheck

? params.prepareMessageAfterIdempotencyCheck(params.message)

: params.message;

if (message === undefined) {

return undefined;

}

const messageId = randomUUID();

const stat = await fs.stat(params.transcriptPath).catch(() => null);

let leafInfo: TranscriptLeafInfo = await readTranscriptLeafInfo(params.transcriptPath).catch(

};

}

const finalMessage = (

isTranscriptAgentMessage(params.message)

? redactTranscriptMessage(params.message, params.config)

: redactSecrets(params.message)

isTranscriptAgentMessage(message)

? redactTranscriptMessage(message, params.config)

: redactSecrets(message)

) as TMessage;

const entry = {

type: "message",