#!/usr/bin/env node
// skill-test-runner v0.4 — Snapshot-based regression tests for 1C skill scripts
// Usage: node tests/skills/runner.mjs [filter] [--update-snapshots] [--runtime python] [--json report.json] [--concurrency N] [--with-validation]

import { execFileSync, execFile } from 'child_process';
import { existsSync, mkdirSync, mkdtempSync, rmSync, readFileSync, writeFileSync,
         readdirSync, statSync, cpSync, copyFileSync } from 'fs';
import { join, resolve, dirname, relative, basename, extname } from 'path';
import { tmpdir, cpus } from 'os';

// ─── Paths ──────────────────────────────────────────────────────────────────

const ROOT      = resolve(dirname(new URL(import.meta.url).pathname).replace(/^\/([A-Z]:)/i, '$1'));
const REPO_ROOT = resolve(ROOT, '../..');
const SKILLS    = resolve(REPO_ROOT, '.claude/skills');
const CASES     = resolve(ROOT, 'cases');
const CACHE     = resolve(ROOT, '.cache');

// ─── CLI args ───────────────────────────────────────────────────────────────

function printHelp() {
  console.log(`skill-test-runner — Snapshot-based regression tests for 1C skill scripts

Usage:
  node tests/skills/runner.mjs [filter] [options]

Arguments:
  filter                  Substring to match case id (e.g. "form-compile" or "form-compile/table")

Options:
  --update-snapshots      Overwrite snapshot files with current actual output
  --runtime <ps|python>   Which script port to run (default: powershell)
  --json <path>           Write JSON report to <path>
  --concurrency <N>       Number of parallel workers (default: cpu count)
  --with-validation       Run platform validation (1cv8 design checks) after compile
  -v, --verbose           Verbose output
  -h, --help, /?          Show this help and exit
`);
}

function parseArgs(argv) {
  const args = { filter: null, updateSnapshots: false, runtime: 'powershell', jsonReport: null, verbose: false, concurrency: cpus().length, withValidation: false, help: false };
  const rest = argv.slice(2);
  for (let i = 0; i < rest.length; i++) {
    const a = rest[i];
    if (a === '-h' || a === '--help' || a === '/?' || a === '/help' || a === '?') { args.help = true; continue; }
    if (a === '--update-snapshots') { args.updateSnapshots = true; continue; }
    if (a === '--runtime' && rest[i + 1]) { args.runtime = rest[++i]; continue; }
    if (a === '--json' && rest[i + 1]) { args.jsonReport = rest[++i]; continue; }
    if (a === '--verbose' || a === '-v') { args.verbose = true; continue; }
    if (a === '--concurrency' && rest[i + 1]) { args.concurrency = parseInt(rest[++i], 10) || 1; continue; }
    if (a === '--with-validation') { args.withValidation = true; continue; }
    if (!a.startsWith('--') && !args.filter) { args.filter = a.replace(/\\/g, '/'); continue; }
  }
  return args;
}

// ─── Case discovery ─────────────────────────────────────────────────────────

function discoverCases(filter) {
  const results = [];
  if (!existsSync(CASES)) return results;

  for (const skillDir of readdirSync(CASES)) {
    const skillPath = join(CASES, skillDir);
    if (!statSync(skillPath).isDirectory()) continue;

    const skillJsonPath = join(skillPath, '_skill.json');
    if (!existsSync(skillJsonPath)) continue;

    const skillConfig = JSON.parse(readFileSync(skillJsonPath, 'utf8'));

    for (const file of readdirSync(skillPath)) {
      if (file.startsWith('_') || !file.endsWith('.json')) continue;
      const caseName = file.replace(/\.json$/, '');
      const caseId = `cases/${skillDir}/${caseName}`;

      // Apply filter
      if (filter) {
        const f = filter.replace(/\.json$/, '');
        if (!caseId.startsWith(f) && !caseId.includes(f)) continue;
      }

      const casePath = join(skillPath, file);
      const caseData = JSON.parse(readFileSync(casePath, 'utf8'));
      const snapshotDir = join(skillPath, 'snapshots', caseName);

      results.push({
        id: caseId,
        name: caseData.name || caseName,
        skillDir,
        skillConfig,
        caseData,
        casePath,
        snapshotDir,
      });
    }
  }

  return results;
}

// ─── Setup / Fixtures ───────────────────────────────────────────────────────

const SKIP = Symbol('skip');

function ensureSetup(setupName, runtime, skillCasesDir) {
  if (setupName === 'none' || !setupName) return null;

  if (setupName.startsWith('fixture:')) {
    // Resolve relative to skill's cases directory (e.g. cases/meta-validate/fixtures/...)
    const fixturePath = join(skillCasesDir, 'fixtures', setupName.slice('fixture:'.length));
    if (!existsSync(fixturePath)) throw new Error(`Fixture not found: ${fixturePath}`);
    return fixturePath;
  }

  if (setupName.startsWith('external:')) {
    // External path — use real config dump as read-only fixture.
    // Returns SKIP if path is unavailable (tests gracefully skipped).
    const extPath = resolve(REPO_ROOT, setupName.slice('external:'.length));
    if (!existsSync(extPath)) return SKIP;
    return extPath;
  }

  if (setupName === 'empty-config') {
    const cached = join(CACHE, 'empty-config');
    if (existsSync(cached)) return cached;

    mkdirSync(cached, { recursive: true });
    const script = resolveScript('cf-init/scripts/cf-init', runtime);
    try {
      execSkillRaw(runtime, script, ['-Name', 'TestConfig', '-OutputDir', cached]);
    } catch (e) {
      rmSync(cached, { recursive: true, force: true });
      throw new Error(`Failed to create empty-config fixture: ${e.message}`);
    }
    return cached;
  }

  if (setupName === 'base-config') {
    const cached = join(CACHE, 'base-config');
    if (existsSync(cached)) return cached;
    throw new Error('base-config fixture not found. Run integration tests first.');
  }

  throw new Error(`Unknown setup: ${setupName}`);
}

