Revert ":recycle: getGroupInfoFlow() 콜백 제거 리펙토링"

This reverts commit 0f7d3f81486d42917e11908137d9534effd751c9.

Author: yonghanJu

data/src/main/java/com/whyranoid/data/group/GroupDataSource.kt

@@ -14,7 +14,6 @@ import com.whyranoid.data.model.UserResponse
 import com.whyranoid.data.model.toGroupInfo
 import com.whyranoid.data.model.toUser
 import com.whyranoid.domain.model.GroupInfo
-import com.whyranoid.domain.model.MoGakRunException
 import com.whyranoid.domain.model.Rule
 import com.whyranoid.domain.model.toRule
 import kotlinx.coroutines.channels.awaitClose
@@ -127,44 +126,32 @@ class GroupDataSource @Inject constructor(
         }
     }
 
-    fun getGroupInfoFlow(uid: String, groupId: String): Flow<GroupInfo> {
-        return callbackFlow {
-            val groupInfoResponse = getGroupInfoResponse(groupId)
-            val userResponse = getUserInfoResponse(uid)
-            val groupInfo = groupInfoResponse.toGroupInfo(
-                leader = userResponse.toUser(),
-                rules = groupInfoResponse.rules.map { it.toRule() }
-            )
-            trySend(groupInfo)
-            awaitClose()
-        }
-    }
+    fun getGroupInfoFlow(uid: String, groupId: String): Flow<GroupInfo> = callbackFlow {
+        db.collection(GROUPS_COLLECTION)
+            .document(groupId)
+            .addSnapshotListener { documentSnapshot, _ ->
+                val groupInfoResponse = documentSnapshot?.toObject(GroupInfoResponse::class.java)
 
-    private suspend fun getGroupInfoResponse(groupId: String): GroupInfoResponse {
-        return suspendCancellableCoroutine { continuation ->
-            db.collection(GROUPS_COLLECTION)
-                .document(groupId)
-                .addSnapshotListener { documentSnapshot, _ ->
-                    continuation.resume(
-                        documentSnapshot?.toObject(GroupInfoResponse::class.java)
-                            ?: throw MoGakRunException.FileNotFoundedException
-
-                    )
-                }
-        }
-    }
+                groupInfoResponse?.let {
+                    db.collection(USERS_COLLECTION)
+                        .document(uid)
+                        .addSnapshotListener { documentSnapshot, _ ->
+                            val userResponse = documentSnapshot?.toObject(UserResponse::class.java)
 
-    private suspend fun getUserInfoResponse(uid: String): UserResponse {
-        return suspendCancellableCoroutine { continuation ->
-            db.collection(USERS_COLLECTION)
-                .document(uid)
-                .addSnapshotListener { documentSnapshot, _ ->
-                    continuation.resume(
-                        documentSnapshot?.toObject(UserResponse::class.java)
-                            ?: throw MoGakRunException.FileNotFoundedException
-                    )
+                            userResponse?.let {
+                                trySend(
+                                    groupInfoResponse.toGroupInfo(
+                                        leader = userResponse.toUser(),
+                                        rules = groupInfoResponse.rules.map {
+                                            it.toRule()
+                                        }
+                                    )
+                                )
+                            }
+                        }
                 }
-        }
+            }
+        awaitClose()
     }
 
     suspend fun isDuplicatedGroupName(groupName: String): Boolean {