Function readAllEvents

src/gep/assetStore.js:474–509

()

}

function readAllEvents() {
  try {
    const p = eventsPath();
    if (!fs.existsSync(p)) return [];
    const stat = fs.statSync(p);
    const fullReadCap = _eventsFullReadMaxBytes();
    if (stat.size <= fullReadCap) {
      const raw = fs.readFileSync(p, 'utf8');
      return raw.split('\n').map(l => l.trim()).filter(Boolean).map(l => {
        try { return JSON.parse(l); } catch { return null; }
      }).filter(Boolean);
    }
    // Large file: tail-read to avoid OOM. Drop the first line ONLY when the
    // chunk does not cover the whole file (readPos > 0), because in that case
    // it can be cut mid-JSON. When chunkSize === stat.size the read starts at
    // 0 and the first line is the actual start-of-file -- discarding it would
    // silently lose a complete event. Bugbot caught this on PR #31.
    const chunkSize = Math.min(stat.size, _eventsTailReadBytes());
    const readPos = stat.size - chunkSize;
    const fd = fs.openSync(p, 'r');
    try {
      const buf = Buffer.alloc(chunkSize);
      fs.readSync(fd, buf, 0, chunkSize, readPos);
      const lines = buf.toString('utf8').split('\n').map(l => l.trim()).filter(Boolean);
      const intact = readPos > 0 && lines.length > 1 ? lines.slice(1) : lines;
      return intact.map(l => {
        try { return JSON.parse(l); } catch { return null; }
      }).filter(Boolean);
    } finally {
      fs.closeSync(fd);
    }
  } catch (e) {
    console.warn('[AssetStore] Failed to read events.jsonl:', e && e.message || e);
    return [];
  }
}

function appendEventJsonl(eventObj) {
  const dir = getGepAssetsDir(); ensureDir(dir);