Function inspectRedis

packages/db/scripts/check-sessions.ts:57–111

(projects: string[])

}

async function inspectRedis(projects: string[]): Promise<{
  total: number;
  totalEligible: number;
  totalStuck: number;
  totalOrphans: number;
  stats: ProjectStat[];
}> {
  const redis = getRedisCache();
  const now = Date.now();
  const eligibleCutoff = now - DEADMAN_MS;
  const stuckCutoff = now - STUCK_CUTOFF_MS;

  const stats: ProjectStat[] = [];
  let total = 0;
  let totalEligible = 0;
  let totalStuck = 0;
  let totalOrphans = 0;

  for (const project of projects) {
    const wallclockKey = `session:wallclock:${project}`;

    const [active, eligible, stuck, oldestEntry] = await Promise.all([
      redis.zcard(wallclockKey),
      redis.zcount(wallclockKey, '-inf', eligibleCutoff),
      redis.zcount(wallclockKey, '-inf', stuckCutoff),
      redis.zrange(wallclockKey, 0, 0, 'WITHSCORES'),
    ]);

    const oldestAgeMin =
      oldestEntry.length === 2 ? (now - Number(oldestEntry[1])) / 60_000 : 0;

    // Sample N oldest entries and verify their blob exists.
    const sampleSize = Math.min(SAMPLE_SIZE_PER_PROJECT, active);
    let orphans = 0;
    if (sampleSize > 0) {
      const sample = await redis.zrange(wallclockKey, 0, sampleSize - 1);
      const multi = redis.multi();
      for (const did of sample) {
        multi.exists(`session:${project}:${did}`);
      }
      const results = await multi.exec();
      for (const entry of results ?? []) {
        if (Number(entry?.[1] ?? 0) === 0) orphans++;
      }
    }

    stats.push({ project, active, eligible, stuck, orphans, oldestAgeMin });
    total += active;
    totalEligible += eligible;
    totalStuck += stuck;
    totalOrphans += orphans;
  }

  return { total, totalEligible, totalStuck, totalOrphans, stats };
}

async function inspectQueue() {
  const [waiting, delayed, active, failed, completed] = await Promise.all([