Merge pull request #627 from dump-hr/lukazuljevic/626-auto-close-fly-talk-applications

Lukazuljevic/626 auto close fly talk applications

Author: lukazuljevic

apps/api/.eslintrc.js

@@ -0,0 +1,28 @@
+import js from '@eslint/js';
+import globals from 'globals';
+import reactHooks from 'eslint-plugin-react-hooks';
+import reactRefresh from 'eslint-plugin-react-refresh';
+import tseslint from 'typescript-eslint';
+
+export default tseslint.config(
+  { ignores: ['dist'] },
+  {
+    extends: [js.configs.recommended, ...tseslint.configs.recommended],
+    files: ['**/*.{ts,tsx}'],
+    languageOptions: {
+      ecmaVersion: 2020,
+      globals: globals.browser,
+    },
+    plugins: {
+      'react-hooks': reactHooks,
+      'react-refresh': reactRefresh,
+    },
+    rules: {
+      ...reactHooks.configs.recommended.rules,
+      'react-refresh/only-export-components': [
+        'warn',
+        { allowConstantExport: true },
+      ],
+    },
+  },
+);

apps/api/eslint.config.js

@@ -26,6 +26,7 @@
     "@nestjs/passport": "^10.0.3",
     "@nestjs/platform-express": "^10.0.0",
     "@nestjs/platform-socket.io": "^10.3.8",
+    "@nestjs/schedule": "^6.0.1",
     "@nestjs/serve-static": "^4.0.0",
     "@nestjs/swagger": "^7.1.16",
     "@nestjs/websockets": "^10.3.8",
@@ -35,6 +36,7 @@
     "bcrypt": "^5.1.1",
     "class-transformer": "^0.5.1",
     "class-validator": "0.13.2",
+    "cron": "^4.3.3",
     "dotenv": "^16.3.1",
     "google-auth-library": "^10.3.0",
     "http-proxy-middleware": "^2.0.6",
@@ -64,6 +66,7 @@
     "eslint-config-ddays": "*",
     "eslint-config-prettier": "^9.0.0",
     "eslint-plugin-prettier": "^5.0.0",
+    "eslint-plugin-react-hooks": "^7.0.0",
     "eslint-plugin-simple-import-sort": "^12.1.1",
     "jest": "^29.5.0",
     "prettier": "^3.0.0",
@@ -73,6 +76,7 @@
     "ts-node": "^10.9.1",
     "tsconfig-paths": "^4.2.0",
     "tsx": "^4.2.0",
-    "typescript": "5.8.2"
+    "typescript": "5.8.2",
+    "typescript-eslint": "^8.46.2"
   }
 }

apps/api/package.json

@@ -3,6 +3,7 @@ import { BadRequestException, Injectable, PipeTransform } from '@nestjs/common';
 
 @Injectable()
 class AchievementNameValidationPipe implements PipeTransform {
+  //eslint-disable-next-line @typescript-eslint/no-explicit-any
   transform(value: any) {
     const achievementNames = Object.values(AchievementNames);
 

apps/api/src/achievement/achievement.validator.ts

@@ -29,9 +29,11 @@ import { SponsorContractModule } from './sponsor-contract/sponsor-contract.modul
 import { SponsorMaterialsModule } from './sponsor-materials/sponsor-materials.module';
 import { SurveyQuestionModule } from './survey-question/survey-question.module';
 import { UserModule } from './user/user.module';
+import { ScheduleModule } from '@nestjs/schedule';
 
 @Module({
   imports: [
+    ScheduleModule.forRoot(),
     BlobModule,
     AuthModule,
     AchievementModule,

apps/api/src/app.module.ts

@@ -105,6 +105,8 @@ export class CompanyController {
       selected: boolean;
       companyId: number;
     },
+    //TODO: Replace any with proper type
+    //eslint-disable-next-line @typescript-eslint/no-explicit-any
   ): Promise<any> {
     return await this.companyService.selectApplicant(
       body.user,

apps/api/src/company/company.controller.ts

@@ -4,9 +4,10 @@ import { PrismaService } from 'src/prisma.service';
 
 import { EventController } from './event.controller';
 import { EventService } from './event.service';
+import { EventScheduler } from './event.scheduler';
 
 @Module({
   controllers: [EventController],
-  providers: [EventService, PrismaService, BlobService],
+  providers: [EventService, PrismaService, BlobService, EventScheduler],
 })
 export class EventModule {}

apps/api/src/event/event.module.ts

@@ -0,0 +1,23 @@
+import { Injectable} from '@nestjs/common';
+import { Cron } from '@nestjs/schedule';
+import { EventService } from './event.service';
+import { FLY_TALK_APPLICATION_STATUS_CRON } from '@ddays-app/types';
+
+@Injectable()
+export class EventScheduler {
+  constructor(private readonly eventService: EventService) {}
+
+  @Cron(FLY_TALK_APPLICATION_STATUS_CRON, { timeZone: 'Europe/Zagreb' })
+  async handleFlyTalkStatusUpdate() {
+    console.log('Starting Fly Talk application status update job');
+    const flyTalkEvents = await this.eventService.getAllFlyTalks();
+
+    for (const event of flyTalkEvents) {
+      try {
+        await this.eventService.updateFlyTalkApplicationStatus(event.id);
+      } catch (error) {
+        console.log(`Failed to update event ${event.id}`, error);
+      }
+    }
+  }
+}

apps/api/src/event/event.scheduler.ts

@@ -603,6 +603,37 @@ export class EventService {
     }));
   }
 
+  async getAllFlyTalks(): Promise<EventDto[]> {
+    const flyTalks = await this.prisma.event.findMany({
+      where: {
+        type: EventType.FLY_TALK,
+      },
+    });
+
+    return flyTalks;
+  }
+
+  async updateFlyTalkApplicationStatus(eventId: number): Promise<EventDto> {
+    const event = await this.prisma.event.findUnique({
+      where: { id: eventId },
+    });
+
+    console.log(`Updating application status for event ID: ${eventId}`);
+
+    if (!event) {
+      throw new NotFoundException(`Event with id ${eventId} not found`);
+    }
+
+    const updatedEvent = await this.prisma.event.update({
+      where: { id: eventId },
+      data: {
+        isApplicationOpen: false,
+      },
+    });
+
+    return updatedEvent;
+  }
+
   async getApplicationStatus(
     userId: number,
     flyTalkId: number,

apps/api/src/event/event.service.ts

@@ -3,7 +3,7 @@ import {
   SpeakerModifyDto,
   SpeakerWithCompanyDto,
 } from '@ddays-app/types';
-import { Injectable } from '@nestjs/common';
+import { Injectable, NotFoundException } from '@nestjs/common';
 import { BlobService } from 'src/blob/blob.service';
 import { PrismaService } from 'src/prisma.service';
 
@@ -38,7 +38,7 @@ export class SpeakerService {
     });
 
     if (!foundSpeaker) {
-      throw new Error('Speaker not found');
+      throw new NotFoundException('Speaker not found');
     }
 
     return foundSpeaker;
@@ -74,7 +74,7 @@ export class SpeakerService {
 
       return deletedSpeaker;
     } catch (error) {
-      throw new Error('Speaker not found');
+      throw new Error(error as string);
     }
   }