import { resolveFastModeState } from "../../agents/fast-mode.js";

import { resolveAgentHarnessPolicy } from "../../agents/harness/selection.js";

import { listOpenAIAuthProfileProvidersForAgentRuntime } from "../../agents/openai-codex-routing.js";

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

import { resolveEmbeddedFullAccessState } from "../../agents/pi-embedded-runner/sandbox-info.js";

import type { EmbeddedFullAccessBlockedReason } from "../../agents/pi-embedded-runner/types.js";

import { resolveIngressWorkspaceOverrideForSpawnedRun } from "../../agents/spawned-context.js";

import { isReasoningTagProvider } from "../../utils/provider-utils.js";

import { hasControlCommand } from "../command-detection.js";

import { resolveEnvelopeFormatOptions } from "../envelope.js";

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

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

import {

type ElevatedLevel,

} from "./inbound-meta.js";

import type { createModelSelectionState } from "./model-selection.js";

import { resolveOriginMessageProvider } from "./origin-routing.js";

import { buildReplyPromptBodies } from "./prompt-prelude.js";

import { buildReplyPromptEnvelope, buildReplyPromptEnvelopeBase } from "./prompt-prelude.js";

import { resolveActiveRunQueueAction } from "./queue-policy.js";

import { resolveQueueSettings } from "./queue/settings-runtime.js";

import { isSteeringQueueMode } from "./queue/steering.js";

: { ...sessionCtx, ThreadStarterBody: undefined },

envelopeOptions,

);

const baseBodyForPrompt = isBareSessionReset

? [

inboundUserContext,

startupContextPrelude,

baseBodyFinal,

softResetTail

? `User note for this reset turn (treat as ordinary user input, not startup instructions):\n${softResetTail}`

: "",

]

.filter(Boolean)

.join("\n\n")

: baseBodyFinal;

const inboundUserContextPromptJoiner = resolveInboundUserContextPromptJoiner(sessionCtx);

const hasUserBody =

baseBodyFinal.trim().length > 0 ||

softResetTail.length > 0 ||

text: "I didn't receive any text in your message. Please resend or add a caption.",

};

}

// When the user sends media without text, provide a minimal body so the agent

// run proceeds and the image/document is injected by the embedded runner.

const effectiveBaseBody = hasUserBody ? baseBodyForPrompt : "[User sent media without caption]";

const transcriptBodyBase = isHeartbeat

? HEARTBEAT_TRANSCRIPT_PROMPT

: isBareSessionReset

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

: hasUserBody

? baseBodyFinal

: "[User sent media without caption]";

const promptEnvelopeBase = buildReplyPromptEnvelopeBase({

ctx,

sessionCtx,

baseBody: baseBodyFinal,

hasUserBody,

inboundUserContext,

inboundUserContextPromptJoiner,

isBareSessionReset,

startupAction,

startupContextPrelude,

softResetTail,

isHeartbeat,

});

const effectiveBaseBody = promptEnvelopeBase.effectiveBaseBody;

let prefixedBodyBase = await applySessionHints({

baseBody: effectiveBaseBody,

abortedLastRun,

prefixedCommandBody: string;

queuedBody: string;

transcriptCommandBody: string;

currentTurnContext?: typeof promptEnvelopeBase.currentTurnContext;

}> => {

if (!useFastReplyRuntime) {

const eventsBlock = await drainFormattedSystemEvents({

}

}

}

return buildReplyPromptBodies({

return buildReplyPromptEnvelope({

ctx,

sessionCtx,

effectiveBaseBody,

baseBody: baseBodyFinal,

prefixedBody: prefixedBodyCore,

transcriptBody: transcriptBodyBase,

hasUserBody,

inboundUserContext,

inboundUserContextPromptJoiner,

isBareSessionReset,

startupAction,

startupContextPrelude,

softResetTail,

isHeartbeat,

threadContextNote,

systemEventBlocks: drainedSystemEventBlocks,

});

sessionEntry = skillResult.sessionEntry ?? sessionEntry;

currentSystemSent = skillResult.systemSent;

const skillsSnapshot = skillResult.skillsSnapshot;

let { prefixedCommandBody, queuedBody, transcriptCommandBody } = await traceRunPhase(

"reply.build_prompt_bodies",

() => rebuildPromptBodies(),

);

const currentTurnContext: CurrentTurnPromptContext | undefined =

!isBareSessionReset && inboundUserContext.trim()

? {

text: inboundUserContext,

promptJoiner: resolveInboundUserContextPromptJoiner(sessionCtx),

}

: undefined;

let { prefixedCommandBody, queuedBody, transcriptCommandBody, currentTurnContext } =

await traceRunPhase("reply.build_prompt_bodies", () => rebuildPromptBodies());

if (!resolvedThinkLevel) {

resolvedThinkLevel = await modelState.resolveDefaultThinkingLevel();

}

isNewSession,

});

preparedSessionState = resolvePreparedSessionState();

({ prefixedCommandBody, queuedBody, transcriptCommandBody } = await traceRunPhase(

"reply.build_prompt_bodies",

() => rebuildPromptBodies(),

));

({ prefixedCommandBody, queuedBody, transcriptCommandBody, currentTurnContext } =

await traceRunPhase("reply.build_prompt_bodies", () => rebuildPromptBodies()));

},

resolveBusyState: resolveQueueBusyState,

});