feat: 푸시 알림 클라이언트 로직 구현 및 서버 API 연동

app/src/main/AndroidManifest.xml

@@ -8,7 +8,7 @@
 
     <uses-permission android:name="android.permission.INTERNET" />
     <uses-permission android:name="android.permission.CAMERA" />
-    <uses-permission android:name="android.permission.POST_NOTIFICATIONS"/>
+    <uses-permission android:name="android.permission.POST_NOTIFICATIONS" />
 
     <application
         android:name=".BooketApplication"
@@ -41,6 +41,10 @@
                 android:name="com.ninecraft.booket.initializer.FirebaseCrashlyticsInitializer"
                 android:value="androidx.startup" />
 
+            <meta-data
+                android:name="com.ninecraft.booket.initializer.NotificationChannelInitializer"
+                android:value="androidx.startup" />
+
         </provider>
 
         <activity
@@ -73,6 +77,19 @@
                 tools:replace="android:resource" />
         </provider>
 
+        <service
+            android:name=".ReedFirebaseMessagingService"
+            android:exported="false">
+            <intent-filter>
+                <action android:name="com.google.firebase.MESSAGING_EVENT" />
+            </intent-filter>
+        </service>
+
+        <meta-data
+            android:name="com.google.firebase.messaging.default_notification_icon"
+            android:resource="@drawable/ic_notification" />
+        <meta-data
+            android:name="com.google.firebase.messaging.default_notification_color"
+            android:resource="@color/green_500" />
     </application>
-
 </manifest>

app/src/main/kotlin/com/ninecraft/booket/ReedFirebaseMessagingService.kt

@@ -0,0 +1,93 @@
+package com.ninecraft.booket
+
+import android.app.NotificationChannel
+import android.app.NotificationManager
+import android.app.PendingIntent
+import android.content.Context
+import android.content.Intent
+import androidx.core.app.NotificationCompat
+import androidx.core.content.ContextCompat
+import com.google.firebase.messaging.FirebaseMessagingService
+import com.google.firebase.messaging.RemoteMessage
+import com.ninecraft.booket.core.data.api.repository.UserRepository
+import com.ninecraft.booket.core.designsystem.R
+import com.ninecraft.booket.feature.main.MainActivity
+import dagger.hilt.android.AndroidEntryPoint
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.SupervisorJob
+import kotlinx.coroutines.cancel
+import kotlinx.coroutines.launch
+import javax.inject.Inject
+
+@AndroidEntryPoint
+class ReedFirebaseMessagingService : FirebaseMessagingService() {
+
+    @Inject
+    lateinit var userRepository: UserRepository
+
+    private val scope = CoroutineScope(Dispatchers.IO + SupervisorJob())
+
+    override fun onNewToken(token: String) {
+        super.onNewToken(token)
+
+        scope.launch {
+            userRepository.syncFcmToken(token)
+        }
+    }
+
+    override fun onMessageReceived(message: RemoteMessage) {
+        super.onMessageReceived(message)
+
+        val title = message.notification?.title ?: "Reed"
+        val body = message.notification?.body ?: ""
+
+        val intent = Intent(this, MainActivity::class.java).apply {
+            flags = Intent.FLAG_ACTIVITY_CLEAR_TOP or Intent.FLAG_ACTIVITY_SINGLE_TOP
+        }
+
+        val pendingIntent = PendingIntent.getActivity(
+            this,
+            0,
+            intent,
+            PendingIntent.FLAG_UPDATE_CURRENT or PendingIntent.FLAG_IMMUTABLE,
+        )
+
+        val builder = NotificationCompat.Builder(this, REED_CHANNEL_ID)
+            .setSmallIcon(R.drawable.ic_notification)
+            .setColor(ContextCompat.getColor(this, R.color.green_500))
+            .setContentTitle(title)
+            .setContentText(body)
+            .setContentIntent(pendingIntent)
+            .setAutoCancel(true)
+            .setPriority(NotificationCompat.PRIORITY_DEFAULT)
+
+        val manager = getSystemService(Context.NOTIFICATION_SERVICE) as NotificationManager
+        manager.notify(System.currentTimeMillis().toInt(), builder.build())
+    }
+
+    override fun onDestroy() {
+        scope.cancel()
+        super.onDestroy()
+    }
+
+    companion object {
+        private const val REED_CHANNEL_ID = "REED_PUSH_CHANNEL"
+        private const val REED_CHANNEL_NAME = "리드 푸시 알림"
+        private const val REED_CHANNEL_DESC = "리드 앱에서 보내는 푸시 알림을 관리합니다."
+
+        // Android 8.0 이상 필수 채널 생성
+        fun createNotificationChannel(context: Context) {
+            val channel = NotificationChannel(
+                REED_CHANNEL_ID,
+                REED_CHANNEL_NAME,
+                NotificationManager.IMPORTANCE_DEFAULT,
+            ).apply {
+                description = REED_CHANNEL_DESC
+            }
+
+            val manager = context.getSystemService(NOTIFICATION_SERVICE) as NotificationManager
+            manager.createNotificationChannel(channel)
+        }
+    }
+}

