import test from "node:test";
import assert from "node:assert/strict";
import { withApp } from "./helpers.js";
import { registerAdapter } from "../src/ingest/adapters/index.js";
import { runSource } from "../src/ingest/pipeline.js";

test("feed pipeline dedupes by url and records runs", async () => {
  await withApp(async ({ api, loginAdmin }) => {
    registerAdapter("test-fake", {
      async fetch() {
        return [
          {
            title: "ripgrep",
            url: "https://github.com/BurntSushi/ripgrep?utm_source=x",
            description: "dup",
          },
          {
            title: "brand-new-tool",
            url: "https://github.com/fake/brand-new-tool",
            description: "new item from fake source",
          },
          { title: "", url: "https://example.com/invalid", description: "" },
        ];
      },
    });

    const cookie = await loginAdmin();
    const created = await api("/api/admin/sources", {
      method: "POST",
      body: {
        name: "fake 源",
        url: "mem://fake",
        adapter: "test-fake",
        cron_expr: "0 9 * * 1",
      },
      cookie,
    });
    assert.equal(created.status, 201);
    const sourceId = created.json.data.id;

    const stats = await runSource(sourceId);
    assert.equal(stats.found, 3);
    assert.equal(stats.created, 1);
    assert.equal(stats.skipped, 2);

    const runs = await api(`/api/admin/sources/${sourceId}/runs`, {}, cookie ? {} : {});
    void runs;

    const pending = await api("/api/entries?q=brand-new-tool&status=all");
    assert.equal(pending.json.data.total, 1);
    assert.equal(pending.json.data.items[0].status, "pending");

    const manual = await api(`/api/admin/sources/${sourceId}/run`, { method: "POST", cookie });
    assert.equal(manual.json.data.created, 0);
    assert.equal(manual.json.data.skipped, 3);
  });
});