푸시 알림 기능 리팩토링 및 알림 선택 구독 기능 추가 #621

pricelees · 2024-10-10T10:55:51Z

PR의 목적이 무엇인가요?

알림 기능 리팩토링 -> 알림 기능은 이벤트를 이용한 비동기로 구현하여 기존 도메인과 별도로 처리되도록 수정
알림 구독 기능 추가(현재는 모임 생성, 특정 채팅방)
FCM 토큰 관리 방법 수정(활성화, 비활성화, 제거 상태로 구분)
FCM 메시지 전송 오류 처리 기능 구현(문제되는 토큰은 삭제, 일부 예외는 재전송 시도)

이슈 ID는 무엇인가요?

푸시 알림 기능 리팩토링 및 알림 선택 구독 기능 추가 #564

설명

모든 기능은 제 개인 EC2에 배포한 뒤 정상 동작 확인했고, 새로 추가된 ChatRoom에 대한 전송도 일단 기존 코드 참고해서 구현해놨어요.
(이쪽은 자세히 알고있는게 아니라 에러가 발생할 수도 있습니다.)

구독 기능은 일단 테스트를 위해 API만 뚫어놨는데, 이 부분은 추후에 프론트와 합의 후 수정하겠습니다.

질문 혹은 공유 사항 (Optional)

# Conflicts: # backend/src/main/java/mouda/backend/moim/business/ChamyoService.java # backend/src/main/java/mouda/backend/moim/business/CommentService.java # backend/src/main/java/mouda/backend/moim/business/MoimService.java # backend/src/main/java/mouda/backend/notification/business/NotificationService.java # backend/src/main/java/mouda/backend/notification/domain/NotificationType.java # backend/src/main/java/mouda/backend/notification/infrastructure/entity/ChatRoomSubscription.java # backend/src/main/java/mouda/backend/notification/infrastructure/entity/SubscriptionEntity.java # backend/src/main/java/mouda/backend/notification/infrastructure/repository/SubscriptionRepository.java # backend/src/main/java/mouda/backend/notification/presentation/request/FcmTokenRequest.java # backend/src/test/java/mouda/backend/notification/infrastructure/SubscriptionEntityTest.java

ay-eonii

상돌 ,, 코드량이 엄청나네요 ... 정말 감사합니다 👍

코멘트 몇개 남겼는데 다른 건 읽어보시고 스웨거부분만 확인부탁드려용

ay-eonii · 2024-10-11T12:57:40Z

...src/main/java/mouda/backend/notification/presentation/controller/SubscriptionController.java

