Daemon アイドル検出インターフェース設計

// GET /health?deep=true
{
  "status": "ok",
 
  // --- 既存フィールド（変更なし）---
  "sessions": 2,
  "pendingPermissions": 0,
 
  // --- 新規フィールド ---
  "activePrompts": 1, // 現在 prompt を実行中の session 数
  "connectedClients": 3, // アクティブな SSE 接続数
  "channelAlive": true, // agent サブプロセスが生存しているか
  "lastActivityAt": "2026-06-10T08:30:00.000Z", // 最終活動時刻（ISO 8601）
  "idleSinceMs": 120000, // 最終活動からの経過ミリ秒
}

def should_reclaim(health, idle_threshold_ms=300_000):
    """推奨リクレーム条件：アイドル時間が閾値（デフォルト5分）を超えた場合"""
    if health["activePrompts"] > 0:
        return False  # タスク実行中
    if health["connectedClients"] > 0:
        return False  # クライアント接続中
    if health["idleSinceMs"] is None:
        # 一度も活動なし — 起動直後の cold daemon である可能性
        return True
    return health["idleSinceMs"] >= idle_threshold_ms

/** 現在 prompt を実行中の session 数 */
get activePromptCount(): number;
 
/** 最終活動時刻（エポックミリ秒）、null は一度も活動なし */
get lastActivityAt(): number | null;

// 新規状態追跡
let lastActivityTimestamp: number | null = null;
 
function touchActivity(): void {
  lastActivityTimestamp = Date.now();
}

get activePromptCount() {
  let count = 0;
  for (const entry of byId.values()) {
    if (entry.promptActive) count++;
  }
  return count;
},
 
get lastActivityAt() {
  return lastActivityTimestamp;
},

const healthHandler = (req: Request, res: Response): void => {
  const deepQuery = req.query['deep'];
  const deep = deepQuery === '1' || deepQuery === 'true' || deepQuery === '';
  if (!deep) {
    res.status(200).json({ status: 'ok' });
    return;
  }
  try {
    const lastActivityAt = bridge.lastActivityAt;
    const now = Date.now();
    res.status(200).json({
      status: 'ok',
      // 既存
      sessions: bridge.sessionCount,
      pendingPermissions: bridge.pendingPermissionCount,
      // 新規
      activePrompts: bridge.activePromptCount,
      connectedClients: getActiveSseCount(),
      channelAlive: bridge.isChannelLive(),
      lastActivityAt:
        lastActivityAt !== null ? new Date(lastActivityAt).toISOString() : null,
      idleSinceMs: lastActivityAt !== null ? now - lastActivityAt : null,
    });
  } catch (err) {
    writeStderrLine(
      `qwen serve: /health deep probe failed: ${err instanceof Error ? err.message : String(err)}`,
    );
    res.status(503).json({ status: 'degraded' });
  }
};