index.ts

import pino from 'pino';
import cron from 'node-cron';
import { env } from "./env";

const logger = pino({ name: 'anomaly-worker', level: env.LOG_LEVEL });

let isRunning = false;
let isShuttingDown = false;

async function runDetectionCycle() {
  if (isRunning || isShuttingDown) {
    return;
  }

  isRunning = true;
  logger.info("Starting anomaly detection cycle...");

  try {
    const { NotificationsService } = await import('@monitor-app/app/server/domain/notifications/service');
    const service = new NotificationsService();
    
    await service.notifyNewAnomalies();
    logger.info("Anomaly detection cycle finished.");
  } catch (error) {
    logger.error({ err: error }, "Error during detection cycle.");
  } finally {
    isRunning = false;
  }
}

const task = cron.schedule('30 * * * *', runDetectionCycle);
logger.info("Anomaly worker scheduled (30 * * * *).");

runDetectionCycle();

process.on('SIGTERM', async () => {
  isShuttingDown = true;
  task.stop();

  if (isRunning) {
    logger.info("Waiting for the current detection cycle to complete...");
    
    const shutdownTimeout = setTimeout(() => {
      logger.error("Shutdown timed out; forcing exit.");
      process.exit(1);
    }, 20000);

    while (isRunning) {
      await new Promise(resolve => setTimeout(resolve, 500));
    }
    
    clearTimeout(shutdownTimeout);
  }

  logger.info("Shutdown complete.");
  process.exit(0);
});