app/src/main/kotlin/com/ninecraft/booket/initializer/NotificationChannelInitializer.kt

@@ -0,0 +1,16 @@
+package com.ninecraft.booket.initializer
+
+import android.content.Context
+import androidx.startup.Initializer
+import com.ninecraft.booket.ReedFirebaseMessagingService.Companion.createNotificationChannel
+
+class NotificationChannelInitializer : Initializer<Unit> {
+
+    override fun create(context: Context) {
+        createNotificationChannel(context)
+    }
+
+    override fun dependencies(): List<Class<out Initializer<*>>> {
+        return emptyList()
+    }
+}

build-logic/src/main/kotlin/AndroidFirebaseConventionPlugin.kt

@@ -19,6 +19,7 @@ internal class AndroidFirebaseConventionPlugin : Plugin<Project> {
                 implementation(platform(libs.firebase.bom))
                 implementation(libs.firebase.analytics)
                 implementation(libs.firebase.crashlytics)
+                implementation(libs.firebase.messaging)
             }
         }
     }

core/data/api/src/main/kotlin/com/ninecraft/booket/core/data/api/repository/UserRepository.kt

@@ -14,7 +14,19 @@ interface UserRepository {
 
     suspend fun setOnboardingCompleted(isCompleted: Boolean)
 
-    val isNotificationEnabled: Flow<Boolean>
+    suspend fun syncFcmToken(): Result<Unit>
 
-    suspend fun setNotificationEnabled(isEnabled: Boolean)
+    suspend fun syncFcmToken(fcmToken: String): Result<Unit>
+
+    val isUserNotificationEnabled: Flow<Boolean>
+
+    suspend fun getUserNotificationEnabled(): Boolean
+
+    suspend fun setUserNotificationEnabled(isEnabled: Boolean)
+
+    suspend fun getLastSyncedNotificationEnabled(): Boolean?
+
+    suspend fun setLastNotificationSyncedEnabled(isEnabled: Boolean)
+
+    suspend fun updateNotificationSettings(notificationEnabled: Boolean): Result<UserProfileModel>
 }

core/data/impl/build.gradle.kts

@@ -28,6 +28,7 @@ dependencies {
 
         platform(libs.firebase.bom),
         libs.firebase.remote.config,
+        libs.firebase.messaging,
         libs.logger,
     )
 }

core/data/impl/src/main/kotlin/com/ninecraft/booket/core/data/impl/di/FirebaseModule.kt

@@ -1,6 +1,8 @@
 package com.ninecraft.booket.core.data.impl.di
 
 import com.google.firebase.Firebase
