feat: cron

package.json

@@ -34,6 +34,7 @@
     "@nestjs/mapped-types": "*",
     "@nestjs/passport": "^10.0.3",
     "@nestjs/platform-express": "^10.0.0",
+    "@nestjs/schedule": "^4.1.1",
     "@nestjs/swagger": "^7.4.0",
     "@nomicfoundation/hardhat-ignition": "^0.15.5",
     "@nomicfoundation/hardhat-toolbox": "^5.0.0",

src/common/providers/schedule.module.ts

@@ -0,0 +1,7 @@
+import { Module } from '@nestjs/common';
+import { ScheduleModule } from '@nestjs/schedule';
+
+@Module({
+  imports: [ScheduleModule.forRoot()],
+})
+export class SHOCKIScheduleModule {}

src/modules/product/product.service.ts

@@ -8,6 +8,7 @@ import {
   NotFoundException,
 } from '@nestjs/common';
 import { ConfigService } from '@nestjs/config';
+import { Cron, CronExpression } from '@nestjs/schedule';
 
 import { PrismaService } from 'src/common/modules/prisma/prisma.service';
 import { S3Service } from 'src/common/modules/s3/s3.service';
@@ -554,6 +555,29 @@ export class ProductService {
     });
   }
 
+  @Cron(CronExpression.EVERY_MINUTE)
+  async authSale() {
+    const users = await this.prisma.user.findMany({
+      select: {
+        id: true,
+      },
+    });
+    const products = await this.prisma.product.findMany({
+      select: {
+        id: true,
+      },
+      where: {
+        type: ProductType.FUNDING,
+      },
+    });
+
+    for (const user of users) {
+      for (const product of products) {
+        await this.saleProductToken(user.id, product.id);
+      }
+    }
+  }
+
   async saleProductToken(userId: string, productId: string) {
     const product = await this.prisma.product.findUnique({
       select: {