Notification repository added

server/src/domain/entities/INotification.ts

@@ -1,7 +1,3 @@
-export enum NotificationStatus {
-    READ = 'read',
-    UNREAD = 'unread'
-}
 export enum NotificationTypes {
     APPOINTMENT_CANCELED = 'appointment_canceled',
     APPOINTMENT_CONFIRMED = 'appointment_confirmed',
@@ -17,5 +13,4 @@ export default interface INotification {
     readonly createdAt?: Date;
     readonly updatedAt?: Date;
     readonly appointmentId?:string
-    status?: NotificationStatus,
 }

server/src/domain/interface/repositories/INotificationRepository.ts

@@ -0,0 +1,9 @@
+import INotification from "../../entities/INotification";
+
+export default interface INotificationRepository {
+    create(notification: INotification): Promise<void>;
+    findByPatientId(patientId: string): Promise<INotification[] | null>;
+    findByDoctorId(doctorId: string): Promise<INotification[] | null>;
+    clear(id: string): Promise<void>;
+    clearAll(notificationIds: string[]): Promise<void>;
+}

server/src/infrastructure/repositories/NotificationRepository.ts

@@ -0,0 +1,23 @@
+import INotification from "../../domain/entities/INotification";
+import INotificationRepository from "../../domain/interface/repositories/INotificationRepository";
+import NotificationModel from "../database/NotificationMode";
+
+export default class NotificationRepository implements INotificationRepository {
+    model = NotificationModel
+
+    async create(notification: INotification): Promise<void> {
+        await this.model.create(notification)
+    }
+    async findByPatientId(patientId: string): Promise<INotification[] | null> {
+        return this.model.find({ patientId })
+    }
+    async findByDoctorId(doctorId: string): Promise<INotification[] | null> {
+        return this.model.find({ doctorId })
+    }
+    async clear(id: string): Promise<void> {
+        await this.model.findByIdAndDelete(id);
+    }
+    async clearAll(notificationIds: string[]): Promise<void> {
+        await this.model.deleteMany({ _id: { $in: notificationIds } })
+    }
+}