🔀 #51 from boostcampwm-2022/feat/recruitPost

peter-j0y · web-flow · commit 40007b3cbcfe · 2022-11-30T10:18:51.000+09:00
홍보 글 작성 기능 구현, 홍보 글 불러오기 기능 구현
diff --git a/data/src/main/java/com/whyranoid/data/Post/PostDataSource.kt b/data/src/main/java/com/whyranoid/data/Post/PostDataSource.kt
@@ -3,13 +3,17 @@ 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.RecruitPostResponse
 import com.whyranoid.data.model.UserResponse
 import com.whyranoid.data.model.toGroupInfo
 import com.whyranoid.data.model.toUser
+import com.whyranoid.domain.model.Post
 import com.whyranoid.domain.model.RecruitPost
 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 kotlinx.coroutines.tasks.await
 import java.util.*
 import javax.inject.Inject
 import kotlin.coroutines.resume
@@ -18,50 +22,80 @@ class PostDataSource @Inject constructor(
     private val db: FirebaseFirestore
 ) {
 
+    //  TODO : 타입을 확인하고 캐스팅하는 부분 필요
+    fun getAllPostFlow(): Flow<List<Post>> =
+        callbackFlow {
+            db.collection(CollectionId.POST_COLLECTION)
+                .addSnapshotListener { snapshot, _ ->
+                    val recruitPostList = mutableListOf<Post>()
+                    snapshot?.forEach { docuemnt ->
+                        docuemnt.toObject(RecruitPostResponse::class.java).let { postResponse ->
+
+                            db.collection(CollectionId.USERS_COLLECTION)
+                                .document(postResponse.authorId)
+                                .get()
+                                .addOnSuccessListener { authorDocument ->
+                                    val authorResponse =
+                                        authorDocument?.toObject(UserResponse::class.java)
+
+                                    authorResponse?.let {
+                                        db.collection(CollectionId.GROUPS_COLLECTION)
+                                            .document(postResponse.groupId)
+                                            .get()
+                                            .addOnSuccessListener { groupDocument ->
+                                                val groupInfoResponse =
+                                                    groupDocument.toObject(GroupInfoResponse::class.java)
+
+                                                groupInfoResponse?.let { groupInfoResponse ->
+                                                    val author = authorResponse.toUser()
+                                                    recruitPostList.add(
+                                                        RecruitPost(
+                                                            postId = postResponse.postId,
+                                                            author = author,
+                                                            updatedAt = postResponse.updatedAt,
+                                                            groupInfo = groupInfoResponse
+                                                                .toGroupInfo(
+                                                                    author,
+                                                                    rules = groupInfoResponse.rules.map {
+                                                                        it.toRule()
+                                                                    }
+                                                                )
+                                                        )
+                                                    )
+                                                    trySend(recruitPostList)
+                                                }
+                                            }
+                                    }
+                                }
+                        }
+                    }
+                }
+
+            awaitClose()
+        }
+
     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)
+        return suspendCancellableCoroutine { cancellableContinuation ->
 
-            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)
-                        }
+            db.collection(CollectionId.POST_COLLECTION)
+                .document(postId)
+                .set(
+                    RecruitPostResponse(
+                        postId = postId,
+                        authorId = authorUid,
+                        updatedAt = System.currentTimeMillis(),
+                        groupId = groupUid
+                    )
+                ).addOnSuccessListener {
+                    cancellableContinuation.resume(true)
+                }.addOnFailureListener {
+                    cancellableContinuation.resume(false)
                 }
-            }
         }
-        return false
     }
 }
diff --git a/data/src/main/java/com/whyranoid/data/Post/PostRepositoryImpl.kt b/data/src/main/java/com/whyranoid/data/Post/PostRepositoryImpl.kt
@@ -16,6 +16,10 @@ class PostRepositoryImpl @Inject constructor(
         TODO("Not yet implemented")
     }
 
