[Release] 0.8.4 (versionCode 31)

.editorconfig

@@ -3,6 +3,7 @@ root = true
 [*.{kt,kts}]
 ktlint_standard_filename = enabled
 ktlint_standard_no-consecutive-comments = disabled
+ktlint_function_naming_ignore_when_annotated_with = Composable
 
 
 

app/build.gradle.kts

@@ -109,6 +109,11 @@ dependencies {
  implementation(libs.androidx.navigation.fragment.ktx)
  implementation(libs.androidx.navigation.ui.ktx)
 
+ // WorkManager (FCM 토큰 전송 예약)
+ implementation(libs.androidx.work.runtime.ktx)
+ implementation(libs.androidx.hilt.work)
+ "ksp"(libs.androidx.hilt.compiler)
+
  implementation(libs.appauth)
 
  // Kakao Map

app/src/main/AndroidManifest.xml

@@ -1,5 +1,6 @@
 <?xml version="1.0" encoding="utf-8"?>
-<manifest xmlns:android="http://schemas.android.com/apk/res/android">
+<manifest xmlns:android="http://schemas.android.com/apk/res/android"
+ xmlns:tools="http://schemas.android.com/tools">
 
  <!-- 인터넷 권한 -->
  <uses-permission android:name="android.permission.INTERNET" />
@@ -44,6 +45,18 @@
  android:name="com.kakao.sdk.AppKey"
  android:value="${KAKAO_NATIVE_APP_KEY}" />
 
+ <!-- WorkManager 기본 초기화를 끄고 Configuration.Provider로 직접 초기화합니다 -->
+ <provider
+ android:name="androidx.startup.InitializationProvider"
+ android:authorities="${applicationId}.androidx-startup"
+ android:exported="false"
+ tools:node="merge">
+ <meta-data
+ android:name="androidx.work.WorkManagerInitializer"
+ android:value="androidx.startup"
+ tools:node="remove" />
+ </provider>
+
  <provider
  android:name="androidx.core.content.FileProvider"
  android:authorities="${applicationId}.fileprovider"

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

@@ -5,13 +5,26 @@ import android.app.NotificationChannel
 import android.app.NotificationManager
 import android.content.Context
 import androidx.appcompat.app.AppCompatDelegate
+import androidx.hilt.work.HiltWorkerFactory
+import androidx.work.Configuration
 import com.google.firebase.crashlytics.FirebaseCrashlytics
 import com.kakao.vectormap.KakaoMapSdk
 import dagger.hilt.android.HiltAndroidApp
 import timber.log.Timber
+import javax.inject.Inject
 
 @HiltAndroidApp
-class ApplicationClass : Application() {
+class ApplicationClass : Application(), Configuration.Provider {
+ @Inject
+ lateinit var workerFactory: HiltWorkerFactory
+
+ /** WorkManager가 Hilt로 Worker를 생성하도록 팩토리를 넘깁니다 */
+ override val workManagerConfiguration: Configuration
+ get() =
+ Configuration.Builder()
+ .setWorkerFactory(workerFactory)
+ .build()
+
  override fun onCreate() {
  super.onCreate()
 

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/FcmService.kt

@@ -30,13 +30,15 @@ class FcmService : FirebaseMessagingService() {
 
  /**
  * 새로운 FCM 토큰이 발급되거나 갱신될 때 호출됩니다.
- * 이 토큰은 백엔드 서버로 전송되어 특정 기기에 알림을 보내는 데 사용됩니다.
+ * 기기에 저장한 뒤 서버 반영은 워커에 맡깁니다.
+ * 이 콜백은 백그라운드에서도 불려 네트워크와 로그인 상태를 확신할 수 없습니다.
  */
  override fun onNewToken(token: String) {
  super.onNewToken(token)
  Timber.tag(TAG).d("Refreshed FCM token: $token")
 
  saveFcmToken(token)
+ FcmTokenSyncWorker.enqueue(applicationContext)
  }
 
  /**

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

@@ -0,0 +1,19 @@
+package com.project200.undabang.fcm
+
+/** FcmTokenSyncWorker의 재시도 판단. 안드로이드 의존성이 없어 단위 테스트로 검증합니다 */
+object FcmTokenSyncPolicy {
+ /** 전송 실패 시 총 시도 횟수 상한 */
+ 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

@@ -0,0 +1,109 @@
+package com.project200.undabang.fcm
+
+import android.content.Context
+import androidx.hilt.work.HiltWorker
+import androidx.work.BackoffPolicy
+import androidx.work.Constraints
+import androidx.work.CoroutineWorker
+import androidx.work.ExistingWorkPolicy
+import androidx.work.NetworkType
+import androidx.work.OneTimeWorkRequestBuilder
+import androidx.work.WorkManager
+import androidx.work.WorkerParameters
+import com.project200.domain.model.FcmTokenSyncResult
+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.assisted.Assisted
+import dagger.assisted.AssistedInject
+import net.openid.appauth.AuthorizationException
+import timber.log.Timber
+import java.util.concurrent.TimeUnit
+
+/**
+ * 갱신된 FCM 토큰을 서버에 반영하는 워커입니다
+ * onNewToken()은 백그라운드나 프로세스 기동 직후에도 불려 네트워크와 로그인 상태를 확신할 수 없습니다
+ * 전송을 워커로 미뤄 연결이 잡힌 뒤에 보내고 실패하면 다시 시도합니다
+ */
+@HiltWorker
+class FcmTokenSyncWorker
+ @AssistedInject
+ constructor(
+ @Assisted appContext: Context,
+ @Assisted params: WorkerParameters,
+ private val syncFcmTokenUseCase: SyncFcmTokenUseCase,
+ private val authStateManager: AuthStateManager,
+ private val authManager: AuthManager,
+ ) : CoroutineWorker(appContext, params) {
+ override suspend fun doWork(): Result {
+ // POST /login은 @AccessTokenWithFcmApi라 401 자동 갱신이 없음 - 만료면 먼저 갱신
+ if (authStateManager.getCurrent().needsTokenRefresh) {
+ when (val refresh = authManager.refreshAccessToken()) {
+ is TokenRefreshResult.Success -> Unit
+ is TokenRefreshResult.Error -> {
+ val ex = refresh.exception
+ val invalidGrant =
+ ex?.type == AuthorizationException.TYPE_OAUTH_TOKEN_ERROR &&
+ ex.error == "invalid_grant"
+ // 세션 정리는 refreshAccessToken() 내부가 함
+ return if (FcmTokenSyncPolicy.shouldRetryAfterRefreshFailure(invalidGrant, runAttemptCount)) {
+ Result.retry()
+ } else {
+ Result.failure()
+ }
+ }
+ is TokenRefreshResult.NoRefreshToken,
+ is TokenRefreshResult.ConfigError,
+ -> return Result.failure()
+ }
+ }
+
+ val syncResult = syncFcmTokenUseCase()
+ Timber.tag(TAG).d("FCM 토큰 전송 결과: $syncResult (시도 ${runAttemptCount + 1}회)")
+
+ return when (syncResult) {
+ FcmTokenSyncResult.SUCCESS -> Result.success()
+ // 로그인 전이거나 보낼 토큰이 없는 상태 - 재시도해도 같으므로 성공 처리
+ FcmTokenSyncResult.SKIPPED -> Result.success()
+ FcmTokenSyncResult.FAILURE ->
+ if (FcmTokenSyncPolicy.shouldRetry(runAttemptCount)) Result.retry() else Result.failure()
+ }
+ }
+
+ companion object {
+ private const val TAG = "FcmTokenSyncWorker"
+ const val WORK_NAME = "fcm_token_sync"
+ private const val BACKOFF_DELAY_SECONDS = 30L
+
+ /**
+ * 토큰 등록을 예약합니다
+ * 대기 중에 토큰이 다시 갱신되면 새 요청으로 바꿔 백오프를 처음부터 다시 셉니다
+ * 워커는 실행 시점에 저장소에서 토큰을 읽으므로 마지막 값이 올라갑니다
+ */
+ fun enqueue(context: Context) {
+ val constraints =
+ Constraints.Builder()
+ .setRequiredNetworkType(NetworkType.CONNECTED)
+ .build()
+
+ val request =
+ OneTimeWorkRequestBuilder<FcmTokenSyncWorker>()
+ .setConstraints(constraints)
+ .setBackoffCriteria(
+ BackoffPolicy.EXPONENTIAL,
+ BACKOFF_DELAY_SECONDS,
+ TimeUnit.SECONDS,
+ )
+ .build()
+
+ 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/EntryState.kt

@@ -0,0 +1,11 @@
+package com.project200.undabang.main
+
+sealed class EntryState {
+ object Loading : EntryState()
+
+ object Content : EntryState()
+
+ object Login : EntryState()
+
+ data class ForceUpdate(val fromReconnect: Boolean) : EntryState()
+}