[feat]: FCM api 연동

app/build.gradle.kts

@@ -3,6 +3,7 @@ plugins {
     alias(libs.plugins.kotlin.compose)
     alias(libs.plugins.hilt)
     alias(libs.plugins.ksp)
+    alias(libs.plugins.google.services)
 }
 
 android {
@@ -66,6 +67,7 @@ dependencies {
     implementation(project(":core:common"))
     implementation(project(":core:designsystem"))
     implementation(project(":core:network"))
+    implementation(project(":core:notification"))
 
     implementation(project(":feature:splash"))
     implementation(project(":feature:login"))

app/src/main/AndroidManifest.xml

@@ -6,7 +6,7 @@
 
     <application
         android:name=".NeveraApplication"
-        android:allowBackup="true"
+        android:allowBackup="false"
         android:dataExtractionRules="@xml/data_extraction_rules"
         android:fullBackupContent="@xml/backup_rules"
         android:icon="@mipmap/ic_launcher"
@@ -18,12 +18,19 @@
         <activity
             android:name=".MainActivity"
             android:exported="true"
-            android:label="@string/app_name"
             android:theme="@style/Theme.Nevera">
             <intent-filter>
                 <action android:name="android.intent.action.MAIN" />
                 <category android:name="android.intent.category.LAUNCHER" />
             </intent-filter>
+
+            <!-- Push notification deep link: nevera://{path} -->
+            <intent-filter>
+                <action android:name="android.intent.action.VIEW" />
+                <category android:name="android.intent.category.DEFAULT" />
+                <category android:name="android.intent.category.BROWSABLE" />
+                <data android:scheme="nevera" />
+            </intent-filter>
         </activity>
 
     </application>

app/src/main/kotlin/com/anddd/nevera/NeveraApplication.kt

@@ -1,6 +1,8 @@
 package com.anddd.nevera
 
 import android.app.Application
+import android.app.NotificationChannel
+import android.app.NotificationManager
 import android.content.Intent
 import com.anddd.nevera.core.network.auth.SessionEventBus
 import dagger.hilt.android.HiltAndroidApp
@@ -9,6 +11,7 @@ import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.SupervisorJob
 import kotlinx.coroutines.launch
 import javax.inject.Inject
+import com.anddd.nevera.core.notification.R as NotificationR
 
 @HiltAndroidApp
 class NeveraApplication : Application() {
@@ -20,9 +23,20 @@ class NeveraApplication : Application() {
 
     override fun onCreate() {
         super.onCreate()
+        createNotificationChannel()
         observeSessionExpired()
     }
 
+    private fun createNotificationChannel() {
+        val channel = NotificationChannel(
+            getString(NotificationR.string.default_notification_channel_id),
+            getString(NotificationR.string.default_notification_channel_name),
+            NotificationManager.IMPORTANCE_DEFAULT,
+        )
+        val notificationManager = getSystemService(NOTIFICATION_SERVICE) as NotificationManager
+        notificationManager.createNotificationChannel(channel)
+    }
+
     /**
      * 세션 만료 이벤트를 구독하여 앱 전체를 초기화한다.
      *
@@ -33,11 +47,9 @@ class NeveraApplication : Application() {
     private fun observeSessionExpired() {
         applicationScope.launch {
             sessionEventBus.sessionExpiredEvent.collect {
-                startActivity(
-                    Intent(this@NeveraApplication, MainActivity::class.java).apply {
-                        addFlags(Intent.FLAG_ACTIVITY_NEW_TASK or Intent.FLAG_ACTIVITY_CLEAR_TASK)
-                    }
-                )
+                Intent(this@NeveraApplication, MainActivity::class.java).apply {
+                    addFlags(Intent.FLAG_ACTIVITY_NEW_TASK or Intent.FLAG_ACTIVITY_CLEAR_TASK)
+                }.let(::startActivity)
             }
         }
     }

build.gradle.kts

@@ -6,4 +6,5 @@ plugins {
     alias(libs.plugins.hilt) apply false
     alias(libs.plugins.ksp) apply false
     alias(libs.plugins.kotlin.serialization) apply false
+    alias(libs.plugins.google.services) apply false
 }

core/notification/build.gradle.kts

@@ -0,0 +1,37 @@
+plugins {
+    alias(libs.plugins.android.library)
+    alias(libs.plugins.hilt)
+    alias(libs.plugins.ksp)
+}
+
+android {
+    namespace = "com.anddd.nevera.core.notification"
+    compileSdk = 36
+
+    defaultConfig {
+        minSdk = 30
+        consumerProguardFiles("consumer-rules.pro")
+    }
+
+    buildFeatures {
+        // AGP 8.0부터는 BuildConfig가 기본 비활성화 상태
+        buildConfig = true
+    }
+
+    compileOptions {
+        sourceCompatibility = JavaVersion.VERSION_17
+        targetCompatibility = JavaVersion.VERSION_17
+    }
+}
+
+dependencies {
+    implementation(project(":domain"))
+    implementation(project(":core:common"))
+
+    implementation(libs.hilt.android)
+    ksp(libs.hilt.compiler)
+    implementation(libs.androidx.core.ktx)
+
+    implementation(platform(libs.firebase.bom))
+    implementation(libs.firebase.messaging)
+}

core/notification/src/main/AndroidManifest.xml

@@ -0,0 +1,18 @@
+<?xml version="1.0" encoding="utf-8"?>
+<manifest xmlns:android="http://schemas.android.com/apk/res/android">
+
+    <application>
+        <service
+            android:name=".NeveraMessagingService"
+            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_channel_id"
+            android:value="@string/default_notification_channel_id" />
+    </application>
+
+</manifest>

core/notification/src/main/kotlin/com/anddd/nevera/core/notification/NeveraMessagingService.kt

@@ -0,0 +1,116 @@
+package com.anddd.nevera.core.notification
+
+import android.app.NotificationManager
+import android.app.PendingIntent
+import android.content.Intent
+import android.util.Log
+import androidx.core.app.NotificationCompat
+import androidx.core.net.toUri
+import com.anddd.nevera.domain.model.notification.logFcmSyncFailure
+import com.anddd.nevera.domain.usecase.notification.UpdateFcmTokenUseCase
+import com.google.firebase.messaging.FirebaseMessagingService
+import com.google.firebase.messaging.RemoteMessage
+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 NeveraMessagingService : FirebaseMessagingService() {
+
+    @Inject lateinit var updateFcmTokenUseCase: UpdateFcmTokenUseCase
+
+    private val serviceScope = CoroutineScope(SupervisorJob() + Dispatchers.IO)
+
+    override fun onNewToken(token: String) {
+        super.onNewToken(token)
+        serviceScope.launch {
+            runCatching {
+                updateFcmTokenUseCase(token)
+            }.onSuccess { result ->
+                result.logFcmSyncFailure(TAG, BuildConfig.DEBUG, Log::w)
+            }.onFailure {
+                if (BuildConfig.DEBUG) {
+                    Log.e(TAG, "FCM 토큰 업데이트 실패", it)
+                }
+            }
+        }
+    }
+
+    override fun onMessageReceived(remoteMessage: RemoteMessage) {
+        super.onMessageReceived(remoteMessage)
+        var type = NotificationType.from(remoteMessage.data[NOTIFICATION_TYPE])
+        val title = remoteMessage.data[NOTIFICATION_TITLE]
+        val body = remoteMessage.data[NOTIFICATION_BODY]
+        val deepLink = remoteMessage.data[NOTIFICATION_DEEPLINK] ?: DEFAULT_DEEP_LINK
+
+        // TODO :: 현재 type과 deepLink가 전달되고 있지 않은 상황, 임시로 type을 default로 설정합니다.
+        type = NotificationType.DEFAULT
+
+        when (type) {
+            NotificationType.DEFAULT -> {
+                showNotification(
+                    title = title,
+                    body = body,
+                    type = type,
+                    deepLink = deepLink,
+                )
+            }
+            NotificationType.UNKNOWN -> {
+                if (BuildConfig.DEBUG) {
+                    Log.e(TAG, "unknown type, $remoteMessage")
+                }
+            }
+        }
+    }
+
+    private fun showNotification(
+        title: String?,
+        body: String?,
+        type: NotificationType,
+        deepLink: String,
+    ) {
+        val intent = Intent(Intent.ACTION_VIEW, deepLink.toUri()).apply {
+            addFlags(Intent.FLAG_ACTIVITY_CLEAR_TOP)
+        }
+
+        val pendingIntent = PendingIntent.getActivity(
+            this,
+            type.ordinal,
+            intent,
+            PendingIntent.FLAG_IMMUTABLE or PendingIntent.FLAG_UPDATE_CURRENT,
+        )
+
+        val notificationBuilder = NotificationCompat.Builder(
+            this,
+            getString(R.string.default_notification_channel_id)
+        )
+
+        val notification = notificationBuilder.setContentTitle(title)
+            .setContentText(body)
+            .setSmallIcon(applicationInfo.icon)
+            .setAutoCancel(true)
+            .setContentIntent(pendingIntent)
+            .build()
+
+        val notificationManager = getSystemService(NOTIFICATION_SERVICE) as NotificationManager
+        notificationManager.notify(type.ordinal, notification)
+    }
+
+    override fun onDestroy() {
+        super.onDestroy()
+        serviceScope.cancel()
+    }
+
+    companion object {
+        private const val TAG = "NeveraMessagingService"
+        private const val NOTIFICATION_TYPE = "type"
+        private const val NOTIFICATION_TITLE = "title"
+        private const val NOTIFICATION_BODY = "body"
+        private const val NOTIFICATION_DEEPLINK = "deepLink"
+        private const val DEFAULT_DEEP_LINK = "nevera://"
+    }
+}

core/notification/src/main/kotlin/com/anddd/nevera/core/notification/NotificationType.kt

@@ -0,0 +1,11 @@
+package com.anddd.nevera.core.notification
+
+enum class NotificationType(val value: String) {
+    DEFAULT("default"),
+    UNKNOWN("unknown");
+
+    companion object {
+        fun from(value: String?): NotificationType =
+            entries.find { it.value == value } ?: UNKNOWN
+    }
+}

core/notification/src/main/res/values/strings.xml

@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="utf-8"?>
+<resources>
+    <string name="default_notification_channel_name" translatable="false">Nevera</string>
+    <string name="default_notification_channel_id" translatable="false">nevera_default</string>
+</resources>

data/build.gradle.kts

@@ -46,6 +46,10 @@ dependencies {
     implementation(libs.okhttp.logging)
     implementation(libs.datastore.preferences)
 
+    // Firebase Messaging
+    implementation(platform(libs.firebase.bom))
+    implementation(libs.firebase.messaging)
+
     testImplementation(libs.junit.jupiter)
     testRuntimeOnly(libs.junit.jupiter.engine)
     testRuntimeOnly(libs.junit.platform.launcher)

data/src/main/kotlin/com/anddd/nevera/data/api/NotificationApi.kt

@@ -0,0 +1,15 @@
+package com.anddd.nevera.data.api
+
+import com.anddd.nevera.core.network.model.ApiResponse
+import com.anddd.nevera.data.model.notification.RegisterFcmTokenRequest
+import com.anddd.nevera.data.model.notification.RegisterFcmTokenResponse
+import retrofit2.http.Body
+import retrofit2.http.POST
+
+internal interface NotificationApi {
+
+    @POST("api/v1/notification/token")
+    suspend fun registerFcmToken(
+        @Body body: RegisterFcmTokenRequest
+    ): ApiResponse<RegisterFcmTokenResponse>
+}

data/src/main/kotlin/com/anddd/nevera/data/datasource/FcmTokenLocalDataSource.kt

@@ -0,0 +1,9 @@
+package com.anddd.nevera.data.datasource
+
+internal interface FcmTokenLocalDataSource {
+    suspend fun getFcmToken(): String?
+    suspend fun saveFcmToken(token: String)
+    suspend fun isSyncNeeded(): Boolean
+    suspend fun setNeedsSync(value: Boolean)
+    suspend fun markTokenForSync(token: String)
+}

data/src/main/kotlin/com/anddd/nevera/data/datasource/FcmTokenLocalDataSourceImpl.kt

@@ -0,0 +1,50 @@
+package com.anddd.nevera.data.datasource
+
+import android.content.Context
+import androidx.datastore.core.DataStore
+import androidx.datastore.preferences.core.Preferences
+import androidx.datastore.preferences.core.booleanPreferencesKey
+import androidx.datastore.preferences.core.edit
+import androidx.datastore.preferences.core.stringPreferencesKey
+import androidx.datastore.preferences.preferencesDataStore
+import dagger.hilt.android.qualifiers.ApplicationContext
+import kotlinx.coroutines.flow.first
+import javax.inject.Inject
+
+private val Context.pushTokenDataStore: DataStore<Preferences> by preferencesDataStore(name = "push_token")
+
+internal class FcmTokenLocalDataSourceImpl @Inject constructor(
+    @param:ApplicationContext private val context: Context,
+) : FcmTokenLocalDataSource {
+
+    private val dataStore = context.pushTokenDataStore
+
+    override suspend fun getFcmToken(): String? =
+        dataStore.data.first()[KEY_FCM_TOKEN]
+
+    override suspend fun saveFcmToken(token: String) {
+        dataStore.edit { it[KEY_FCM_TOKEN] = token }
+    }
+
+    override suspend fun isSyncNeeded(): Boolean =
+        dataStore.data.first()[KEY_NEEDS_SYNC] ?: false
+
+    override suspend fun setNeedsSync(value: Boolean) {
+        dataStore.edit { it[KEY_NEEDS_SYNC] = value }
+    }
+
+    override suspend fun markTokenForSync(token: String) {
+        // DataStore.edit는 atomic transaction으로 동작한다.
+        // FCM 토큰 저장과 서버 동기화 필요 상태를 동시에 업데이트하여
+        // 토큰과 sync 상태 간의 불일치가 발생하지 않도록 한다.
+        dataStore.edit {
+            it[KEY_FCM_TOKEN] = token
+            it[KEY_NEEDS_SYNC] = true
+        }
+    }
+
+    companion object {
+        private val KEY_FCM_TOKEN = stringPreferencesKey("fcm_token")
+        private val KEY_NEEDS_SYNC = booleanPreferencesKey("fcm_token_needs_sync")
+    }
+}