ADD: get notifications (#73)

backend/code/src/profile/profile.controller.ts

@@ -9,6 +9,7 @@ import {
  Param,
  ParseFilePipe,
  Post,
+ Query,
  UploadedFile,
  UseGuards,
  UseInterceptors,
@@ -29,6 +30,7 @@ import {
  ApiTags,
 } from '@nestjs/swagger';
 import { AuthGuard } from '@nestjs/passport';
+import { QueryOffsetDto } from 'src/friends/dto/query-ofsset-dto';
 
 @ApiTags('profile')
 @ApiCookieAuth('X-Acces-Token')
@@ -106,4 +108,13 @@ export class ProfileController {
  getAvatar(@Param('id') recourseId: string) {
  return this.profileService.getAvatar(recourseId);
  }
+
+ @Get('notifications')
+ @UseGuards(AtGuard)
+ getNotifications(
+ @GetCurrentUser('userId') userId: string,
+ @Query() { offset, limit }: QueryOffsetDto,
+ ) {
+ return this.profileService.getNotifications(userId, offset, limit);
+ }
 }

backend/code/src/profile/profile.service.ts

@@ -3,11 +3,15 @@ import { UsersService } from 'src/users/users.service';
 import { ProfileDto } from './dto/profile.dto';
 import { UpdateProfileDto } from './dto/update-profile.dto';
 import { UploadApiResponse, v2 as cloudinary } from 'cloudinary';
+import { PrismaService } from 'src/prisma/prisma.service';
 import { Readable } from 'stream';
 
 @Injectable()
 export class ProfileService {
- constructor(private usersService: UsersService) {}
+ constructor(
+ private usersService: UsersService,
+ private readonly prisma: PrismaService,
+ ) {}
 
  async getProfile(userId: string): Promise<ProfileDto> {
  const user = await this.usersService.getUserById(userId);
@@ -98,4 +102,14 @@ export class ProfileService {
  });
  return result;
  }
+
+ async getNotifications(userId: string, offset: number, limit: number) {
+ return await this.prisma.notification.findMany({
+ skip: offset,
+ take: limit,
+ where: {
+ recipientId: userId,
+ },
+ });
+ }
 }