refactor: FCM 토큰 등록 경로를 워커로 통합 #569

진입 경로와 워커가 같은 일을 두 갈래로 하던 것을 워커 하나로 모읍니다.
재시도와 백오프, 프로세스 종료 후 재개를 WorkManager가 맡습니다.

Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>

Author: edv-Shin

app/src/main/java/com/project200/undabang/di/RepositoryModule.kt

@@ -1,7 +1,9 @@
 package com.project200.undabang.di
 
 import com.project200.common.utils.ChatRoomStateRepository
+import com.project200.domain.manager.FcmTokenSyncScheduler
 import com.project200.undabang.fcm.ChatRoomStateRepositoryImpl
+import com.project200.undabang.fcm.FcmTokenSyncSchedulerImpl
 import dagger.Binds
 import dagger.Module
 import dagger.hilt.InstallIn
@@ -14,4 +16,8 @@ abstract class RepositoryModule {
     @Binds
     @Singleton
     abstract fun bindChatRoomStateRepository(impl: ChatRoomStateRepositoryImpl): ChatRoomStateRepository
+
+    @Binds
+    @Singleton
+    abstract fun bindFcmTokenSyncScheduler(impl: FcmTokenSyncSchedulerImpl): FcmTokenSyncScheduler
 }

app/src/main/java/com/project200/undabang/fcm/FcmTokenSyncPolicy.kt

@@ -3,8 +3,17 @@ package com.project200.undabang.fcm
 /** FcmTokenSyncWorker의 재시도 판단. 안드로이드 의존성이 없어 단위 테스트로 검증합니다 */
 object FcmTokenSyncPolicy {
     /** 전송 실패 시 총 시도 횟수 상한 */
-    const val MAX_ATTEMPT_COUNT = 5
+    const val MAX_ATTEMPT_COUNT = 10
 
     /** runAttemptCount는 WorkManager가 주는 값으로 첫 실행이 0입니다 */
     fun shouldRetry(runAttemptCount: Int): Boolean = runAttemptCount + 1 < MAX_ATTEMPT_COUNT
+
+    /**
+     * 토큰 갱신 실패 시 재시도 여부입니다.
+     * invalid_grant는 리프레시 토큰이 무효한 상태라 재시도해도 결과가 같습니다
+     */
+    fun shouldRetryAfterRefreshFailure(
+        invalidGrant: Boolean,
+        runAttemptCount: Int,
+    ): Boolean = !invalidGrant && shouldRetry(runAttemptCount)
 }

app/src/main/java/com/project200/undabang/fcm/FcmTokenSyncSchedulerImpl.kt

@@ -0,0 +1,18 @@
+package com.project200.undabang.fcm
+
+import android.content.Context
+import com.project200.domain.manager.FcmTokenSyncScheduler
+import dagger.hilt.android.qualifiers.ApplicationContext
+import javax.inject.Inject
+import javax.inject.Singleton
+
+@Singleton
+class FcmTokenSyncSchedulerImpl
+    @Inject
+    constructor(
+        @ApplicationContext private val context: Context,
+    ) : FcmTokenSyncScheduler {
+        override fun schedule() = FcmTokenSyncWorker.enqueue(context)
+
+        override fun cancel() = FcmTokenSyncWorker.cancel(context)
+    }

app/src/main/java/com/project200/undabang/fcm/FcmTokenSyncWorker.kt

@@ -46,10 +46,8 @@ class FcmTokenSyncWorker
                         val invalidGrant =
                             ex?.type == AuthorizationException.TYPE_OAUTH_TOKEN_ERROR &&
                                 ex.error == "invalid_grant"
-                        // invalid_grant는 재시도해도 같음. 세션 정리는 refreshAccessToken() 내부가 함
-                        return if (invalidGrant) {
-                            Result.failure()
-                        } else if (FcmTokenSyncPolicy.shouldRetry(runAttemptCount)) {
+                        // 세션 정리는 refreshAccessToken() 내부가 함
+                        return if (FcmTokenSyncPolicy.shouldRetryAfterRefreshFailure(invalidGrant, runAttemptCount)) {
                             Result.retry()
                         } else {
                             Result.failure()
@@ -102,5 +100,10 @@ class FcmTokenSyncWorker
                 WorkManager.getInstance(context)
                     .enqueueUniqueWork(WORK_NAME, ExistingWorkPolicy.REPLACE, request)
             }
+
+            /** 예약된 등록을 취소합니다. 세션이 정리되면 보낼 회원ID가 없어 실행할 이유가 없습니다 */
+            fun cancel(context: Context) {
+                WorkManager.getInstance(context).cancelUniqueWork(WORK_NAME)
+            }
         }
     }

app/src/main/java/com/project200/undabang/main/MainViewModel.kt

@@ -3,18 +3,16 @@ package com.project200.undabang.main
 import androidx.lifecycle.ViewModel
 import androidx.lifecycle.viewModelScope
 import com.project200.common.utils.NetworkMonitor