+    override fun getAllPostFlow(): Flow<List<Post>> {
+        return postDataSource.getAllPostFlow()
+    }
+
     override suspend fun createPost(
         user: User,
         postContent: String,
@@ -27,10 +31,9 @@ class PostRepositoryImpl @Inject constructor(
 
     override suspend fun createRecruitPost(
         authorUid: String,
-        updatedAt: Long,
         groupUid: String
     ): Boolean {
-        return postDataSource.createRecruitPost(authorUid, updatedAt, groupUid)
+        return postDataSource.createRecruitPost(authorUid, groupUid)
     }
 
     override suspend fun deletePost(postId: String): Boolean {
diff --git a/data/src/main/java/com/whyranoid/data/model/PostResponse.kt b/data/src/main/java/com/whyranoid/data/model/PostResponse.kt
@@ -2,13 +2,13 @@ package com.whyranoid.data.model
 
 sealed interface PostResponse {
     val postId: String
-    val author: String
+    val authorId: String
     val updatedAt: Long
 }
 
 data class RecruitPostResponse(
+    override val authorId: String = "",
+    val groupId: String = "",
     override val postId: String = "",
-    override val author: String = "",
-    override val updatedAt: Long = 0L,
-    val groupUid: String = ""
+    override val updatedAt: Long = 0L
 ) : PostResponse
diff --git a/domain/src/main/java/com/whyranoid/domain/repository/PostRepository.kt b/domain/src/main/java/com/whyranoid/domain/repository/PostRepository.kt
@@ -11,6 +11,8 @@ interface PostRepository {
     // 글(홍보 / 인증) 페이징으로 가져오기 - 리모트
     fun getPagingPosts(): Flow<List<Post>>
 
+    fun getAllPostFlow(): Flow<List<Post>>
+
     // 글 작성하기 - 리모트
     suspend fun createPost(
         user: User,
@@ -21,7 +23,6 @@ interface PostRepository {
 
     suspend fun createRecruitPost(
         authorUid: String,
-        updatedAt: Long,
         groupUid: String
     ): Boolean
 
diff --git a/domain/src/main/java/com/whyranoid/domain/usecase/CreateRecruitPostUseCase.kt b/domain/src/main/java/com/whyranoid/domain/usecase/CreateRecruitPostUseCase.kt
@@ -0,0 +1,18 @@
+package com.whyranoid.domain.usecase
+
+import com.whyranoid.domain.repository.AccountRepository
+import com.whyranoid.domain.repository.PostRepository
+import javax.inject.Inject
+
+class CreateRecruitPostUseCase @Inject constructor(
+    private val postRepository: PostRepository,
+    private val accountRepository: AccountRepository
+) {
+    // TODO : accountRepository에서 User를 가져오도록 수정
+    suspend operator fun invoke(
+        authorUid: String,
+        groupUid: String
+    ): Boolean {
+        return postRepository.createRecruitPost(authorUid, groupUid)
+    }
+}
diff --git a/domain/src/main/java/com/whyranoid/domain/usecase/GetPostsUseCase.kt b/domain/src/main/java/com/whyranoid/domain/usecase/GetPostsUseCase.kt
@@ -0,0 +1,15 @@
+package com.whyranoid.domain.usecase
+
+import com.whyranoid.domain.model.Post
+import com.whyranoid.domain.repository.PostRepository
+import kotlinx.coroutines.flow.Flow
+import javax.inject.Inject
+
+class GetPostsUseCase @Inject constructor(
+    private val postRepository: PostRepository
+) {
+
+    operator fun invoke(): Flow<List<Post>> {
+        return postRepository.getAllPostFlow()
+    }
+}
diff --git a/presentation/src/main/java/com/whyranoid/presentation/community/CommunityItemFragment.kt b/presentation/src/main/java/com/whyranoid/presentation/community/CommunityItemFragment.kt
@@ -40,6 +40,7 @@ internal class CommunityItemFragment :
         when (category) {
             CommunityCategory.BOARD -> {
                 // TODO: Adapter 설정
+                setPostAdapter()
             }
             CommunityCategory.MY_GROUP -> {
                 setMyGroupAdapter()
@@ -68,6 +69,19 @@ internal class CommunityItemFragment :
         }
     }
 
+    private fun setPostAdapter() {
+        // TODO uid를 데이터 소스에서 가져오도록 수정
+        val postAdapter = PostAdapter("hsjeon")
+        binding.rvCommunity.adapter = postAdapter
+
+        viewLifecycleOwner.repeatWhenUiStarted {
+            viewModel.postList.collect { postList ->
+                removeShimmer()
+                postAdapter.submitList(postList)
+            }
+        }
+    }
+
     // TODO 카테고리 별 다른 아이템 처리
     private fun setMyGroupAdapter() {
         val myGroupAdapter = MyGroupAdapter { groupInfo ->
diff --git a/presentation/src/main/java/com/whyranoid/presentation/community/CommunityViewModel.kt b/presentation/src/main/java/com/whyranoid/presentation/community/CommunityViewModel.kt
@@ -2,7 +2,9 @@ package com.whyranoid.presentation.community
 
 import androidx.lifecycle.ViewModel
 import androidx.lifecycle.viewModelScope
+import com.whyranoid.domain.model.Post
 import com.whyranoid.domain.usecase.GetMyGroupListUseCase
+import com.whyranoid.domain.usecase.GetPostsUseCase
 import com.whyranoid.presentation.model.GroupInfoUiModel
 import com.whyranoid.presentation.model.toGroupInfoUiModel
 import dagger.hilt.android.lifecycle.HiltViewModel
@@ -19,9 +21,14 @@ import javax.inject.Inject
 
 @HiltViewModel
 class CommunityViewModel @Inject constructor(
-    getMyGroupListUseCase: GetMyGroupListUseCase
+    getMyGroupListUseCase: GetMyGroupListUseCase,
+    getPostsUseCase: GetPostsUseCase
 ) : ViewModel() {
 
+    private val _postList = MutableStateFlow<List<Post>>(emptyList())
+    val postList: StateFlow<List<Post>>
+        get() = _postList.asStateFlow()
+
     private val _myGroupList = MutableStateFlow<List<GroupInfoUiModel>>(emptyList())
     val myGroupList: StateFlow<List<GroupInfoUiModel>>
         get() = _myGroupList.asStateFlow()
@@ -46,5 +53,9 @@ class CommunityViewModel @Inject constructor(
                 groupInfo.toGroupInfoUiModel()
             }
         }.launchIn(viewModelScope)
+
+        getPostsUseCase().onEach { postList ->
+            _postList.value = postList
+        }.launchIn(viewModelScope)
     }
 }
diff --git a/presentation/src/main/java/com/whyranoid/presentation/community/PostAdapter.kt b/presentation/src/main/java/com/whyranoid/presentation/community/PostAdapter.kt
@@ -0,0 +1,54 @@
+package com.whyranoid.presentation.community
+
+import android.view.LayoutInflater
+import android.view.View
+import android.view.ViewGroup
+import androidx.recyclerview.widget.DiffUtil
+import androidx.recyclerview.widget.ListAdapter
+import androidx.recyclerview.widget.RecyclerView
+import com.whyranoid.domain.model.Post
+import com.whyranoid.domain.model.RecruitPost
+import com.whyranoid.presentation.databinding.ItemRecruitPostBinding
+
+class PostAdapter(private val myUid: String) :
+    ListAdapter<Post, PostAdapter.RecruitPostViewHolder>(diffUtil) {
+
+    companion object {
+        val diffUtil = object : DiffUtil.ItemCallback<Post>() {
+            override fun areItemsTheSame(oldItem: Post, newItem: Post) =
+                oldItem.postId == newItem.postId
+
+            override fun areContentsTheSame(oldItem: Post, newItem: Post) =
+                oldItem == newItem
+        }
+    }
+
+    inner class RecruitPostViewHolder(
+        parent: ViewGroup,
+        private val binding: ItemRecruitPostBinding = ItemRecruitPostBinding.inflate(
+            LayoutInflater.from(parent.context),
+            parent,
+            false
+        )
+    ) : RecyclerView.ViewHolder(binding.root) {
+        fun bind(post: Post) {
+            if (post is RecruitPost) {
+                binding.recruitPost = post
+                if (myUid == post.author.uid) {
+                    println("테스트 $myUid ${post.author.uid}")
+                    binding.btnJoinGroup.visibility = View.GONE
+                } else {
+                    binding.btnJoinGroup.visibility = View.VISIBLE
+                }
+            }
+        }
+    }
+
+    override fun onCreateViewHolder(parent: ViewGroup, viewType: Int): RecruitPostViewHolder {
+        return RecruitPostViewHolder(parent)
+    }
+
+    override fun onBindViewHolder(holder: RecruitPostViewHolder, position: Int) {
+        holder.bind(getItem(position))
+    }
+}
diff --git a/presentation/src/main/java/com/whyranoid/presentation/community/group/detail/Event.kt b/presentation/src/main/java/com/whyranoid/presentation/community/group/detail/Event.kt
@@ -3,4 +3,5 @@ package com.whyranoid.presentation.community.group.detail
 sealed class Event {
     object RecruitButtonClick : Event()
     object ExitGroupButtonClick : Event()
+    data class RecruitSnackBarButtonClick(val isSuccess: Boolean = true) : Event()
 }
diff --git a/presentation/src/main/java/com/whyranoid/presentation/community/group/detail/GroupDetailFragment.kt b/presentation/src/main/java/com/whyranoid/presentation/community/group/detail/GroupDetailFragment.kt
@@ -76,9 +76,11 @@ internal class GroupDetailFragment :
                     Event.RecruitButtonClick -> {
                         Snackbar.make(
                             binding.root,
-                            getString(R.string.text_recruit),
+                            getString(R.string.text_check_recruit),
                             Snackbar.LENGTH_SHORT
-                        ).show()
+                        ).setAction(R.string.text_recruit) {
+                            viewModel.onRecruitSnackBarButtonClick()
+                        }.show()
                     }
                     // TODO : 그룹 나가기
                     Event.ExitGroupButtonClick -> {
@@ -88,6 +90,21 @@ internal class GroupDetailFragment :
                             Snackbar.LENGTH_SHORT
                         ).show()
                     }
+                    is Event.RecruitSnackBarButtonClick -> {
+                        if (event.isSuccess) {
+                            Snackbar.make(
+                                binding.root,
+                                getString(R.string.text_recruit_success),
+                                Snackbar.LENGTH_SHORT
+                            ).show()
+                        } else {
+                            Snackbar.make(
+                                binding.root,
+                                getString(R.string.text_recruit_fail),
+                                Snackbar.LENGTH_SHORT
+                            ).show()
+                        }
+                    }
                 }
             }
         }
diff --git a/presentation/src/main/java/com/whyranoid/presentation/community/group/detail/GroupDetailViewModel.kt b/presentation/src/main/java/com/whyranoid/presentation/community/group/detail/GroupDetailViewModel.kt
diff --git a/presentation/src/main/res/layout/item_recruit_post.xml b/presentation/src/main/res/layout/item_recruit_post.xml
diff --git a/presentation/src/main/res/values/strings.xml b/presentation/src/main/res/values/strings.xml

Original file line number	Diff line number	Diff line change
`@@ -3,4 +3,5 @@ package com.whyranoid.presentation.community.group.detail`
`3`	`3`	`sealed class Event {`
`4`	`4`	`object RecruitButtonClick : Event()`
`5`	`5`	`object ExitGroupButtonClick : Event()`
	`6`	`+ data class RecruitSnackBarButtonClick(val isSuccess: Boolean = true) : Event()`
`6`	`7`	`}`