/**
 * `graph_files` 的**旧无条件唯一索引** `idx_graph_files_path` 必须在存量库上被删掉。
 *
 * ── 病症 ──────────────────────────────────────────────────────────────
 * 产物索引加「版本」之前，唯一索引是无条件的：
 *   UNIQUE(company_id, COALESCE(task_id,''), rel_path)
 * 加版本之后建表块换成了带谓词的 `idx_graph_files_current`
 *   ... WHERE superseded_by IS NULL
 * **但没人删旧的那条**。`CREATE ... IF NOT EXISTS` 只管不重复建，不会删已有的。
 *
 * 于是 `recordFile` 那套「先把旧行 superseded_by 指向新行、再插新行」的版本化写法
 * 在存量库上**整个失效** —— 旧索引不认 superseded_by，同路径的第二行直接撞。
 *
 * ── 为什么没被任何测试照到 ────────────────────────────────────────────
 * 新建库压根没有那条索引（建表块里早就只剩 current），所以**只有存量库会踩**。
 * 这是同一类问题的第三次（tasks 加列的索引顺序、墙钟锚点迁移、这次）——
 * 判据固定下来就是一句话：**凡是碰 schema，「存量库重启」那条路必须单独走一遍。**
 *
 * ── 失效方向 ──────────────────────────────────────────────────────────
 * 不是崩溃：`writeFileIndex` 把 `recordFile` 的抛降级成一条 timeline，节点照样 success。
 * 后果是**产物索引在任何有重试的 run 上都不全**，而下游节点正是靠它按 kind 找上游产物。
 * 2026-08-20 那次真跑里，一条 run 的**每个**节点产物索引写入全部失败。
 */
import { describe, it, expect } from 'vitest';
import { createRequire } from 'module';
import fs from 'fs';
import os from 'os';
import path from 'path';
const require_ = createRequire(import.meta.url);

function freshDb(dbPath) {
  process.env.GRAPH_DB_PATH = dbPath;
  for (const m of ['../../services/work-graph-db', '../../services/graph-db']) {
    delete require_.cache[require_.resolve(m)];
  }
  const wdb = require_('../../services/work-graph-db');
  wdb.getDb();
  return wdb;
}

const indexNames = (db) => db
  .prepare(`SELECT name FROM sqlite_master WHERE type='index' AND tbl_name='graph_files'`)
  .all().map((r) => r.name);

describe('graph_files 旧唯一索引的清理', () => {
  it('存量库重启：旧的 idx_graph_files_path 被删掉，同路径可以再产出一次', () => {
    const dbPath = path.join(fs.mkdtempSync(path.join(os.tmpdir(), 'gf-idx-')), 'graph.sqlite');
    const wdb = freshDb(dbPath);
    expect(indexNames(wdb.getDb())).not.toContain('idx_graph_files_path'); // 新建库本来就没有
    wdb.getDb().close();

    // 退回加版本之前的形态：把旧的无条件唯一索引建回来
    const Database = require_('better-sqlite3');
    const raw = new Database(dbPath);
    raw.exec(`CREATE UNIQUE INDEX idx_graph_files_path
                ON graph_files(company_id, COALESCE(task_id, ''), rel_path)`);
    expect(raw.prepare(`SELECT name FROM sqlite_master WHERE type='index' AND tbl_name='graph_files'`)
      .all().map((r) => r.name)).toContain('idx_graph_files_path');
    raw.close();

    // 重开进程 = 服务重启
    const wdb2 = freshDb(dbPath);
    expect(indexNames(wdb2.getDb())).not.toContain('idx_graph_files_path');
    // 部分索引必须还在 —— 删错了那条会让「同一路径同时有两个当前版本」变成可能
    expect(indexNames(wdb2.getDb())).toContain('idx_graph_files_current');

    // 真正要的行为：同一条 rel_path 产出两次（= 节点重试），第二次不该抛
    const args = { companyId: 'co-x', taskId: 'T-x', relPath: 'nodes/rn_1/sdd.md', kind: 'sdd' };
    const first = wdb2.recordFile(args);
    const second = wdb2.recordFile(args); // 修之前这一句抛 UNIQUE constraint failed
    expect(second).not.toBe(first);

    // 旧行被指向新行，当前版本只有一条 —— 版本化语义没被削弱
    const rows = wdb2.getDb()
      .prepare(`SELECT id, superseded_by FROM graph_files WHERE rel_path = ?`).all(args.relPath);
    expect(rows).toHaveLength(2);
    expect(rows.filter((r) => r.superseded_by === null)).toHaveLength(1);
    expect(rows.find((r) => r.id === first).superseded_by).toBe(second);

    wdb2.getDb().close();
    fs.rmSync(path.dirname(dbPath), { recursive: true, force: true });
    delete process.env.GRAPH_DB_PATH;
  });
});