abortSignal: params.replyOperation?.abortSignal ?? params.opts?.abortSignal,

replyOperation: params.replyOperation,

});

const result = isRoomEventCliTurn

? {

...rawResult,

meta: {

...rawResult.meta,

agentMeta: {

...rawResult.meta?.agentMeta,

sessionId: "",

cliSessionBinding: undefined,

},

},

}

: rawResult;

const result: EmbeddedAgentRunResult =

isRoomEventCliTurn && rawResult.meta.agentMeta

? (() => {

const { cliSessionBinding: _cliSessionBinding, ...agentMeta } =

rawResult.meta.agentMeta;

return {

...rawResult,

meta: {

...rawResult.meta,

agentMeta: {

...agentMeta,

sessionId: "",

},

},

};

})()

: rawResult;

bootstrapPromptWarningSignaturesSeen = resolveBootstrapWarningSignaturesSeen(

result.meta?.systemPromptReport,

);

}

function clearFollowupQueueSummaryState(queue: {

dropPolicy: "summarize" | "old" | "new";

droppedCount: number;

summaryLines: string[];

summarySources?: FollowupRun[];

export type { InboundTurnKind } from "./types.js";

export type InboundTurnKind = "user_request" | "room_event";

import type { ChannelBotLoopProtectionFacts } from "./bot-loop-protection.js";

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

export type { InboundTurnKind } from "./kind.js";

export type ChannelTurnAdmission =

| { kind: "dispatch"; reason?: string }

| { kind: "observeOnly"; reason: string }