Function runScan

scripts/watch.js:470–613

(opts)

// -- Commands -----------------------------------------------------------------

function runScan(opts) {
  const currentHead = getCurrentHead();

  if (!currentHead) {
    console.error('[watch] Not a git repository or git not available.');
    process.exit(1);
  }

  if (!acquireLock()) {
    // Another process holds the lock. If it recorded a scan start within the
    // overlap window, this is a concurrent scan: skip cleanly.
    const lockedState = readState();
    const startedAt = lockedState.scanStartedAt
      ? Date.parse(lockedState.scanStartedAt)
      : NaN;
    if (Number.isFinite(startedAt) && Date.now() - startedAt < SCAN_OVERLAP_MS) {
      const ageSec = Math.max(0, Math.round((Date.now() - startedAt) / 1000));
      console.log(
        `[watch] Scan skipped: another scan (pid ${lockedState.scanPid ?? 'unknown'}) started ${ageSec}s ago and still holds the lock.`
      );
      process.exit(0);
    }
    console.error(
      `[watch] Could not acquire state lock after ${LOCK_RETRIES} attempts. Remove ${path.relative(ROOT, LOCK_PATH)} if no scan is running.`
    );
    process.exit(1);
  }

  // process.exit() skips finally blocks, so all exits below happen only after
  // this try/finally has released the lock.
  let outputText;
  try {
    const state = readState();
    state.scanStartedAt = new Date().toISOString();
    state.scanPid = process.pid;
    writeState(state);

    const changedFiles = getChangedFiles(state.lastScanCommit);

    // Scan for markers in changed files that exist on disk
    const allMarkers = [];
    for (const relFile of changedFiles) {
      const fullPath = path.join(ROOT, relFile);
      if (fs.existsSync(fullPath)) {
        const markers = scanFileForMarkers(fullPath, relFile);
        allMarkers.push(...markers);
      }
    }

    const categories = categorizeFiles(changedFiles);

    // Dedup markers by hash; write intake items only for never-seen markers
    const intakeFiles = [];
    const existingIntakeHashes =
      opts.intake && allMarkers.length > 0 ? readExistingIntakeHashes() : new Set();
    const now = new Date().toISOString();

    for (const marker of allMarkers) {