inject buffer service, implement drain

server/src/config/services.worker.ts

@@ -136,6 +136,7 @@ export const buildWorker = async (shared: SharedServices, envSettings: EnvConfig
 		monitorsRepository,
 		checksRepository,
 		checkService,
+		bufferService,
 		checkProducer,
 		checkEvaluator,
 		geoCheckPipeline,

server/src/shutdown.ts

@@ -24,6 +24,7 @@ export const initShutdownListener = (server: Server | null, services: ShutdownTa
 
 		try {
 			server?.close();
+			await services.worker.drain();
 			await services.worker.shutdown();
 			await services.db.disconnect();
 			logger.info({ message: "Graceful shutdown complete" });

server/src/worker/worker.job-scheduler.ts

@@ -154,6 +154,10 @@ export class JobScheduler implements IJobScheduler {
 		return { success: true };
 	};
 
+	drain = async () => {
+		this.stopped = true;
+	};
+
 	shutdown = async () => {
 		this.stopped = true;
 		// Stop all timers