resolveDefaultAgentId,

} from "../agents/agent-scope.js";

import { appendCronStyleCurrentTimeLine } from "../agents/current-time.js";

import { resolveEffectiveMessagesConfig } from "../agents/identity.js";

import { isNestedAgentLane } from "../agents/lanes.js";

import { resolveEmbeddedSessionLane } from "../agents/pi-embedded-runner/lanes.js";

import { DEFAULT_HEARTBEAT_FILENAME } from "../agents/workspace.js";

stripHeartbeatToken,

type HeartbeatTask,

} from "../auto-reply/heartbeat.js";

import { resolveResponsePrefixTemplate } from "../auto-reply/reply/response-prefix-template.js";

import { HEARTBEAT_TOKEN } from "../auto-reply/tokens.js";

import type { ReplyPayload } from "../auto-reply/types.js";

import { getChannelPlugin } from "../channels/plugins/index.js";

ChannelId,

ChannelPlugin,

} from "../channels/plugins/types.public.js";

import { createReplyPrefixContext } from "../channels/reply-prefix.js";

import {

listDueCommitmentsForSession,

listDueCommitmentSessionKeys,

})

: { showOk: false, showAlerts: true, useIndicator: true };

const { sender } = resolveHeartbeatSenderContext({ cfg, entry, delivery });

const responsePrefix = resolveEffectiveMessagesConfig(cfg, agentId, {

const replyPrefix = createReplyPrefixContext({

cfg,

agentId,

channel: delivery.channel !== "none" ? delivery.channel : undefined,

accountId: delivery.accountId,

}).responsePrefix;

});

const canRelayToUser = Boolean(

delivery.channel !== "none" && delivery.to && visibility.showAlerts,

nowMs: startedAt,

});

const heartbeatOkText = responsePrefix ? `${responsePrefix} ${HEARTBEAT_TOKEN}` : HEARTBEAT_TOKEN;

const resolveHeartbeatResponsePrefix = () =>

resolveResponsePrefixTemplate(

replyPrefix.responsePrefix,

replyPrefix.responsePrefixContextProvider(),

);

const resolveHeartbeatOkText = () => {

const responsePrefix = resolveHeartbeatResponsePrefix();

return responsePrefix ? `${responsePrefix} ${HEARTBEAT_TOKEN}` : HEARTBEAT_TOKEN;

};

const outboundSession = buildOutboundSessionContext({

cfg,

agentId,

to: delivery.to,

accountId: delivery.accountId,

threadId: delivery.threadId,

payloads: [{ text: heartbeatOkText }],

payloads: [{ text: resolveHeartbeatOkText() }],

session: outboundSession,

deps: opts.deps,

});

// Heartbeat timeout is a per-run override so user turns keep the global default.

timeoutOverrideSeconds,

bootstrapContextMode,

onModelSelected: replyPrefix.onModelSelected,

};

const getReplyFromConfig =

opts.deps?.getReplyFromConfig ?? (await loadHeartbeatRunnerRuntime()).getReplyFromConfig;

}

const ackMaxChars = resolveHeartbeatAckMaxChars(cfg, heartbeat);

const responsePrefix = resolveHeartbeatResponsePrefix();

const normalized = normalizeHeartbeatReply(replyPayload, responsePrefix, ackMaxChars);

// For exec completion events, don't skip even if the response looks like HEARTBEAT_OK.

// The model should be responding with exec results, not ack tokens.