// ─── Script resolution ──────────────────────────────────────────────────────

function resolveScript(scriptRelPath, runtime) {
  const ext = runtime === 'python' ? '.py' : '.ps1';
  const full = join(SKILLS, scriptRelPath + ext);
  if (!existsSync(full)) throw new Error(`Script not found: ${full}`);
  return full;
}

function execSkillRaw(runtime, scriptPath, args, cwd) {
  const execCwd = cwd || REPO_ROOT;
  if (runtime === 'python') {
    return execFileSync(process.env.PYTHON || 'python', [scriptPath, ...args], {
      encoding: 'utf8',
      timeout: 60_000,
      stdio: ['pipe', 'pipe', 'pipe'],
      cwd: execCwd,
    });
  }
  // PowerShell
  return execFileSync('powershell.exe', [
    '-NoProfile', '-NonInteractive', '-ExecutionPolicy', 'Bypass',
    '-File', scriptPath, ...args
  ], {
    encoding: 'utf8',
    timeout: 60_000,
    stdio: ['pipe', 'pipe', 'pipe'],
    cwd: execCwd,
  });
}

function execSkillAsync(runtime, scriptPath, args, cwd) {
  return new Promise((resolve, reject) => {
    const execCwd = cwd || REPO_ROOT;
    const cmd = runtime === 'python'
      ? [process.env.PYTHON || 'python', [scriptPath, ...args]]
      : ['powershell.exe', ['-NoProfile', '-NonInteractive', '-ExecutionPolicy', 'Bypass', '-File', scriptPath, ...args]];

    const child = execFile(cmd[0], cmd[1], {
      encoding: 'utf8',
      timeout: 60_000,
      cwd: execCwd,
    }, (error, stdout, stderr) => {
      if (error) {
        const err = new Error(error.message);
        err.status = error.code === 'ERR_CHILD_PROCESS_STDIO_MAXBUFFER' ? 1 : (error.code ?? 1);
        err.stdout = stdout || '';
        err.stderr = stderr || '';
        reject(err);
      } else {
        resolve(stdout);
      }
    });
  });
}

// ─── Workspace ──────────────────────────────────────────────────────────────

function createWorkspace(fixturePath, readOnly) {
  if (readOnly && fixturePath) {
    // Use fixture path directly without copying (for large external dirs)
    return { path: fixturePath, readOnly: true };
  }
  const tmp = mkdtempSync(join(tmpdir(), 'skill-test-'));
  if (fixturePath) {
    cpSync(fixturePath, tmp, { recursive: true });
  }
  return { path: tmp, readOnly: false };
}

function cleanupWorkspace(ws) {
  if (ws.readOnly) return;
  // On Windows, file handles from db-update (1cv8) may linger briefly after the
  // process exits — rmSync then throws EBUSY. Retry a few times, then swallow:
  // a leaked tmp dir is preferable to crashing the entire runner.
  try {
    rmSync(ws.path, { recursive: true, force: true, maxRetries: 10, retryDelay: 200 });
  } catch (e) {
    console.warn(`Warning: failed to clean workspace ${ws.path}: ${e.message}`);
  }
}

// ─── Arg building ───────────────────────────────────────────────────────────

function buildArgs(skillConfig, caseData, workDir, inputFilePath, runtime) {
  const args = [];
  const scriptPath = resolveScript(skillConfig.script, runtime);

  for (const mapping of skillConfig.args) {
    args.push(mapping.flag);

    switch (mapping.from) {
      case 'inputFile':
        args.push(inputFilePath);
        break;
      case 'workDir':
        args.push(workDir);
        break;
      case 'outputPath':
        args.push(join(workDir, caseData.outputPath || ''));
        break;
      case 'workPath':
        // workDir + value from case.params or case (specified in mapping.field)
        const wpField = mapping.field || 'objectPath';
        const wpVal = caseData.params?.[wpField] ?? caseData[wpField];
        if (wpVal === undefined || wpVal === null || wpVal === '') {
          if (mapping.optional) {
            args.pop(); // remove the flag we pushed at the top of the loop
            break;
          }
          args.push(join(workDir, ''));
        } else {
          args.push(join(workDir, wpVal));
        }
        break;
      case 'switch':
        // flag already pushed, no value needed — remove the flag and re-push conditionally
        args.pop(); // remove flag, will re-add if switch is active
        if (caseData[mapping.flag.replace(/^-/, '')] !== false) {
          args.push(mapping.flag);
        }
        break;
      default:
        if (mapping.from.startsWith('case.')) {
          const field = mapping.from.slice(5);
          const val = caseData.params?.[field] ?? caseData[field] ?? '';
          args.push(String(val));
        } else if (mapping.from === 'literal') {
          args.push(mapping.value || '');
        }
    }
  }

  // Append extra args from case (for optional params like -Vendor, -Version).
  // Supports {workDir} substitution for tests that need absolute paths inside the workspace.
  if (caseData.args_extra) {
    args.push(...caseData.args_extra.map(a => typeof a === 'string' ? a.replace('{workDir}', workDir) : a));
  }

  return { scriptPath, args };
}

// ─── Snapshot normalization ─────────────────────────────────────────────────

const UUID_RE = /[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}/gi;

