Function cleanExpiredAgentJobKeys

lib/maintenance.js:9–59

()

const ONE_HOUR = 60 * 60 * 1000;

async function cleanExpiredAgentJobKeys() {
  try {
    const db = getDb();
    const rows = db
      .select({ id: settings.id, key: settings.key, lastUsedAt: settings.lastUsedAt, createdAt: settings.createdAt })
      .from(settings)
      .where(eq(settings.type, 'agent_job_api_key'))
      .all();

    // Split into SDK keys (no container) vs container-backed keys
    const sdkRows = rows.filter(r => r.key.includes('sdk'));
    const containerRows = rows.filter(r => !r.key.includes('sdk'));

    let deleted = 0;

    // SDK keys: delete any older than 1 hour (no container to inspect)
    const sdkCutoff = Date.now() - ONE_HOUR;
    for (const r of sdkRows) {
      const age = r.lastUsedAt !== null ? r.lastUsedAt : r.createdAt;
      if (age < sdkCutoff) {
        db.delete(settings).where(eq(settings.id, r.id)).run();
        deleted++;
      }
    }

    // Container-backed keys: existing logic — 24h expiry + container inspect
    const containerCutoff = Date.now() - TWENTY_FOUR_HOURS;
    const candidates = containerRows.filter(r =>
      (r.lastUsedAt !== null ? r.lastUsedAt : r.createdAt) < containerCutoff
    );

    if (candidates.length > 0) {
      const { inspectContainer } = await import('./tools/docker.js');
      for (const r of candidates) {
        const info = await inspectContainer(r.key);
        if (!info) {
          db.delete(settings).where(eq(settings.id, r.id)).run();
          deleted++;
        }
      }
    }

    if (deleted > 0) {
      console.log(`[maintenance] Deleted ${deleted} expired agent job key(s)`);
    } else {
      console.log(`[maintenance] No expired agent job keys (${rows.length} active)`);
    }
  } catch (err) {
    console.error('[maintenance] cleanExpiredAgentJobKeys failed:', err);
  }
}

async function runMaintenance() {
  console.log('[maintenance] Running maintenance...');