/** Embedded-agent helper barrel for bootstrap, provider error, media, and turn sanitizers. */

export { isModelNotFoundErrorMessage } from "./live-model-errors.js";

export {

buildBootstrapContextFiles,

DEFAULT_BOOTSTRAP_MAX_CHARS,

isAuthAssistantError,

isAuthErrorMessage,

isAuthPermanentErrorMessage,

isModelNotFoundErrorMessage,

isBillingAssistantError,

extractObservedOverflowTokenCount,

parseApiErrorInfo,

return isAuthErrorMessage(msg.errorMessage ?? "");

}

export { isModelNotFoundErrorMessage };

function isCliSessionExpiredErrorMessage(raw: string): boolean {

if (!raw) {

return false;

runSubagentEnded: vi.fn(async () => {}),

}));

vi.mock("./tools/agent-step.js", () => ({

readLatestAssistantReply: async () => "done",

}));

const callGatewayMock = getCallGatewayMock();

const RUN_TIMEOUT_SECONDS = 1;

import { testing as subagentAnnounceDeliveryTesting } from "./subagent-announce-delivery.js";

import { runSubagentAnnounceDispatch } from "./subagent-announce-dispatch.js";

import { testing as subagentAnnounceOutputTesting } from "./subagent-announce-output.js";

import * as agentStep from "./tools/agent-step.js";

type AgentCallRequest = {

method?: string;

const resolveMainSessionKeySpy = vi.spyOn(configSessions, "resolveMainSessionKey");

const callGatewaySpy = vi.spyOn(gatewayCall, "callGateway");

const getGlobalHookRunnerSpy = vi.spyOn(hookRunnerGlobal, "getGlobalHookRunner");

const readLatestAssistantReplySpy = vi.spyOn(agentStep, "readLatestAssistantReply");

const isEmbeddedAgentRunActiveSpy = vi.spyOn(embeddedRuns, "isEmbeddedAgentRunActive");

const isEmbeddedAgentRunStreamingSpy = vi.spyOn(embeddedRuns, "isEmbeddedAgentRunStreaming");

const queueEmbeddedAgentMessageWithOutcomeSpy = vi.spyOn(

.mockImplementation(

() => hookRunnerMock as unknown as ReturnType<typeof hookRunnerGlobal.getGlobalHookRunner>,

);

readLatestAssistantReplySpy

.mockReset()

.mockImplementation(async (params) => await readLatestAssistantReplyMock(params?.sessionKey));

isEmbeddedAgentRunActiveSpy

.mockReset()

.mockImplementation((sessionId) => embeddedRunMock.isEmbeddedAgentRunActive(sessionId));

});

const resolveStorePathMock = vi.fn((_store: unknown, _options: unknown) => "/tmp/sessions.json");

const resolveMainSessionKeyMock = vi.fn((_cfg: unknown) => "agent:main:main");

const readLatestAssistantReplyMock = vi.fn(async (_params?: unknown) => "raw subagent reply");

const isEmbeddedAgentRunActiveMock = vi.fn((_sessionId: string) => false);

const queueEmbeddedAgentMessageWithOutcomeMock = vi.fn(

(sessionId: string, _text: string, _options?: unknown): EmbeddedAgentQueueMessageOutcome => ({

waitForEmbeddedAgentRunEndMock(sessionId, timeoutMs),

}));

vi.mock("./tools/agent-step.js", () => ({

readLatestAssistantReply: (params?: unknown) => readLatestAssistantReplyMock(params),

}));

vi.mock("./subagent-announce-delivery.runtime.js", () =>

createSubagentAnnounceDeliveryRuntimeMock({

callGateway: (request: unknown) => callGatewayMock(request),

resolveAgentIdFromSessionKeyMock.mockReset().mockImplementation(() => "main");

resolveStorePathMock.mockReset().mockImplementation(() => "/tmp/sessions.json");

resolveMainSessionKeyMock.mockReset().mockImplementation(() => "agent:main:main");

readLatestAssistantReplyMock.mockReset().mockResolvedValue("raw subagent reply");

isEmbeddedAgentRunActiveMock.mockReset().mockReturnValue(false);

queueEmbeddedAgentMessageWithOutcomeMock

.mockReset()

import { resolveNestedAgentLaneForSession } from "../lanes.js";

import { waitForAgentRunAndReadUpdatedAssistantReply } from "../run-wait.js";

export { readLatestAssistantReply } from "../run-wait.js";

type GatewayCaller = typeof callGateway;

type AgentCommandRunner = typeof import("../../commands/agent.js").agentCommandFromIngress;

export const ACP_DOCTOR_USAGE = "Usage: /acp doctor";

export const ACP_SESSIONS_USAGE = "Usage: /acp sessions";

export const ACP_STEER_OUTPUT_LIMIT = 800;

export { SESSION_ID_RE } from "../../../sessions/session-id.js";

export type AcpAction =

| "spawn"

| "cancel"

// Resolves ACP command target sessions from user text and active state.

import { normalizeOptionalString } from "@openclaw/normalization-core/string-coerce";

import { callGateway } from "../../../gateway/call.js";

import { SESSION_ID_RE } from "../../../sessions/session-id.js";

import { resolveEffectiveResetTargetSessionKey } from "../acp-reset-target.js";

import { resolveRequesterSessionKey } from "../commands-subagents/shared.js";

import type { HandleCommandsParams } from "../commands-types.js";

import { resolveAcpCommandBindingContext } from "./context.js";

import { SESSION_ID_RE } from "./shared.js";

async function resolveSessionKeyByToken(token: string): Promise<string | null> {

const trimmed = token.trim();