✨ Feat: 크루 게시글, 멤버 관련 알림 기능 추가 적용

✨ Feat: 크루 게시글, 멤버 관련 알림 기능 추가 적용

Author: silversieon

src/crew/page/member/repository/member.repository.js

@@ -143,6 +143,13 @@ export const isExistCrewMember = async ({ crewMemberId }) => {
             {
                 where: {
                     id: crewMemberId,
+                },
+                include: {
+                    user: {
+                        select: {
+                            id: true
+                        }
+                    }
                 }
             }
         )

src/crew/page/member/service/member.service.js

@@ -1,6 +1,7 @@
 import * as baseError from "../../../../error.js";
 import * as memberResponse from "../dto/response/member.response.dto.js";
 import * as memberRepository from "../repository/member.repository.js";
+import { eventEmitter } from "../../../../index.js";
 
 export const readMembersByCrew = async ({ userId, crewId, page, size }) => {
     try {
@@ -91,6 +92,10 @@ export const kickCrewMember = async ({ userId, crewId, crewMemberId }) => {
             throw new baseError.PermissionDeniedError("권한이 없는 크루원입니다.");
         }
         const member = await memberRepository.removeMemberByCrewMemberId({ crewMemberId });
+        eventEmitter.emit('CREW_KICKED', {
+            targetId: { crewId },
+            userId: [isExistCrewMember.user.id]
+        });
         return memberResponse.CrewMemberResponse(member);
     } catch (err) {
         throw err;

src/crew/page/post/repository/post.repository.js

@@ -546,6 +546,11 @@ export const isExistPost = async ({ postId }) => {
 					crewMember: {
 						select: {
 							role: true,
+							user: {
+								select: {
+									id: true
+								}
+							}
 						}
 					}
 				}

src/crew/page/post/service/post.service.js

@@ -3,6 +3,7 @@ import * as postResponse from "../dto/response/post.response.dto.js"
 import * as postRepository from "../repository/post.repository.js"
 import * as baseError from "../../../../error.js"
 import * as s3Function from "../../../../utils/s3.js"
+import { eventEmitter } from '../../../../index.js';
 
 export const readPostsByCrew = async ({ crewId, page, size }) => {
 	try {
@@ -209,10 +210,15 @@ export const toggleCrewPostLike = async ({ userId, crewId, postId }) => {
 		if (!crewMember) {
 			throw new baseError.NotCrewMemberError("크루 멤버에 속하지 않은 유저입니다.", { userId });
 		}
+		const crewMemberId = crewMember.id;
 		const likeInfo = await postRepository.likeCrewPost({
-			crewMemberId: crewMember.id,
+			crewMemberId: crewMemberId,
 			postId,
 		})
+		eventEmitter.emit('POST_LIKED', {
+			targetId: { userId, postId },
+			userId: [isExistPost.crewMember.user.id]
+		})
 		return postResponse.likeCrewPostResponse(likeInfo);
 	} catch (err) {
 		throw err;
@@ -272,7 +278,10 @@ export const createCrewPostComment = async ({ crewId, postId, userId, content, i
 			content,
 			isPublic
 		})
-
+		eventEmitter.emit('POST_COMMENTED', {
+			targetId: { userId, postId },
+			userId: [isExistPost.crewMember.user.id]
+		})
 		return postResponse.CrewCommentResponse(comment);
 	} catch (err) {
 		throw err;