// Codex tests cover attempt turn watches plugin behavior.

import { MAX_TIMER_TIMEOUT_MS } from "openclaw/plugin-sdk/number-runtime";

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

import { updateActiveCompletionBlockerItemIds } from "./attempt-notifications.js";

import { createCodexAttemptTurnWatchController } from "./attempt-turn-watches.js";

describe("Codex app-server attempt turn watches", () => {

let terminalQueued = false;

let activeRequests = 0;

let activeItems = 0;

let activeCompletionBlockers = 0;

const interrupts: Array<Record<string, unknown>> = [];

const timeouts: Array<Record<string, unknown>> = [];

const events: Array<{ name: string; fields: Record<string, unknown> }> = [];

isTerminalTurnNotificationQueued: () => terminalQueued,

getActiveAppServerTurnRequests: () => activeRequests,

getActiveTurnItemCount: () => activeItems,

getActiveCompletionBlockerItemCount: () => activeCompletionBlockers,

turnCompletionIdleTimeoutMs: 10,

turnAssistantCompletionIdleTimeoutMs: 10,

turnAttemptIdleTimeoutMs: 10,

set activeItems(value: number) {

activeItems = value;

},

set activeCompletionBlockers(value: number) {

activeCompletionBlockers = value;

},

interrupts,

timeouts,

events,

expect(harness.abortController.signal.aborted).toBe(false);

});

it("waits for active completion blocker items before firing completion idle timeout", () => {

const harness = createController();

harness.activeCompletionBlockers = 1;

harness.controller.touchActivity("request:mcpServer/elicitation/request:response", {

arm: true,

});

vi.advanceTimersByTime(10);

expect(harness.timeouts).toEqual([]);

expect(harness.abortController.signal.aborted).toBe(false);

harness.activeCompletionBlockers = 0;

harness.controller.touchActivity("notification:item/completed");

vi.advanceTimersByTime(10);

expect(harness.timeouts).toMatchObject([

{

kind: "completion",

idleMs: 10,

timeoutMs: 10,

lastActivityReason: "notification:item/completed",

},

]);

});

it("releases a completed assistant item after the assistant idle guard expires", () => {

const harness = createController();

expect(harness.abortController.signal.reason).toBe("turn_progress_idle_timeout");

});

});

describe("Codex completion blocker item tracking", () => {

it.each([

"collabAgentToolCall",

"commandExecution",

"dynamicToolCall",

"fileChange",

"imageGeneration",

"imageView",

"mcpToolCall",

"webSearch",

])("tracks the %s lifecycle", (type) => {

const activeItemIds = new Set<string>();

updateActiveCompletionBlockerItemIds(

{ method: "item/started", params: { item: { id: "item-1", type } } },

activeItemIds,

);

expect(activeItemIds).toEqual(new Set(["item-1"]));

updateActiveCompletionBlockerItemIds(

{ method: "item/completed", params: { item: { id: "item-1", type } } },

activeItemIds,

);

expect(activeItemIds).toEqual(new Set());

});

it.each(["agentMessage", "contextCompaction", "plan", "reasoning", "subAgentActivity"])(

"does not track the %s lifecycle",

(type) => {

const activeItemIds = new Set<string>();

updateActiveCompletionBlockerItemIds(

{ method: "item/started", params: { item: { id: "item-1", type } } },

activeItemIds,

);

expect(activeItemIds).toEqual(new Set());

},

);

});