+	@Override
+	public ResponseEntity<RestResponse<SubscriptionResponse>> readSpecificChatRoomSubscription(
+		@LoginMember Member member,
+		@Valid @RequestBody ChatSubscriptionRequest chatSubscriptionRequest


스웨거에서 이렇게 나와요 ㅜㅅㅜ

스웨거에서 이렇게 나와요 ㅜㅅㅜ

Get요청을 보낼때 RequestBody를 쓴 실수.. RequestParam으로 수정했어요!

ay-eonii · 2024-10-11T13:06:33Z

backend/src/main/java/mouda/backend/notification/infrastructure/entity/SubscriptionEntity.java

+	public void changeChatRoomSubscription(long darakbangId, long chatRoomId) {
+		for (UnsubscribedChatRooms unsubscribedChatRoom : unsubscribedChats) {
+			if (unsubscribedChatRoom.getDarakbangId() == darakbangId) {
+				unsubscribedChatRoom.changeChatRoomSubscription(chatRoomId);
+				return;
+			}
+		}
+		unsubscribedChats.add(UnsubscribedChatRooms.create(darakbangId, chatRoomId));
+	}


여기서 완전탐색을 해야한다면 Map형식으로 저장하는 것도 고려해보면 좋을 것 가탕요

다락방Id를 key, List만 가진 UnsubscribedChatRooms를 value 로 하는 방식으로요

여기서 완전탐색을 해야한다면 Map형식으로 저장하는 것도 고려해보면 좋을 것 가탕요

다락방Id를 key, List만 가진 UnsubscribedChatRooms를 value 로 하는 방식으로요

이 부분은 조금 더 고민해볼게요. 일단 [{"darakbangId":1,"chatRoomIds":[1]},{"darakbangId":2,"chatRoomIds":[1,2]}] 형태로 데이터를 저장하고자 해서 List를 사용했어요!

@ksk0605 이건 테바가 확인해주면 좋겠네요.

ay-eonii · 2024-10-11T13:11:54Z

...d/src/main/java/mouda/backend/notification/infrastructure/repository/FcmTokenRepository.java

+
+    Optional<FcmTokenEntity> findByToken(String token);
+
+	void deleteAllByTokenIn(List<String> unregisteredTokens);


얘만 인덴트가 안맞아여ㅎㅎ

얘만 인덴트가 안맞아여ㅎㅎ

제꺼에서는 맞는데요..? ㅋㅋㅋ 그래도 한번 더 정렬해서 다시 올릴게요 ~

ay-eonii · 2024-10-11T15:13:16Z

backend/src/main/java/mouda/backend/notification/implement/fcm/FcmResponseHandler.java

+				FcmFailedResponse retryResponse = retry(failedResponse, notification,
+					failedResponse.getNonRetryableFailedTokens());


(잘 못 이해했을수도 있는데 ㅜㅜ) 재시도할수 없는 토큰을 retry 하는 이유가 뭔ㄱㅏ요 ..?

(잘 못 이해했을수도 있는데 ㅜㅜ) 재시도할수 없는 토큰을 retry 하는 이유가 뭔ㄱㅏ요 ..?

디버깅용으로 찍어보고 수정을 안한 오타입니다..ㅎㅎ getFailedWith5xxTokens()가 들어가는게 맞아요👍

ay-eonii · 2024-10-11T15:17:24Z

backend/src/main/java/mouda/backend/notification/implement/fcm/FcmResponseHandler.java

+		List<String> retryTokens) {
+		log.info("Retrying for notification: {}. failed: {}, Thread: {}", notification.getTitle(), retryTokens,
+			Thread.currentThread().getName());
+		MulticastMessage message = fcmMessageFactory.createMessage(notification, retryTokens).get(0);


get(0)을 하는 이유에 대해 설명해주실 수 있낭요

get(0)을 하는 이유에 대해 설명해주실 수 있낭요

토큰이 500개 이상인 경우 500개당 1개의 MulticastMessage 객체를 만드는데, fcmMessageFactory에서는 일원화를 위해 500개 미만이어도 리스트에 담아 반환하고 있습니다. 그리고 List<MulticastMessage>를 forEach를 통해 하나씩 전송하구요.

�FcmResponseHandler에서의 재시도 처리는 한 개의 MulticastMessage만을 대상으로 하는데요, 그래서 여기서 fcmMessageFactory.createMessage()로 얻는 리스트는 1개의 MulticastMessage를 가질 수 밖에 없습니다. 그래서 get(0)으로 그걸 꺼내오는거에요!

ay-eonii · 2024-10-11T15:19:55Z

backend/src/test/java/mouda/backend/moim/implement/finder/CommentFinderTest.java

-		Long memberId = commentFinder.readMemberIdByParentId(childComment.getParentId());
-
-		assertThat(memberId).isEqualTo(darakbangHogee.getId());
-	}
 }


개행 한번만 해주세용

개행 한번만 해주세용

싫어요

ay-eonii · 2024-10-11T15:20:11Z

backend/src/test/java/mouda/backend/moim/implement/finder/CommentRecipientFinderTest.java

+	@Test
+	void getNewCommentNotificationRecipients() {
+	}
+
+	@Test
+	void getNewReplyNotificationRecipients() {
+	}


ㅋㅋㅋ 투두인가요?

ㅋㅋㅋ 투두인가요?

경우의 수가 너무 많아서 고민이 필요했던 부분인데.. 테스트 추가했어요!
테스트 돌리면서 보니 처리가 하나 틀린 부분이 있더라구요. 덕분에 그거까지 수정할 수 있었네요~ 🫡

pricelees

테니 디버깅 미쳤다..👍🙇

pricelees · 2024-10-13T05:04:22Z

backend/src/main/java/mouda/backend/notification/implement/fcm/FcmResponseHandler.java

+				FcmFailedResponse retryResponse = retry(failedResponse, notification,
+					failedResponse.getNonRetryableFailedTokens());


(잘 못 이해했을수도 있는데 ㅜㅜ) 재시도할수 없는 토큰을 retry 하는 이유가 뭔ㄱㅏ요 ..?

