feat: FCM을 통해 푸쉬 알림 구현

.github/workflows/backend-dev-ci-cd.yml

@@ -7,12 +7,12 @@ on:
       - "backend/**"
       - ".github/workflows/backend-dev-ci-cd.yml"
       - "Dockerfile"
-#  pull_request:
-#    branches: [ "develop" ]
-#    paths:
-#     - "backend/**"
-#     - ".github/workflows/backend-dev-ci-cd.yml"
-#     - "Dockerfile"
+  # pull_request:
+  #  branches: [ "develop" ]
+  #  paths:
+  #     - "backend/**"
+  #     - ".github/workflows/backend-dev-ci-cd.yml"
+  #     - "Dockerfile"
 
 jobs:
 
@@ -44,6 +44,10 @@ jobs:
       - name: Set Application yml for dev
         run: |
           echo "${{ secrets.APPLICATION_PROPERTIES_DEV }}" > src/main/resources/application.properties
+          mkdir -p src/main/resources/fcm
+          echo '${{ secrets.FCM_SECRET_KEY }}' > src/main/resources/fcm/chongdaemarket-fcm-key.json
+          mkdir -p src/test/resources/fcm
+          echo '${{ secrets.FCM_SECRET_KEY }}' > src/test/resources/fcm/chongdaemarket-fcm-key.json
         working-directory: ./backend
 
       - name: Build with Gradle Wrapper

.github/workflows/backend-prod-ci-cd.yml

@@ -44,6 +44,10 @@ jobs:
       - name: Set Application yml for prod
         run: |
           echo "${{ secrets.APPLICATION_PROPERTIES_PROD }}" > src/main/resources/application.properties
+          mkdir -p src/main/resources/fcm
+          echo '${{ secrets.FCM_SECRET_KEY }}' > src/main/resources/fcm/chongdaemarket-fcm-key.json
+          mkdir -p src/test/resources/fcm
+          echo '${{ secrets.FCM_SECRET_KEY }}' > src/test/resources/fcm/chongdaemarket-fcm-key.json
         working-directory: ./backend
 
       - name: Build with Gradle Wrapper

backend/.gitignore

@@ -46,4 +46,4 @@ openapi3.yaml
 .idea
 
 ### FCM ###
-/src/main/resources/fcm
+/src/main/resources/fcm

backend/src/main/java/com/zzang/chongdae/auth/service/AuthService.java

@@ -11,27 +11,33 @@
 import com.zzang.chongdae.member.repository.MemberRepository;
 import com.zzang.chongdae.member.repository.entity.MemberEntity;
 import com.zzang.chongdae.member.service.NicknameGenerator;
+import com.zzang.chongdae.notification.service.FcmNotificationService;
 import java.util.UUID;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
