Refactor: syncError 노출 및 ObserveRoutineSyncErrorUseCase 추가

Author: wjdrjs00

data/src/main/java/com/threegap/bitnagil/data/routine/repositoryImpl/RoutineRepositoryImpl.kt

@@ -19,6 +19,8 @@ import kotlinx.coroutines.SupervisorJob
 import kotlinx.coroutines.channels.BufferOverflow
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.MutableSharedFlow
+import kotlinx.coroutines.flow.SharedFlow
+import kotlinx.coroutines.flow.asSharedFlow
 import kotlinx.coroutines.flow.debounce
 import kotlinx.coroutines.flow.emitAll
 import kotlinx.coroutines.flow.filterNotNull
@@ -41,6 +43,8 @@ class RoutineRepositoryImpl @Inject constructor(
     private val mutex = Mutex()
     private val pendingChangesByDate = mutableMapOf<String, MutableMap<String, RoutineCompletionInfo>>()
     private val originalStatesByDate = mutableMapOf<String, MutableMap<String, RoutineCompletionInfo>>()
+    private val _syncError = MutableSharedFlow<Unit>(extraBufferCapacity = 1, onBufferOverflow = BufferOverflow.DROP_OLDEST)
+    override val syncError: SharedFlow<Unit> = _syncError.asSharedFlow()
     private val syncTrigger = MutableSharedFlow<Unit>(
         extraBufferCapacity = 1,
         onBufferOverflow = BufferOverflow.DROP_OLDEST,
@@ -105,6 +109,7 @@ class RoutineRepositoryImpl @Inject constructor(
             val syncRequest = RoutineCompletionInfos(routineCompletionInfos = actualChanges.values.toList())
             routineRemoteDataSource.syncRoutineCompletion(syncRequest.toDto())
                 .onFailure {
+                    _syncError.emit(Unit)
                     val range = routineLocalDataSource.lastFetchRange ?: return@onFailure
                     fetchAndSave(range.first, range.second)
                 }

domain/src/main/java/com/threegap/bitnagil/domain/routine/repository/RoutineRepository.kt

@@ -6,8 +6,10 @@ import com.threegap.bitnagil.domain.routine.model.RoutineEditInfo
 import com.threegap.bitnagil.domain.routine.model.RoutineRegisterInfo
 import com.threegap.bitnagil.domain.routine.model.RoutineSchedule
 import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.SharedFlow
 
 interface RoutineRepository {
+    val syncError: SharedFlow<Unit>
     fun observeWeeklyRoutines(startDate: String, endDate: String): Flow<RoutineSchedule>
     suspend fun applyRoutineToggle(dateKey: String, routineId: String, completionInfo: RoutineCompletionInfo)
     suspend fun getRoutine(routineId: String): Result<Routine>

domain/src/main/java/com/threegap/bitnagil/domain/routine/usecase/ObserveRoutineSyncErrorUseCase.kt

@@ -0,0 +1,11 @@
+package com.threegap.bitnagil.domain.routine.usecase
+
+import com.threegap.bitnagil.domain.routine.repository.RoutineRepository
+import kotlinx.coroutines.flow.Flow
+import javax.inject.Inject
+
+class ObserveRoutineSyncErrorUseCase @Inject constructor(
+    private val routineRepository: RoutineRepository,
+) {
+    operator fun invoke(): Flow<Unit> = routineRepository.syncError
+}