Function updateQueue

hooks_src/doc-sync.js:202–217

(queuePath, entries, summary, options = {})

}

function updateQueue(queuePath, entries, summary, options = {}) {
  const now = options.now || new Date().toISOString();
  const fileSet = new Set(summary.files.map(item => item.file));
  const deletedSet = new Set(summary.deleted);
  const generalSet = new Set(summary.general);

  const updated = entries.map((entry) => {
    if (!ACTIONABLE_STATUSES.has(entry.status)) return entry;
    if (entry.file && fileSet.has(entry.file)) return { ...entry, status: 'surfaced', surfacedAt: now };
    if (deletedSet.has(entry)) return { ...entry, status: 'skipped-deleted', surfacedAt: now };
    if (generalSet.has(entry)) return { ...entry, status: 'surfaced', surfacedAt: now };
    return entry;
  });

  fs.writeFileSync(queuePath, updated.map(entry => JSON.stringify(entry)).join('\n') + (updated.length ? '\n' : ''), 'utf8');
}

function processDocSyncQueue(projectRoot, options = {}) {
  const queuePath = path.join(projectRoot, '.planning', 'telemetry', 'doc-sync-queue.jsonl');