ADD: notifaction table

backend/code/prisma/dbml/schema.dbml

@@ -106,6 +106,19 @@ Table room_members {
   }
 }
 
+Table notifications {
+  createdAt DateTime [default: `now()`, unique, not null]
+  id String [pk]
+  recipientId String [not null]
+  content NotifType [not null]
+  is_read Boolean [not null, default: false]
+  readAt DateTime
+}
+
+Enum NotifType {
+  addFriend
+}
+
 Enum RoomType {
   public
   private

backend/code/prisma/schema.prisma

@@ -136,6 +136,23 @@ model RoomMember {
   @@map("room_members")
 }
 
+model Notification {
+  createdAt   DateTime  @default(now())
+
+  id           String    @id @default(cuid())
+  recipientId String
+  content     NotifType
+  is_read     Boolean @default(false)
+  readAt      DateTime?
+
+  @@map("notifications")
+  @@unique([createdAt])
+}
+
+enum NotifType {
+  addFriend
+}
+
 enum RoomType {
   public
   private

backend/code/src/friends/friends.service.ts

@@ -2,12 +2,14 @@ import { HttpException, HttpStatus, Injectable } from '@nestjs/common';
 import { PrismaService } from 'src/prisma/prisma.service';
 import { UsersService } from 'src/users/users.service';
 import { FriendResponseDto } from './dto/frined-response.dto';
+import { EventEmitter2 } from '@nestjs/event-emitter';
 
 @Injectable()
 export class FriendsService {
   constructor(
     private readonly prisma: PrismaService,
     private readonly usersService: UsersService,
+    private evenEmitter: EventEmitter2,
   ) {}
 
   async addFriend(userId: string, friendId: string) {
@@ -34,6 +36,13 @@ export class FriendsService {
       },
       update: {},
     });
+    const notifData = await this.prisma.notification.create({
+      data: {
+        recipientId: friendId,
+        content: 'addFriend',
+      },
+    });
+    this.evenEmitter.emit('addFriendNotif', notifData);
     return new FriendResponseDto(frinedship);
   }
 

backend/code/src/gateways/gateways.gateway.ts

@@ -36,6 +36,7 @@ export class Gateways implements OnGatewayConnection {
         client.join(`Romm:${room.room.id}`);
       });
     });
+    client.join(`notif:${userId}`);
   }
 
   @WebSocketServer() private server: Server;
@@ -45,4 +46,9 @@ export class Gateways implements OnGatewayConnection {
     const chanellname: string = `Romm:${message.roomId}`;
     this.server.to(chanellname).emit('message', message);
   }
+  @OnEvent('addFriendNotif')
+  sendFriendReq(notif: any) {
+    const channellname: string = `notif:${notif.recipientId}`;
+    this.server.to(channellname).emit('message', notif);
+  }
 }