IO

1// File-IO helpers shared across the pipeline. Mirrors the conventions of
2// browser-trace/scripts/lib.mjs. Node stdlib only.
3
4import fs from 'node:fs';
5import path from 'node:path';
6
7export function ensureDir(p) {
8  fs.mkdirSync(p, { recursive: true });
9}
10
11export function readJsonl(p) {
12  if (!fs.existsSync(p)) return [];
13  const out = [];
14  for (const line of fs.readFileSync(p, 'utf8').split('\n')) {
15    if (!line) continue;
16    try { out.push(JSON.parse(line)); } catch { /* skip malformed */ }
17  }
18  return out;
19}
20
21export function writeJsonl(p, items) {
22  ensureDir(path.dirname(p));
23  const body = items.length ? items.map(o => JSON.stringify(o)).join('\n') + '\n' : '';
24  fs.writeFileSync(p, body);
25}
26
27export function readJson(p, fallback = null) {
28  if (!fs.existsSync(p)) return fallback;
29  try { return JSON.parse(fs.readFileSync(p, 'utf8')); }
30  catch { return fallback; }
31}
32
33export function writeJson(p, obj) {
34  ensureDir(path.dirname(p));
35  fs.writeFileSync(p, JSON.stringify(obj, null, 2) + '\n');
36}
37
38export function writeText(p, s) {
39  ensureDir(path.dirname(p));
40  fs.writeFileSync(p, s);
41}
42
43export function resolveRun(runArg) {
44  // Accept both bare run-id and full path.
45  if (fs.existsSync(runArg) && fs.statSync(runArg).isDirectory()) return path.resolve(runArg);
46  const root = process.env.O11Y_ROOT || '.o11y';
47  const guess = path.join(root, runArg);
48  if (fs.existsSync(guess)) return path.resolve(guess);
49  throw new Error(`run path not found: ${runArg} (tried ${guess})`);
50}
51
52export function intermediatePath(outDir, name) {
53  return path.join(outDir, 'intermediate', name);
54}
55
56export function samplePath(outDir, method, pathHash) {
57  return path.join(outDir, 'samples', `${method.toLowerCase()}__${pathHash}.json`);
58}