ported notification replaceById and deps

notify-bc-lb/src/controllers/notification.controller.ts

@@ -282,6 +282,7 @@ export class NotificationController extends BaseController {
     await this.notificationRepository.updateById(id, notification, undefined);
   }
 
+  // start: ported
   @put('/notifications/{id}', {
     responses: {
       '204': {
@@ -303,6 +304,7 @@ export class NotificationController extends BaseController {
     this.httpContext.bind('args').to({data: notification});
     await this.dispatchNotification(notification);
   }
+  // end: ported
 
   @del('/notifications/{id}', {
     responses: {
@@ -353,6 +355,7 @@ export class NotificationController extends BaseController {
     return this.sendPushNotification(notification);
   }
 
+  // start: ported
   async sendPushNotification(data: Notification) {
     const inboundSmtpServerDomain =
       this.appConfig.email.inboundSmtpServer?.domain;
@@ -1022,4 +1025,5 @@ export class NotificationController extends BaseController {
       throw new HttpErrors[403]('invalid user');
     }
   }
+  // end: ported
 }

package.json

@@ -35,6 +35,7 @@
     "@nestjs/mongoose": "^10.0.1",
     "@nestjs/platform-express": "^10.0.0",
     "@nestjs/swagger": "^7.1.8",
+    "async": "^3.2.4",
     "bcryptjs": "^2.4.3",
     "bottleneck": "^2.19.5",
     "class-transformer": "^0.5.1",

src/api/bounces/bounces.module.ts

@@ -17,5 +17,6 @@ import { Bounce, BounceSchema } from './entities/bounce.entity';
   ],
   controllers: [BouncesController],
   providers: [BouncesService],
+  exports: [BouncesService],
 })
 export class BouncesModule {}

src/api/notifications/entities/notification.entity.ts

@@ -1,5 +1,5 @@
-import { Schema, SchemaFactory } from '@nestjs/mongoose';
-import { HydratedDocument } from 'mongoose';
+import { Prop, Schema, SchemaFactory } from '@nestjs/mongoose';
+import mongoose, { AnyObject, HydratedDocument } from 'mongoose';
 import { BaseEntity, BaseSchemaOptions } from 'src/api/common/base.entity';
 
 export type NotificationDocument = HydratedDocument<Notification>;
@@ -8,7 +8,63 @@ export type NotificationDocument = HydratedDocument<Notification>;
   collection: 'notification',
   ...BaseSchemaOptions,
 })
-export class Notification extends BaseEntity {}
+export class Notification extends BaseEntity {
+  @Prop({ required: true })
+  serviceName: string;
+
+  @Prop({
+    default: 'new',
+  })
+  state: string;
+
+  @Prop()
+  userChannelId?: string;
+
+  @Prop({
+    type: mongoose.Schema.Types.Mixed,
+    required: true,
+    default: {},
+  })
+  message: AnyObject;
+
+  @Prop({
+    required: true,
+    default: 'inApp',
+  })
+  channel: string;
+
+  @Prop({
+    default: false,
+  })
+  isBroadcast?: boolean;
+
+  @Prop({
+    default: false,
+  })
+  skipSubscriptionConfirmationCheck?: boolean;
+
+  @Prop()
+  validTill?: Date;
+
+  @Prop()
+  invalidBefore?: Date;
+
+  @Prop({
+    type: mongoose.Schema.Types.Mixed,
+  })
+  data?: AnyObject;
+
+  @Prop({
+    type: mongoose.Schema.Types.Mixed,
+  })
+  asyncBroadcastPushNotification?: any;
+
+  @Prop()
+  broadcastPushNotificationSubscriptionFilter?: string;
+
+  // Indexer property to allow additional data
+  [prop: string]: any;
+}
 
 export const NotificationSchema = SchemaFactory.createForClass(
   Notification,