✨ FinishRunningUseCase 구현

bngsh · yonghanJu · bngsh · commit 6fb7d3028388 · 2022-12-01T14:46:24.000+09:00
Co-authored-by: yonghanJu &lt;ju990828@naver.com&gt;
diff --git a/data/src/main/java/com/whyranoid/data/group/GroupRepositoryImpl.kt b/data/src/main/java/com/whyranoid/data/group/GroupRepositoryImpl.kt
@@ -5,6 +5,7 @@ import com.whyranoid.data.user.UserDataSource
 import com.whyranoid.domain.model.GroupInfo
 import com.whyranoid.domain.model.GroupNotification
 import com.whyranoid.domain.model.Rule
+import com.whyranoid.domain.model.RunningHistory
 import com.whyranoid.domain.repository.GroupRepository
 import kotlinx.coroutines.flow.Flow
 import javax.inject.Inject
@@ -50,6 +51,14 @@ class GroupRepositoryImpl @Inject constructor(
         groupNotificationDataSource.notifyRunningStart(uid, groupIdList)
     }
 
+    override suspend fun notifyRunningFinish(
+        uid: String,
+        runningHistory: RunningHistory,
+        groupIdList: List<String>
+    ) {
+        groupNotificationDataSource.notifyRunningFinish(uid, runningHistory, groupIdList)
+    }
+
     override suspend fun createGroup(
         groupName: String,
         introduce: String,
diff --git a/data/src/main/java/com/whyranoid/data/groupnotification/GroupNotificationDataSource.kt b/data/src/main/java/com/whyranoid/data/groupnotification/GroupNotificationDataSource.kt
@@ -73,6 +73,28 @@ class GroupNotificationDataSource @Inject constructor(
         }
     }
 
