agentDeleteWorker.js

Go to the documentation of this file.

// agentDeleteWorker.js - Redis-based agent deletion worker
const pool = require('./db');
const Redis = require('ioredis');
const redisConfig = require('../config/redis');
const redis = new Redis(redisConfig);
 
/**
 *
 */
async function checkAndDeleteAgents() {
  const stream = redis.scanStream({ match: 'agent:delete:*' });
  stream.on('data', async (keys) => {
    for (const key of keys) {
      const ttl = await redis.ttl(key);
      if (ttl === -2) { // Key expired
        const agent_uuid = key.split(':').pop();
        try {
          await pool.query('DELETE FROM agents WHERE agent_uuid = $1', [agent_uuid]);
          console.log(`[AgentDeleteWorker] Deleted agent ${agent_uuid} from DB.`);
        } catch (err) {
          console.error(`[AgentDeleteWorker] Failed to delete agent ${agent_uuid}:`, err);
        }
      }
    }
  });
}
 
// Run every hour
setInterval(checkAndDeleteAgents, 60 * 60 * 1000);
console.log('[AgentDeleteWorker] Started agent deletion worker.');