import { resolve } from 'node:path';
import { fileURLToPath } from 'node:url';

import { mintPid } from './github-pid-register.mjs';

export const RECONCILE_ID = 'github-live-pid-reconcile.v1';
export const SNAPSHOT_SOURCE = 'liris-supervisors-hbp-2026-06-12-count41-acer-office-pending';
export const RECONCILE_STATUS = Object.freeze({
  MATCH: 'MATCH',
  DIVERGENT: 'DIVERGENT',
  PENDING: 'PENDING-OFFICE-SNAPSHOT',
});

export const LIVE_SNAPSHOT = Object.freeze({
  shannon: Object.freeze({
    name: 'shannon',
    role: 'AGT',
    tier: 4,
    prime: 1,
    nest: 1,
    live_pid: 'AGT-SHANNON-PID-HD16C-A04-W1024-P01-N00001',
    live_hex: 'HD16C',
    live_source: 'AGT-SHANNON-PID-HD16C-A04-W1024-P01-N00001',
  }),
  hermes: Object.freeze({
    name: 'hermes',
    role: 'AGT',
    tier: 4,
    prime: 1,
    nest: 1,
    live_pid: 'AGT-HERMES-PID-HD17C-A04-W1024-P01-N00001',
    live_hex: 'HD17C',
    live_source: 'AGT-HERMES-PID-HD17C-A04-W1024-P01-N00001',
  }),
  deepseek: Object.freeze({
    name: 'deepseek',
    role: 'AGT',
    tier: 4,
    prime: 67,
    nest: 67,
    live_pid: 'AGT-DEEPSEEK-TUI-PID-HD15C-A04-W1024-P67-N00067',
    live_hex: 'HD15C',
    live_source: 'AGT-DEEPSEEK-TUI-PID-HD15C-A04-W1024-P67-N00067',
  }),
});

function keyFor(name) {
  const k = String(name || '').toLowerCase().replace(/[^a-z0-9]+/g, '-').replace(/^-|-$/g, '');
  if (!k) throw new Error('name-required');
  return k;
}

function hbpValue(field, value) {
  const s = String(value ?? '');
  if (!s || /[|\r\n]/.test(s)) throw new Error(`${field}-invalid`);
  return s.replace(/[^A-Za-z0-9._:/-]+/g, '-').replace(/^-|-$/g, '') || 'empty';
}

export function reconcile({ name, role = 'AGT', tier, prime, nest } = {}) {
  const key = keyFor(name);
  const snap = LIVE_SNAPSHOT[key];
  const p = mintPid({
    role: snap?.role || role,
    name: key,
    tier: tier ?? snap?.tier ?? 4,
    prime: prime ?? snap?.prime ?? 1,
    nest: nest ?? snap?.nest ?? 1,
  });
  if (!snap) {
    return {
      name: key,
      status: RECONCILE_STATUS.PENDING,
      snapshot_source: SNAPSHOT_SOURCE,
      github_pid: p.pid,
      github_hex: p.hex,
      github_sha16: p.sha16,
      live_pid: 'none',
      live_hex: 'none',
      live_source: 'none',
    };
  }
  const status = p.hex === snap.live_hex ? RECONCILE_STATUS.MATCH : RECONCILE_STATUS.DIVERGENT;
  return {
    name: key,
    status,
    snapshot_source: SNAPSHOT_SOURCE,
    github_pid: p.pid,
    github_hex: p.hex,
    github_sha16: p.sha16,
    live_pid: snap.live_pid,
    live_hex: snap.live_hex,
    live_source: snap.live_source,
  };
}

export function emitReconcileRow(r) {
  const x = r.status ? r : reconcile(r);
  return `PIDRECONCILE|name=${hbpValue('name', x.name)}|status=${x.status}|github_pid=${hbpValue('github_pid', x.github_pid)}|github_hex=${x.github_hex}|github_sha16=${x.github_sha16}|live_pid=${hbpValue('live_pid', x.live_pid)}|live_hex=${x.live_hex}|snapshot_source=${SNAPSHOT_SOURCE}|json=0`;
}

export function emitSnapshotRows() {
  const rows = [`PIDRECONCILEHDR|tool=${RECONCILE_ID}|snapshot_source=${SNAPSHOT_SOURCE}|entries=${Object.keys(LIVE_SNAPSHOT).length}|mode=github-proposed-vs-live-office-snapshot|json=0`];
  for (const name of Object.keys(LIVE_SNAPSHOT).sort()) rows.push(emitReconcileRow(reconcile({ name })));
  rows.push('PIDRECONCILEFTR|rule=github-pid-is-PROPOSED-until-live-office-assignment-or-alias-map-byte-receipted|unknown=PENDING-OFFICE-SNAPSHOT-not-fabricated|json=0');
  return rows;
}

export function selfTest() {
  const checks = [];
  const add = (name, ok) => checks.push({ name, ok: Boolean(ok) });
  const shannon = reconcile({ name: 'shannon' });
  const hermes = reconcile({ name: 'hermes' });
  const deepseek = reconcile({ name: 'deepseek' });
  add('shannon-divergent', shannon.github_hex === 'HE2EC' && shannon.live_hex === 'HD16C' && shannon.status === RECONCILE_STATUS.DIVERGENT);
  add('hermes-divergent', hermes.github_hex === 'HDFEC' && hermes.live_hex === 'HD17C' && hermes.status === RECONCILE_STATUS.DIVERGENT);
  add('deepseek-corrected-h4dac', deepseek.github_hex === 'H4DAC' && deepseek.live_hex === 'HD15C' && deepseek.status === RECONCILE_STATUS.DIVERGENT);
  add('no-stale-hb5ec', deepseek.github_hex !== 'HB5EC');
  add('unknown-pending', reconcile({ name: 'new-model' }).status === RECONCILE_STATUS.PENDING);
  add('rows-hbp-only', emitSnapshotRows().every((row) => row.endsWith('|json=0') && !row.includes('\n')));
  add('source-named', SNAPSHOT_SOURCE.includes('count41'));
  return { ok: checks.every((c) => c.ok), checks };
}

const isMain = process.argv[1] && fileURLToPath(import.meta.url) === resolve(process.argv[1]);
if (isMain) {
  if (process.argv[2] === '--self-test') {
    const r = selfTest();
    for (const c of r.checks) console.log(`${c.ok ? 'PASS' : 'FAIL'} ${c.name}`);
    process.exit(r.ok ? 0 : 1);
  }
  for (const row of emitSnapshotRows()) console.log(row);
}