import { afterEach, beforeAll, beforeEach, describe, expect, it, vi } from "vitest";

import type { OpenClawConfig } from "../../config/config.js";

import type { SessionEntry } from "../../config/sessions/types.js";

import {

createUserTurnTranscriptRecorder,

type PersistedUserTurnMessage,

} from "../../sessions/user-turn-transcript.js";

import type { FollowupRun, QueueSettings } from "./queue.js";

const runEmbeddedPiAgentMock = vi.fn();

return promptSections.join("\n\n");

}

function createTestUserTurnRecorder(message: PersistedUserTurnMessage) {

return createUserTurnTranscriptRecorder({

message,

target: { transcriptPath: "/tmp/session.jsonl" },

updateMode: "none",

});

}

function requireRecord(value: unknown, label: string): Record<string, unknown> {

if (!value || typeof value !== "object" || Array.isArray(value)) {

throw new Error(`expected ${label} to be an object`);

describe("createFollowupRunner reply-lane admission", () => {

it("passes prepared media user turns to embedded runtime dispatch", async () => {

const userMessageForPersistence = {

const preparedUserTurnMessage = {

role: "user",

content: "describe this",

MediaPath: "/tmp/image.png",

await runner(

createQueuedRun({

userMessageForPersistence,

userTurnTranscriptRecorder: createTestUserTurnRecorder(preparedUserTurnMessage),

run: {

provider: "anthropic",

model: "claude",

expect(runEmbeddedPiAgentMock).toHaveBeenCalledOnce();

const call = requireLastMockCallArg(runEmbeddedPiAgentMock, "run embedded pi agent");

expect(call.userMessageForPersistence).toBe(userMessageForPersistence);

expect(call.userTurnTranscriptRecorder?.message).toBe(preparedUserTurnMessage);

});

it("runs queued followups with the session id returned by admission", async () => {

},

},

};

const userMessageForPersistence = {

const preparedUserTurnMessage = {

role: "user",

content: "describe this",

MediaPath: "/tmp/image.png",

await runner(

createQueuedRun({

userMessageForPersistence,

userTurnTranscriptRecorder: createTestUserTurnRecorder(preparedUserTurnMessage),

run: {

config: runtimeConfig,

provider: "anthropic",

expect(runCliAgentMock).toHaveBeenCalledOnce();

const mediaCall = requireLastMockCallArg(runCliAgentMock, "run cli agent");

expect(mediaCall.userTurnTranscript).toEqual({ message: userMessageForPersistence });

expect(mediaCall.userTurnTranscript).toEqual({ message: preparedUserTurnMessage });

});

it("defers queued CLI attempt terminal lifecycle events until fallback settles", async () => {