🔀 #62 from boostcampwm-2022/feat/running_tab

러닝 히스토리 서버 업로드 구현

Author: bngsh

data/src/main/java/com/whyranoid/data/account/RunningHistoryRemoteDataSource.kt

@@ -0,0 +1,8 @@
+package com.whyranoid.data.account
+
+import com.whyranoid.domain.model.RunningHistory
+
+interface RunningHistoryRemoteDataSource {
+
+    suspend fun uploadRunningHistory(runningHistory: RunningHistory): Result<Boolean>
+}

data/src/main/java/com/whyranoid/data/account/RunningHistoryRemoteDataSourceImpl.kt

@@ -0,0 +1,35 @@
+package com.whyranoid.data.account
+
+import com.google.firebase.firestore.FirebaseFirestore
+import com.whyranoid.data.constant.CollectionId
+import com.whyranoid.data.model.toRunningHistoryResponse
+import com.whyranoid.domain.model.RunningHistory
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.tasks.await
+import kotlinx.coroutines.withContext
+import javax.inject.Inject
+
+class RunningHistoryRemoteDataSourceImpl @Inject constructor(private val firebaseDB: FirebaseFirestore) :
+    RunningHistoryRemoteDataSource {
+    override suspend fun uploadRunningHistory(runningHistory: RunningHistory): Result<Boolean> {
+        val runningHistoryResponse = runningHistory.toRunningHistoryResponse()
+        var uploadSuccess = false
+
+        return runCatching {
+            withContext(Dispatchers.IO) {
+                val task = firebaseDB.collection(CollectionId.RUNNING_HISTORY_COLLECTION)
+                    .document(runningHistoryResponse.historyId)
+                    .set(runningHistoryResponse)
+                    .addOnSuccessListener {
+                        uploadSuccess = true
+                    }
+                    .addOnFailureListener { exception ->
+                        throw exception
+                    }
+
+                task.await()
+            }
+            uploadSuccess
+        }
+    }
+}

data/src/main/java/com/whyranoid/data/account/RunningHistoryRepositoryImpl.kt

@@ -7,7 +7,8 @@ import kotlinx.coroutines.flow.Flow
 import javax.inject.Inject
 
 class RunningHistoryRepositoryImpl @Inject constructor(
-    private val runningHistoryLocalDataSource: RunningHistoryLocalDataSource
+    private val runningHistoryLocalDataSource: RunningHistoryLocalDataSource,
+    private val runningHistoryRemoteDataSource: RunningHistoryRemoteDataSource
 ) : RunningHistoryRepository {
     override fun getRunningHistory(): Flow<Result<List<RunningHistory>>> {
         return runningHistoryLocalDataSource.getRunningHistory()
@@ -36,4 +37,8 @@ class RunningHistoryRepositoryImpl @Inject constructor(
             )
         )
     }
+
+    override suspend fun uploadRunningHistory(runningHistory: RunningHistory): Result<Boolean> {
+        return runningHistoryRemoteDataSource.uploadRunningHistory(runningHistory)
+    }
 }

data/src/main/java/com/whyranoid/data/di/AccountModule.kt

@@ -5,6 +5,8 @@ import com.whyranoid.data.account.AccountDataSourceImpl
 import com.whyranoid.data.account.AccountRepositoryImpl
 import com.whyranoid.data.account.RunningHistoryLocalDataSource
 import com.whyranoid.data.account.RunningHistoryLocalDataSourceImpl
+import com.whyranoid.data.account.RunningHistoryRemoteDataSource
+import com.whyranoid.data.account.RunningHistoryRemoteDataSourceImpl
 import com.whyranoid.data.account.RunningHistoryRepositoryImpl
 import com.whyranoid.domain.repository.AccountRepository
 import com.whyranoid.domain.repository.RunningHistoryRepository
@@ -28,4 +30,7 @@ abstract class AccountModule {
 
     @Binds
     abstract fun provideRunningHistoryDataSource(runningHistoryLocalDataSourceImpl: RunningHistoryLocalDataSourceImpl): RunningHistoryLocalDataSource
+
+    @Binds
+    abstract fun bindRunningHistoryRemoteDataSource(runningHistoryRemoteDataSourceImpl: RunningHistoryRemoteDataSourceImpl): RunningHistoryRemoteDataSource
 }

data/src/main/java/com/whyranoid/data/model/RunningHistoryResponse.kt

@@ -0,0 +1,22 @@
+package com.whyranoid.data.model
+
+import com.whyranoid.domain.model.RunningHistory
+
+data class RunningHistoryResponse(
+    val historyId: String = "",
+    val startedAt: Long = 0L,
+    val finishedAt: Long = 0L,
+    val totalRunningTime: Int = 0,
+    val pace: Double = 0.0,
+    val totalDistance: Double = 0.0
+)
+
+fun RunningHistory.toRunningHistoryResponse() =
+    RunningHistoryResponse(
+        historyId = historyId,
+        startedAt = startedAt,
+        finishedAt = finishedAt,
+        totalRunningTime = totalRunningTime,
+        pace = pace,
+        totalDistance = totalDistance
+    )

domain/src/main/java/com/whyranoid/domain/repository/RunningHistoryRepository.kt

@@ -20,4 +20,6 @@ interface RunningHistoryRepository {
         pace: Double,
         totalDistance: Double
     ): Result<RunningHistory>
+
+    suspend fun uploadRunningHistory(runningHistory: RunningHistory): Result<Boolean>
 }

domain/src/main/java/com/whyranoid/domain/usecase/FinishRunningUseCase.kt

@@ -4,19 +4,27 @@ import com.whyranoid.domain.model.RunningHistory
 import com.whyranoid.domain.repository.AccountRepository
 import com.whyranoid.domain.repository.GroupRepository
 import com.whyranoid.domain.repository.RunnerRepository
+import com.whyranoid.domain.repository.RunningHistoryRepository
 import javax.inject.Inject
 
 class FinishRunningUseCase @Inject constructor(
     private val runnerRepository: RunnerRepository,
     private val accountRepository: AccountRepository,
-    private val groupRepository: GroupRepository
+    private val groupRepository: GroupRepository,
+    private val runningHistoryRepository: RunningHistoryRepository
 ) {
     suspend operator fun invoke(runningHistory: RunningHistory? = null): Boolean {
         val uid = accountRepository.getUid()
 
         runnerRepository.finishRunning(uid)
 
         if (runningHistory != null) {
+            val uploadResult = runningHistoryRepository.uploadRunningHistory(runningHistory)
+
+            if (uploadResult.isFailure) {
+                return false
+            }
+
             groupRepository.getMyGroupList(uid).onSuccess { groupInfos ->
                 groupRepository.notifyRunningFinish(
                     uid = uid,