? (internalOpts?.queuedFollowupAbortSignal ?? opts?.abortSignal)

: undefined;

const userTurnMediaForPersistence = buildPersistedUserTurnMediaInputsFromFields(ctx);

const inputProvenance = ctx.InputProvenance ?? sessionCtx.InputProvenance;

const userTurnTranscriptText = resolvePersistedUserTurnText(transcriptBody, {

hasMedia: userTurnMediaForPersistence.length > 0,

});

const userTurnInput =

userTurnTranscriptText !== undefined || userTurnMediaForPersistence.length > 0

? {

text: userTurnTranscriptText,

...(inputProvenance ? { provenance: inputProvenance } : {}),

...(userTurnMediaForPersistence.length > 0

? {

media: userTurnMediaForPersistence,

timeoutMs,

blockReplyBreak: resolvedBlockStreamingBreak,

ownerNumbers: command.ownerList.length > 0 ? command.ownerList : undefined,

inputProvenance: ctx.InputProvenance ?? sessionCtx.InputProvenance,

inputProvenance,

extraSystemPrompt: extraSystemPromptParts.join("\n\n") || undefined,

sourceReplyDeliveryMode: isRoomEvent ? "message_tool_only" : opts?.sourceReplyDeliveryMode,

silentReplyPromptMode,

text: rawMessage,

timestamp: now,

idempotencyKey: `${clientRunId}:user`,

...(systemInputProvenance ? { provenance: systemInputProvenance } : {}),

};

const userTurnInputPromise: Promise<UserTurnInput> = userTurnMediaPromise.then((media) => ({

...baseUserTurnInput,

text: "What is in this image?",

media: [{ path: "/tmp/image.png", contentType: "image/png" }],

timestamp: 123,

provenance: {

kind: "inter_session",

sourceSessionKey: "source-main",

sourceTool: "sessions_send",

},

},

updateMode: "none",

});

role: "user",

content: "What is in this image?",

MediaPath: "/tmp/image.png",

provenance: {

kind: "inter_session",

sourceSessionKey: "source-main",

sourceTool: "sessions_send",

},

MediaType: "image/png",

}),

]);

import type { AgentMessage } from "@earendil-works/pi-agent-core";

import { appendSessionTranscriptMessage } from "../config/sessions/transcript-append.js";

import { mimeTypeFromFilePath } from "../media/mime.js";

import { applyInputProvenanceToUserMessage, type InputProvenance } from "./input-provenance.js";

import { emitSessionTranscriptUpdate } from "./transcript-events.js";

type TranscriptAppendConfig = Parameters<typeof appendSessionTranscriptMessage>[0]["config"];

media?: readonly PersistedUserTurnMediaInput[] | null;

timestamp?: number;

idempotencyKey?: string;

provenance?: InputProvenance;

mediaOnlyText?: string;

};

const hasMedia = Boolean(mediaFields.MediaPath);

const text = normalizeTranscriptText(params.text);

const content = text || (hasMedia ? (params.mediaOnlyText ?? "") : "");

return {

const message = {

role: "user",

content,

timestamp: params.timestamp ?? Date.now(),

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

...mediaFields,

} as PersistedUserTurnMessage;

return applyInputProvenanceToUserMessage(message, params.provenance) as PersistedUserTurnMessage;

}

function resolvePersistedUserTurnMessage(