Function readEntries

hooks_src/doc-sync.js:74–90

(queuePath)

}

function readEntries(queuePath) {
  if (!fs.existsSync(queuePath)) return { exists: false, entries: [], malformed: 0 };
  const raw = fs.readFileSync(queuePath, 'utf8');
  const lines = raw.split('\n').filter(line => line.trim().length > 0);
  const entries = [];
  let malformed = 0;

  for (const line of lines) {
    try {
      entries.push(JSON.parse(line));
    } catch {
      malformed++;
    }
  }

  return { exists: true, entries, malformed };
}

function eventTime(entry) {
  return entry.timestamp || entry.time || entry.created_at || null;