import { test } from "node:test";
import { assert, assertEquals, assertStringIncludes } from "#test-assert";
import type { DataLayer } from "@nanobpm/urban";
import { noopLog } from "../../test/log.ts";
import { memBlackboardSource } from "../../test/blackboardDb.ts";
import { withTrackingViews } from "../../test/trackingViews.ts";
import { appendEntry } from "../../app/blackboard.ts";
import handler from "./worker.ts";

function memData(): { data: DataLayer; stores: Record<string, any[]> } {
  const stores: Record<string, any[]> = {};
  const seq: Record<string, number> = {};
  function tbl(name: string, pk = "id") {
    const rows = (stores[name] ??= [] as any[]);
    const match = (r: any, where: any) => Object.entries(where).every(([k, v]) => r[k] === v);
    return {
      async insert(row: any) {
        const id = (seq[name] = (seq[name] ?? 0) + 1);
        rows.push(pk === "id" ? { id, ...row } : { ...row });
        return pk === "id" ? id : row[pk];
      },
      async find(where: any = {}) {
        return rows.filter((r) => match(r, where));
      },
      async findOne(where: any = {}) {
        return rows.find((r) => match(r, where));
      },
      async get(id: any) {
        return rows.find((row) => row[pk] === id);
      },
      async update() {},
    };
  }
  const data = { table: withTrackingViews((n: string, pk?: string) => tbl(n, pk)), source: memBlackboardSource().source } as any as DataLayer;
  return { data, stores };
}

test("retro-gather: emits a digest brief + learning count for the plan", async () => {
  const { data, stores } = memData();
  stores["plans"] = [{ plan_key: "o/r#3", repo: "o/r", issue_url: "https://x/3", title: "Epic" }];
  stores["plan_tasks"] = [{ id: 1, plan_key: "o/r#3", task_index: 0, task_id: "t1", title: "Auth", prompt: "add auth", status: "opened", pr_key: "o/r#10" }];
  stores["pull_requests"] = [{ pr_key: "o/r#10", status: "merged" }];
  await appendEntry(data, "o/r#3", { author_task: "t1", kind: "learning", body: "regen before build" });
  await appendEntry(data, "o/r#3", { author_task: "t2", kind: "learning", body: "use nextest" });

  const app = { data, log: noopLog() };
  const out = await handler(
    { variables: { planKey: "o/r#3" } } as any,
    app as any,
  ) as Record<string, unknown>;

  assertEquals(out.retroLearnings, 2);
  assertStringIncludes(String(out.retroDigest), "regen before build");
  assertStringIncludes(String(out.retroDigest), "use nextest");
  assertStringIncludes(String(out.retroDigest), "o/r#3");
  // The gather step also produces the conformance brief pointing at the landed PR + slice spec.
  assertStringIncludes(String(out.conformanceDigest), "Conformance input");
  assertStringIncludes(String(out.conformanceDigest), "o/r#10");
  assertStringIncludes(String(out.conformanceDigest), "add auth");
});

test("retro-gather: an epic with no learnings still renders a valid brief", async () => {
  const { data, stores } = memData();
  stores["plans"] = [{ plan_key: "o/r#4", repo: "o/r", issue_url: "", title: null }];
  const app = { data, log: noopLog() };
  const out = await handler(
    { variables: { planKey: "o/r#4" } } as any,
    app as any,
  ) as Record<string, unknown>;

  assertEquals(out.retroLearnings, 0);
  assert(typeof out.retroDigest === "string");
  assertStringIncludes(String(out.retroDigest), "none");
});