}

};

const abortActiveRunExternally = () => {

externalAbort = true;

abortRun();

};

const queueHandle: EmbeddedAgentQueueHandle & {

kind: "embedded";

cancel: (reason?: "user_abort" | "restart" | "superseded") => void;

isCompacting: () => subscription.isCompacting(),

supportsTranscriptCommitWait: true,

sourceReplyDeliveryMode: params.sourceReplyDeliveryMode,

cancel: () => {

abortRun();

},

abort: abortRun,

cancel: abortActiveRunExternally,

abort: abortActiveRunExternally,

};

let lastAssistant: AssistantMessage | undefined;

let currentAttemptAssistant: EmbeddedRunAttemptResult["currentAttemptAssistant"];