디버깅용으로 찍어보고 수정을 안한 오타입니다..ㅎㅎ getFailedWith5xxTokens()가 들어가는게 맞아요👍

pricelees · 2024-10-13T05:06:36Z

backend/src/main/java/mouda/backend/notification/implement/fcm/FcmResponseHandler.java

+		List<String> retryTokens) {
+		log.info("Retrying for notification: {}. failed: {}, Thread: {}", notification.getTitle(), retryTokens,
+			Thread.currentThread().getName());
+		MulticastMessage message = fcmMessageFactory.createMessage(notification, retryTokens).get(0);


get(0)을 하는 이유에 대해 설명해주실 수 있낭요

토큰이 500개 이상인 경우 500개당 1개의 MulticastMessage 객체를 만드는데, fcmMessageFactory에서는 일원화를 위해 500개 미만이어도 리스트에 담아 반환하고 있습니다. 그리고 List<MulticastMessage>를 forEach를 통해 하나씩 전송하구요.

�FcmResponseHandler에서의 재시도 처리는 한 개의 MulticastMessage만을 대상으로 하는데요, 그래서 여기서 fcmMessageFactory.createMessage()로 얻는 리스트는 1개의 MulticastMessage를 가질 수 밖에 없습니다. 그래서 get(0)으로 그걸 꺼내오는거에요!

pricelees · 2024-10-13T05:08:27Z

backend/src/main/java/mouda/backend/notification/infrastructure/entity/SubscriptionEntity.java

+	public void changeChatRoomSubscription(long darakbangId, long chatRoomId) {
+		for (UnsubscribedChatRooms unsubscribedChatRoom : unsubscribedChats) {
+			if (unsubscribedChatRoom.getDarakbangId() == darakbangId) {
+				unsubscribedChatRoom.changeChatRoomSubscription(chatRoomId);
+				return;
+			}
+		}
+		unsubscribedChats.add(UnsubscribedChatRooms.create(darakbangId, chatRoomId));
+	}


여기서 완전탐색을 해야한다면 Map형식으로 저장하는 것도 고려해보면 좋을 것 가탕요

다락방Id를 key, List만 가진 UnsubscribedChatRooms를 value 로 하는 방식으로요

이 부분은 조금 더 고민해볼게요. 일단 [{"darakbangId":1,"chatRoomIds":[1]},{"darakbangId":2,"chatRoomIds":[1,2]}] 형태로 데이터를 저장하고자 해서 List를 사용했어요!

@ksk0605 이건 테바가 확인해주면 좋겠네요.

pricelees · 2024-10-13T05:08:46Z

...d/src/main/java/mouda/backend/notification/infrastructure/repository/FcmTokenRepository.java

+
+    Optional<FcmTokenEntity> findByToken(String token);
+
+	void deleteAllByTokenIn(List<String> unregisteredTokens);


얘만 인덴트가 안맞아여ㅎㅎ

제꺼에서는 맞는데요..? ㅋㅋㅋ 그래도 한번 더 정렬해서 다시 올릴게요 ~

pricelees · 2024-10-13T05:09:31Z

...src/main/java/mouda/backend/notification/presentation/controller/SubscriptionController.java

+	@Override
+	public ResponseEntity<RestResponse<SubscriptionResponse>> readSpecificChatRoomSubscription(
+		@LoginMember Member member,
+		@Valid @RequestBody ChatSubscriptionRequest chatSubscriptionRequest


스웨거에서 이렇게 나와요 ㅜㅅㅜ

Get요청을 보낼때 RequestBody를 쓴 실수.. RequestParam으로 수정했어요!

pricelees · 2024-10-13T05:09:42Z

backend/src/test/java/mouda/backend/moim/implement/finder/CommentFinderTest.java

-		Long memberId = commentFinder.readMemberIdByParentId(childComment.getParentId());
-
-		assertThat(memberId).isEqualTo(darakbangHogee.getId());
-	}
 }


개행 한번만 해주세용

싫어요

pricelees · 2024-10-13T05:10:18Z

backend/src/test/java/mouda/backend/moim/implement/finder/CommentRecipientFinderTest.java

+	@Test
+	void getNewCommentNotificationRecipients() {
+	}
+
+	@Test
+	void getNewReplyNotificationRecipients() {
+	}


ㅋㅋㅋ 투두인가요?

