created the notification feature for users

src/shared/schema/user.schema.ts

@@ -30,6 +30,19 @@ export type UserDocument = HydratedDocument<User>;
 
 @Schema({ timestamps: true })
 export class User {
+
+  @Prop({ type: Types.ObjectId, ref: 'User', required: true })
+  userId: string
+
+  @Prop({ required: true })
+  message: string;
+
+  @Prop({ default: false })
+  read: boolean;
+
+  @Prop({ type: [{ message: String, read: Boolean, createdAt: Date }], default: [] })
+  notifications: { message: string; read: boolean; createdAt: Date }[];
+
   @Prop({ index: true })
   firstName: string;
 
@@ -65,8 +78,8 @@ export class User {
 
   @Prop({ index: true })
   gender: string;
-  
-  
+
+
 
   @Prop({
     type: {
@@ -116,15 +129,15 @@ export class User {
 
   @Prop(raw(SocialsRawSchema))
   socials: Socials;
-  
-@Prop({
-  index: true,
-  default: VerificationStatus.NOT_VERIFIED
-})
- verificationStatus: VerificationStatus;
-
- @Prop({ type: Date })
- nextVerificationRequestDate: Date;
+
+  @Prop({
+    index: true,
+    default: VerificationStatus.NOT_VERIFIED
+  })
+  verificationStatus: VerificationStatus;
+
+  @Prop({ type: Date })
+  nextVerificationRequestDate: Date;
 }
 
 export const UserSchema = SchemaFactory.createForClass(User);

src/users/dto/create-notification.dto.ts

@@ -0,0 +1,10 @@
+import { ApiProperty } from "@nestjs/swagger";
+import { IsNotEmpty, IsString } from "class-validator";
+
+export class CreateNotificationDto {
+    @ApiProperty()
+    @IsString()
+    @IsNotEmpty()
+    message: any;
+
+}

src/users/dto/update-notification.dto.ts

@@ -0,0 +1,8 @@
+import { IsMongoId, IsNotEmpty } from 'class-validator';
+
+export class UpdateNotificationDto {
+    @IsMongoId()
+    @IsNotEmpty()
+    message: string;
+    read: boolean;
+}

src/users/users.controller.ts

@@ -17,11 +17,12 @@ import { ApiReq, userRoles, userStatuses } from 'src/shared/interfaces';
 import { CreateUserDto } from 'src/shared/dtos/create-user.dto';
 import { UserChangePasswordDto } from './dto/user-change-password.dto';
 import { UserAddPhotoDto } from './dto/user-add-photo.dto';
+import { CreateNotificationDto } from './dto/create-notification.dto';
 
 @ApiTags('users')
 @Controller('users')
 export class UsersController {
-  constructor(private readonly usersService: UsersService) {}
+  constructor(private readonly usersService: UsersService) { }
 
   @Post()
   create(@Request() req: ApiReq, @Body() createUserDto: CreateUserDto) {
@@ -127,4 +128,33 @@ export class UsersController {
   ) {
     return this.usersService.requestVerification(req, userId);
   }
+
+  @ApiBearerAuth()
+  @UseGuards(JwtUsersGuard)
+  @Post(':userId/create-notification')
+  async createNotification(
+    @Param('userId') userId: string,
+    @Body() createNotificationDto: CreateNotificationDto,
+
+  ) {
+    const { message } = createNotificationDto;
+    return this.usersService.createNotification(userId, message)
+  }
+
+  @ApiBearerAuth()
+  @UseGuards(JwtUsersGuard)
+  @Get(':userId/get-notifications')
+  async getAllNotificationsForUser(
+    @Param('userId') userId: string
+  ) {
+    return this.usersService.getAllNotificationsForUser(userId);
+  }
+
+  @Patch(':userId/is-read-notifications/:notificationId')
+  async markNotificationAsRead(
+    @Param('userId') userId: string,
+    @Param('notificationId') notificationId: string,
+  ) {
+    return this.usersService.markNotificationAsRead(userId, notificationId);
+  }
 }

src/users/users.service.ts

@@ -30,6 +30,8 @@ import {
 } from 'src/shared/interfaces';
 import { UserInviteDto } from './dto/user-invite.dto';
 import { VerificationStatus } from 'src/shared/interfaces/user.type';
+import { UpdateNotificationDto } from './dto/update-notification.dto';
+import { CreateNotificationDto } from './dto/create-notification.dto';
 @Injectable()
 export class UsersService {
   constructor(
@@ -299,5 +301,38 @@ export class UsersService {
     //5. Save the updated user
     await user.save();
   }
+
+  async createNotification(userId: string, message: string) {
+    const notification = { message: message, read: false, createdAt: new Date() };
+    return this.userModel.findOneAndUpdate(
+      { _id: userId },
+      { $push: { notifications: notification } },
+      { new: true }
+    ).exec();
+
+  }
+
+  async getAllNotificationsForUser(userId) {
+    const user = await this.userModel.findById(userId, 'notifications').exec();
+    if (!user) {
+      throw new NotFoundException(`User with ID ${userId} not found`);
+    }
+    return user.notifications;
+  }
+  async updateNotification(userId: string, notificationId: string, updateNotificationDto: UpdateNotificationDto): Promise<User> {
+    return this.userModel.findOneAndUpdate(
+      { _id: userId, 'notifications._id': notificationId },
+      { $set: { 'notifications.$.message': updateNotificationDto.message } },
+      { new: true }
+    ).exec();
+  }
+  async markNotificationAsRead(userId: string, notificationId: string): Promise<User> {
+    return this.userModel.findOneAndUpdate(
+      { _id: userId, 'notifications._id': notificationId },
+      { $set: { 'notifications.$.read': true } },
+      { new: true }
+    ).exec();
+  }
+
 }