import { isCliProvider } from "../model-selection.js";

import { runEmbeddedPiAgent, type EmbeddedPiRunResult } from "../pi-embedded.js";

import { buildAgentRuntimeAuthPlan } from "../runtime-plan/auth.js";

import { acquireSessionWriteLock } from "../session-write-lock.js";

import {

acquireSessionWriteLock,

resolveSessionWriteLockAcquireTimeoutMs,

} from "../session-write-lock.js";

import { buildWorkspaceSkillSnapshot } from "../skills.js";

import { buildUsageWithNoCost } from "../stream-message-shared.js";

import {

sessionAgentId: string;

threadId?: string | number;

sessionCwd: string;

config: OpenClawConfig;

assistant: {

api: string;

provider: string;

});

const lock = await acquireSessionWriteLock({

sessionFile,

timeoutMs: 10_000,

timeoutMs: resolveSessionWriteLockAcquireTimeoutMs(params.config),

allowReentrant: true,

});

try {

transcriptPath: sessionFile,

sessionId: params.sessionId,

cwd: params.sessionCwd,

config: params.config,

message: {

role: "user",

content: promptText,

transcriptPath: sessionFile,

sessionId: params.sessionId,

cwd: params.sessionCwd,

config: params.config,

message: {

role: "assistant",

content: [{ type: "text", text: replyText }],

sessionAgentId: string;

threadId?: string | number;

sessionCwd: string;

config: OpenClawConfig;

}): Promise<SessionEntry | undefined> {

return await persistTextTurnTranscript({

...params,

sessionAgentId: string;

threadId?: string | number;

sessionCwd: string;

config: OpenClawConfig;

}): Promise<SessionEntry | undefined> {

const replyText = resolveCliTranscriptReplyText(params.result);

const provider = params.result.meta.agentMeta?.provider?.trim() ?? "cli";

sessionAgentId: params.sessionAgentId,

threadId: params.threadId,

sessionCwd: params.sessionCwd,

config: params.config,

assistant: {

api: "cli",

provider,