[FEAT] FCM Token 발급, 등록, 푸시알림 기능 구현 및 기타 QA수정

app/build.gradle.kts

@@ -103,6 +103,7 @@ dependencies {
     implementation(libs.foundation)
     implementation(libs.androidx.lifecycle.runtime.compose)
     implementation(libs.androidx.datastore.preferences)
+    implementation(libs.firebase.messaging)
     testImplementation(libs.junit)
     androidTestImplementation(libs.androidx.junit)
     androidTestImplementation(libs.androidx.espresso.core)

app/src/main/AndroidManifest.xml

@@ -3,6 +3,7 @@
     xmlns:tools="http://schemas.android.com/tools">
 
     <uses-permission android:name="android.permission.INTERNET" />
+    <uses-permission android:name="android.permission.POST_NOTIFICATIONS" />
 
     <application
         android:name=".ThipApplication"
@@ -47,5 +48,13 @@
                 <category android:name="android.intent.category.LAUNCHER" />
             </intent-filter>
         </activity>
+
+        <service
+            android:name=".service.MyFirebaseMessagingService"
+            android:exported="false">
+            <intent-filter>
+                <action android:name="com.google.firebase.MESSAGING_EVENT" />
+            </intent-filter>
+        </service>
     </application>
 </manifest>

app/src/main/java/com/texthip/thip/MainActivity.kt

@@ -4,6 +4,7 @@ import android.os.Bundle
 import androidx.activity.ComponentActivity
 import androidx.activity.compose.setContent
 import androidx.activity.enableEdgeToEdge
+import androidx.activity.result.contract.ActivityResultContracts
 import androidx.compose.runtime.Composable
 import androidx.compose.runtime.LaunchedEffect
 import androidx.navigation.compose.NavHost
@@ -14,6 +15,7 @@ import com.texthip.thip.data.manager.TokenManager
 import com.texthip.thip.ui.navigator.navigations.authNavigation
 import com.texthip.thip.ui.navigator.routes.CommonRoutes
 import com.texthip.thip.ui.theme.ThipTheme
+import com.texthip.thip.utils.permission.NotificationPermissionUtils
 import dagger.hilt.android.AndroidEntryPoint
 import kotlinx.coroutines.flow.collectLatest
 import javax.inject.Inject
@@ -22,19 +24,34 @@ import javax.inject.Inject
 class MainActivity : ComponentActivity() {
     @Inject
     lateinit var tokenManager: TokenManager
+
     @Inject
     lateinit var authStateManager: AuthStateManager
 
+    private val notificationPermissionLauncher = registerForActivityResult(
+        ActivityResultContracts.RequestPermission()
+    ) {}
+
     override fun onCreate(savedInstanceState: Bundle?) {
         super.onCreate(savedInstanceState)
         enableEdgeToEdge()
+
+        // 앱 시작 시 알림 권한 요청
+        requestNotificationPermissionIfNeeded()
+
         setContent {
             ThipTheme {
                 RootNavHost(authStateManager)
             }
         }
 //        getKakaoKeyHash(this)
     }
+
+    private fun requestNotificationPermissionIfNeeded() {
+        if (NotificationPermissionUtils.shouldRequestNotificationPermission(this)) {
+            notificationPermissionLauncher.launch(android.Manifest.permission.POST_NOTIFICATIONS)
+        }
+    }
 }
 
 @Composable
@@ -48,7 +65,7 @@ fun RootNavHost(authStateManager: AuthStateManager) {
             }
         }
     }