+import com.google.firebase.messaging.FirebaseMessaging
+import com.google.firebase.messaging.messaging
 import com.google.firebase.remoteconfig.FirebaseRemoteConfig
 import com.google.firebase.remoteconfig.remoteConfig
 import com.google.firebase.remoteconfig.remoteConfigSettings
@@ -26,4 +28,8 @@ internal object FirebaseModule {
             setConfigSettingsAsync(configSettings)
         }
     }
+
+    @Singleton
+    @Provides
+    fun provideFirebaseMessaging(): FirebaseMessaging = Firebase.messaging
 }

core/data/impl/src/main/kotlin/com/ninecraft/booket/core/data/impl/mapper/ResponseToModel.kt

@@ -49,6 +49,7 @@ internal fun UserProfileResponse.toModel(): UserProfileModel {
         nickname = nickname,
         provider = provider,
         termsAgreed = termsAgreed,
+        notificationEnabled = notificationEnabled,
     )
 }
 

core/data/impl/src/main/kotlin/com/ninecraft/booket/core/data/impl/repository/DefaultAuthRepository.kt

@@ -2,6 +2,7 @@ package com.ninecraft.booket.core.data.impl.repository
 
 import com.ninecraft.booket.core.common.utils.runSuspendCatching
 import com.ninecraft.booket.core.data.api.repository.AuthRepository
+import com.ninecraft.booket.core.datastore.api.datasource.NotificationDataSource
 import com.ninecraft.booket.core.datastore.api.datasource.TokenDataSource
 import com.ninecraft.booket.core.model.AutoLoginState
 import com.ninecraft.booket.core.model.UserState
