mirror of
https://github.com/Nikolay-Shirokov/cc-1c-skills.git
synced 2026-07-27 07:01:02 +03:00
Nick ShirokovandClaude Opus 5
d05aef54b4
Три навыка для работы с пакетами XDTO. Формат описания — обычная XSD, своего DSL нет: рутину снимает конвертер (локальные объявления префиксов dNpM на каждой ссылке, инвертированная кратность lowerBound/upperBound, фасеты атрибутами вместо дочерних элементов, обязательный порядок элементов верхнего уровня). То, чего XSD выразить не может — nillable у атрибута, qualified у свойства, «атрибут записан явно» — едет атрибутами из пространства имён модели XDTO по правилу «то же имя, что в Package.bin». Свойства объекта метаданных живут в xs:appinfo, поэтому пара decompile → compile замыкается без потерь. Инвариант bin → xsd → bin проверен побайтово на 760 пакетах выгрузок Бухгалтерии и ERP 8.3.24 (харнесс debug/xdto/roundtrip-corpus.mjs). Сборка из рукописной XSD проверена загрузкой в базу 8.3.24 — именно она вскрыла обязательный порядок import→property→valueType→objectType, невидимый для корпусной сверки: все выгрузки уже канонические. xdto-validate ловит два класса тихих дефектов, которые платформа не диагностирует: подмену неразрешённого чужого типа на xs:anyType при импорте XML-схемы и nillable у свойства-атрибута, теряемый экспортом схемы в Конфигураторе. Тесты: 18 снэпшот-кейсов на синтетических схемах (типовые конфигурации в репозиторий не тащим), паритет PS↔PY на общих эталонах. Раннер получил caseFiles — копирование файлов кейса в workDir для навыков с файловым, а не JSON входом. Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
1382 lines
58 KiB
JavaScript
1382 lines
58 KiB
JavaScript
#!/usr/bin/env node
|
||
// skill-test-runner v0.5 — 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;
|
||
}
|
||
|
||
// Пустые конфигурации-фикстуры. Версия формата и режим совместимости — независимые оси:
|
||
// формат задаёт платформа выгрузки, а режим влияет на дефолт <LineNumberLength> у ТЧ
|
||
// (<=8_3_26 → 5, >=8_3_27 → 9). Отсюда две 2.20-фикстуры с разными режимами.
|
||
const EMPTY_CONFIGS = {
|
||
'empty-config': [],
|
||
'empty-config-220': ['-FormatVersion', '2.20', '-CompatibilityMode', 'Version8_3_27'],
|
||
'empty-config-220-compat24': ['-FormatVersion', '2.20', '-CompatibilityMode', 'Version8_3_24'],
|
||
};
|
||
if (EMPTY_CONFIGS[setupName]) {
|
||
const cached = join(CACHE, setupName);
|
||
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, ...EMPTY_CONFIGS[setupName]]);
|
||
} catch (e) {
|
||
rmSync(cached, { recursive: true, force: true });
|
||
throw new Error(`Failed to create ${setupName} 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, opts = {}) {
|
||
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. Strip xmlns declarations (Python etree strips unused ones).
|
||
// Skipped for Configuration.xml: those declarations are load-bearing (they back
|
||
// xsi:type values like app:ApplicationUsePurpose in UsePurposes) and dropping them
|
||
// is exactly the corruption of issue #38 — keeping them lets the test guard against it.
|
||
if (!opts.keepXmlns) {
|
||
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, relFile) {
|
||
// 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') {
|
||
const base = relFile ? relFile.split(/[\\/]/).pop() : '';
|
||
s = normalizeXmlContent(s, { keepXmlns: base === 'Configuration.xml' });
|
||
}
|
||
|
||
// 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;
|
||
}
|
||
|
||
// ─── Byte-style preservation check (round-trip #44/#46/#47) ─────────────────
|
||
// Проверяет СЫРЫЕ байты файла (в обход normalizeContent): BOM / EOL / регистр
|
||
// encoding / финальный перенос / отсутствие . spec: { file, bom, eol:"crlf"|"lf",
|
||
// encoding, finalNewline, noCR13 }. Возвращает массив ошибок.
|
||
function checkPreserves(workDir, spec) {
|
||
const errs = [];
|
||
const target = join(workDir, spec.file);
|
||
if (!existsSync(target)) { errs.push(`preserves: file not found: ${spec.file}`); return errs; }
|
||
const buf = readFileSync(target);
|
||
const hasBom = buf[0] === 0xEF && buf[1] === 0xBB && buf[2] === 0xBF;
|
||
const body = hasBom ? buf.subarray(3) : buf;
|
||
const text = body.toString('utf8');
|
||
if (spec.bom !== undefined && hasBom !== spec.bom)
|
||
errs.push(`preserves: BOM expected ${spec.bom}, got ${hasBom}`);
|
||
if (spec.eol) {
|
||
const hasCR = body.includes(0x0d);
|
||
const wantCR = spec.eol === 'crlf';
|
||
if (hasCR !== wantCR) errs.push(`preserves: EOL expected ${spec.eol} (CR=${wantCR}), got CR=${hasCR}`);
|
||
}
|
||
if (spec.encoding) {
|
||
const m = /encoding="([^"]+)"/.exec(text);
|
||
if (!m || m[1] !== spec.encoding) errs.push(`preserves: encoding expected "${spec.encoding}", got "${m ? m[1] : '?'}"`);
|
||
}
|
||
if (spec.finalNewline !== undefined) {
|
||
const endsNL = body.length > 0 && body[body.length - 1] === 0x0a;
|
||
if (endsNL !== spec.finalNewline) errs.push(`preserves: finalNewline expected ${spec.finalNewline}, got ${endsNL}`);
|
||
}
|
||
if (spec.noCR13 && text.includes(' ')) errs.push(`preserves: unexpected literal in output`);
|
||
return errs;
|
||
}
|
||
|
||
// ─── 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();
|
||
}
|
||
|
||
// Строгий режим: отсутствие эталона НЕ проходит молча. Кейс либо сверяется со снэпшотом,
|
||
// либо явно объявляет `"noSnapshot": "<причина>"`. Иначе потерянный (или не созданный при
|
||
// добавлении кейса) эталон неотличим от намеренного отсутствия — тест зелёный, а не проверяет ничего.
|
||
function compareSnapshot(workDir, snapshotDir, snapshotConfig, caseData) {
|
||
const optOut = caseData?.noSnapshot;
|
||
const hasSnapshotDir = existsSync(snapshotDir) && listFilesRecursive(snapshotDir).length > 0;
|
||
|
||
if (optOut !== undefined && optOut !== false) {
|
||
// Причина обязательна: opt-out должен стоить автору формулировки, а ревьюеру — быть виден в diff'е.
|
||
if (typeof optOut !== 'string' || !optOut.trim()) return { match: false, badOptOut: true };
|
||
// Мёртвый эталон: помечен как ненужный, но лежит в репозитории — выглядит покрытием, не сверяется.
|
||
if (hasSnapshotDir) return { match: false, deadSnapshot: true };
|
||
return { match: true, reason: `no snapshot (opt-out: ${optOut})` };
|
||
}
|
||
|
||
if (!hasSnapshotDir) return { match: false, missingSnapshot: true };
|
||
|
||
const snapshotFiles = listFilesRecursive(snapshotDir);
|
||
|
||
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, relFile);
|
||
const expected = normalizeContent(snapshotRaw, snapshotConfig, relFile);
|
||
|
||
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 };
|
||
}
|
||
|
||
// Диагностика снэпшот-сверки — общая для обеих веток запуска (runCase / runCaseAsync),
|
||
// чтобы сообщения и условия не разъехались.
|
||
function snapshotErrors(cmp, caseId) {
|
||
if (cmp.match) return [];
|
||
if (cmp.badOptOut) {
|
||
return [`Snapshot: "noSnapshot" должен быть непустой строкой с причиной, почему эталон не нужен`];
|
||
}
|
||
if (cmp.deadSnapshot) {
|
||
return [`Snapshot: кейс объявил "noSnapshot", но эталон существует — он не сверяется и вводит в заблуждение.\n`
|
||
+ ` Удалите каталог snapshots/<кейс>/ либо снимите "noSnapshot"`];
|
||
}
|
||
if (cmp.missingSnapshot) {
|
||
return [`Snapshot: эталон отсутствует. Создайте:\n`
|
||
+ ` node tests/skills/runner.mjs ${caseId} --update-snapshots\n`
|
||
+ `либо объявите в кейсе: "noSnapshot": "<почему эталон не нужен>"`];
|
||
}
|
||
const errs = [];
|
||
for (const d of cmp.diffs || []) {
|
||
if (d.type === 'missing') errs.push(`Snapshot: file missing — ${d.file}`);
|
||
else errs.push(`Snapshot: ${d.file}:${d.line} differs\n expected: ${d.expected}\n actual: ${d.actual}`);
|
||
}
|
||
return errs;
|
||
}
|
||
|
||
function updateSnapshot(workDir, snapshotDir, snapshotConfig, caseData) {
|
||
// Кейс объявил, что эталон не нужен — не создаём. Иначе --update-snapshots по навыку
|
||
// дорисовал бы эталон и сам породил противоречие с opt-out.
|
||
if (caseData?.noSnapshot) return;
|
||
|
||
// 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, relFile);
|
||
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;
|
||
|
||
// runtimeOnly: gate a case to a single port (e.g. a .cmd fake platform only runs via
|
||
// PowerShell's Start-Process; python's list-exec can't launch it). Skipped elsewhere.
|
||
if (caseData.runtimeOnly && caseData.runtimeOnly !== opts.runtime) {
|
||
return { id: testCase.id, skill: testCase.skillDir, name: testCase.name, passed: true, skipped: true, errors: [], elapsed: '0.0s' };
|
||
}
|
||
|
||
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;
|
||
copyCaseFiles(caseData, workDir, skillCasesDir);
|
||
|
||
// 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);
|
||
mkdirSync(dirname(wfPath), { recursive: true });
|
||
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) {
|
||
const needles = Array.isArray(caseData.expect.stdoutContains)
|
||
? caseData.expect.stdoutContains : [caseData.expect.stdoutContains];
|
||
for (const needle of needles) {
|
||
if (!stdout.includes(needle)) errors.push(`stdout does not contain "${needle}"`);
|
||
}
|
||
}
|
||
if (caseData.expect?.stdoutNotContains) {
|
||
const needles = Array.isArray(caseData.expect.stdoutNotContains)
|
||
? caseData.expect.stdoutNotContains : [caseData.expect.stdoutNotContains];
|
||
for (const needle of needles) {
|
||
if (stdout.includes(needle)) errors.push(`stdout unexpectedly contains "${needle}"`);
|
||
}
|
||
}
|
||
if (caseData.expect?.preserves) {
|
||
const specs = Array.isArray(caseData.expect.preserves)
|
||
? caseData.expect.preserves : [caseData.expect.preserves];
|
||
for (const spec of specs) errors.push(...checkPreserves(workDir, spec));
|
||
}
|
||
if (errors.length === 0 && !caseData.expectError && !workspace.readOnly) {
|
||
const snapshotConfig = { ...skillConfig.snapshot, runtime: opts.runtime };
|
||
if (opts.updateSnapshots) {
|
||
updateSnapshot(workDir, snapshotDir, snapshotConfig, caseData);
|
||
} else {
|
||
const cmp = compareSnapshot(workDir, snapshotDir, snapshotConfig, caseData);
|
||
errors.push(...snapshotErrors(cmp, testCase.id));
|
||
}
|
||
}
|
||
|
||
// 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);
|
||
}
|
||
}
|
||
|
||
// Скопировать файлы из каталога кейса в workDir — для навыков, вход которых
|
||
// не JSON, а файл (например XSD для xdto-compile). Так эталонные входы остаются
|
||
// читаемыми файлами, а не строками внутри JSON кейса.
|
||
function copyCaseFiles(caseData, workDir, skillCasesDir) {
|
||
if (!caseData.caseFiles) return;
|
||
for (const rel of caseData.caseFiles) {
|
||
const src = join(skillCasesDir, rel);
|
||
if (!existsSync(src)) throw new Error(`caseFiles: файл не найден: ${src}`);
|
||
// Путь со слэшем сохраняет структуру каталогов (напр. дерево пакета),
|
||
// простое имя кладётся в корень workDir
|
||
const dst = rel.includes('/') ? join(workDir, rel) : join(workDir, basename(rel));
|
||
mkdirSync(dirname(dst), { recursive: true });
|
||
copyFileSync(src, dst);
|
||
}
|
||
}
|
||
|
||
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;
|
||
copyCaseFiles(caseData, workDir, skillCasesDir);
|
||
|
||
// 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 / stdoutNotContains (string or array)
|
||
if (caseData.expect?.stdoutContains) {
|
||
const needles = Array.isArray(caseData.expect.stdoutContains)
|
||
? caseData.expect.stdoutContains : [caseData.expect.stdoutContains];
|
||
for (const needle of needles) {
|
||
if (!stdout.includes(needle)) errors.push(`stdout does not contain "${needle}"`);
|
||
}
|
||
}
|
||
if (caseData.expect?.stdoutNotContains) {
|
||
const needles = Array.isArray(caseData.expect.stdoutNotContains)
|
||
? caseData.expect.stdoutNotContains : [caseData.expect.stdoutNotContains];
|
||
for (const needle of needles) {
|
||
if (stdout.includes(needle)) errors.push(`stdout unexpectedly contains "${needle}"`);
|
||
}
|
||
}
|
||
if (caseData.expect?.preserves) {
|
||
const specs = Array.isArray(caseData.expect.preserves)
|
||
? caseData.expect.preserves : [caseData.expect.preserves];
|
||
for (const spec of specs) errors.push(...checkPreserves(workDir, spec));
|
||
}
|
||
|
||
// 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, caseData);
|
||
} else {
|
||
const cmp = compareSnapshot(workDir, snapshotDir, snapshotConfig, caseData);
|
||
errors.push(...snapshotErrors(cmp, testCase.id));
|
||
}
|
||
}
|
||
|
||
// 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;
|
||
// Platform executable names: Windows uses .exe; *nix (macOS/Linux) plain names.
|
||
const exeName = process.platform === 'win32' ? '1cv8.exe' : '1cv8';
|
||
const ibcmdName = process.platform === 'win32' ? 'ibcmd.exe' : 'ibcmd';
|
||
const v8exe = v8bin && existsSync(join(v8bin, exeName)) ? join(v8bin, exeName) : null;
|
||
if (!v8exe) return null;
|
||
const ibcmdExe = v8bin && existsSync(join(v8bin, ibcmdName)) ? join(v8bin, ibcmdName) : null;
|
||
const defaultDb = proj.databases?.find(d => d.id === proj.default) || proj.databases?.[0];
|
||
return {
|
||
v8path: v8bin,
|
||
v8exe,
|
||
ibcmdExe,
|
||
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, '/')}`);
|
||
const engines = Array.isArray(mod.engines) && mod.engines.length ? mod.engines : ['1cv8'];
|
||
results.push({ id, name: mod.name || testName, steps: mod.steps || [], file, cache: mod.cache, setup: mod.setup || 'empty-config', requiresPlatform: !!mod.requiresPlatform, engines });
|
||
}
|
||
return results;
|
||
}
|
||
|
||
// Run a test once per declared engine (engine matrix). The ibcmd pass swaps
|
||
// {v8path} → ibcmd.exe so the same steps exercise the ibcmd opt-in branch.
|
||
async function runIntegrationTest(test, opts) {
|
||
const engines = test.engines && test.engines.length ? test.engines : ['1cv8'];
|
||
// No platform at all → single skipped result (don't multiply across engines)
|
||
if (test.requiresPlatform && !opts.v8ctx) {
|
||
return [{ id: test.id, name: test.name, passed: true, skipped: true, skipReason: 'no platform', steps: [], elapsed: '0.0s', errors: [] }];
|
||
}
|
||
const out = [];
|
||
const labelEngine = engines.length > 1;
|
||
for (const engine of engines) {
|
||
out.push(await runIntegrationOnce(test, opts, engine, labelEngine));
|
||
}
|
||
return out;
|
||
}
|
||
|
||
async function runIntegrationOnce(test, opts, engine, labelEngine) {
|
||
const t0 = performance.now();
|
||
const stepResults = [];
|
||
let workspace = null;
|
||
const idSuffix = labelEngine ? ` [${engine}]` : '';
|
||
const id = test.id + idSuffix;
|
||
const name = test.name + idSuffix;
|
||
|
||
// ibcmd pass requires ibcmd.exe alongside 1cv8.exe
|
||
if (engine === 'ibcmd' && !opts.v8ctx?.ibcmdExe) {
|
||
const elapsed = ((performance.now() - t0) / 1000).toFixed(1);
|
||
return { id, name, passed: true, skipped: true, skipReason: 'no ibcmd.exe', 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, name, passed: true, skipped: true, skipReason: 'fixture unavailable', steps: [], elapsed: `${elapsed}s`, errors: [] };
|
||
}
|
||
workspace = createWorkspace(fixturePath, false);
|
||
const workDir = workspace.path;
|
||
|
||
// Platform placeholders. {v8path} resolves to ibcmd.exe on the ibcmd pass
|
||
// (engine detected by exe name) and to the bin dir otherwise (auto-resolves 1cv8.exe).
|
||
const v8 = opts.v8ctx || {};
|
||
const v8pathForEngine = engine === 'ibcmd' ? (v8.ibcmdExe || '') : (v8.v8path || '');
|
||
const replacePlaceholders = (s) => s
|
||
.replace('{workDir}', workDir)
|
||
.replace('{inputFile}', '')
|
||
.replace('{v8path}', v8pathForEngine)
|
||
.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;
|
||
}
|
||
|
||
// editFile step: substring replace in an existing file (e.g. inject a marker)
|
||
if (step.editFile) {
|
||
try {
|
||
const target = replacePlaceholders(step.editFile);
|
||
const abs = target.includes(':') || target.startsWith('/') ? target : join(workDir, target);
|
||
let txt = readFileSync(abs, 'utf8');
|
||
if (!txt.includes(step.replace)) throw new Error(`pattern not found: ${step.replace}`);
|
||
txt = txt.replace(step.replace, replacePlaceholders(step.with ?? ''));
|
||
writeFileSync(abs, txt, '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: `editFile failed: ${e.message}` });
|
||
break;
|
||
}
|
||
continue;
|
||
}
|
||
|
||
// assertContains step: fail unless target file contains the expected substring
|
||
if (step.assertContains) {
|
||
try {
|
||
const target = replacePlaceholders(step.assertContains);
|
||
const abs = target.includes(':') || target.startsWith('/') ? target : join(workDir, target);
|
||
const txt = existsSync(abs) ? readFileSync(abs, 'utf8') : '';
|
||
const needle = replacePlaceholders(step.expect ?? '');
|
||
if (!txt.includes(needle)) throw new Error(`"${needle}" not found in ${target}`);
|
||
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: `assert 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, 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, 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 — ${r.skipReason || '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();
|