Function main

hooks_src/instructions-loaded.js:45–107

()

}

function main() {
  let input = '';
  process.stdin.setEncoding('utf8');
  process.stdin.on('data', (chunk) => { input += chunk; });
  process.stdin.on('end', () => {
    let event = {};
    try { event = JSON.parse(input); } catch { /* partial input ok */ }

    const filePath = event.file_path || event.path || null;
    const sessionId = event.session_id || null;

    health.increment('instructions-loaded', 'count');

    health.logTiming('instructions-loaded', 0, {
      event: 'instructions-loaded',
      file: filePath ? path.relative(PROJECT_ROOT, filePath).replace(/\\/g, '/') : null,
      session_id: sessionId,
    });

    if (!filePath) {
      process.exit(0);
      return;
    }

    const relativePath = path.relative(PROJECT_ROOT, filePath).replace(/\\/g, '/');

    // Check if the file has changed since we last saw it
    try {
      const state = readState();
      let mtime = null;
      try {
        mtime = fs.statSync(filePath).mtimeMs;
      } catch { /* file may be virtual */ }

      const lastSeen = state[relativePath] || null;
      const changed = mtime !== null && lastSeen !== null && mtime > lastSeen;

      if (changed) {
        // Queue a doc-sync review for this file
        const queuePath = path.join(TELEMETRY_DIR, 'doc-sync-queue.jsonl');
        if (fs.existsSync(TELEMETRY_DIR)) {
          const entry = JSON.stringify({
            event: 'instructions-changed',
            file: relativePath,
            timestamp: new Date().toISOString(),
            status: 'needs-review',
            prev_mtime: lastSeen,
            curr_mtime: mtime,
          });
          fs.appendFileSync(queuePath, entry + '\n');
        }
      }

      // Update last-seen mtime
      if (mtime !== null) {
        state[relativePath] = mtime;
        writeState(state);
      }