-import com.project200.domain.model.FcmTokenSyncResult
+import com.project200.domain.manager.FcmTokenSyncScheduler
 import com.project200.domain.model.UpdateCheckResult
 import com.project200.domain.usecase.CheckForUpdateUseCase
 import com.project200.domain.usecase.ClearSessionUseCase
 import com.project200.domain.usecase.GetMemberIdUseCase
-import com.project200.domain.usecase.SyncFcmTokenUseCase
 import com.project200.undabang.oauth.AuthManager
 import com.project200.undabang.oauth.AuthStateManager
 import com.project200.undabang.oauth.TokenRefreshResult
 import dagger.hilt.android.lifecycle.HiltViewModel
 import kotlinx.coroutines.CancellationException
-import kotlinx.coroutines.Job
 import kotlinx.coroutines.delay
 import kotlinx.coroutines.flow.MutableStateFlow
 import kotlinx.coroutines.flow.StateFlow
@@ -30,7 +28,7 @@ class MainViewModel
     @Inject
     constructor(
         private val checkForUpdateUseCase: CheckForUpdateUseCase,
-        private val syncFcmTokenUseCase: SyncFcmTokenUseCase,
+        private val fcmTokenSyncScheduler: FcmTokenSyncScheduler,
         private val networkMonitor: NetworkMonitor,
         private val authManager: AuthManager,
         private val authStateManager: AuthStateManager,
@@ -46,9 +44,6 @@ class MainViewModel
 
         private var wasOffline = !networkMonitor.isCurrentlyConnected()
 
-        private var registrationJob: Job? = null
-        private var registrationPending = false
-
         init {
             observeNetworkReconnection()
             observeForceLogout()
@@ -119,7 +114,8 @@ class MainViewModel
                     }
                 }
             }
-            ensureFcmRegistration()
+            // 등록은 워커에 맡김. 재시도와 백오프, 프로세스 종료 후 재개를 WorkManager가 처리
+            fcmTokenSyncScheduler.schedule()
             _entryState.compareAndSet(EntryState.Loading, EntryState.Content)
         }
 
@@ -145,9 +141,6 @@ class MainViewModel
             viewModelScope.launch {
                 networkMonitor.networkState.collect { isOnline ->
                     if (isOnline && wasOffline && _entryState.value is EntryState.Content) {
-                        if (registrationPending) {
-                            ensureFcmRegistration() // 실패했던 FCM 등록 재시도
-                        }
                         recheckForUpdateOnReconnect()
                     }
                     wasOffline = !isOnline
@@ -170,23 +163,6 @@ class MainViewModel
                 .onFailure { Timber.w(it, "재연결 후 업데이트 확인 실패 - 무시") }
         }
 
-        // FCM 토큰 등록
-        private fun ensureFcmRegistration() {
-            // 재시도 중 재연결이 겹치면 등록 요청이 중복 발행되는 것을 방지
-            if (registrationJob?.isActive == true) return
-            registrationPending = true
-            registrationJob =
-                viewModelScope.launch {
-                    // SKIPPED는 보낼 토큰이 없는 상태 - 대기를 닫지 않고 재연결 때 재시도
-                    if (syncFcmTokenUseCase() == FcmTokenSyncResult.SUCCESS) {
-                        registrationPending = false
-                        Timber.d("FCM 토큰 등록 성공")
-                    } else {
-                        Timber.w("FCM 토큰 등록 실패 - 재연결 시 재시도 예정")
-                    }
-                }
-        }
-
         private suspend fun transitionToLogin() {
             runCatching { clearSessionUseCase() }
                 .onFailure { Timber.e(it, "세션 정리 실패 - 전이는 계속") }

app/src/test/java/com/project200/undabang/fcm/FcmTokenSyncPolicyTest.kt

@@ -27,4 +27,27 @@ class FcmTokenSyncPolicyTest {
     fun `상한을 넘긴 뒤에도 재시도하지 않는다`() {
         assertThat(FcmTokenSyncPolicy.shouldRetry(FcmTokenSyncPolicy.MAX_ATTEMPT_COUNT)).isFalse()
     }
+
+    @Test
+    fun `토큰 갱신이 일시 실패하면 재시도한다`() {
+        assertThat(
+            FcmTokenSyncPolicy.shouldRetryAfterRefreshFailure(invalidGrant = false, runAttemptCount = 0),
+        ).isTrue()
+    }
+
+    @Test
+    fun `invalid_grant면 첫 시도라도 재시도하지 않는다`() {
+        assertThat(
+            FcmTokenSyncPolicy.shouldRetryAfterRefreshFailure(invalidGrant = true, runAttemptCount = 0),
+        ).isFalse()
+    }
+
+    @Test
+    fun `토큰 갱신 실패도 상한에 닿으면 재시도하지 않는다`() {
+        val lastAttempt = FcmTokenSyncPolicy.MAX_ATTEMPT_COUNT - 1
+
+        assertThat(
+            FcmTokenSyncPolicy.shouldRetryAfterRefreshFailure(invalidGrant = false, runAttemptCount = lastAttempt),
+        ).isFalse()
+    }
 }