Resolve INotificationRepository injection and update NotificationController

Author: sourcecode71

package-lock.json

@@ -21,10 +21,12 @@
   },
   "dependencies": {
     "@nestjs/common": "^11.0.1",
+    "@nestjs/config": "^4.0.2",
     "@nestjs/core": "^11.0.1",
     "@nestjs/mongoose": "^11.0.3",
     "@nestjs/platform-express": "^11.0.1",
     "@types/joi": "^17.2.2",
+    "dotenv": "^16.5.0",
     "joi": "^17.13.3",
     "mongoose": "^8.13.2",
     "reflect-metadata": "^0.2.2",

package.json

@@ -1,10 +1,13 @@
 import { Module } from '@nestjs/common';
-import { AppController } from './app.controller';
-import { AppService } from './app.service';
+import { MongooseModule } from '@nestjs/mongoose';
+import { ConfigModule } from '@nestjs/config';
+import { NotificationModule } from './notification/notification.module';
 
 @Module({
-  imports: [],
-  controllers: [AppController],
-  providers: [AppService],
+  imports: [
+    ConfigModule.forRoot({ isGlobal: true }),
+    MongooseModule.forRoot('mongodb://localhost:27017/smartedu'),
+    NotificationModule,
+  ],
 })
 export class AppModule {}

src/app.module.ts

@@ -7,6 +7,10 @@ import { NotificationChannel } from 'src/config/notification.config';
 
 @Injectable()
 export class NotificationFactory {
+  // eslint-disable-next-line @typescript-eslint/no-unused-vars
+  static create(_arg0: any): INotificationStrategy {
+    throw new Error('Method not implemented.');
+  }
   constructor(
     private readonly emailStrategy: EmailNotificationStrategy,
     private readonly smsStrategy: SMSNotificationStrategy,

src/application/factories/common/notification.factory.ts

@@ -47,11 +47,7 @@ export class SendNotificationUseCase {
     // Send notification
     const strategy: INotificationStrategy =
       NotificationFactory.create(mediaType);
-    await strategy.send(
-      notification.recipient,
-      notification.subject,
-      notification.body,
-    );
+    await strategy.send(notification);
 
     // Save to MongoDB
     await this.notificationRepository.save(notification);

src/application/use-cases/send-notification.use-case.ts

@@ -1,3 +1,5 @@
+import { Notification } from 'src/domain/entities/common/notification.entity';
+
 export interface INotificationStrategy {
-  send(recipient: string, subject: string, body: string): Promise<void>;
+  send(recipient: Notification): Promise<void>;
 }

src/domain/interfaces/common/notification-strategy.interface.ts

@@ -1,6 +1,6 @@
-import { MediaValidation } from '../../entities/common/media-validation.entity';
+import { Notification } from '../../../domain/entities/common/notification.entity';
 
 export interface IMediaValidationRepository {
-  save(validation: MediaValidation): Promise<void>;
-  findUserByMedia(media: string): Promise<MediaValidation | null>;
+  save(validation: Notification): Promise<void>;
+  findUserByMedia(media: string): Promise<Notification | null>;
 }

src/domain/repositories/common/media-validation.repository.ts

@@ -15,7 +15,10 @@ import { SMSNotificationStrategy } from '../application/strategies/sms-notificat
   ],
   controllers: [NotificationController],
   providers: [
-    NotificationRepository,
+    {
+      provide: 'INotificationRepository',
+      useClass: NotificationRepository,
+    },
     NotificationFactory,
     EmailNotificationStrategy,
     SMSNotificationStrategy,

src/notification/notification.module.ts

@@ -1,15 +1,23 @@
-import { Controller, Post, Body, HttpCode, HttpStatus } from '@nestjs/common';
-import { INotificationRepository } from '../../domain/interfaces/common/notification-repository.interface';
+import {
+  Controller,
+  Post,
+  Body,
+  HttpCode,
+  HttpStatus,
+  Inject,
+} from '@nestjs/common';
 import { NotificationFactory } from '../../application/factories/common/notification.factory';
 import { NotificationValidator } from '../../application/validators/notification.validator';
 import { SendNotificationDto } from '../dtos/common/send-notification.dto';
 import { Notification } from '../../domain/entities/common/notification.entity';
 import { INotificationStrategy } from '../../domain/interfaces/common/notification-strategy.interface';
+import { INotificationRepository } from '../../domain/interfaces/common/notification-repository.interface';
 
 @Controller('notifications')
 export class NotificationController {
   constructor(
     private readonly notificationFactory: NotificationFactory,
+    @Inject('INotificationRepository')
     private readonly notificationRepository: INotificationRepository,
   ) {}
 
@@ -32,8 +40,9 @@ export class NotificationController {
     );
 
     // Send notification
-    const strategy: INotificationStrategy =
-      this.notificationFactory.createStrategy(dto.mediaType);
+    const strategy: INotificationStrategy = NotificationFactory.create(
+      dto.mediaType as any,
+    );
     await strategy.send(notification);
 
     // Save notification after successful send