feat: added the webhooks

Author: sourcecode71

src/notification/domain/interfaces/webhook-repository.interface.ts

@@ -0,0 +1,6 @@
+import { Webhook } from '../../infrastructure/persistence/mongoose/webhook.schema';
+
+export interface IWebhookRepository {
+  createWebhook(url: string, event: string, ownerId: string): Promise<Webhook>;
+  findByOwnerId(ownerId: string): Promise<Webhook[]>;
+}

src/notification/infrastructure/persistence/mongoose/webhook.schema.ts

@@ -0,0 +1,19 @@
+import { Prop, Schema, SchemaFactory } from '@nestjs/mongoose';
+import { Document } from 'mongoose';
+
+@Schema({ timestamps: true })
+export class Webhook extends Document {
+  @Prop({ required: true })
+  url: string;
+
+  @Prop({ required: true })
+  event: string; // e.g., 'notification.sent', 'notification.failed'
+
+  @Prop({ required: true })
+  ownerId: string; // e.g., user or system ID
+
+  @Prop({ default: true })
+  active: boolean;
+}
+
+export const WebhookSchema = SchemaFactory.createForClass(Webhook);

src/notification/infrastructure/repositories/webhook.repository.ts

@@ -0,0 +1,26 @@
+import { Injectable } from '@nestjs/common';
+import { InjectModel } from '@nestjs/mongoose';
+import { Model } from 'mongoose';
+import { Webhook } from '../persistence/mongoose/webhook.schema';
+import { IWebhookRepository } from '../../domain/interfaces/webhook-repository.interface';
+
+@Injectable()
+export class WebhookRepository implements IWebhookRepository {
+  constructor(
+    @InjectModel('Webhook')
+    private readonly webhookModel: Model<Webhook>,
+  ) {}
+
+  async createWebhook(
+    url: string,
+    event: string,
+    ownerId: string,
+  ): Promise<Webhook> {
+    const webhook = new this.webhookModel({ url, event, ownerId });
+    return webhook.save();
+  }
+
+  async findByOwnerId(ownerId: string): Promise<Webhook[]> {
+    return this.webhookModel.find({ ownerId, active: true }).exec();
+  }
+}

src/notification/notification.module.ts

@@ -1,9 +1,12 @@
 import { Module } from '@nestjs/common';
 import { MongooseModule } from '@nestjs/mongoose';
 import { NotificationController } from './presentation/controllers/notification.controller';
+import { WebhookController } from './presentation/controllers/webhook.controller';
 import { LogController } from './presentation/controllers/log.controller';
 import { NotificationRepository } from './infrastructure/repositories/notification.repository';
+import { WebhookRepository } from './infrastructure/repositories/webhook.repository';
 import { NotificationSchema } from './infrastructure/persistence/mongoose/notification.schema';
+import { WebhookSchema } from './infrastructure/persistence/mongoose/webhook.schema';
 import { NotificationFactory } from './application/factories/notification.factory';
 import { EmailNotificationStrategy } from './application/strategies/email-notification.strategy';
 import { SMSNotificationStrategy } from './application/strategies/sms-notification.strategy';
@@ -13,15 +16,20 @@ import { LoggerModule } from '../logger/logger.module';
   imports: [
     MongooseModule.forFeature([
       { name: 'Notification', schema: NotificationSchema },
+      { name: 'Webhook', schema: WebhookSchema }, // Register Webhook schema
     ]),
     LoggerModule,
   ],
-  controllers: [NotificationController, LogController],
+  controllers: [NotificationController, WebhookController, LogController],
   providers: [
     {
       provide: 'INotificationRepository',
       useClass: NotificationRepository,
     },
+    {
+      provide: 'IWebhookRepository',
+      useClass: WebhookRepository,
+    },
     NotificationFactory,
     EmailNotificationStrategy,
     SMSNotificationStrategy,

src/notification/presentation/controllers/webhook.controller.ts

@@ -0,0 +1,45 @@
+import { Body, Controller, Get, HttpStatus, Post, Query } from '@nestjs/common';
+import { Inject } from '@nestjs/common';
+import { IWebhookRepository } from '../../domain/interfaces/webhook-repository.interface';
+import { ApiOperation, ApiResponse, ApiTags } from '@nestjs/swagger';
+
+class CreateWebhookDto {
+  url: string;
+  event: string;
+  ownerId: string;
+}
+
+@ApiTags('Webhooks')
+@Controller('api/webhooks')
+export class WebhookController {
+  constructor(
+    @Inject('IWebhookRepository')
+    private readonly webhookRepository: IWebhookRepository,
+  ) {}
+
+  @Post()
+  @ApiOperation({ summary: 'Create a webhook subscription' })
+  @ApiResponse({
+    status: HttpStatus.CREATED,
+    description: 'Webhook created successfully',
+  })
+  async createWebhook(@Body() dto: CreateWebhookDto) {
+    const webhook = await this.webhookRepository.createWebhook(
+      dto.url,
+      dto.event,
+      dto.ownerId,
+    );
+    return { message: 'Webhook created successfully', data: webhook };
+  }
+
+  @Get()
+  @ApiOperation({ summary: 'Get webhooks for an owner' })
+  @ApiResponse({
+    status: HttpStatus.OK,
+    description: 'Webhooks retrieved successfully',
+  })
+  async getWebhooks(@Query('ownerId') ownerId: string) {
+    const webhooks = await this.webhookRepository.findByOwnerId(ownerId);
+    return { data: webhooks };
+  }
+}