🔀 #46 from boostcampwm-2022/feat/editGroup

그룹 수정 페이지 일부 구현, 홍보 글 작성 로직 추가

Author: soopeach

data/src/main/java/com/whyranoid/data/Post/PostDataSource.kt

@@ -0,0 +1,67 @@
+package com.whyranoid.data.Post
+
+import com.google.firebase.firestore.FirebaseFirestore
+import com.whyranoid.data.constant.CollectionId
+import com.whyranoid.data.model.GroupInfoResponse
+import com.whyranoid.data.model.UserResponse
+import com.whyranoid.data.model.toGroupInfo
+import com.whyranoid.data.model.toUser
+import com.whyranoid.domain.model.RecruitPost
+import com.whyranoid.domain.model.toRule
+import kotlinx.coroutines.suspendCancellableCoroutine
+import kotlinx.coroutines.tasks.await
+import java.util.*
+import javax.inject.Inject
+import kotlin.coroutines.resume
+
+class PostDataSource @Inject constructor(
+    private val db: FirebaseFirestore
+) {
+
+    suspend fun createRecruitPost(
+        authorUid: String,
+        updatedAt: Long,
+        groupUid: String
+    ): Boolean {
+        val postId = UUID.randomUUID().toString()
+
+        val author = db.collection(CollectionId.USERS_COLLECTION)
+            .document(authorUid)
+            .get()
+            .await()
+            .toObject(UserResponse::class.java)
+            ?.toUser()
+
+        author?.let {
+            val groupInfo = db.collection(CollectionId.GROUPS_COLLECTION)
+                .document(groupUid)
+                .get()
+                .await()
+                .toObject(GroupInfoResponse::class.java)
+
+            groupInfo?.let {
+                return suspendCancellableCoroutine { cancellableContinuation ->
+
+                    db.collection(CollectionId.POST_COLLECTION)
+                        .document(postId)
+                        .set(
+                            RecruitPost(
+                                postId = postId,
+                                author = author,
+                                updatedAt = updatedAt,
+                                groupInfo = groupInfo.toGroupInfo(
+                                    leader = author,
+                                    rules = groupInfo.rules.map { it.toRule() }
+                                )
+                            )
+                        ).addOnSuccessListener {
+                            cancellableContinuation.resume(true)
+                        }.addOnFailureListener {
+                            cancellableContinuation.resume(false)
+                        }
+                }
+            }
+        }
+        return false
+    }
+}

data/src/main/java/com/whyranoid/data/Post/PostRepositoryImpl.kt

@@ -0,0 +1,43 @@
+package com.whyranoid.data.Post
+
+import com.whyranoid.domain.model.Post
+import com.whyranoid.domain.model.RunningHistory
+import com.whyranoid.domain.model.User
+import com.whyranoid.domain.repository.PostRepository
+import kotlinx.coroutines.flow.Flow
+import javax.inject.Inject
+
+class PostRepositoryImpl @Inject constructor(
+    private val postDataSource: PostDataSource
+) : PostRepository {
+
+    // TODO : 페이징처리하기
+    override fun getPagingPosts(): Flow<List<Post>> {
+        TODO("Not yet implemented")
+    }
+
+    override suspend fun createPost(
+        user: User,
+        postContent: String,
+        runningHistory: RunningHistory,
+        updatedAt: Long
+    ): Boolean {
+        TODO("Not yet implemented")
+    }
+
+    override suspend fun createRecruitPost(
+        authorUid: String,
+        updatedAt: Long,
+        groupUid: String
+    ): Boolean {
+        return postDataSource.createRecruitPost(authorUid, updatedAt, groupUid)
+    }
+
+    override suspend fun deletePost(postId: String): Boolean {
+        TODO("Not yet implemented")
+    }
+
+    override suspend fun updatePost(postId: String, postContent: String, updatedAt: Long): Boolean {
+        TODO("Not yet implemented")
+    }
+}

data/src/main/java/com/whyranoid/data/constant/CollectionId.kt

@@ -8,4 +8,5 @@ object CollectionId {
     const val GROUP_NOTIFICATIONS_COLLECTION = "GroupNotifications"
     const val START_NOTIFICATION = "start"
     const val FINISH_NOTIFICATION = "finish"
+    const val POST_COLLECTION = "Posts"
 }

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

@@ -0,0 +1,16 @@
+package com.whyranoid.data.di
+
+import com.whyranoid.data.Post.PostRepositoryImpl
+import com.whyranoid.domain.repository.PostRepository
+import dagger.Binds
+import dagger.Module
+import dagger.hilt.InstallIn
+import dagger.hilt.components.SingletonComponent
+
+@Module
+@InstallIn(SingletonComponent::class)
+abstract class PostModule {
+
+    @Binds
+    abstract fun bindPostRepository(postRepositoryImpl: PostRepositoryImpl): PostRepository
+}

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