function normalizeXmlContent(text) {
  let s = text;
  // 1. XML declaration: normalize quotes and encoding case
  s = s.replace(
    /<\?xml\s+version=['"]1\.0['"]\s+encoding=['"]([^'"]+)['"]\s*\?>/gi,
    (_, enc) => `<?xml version="1.0" encoding="${enc.toLowerCase()}"?>`
  );
  // 2. Remove &#13; (CR encoded as XML entity by Python etree)
  s = s.replace(/&#13;/g, '');
  // 3. Strip xmlns declarations (Python etree strips unused ones)
  s = s.replace(/\s+xmlns(?::[\w]+)?="[^"]*"/g, '');
  // 4. Normalize self-closing tags: remove space before />
  s = s.replace(/\s*\/>/g, '/>');
  // 5. Collapse whitespace between tags: ">  \n\t  <" → "><"
  s = s.replace(/>\s+</g, '><');
  // 6. Normalize empty elements: <Tag></Tag> → <Tag/>
  s = s.replace(/<([\w:.]+)([^>]*)><\/\1>/g, '<$1$2/>');
  // 7. Strip trailing whitespace
  s = s.trimEnd();
  return s;
}

function normalizeContent(text, config) {
  // Strip BOM
  let s = text.replace(/^\uFEFF/, '');
  // Normalize line endings
  s = s.replace(/\r\n/g, '\n');
  // Normalize XML differences (Python etree serialization quirks)
  if (config?.runtime === 'python') {
    s = normalizeXmlContent(s);
  }

  // Normalize UUIDs
  if (config?.normalizeUuids) {
    const uuidMap = new Map();
    let counter = 0;
    s = s.replace(UUID_RE, (match) => {
      const lower = match.toLowerCase();
      if (!uuidMap.has(lower)) {
        counter++;
        uuidMap.set(lower, `UUID-${String(counter).padStart(3, '0')}`);
      }
      return uuidMap.get(lower);
    });
  }

  return s;
}

// ─── Snapshot comparison ────────────────────────────────────────────────────

// Capture raw byte contents of every file in dir, keyed by relative path.
// Used by idempotency checks to verify byte-equality after a re-run.
function snapshotWorkDirBytes(dir) {
  const files = listFilesRecursive(dir);
  const map = new Map();
  for (const rel of files) {
    map.set(rel, readFileSync(join(dir, rel)));
  }
  return map;
}

// Compare two byte-snapshots. Returns null if identical, else a list of diff lines.
function diffByteSnapshots(before, after) {
  const diffs = [];
  for (const [rel, b1] of before) {
    if (!after.has(rel)) { diffs.push(`removed: ${rel}`); continue; }
    const b2 = after.get(rel);
    if (b1.length !== b2.length || !b1.equals(b2)) diffs.push(`changed: ${rel} (${b1.length} -> ${b2.length} bytes)`);
  }
  for (const rel of after.keys()) {
    if (!before.has(rel)) diffs.push(`added: ${rel}`);
  }
  return diffs.length === 0 ? null : diffs;
}

function listFilesRecursive(dir, base = '') {
  const result = [];
  if (!existsSync(dir)) return result;
  for (const entry of readdirSync(dir)) {
    const full = join(dir, entry);
    const rel = base ? `${base}/${entry}` : entry;
    if (statSync(full).isDirectory()) {
      result.push(...listFilesRecursive(full, rel));
    } else {
      result.push(rel);
    }
  }
  return result.sort();
}

function compareSnapshot(workDir, snapshotDir, snapshotConfig) {
  if (!existsSync(snapshotDir)) return { match: true, reason: 'no snapshot (skipped)' };

  const snapshotFiles = listFilesRecursive(snapshotDir);
  if (snapshotFiles.length === 0) return { match: true, reason: 'empty snapshot (skipped)' };

  const diffs = [];

  for (const relFile of snapshotFiles) {
    const actualPath = join(workDir, relFile);
    const snapshotPath = join(snapshotDir, relFile);

    if (!existsSync(actualPath)) {
      diffs.push({ file: relFile, type: 'missing', detail: 'file not found in output' });
      continue;
    }

    const actualRaw = readFileSync(actualPath, 'utf8');
    const snapshotRaw = readFileSync(snapshotPath, 'utf8');

    const actual = normalizeContent(actualRaw, snapshotConfig);
    const expected = normalizeContent(snapshotRaw, snapshotConfig);

    if (actual !== expected) {
      // Find first differing line
      const actualLines = actual.split('\n');
      const expectedLines = expected.split('\n');
      let diffLine = -1;
      for (let i = 0; i < Math.max(actualLines.length, expectedLines.length); i++) {
        if (actualLines[i] !== expectedLines[i]) { diffLine = i + 1; break; }
      }
      diffs.push({
        file: relFile,
        type: 'content',
        line: diffLine,
        expected: expectedLines[diffLine - 1]?.substring(0, 600),
        actual: actualLines[diffLine - 1]?.substring(0, 600),
      });
    }
  }

  if (diffs.length === 0) return { match: true };
  return { match: false, diffs };
}

function updateSnapshot(workDir, snapshotDir, snapshotConfig) {
  // Remove old snapshot
  if (existsSync(snapshotDir)) rmSync(snapshotDir, { recursive: true, force: true });

  // Determine which files to snapshot — all files in workDir that were created by the skill
  // For "workDir" root mode, we need to figure out what files the skill added.
  // Strategy: snapshot all files in workDir (the fixture files + skill output).
  // On comparison, only files IN the snapshot are checked, so this is safe.
  const files = listFilesRecursive(workDir);
  if (files.length === 0) return;

  mkdirSync(snapshotDir, { recursive: true });
  for (const relFile of files) {
    const src = join(workDir, relFile);
    const dst = join(snapshotDir, relFile);
    mkdirSync(dirname(dst), { recursive: true });

    const raw = readFileSync(src, 'utf8');
    const normalized = normalizeContent(raw, snapshotConfig);
    writeFileSync(dst, normalized, 'utf8');
  }
}

// ─── Post-run validation ─────────────────────────────────────────────────────

function resolveValidatePath(postValidate, caseData, workDir) {
  const pathFrom = postValidate.pathFrom || 'validatePath';
  if (pathFrom === 'workDir') return workDir;
  const relPath = caseData[pathFrom] || caseData.params?.[pathFrom];
  if (!relPath) return null; // no path — skip validation for this case
  const full = join(workDir, relPath);
  // For flat metadata objects (e.g. DefinedTypes/X) the path is a file, not a dir
  if (!existsSync(full) && existsSync(full + '.xml')) return full + '.xml';
  return full;
}

function runPostValidation(postValidate, caseData, workDir, runtime) {
  const targetPath = resolveValidatePath(postValidate, caseData, workDir);
  if (!targetPath) return null; // no validatePath in case — skip silently

  const script = resolveScript(postValidate.script, runtime);
  const args = [postValidate.flag, targetPath];
  try {
    execSkillRaw(runtime, script, args);
    return null; // validation passed
  } catch (e) {
    const detail = e.stderr?.trim() || e.stdout?.trim() || e.message;
    return `Validation failed (${postValidate.script}):\n${detail.substring(0, 500)}`;
  }
}

async function runPostValidationAsync(postValidate, caseData, workDir, runtime) {
  const targetPath = resolveValidatePath(postValidate, caseData, workDir);
  if (!targetPath) return null;

  const script = resolveScript(postValidate.script, runtime);
  const args = [postValidate.flag, targetPath];
  try {
    await execSkillAsync(runtime, script, args);
    return null;
  } catch (e) {
    const detail = e.stderr?.trim() || e.stdout?.trim() || e.message;
    return `Validation failed (${postValidate.script}):\n${detail.substring(0, 500)}`;
  }
}

// ─── Run a single case ──────────────────────────────────────────────────────

async function runCaseAsync(testCase, opts) {
  const { skillConfig, caseData, snapshotDir } = testCase;
  const t0 = performance.now();
  const setupName = caseData.setup || skillConfig.setup || 'none';
  let workspace = null;
  let workDir = null;
  let inputFile = null;

  try {
    const skillCasesDir = join(CASES, testCase.skillDir);
    const fixturePath = ensureSetup(setupName, opts.runtime, skillCasesDir);
    if (fixturePath === SKIP) {
      return { id: testCase.id, skill: testCase.skillDir, name: testCase.name, passed: true, skipped: true, errors: [], elapsed: '0.0s' };
    }
    const isExternal = typeof setupName === 'string' && setupName.startsWith('external:');
    workspace = createWorkspace(fixturePath, isExternal);
    workDir = workspace.path;

    // Pre-run steps
    if (caseData.preRun) {
      for (const step of caseData.preRun) {
        // writeFile step — записать произвольный файл в workDir перед запуском скрипта
        if (step.writeFile) {
          const wfPath = join(workDir, step.writeFile.path);
          const wfContent = typeof step.writeFile.content === 'string'
            ? step.writeFile.content
            : JSON.stringify(step.writeFile.content, null, 2);
          writeFileSync(wfPath, wfContent, 'utf8');
          continue;
        }
        const preScript = resolveScript(step.script, opts.runtime);
        const preArgs = [];
        for (const [flag, value] of Object.entries(step.args || {})) {
          preArgs.push(flag);
          if (value === true || value === '') continue;
          preArgs.push(String(value).replace('{workDir}', workDir).replace('{inputFile}', ''));
        }
        let preInputFile = null;
        if (step.input) {
          preInputFile = join(workDir, '__pre_input.json');
          writeFileSync(preInputFile, JSON.stringify(step.input, null, 2), 'utf8');
          for (let i = 0; i < preArgs.length; i++) {
            if (preArgs[i] === '') preArgs[i] = preInputFile;
          }
        }
        try {
          const preCwd = step.cwd === '{workDir}' ? workDir : undefined;
          await execSkillAsync(opts.runtime, preScript, preArgs, preCwd);
        } catch (e) {
          throw new Error(`preRun step "${step.script}" failed: ${e.stderr || e.message}`);
        }
        if (preInputFile && existsSync(preInputFile)) rmSync(preInputFile);
      }
    }

    // Write input
    if (caseData.input !== undefined) {
      inputFile = join(workDir, '__input.json');
      writeFileSync(inputFile, JSON.stringify(caseData.input, null, 2), 'utf8');
    }

    // Execute
    const { scriptPath, args } = buildArgs(skillConfig, caseData, workDir, inputFile, opts.runtime);
    let stdout = '', stderr = '', exitCode = 0;
    try {
      const execCwd = skillConfig.cwd === 'workDir' ? workDir : undefined;
      stdout = await execSkillAsync(opts.runtime, scriptPath, args, execCwd);
    } catch (e) {
      exitCode = e.status ?? 1;
      stdout = e.stdout || '';
      stderr = e.stderr || '';
    }

    if (inputFile && existsSync(inputFile)) rmSync(inputFile);

    // Assertions
    const errors = [];
    if (caseData.expectError) {
      if (exitCode === 0) errors.push('Expected error (non-zero exit) but got exitCode=0');
      if (typeof caseData.expectError === 'string' && !stderr.includes(caseData.expectError)) {
        errors.push(`Expected stderr to contain "${caseData.expectError}", got: ${stderr.substring(0, 200)}`);
      }
    } else {
      if (exitCode !== 0) {
        errors.push(`exitCode=${exitCode}\nstdout: ${stdout.substring(0, 300)}\nstderr: ${stderr.substring(0, 300)}`);
      }
      if (caseData.expect?.files) {
        for (const f of caseData.expect.files) {
          if (!existsSync(join(workDir, f))) errors.push(`Expected file not found: ${f}`);
        }
      }
      if (caseData.expect?.stdoutContains) {
        if (!stdout.includes(caseData.expect.stdoutContains)) {
          errors.push(`stdout does not contain "${caseData.expect.stdoutContains}"`);
        }
      }
      if (errors.length === 0 && !caseData.expectError && !workspace.readOnly) {
        const snapshotConfig = { ...skillConfig.snapshot, runtime: opts.runtime };
        if (opts.updateSnapshots) {
          updateSnapshot(workDir, snapshotDir, snapshotConfig);
        } else {
          const cmp = compareSnapshot(workDir, snapshotDir, snapshotConfig);
          if (!cmp.match && cmp.diffs) {
            for (const d of cmp.diffs) {
              if (d.type === 'missing') errors.push(`Snapshot: file missing — ${d.file}`);
              else errors.push(`Snapshot: ${d.file}:${d.line} differs\n  expected: ${d.expected}\n  actual:   ${d.actual}`);
            }
          }
        }
      }

      // Idempotency check: re-run the same script with the same args and assert
      // every file in workDir is byte-identical to the first-run output.
      if (errors.length === 0 && caseData.idempotent && !workspace.readOnly) {
        const before = snapshotWorkDirBytes(workDir);
        try {
          const execCwd = skillConfig.cwd === 'workDir' ? workDir : undefined;
          await execSkillAsync(opts.runtime, scriptPath, args, execCwd);
        } catch (e) {
          errors.push(`Idempotency rerun failed: exitCode=${e.status}\nstderr: ${(e.stderr || '').substring(0, 300)}`);
        }
        if (errors.length === 0) {
          const after = snapshotWorkDirBytes(workDir);
          const diffs = diffByteSnapshots(before, after);
          if (diffs) errors.push(`Idempotency: workspace changed on rerun:\n  ${diffs.join('\n  ')}`);
        }
      }
    }

    // Post-run validation (on real output, before cleanup)
    let validationError = null;
    if (opts.withValidation && !caseData.expectError && !caseData.skipValidation && exitCode === 0 && skillConfig.postValidate) {
      validationError = await runPostValidationAsync(skillConfig.postValidate, caseData, workDir, opts.runtime);
      if (validationError) errors.push(validationError);
    }

    const elapsed = ((performance.now() - t0) / 1000).toFixed(1);
    return { id: testCase.id, skill: testCase.skillDir, name: testCase.name, passed: errors.length === 0, errors, elapsed: `${elapsed}s`, snapshotUpdated: opts.updateSnapshots && !caseData.expectError && !workspace.readOnly, validationError: !!validationError };
  } catch (e) {
    const elapsed = ((performance.now() - t0) / 1000).toFixed(1);
    return { id: testCase.id, skill: testCase.skillDir, name: testCase.name, passed: false, errors: [`Runner error: ${e.message}`], elapsed: `${elapsed}s` };
  } finally {
    if (workspace) cleanupWorkspace(workspace);
  }
}

function runCase(testCase, opts) {
  const { skillConfig, caseData, snapshotDir } = testCase;
  const t0 = performance.now();
  const setupName = caseData.setup || skillConfig.setup || 'none';
  let workspace = null;
  let workDir = null;
  let inputFile = null;

  try {
    // 1. Setup workspace
    const skillCasesDir = join(CASES, testCase.skillDir);
    const fixturePath = ensureSetup(setupName, opts.runtime, skillCasesDir);
    if (fixturePath === SKIP) {
      const elapsed = ((performance.now() - t0) / 1000).toFixed(1);
      return {
        id: testCase.id,
        skill: testCase.skillDir,
        name: testCase.name,
        passed: true,
        skipped: true,
        errors: [],
        elapsed: `${elapsed}s`,
      };
    }
    const isExternal = typeof setupName === 'string' && setupName.startsWith('external:');
    workspace = createWorkspace(fixturePath, isExternal);
    workDir = workspace.path;

    // 2. Pre-run steps (setup prerequisites like creating objects)
    if (caseData.preRun) {
      for (const step of caseData.preRun) {
        const preScript = resolveScript(step.script, opts.runtime);
        const preArgs = [];
        for (const [flag, value] of Object.entries(step.args || {})) {
          preArgs.push(flag);
          if (value === true || value === '') {
            // Switch parameter — no value
            continue;
          }
          const resolved = String(value)
            .replace('{workDir}', workDir)
            .replace('{inputFile}', '');
          preArgs.push(resolved);
        }
        // Write step input to temp file if needed
        let preInputFile = null;
        if (step.input) {
          preInputFile = join(workDir, '__pre_input.json');
          writeFileSync(preInputFile, JSON.stringify(step.input, null, 2), 'utf8');
          // Replace {inputFile} references in args
          for (let i = 0; i < preArgs.length; i++) {
            if (preArgs[i] === '') preArgs[i] = preInputFile;
          }
        }
        try {
          const preCwd = step.cwd === '{workDir}' ? workDir : undefined;
          execSkillRaw(opts.runtime, preScript, preArgs, preCwd);
        } catch (e) {
          throw new Error(`preRun step "${step.script}" failed: ${e.stderr || e.message}`);
        }
        if (preInputFile && existsSync(preInputFile)) rmSync(preInputFile);
      }
    }

    // 3. Write input JSON if needed
    if (caseData.input !== undefined) {
      inputFile = join(workDir, '__input.json');
      writeFileSync(inputFile, JSON.stringify(caseData.input, null, 2), 'utf8');
    }

    // 4. Build CLI args and execute
    const { scriptPath, args } = buildArgs(skillConfig, caseData, workDir, inputFile, opts.runtime);
    let stdout = '', stderr = '', exitCode = 0;

    try {
      const execCwd = skillConfig.cwd === 'workDir' ? workDir : undefined;
      stdout = execSkillRaw(opts.runtime, scriptPath, args, execCwd);
    } catch (e) {
      exitCode = e.status ?? 1;
      stdout = e.stdout || '';
      stderr = e.stderr || '';
    }

    // Remove temp input file from workDir before snapshot comparison
    if (inputFile && existsSync(inputFile)) rmSync(inputFile);

    // 4. Assertions
    const errors = [];

    if (caseData.expectError) {
      // Negative case — expect failure
      if (exitCode === 0) {
        errors.push('Expected error (non-zero exit) but got exitCode=0');
      }
      if (typeof caseData.expectError === 'string' && !stderr.includes(caseData.expectError)) {
        errors.push(`Expected stderr to contain "${caseData.expectError}", got: ${stderr.substring(0, 200)}`);
      }
    } else {
      // Positive case — expect success
      if (exitCode !== 0) {
        errors.push(`exitCode=${exitCode}\nstdout: ${stdout.substring(0, 300)}\nstderr: ${stderr.substring(0, 300)}`);
      }

      // expect.files
      if (caseData.expect?.files) {
        for (const f of caseData.expect.files) {
          if (!existsSync(join(workDir, f))) {
            errors.push(`Expected file not found: ${f}`);
          }
        }
      }

      // expect.stdoutContains
      if (caseData.expect?.stdoutContains) {
        if (!stdout.includes(caseData.expect.stdoutContains)) {
          errors.push(`stdout does not contain "${caseData.expect.stdoutContains}"`);
        }
      }

      // Snapshot comparison (skip for external/read-only workspaces)
      if (errors.length === 0 && !caseData.expectError && !workspace.readOnly) {
        const snapshotConfig = { ...skillConfig.snapshot, runtime: opts.runtime };
        if (opts.updateSnapshots) {
          updateSnapshot(workDir, snapshotDir, snapshotConfig);
        } else {
          const cmp = compareSnapshot(workDir, snapshotDir, snapshotConfig);
          if (!cmp.match && cmp.diffs) {
            for (const d of cmp.diffs) {
              if (d.type === 'missing') {
                errors.push(`Snapshot: file missing — ${d.file}`);
              } else {
                errors.push(`Snapshot: ${d.file}:${d.line} differs\n  expected: ${d.expected}\n  actual:   ${d.actual}`);
              }
            }
          }
        }
      }

      // Idempotency check: re-run the same script and assert byte-equality.
      if (errors.length === 0 && caseData.idempotent && !workspace.readOnly) {
        const before = snapshotWorkDirBytes(workDir);
        try {
          const execCwd = skillConfig.cwd === 'workDir' ? workDir : undefined;
          execSkillRaw(opts.runtime, scriptPath, args, execCwd);
        } catch (e) {
          errors.push(`Idempotency rerun failed: exitCode=${e.status}\nstderr: ${(e.stderr || '').substring(0, 300)}`);
        }
        if (errors.length === 0) {
          const after = snapshotWorkDirBytes(workDir);
          const diffs = diffByteSnapshots(before, after);
          if (diffs) errors.push(`Idempotency: workspace changed on rerun:\n  ${diffs.join('\n  ')}`);
        }
      }
    }

    // Post-run validation (on real output, before cleanup)
    let validationError = null;
    if (opts.withValidation && !caseData.expectError && !caseData.skipValidation && exitCode === 0 && skillConfig.postValidate) {
      validationError = runPostValidation(skillConfig.postValidate, caseData, workDir, opts.runtime);
      if (validationError) errors.push(validationError);
    }

    const elapsed = ((performance.now() - t0) / 1000).toFixed(1);
    return {
      id: testCase.id,
      skill: testCase.skillDir,
      name: testCase.name,
      passed: errors.length === 0,
      errors,
      elapsed: `${elapsed}s`,
      snapshotUpdated: opts.updateSnapshots && !caseData.expectError && !workspace.readOnly,
      validationError: !!validationError,
    };

  } catch (e) {
    const elapsed = ((performance.now() - t0) / 1000).toFixed(1);
    return {
      id: testCase.id,
      skill: testCase.skillDir,
      name: testCase.name,
      passed: false,
      errors: [`Runner error: ${e.message}`],
      elapsed: `${elapsed}s`,
    };
  } finally {
    if (workspace) cleanupWorkspace(workspace);
  }
}

// ─── Reporter ───────────────────────────────────────────────────────────────

function printReport(results, opts, wallTime) {
  const skipped = results.filter(r => r.skipped);
  const passed = results.filter(r => r.passed && !r.skipped);
  const failed = results.filter(r => !r.passed);

  // Group by skill
  const bySkill = new Map();
  for (const r of results) {
    if (!bySkill.has(r.skill)) bySkill.set(r.skill, []);
    bySkill.get(r.skill).push(r);
  }

  console.log('');

  for (const [skill, cases] of bySkill) {
    const skillPassed = cases.filter(r => r.passed).length;
    const skillTotal = cases.length;
    const skillFailed = cases.filter(r => !r.passed);
    const skillTime = cases.reduce((s, r) => s + parseFloat(r.elapsed), 0).toFixed(1);
    const allOk = skillFailed.length === 0;

    if (opts.verbose) {
      // Verbose: show every case with id
      console.log(`  ${skill}`);
      for (const r of cases) {
        const icon = r.skipped ? '\u25CB' : r.passed ? '\u2713' : r.validationError ? '\u2717' : '\u2717';
        const suffix = r.skipped ? ' [skipped]' : r.snapshotUpdated ? ' [snapshot updated]' : r.validationError ? ' [VFAIL]' : '';
        console.log(`    ${icon} ${r.name} (${r.elapsed})  ${r.id}${suffix}`);
        if (!r.passed) {
          for (const err of r.errors) {
            for (const line of err.split('\n')) {
              console.log(`      ${line}`);
            }
          }
        }
      }
    } else {
      // Compact: one line per skill, details only for failures
      const skillSkipped = cases.filter(r => r.skipped).length;
      const icon = allOk ? '\u2713' : '\u2717';
      const skipSuffix = skillSkipped > 0 ? `, ${skillSkipped} skipped` : '';
      console.log(`  ${icon} ${skill}  ${skillPassed}/${skillTotal} (${skillTime}s${skipSuffix})`);
      if (!allOk) {
        for (const r of skillFailed) {
          console.log(`    \u2717 ${r.name}  ${r.id}`);
          for (const err of r.errors) {
            for (const line of err.split('\n')) {
              console.log(`      ${line}`);
            }
          }
        }
      }
    }
  }

  const cpuTime = results.reduce((s, r) => s + parseFloat(r.elapsed), 0).toFixed(1);
  const vfails = results.filter(r => r.validationError).length;
  console.log('');
  const skippedStr = skipped.length > 0 ? ` | Skipped: ${skipped.length}` : '';
  const vfailStr = vfails > 0 ? ` | VFail: ${vfails}` : '';
  const timeStr = wallTime ? `${wallTime}s wall, ${cpuTime}s cpu` : `${cpuTime}s`;
  console.log(`  Passed: ${passed.length} | Failed: ${failed.length}${vfailStr}${skippedStr} | Total: ${results.length} | Time: ${timeStr}`);
  console.log('');

  if (opts.jsonReport) {
    const report = {
      timestamp: new Date().toISOString(),
      runtime: opts.runtime,
      passed: passed.length,
      failed: failed.length,
      total: results.length,
      results: results.map(r => ({
        id: r.id,
        name: r.name,
        passed: r.passed,
        elapsed: r.elapsed,
        errors: r.errors.length > 0 ? r.errors : undefined,
      })),
    };
    writeFileSync(opts.jsonReport, JSON.stringify(report, null, 2), 'utf8');
    console.log(`  Report: ${opts.jsonReport}`);
  }

  return failed.length === 0;
}

// ─── Parallel pool ─────────────────────────────────────────────────────────

async function runPool(cases, opts) {
  const results = new Array(cases.length);
  let next = 0;

  async function worker() {
    while (next < cases.length) {
      const idx = next++;
      results[idx] = await runCaseAsync(cases[idx], opts);
    }
  }

  const workers = [];
  for (let i = 0; i < Math.min(opts.concurrency, cases.length); i++) {
    workers.push(worker());
  }
  await Promise.all(workers);
  return results;
}

// ─── Integration tests ──────────────────────────────────────────────────────

const INTEGRATION = resolve(ROOT, 'integration');

// ─── Platform context (.v8-project.json) ─────────────────────────────────────

function loadV8Context() {
  const projectFile = join(REPO_ROOT, '.v8-project.json');
  if (!existsSync(projectFile)) return null;
  try {
    const proj = JSON.parse(readFileSync(projectFile, 'utf8'));
    const v8bin = proj.v8path;
    const v8exe = v8bin ? (existsSync(join(v8bin, '1cv8.exe')) ? join(v8bin, '1cv8.exe') : null) : null;
    if (!v8exe) return null;
    const defaultDb = proj.databases?.find(d => d.id === proj.default) || proj.databases?.[0];
    return {
      v8path: v8bin,
      v8exe,
      dbPath: defaultDb?.path || '',
      dbUser: defaultDb?.user || '',
      dbPassword: defaultDb?.password || '',
      configSrc: defaultDb?.configSrc || '',
      databases: proj.databases || [],
    };
  } catch { return null; }
}

async function discoverIntegration(filter) {
  if (!existsSync(INTEGRATION)) return [];
  const results = [];
  for (const file of readdirSync(INTEGRATION)) {
    if (!file.endsWith('.test.mjs')) continue;
    const testName = file.replace(/\.test\.mjs$/, '');
    const id = `integration/${testName}`;
    if (filter && !id.startsWith(filter) && !id.includes(filter)) continue;
    const mod = await import(`file://${join(INTEGRATION, file).replace(/\\/g, '/')}`);
    results.push({ id, name: mod.name || testName, steps: mod.steps || [], file, cache: mod.cache, setup: mod.setup || 'empty-config', requiresPlatform: !!mod.requiresPlatform });
  }
  return results;
}

async function runIntegrationTest(test, opts) {
  const t0 = performance.now();
  const stepResults = [];
  let workspace = null;

  // Skip platform-dependent tests if platform unavailable
  if (test.requiresPlatform && !opts.v8ctx) {
    const elapsed = ((performance.now() - t0) / 1000).toFixed(1);
    return { id: test.id, name: test.name, passed: true, skipped: true, steps: [], elapsed: `${elapsed}s`, errors: [] };
  }

  try {
    // Start from configured fixture or empty workspace
    const fixturePath = test.setup === 'none' ? null : ensureSetup(test.setup, opts.runtime, CASES);
    if (fixturePath === SKIP) {
      const elapsed = ((performance.now() - t0) / 1000).toFixed(1);
      return { id: test.id, name: test.name, passed: true, skipped: true, steps: [], elapsed: `${elapsed}s`, errors: [] };
    }
    workspace = createWorkspace(fixturePath, false);
    const workDir = workspace.path;

    // Platform placeholders
    const v8 = opts.v8ctx || {};
    const replacePlaceholders = (s) => s
      .replace('{workDir}', workDir)
      .replace('{inputFile}', '')
      .replace('{v8path}', v8.v8path || '')
      .replace('{v8exe}', v8.v8exe || '')
      .replace('{dbPath}', v8.dbPath || '')
      .replace('{dbUser}', v8.dbUser || '')
      .replace('{dbPassword}', v8.dbPassword || '')
      .replace('{configSrc}', v8.configSrc || '');

    for (let i = 0; i < test.steps.length; i++) {
      const step = test.steps[i];
      const stepT0 = performance.now();

      // writeFile step: записать содержимое (обычно .bsl модуля) в workDir
      if (step.writeFile) {
        try {
          const target = replacePlaceholders(step.writeFile);
          const abs = target.includes(':') || target.startsWith('/') ? target : join(workDir, target);
          mkdirSync(dirname(abs), { recursive: true });
          writeFileSync(abs, step.content ?? '', 'utf8');
          const stepElapsed = ((performance.now() - stepT0) / 1000).toFixed(1);
          stepResults.push({ name: step.name, passed: true, elapsed: `${stepElapsed}s` });
        } catch (e) {
          stepResults.push({ name: step.name, passed: false, error: `writeFile failed: ${e.message}` });
          break;
        }
        continue;
      }

      // Write input if provided
      let inputFile = null;
      if (step.input) {
        inputFile = join(workDir, '__input.json');
        writeFileSync(inputFile, JSON.stringify(step.input, null, 2), 'utf8');
      }

      // Resolve args: replace placeholders
      const script = resolveScript(step.script, opts.runtime);
      const args = [];
      for (const [flag, value] of Object.entries(step.args || {})) {
        args.push(flag);
        if (value === true) continue; // switch
        let resolved = String(value).replace('{inputFile}', inputFile || '');
        resolved = replacePlaceholders(resolved);
        args.push(resolved);
      }

      // Execute
      let stdout = '', stderr = '';
      try {
        stdout = await execSkillAsync(opts.runtime, script, args);
      } catch (e) {
        const detail = e.stderr?.trim() || e.stdout?.trim() || e.message;
        stepResults.push({ name: step.name, passed: false, error: `Step ${i + 1} failed: ${detail.substring(0, 1000)}` });
        break; // stop on first failure
      }

      if (inputFile && existsSync(inputFile)) rmSync(inputFile);

      // Post-step validation
      if (opts.withValidation && step.validate) {
        const valScript = resolveScript(step.validate.script, opts.runtime);
        let valPath = workDir;
        if (step.validate.path) {
          valPath = join(workDir, step.validate.path);
          if (!existsSync(valPath) && existsSync(valPath + '.xml')) valPath += '.xml';
        }
        try {
          await execSkillAsync(opts.runtime, valScript, [step.validate.flag, valPath]);
        } catch (e) {
          const detail = e.stderr?.trim() || e.stdout?.trim() || e.message;
          stepResults.push({ name: step.name, passed: false, error: `Validation: ${detail.substring(0, 500)}` });
          break;
        }
      }

      const stepElapsed = ((performance.now() - stepT0) / 1000).toFixed(1);
      stepResults.push({ name: step.name, passed: true, elapsed: `${stepElapsed}s` });
    }

    // Cache result if configured
    if (test.cache && stepResults.every(s => s.passed)) {
      const cachePath = join(CACHE, test.cache);
      if (existsSync(cachePath)) rmSync(cachePath, { recursive: true, force: true });
      cpSync(workDir, cachePath, { recursive: true });
    }

    const allPassed = stepResults.every(s => s.passed);
    const elapsed = ((performance.now() - t0) / 1000).toFixed(1);
    return { id: test.id, name: test.name, passed: allPassed, steps: stepResults, elapsed: `${elapsed}s`, errors: allPassed ? [] : stepResults.filter(s => !s.passed).map(s => s.error) };
  } catch (e) {
    const elapsed = ((performance.now() - t0) / 1000).toFixed(1);
    return { id: test.id, name: test.name, passed: false, steps: stepResults, elapsed: `${elapsed}s`, errors: [`Runner error: ${e.message}`] };
  } finally {
    if (workspace) cleanupWorkspace(workspace);
  }
}

function printIntegrationReport(results, opts) {
  console.log('');
  for (const r of results) {
    const icon = r.skipped ? '\u25CB' : r.passed ? '\u2713' : '\u2717';
    const suffix = r.skipped ? ' [skipped — no platform]' : '';
    console.log(`  ${icon} ${r.name} (${r.elapsed})  ${r.id}${suffix}`);
    for (const step of r.steps) {
      const sIcon = step.passed ? '\u2713' : '\u2717';
      console.log(`    ${sIcon} ${step.name}${step.elapsed ? ` (${step.elapsed})` : ''}`);
      if (!step.passed) {
        for (const line of step.error.split('\n')) {
          console.log(`      ${line}`);
        }
      }
    }
  }
  const passed = results.filter(r => r.passed).length;
  const failed = results.filter(r => !r.passed).length;
  console.log('');
  console.log(`  Integration: Passed: ${passed} | Failed: ${failed} | Total: ${results.length}`);
  console.log('');
  return failed === 0;
}

// ─── Main ───────────────────────────────────────────────────────────────────

async function main() {
  const opts = parseArgs(process.argv);
  if (opts.help) { printHelp(); return; }
  mkdirSync(CACHE, { recursive: true });

  // Load platform context for platform-dependent tests
  opts.v8ctx = loadV8Context();

  const isIntegrationFilter = opts.filter && opts.filter.startsWith('integration');

  // Run integration tests if filter matches or no filter (run both)
  let integrationOk = true;
  if (isIntegrationFilter || !opts.filter) {
    const integrationTests = await discoverIntegration(opts.filter);
    if (integrationTests.length > 0) {
      const valStr = opts.withValidation ? ', +validation' : '';
      console.log(`\nRunning ${integrationTests.length} integration test(s)... [runtime: ${opts.runtime}${valStr}]`);
      const integrationResults = [];
      for (const test of integrationTests) {
        integrationResults.push(await runIntegrationTest(test, opts));
      }
      integrationOk = printIntegrationReport(integrationResults, opts);
    }
  }

  // Run unit cases (skip if filter is purely integration)
  let casesOk = true;
  if (!isIntegrationFilter) {
    const cases = discoverCases(opts.filter);
    if (cases.length > 0) {
      const parallel = opts.concurrency > 1;
      const modeStr = parallel ? `${opts.concurrency} workers` : 'sequential';
      const valStr = opts.withValidation ? ', +validation' : '';
      console.log(`\nRunning ${cases.length} test(s)... [runtime: ${opts.runtime}, ${modeStr}${valStr}]`);

      // Pre-warm shared fixtures before parallel run
      const setups = new Set(cases.map(c => c.caseData.setup || c.skillConfig.setup || 'none'));
      for (const setup of setups) {
        if (setup === 'empty-config' || setup === 'base-config') {
          try { ensureSetup(setup, opts.runtime, CASES); } catch {}
        }
      }

      const wallStart = performance.now();
      let results;
      if (parallel) {
        results = await runPool(cases, opts);
      } else {
        results = [];
        for (const tc of cases) {
          results.push(await runCaseAsync(tc, opts));
        }
      }
      const wallTime = ((performance.now() - wallStart) / 1000).toFixed(1);
      casesOk = printReport(results, opts, wallTime);
    } else if (opts.filter && !isIntegrationFilter) {
      console.log('No test cases found.' + (opts.filter ? ` Filter: "${opts.filter}"` : ''));
    }
  }

  process.exit(integrationOk && casesOk ? 0 : 1);
}

main();