Function main

hooks_src/session-end.js:69–117

()

    fs.writeFileSync(path.join(telemetryDir, 'session-end.lock'), sessionId, 'utf8');
  } catch { /* non-critical */ }
}

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 sessionId = event.session_id || null;

    // Idempotency: skip if we've already run for this session_id.
    // This is what makes the hook safe under Codex's SessionEnd→Stop collapse.
    if (alreadyFiredForSession(sessionId)) {
      process.exit(0);
    }
    recordFiredForSession(sessionId);

    health.increment('session-end', 'count');

    // Log session end
    health.logTiming('session-end', 0, {
      event: 'session-end',
      session_id: sessionId,
    });

    // Log session cost data to telemetry
    logSessionCost(event);

    // Increment trust counters for contextual appropriateness
    incrementTrustCounters();

    // Check for active campaigns and mark continuation point
    markCampaignContinuation();

    // Clean up expired dynamic directories per organization manifest
    cleanupDynamicDirectories();

    // Sweep expired consent markers, one-time tokens, and stale lockdirs
    runStateHygiene();

    // Update daemon state if this was a daemon-driven session
    updateDaemonState();

    // Write doc sync queue entry (Tier 6 - processed by next session or doc-sync hook)
    queueDocSync();

    // Snapshot only opted-in durable knowledge. Active execution state,
    // telemetry, consent, and runtime configuration never enter this store.
    syncRepositoryMemory();