Adding monitoring queue

src/monitoring/config.ts

@@ -0,0 +1 @@
+export const MONITORING_QUEUE_NAME = 'monitoring'

src/monitoring/module.ts

@@ -1,13 +1,20 @@
+import { BullModule } from '@nestjs/bull'
 import { Module } from '@nestjs/common'
 import { TypeOrmModule } from '@nestjs/typeorm'
 
 import { LoggerModule } from '../logger/module'
 import { NtfyModule } from '../ntfy/module'
+import { MONITORING_QUEUE_NAME } from './config'
 import { Monitor } from './entity'
 import { MonitorsService } from './service'
 
 @Module({
-	imports: [LoggerModule, NtfyModule, TypeOrmModule.forFeature([Monitor])],
+	imports: [
+		LoggerModule,
+		NtfyModule,
+		TypeOrmModule.forFeature([Monitor]),
+		BullModule.registerQueueAsync({ name: MONITORING_QUEUE_NAME }),
+	],
 	providers: [MonitorsService],
 	exports: [MonitorsService],
 })

src/monitoring/worker.ts

@@ -0,0 +1,22 @@
+import { Process, Processor } from '@nestjs/bull'
+import { Inject } from '@nestjs/common'
+import { Job } from 'bull'
+
+import { MONITORING_QUEUE_NAME } from './config'
+import { MonitorType } from './entity'
+import { MonitorsService } from './service'
+
+@Processor(MONITORING_QUEUE_NAME)
+export class MonitoringWorker {
+	constructor(
+		@Inject(MonitorsService)
+		private readonly monitorsService: MonitorsService,
+	) {}
+
+	@Process()
+	async handleMonitoringCourtsJob(
+		job: Job<{ type: MonitorType; data: unknown }>,
+	) {
+		await this.monitorsService.performMonitor(job.data.type, job.data.data)
+	}
+}

src/reservations/worker.ts

@@ -10,9 +10,9 @@ import {
 	NoCourtAvailableError,
 } from '../runner/baanreserveren/service'
 import { RESERVATIONS_QUEUE_NAME } from './config'
+import { DAILY_RESERVATIONS_ATTEMPTS } from './cron'
 import { Reservation } from './entity'
 import { ReservationsService } from './service'
-import { DAILY_RESERVATIONS_ATTEMPTS } from './cron'
 
 @Processor(RESERVATIONS_QUEUE_NAME)
 export class ReservationsWorker {