Function startSessionCleanup

server/src/training-agent/state.ts:418–444

()

/** Start the TTL cleanup interval. Deletes stale sessions from the store. */
export function startSessionCleanup(): void {
  if (cleanupTimer) return;
  cleanupTimer = setInterval(async () => {
    try {
      if (isDatabaseInitialized()) {
        const { rowCount } = await getPool().query(
          `DELETE FROM adcp_state WHERE collection = $1 AND updated_at < NOW() - ($2 || ' milliseconds')::interval`,
          [SESSIONS_COLLECTION, String(SESSION_TTL_MS)],
        );
        if ((rowCount ?? 0) > 0) {
          logger.info({ deleted: rowCount }, 'Cleaned up expired training-agent sessions');
        }
        const taskDeleted = await cleanupExpiredTasks(getPool());
        if (taskDeleted > 0) {
          logger.info({ deleted: taskDeleted }, 'Cleaned up expired MCP tasks');
        }
        const idempDeleted = await cleanupExpiredIdempotency(getPool());
        if (idempDeleted > 0) {
          logger.info({ deleted: idempDeleted }, 'Cleaned up expired idempotency entries');
        }
      }
    } catch (err) {
      logger.warn({ err }, 'Session/task cleanup failed');
    }
  }, CLEANUP_INTERVAL_MS);
  if (cleanupTimer.unref) cleanupTimer.unref();
}

export function stopSessionCleanup(): void {
  if (cleanupTimer) {