+    suspend fun notifyRunningFinish(
+        uid: String,
+        runningHistory: RunningHistory,
+        groupIdList: List<String>
+    ) {
+        withContext(Dispatchers.IO) {
+            groupIdList.forEach { groupId ->
+                db.collection(GROUP_NOTIFICATIONS_COLLECTION)
+                    .document(groupId)
+                    .collection(FINISH_NOTIFICATION)
+                    .document(UUID.randomUUID().toString())
+                    .set(
+                        FinishNotificationResponse(
+                            type = "finish",
+                            uid = uid,
+                            historyId = runningHistory.historyId
+                        )
+                    )
+            }
+        }
+    }
+
     private fun getGroupFinishNotifications(groupId: String): Flow<List<GroupNotification>> =
         callbackFlow {
             db.collection(GROUP_NOTIFICATIONS_COLLECTION)
diff --git a/data/src/main/java/com/whyranoid/data/running/RunnerDataSourceImpl.kt b/data/src/main/java/com/whyranoid/data/running/RunnerDataSourceImpl.kt
@@ -2,6 +2,7 @@ package com.whyranoid.data.running
 
 import com.google.firebase.firestore.FieldValue
 import com.google.firebase.firestore.FirebaseFirestore
+import com.whyranoid.data.constant.CollectionId
 import kotlinx.coroutines.channels.awaitClose
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.callbackFlow
@@ -11,7 +12,7 @@ import kotlin.coroutines.suspendCoroutine
 class RunnerDataSourceImpl(private val db: FirebaseFirestore) : RunnerDataSource {
 
     override fun getCurrentRunnerCount(): Flow<Int> = callbackFlow {
-        db.collection("Runners")
+        db.collection(CollectionId.RUNNERS_COLLECTION)
             .document("runnersId")
             .addSnapshotListener { snapshot, _ ->
                 snapshot?.let {
@@ -26,7 +27,7 @@ class RunnerDataSourceImpl(private val db: FirebaseFirestore) : RunnerDataSource
     override suspend fun startRunning(uid: String): Boolean {
         if (uid.isBlank()) return false
         return suspendCoroutine { continuation ->
-            db.collection("Runners")
+            db.collection(CollectionId.RUNNERS_COLLECTION)
                 .document("runnersId")
                 .update(uid, uid)
                 .addOnSuccessListener {
@@ -39,9 +40,9 @@ class RunnerDataSourceImpl(private val db: FirebaseFirestore) : RunnerDataSource
     }
 
     override suspend fun finishRunning(uid: String): Boolean {
-        // TODO 구현
+        if (uid.isBlank()) return false
         return suspendCoroutine { continuation ->
-            db.collection("Runners")
+            db.collection(CollectionId.RUNNERS_COLLECTION)
                 .document("runnersId")
                 .update(uid, FieldValue.delete())
                 .addOnSuccessListener {
diff --git a/data/src/main/java/com/whyranoid/data/running/RunnerRepositoryImpl.kt b/data/src/main/java/com/whyranoid/data/running/RunnerRepositoryImpl.kt
@@ -13,6 +13,6 @@ class RunnerRepositoryImpl(private val runnerDataSource: RunnerDataSource) : Run
     }
 
     override suspend fun finishRunning(uid: String): Boolean {
-        return true
+        return runnerDataSource.finishRunning(uid)
     }
 }
diff --git a/domain/src/main/java/com/whyranoid/domain/repository/GroupRepository.kt b/domain/src/main/java/com/whyranoid/domain/repository/GroupRepository.kt
@@ -3,6 +3,7 @@ package com.whyranoid.domain.repository
 import com.whyranoid.domain.model.GroupInfo
 import com.whyranoid.domain.model.GroupNotification
 import com.whyranoid.domain.model.Rule
+import com.whyranoid.domain.model.RunningHistory
 import kotlinx.coroutines.flow.Flow
 
 interface GroupRepository {
@@ -33,6 +34,12 @@ interface GroupRepository {
 
     suspend fun notifyRunningStart(uid: String, groupIdList: List<String>)
 
+    suspend fun notifyRunningFinish(
+        uid: String,
+        runningHistory: RunningHistory,
+        groupIdList: List<String>
+    )
+
     // 그룹 생성하기
     suspend fun createGroup(
         groupName: String,
diff --git a/domain/src/main/java/com/whyranoid/domain/usecase/FinishRunningUseCase.kt b/domain/src/main/java/com/whyranoid/domain/usecase/FinishRunningUseCase.kt
@@ -1,15 +1,30 @@
 package com.whyranoid.domain.usecase
 
+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 javax.inject.Inject
 
 class FinishRunningUseCase @Inject constructor(
     private val runnerRepository: RunnerRepository,
-    private val accountRepository: AccountRepository
+    private val accountRepository: AccountRepository,
+    private val groupRepository: GroupRepository
 ) {
-    suspend operator fun invoke(): Boolean {
-        runnerRepository.finishRunning(accountRepository.getUid())
+    suspend operator fun invoke(runningHistory: RunningHistory? = null): Boolean {
+        val uid = accountRepository.getUid()
+
+        runnerRepository.finishRunning(uid)
+
+        if (runningHistory != null) {
+            groupRepository.getMyGroupList(uid).onSuccess { groupInfos ->
+                groupRepository.notifyRunningFinish(
+                    uid = uid,
+                    runningHistory = runningHistory,
+                    groupIdList = groupInfos.map { it.groupId }
+                )
+            }
+        }
         return true
     }
 }
diff --git a/presentation/src/main/java/com/whyranoid/presentation/model/RunningHistoryUiModel.kt b/presentation/src/main/java/com/whyranoid/presentation/model/RunningHistoryUiModel.kt
@@ -24,3 +24,14 @@ fun RunningHistory.toRunningHistoryUiModel(): RunningHistoryUiModel {
         pace = pace
     )
 }
+
+fun RunningHistoryUiModel.toRunningHistory(): RunningHistory {
+    return RunningHistory(
+        historyId = historyId,
+        startedAt = startedAt,
+        finishedAt = finishedAt,
+        totalRunningTime = totalRunningTime,
+        pace = pace,
+        totalDistance = totalDistance
+    )
+}
diff --git a/presentation/src/main/java/com/whyranoid/presentation/running/RunningViewModel.kt b/presentation/src/main/java/com/whyranoid/presentation/running/RunningViewModel.kt
@@ -10,7 +10,9 @@ import androidx.work.NetworkType
 import androidx.work.OneTimeWorkRequestBuilder
 import androidx.work.WorkInfo
 import androidx.work.WorkManager
+import com.whyranoid.domain.usecase.FinishRunningUseCase
 import com.whyranoid.domain.usecase.StartRunningUseCase
+import com.whyranoid.presentation.model.toRunningHistory
 import dagger.hilt.android.lifecycle.HiltViewModel
 import dagger.hilt.android.qualifiers.ApplicationContext
 import kotlinx.coroutines.flow.MutableSharedFlow
@@ -24,6 +26,7 @@ import javax.inject.Inject
 class RunningViewModel @Inject constructor(
     @ApplicationContext context: Context,
     startRunningUseCase: StartRunningUseCase,
+    private val finishRunningUseCase: FinishRunningUseCase,
     private val runningDataManager: RunningDataManager
 ) : ViewModel() {
 
@@ -108,6 +111,9 @@ class RunningViewModel @Inject constructor(
 
     fun onFinishButtonClicked() {
         runningDataManager.finishRunning().onSuccess { runningFinishData ->
+            viewModelScope.launch {
+                finishRunningUseCase(runningFinishData.runningHistory.toRunningHistory())
+            }
             emitEvent(Event.FinishButtonClick(runningFinishData))
         }.onFailure {
             emitEvent(Event.RunningFinishFailure)
diff --git a/presentation/src/main/res/layout/item_running_history.xml b/presentation/src/main/res/layout/item_running_history.xml
@@ -141,6 +141,5 @@
             android:layout_marginTop="24dp"
             android:layout_marginEnd="50dp" />
 
-
     </androidx.constraintlayout.widget.ConstraintLayout>
 </layout>

Original file line number	Diff line number	Diff line change
`@@ -13,6 +13,6 @@ class RunnerRepositoryImpl(private val runnerDataSource: RunnerDataSource) : Run`
`13`	`13`	`}`
`14`	`14`
`15`	`15`	`override suspend fun finishRunning(uid: String): Boolean {`
`16`		`- return true`
	`16`	`+ return runnerDataSource.finishRunning(uid)`
`17`	`17`	`}`
`18`	`18`	`}`