[CHORE/#396] groupBy 확장함수 없이 구현

Author: leeeyubin

feature/mypage/src/main/java/com/terning/feature/mypage/mypage/MyPageViewModel.kt

@@ -3,14 +3,12 @@ package com.terning.feature.mypage.mypage
 import androidx.lifecycle.ViewModel
 import androidx.lifecycle.viewModelScope
 import com.kakao.sdk.user.UserApiClient
-import com.terning.core.designsystem.extension.groupBy
 import com.terning.core.designsystem.state.UiState
 import com.terning.core.designsystem.type.AlarmType.DISABLED
 import com.terning.core.designsystem.type.AlarmType.ENABLED
 import com.terning.domain.mypage.entity.AlarmStatus
 import com.terning.domain.mypage.repository.MyPageRepository
 import com.terning.domain.user.repository.UserRepository
-import com.terning.feature.mypage.mypage.model.AlarmInfo
 import dagger.hilt.android.lifecycle.HiltViewModel
 import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.FlowPreview
@@ -21,7 +19,6 @@ import kotlinx.coroutines.flow.StateFlow
 import kotlinx.coroutines.flow.asSharedFlow
 import kotlinx.coroutines.flow.asStateFlow
 import kotlinx.coroutines.flow.debounce
-import kotlinx.coroutines.flow.flatMapMerge
 import kotlinx.coroutines.flow.update
 import kotlinx.coroutines.launch
 import javax.inject.Inject
@@ -40,22 +37,25 @@ class MyPageViewModel @Inject constructor(
     private val _sideEffects = MutableSharedFlow<MyPageSideEffect>()
     val sideEffects: SharedFlow<MyPageSideEffect> get() = _sideEffects.asSharedFlow()
 
-    private val debounceFlow = MutableSharedFlow<AlarmInfo>()
+    private val debounceFlow = MutableSharedFlow<Boolean>()
 
-    private val lastSuccessfulAlarmStatus = mutableMapOf<String, Boolean>()
+    private var lastSuccessfulAlarmStatus: Boolean? = null
 
     init {
+        handleDebouncedAlarm()
+    }
+
+    private fun handleDebouncedAlarm() {
         viewModelScope.launch {
             debounceFlow
-                .groupBy { it.id }
-                .flatMapMerge { (_, flow) -> flow.debounce(DEBOUNCE_DURATION) }
-                .collect { info ->
+                .debounce(DEBOUNCE_DURATION)
+                .collect { isEnabled ->
                     myPageRepository.updateAlarmState(
-                        AlarmStatus(if (info.isAlarmAvailable) ENABLED.value else DISABLED.value)
+                        AlarmStatus(if (isEnabled) ENABLED.value else DISABLED.value)
                     ).onSuccess {
-                        lastSuccessfulAlarmStatus[info.id] = info.isAlarmAvailable
+                        lastSuccessfulAlarmStatus = isEnabled
                     }.onFailure {
-                        val previous = lastSuccessfulAlarmStatus[info.id] ?: !info.isAlarmAvailable
+                        val previous = lastSuccessfulAlarmStatus ?: !isEnabled
                         _state.update { currentState ->
                             currentState.copy(alarmStatus = if (previous) ENABLED.value else DISABLED.value)
                         }
@@ -180,7 +180,7 @@ class MyPageViewModel @Inject constructor(
         userRepository.setAlarmAvailable(availability)
 
         viewModelScope.launch {
-            debounceFlow.emit(AlarmInfo(id = DEBOUNCE_KEY, isAlarmAvailable = availability))
+            debounceFlow.emit(availability)
         }
     }
 
@@ -196,6 +196,5 @@ class MyPageViewModel @Inject constructor(
 
     companion object {
         private const val DEBOUNCE_DURATION = 300L
-        private const val DEBOUNCE_KEY = "NOTIFICATION"
     }
 }