feature/supply-priority-expiration

.env.local

@@ -10,4 +10,10 @@ DATABASE_URL="postgresql://${DB_USER}:${DB_PASSWORD}@${DB_HOST}:${DB_PORT}/${DB_
 SECRET_KEY=batata
 
 HOST=::0.0.0.0
-PORT=4000
+PORT=4000
+
+# In hours
+SHELTER_SUPPLY_PRIORITY_EXPIRY_INTERVAL=4 
+
+# Every 30 minutes
+SHELTER_SUPPLY_PRIORITY_JOB_INTERVAL="0 */30 * * * *" 

src/app.module.ts

@@ -1,5 +1,6 @@
 import { MiddlewareConsumer, Module, NestModule } from '@nestjs/common';
 import { APP_INTERCEPTOR } from '@nestjs/core';
+import { ScheduleModule } from '@nestjs/schedule';
 
 import { PrismaModule } from './prisma/prisma.module';
 import { ShelterModule } from './shelter/shelter.module';
@@ -15,6 +16,7 @@ import { ShelterSupplyModule } from './shelter-supply/shelter-supply.module';
 @Module({
   imports: [
     PrismaModule,
+    ScheduleModule.forRoot(),
     UsersModule,
     SessionsModule,
     ShelterModule,

src/shelter-supply/constants.ts

@@ -0,0 +1,8 @@
+const jobInterval: string =
+  process.env.SHELTER_SUPPLY_PRIORITY_JOB_INTERVAL ?? '0 */30 * * * *';
+
+const priorityExpiryInterval: number = Number.parseInt(
+  process.env.SHELTER_SUPPLY_PRIORITY_EXPIRY_INTERVAL ?? '4',
+);
+
+export { jobInterval, priorityExpiryInterval };

src/shelter-supply/shelter-supply-expiration.job.ts

@@ -0,0 +1,35 @@
+import { Injectable, Logger } from '@nestjs/common';
+import { Cron } from '@nestjs/schedule';
+import { PrismaService } from '../prisma/prisma.service';
+import { addHours } from '@/utils';
+import { priorityExpiryInterval, jobInterval } from './constants';
+import { SupplyPriority } from '../supply/types';
+import { ShelterSupplyService } from './shelter-supply.service';
+
+@Injectable()
+export class ShelterSupplyExpirationJob {
+  constructor(
+    private readonly prismaService: PrismaService,
+    private readonly shelterSupplyService: ShelterSupplyService,
+  ) {}
+
+  private readonly logger = new Logger(ShelterSupplyExpirationJob.name);
+
+  @Cron(jobInterval)
+  async handleCron() {
+    this.logger.log(`${ShelterSupplyExpirationJob.name} running`);
+
+    const expiryDate = addHours(new Date(Date.now()), -priorityExpiryInterval);
+    await this.prismaService.shelterSupply.updateMany({
+      data: {
+        priority: SupplyPriority.Needing,
+      },
+      where: {
+        priority: SupplyPriority.Urgent,
+        createdAt: {
+          lte: expiryDate,
+        },
+      },
+    });
+  }
+}

src/shelter-supply/shelter-supply.module.ts

@@ -3,10 +3,11 @@ import { Module } from '@nestjs/common';
 import { ShelterSupplyService } from './shelter-supply.service';
 import { ShelterSupplyController } from './shelter-supply.controller';
 import { PrismaModule } from '../prisma/prisma.module';
+import { ShelterSupplyExpirationJob } from './shelter-supply-expiration.job';
 
 @Module({
   imports: [PrismaModule],
-  providers: [ShelterSupplyService],
+  providers: [ShelterSupplyService, ShelterSupplyExpirationJob],
   controllers: [ShelterSupplyController],
 })
 export class ShelterSupplyModule {}

src/utils/index.ts

@@ -4,6 +4,7 @@ import {
   getSessionData,
   deepMerge,
   capitalize,
+  addHours,
 } from './utils';
 
 export {
@@ -12,4 +13,5 @@ export {
   removeNotNumbers,
   getSessionData,
   deepMerge,
+  addHours,
 };

src/utils/utils.ts

@@ -75,10 +75,17 @@ function deepMerge(target: Record<string, any>, source: Record<string, any>) {
   }
 }
 
+function addHours(date: Date, hours: number) {
+  const result = new Date();
+  result.setTime(date.getTime() + hours * 60 * 60 * 1000);
+  return result;
+}
+
 export {
   ServerResponse,
   removeNotNumbers,
   getSessionData,
   deepMerge,
   capitalize,
+  addHours,
 };