전송 실패한 알림에 대한 로깅 구체화

backend/src/main/java/mouda/backend/notification/domain/FcmFailedResponse.java

@@ -6,6 +6,7 @@
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.function.Predicate;
+import java.util.stream.Collectors;
 import java.util.stream.IntStream;
 
 import com.google.firebase.messaging.BatchResponse;
@@ -53,14 +54,10 @@ public List<FcmToken> getFailedWith5xxTokens() {
 		return getTokens(this::isFailedWith5xx);
 	}
 
-	public List<FcmToken> getNonRetryableFailedTokens() {
-		return getTokens(errorCode -> !isFailedWith429(errorCode) && !isFailedWith5xx(errorCode));
-	}
-
-	public List<FcmToken> getFinallyFailedTokens() {
-		return failedTokens.values().stream()
-			.flatMap(List::stream)
-			.toList();
+	public Map<MessagingErrorCode, List<FcmToken>> getNonRetryableFailedTokens() {
+		return failedTokens.keySet().stream()
+			.filter(errorCode -> !isFailedWith429(errorCode) && !isFailedWith5xx(errorCode))
+			.collect(Collectors.toMap(errorCode -> errorCode, failedTokens::get));
 	}
 
 	public int getRetryAfterSeconds() {
@@ -101,4 +98,8 @@ private boolean isTokenAbsent(MessagingErrorCode... errorCodes) {
 	public boolean hasNoFailedTokens() {
 		return failedTokens.isEmpty();
 	}
+
+	public void removeFailedWith404Tokens() {
+		failedTokens.remove(MessagingErrorCode.UNREGISTERED);
+	}
 }

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

@@ -23,41 +23,40 @@ public class FcmRetryableChecker {
 
 	@Transactional
 	public boolean check(CommonNotification notification, FcmFailedResponse failedResponse, int attempt) {
-		handleNonRetryableTokens(notification, failedResponse);
 		if (failedResponse.hasNoFailedTokens()) {
 			log.info("No failed tokens for title: {}, body: {}.", notification.getTitle(), notification.getBody());
 			return false;
 		}
+		return checkWhenFailedTokensExist(notification, failedResponse, attempt);
+	}
+
+	private boolean checkWhenFailedTokensExist(
+		CommonNotification notification, FcmFailedResponse failedResponse, int attempt
+	) {
+		removeAllUnregisteredTokens(failedResponse);
 		if (attempt > MAX_ATTEMPT) {
-			log.info("Max attempt reached for title: {}, body: {}, failed: {}", notification.getTitle(),
-				notification.getBody(), failedResponse.getFinallyFailedTokens());
+			log.info("Max attempt reached for title: {}, body: {}, tokens: {}", notification.getTitle(),
+				notification.getBody(), failedResponse.getFailedTokens());
 			return false;
 		}
 		if (failedResponse.hasNoRetryableTokens()) {
-			log.info("No retryable tokens for title: {}, body: {}.", notification.getTitle(), notification.getBody());
+			log.info("No retryable tokens for title: {}, body: {}, tokens: {}", notification.getTitle(), notification.getBody(),
+				failedResponse.getNonRetryableFailedTokens());
 			return false;
 		}
 		return true;
 	}
 
-	private void handleNonRetryableTokens(CommonNotification notification, FcmFailedResponse failedResponse) {
-		List<FcmToken> nonRetryableFailedTokens = failedResponse.getNonRetryableFailedTokens();
-		if (nonRetryableFailedTokens.isEmpty()) {
-			return;
-		}
-
-		log.info("Cannot Retry for title: {}, body: {}, failed: {}.", notification.getTitle(),
-			notification.getBody(), nonRetryableFailedTokens);
-		removeAllUnregisteredTokens(failedResponse.getFailedWith404Tokens());
-	}
-
-	private void removeAllUnregisteredTokens(List<FcmToken> failedWith404Tokens) {
+	private void removeAllUnregisteredTokens(FcmFailedResponse failedResponse) {
+		List<FcmToken> failedWith404Tokens = failedResponse.getFailedWith404Tokens();
 		if (failedWith404Tokens.isEmpty()) {
 			return;
 		}
+
 		log.info("Removing all unregistered tokens: {}", failedWith404Tokens);
 		List<String> tokens = failedWith404Tokens.stream().map(FcmToken::getToken).toList();
 
 		fcmTokenWriter.deleteAll(tokens);
+		failedResponse.removeFailedWith404Tokens();
 	}
 }