import type { CurrentTurnPromptContext } from "../../agents/pi-embedded-runner/run/params.js";

import type { InboundTurnKind } from "../../channels/turn/kind.js";

import { annotateInterSessionPromptText } from "../../sessions/input-provenance.js";

import { normalizeOptionalString } from "../../shared/string-coerce.js";

import { HEARTBEAT_TRANSCRIPT_PROMPT } from "../heartbeat.js";

import { buildInboundMediaNote } from "../media-note.js";

import type { MsgContext, TemplateContext } from "../templating.js";

import { appendUntrustedContext } from "./untrusted-context.js";

const REPLY_MEDIA_HINT =

"To send an image back, prefer the message tool (media/path/filePath). If you must inline, use MEDIA:https://example.com/image.jpg (spaces ok, quote if needed) or a safe relative path like MEDIA:./image.jpg. Absolute and ~ paths only work when they stay inside your allowed file-read boundary; host file:// URLs are blocked. Keep caption in the text body.";

const ROOM_EVENT_PROMPT = "[OpenClaw room event]";

const ROOM_EVENT_VISIBLE_REPLY_CONTRACT = "message_tool_only";

export function buildReplyPromptBodies(params: {

ctx: MsgContext;

? [mediaNote, mediaReplyHint, prefixedBody].filter(Boolean).join("\n").trim()

: prefixedBody;

const transcriptBody = params.transcriptBody ?? params.effectiveBaseBody;

const transcriptCommandBodyRaw = mediaNote

? [mediaNote, transcriptBody].filter(Boolean).join("\n").trim()

: transcriptBody;

const transcriptCommandBodyRaw = transcriptBody

? mediaNote

? [mediaNote, transcriptBody].filter(Boolean).join("\n").trim()

: transcriptBody

: "";

return {

mediaNote,

mediaReplyHint,

startupContextPrelude?: string | null;

softResetTail?: string;

isHeartbeat?: boolean;

turnKind?: InboundTurnKind;

};

function formatRoomEventLine(ctx: TemplateContext, body: string): string {

const messageId =

normalizeOptionalString(ctx.MessageSid) ?? normalizeOptionalString(ctx.MessageSidFull);

const sender =

normalizeOptionalString(ctx.SenderName) ??

normalizeOptionalString(ctx.SenderUsername) ??

normalizeOptionalString(ctx.SenderId);

const prefix = [messageId ? `#${messageId}` : undefined, sender].filter(Boolean).join(" ");

return prefix ? `${prefix}: ${body}` : body;

}

function buildRoomEventContext(params: ReplyPromptEnvelopeBaseParams): string {

const roomEventBody = params.hasUserBody

? params.baseBody.trim()

: "[User sent media without caption]";

return [

"[OpenClaw turn]",

"kind: room_event",

`visible_reply_contract: ${ROOM_EVENT_VISIBLE_REPLY_CONTRACT}`,

params.inboundUserContext.trim() ? `Room context:\n${params.inboundUserContext.trim()}` : "",

`Current event:\n${formatRoomEventLine(params.sessionCtx, roomEventBody)}`,

"Treat this as observed room activity. Decide whether to act.",

]

.filter(Boolean)

.join("\n\n");

}

export function buildReplyPromptEnvelopeBase(

params: ReplyPromptEnvelopeBaseParams,

): ReplyPromptEnvelopeBase {

const softResetTail = params.softResetTail?.trim() ?? "";

const isRoomEvent = params.turnKind === "room_event";

const roomEventContext = buildRoomEventContext(params);

const currentTurnContextText = isRoomEvent ? roomEventContext : params.inboundUserContext.trim();

const resetModelBody = params.isBareSessionReset

? [

params.inboundUserContext,

.filter(Boolean)

.join("\n\n")

: params.baseBody;

const effectiveBaseBody = params.hasUserBody

? resetModelBody

: "[User sent media without caption]";

const effectiveBaseBody = isRoomEvent

? ROOM_EVENT_PROMPT

: params.hasUserBody

? resetModelBody

: "[User sent media without caption]";

const transcriptBody = params.isHeartbeat

? HEARTBEAT_TRANSCRIPT_PROMPT

: params.isBareSessionReset

? softResetTail || `[OpenClaw session ${params.startupAction}]`

: params.hasUserBody

? params.baseBody

: "[User sent media without caption]";

: isRoomEvent

? ""

: params.hasUserBody

? params.baseBody

: "[User sent media without caption]";

const currentTurnContext: CurrentTurnPromptContext | undefined =

!params.isBareSessionReset && params.inboundUserContext.trim()

!params.isBareSessionReset && currentTurnContextText

? {

text: params.inboundUserContext,

text: currentTurnContextText,

promptJoiner: params.inboundUserContextPromptJoiner,

}

: undefined;