Merge pull request #40 from DevKor-github/feat/notification

feat: notifications

Author: juwoong

src/notification/controller.ts

@@ -0,0 +1,49 @@
+import {
+  Controller,
+  Get,
+  Query,
+  DefaultValuePipe,
+  ParseIntPipe,
+  Res,
+  UseGuards,
+  HttpStatus,
+} from '@nestjs/common';
+import { Response } from 'express';
+import { ApiBearerAuth, ApiResponse, ApiTags } from '@nestjs/swagger';
+import { AccessTokenGuard } from '@/auth/guards/access-token.guard';
+import { User } from '@/decorators/user.decorator';
+import { GetUserNotificationsUseCase } from './usecases/getUserNotifications';
+import { GetUserNotificationsResult } from './params';
+
+@ApiTags('Notification')
+@ApiBearerAuth()
+@Controller('notifications')
+export class NotificationController {
+  constructor(
+    private readonly getUserNotificationsUseCase: GetUserNotificationsUseCase,
+  ) {}
+
+  // 내 푸시 알림 히스토리를 최근순으로 조회합니다.
+  @Get('me')
+  @UseGuards(AccessTokenGuard)
+  @ApiResponse({
+    status: 200,
+    description: 'Get my notifications (recent first) with pagination',
+    type: Object,
+  })
+  async getMyNotifications(
+    @User('id') userId: string,
+    @Query('page', new DefaultValuePipe(1), ParseIntPipe) page: number,
+    @Query('per_page', new DefaultValuePipe(20), ParseIntPipe) perPage: number,
+    @Res() res: Response,
+  ) {
+    const result: GetUserNotificationsResult =
+      await this.getUserNotificationsUseCase.execute({
+        userId,
+        page,
+        limit: perPage,
+      });
+
+    return res.status(HttpStatus.OK).json(result);
+  }
+}

src/notification/module.ts

@@ -1,4 +1,6 @@
 import { Module } from '@nestjs/common';
+import { PrismaModule } from '@/prisma/prisma.module';
+import { NotificationController } from './controller';
 import { FCMService } from './infrastructure/fcm';
 import { NotificationRepository } from './repository';
 import { CreateWaterNotificationUseCase } from './usecases/createWaterNotification';
@@ -9,8 +11,8 @@ import { UserRepository } from '@/user/repositories/user';
 import { RestaurantRepository } from '@/restaurant/repositories/restaurant';
 
 @Module({
-  imports: [],
-  controllers: [],
+  imports: [PrismaModule],
+  controllers: [NotificationController],
   providers: [
     FCMService,
     NotificationRepository,
@@ -20,6 +22,8 @@ import { RestaurantRepository } from '@/restaurant/repositories/restaurant';
     CreateFollowNotificationUseCase,
     CreateGrowNotificationUseCase,
     GetUserNotificationsUseCase,
+    UserRepository,
+    RestaurantRepository,
   ],
   exports: [
     FCMService,

src/tree/module.ts

@@ -6,6 +6,10 @@ import { PrismaService } from 'src/prisma/prisma.service';
 import { AuthModule } from '../auth/module';
 import { UserRepository } from '@/user/repositories/user';
 import { AccessTokenGuard } from '@/auth/guards/access-token.guard';
+import { NotificationRepository } from '@/notification/repository';
+import { FCMService } from '@/notification/infrastructure/fcm';
+import { CreateWaterNotificationUseCase } from '@/notification/usecases/createWaterNotification';
+import { RestaurantRepository } from '@/restaurant/repositories/restaurant';
 
 @Module({
   imports: [AuthModule],
@@ -16,6 +20,10 @@ import { AccessTokenGuard } from '@/auth/guards/access-token.guard';
     PrismaService,
     UserRepository,
     AccessTokenGuard,
+    NotificationRepository,
+    FCMService,
+    CreateWaterNotificationUseCase,
+    RestaurantRepository,
   ],
   exports: [TreeRepository],
 })

src/tree/service.ts

@@ -16,6 +16,7 @@ import { PrismaService } from '@/prisma/prisma.service';
 import { TreeDetail } from './types';
 import { UserParam } from '@/user/params/user';
 import config from '@/config';
+import { CreateWaterNotificationUseCase } from '@/notification/usecases/createWaterNotification';
 import { UserResponse } from '@/user/dtos/user';
 
 const toTreeDetailResponse = (detail: TreeDetail): TreeDetailResponse => {
@@ -57,6 +58,7 @@ export class TreeService {
   constructor(
     private readonly treeRepository: TreeRepository,
     private readonly prisma: PrismaService,
+    private readonly waterNotificationUseCase: CreateWaterNotificationUseCase,
   ) {}
 
   async getFollowersTree(
@@ -165,6 +167,13 @@ export class TreeService {
       restaurantId,
       user.id,
     );
+
+    await this.waterNotificationUseCase.execute({
+      userId: ownerId,
+      treeType: result.tree.treeType,
+      restaurantId,
+    });
+
     return toTreeDetailResponse(result);
   }
 

src/user/module.ts

@@ -16,6 +16,9 @@ import { GetMyProfileUseCase } from './usecases/getMyProfile';
 import { AccessTokenGuard } from '@/auth/guards/access-token.guard';
 import { UpdateProfileUseCase } from './usecases/updateProfile';
 import { UpdateMbtiAndTagsUseCase } from './usecases/updateMbtiAndTags';
+import { CreateFollowNotificationUseCase } from '@/notification/usecases/createFollowNotification';
+import { NotificationRepository } from '@/notification/repository';
+import { FCMService } from '@/notification/infrastructure/fcm';
 
 import { TreeModule } from '@/tree/module';
 import { GetFollowingCountUsecase } from './usecases/getFollowingCount';
@@ -45,6 +48,9 @@ import { CheckFollowingStatusUseCase } from './usecases/checkFollowingStatus';
     AccessTokenGuard,
     UpdateProfileUseCase,
     UpdateMbtiAndTagsUseCase,
+    CreateFollowNotificationUseCase,
+    NotificationRepository,
+    FCMService,
     GetFollowerCountUsecase,
     GetFollowingCountUsecase,
     GetUserProfileUseCase,

src/user/usecases/followUser.ts

@@ -6,12 +6,14 @@ import {
 import { FollowerRepository } from '../repositories/follower';
 import { UserRepository } from '../repositories/user';
 import { FollowerStatus } from '@prisma/client';
+import { CreateFollowNotificationUseCase } from '@/notification/usecases/createFollowNotification';
 
 @Injectable()
 export class FollowUserUseCase {
   constructor(
     private readonly followerRepository: FollowerRepository,
     private readonly userRepository: UserRepository,
+    private readonly notificationUseCase: CreateFollowNotificationUseCase,
   ) {}
 
   async execute(followerId: string, userId: string): Promise<void> {
@@ -38,5 +40,10 @@ export class FollowUserUseCase {
         ? FollowerStatus.PENDING
         : FollowerStatus.ACCEPTED,
     });
+
+    await this.notificationUseCase.execute({
+      followerId,
+      userId,
+    });
   }
 }