introduce the push notification for the airport

src/airport/airport.controller.ts

@@ -8,6 +8,7 @@ import {
   Query,
   HttpException,
   HttpStatus,
+  Sse,
   UseGuards,
 } from '@nestjs/common';
 import { ApiBody, ApiQuery, ApiResponse } from '@nestjs/swagger';
@@ -33,11 +34,16 @@ import { ActiveRunwaysDto } from './dto/activerunways.dto';
 import { Runway } from './models/runway.model';
 import { RunwayDto } from './dto/runway.dto';
 import { AirportOverviewDto } from './dto/airportoverview.dto';
+import { Observable } from 'rxjs';
+import { EventsService } from '../events/events.service';
 import { JwtGuard } from 'src/auth/guards/jwt.guard';
 
 @Controller('airport')
 export class AirportController {
-  constructor(private readonly airportService: AirportService) {}
+  constructor(
+    private readonly airportService: AirportService,
+    private readonly eventService: EventsService,
+  ) {}
 
   private static convertConstraint<T>(
     constraint: Constraint | ConstraintDto,
@@ -248,6 +254,11 @@ export class AirportController {
     });
   }
 
+  @Sse('/renew')
+  renew(): Observable<unknown> {
+    return this.eventService.subscribeAirportRenew();
+  }
+
   @UseGuards(JwtGuard)
   @Get('/all')
   @ApiResponse({

src/airport/airport.module.ts

@@ -3,10 +3,12 @@ import { MongooseModule } from '@nestjs/mongoose';
 import { AirportSchema } from './models/airport.model';
 import { AirportService } from './airport.service';
 import { AirportController } from './airport.controller';
+import { EventsModule } from 'src/events/events.module';
 
 @Module({
   imports: [
     MongooseModule.forFeature([{ name: 'airport', schema: AirportSchema }]),
+    EventsModule,
   ],
   providers: [AirportService],
   controllers: [AirportController],