@@ -15,6 +16,7 @@ private const val KAKAO_PROVIDER_TYPE = "KAKAO"
 internal class DefaultAuthRepository @Inject constructor(
     private val service: ReedService,
     private val tokenDataSource: TokenDataSource,
+    private val notificationDataSource: NotificationDataSource,
 ) : AuthRepository {
     override suspend fun login(accessToken: String) = runSuspendCatching {
         val response = service.login(
@@ -29,6 +31,7 @@ internal class DefaultAuthRepository @Inject constructor(
     override suspend fun logout() = runSuspendCatching {
         service.logout()
         clearTokens()
+        clearNotificationDataStore()
     }
 
     override suspend fun withdraw() = runSuspendCatching {
@@ -61,4 +64,8 @@ internal class DefaultAuthRepository @Inject constructor(
         val accessToken = tokenDataSource.getAccessToken()
         return if (accessToken.isBlank()) UserState.Guest else UserState.LoggedIn
     }
+
+    private suspend fun clearNotificationDataStore() {
+        notificationDataSource.clearNotificationDataStore()
+    }
 }

core/data/impl/src/main/kotlin/com/ninecraft/booket/core/data/impl/repository/DefaultUserRepository.kt

@@ -1,18 +1,26 @@
 package com.ninecraft.booket.core.data.impl.repository
 
+import com.google.firebase.messaging.FirebaseMessaging
 import com.ninecraft.booket.core.common.utils.runSuspendCatching
 import com.ninecraft.booket.core.data.api.repository.UserRepository
 import com.ninecraft.booket.core.data.impl.mapper.toModel
 import com.ninecraft.booket.core.datastore.api.datasource.NotificationDataSource
 import com.ninecraft.booket.core.datastore.api.datasource.OnboardingDataSource
+import com.ninecraft.booket.core.network.request.FcmTokenRequest
+import com.ninecraft.booket.core.network.request.NotificationSettingsRequest
 import com.ninecraft.booket.core.network.request.TermsAgreementRequest
 import com.ninecraft.booket.core.network.service.ReedService
+import com.orhanobut.logger.Logger
+import kotlinx.coroutines.flow.first
+import kotlinx.coroutines.flow.firstOrNull
+import kotlinx.coroutines.tasks.await
 import javax.inject.Inject
 
 internal class DefaultUserRepository @Inject constructor(
     private val service: ReedService,
     private val onboardingDataSource: OnboardingDataSource,
     private val notificationDataSource: NotificationDataSource,
+    private val firebaseMessaging: FirebaseMessaging,
 ) : UserRepository {
     override suspend fun agreeTerms(termsAgreed: Boolean) = runSuspendCatching {
         service.agreeTerms(TermsAgreementRequest(termsAgreed)).toModel()
@@ -28,9 +36,59 @@ internal class DefaultUserRepository @Inject constructor(
         onboardingDataSource.setOnboardingCompleted(isCompleted)
     }
 
-    override val isNotificationEnabled = notificationDataSource.isNotificationEnabled
+    override suspend fun syncFcmToken() = runSuspendCatching {
+        val newToken = getRemoteFcmToken()
+        val localToken = getLocalFcmToken()
 
-    override suspend fun setNotificationEnabled(isEnabled: Boolean) {
-        notificationDataSource.setNotificationEnabled(isEnabled)
+        if (newToken == localToken) {
+            Logger.d("Skip FCM token sync (already up-to-date)")
+            return@runSuspendCatching
+        }
+
+        updateFcmToken(newToken)
+        setFcmToken(newToken)
+    }
+
+    override suspend fun syncFcmToken(fcmToken: String): Result<Unit> = runSuspendCatching {
+        updateFcmToken(fcmToken)
+        setFcmToken(fcmToken)
+    }
+
+    override val isUserNotificationEnabled = notificationDataSource.isUserNotificationEnabled
+
+    override suspend fun getUserNotificationEnabled(): Boolean = isUserNotificationEnabled.first()
+
+    override suspend fun setUserNotificationEnabled(isEnabled: Boolean) {
+        notificationDataSource.setUserNotificationEnabled(isEnabled)
+    }
+
+    override suspend fun getLastSyncedNotificationEnabled(): Boolean? =
+        notificationDataSource.lastSyncedNotificationEnabled.firstOrNull()
+
+    override suspend fun setLastNotificationSyncedEnabled(isEnabled: Boolean) {
+        notificationDataSource.setLastSyncedNotificationEnabled(isEnabled)
+    }
+
+    override suspend fun updateNotificationSettings(notificationEnabled: Boolean) = runSuspendCatching {
+        service.updateNotificationSettings(NotificationSettingsRequest(notificationEnabled)).toModel()
+    }
+
+    private suspend fun getRemoteFcmToken(): String {
+        return try {
+            firebaseMessaging.token.await()
+        } catch (e: Exception) {
+            Logger.e("Failed to fetch FCM token: ${e.message}")
+            throw e
+        }
+    }
+
+    private suspend fun getLocalFcmToken(): String = notificationDataSource.fcmToken.first()
+
+    private suspend fun setFcmToken(fcmToken: String) {
+        notificationDataSource.setFcmToken(fcmToken)
+    }
+
+    private suspend fun updateFcmToken(fcmToken: String) {
+        service.updateFcmToken(FcmTokenRequest(fcmToken))
     }
 }

core/datastore/api/src/main/kotlin/com/ninecraft/booket/core/datastore/api/datasource/NotificationDataSource.kt

@@ -3,6 +3,14 @@ package com.ninecraft.booket.core.datastore.api.datasource
 import kotlinx.coroutines.flow.Flow
 
 interface NotificationDataSource {
-    val isNotificationEnabled: Flow<Boolean>
-    suspend fun setNotificationEnabled(isEnabled: Boolean)
+    val fcmToken: Flow<String>
+    suspend fun setFcmToken(fcmToken: String)
+
+    val isUserNotificationEnabled: Flow<Boolean>
+    suspend fun setUserNotificationEnabled(isEnabled: Boolean)
+
+    val lastSyncedNotificationEnabled: Flow<Boolean?>
+    suspend fun setLastSyncedNotificationEnabled(isEnabled: Boolean)
+
+    suspend fun clearNotificationDataStore()
 }