@@ -10,7 +10,15 @@ import com.whyranoid.data.constant.FieldId.GROUP_NAME
 import com.whyranoid.data.constant.FieldId.JOINED_GROUP_LIST
 import com.whyranoid.data.constant.FieldId.RULES
 import com.whyranoid.data.model.GroupInfoResponse
+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.Rule
+import com.whyranoid.domain.model.toRule
+import kotlinx.coroutines.channels.awaitClose
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.callbackFlow
 import kotlinx.coroutines.suspendCancellableCoroutine
 import java.util.UUID
 import javax.inject.Inject
@@ -116,4 +124,32 @@ class GroupDataSource @Inject constructor(
                 }
         }
     }
+
+    fun getGroupInfoFlow(uid: String, groupId: String): Flow<GroupInfo> = callbackFlow {
+        db.collection(GROUPS_COLLECTION)
+            .document(groupId)
+            .addSnapshotListener { documentSnapshot, _ ->
+                val groupInfoResponse = documentSnapshot?.toObject(GroupInfoResponse::class.java)
+
+                groupInfoResponse?.let {
+                    db.collection(USERS_COLLECTION)
+                        .document(uid)
+                        .addSnapshotListener { documentSnapshot, _ ->
+                            val userResponse = documentSnapshot?.toObject(UserResponse::class.java)
+
+                            userResponse?.let {
+                                trySend(
+                                    groupInfoResponse.toGroupInfo(
+                                        leader = userResponse.toUser(),
+                                        rules = groupInfoResponse.rules.map {
+                                            it.toRule()
+                                        }
+                                    )
+                                )
+                            }
+                        }
+                }
+            }
+        awaitClose()
+    }
 }

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

@@ -38,6 +38,10 @@ class GroupRepositoryImpl @Inject constructor(
         return groupDataSource.joinGroup(uid, groupId)
     }
 
+    override fun getGroupInfoFlow(uid: String, groupId: String): Flow<GroupInfo> {
+        return groupDataSource.getGroupInfoFlow(uid, groupId)
+    }
+
     override fun getGroupNotifications(groupId: String): Flow<List<GroupNotification>> {
         return groupNotificationDataSource.getGroupNotifications(groupId)
     }
@@ -46,7 +50,12 @@ class GroupRepositoryImpl @Inject constructor(
         groupNotificationDataSource.notifyRunningStart(uid, groupIdList)
     }
 
-    override suspend fun createGroup(groupName: String, introduce: String, rules: List<String>, uid: String): Boolean {
+    override suspend fun createGroup(
+        groupName: String,
+        introduce: String,
+        rules: List<String>,
+        uid: String
+    ): Boolean {
         return groupDataSource.createGroup(groupName, introduce, rules, uid)
     }
 }

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

@@ -0,0 +1,14 @@
+package com.whyranoid.data.model
+
+sealed interface PostResponse {
+    val postId: String
+    val author: String
+    val updatedAt: Long
+}
+
+data class RecruitPostResponse(
+    override val postId: String = "",
+    override val author: String = "",
+    override val updatedAt: Long = 0L,
+    val groupUid: String = ""
+) : PostResponse

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

@@ -1,7 +1,5 @@
 package com.whyranoid.data.model
 
-import com.whyranoid.domain.model.DayOfWeek
-import com.whyranoid.domain.model.Rule
 import com.whyranoid.domain.model.User
 
 data class UserResponse(
@@ -17,12 +15,3 @@ fun UserResponse.toUser() =
         name = this.name,
         profileUrl = this.profileUrl
     )
-
-fun String.toRule(): Rule {
-    val ruleString = this.split("-")
-    return Rule(
-        dayOfWeek = DayOfWeek.values().find { it.dayResId == ruleString[0] } ?: DayOfWeek.SUN,
-        hour = ruleString[1].toInt(),
-        minute = ruleString[2].toInt()
-    )
-}

data/src/main/java/com/whyranoid/data/user/UserDataSource.kt

@@ -9,9 +9,9 @@ import com.whyranoid.data.constant.Exceptions.NO_USER_EXCEPTION
 import com.whyranoid.data.model.GroupInfoResponse
 import com.whyranoid.data.model.UserResponse
 import com.whyranoid.data.model.toGroupInfo
-import com.whyranoid.data.model.toRule
 import com.whyranoid.data.model.toUser
 import com.whyranoid.domain.model.GroupInfo
+import com.whyranoid.domain.model.toRule
 import kotlinx.coroutines.channels.awaitClose
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.callbackFlow

domain/src/main/java/com/whyranoid/domain/model/Rule.kt

@@ -10,6 +10,15 @@ data class Rule(
     }
 }
 
+fun String.toRule(): Rule {
+    val ruleString = this.split("-")
+    return Rule(
+        dayOfWeek = DayOfWeek.values().find { it.dayResId == ruleString[0] } ?: DayOfWeek.SUN,
+        hour = ruleString[1].toInt(),
+        minute = ruleString[2].toInt()
+    )
+}
+
 enum class DayOfWeek(val dayResId: String) {
     MON("월"),
     TUE("화"),