✨ PostDataSource 일부 구현

Author: soopeach

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

@@ -0,0 +1,40 @@
+package com.whyranoid.data.Post
+
+import com.google.firebase.firestore.FirebaseFirestore
+import com.whyranoid.data.constant.CollectionId
+import com.whyranoid.domain.model.GroupInfo
+import com.whyranoid.domain.model.RecruitPost
+import com.whyranoid.domain.model.User
+import kotlinx.coroutines.suspendCancellableCoroutine
+import java.util.*
+import javax.inject.Inject
+import kotlin.coroutines.resume
+
+class PostDataSource @Inject constructor(
+    private val db: FirebaseFirestore
+) {
+
+    suspend fun createRecruitPost(
+        author: User,
+        updatedAt: Long,
+        groupInfo: GroupInfo
+    ): Boolean {
+        return suspendCancellableCoroutine { cancellableContinuation ->
+            val postId = UUID.randomUUID().toString()
+            db.collection(CollectionId.POST_COLLECTION)
+                .document(postId)
+                .set(
+                    RecruitPost(
+                        postId = postId,
+                        author = author,
+                        updatedAt = updatedAt,
+                        groupInfo = groupInfo
+                    )
+                ).addOnSuccessListener {
+                    cancellableContinuation.resume(true)
+                }.addOnFailureListener {
+                    cancellableContinuation.resume(false)
+                }
+        }
+    }
+}

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

@@ -0,0 +1,44 @@
+package com.whyranoid.data.Post
+
+import com.whyranoid.domain.model.GroupInfo
+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(
+        author: User,
+        updatedAt: Long,
+        groupInfo: GroupInfo
+    ): Boolean {
+        return postDataSource.createRecruitPost(author, updatedAt, groupInfo)
+    }
+
+    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/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/model/PostResponse.kt

@@ -0,0 +1,32 @@
+package com.whyranoid.data.model
+
+import com.whyranoid.domain.model.RecruitPost
+import com.whyranoid.domain.model.toRule
+
+sealed interface PostResponse {
+    val postId: String
+    val author: UserResponse
+    val updatedAt: Long
+}
+
+data class RecruitPostResponse(
+    override val postId: String = "",
+    override val author: UserResponse = UserResponse(),
+    override val updatedAt: Long = 0L,
+    val groupInfo: GroupInfoResponse = GroupInfoResponse()
+) : PostResponse
+
+fun RecruitPostResponse.toRecruitPost(): RecruitPost {
+    val leader = this.author.toUser()
+    return RecruitPost(
+        postId = this.postId,
+        author = leader,
+        updatedAt = this.updatedAt,
+        groupInfo = this.groupInfo.toGroupInfo(
+            leader,
+            this.groupInfo.rules.map {
+                it.toRule()
+            }
+        )
+    )
+}

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

@@ -1,15 +1,16 @@
 package com.whyranoid.domain.repository
 
-import androidx.paging.PagingData
+import com.whyranoid.domain.model.GroupInfo
 import com.whyranoid.domain.model.Post
 import com.whyranoid.domain.model.RunningHistory
 import com.whyranoid.domain.model.User
 import kotlinx.coroutines.flow.Flow
 
 interface PostRepository {
 
+    // TODO : 페이징 처리
     // 글(홍보 / 인증) 페이징으로 가져오기 - 리모트
-    fun getPagingPosts(): Flow<PagingData<Post>>
+    fun getPagingPosts(): Flow<List<Post>>
 
     // 글 작성하기 - 리모트
     suspend fun createPost(
@@ -19,6 +20,12 @@ interface PostRepository {
         updatedAt: Long
     ): Boolean
 
+    suspend fun createRecruitPost(
+        author: User,
+        updatedAt: Long = 0L,
+        groupInfo: GroupInfo
+    ): Boolean
+
     // 글 삭제하기 - 리모트
     suspend fun deletePost(postId: String): Boolean
 

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

@@ -1,13 +1,12 @@
 package com.whyranoid.domain.usecase
 
-import androidx.paging.PagingData
 import com.whyranoid.domain.model.Post
 import com.whyranoid.domain.repository.PostRepository
 import kotlinx.coroutines.flow.Flow
 import javax.inject.Inject
 
 class GetPagingPostsUseCase @Inject constructor(private val postRepository: PostRepository) {
-    operator fun invoke(): Flow<PagingData<Post>> {
+    operator fun invoke(): Flow<List<Post>> {
         return postRepository.getPagingPosts()
     }
 }