import assert from 'node:assert/strict';
import { mkdir, mkdtemp, writeFile } from 'node:fs/promises';
import { join, resolve } from 'node:path';
import test from 'node:test';
import { Store } from '../src/adapters/storage/file-store.js';
import { resolveCommit, snapshot } from '../src/adapters/storage/git.js';
import { checked, execute } from '../src/shared/process.js';

test('real Git snapshots and CLI compare pinned commits without editing checkout', async () => {
  await mkdir('.cache/tests', { recursive: true });
  const root = await mkdtemp(resolve('.cache/tests/git-'));
  await checked('git', ['init', '-b', 'main'], root);
  await checked('git', ['config', 'user.name', 'RepoPilot Test'], root);
  await checked('git', ['config', 'user.email', 'test@example.invalid'], root);
  await mkdir(join(root, '.repopilot'));
  await writeFile(join(root, '.repopilot/policy.json'), JSON.stringify({ rules: [{ id: 'no-bad', forbiddenText: 'BAD', extensions: ['.ts'], message: 'No bad code' }] }));
  await writeFile(join(root, 'a.ts'), 'GOOD\n');
  await checked('git', ['add', '.'], root); await checked('git', ['commit', '-m', 'base'], root);
  const base = await resolveCommit(root, 'HEAD');
  await writeFile(join(root, 'a.ts'), 'BAD\n');
  await checked('git', ['add', '.'], root); await checked('git', ['commit', '-m', 'regression'], root);
  const head = await resolveCommit(root, 'HEAD');
  assert.equal((await snapshot(root, base)).get('a.ts'), 'GOOD\n');
  assert.equal((await snapshot(root, head)).get('a.ts'), 'BAD\n');
  const configuration = join(root, 'controller.local.json');
  await writeFile(configuration, JSON.stringify({ repository: 'example/repo', dataDir: join(root, 'reports') }));
  const output = await execute(process.execPath, ['--import', 'tsx', 'src/cli.ts', 'check', '--config', configuration,
    '--repo', root, '--base', base, '--head', head]);
  assert.equal(output.code, 2, output.stderr);
  assert.equal(JSON.parse(output.stdout).findings, 1);
  assert.equal(await resolveCommit(root, 'HEAD'), head);
  const id = JSON.parse(output.stdout).id;
  const cli = (...args: string[]) => execute(process.execPath, ['--import', 'tsx', 'src/cli.ts', 'tasks', ...args, '--config', configuration]);
  const listed = await cli('list'); assert.equal(listed.code, 0, listed.stderr);
  assert.equal(JSON.parse(listed.stdout).tasks[0].id, id);
  const shown = await cli('show', id, '--format', 'markdown'); assert.equal(shown.code, 0, shown.stderr);
  assert.match(shown.stdout, /RepoPilot verification/);
  const saved = new Store(join(root, 'reports'));
  const release = await saved.acquire();
  try {
    assert.equal((await cli('cancel', id)).code, 0);
    assert.equal((await cli('list')).code, 0);
    const blocked = await cli('rerun', id); assert.equal(blocked.code, 1); assert.match(blocked.stderr, /lock exists/);
  } finally { await release(); }
  const rerun = await cli('rerun', id); assert.equal(rerun.code, 2, rerun.stderr);
  const newId = JSON.parse(rerun.stdout).id; assert.notEqual(newId, id);
  assert.equal((await saved.read(newId))?.rerunOf, id);
  assert.equal(await saved.cancellationRequested(id), true);
  const interrupted = (await saved.read(newId))!; interrupted.status = 'cancelled'; await saved.save(interrupted);
  await saved.requestCancellation(newId);
  const resumed = await cli('resume', newId); assert.equal(resumed.code, 2, resumed.stderr);
  assert.equal(JSON.parse(resumed.stdout).id, newId);
  assert.equal((await saved.read(newId))?.executions, 2);
  assert.equal(await saved.cancellationRequested(newId), false);
  assert.equal(await resolveCommit(root, 'HEAD'), head);
});