경우의 수가 너무 많아서 고민이 필요했던 부분인데.. 테스트 추가했어요!
테스트 돌리면서 보니 처리가 하나 틀린 부분이 있더라구요. 덕분에 그거까지 수정할 수 있었네요~ 🫡

ay-eonii

짱 멋집니다 짱돌 👍

Mingyum-Kim

고생했습니다 상돌 😀 나중에 알림 작업하게 될 때 자세히 읽어볼게요 ...

ksk0605

고생했어요 상돌 이제 알림은 그만 보고싶네요 ㅋㅋ큐ㅠㅠ

ksk0605 · 2024-10-15T01:32:06Z

backend/src/main/java/mouda/backend/moim/implement/finder/MoimRecipientFinder.java

+
+		return darakbangMembers.stream()
+			.filter(darakbangMember -> darakbangMember.getId() != authorId) // TODO: 모임 만들어진 알림을 정말 만든 사람이 몰라야 하나?
+			.map(darakbangMember -> new Recipient(darakbangMember.getMemberId(), darakbangMember.getId()))
+			.toList();
+	}
+
+	public List<Recipient> getMoimStatusChangedNotificationRecipients(long moimId) {
+		List<Chamyo> chamyos = chamyoRepository.findAllByMoimId(moimId);
+
+		return chamyos.stream()
+			.filter(chamyo -> chamyo.getMoimRole() != MoimRole.MOIMER) // TODO: 모임 상태의 변화도 알림을 정말 만든 사람이 몰라야 하나?
+			.map(chamyo -> new Recipient(chamyo.getDarakbangMember().getMemberId(), chamyo.getDarakbangMember().getId()))


TODO에 있는 내용은 같이 이야기를 나눴으니까 지워주세요!

pricelees and others added 30 commits October 2, 2024 18:00

feat: FCM Token 엔티티 재정의

0bd501a

feat: 알림 구독 정보, 멤버 알림 테이블 Entity 구현

f16cd92

feat: FCM Token 엔티티 재정의

fc62b62

feat: 알림 구독 정보, 멤버 알림 테이블 Entity 구현

9adef85

feat: 모임 도메인 기본 이벤트 객체 초기 구현

3a19ee9

refactor: 채팅 구독에서의 필드명 수정 (id -> darakbangId)

a294112

feat: parentId로 댓글을 찾는 기능 추가

c11a84a

feat: 모임 도메인에서의 알림 초기 코드 작성

9a7f668

feat: application 설정 파일에서 url 정보를 가져오는 객체 구현

015659b

refactor: 알림 기능 수정을 위한 notification 패키지 초기 코드 작성

6e5105b

feat: MoimNotificationSender, MoimRecipientFinder 구현

d04ac09

feat: ChamyoNotificationSender, ChamyoRecipientFinder 구현

33652df

feat: CommentNotificationSender, CommentRecipientFinder 구현

f990605

fix: darakbangMemberId 가 아닌 memberId 를 Recipient에 담도록 수정

3b0cf76

refactor: 알림 기능 흐름 리팩토링

3443cc3

refactor: 알림 기능 스팩 변경

477c6be

refactor: 알림 구독 기능 수정 및 관련 API 추가

bfeb683

feat: FCM 토큰 등록 및 관리 로직 추가

a5a3d75

feat: FCM 알림 재전송 로직 구현

d9e2a09

test: 구독 정보 조회 테스트 추가

e24e7f7

test: 구독 정보 변경 테스트 추가

742738b

test: FCM 토큰 등록 / 갱신 / 삭제 테스트 추가

0b28a6c

test: FCM 메시지 생성 테스트 추가

fdb5864

feat: 회원 개별 알림 조회 기능 및 테스트 구현

b0f3292

style: 미사용 import 제거

584f5f1

feat: 채팅 알림 전송 기능 구현

1199190

test: 채팅 알림 수신자 필터 테스트 추가

67a0c58

refactor: 모임 취소시 생성 알림을 보내는 오류 수정

937062b

refactor: 댓글 알림 기능 수정

5a05f5d

pricelees added 4 commits October 10, 2024 19:35

Merge branch 'develop-backend' into refactor/#564

e4e2054

remove: 미사용 코드 제거

9fcf1f7

refactor: 기존 채팅 알림 전송에 사용되는 Sender 클래스명 수정

5580ce5

test: 실패하는 테스트 수정

6a6b6fc

pricelees requested review from Mingyum-Kim, ksk0605 and ay-eonii October 10, 2024 10:55

pricelees assigned ksk0605 Oct 10, 2024

pricelees requested a review from hoyeonyy October 10, 2024 10:55

pricelees added BE 백엔드 관련 이슈입니다. 🌱 기능추가 feature (새로운 기능 구현) ⚒️ 리팩터링 refactor (기능이 변경되지는 않지만 코드를 수정) labels Oct 10, 2024

fix: 채팅 알림이 저장되는 문제 해결

ed29896

ay-eonii requested changes Oct 11, 2024

View reviewed changes

pricelees added 4 commits October 13, 2024 13:20

fix: GET 요청에서 RequestBody를 사용함으로써 나오는 400 에러 해결

6fc69e1

style: 컨벤션 수정

c14ee0c

refactor: 댓글 작성시 알림 대상자 조회 로직 수정 및 테스트 추가

d05b65e

Fix: 알림 재전송 처리에서의 오타 수정

0324b84

pricelees commented Oct 13, 2024

View reviewed changes

pricelees requested a review from ay-eonii October 13, 2024 05:12

comment: 댓글 알림 대상자 조회 메서드에 주석 추가

649568e

ay-eonii approved these changes Oct 13, 2024

View reviewed changes

Mingyum-Kim approved these changes Oct 15, 2024

View reviewed changes

pricelees added 4 commits October 15, 2024 10:33

test: 채팅 알림 대상자 찾기 테스트 추가

6c20aca

refactor: TODO 제거

55a9557

Merge branch 'develop-backend' into refactor/#564

9c55d8f

refactor: 미사용 필드 제거

f60d06d

pricelees merged commit 0c432a1 into develop-backend Oct 15, 2024
1 check passed

ksk0605 approved these changes Oct 15, 2024

View reviewed changes

ay-eonii deleted the refactor/#564 branch October 17, 2024 07:15

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

푸시 알림 기능 리팩토링 및 알림 선택 구독 기능 추가 #621

푸시 알림 기능 리팩토링 및 알림 선택 구독 기능 추가 #621

pricelees commented Oct 10, 2024

ay-eonii left a comment

ay-eonii Oct 11, 2024

pricelees Oct 13, 2024

ay-eonii Oct 11, 2024

pricelees Oct 13, 2024

ay-eonii Oct 11, 2024

pricelees Oct 13, 2024

ay-eonii Oct 11, 2024

pricelees Oct 13, 2024

ay-eonii Oct 11, 2024

pricelees Oct 13, 2024 •

edited

Loading

ay-eonii Oct 11, 2024

pricelees Oct 13, 2024

ay-eonii Oct 11, 2024

pricelees Oct 13, 2024

pricelees left a comment

pricelees Oct 13, 2024

pricelees Oct 13, 2024 •

edited

Loading

pricelees Oct 13, 2024

pricelees Oct 13, 2024

pricelees Oct 13, 2024

pricelees Oct 13, 2024

pricelees Oct 13, 2024

ay-eonii left a comment

Mingyum-Kim left a comment

ksk0605 left a comment

ksk0605 Oct 15, 2024


		Optional<FcmTokenEntity> findByToken(String token);

		void deleteAllByTokenIn(List<String> unregisteredTokens);

		FcmFailedResponse retryResponse = retry(failedResponse, notification,
		failedResponse.getNonRetryableFailedTokens());

푸시 알림 기능 리팩토링 및 알림 선택 구독 기능 추가 #621

푸시 알림 기능 리팩토링 및 알림 선택 구독 기능 추가 #621

Conversation

pricelees commented Oct 10, 2024

PR의 목적이 무엇인가요?

이슈 ID는 무엇인가요?

설명

질문 혹은 공유 사항 (Optional)

ay-eonii left a comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

pricelees Oct 13, 2024 • edited Loading

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

pricelees left a comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

pricelees Oct 13, 2024 • edited Loading

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

ay-eonii left a comment

Choose a reason for hiding this comment

Mingyum-Kim left a comment

Choose a reason for hiding this comment

ksk0605 left a comment

Choose a reason for hiding this comment

Choose a reason for hiding this comment

pricelees Oct 13, 2024 •

edited

Loading

pricelees Oct 13, 2024 •

edited

Loading