import { handleAssistantFailover } from "./run/assistant-failover.js";

import {

createEmbeddedRunStageTracker,

EMBEDDED_RUN_ATTEMPT_DISPATCH_STAGE,

formatEmbeddedRunStageSummary,

shouldWarnEmbeddedRunStageSummary,

} from "./run/attempt-stage-timing.js";

"The previous attempt compacted the conversation context before producing a final user-visible answer. Continue from the compacted transcript and produce the final answer now. Do not restart from scratch, do not repeat completed work, and do not rerun tools unless the transcript clearly lacks required evidence.";

type EmbeddedRunAttemptForRunner = Awaited<ReturnType<typeof runEmbeddedAttemptWithBackend>>;

function resolveAttemptDispatchApiKey(params: {

apiKeyInfo: ApiKeyInfo | null;

runtimeAuthState: RuntimeAuthState | null;

}): string | undefined {

if (params.runtimeAuthState) {

return undefined;

}

return params.apiKeyInfo?.apiKey;

}

function resolveEmbeddedRunLaneTimeoutMs(timeoutMs: number): number | undefined {

if (!Number.isFinite(timeoutMs) || timeoutMs <= 0) {

return undefined;

authRetryPending = false;

attemptedThinking.add(thinkLevel);

await fs.mkdir(resolvedWorkspace, { recursive: true });

if (!startupStagesEmitted) {

startupStages.mark(EMBEDDED_RUN_ATTEMPT_DISPATCH_STAGE.workspace);

}

const basePrompt =

nextAttemptPromptOverride ??

promptAdditions.length > 0

? `${basePrompt}\n\n${promptAdditions.join("\n\n")}`

: basePrompt;

let resolvedStreamApiKey: string | undefined;

if (!runtimeAuthState && apiKeyInfo) {

resolvedStreamApiKey = (apiKeyInfo as ApiKeyInfo).apiKey;

const resolvedStreamApiKey = resolveAttemptDispatchApiKey({

apiKeyInfo,

runtimeAuthState,

});

if (!startupStagesEmitted) {

startupStages.mark(EMBEDDED_RUN_ATTEMPT_DISPATCH_STAGE.prompt);

}

const runtimePlan = buildAgentRuntimePlan({

provider,

},

});

if (!startupStagesEmitted) {

startupStages.mark("attempt-dispatch");

startupStages.mark(EMBEDDED_RUN_ATTEMPT_DISPATCH_STAGE.runtimePlan);

startupStages.mark(EMBEDDED_RUN_ATTEMPT_DISPATCH_STAGE.dispatch);

notifyExecutionPhase("attempt_dispatch", { provider, model: modelId });

emitStartupStageSummary("attempt-dispatch");

emitStartupStageSummary(EMBEDDED_RUN_ATTEMPT_DISPATCH_STAGE.dispatch);

startupStagesEmitted = true;

}