// src/runtime/session-file-gc.ts
//
// 概率性清理过期 subagent session 文件（TTL 30 天）。
// session_start 时调用，best-effort（失败不影响启动）。

import * as fs from "node:fs";
import * as path from "node:path";

import { isProcessAlive, readAliveMarker } from "./alive-store.ts";

/** 30 天 TTL（毫秒）。 */
const TTL_DAYS = 30;
const HOURS_PER_DAY = 24;
const MINUTES_PER_HOUR = 60;
const SECONDS_PER_MINUTE = 60;
const MS_PER_SECOND = 1000;
const TTL_MS = TTL_DAYS * HOURS_PER_DAY * MINUTES_PER_HOUR * SECONDS_PER_MINUTE * MS_PER_SECOND;

/** 触发概率（1/20 = 5%，避免每次 session_start 都全扫）。 */
const CLEANUP_PROBABILITY_DIVISOR = 20;
const CLEANUP_PROBABILITY = 1 / CLEANUP_PROBABILITY_DIVISOR;

/** subagent session 文件目录（相对 agentDir）。 */
const SUBAGENTS_DIR = "subagents";

/**
 * 概率性清理过期 session 文件。best-effort——任何异常不外抛。
 *
 *   1. 概率性触发（CLEANUP_PROBABILITY）
 *   2. 递归扫描 <agentDir>/subagents 下所有 .jsonl 文件
 *   3. mtime 超 TTL → unlink
 */
export function maybeCleanupExpiredSessionFiles(agentDir: string, cwd: string): void {
  void cwd;
  try {
    if (Math.random() >= CLEANUP_PROBABILITY) return;
    const dir = path.join(agentDir, SUBAGENTS_DIR);
    if (!fs.existsSync(dir)) return;
    const now = Date.now();
    walkAndClean(dir, now);
  } catch (_e) {
    // best-effort：任何异常不阻断 session_start
    void _e;
  }
}

/** 递归扫描目录，unlink 超 TTL 的 .jsonl 文件及其 .cancelled sidecar。
 *  [F2] 进入名为 records 的子目录时，额外清理超 TTL 的 manifest .json（跳过 .tmp.——
 *  recoverTmpFiles 同步处理）。allowManifestJson 仅由父调用按目录名开启，其他位置
 *  （如 subagents/worktrees.json）不匹配 .json，避免误删 worktree reaper 状态文件。 */
function walkAndClean(dir: string, now: number, allowManifestJson = false): void {
  let entries: fs.Dirent[];
  try {
    entries = fs.readdirSync(dir, { withFileTypes: true });
  } catch (_e) {
    void _e;
    return;
  }
  for (const entry of entries) {
    const full = path.join(dir, entry.name);
    if (entry.isDirectory()) {
      // 只在进入名为 records 的子目录时打开 manifest .json 清理。
      // records 在 <enc>/records/ 下递归自动覆盖；其他位置（如 subagents/worktrees.json）
      // 不能匹配 .json——否则会误删 worktree reaper 依赖的状态文件。
      walkAndClean(full, now, entry.name === "records");
    } else if (
      allowManifestJson &&
      entry.name.endsWith(".json") &&
      // 跳过 .tmp.：recoverTmpFiles（session_start）同步处理 tmp，GC 不重复。
      // 不校验内容——30 天 mtime 已是强 orphan 信号，扩展名 + 文件名足够。
      !entry.name.includes(".tmp.")
    ) {
      try {
        const stat = fs.statSync(full);
        if (now - stat.mtimeMs > TTL_MS) {
          fs.unlinkSync(full);
        }
      } catch (_e) {
        // 文件可能已被删除，忽略
        void _e;
      }
    } else if (entry.name.endsWith(".jsonl")) {
      try {
        const stat = fs.statSync(full);
        if (now - stat.mtimeMs > TTL_MS) {
          // .alive 探活：活进程的 session 不删（D-024 安全网）。
          const aliveMarker = readAliveMarker(full);
          if (aliveMarker !== undefined && isProcessAlive(aliveMarker.pid)) {
            continue; // 活进程 → 跳过，不清理
          }
          fs.unlinkSync(full);
          // 同名 sidecar 一起清理。
          for (const ext of [".cancelled", ".finalized", ".alive"]) {
            try { fs.unlinkSync(`${full}${ext}`); } catch (_e) { void _e; /* sidecar 可能不存在 */ }
          }
        }
      } catch (_e) {
        // 文件可能已被删除，忽略
        void _e;
      }
    } else if (
      entry.name.endsWith(".cancelled") ||
      entry.name.endsWith(".finalized") ||
      entry.name.endsWith(".alive") ||
      // [MF#2] patch 回传（<branch>.patch）按 branch 命名，与 .jsonl basename 无关联，
      // 删除 .jsonl 时无法同删；作为孤儿按 TTL 清理，避免永久堆积。
      entry.name.endsWith(".patch")
    ) {
      // 孤儿 sidecar（兄弟 .jsonl 已被外部删除）：按同 TTL 清理。
      try {
        const stat = fs.statSync(full);
        if (now - stat.mtimeMs > TTL_MS) {
          fs.unlinkSync(full);
        }
      } catch (_e) {
        void _e;
      }
    }
  }
}