type AcpRuntimeTurn,

} from "../runtime-api.js";

import { OPENCLAW_ACPX_LEASE_ID_ARG, OPENCLAW_GATEWAY_INSTANCE_ID_ARG } from "./process-lease.js";

import { AcpxRuntime, testing } from "./runtime.js";

import { AcpxRuntime, testing, type AcpSessionStore } from "./runtime.js";

type TestSessionStore = {

load(sessionId: string): Promise<Record<string, unknown> | undefined>;

const runtime = new AcpxRuntime(

{

cwd: "/tmp",

sessionStore: baseStore,

sessionStore: baseStore as unknown as AcpSessionStore,

agentRegistry: {

resolve: (agentName: string) => (agentName === "openclaw" ? "openclaw acp" : agentName),

list: () => ["codex", "openclaw"],

...(record as Record<string, unknown>),

openclawLeaseId: lease.leaseId,

openclawGatewayInstanceId: lease.gatewayInstanceId,

} as AcpLoadedSessionRecord;

} as unknown as AcpLoadedSessionRecord;

},

async save(record: AcpSessionRecord): Promise<void> {

let recordToSave = record;

agentCommand: stableAgentCommand,

openclawLeaseId: launch.leaseId,

openclawGatewayInstanceId: launch.gatewayInstanceId,

} as AcpSessionRecord;

} as unknown as AcpSessionRecord;

}

await baseStore.save(recordToSave);

if (sessionName) {

);

}

let emittedAssistantText = false;

for (const part of content.modelTurn?.parts ?? []) {

if (part.inlineData?.data) {

const pcm = Buffer.from(part.inlineData.data, "base64");

continue;

}

if (!content.outputTranscription?.text && typeof part.text === "string" && part.text.trim()) {

emittedAssistantText = true;

this.config.onTranscript?.("assistant", part.text, content.turnComplete ?? false);

}

}

}

}

const result = await deliverWithFinalizableLivePreviewAdapter({

await deliverWithFinalizableLivePreviewAdapter({

kind: info.kind,

payload,

adapter: defineFinalizableLivePreviewAdapter({