import { beforeAll, beforeEach, describe, expect, it, vi } from "vitest";
import type { OpenClawConfig } from "../../config/config.js";

const hoisted = vi.hoisted(() => {
  const resolveAllAgentSessionStoreTargetsMock = vi.fn();
  const loadSessionStoreMock = vi.fn();
  return {
    resolveAllAgentSessionStoreTargetsMock,
    loadSessionStoreMock,
  };
});

vi.mock("../../config/sessions/store-load.js", () => ({
  loadSessionStore: (storePath: string, opts?: unknown) =>
    hoisted.loadSessionStoreMock(storePath, opts),
}));

vi.mock("../../config/sessions/targets.js", () => ({
  resolveAllAgentSessionStoreTargets: (cfg: OpenClawConfig, opts: unknown) =>
    hoisted.resolveAllAgentSessionStoreTargetsMock(cfg, opts),
}));
let listAcpSessionEntries: typeof import("./session-meta.js").listAcpSessionEntries;

describe("listAcpSessionEntries", () => {
  beforeAll(async () => {
    ({ listAcpSessionEntries } = await import("./session-meta.js"));
  });

  beforeEach(() => {
    vi.clearAllMocks();
  });

  it("reads ACP sessions from resolved configured store targets", async () => {
    const cfg = {
      session: {
        store: "/custom/sessions/{agentId}.json",
      },
    } as OpenClawConfig;
    hoisted.resolveAllAgentSessionStoreTargetsMock.mockResolvedValue([
      {
        agentId: "ops",
        storePath: "/custom/sessions/ops.json",
      },
    ]);
    const storedEntry = {
      updatedAt: 123,
      acp: {
        backend: "acpx",
        agent: "ops",
        mode: "persistent",
        state: "idle",
      },
    };
    hoisted.loadSessionStoreMock.mockReturnValue({
      "agent:ops:acp:s1": storedEntry,
    });

    const entries = await listAcpSessionEntries({ cfg });

    expect(hoisted.resolveAllAgentSessionStoreTargetsMock).toHaveBeenCalledWith(cfg, undefined);
    expect(hoisted.loadSessionStoreMock).toHaveBeenCalledWith(
      "/custom/sessions/ops.json",
      undefined,
    );
    expect(entries).toEqual([
      {
        acp: storedEntry.acp,
        cfg,
        entry: storedEntry,
        storePath: "/custom/sessions/ops.json",
        sessionKey: "agent:ops:acp:s1",
        storeSessionKey: "agent:ops:acp:s1",
      },
    ]);
  });

  it("can skip cloning for maintenance callers that only inspect ACP entries", async () => {
    const cfg = { session: { store: "/custom/sessions/{agentId}.json" } } as OpenClawConfig;
    hoisted.resolveAllAgentSessionStoreTargetsMock.mockResolvedValue([
      { agentId: "ops", storePath: "/custom/sessions/ops.json" },
    ]);
    hoisted.loadSessionStoreMock.mockReturnValue({});

    await listAcpSessionEntries({ cfg, clone: false });

    expect(hoisted.loadSessionStoreMock).toHaveBeenCalledWith("/custom/sessions/ops.json", {
      clone: false,
    });
  });
});