Feature/#225

app/src/main/kotlin/com/bff/wespot/splash/SplashViewModel.kt

@@ -3,7 +3,6 @@ package com.bff.wespot.splash
 import androidx.lifecycle.ViewModel
 import androidx.lifecycle.viewModelScope
 import com.bff.wespot.domain.repository.firebase.config.RemoteConfigRepository
-import com.bff.wespot.domain.util.RemoteConfigKey
 import dagger.hilt.android.lifecycle.HiltViewModel
 import kotlinx.coroutines.flow.MutableStateFlow
 import kotlinx.coroutines.flow.asStateFlow
@@ -12,20 +11,14 @@ import javax.inject.Inject
 
 @HiltViewModel
 class SplashViewModel @Inject constructor(
-    private val dataSource: RemoteConfigRepository
+    private val remoteConfigRepository: RemoteConfigRepository,
 ) : ViewModel() {
     private val _start = MutableStateFlow(false)
     val start = _start.asStateFlow()
 
-    private val _minVersion = MutableStateFlow("")
-    val minVersion = _minVersion.asStateFlow()
-
     init {
         viewModelScope.launch {
-            _start.value = dataSource.startRemoteConfig()
-            if (_start.value) {
-                _minVersion.emit(dataSource.fetchFromRemoteConfig(RemoteConfigKey.MIN_VERSION))
-            }
+            _start.value = remoteConfigRepository.startRemoteConfig()
         }
     }
-}
+}

data-remote/src/main/kotlin/com/bff/wespot/data/remote/extensions/TaskExtensions.kt

@@ -0,0 +1,23 @@
+package com.bff.wespot.data.remote.extensions
+
+import com.google.android.gms.tasks.Task
+import kotlinx.coroutines.ExperimentalCoroutinesApi
+import kotlinx.coroutines.suspendCancellableCoroutine
+import timber.log.Timber
+import kotlin.coroutines.resumeWithException
+
+@OptIn(ExperimentalCoroutinesApi::class)
+suspend fun <T> Task<T>.await(): T {
+    return suspendCancellableCoroutine { cont ->
+        addOnCompleteListener {
+            val exception = it.exception
+            if (exception != null) {
+                cont.resumeWithException(exception)
+                Timber.e(exception)
+            } else {
+                cont.resume(it.result, null)
+                Timber.d(it.result.toString())
+            }
+        }
+    }
+}

data-remote/src/main/kotlin/com/bff/wespot/data/remote/source/firebase/messaging/MessagingDataSource.kt

@@ -2,4 +2,6 @@ package com.bff.wespot.data.remote.source.firebase.messaging
 
 interface MessagingDataSource {
     suspend fun getFcmToken(): String
+
+    suspend fun removeFcmToken()
 }

data-remote/src/main/kotlin/com/bff/wespot/data/remote/source/firebase/messaging/MessagingDataSourceImpl.kt

@@ -1,20 +1,19 @@
 package com.bff.wespot.data.remote.source.firebase.messaging
 
+import com.bff.wespot.data.remote.extensions.await
 import com.google.firebase.messaging.FirebaseMessaging
-import kotlinx.coroutines.suspendCancellableCoroutine
-import timber.log.Timber
 import javax.inject.Inject
 
 class MessagingDataSourceImpl @Inject constructor(
     private val messaging: FirebaseMessaging,
 ) : MessagingDataSource {
     override suspend fun getFcmToken(): String {
-        return suspendCancellableCoroutine { continuation ->
-            messaging.token.addOnCompleteListener {
-                continuation.resumeWith(Result.success(it.result))
-            }.addOnFailureListener {
-                Timber.e("Update FcmToken Failed Exception : ", it)
-            }
-        }
+        messaging.isAutoInitEnabled = true
+        return messaging.token.await()
+    }
+
+    override suspend fun removeFcmToken() {
+        messaging.isAutoInitEnabled = false
+        messaging.deleteToken().await()
     }
 }

data/src/main/kotlin/com/bff/wespot/data/repository/firebase/messaging/MessagingRepositoryImpl.kt

@@ -8,4 +8,6 @@ class MessagingRepositoryImpl @Inject constructor(
     private val messagingDataSource: MessagingDataSource,
 ): MessagingRepository {
     override suspend fun getFcmToken(): String = messagingDataSource.getFcmToken()
+
+    override suspend fun removeFcmToken() = messagingDataSource.removeFcmToken()
 }

domain/src/main/kotlin/com/bff/wespot/domain/repository/firebase/messaging/MessagingRepository.kt

@@ -2,4 +2,6 @@ package com.bff.wespot.domain.repository.firebase.messaging
 
 interface MessagingRepository {
     suspend fun getFcmToken(): String
+
+    suspend fun removeFcmToken()
 }

feature/entire/src/main/java/com/bff/wespot/entire/viewmodel/EntireViewModel.kt

@@ -7,6 +7,7 @@ import com.bff.wespot.domain.repository.BasePagingRepository
 import com.bff.wespot.domain.repository.DataStoreRepository
 import com.bff.wespot.domain.repository.auth.AuthRepository
 import com.bff.wespot.domain.repository.firebase.config.RemoteConfigRepository
+import com.bff.wespot.domain.repository.firebase.messaging.MessagingRepository
 import com.bff.wespot.domain.repository.message.MessageStorageRepository
 import com.bff.wespot.domain.repository.user.ProfileRepository
 import com.bff.wespot.domain.util.RemoteConfigKey
@@ -22,6 +23,7 @@ import dagger.hilt.android.lifecycle.HiltViewModel
 import kotlinx.coroutines.flow.catch
 import kotlinx.coroutines.flow.distinctUntilChanged
 import kotlinx.coroutines.launch
+import kotlinx.coroutines.supervisorScope
 import org.orbitmvi.orbit.ContainerHost
 import org.orbitmvi.orbit.syntax.simple.intent
 import org.orbitmvi.orbit.syntax.simple.postSideEffect
@@ -35,6 +37,7 @@ class EntireViewModel @Inject constructor(
     private val profileRepository: ProfileRepository,
     private val authRepository: AuthRepository,
     private val remoteConfigRepository: RemoteConfigRepository,
+    private val messagingRepository: MessagingRepository,
     private val messageStorageRepository: MessageStorageRepository,
     private val dataStoreRepository: DataStoreRepository,
     private val messageBlockedRepository: BasePagingRepository<BlockedMessage, Paging<BlockedMessage>>,
@@ -124,9 +127,12 @@ class EntireViewModel @Inject constructor(
     }
 
     private fun clearCachedData() {
-        viewModelScope.launch {
-            launch { dataStoreRepository.clear() }
-            launch { profileRepository.clearProfile() }
+        viewModelScope.launch(coroutineDispatcher) {
+            supervisorScope {
+                launch { dataStoreRepository.clear() }
+                launch { profileRepository.clearProfile() }
+                launch { messagingRepository.removeFcmToken() }
+            }
         }
     }