+@Slf4j
 @RequiredArgsConstructor
 @Service
 public class AuthService {
 
+    private final FcmNotificationService notificationService;
     private final MemberRepository memberRepository;
     private final PasswordEncoder passwordEncoder;
     private final JwtTokenProvider jwtTokenProvider;
     private final NicknameGenerator nickNameGenerator;
     private final AuthClient authClient;
 
     @WriterDatabase
+    @Transactional
     public AuthInfoDto kakaoLogin(KakaoLoginRequest request) {
         String loginId = authClient.getKakaoUserInfo(request.accessToken());
         AuthProvider provider = AuthProvider.KAKAO;
         MemberEntity member = memberRepository.findByLoginId(loginId)
                 .orElseGet(() -> signup(provider, loginId, request.fcmToken()));
-        return login(member);
+        return login(member, request.fcmToken());
     }
 
     private MemberEntity signup(AuthProvider provider, String loginId, String fcmToken) {
@@ -40,12 +46,21 @@ private MemberEntity signup(AuthProvider provider, String loginId, String fcmTok
         return memberRepository.save(member);
     }
 
-    private AuthInfoDto login(MemberEntity member) {
+    private AuthInfoDto login(MemberEntity member, String fcmToken) {
         AuthMemberDto authMember = new AuthMemberDto(member);
         AuthTokenDto authToken = jwtTokenProvider.createAuthToken(member.getId().toString());
+        checkFcmToken(member, fcmToken);
+        notificationService.login(member);
         return new AuthInfoDto(authMember, authToken);
     }
 
+    private void checkFcmToken(MemberEntity member, String fcmToken) {
+        if (!memberRepository.existsByIdAndFcmToken(member.getId(), fcmToken)) {
+            log.info("토큰 갱신 사용자 id: {}", member.getId());
+            member.updateFcmToken(fcmToken);
+        }
+    }
+
     public AuthTokenDto refresh(String refreshToken) {
         Long memberId = jwtTokenProvider.getMemberIdByRefreshToken(refreshToken);
         return jwtTokenProvider.createAuthToken(memberId.toString());

backend/src/main/java/com/zzang/chongdae/auth/service/dto/KakaoLoginRequest.java

@@ -1,9 +1,9 @@
 package com.zzang.chongdae.auth.service.dto;
 
-import javax.annotation.Nullable;
+import jakarta.validation.constraints.NotEmpty;
 
 public record KakaoLoginRequest(String accessToken,
 
-                                @Nullable
+                                @NotEmpty
                                 String fcmToken) {
 }

backend/src/main/java/com/zzang/chongdae/comment/service/CommentService.java

@@ -46,8 +46,8 @@ public Long saveComment(CommentSaveRequest request, MemberEntity member) {
         CommentEntity comment = new CommentEntity(member, offering, request.content());
         CommentEntity savedComment = commentRepository.save(comment);
 
-        List<OfferingMemberEntity> members = offeringMemberRepository.findAllByOffering(offering);
-        notificationService.saveComment(savedComment, members);
+        List<OfferingMemberEntity> offeringMembers = offeringMemberRepository.findAllByOffering(offering);
+        notificationService.saveComment(savedComment, offeringMembers);
         return savedComment.getId();
     }
 

backend/src/main/java/com/zzang/chongdae/member/repository/MemberRepository.java

@@ -13,4 +13,6 @@ public interface MemberRepository extends JpaRepository<MemberEntity, Long> {
     boolean existsByNickname(String nickname);
 
     Optional<MemberEntity> findByLoginId(String loginId);
+
+    boolean existsByIdAndFcmToken(Long id, String fcmToken);
 }

backend/src/main/java/com/zzang/chongdae/member/repository/entity/MemberEntity.java

@@ -54,4 +54,8 @@ public MemberEntity(String nickname, AuthProvider provider, String loginId, Stri
     public boolean isSame(MemberEntity other) {
         return this.equals(other);
     }
+
+    public void updateFcmToken(String fcmToken) {
+        this.fcmToken = fcmToken;
+    }
 }

backend/src/main/java/com/zzang/chongdae/notification/config/FcmConfig.java

@@ -3,13 +3,8 @@
 import com.google.auth.oauth2.GoogleCredentials;
 import com.google.firebase.FirebaseApp;
 import com.google.firebase.FirebaseOptions;
-import com.zzang.chongdae.global.exception.MarketException;
-import com.zzang.chongdae.notification.exception.NotificationErrorCode;
-import java.io.File;
-import java.io.FileInputStream;
 import java.io.IOException;
-import java.net.URISyntaxException;
-import java.net.URL;
+import java.io.InputStream;
 import javax.annotation.PostConstruct;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
@@ -29,23 +24,16 @@ public void initialize() {
             return;
         }
         try {
-            URL url = this.getClass().getResource(secretKeyPath);
-            if (url == null) {
-                throw new MarketException(NotificationErrorCode.CANNOT_FIND_URL);
-            }
-            File secretKeyFile = new File(url.toURI());
-            FileInputStream secretKey = new FileInputStream(secretKeyFile);
+            InputStream secretKey = this.getClass().getResourceAsStream(secretKeyPath);
             FirebaseApp.initializeApp(fcmOptions(secretKey));
             log.info("성공적으로 FCM 앱을 초기화하였습니다.");
         } catch (IOException e) {
             e.printStackTrace();
             throw new RuntimeException(e);
-        } catch (URISyntaxException e) { // todo
-            throw new RuntimeException(e);
         }
     }
 
-    private FirebaseOptions fcmOptions(FileInputStream secretKey) throws IOException {
+    private FirebaseOptions fcmOptions(InputStream secretKey) throws IOException {
         return FirebaseOptions.builder()
                 .setCredentials(GoogleCredentials.fromStream(secretKey))
                 .build();

backend/src/main/java/com/zzang/chongdae/notification/domain/FcmCondition.java

@@ -1,11 +1,30 @@
 package com.zzang.chongdae.notification.domain;
 
+import com.zzang.chongdae.offering.repository.entity.OfferingEntity;
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 
+@Slf4j
 @Getter
 @RequiredArgsConstructor
 public class FcmCondition {
 
+    private static final String CONDITION_FORMAT_TRUE_AND_FALSE = "'%s' in topics && !('%s' in topics)";
+
     private final String value;
+
+    public static FcmCondition roomStatusCondition(OfferingEntity offering) {
+        FcmTopic offeringTopic = FcmTopic.offeringMemberTopic(offering);
+        FcmTopic proposerTopic = FcmTopic.proposerTopic(offering);
+        String value = CONDITION_FORMAT_TRUE_AND_FALSE.formatted(offeringTopic.getValue(), proposerTopic.getValue());
+        return new FcmCondition(value);
+    }
+
+    public static FcmCondition offeringCondition(OfferingEntity offering) {
+        FcmTopic memberTopic = FcmTopic.memberTopic();
+        FcmTopic proposerTopic = FcmTopic.proposerTopic(offering);
+        String value = CONDITION_FORMAT_TRUE_AND_FALSE.formatted(memberTopic.getValue(), proposerTopic.getValue());
+        return new FcmCondition(value);
+    }
 }

backend/src/main/java/com/zzang/chongdae/notification/domain/FcmData.java

@@ -0,0 +1,21 @@
+package com.zzang.chongdae.notification.domain;
+
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.Map;
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+public class FcmData {
+
+    private final Map<String, String> data = new HashMap<>();
+
+    public void addData(String key, Object value) {
+        data.put(key, value.toString());
+    }
+
+    public Map<String, String> getData() {
+        data.forEach((key, value) -> log.info("{} : {}", key, value));
+        return Collections.unmodifiableMap(data);
+    }
+}

backend/src/main/java/com/zzang/chongdae/notification/domain/FcmToken.java

@@ -1,11 +1,14 @@
 package com.zzang.chongdae.notification.domain;
 
+import com.zzang.chongdae.member.repository.entity.MemberEntity;
 import lombok.Getter;
-import lombok.RequiredArgsConstructor;
 
 @Getter
-@RequiredArgsConstructor
 public class FcmToken {
 
     private final String value;
+
+    public FcmToken(MemberEntity member) {
+        this.value = member.getFcmToken();
+    }
 }

backend/src/main/java/com/zzang/chongdae/notification/domain/FcmTokens.java

@@ -13,7 +13,7 @@ private FcmTokens(List<FcmToken> tokens) {
 
     public static FcmTokens from(List<MemberEntity> members) {
         List<FcmToken> tokens = members.stream()
-                .map(member -> new FcmToken(member.getFcmToken()))
+                .map(FcmToken::new)
                 .toList();
         return new FcmTokens(tokens);
     }

backend/src/main/java/com/zzang/chongdae/notification/domain/FcmTopic.java

@@ -0,0 +1,31 @@
+package com.zzang.chongdae.notification.domain;
+
+import com.zzang.chongdae.offering.repository.entity.OfferingEntity;
+import lombok.AccessLevel;
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+@Getter
+@RequiredArgsConstructor(access = AccessLevel.PRIVATE)
+public class FcmTopic {
+
+    private static final String TOPIC_FORMAT_MEMBER = "member";
+    private static final String TOPIC_FORMAT_OFFERING_MEMBER = "member_of_offering_%d";
+    private static final String TOPIC_FORMAT_OFFERING_PROPOSER = "proposer_of_offering_%d";
+
+    private final String value;
+
+    public static FcmTopic offeringMemberTopic(OfferingEntity offering) {
+        String value = TOPIC_FORMAT_OFFERING_MEMBER.formatted(offering.getId());
+        return new FcmTopic(value);
+    }
+
+    public static FcmTopic proposerTopic(OfferingEntity offering) {
+        String value = TOPIC_FORMAT_OFFERING_PROPOSER.formatted(offering.getId());
+        return new FcmTopic(value);
+    }
+
+    public static FcmTopic memberTopic() {
+        return new FcmTopic(TOPIC_FORMAT_MEMBER);
+    }
+}