Function main

packages/db/scripts/check-sessions.ts:222–419

()

}

async function main() {
  const args = process.argv.slice(2);
  const verbose = args.includes('--verbose');
  const projectIdx = args.indexOf('--project');
  const projectFilter = projectIdx >= 0 ? args[projectIdx + 1] : null;
  const hoursIdx = args.indexOf('--hours');
  const hours = hoursIdx >= 0 ? Number(args[hoursIdx + 1]) : 24;

  const redis = getRedisCache();

  console.log('═'.repeat(70));
  console.log('SESSION LIFECYCLE HEALTH CHECK');
  console.log(`time:           ${new Date().toISOString()}`);
  console.log(`deadman:        ${DEADMAN_MS / 60_000} min`);
  console.log(`stuck cutoff:   ${STUCK_CUTOFF_MS / 60_000} min (deadman + 3 reaper ticks)`);
  console.log(`ch window:      ${hours}h`);
  if (projectFilter) console.log(`project:        ${projectFilter}`);
  console.log('═'.repeat(70));

  // 1. Redis inventory
  const allProjects = await redis.smembers('session:projects');
  const projects = projectFilter
    ? [projectFilter]
    : allProjects.slice().sort();

  header('REDIS — active sessions');
  console.log(`  ${allProjects.length} projects in session:projects`);

  const redisInfo = await inspectRedis(projects);
  console.log(`  ${redisInfo.total} total active sessions`);
  console.log(`  ${redisInfo.totalEligible} past deadman (expected to reap soon)`);
  console.log(
    `  ${redisInfo.totalStuck} past deadman + ${STUCK_GRACE_MS / 60_000}min (stuck — reaper is behind)`
  );
  console.log(
    `  ${redisInfo.totalOrphans} wallclock entries with no blob (in sampled ${SAMPLE_SIZE_PER_PROJECT}/project)`
  );

  if (verbose && redisInfo.stats.length > 0) {
    console.log('');
    console.log(
      `  ${'project'.padEnd(40)} ${'active'.padStart(8)} ${'eligible'.padStart(10)} ${'stuck'.padStart(8)} ${'orphans'.padStart(8)} ${'oldest'.padStart(10)}`
    );
    for (const s of redisInfo.stats.sort((a, b) => b.active - a.active)) {
      console.log(
        `  ${s.project.padEnd(40)} ${fmt(s.active, 8)} ${fmt(s.eligible, 10)} ${fmt(s.stuck, 8)} ${fmt(s.orphans, 8)} ${s.oldestAgeMin.toFixed(1).padStart(8)}m`
      );
    }
  }

  // 2. Sessions queue
  header('SESSIONS QUEUE — createSessionEnd jobs');
  const queue = await inspectQueue();
  console.log(`  waiting:   ${queue.waiting}`);
  console.log(`  delayed:   ${queue.delayed}`);
  console.log(`  active:    ${queue.active}`);
  console.log(`  failed:    ${queue.failed}`);
  console.log(`  completed: ${queue.completed} (removed-on-complete)`);