-    
+
     NavHost(
         navController = navController,
         startDestination = CommonRoutes.Splash

app/src/main/java/com/texthip/thip/MainScreen.kt

@@ -38,6 +38,7 @@ fun MainScreen(
                             MainTabRoutes.Feed -> {
                                 feedReselectionTrigger += 1
                             }
+
                             else -> {
                                 // 다른 탭들은 향후 확장 가능
                             }

app/src/main/java/com/texthip/thip/ThipApplication.kt

@@ -8,7 +8,7 @@ import javax.inject.Inject
 
 
 @HiltAndroidApp
-class ThipApplication : Application(){
+class ThipApplication : Application() {
     @Inject
     lateinit var tokenManager: TokenManager
 
@@ -18,7 +18,7 @@ class ThipApplication : Application(){
         // 카카오 SDK 초기화
         try {
             KakaoSdk.init(this, BuildConfig.NATIVE_APP_KEY)
-        }catch (e: Exception){
+        } catch (e: Exception) {
             e.printStackTrace()
         }
     }

app/src/main/java/com/texthip/thip/data/di/ServiceModule.kt

@@ -7,6 +7,7 @@ import com.texthip.thip.data.service.CommentsService
 import com.texthip.thip.data.service.FeedService
 import com.texthip.thip.data.service.RoomsService
 import com.texthip.thip.data.service.UserService
+import com.texthip.thip.data.service.NotificationService
 import dagger.Module
 import dagger.Provides
 import dagger.hilt.InstallIn
@@ -56,4 +57,9 @@ object ServiceModule {
     @Singleton
     fun provideFeedService(retrofit: Retrofit): FeedService =
         retrofit.create(FeedService::class.java)
+
+    @Provides
+    @Singleton
+    fun provideNotificationService(retrofit: Retrofit): NotificationService =
+        retrofit.create(NotificationService::class.java)
 }

app/src/main/java/com/texthip/thip/data/manager/FcmTokenManager.kt

@@ -0,0 +1,111 @@
+package com.texthip.thip.data.manager
+
+import android.content.Context
+import android.util.Log
+import androidx.datastore.core.DataStore
+import androidx.datastore.preferences.core.Preferences
+import androidx.datastore.preferences.core.edit
+import androidx.datastore.preferences.core.stringPreferencesKey
+import com.google.firebase.messaging.FirebaseMessaging
+import com.texthip.thip.data.repository.NotificationRepository
+import com.texthip.thip.utils.auth.getAppScopeDeviceId
+import com.texthip.thip.utils.permission.NotificationPermissionUtils
+import dagger.hilt.android.qualifiers.ApplicationContext
+import kotlinx.coroutines.flow.first
+import kotlinx.coroutines.flow.map
+import kotlinx.coroutines.suspendCancellableCoroutine
+import kotlin.coroutines.resume
+import kotlin.coroutines.resumeWithException
+import javax.inject.Inject
+import javax.inject.Singleton
+
+@Singleton
+class FcmTokenManager @Inject constructor(
+    private val dataStore: DataStore<Preferences>,
+    private val notificationRepository: NotificationRepository,
+    @param:ApplicationContext private val context: Context
+) {
+
+    companion object {
+        private val FCM_TOKEN_KEY = stringPreferencesKey("fcm_token")
+    }
+
+    suspend fun handleNewToken(newToken: String) {
+        val storedToken = getFcmTokenOnce()
+
+        if (storedToken != newToken) {
+            Log.d("FCM", "Token updated")
+
+            saveFcmToken(newToken)
+            sendTokenToServer(newToken)
+        }
+    }
+
+    suspend fun sendCurrentTokenIfExists() {
+        val storedFcmToken = getFcmTokenOnce()
+
+        if (storedFcmToken != null) {
+            sendTokenToServer(storedFcmToken)
+        } else {
+            // 저장된 토큰이 없으면 Firebase에서 직접 가져와서 저장하고 전송
+            try {
+                val token = fetchCurrentToken()
+                saveFcmToken(token)
+                sendTokenToServer(token)
+            } catch (e: Exception) {
+                Log.e("FCM", "Failed to fetch and send current token", e)
+            }
+        }
+    }
+
+    private suspend fun fetchCurrentToken(): String = suspendCancellableCoroutine { continuation ->
+        try {
+            FirebaseMessaging.getInstance().token.addOnCompleteListener { task ->
+                when {
+                    task.isSuccessful -> {
+                        val token = task.result
+                        if (token != null) {
+                            continuation.resume(token)
+                        } else {
+                            continuation.resumeWithException(IllegalStateException("FCM token is null"))
+                        }
+                    }
+                    else -> {
+                        val exception = task.exception ?: Exception("Unknown error fetching FCM token")
+                        Log.w("FCM", "Failed to fetch token", exception)
+                        continuation.resumeWithException(exception)
+                    }
+                }
+            }
+        } catch (e: Exception) {
+            Log.e("FCM", "Error fetching FCM token", e)
+            continuation.resumeWithException(e)
+        }
+    }
+
+    // FCM 토큰 로컬 저장 관리
+    private suspend fun saveFcmToken(token: String) {
+        dataStore.edit { prefs -> prefs[FCM_TOKEN_KEY] = token }
+    }
+
+    private suspend fun getFcmTokenOnce(): String? {
+        return dataStore.data.map { prefs -> prefs[FCM_TOKEN_KEY] }.first()
+    }
+
+    private suspend fun sendTokenToServer(token: String) {
+        // 알림 권한이 없으면 토큰을 서버에 전송하지 않음
+        if (!NotificationPermissionUtils.isNotificationPermissionGranted(context)) {
+            Log.w("FCM", "Notification permission not granted, skipping token registration")
+            return
+        }
+
+        val deviceId = context.getAppScopeDeviceId()
+        notificationRepository.registerFcmToken(deviceId, token)
+            .onSuccess {
+                Log.d("FCM", "Token sent successfully")
+            }
+            .onFailure { exception ->
+                Log.e("FCM", "Failed to send token", exception)
+            }
+    }
+}

app/src/main/java/com/texthip/thip/data/manager/Genre.kt

@@ -1,8 +1,6 @@
 package com.texthip.thip.data.manager
 
-/**
- * 도서 장르를 나타내는 enum class
- */
+
 enum class Genre(
     val displayKey: String,
     val apiCategory: String,

app/src/main/java/com/texthip/thip/data/manager/TokenManager.kt

@@ -18,7 +18,7 @@ class TokenManager @Inject constructor(
     companion object {
         private val APP_TOKEN_KEY = stringPreferencesKey("app_token") // 정식 액세스토큰
         private val TEMP_TOKEN_KEY = stringPreferencesKey("temp_token") // 임시 토큰
-        private val REFRESH_TOKEN_KEY = stringPreferencesKey("refresh_token")
+        //private val REFRESH_TOKEN_KEY = stringPreferencesKey("refresh_token")
     }
 
     // ====== 정식 토큰 ======
@@ -54,13 +54,13 @@ class TokenManager @Inject constructor(
     }
 
     // ====== Refresh 토큰 (추후 확장용) ======
-    suspend fun saveRefreshToken(token: String) {
+    /*suspend fun saveRefreshToken(token: String) {
         dataStore.edit { prefs -> prefs[REFRESH_TOKEN_KEY] = token }
     }
 
     suspend fun getRefreshTokenOnce(): String? {
         return dataStore.data.map { prefs -> prefs[REFRESH_TOKEN_KEY] }.first()
-    }
+    }*/
 
     suspend fun clearTokens() {
         dataStore.edit { prefs -> prefs.clear() }

app/src/main/java/com/texthip/thip/data/model/notification/request/FcmTokenDeleteRequest.kt

@@ -0,0 +1,8 @@
+package com.texthip.thip.data.model.notification.request
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class FcmTokenDeleteRequest(
+    val deviceId: String
+)

app/src/main/java/com/texthip/thip/data/model/notification/request/FcmTokenRequest.kt

@@ -0,0 +1,10 @@
+package com.texthip.thip.data.model.notification.request
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class FcmTokenRequest(
+    val deviceId: String,
+    val fcmToken: String,
+    val platformType: String = "ANDROID"
+)

app/src/main/java/com/texthip/thip/data/model/notification/request/NotificationEnabledRequest.kt

@@ -0,0 +1,9 @@
+package com.texthip.thip.data.model.notification.request
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class NotificationEnabledRequest(
+    val enable: Boolean,
+    val deviceId: String
+)

app/src/main/java/com/texthip/thip/data/model/notification/response/NotificationEnabledResponse.kt

@@ -0,0 +1,8 @@
+package com.texthip.thip.data.model.notification.response
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class NotificationEnabledResponse(
+    val isEnabled: Boolean
+)