import { createEmbeddedRunReplayState, observeReplayMetadata } from "./replay-state.js";

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

import { createEmbeddedRunAuthController } from "./run/auth-controller.js";

import { resolveAuthProfileFailureReason } from "./run/auth-profile-failure-policy.js";

import { runEmbeddedAttemptWithBackend } from "./run/backend.js";

import { createFailoverDecisionLogger } from "./run/failover-observation.js";

import { mergeRetryFailoverReason, resolveRunFailoverDecision } from "./run/failover-policy.js";

modelId: failure.modelId,

});

};

const resolveAuthProfileFailureReason = (

failoverReason: FailoverReason | null,

): AuthProfileFailureReason | null => {

// Timeouts are transport/model-path failures, not auth health signals,

// so they should not persist auth-profile failure state.

if (!failoverReason || failoverReason === "timeout") {

return null;

}

return failoverReason;

};

const resolveRunAuthProfileFailureReason = (failoverReason: FailoverReason | null) =>

resolveAuthProfileFailureReason({

failoverReason,

policy: params.authProfileFailurePolicy,

});

const maybeBackoffBeforeOverloadFailover = async (reason: FailoverReason | null) => {

if (reason !== "overloaded" || overloadFailoverBackoffMs <= 0) {

return;

const promptFailoverReason =

promptErrorDetails.reason ?? classifyFailoverReason(errorText, { provider });

const promptProfileFailureReason =

resolveAuthProfileFailureReason(promptFailoverReason);

resolveRunAuthProfileFailureReason(promptFailoverReason);

await maybeMarkAuthProfileFailure({

profileId: lastProfileId,

reason: promptProfileFailureReason,

},

);

const assistantProfileFailureReason =

resolveAuthProfileFailureReason(assistantFailoverReason);

resolveRunAuthProfileFailureReason(assistantFailoverReason);

const cloudCodeAssistFormatError = attempt.cloudCodeAssistFormatError;

const imageDimensionError = parseImageDimensionError(

assistantForFailover?.errorMessage ?? "",

if (lastProfileId) {

await maybeMarkAuthProfileFailure({

profileId: lastProfileId,

reason: resolveAuthProfileFailureReason(assistantFailoverReason),

reason: resolveRunAuthProfileFailureReason(assistantFailoverReason),

});

}

return {

if (lastProfileId) {

await maybeMarkAuthProfileFailure({

profileId: lastProfileId,

reason: resolveAuthProfileFailureReason(assistantFailoverReason),

reason: resolveRunAuthProfileFailureReason(assistantFailoverReason),

});

}