Merge pull request #290 from YAPP-Github/feat/#289

[feat #289] Fcm 토큰 중복 무시처리 및 Firebase 설정

Author: dlswns2480

.github/workflows/api-deploy.yml

@@ -40,8 +40,8 @@ jobs:
         run: |
           mkdir -p ./adapters/out-persistence/src/main/resources
           echo "${{ secrets.OUT_PERSISTENCE_YML }}" > ./adapters/out-persistence/src/main/resources/application-out-persistence.yml
-          mkdir -p ./adapters/out-web/src/main/resources
-          echo "${{ secrets.OUT_WEB_GOOGLE }}" | base64 --decode > ./adapters/out-web/src/main/resources/google-services.json
+          mkdir -p ./adapters/out-web/src/main/resources/firebase
+          echo "${{ secrets.OUT_WEB_GOOGLE }}" | base64 --decode > ./adapters/out-web/src/main/resources/firebase/push-account-key.json
           echo "${{ secrets.OUT_WEB_YML }}" > ./adapters/out-web/src/main/resources/application-out-web.yml
           mkdir -p ./application/src/main/resources
           echo "${{ secrets.APPLICATION_CORE }}" > ./application/src/main/resources/application-core.yml

.gitignore

@@ -45,5 +45,10 @@ out/
 ### Resources ###
 **/src/main/resources/application-*.yml
 **/src/main/resources/google-services.json
+**/src/main/resources/firebase/*.json
 **/src/main/resources/*.p8
-**/src/main/resources/logback.xml
+**/src/main/resources/logback.xml
+
+### Logs ###
+logs/
+*.log

adapters/out-persistence/src/main/kotlin/com/pokit/out/persistence/user/impl/FcmTokenAdapter.kt

@@ -20,4 +20,8 @@ class FcmTokenAdapter(
         return fcmTokenRepository.findByUserId(userId)
             .map { it.toDomain() }
     }
+
+    override fun loadByUserIdAndToken(userId: Long, token: String): FcmToken? {
+        return fcmTokenRepository.findByUserIdAndToken(userId, token)?.toDomain()
+    }
 }

adapters/out-persistence/src/main/kotlin/com/pokit/out/persistence/user/persist/FcmTokenRepository.kt

@@ -4,4 +4,6 @@ import org.springframework.data.jpa.repository.JpaRepository
 
 interface FcmTokenRepository : JpaRepository<FcmTokenEntity, Long> {
     fun findByUserId(userId: Long): List<FcmTokenEntity>
+
+    fun findByUserIdAndToken(userId: Long, token: String): FcmTokenEntity?
 }

adapters/out-web/src/main/kotlin/com/pokit/alert/config/FirebaseConfig.kt

@@ -1,15 +1,32 @@
 package com.pokit.alert.impl
 
+import com.google.auth.oauth2.GoogleCredentials
+import com.google.firebase.FirebaseApp
+import com.google.firebase.FirebaseOptions
 import com.google.firebase.messaging.FirebaseMessaging
 import com.google.firebase.messaging.FirebaseMessagingException
 import com.google.firebase.messaging.Message
 import com.google.firebase.messaging.Notification
 import com.pokit.alert.port.out.AlertSender
 import io.github.oshai.kotlinlogging.KotlinLogging
+import jakarta.annotation.PostConstruct
+import org.springframework.core.io.ClassPathResource
 import org.springframework.stereotype.Component
 
 @Component
 class FcmSender : AlertSender {
+    @PostConstruct
+    fun init() {
+        if (FirebaseApp.getApps().isEmpty()) {
+            val firebaseCredentials = ClassPathResource("/firebase/push-account-key.json").inputStream
+            val options = FirebaseOptions.builder()
+                .setCredentials(GoogleCredentials.fromStream(firebaseCredentials))
+                .build()
+            FirebaseApp.initializeApp(options)
+        }
+    }
+
+
     private val logger = KotlinLogging.logger { }
 
     companion object {

adapters/out-web/src/main/kotlin/com/pokit/alert/impl/FcmSender.kt

@@ -6,4 +6,6 @@ interface FcmTokenPort {
     fun persist(fcmToken: FcmToken): FcmToken
 
     fun loadByUserId(userId: Long): List<FcmToken>
+
+    fun loadByUserIdAndToken(userId: Long, token: String): FcmToken?
 }

application/src/main/kotlin/com/pokit/user/port/out/FcmTokenPort.kt

@@ -112,6 +112,9 @@ class UserService(
     override fun createFcmToken(userId: Long, request: CreateFcmTokenRequest): FcmToken {
         val user = userPort.loadById(userId)
             ?: throw NotFoundCustomException(UserErrorCode.NOT_FOUND_USER)
+        fcmTokenPort.loadByUserIdAndToken(user.id, request.token)
+            ?.let { return it }
+
         val fcmToken = FcmToken(user.id, request.token)
         return fcmTokenPort.persist(fcmToken)
     }