✨ PostDataSource 추상화

Author: soopeach

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

@@ -1,5 +1,7 @@
 package com.whyranoid.data.di
 
+import com.whyranoid.data.post.PostDataSource
+import com.whyranoid.data.post.PostDataSourceImpl
 import com.whyranoid.data.post.PostRepositoryImpl
 import com.whyranoid.domain.repository.PostRepository
 import dagger.Binds
@@ -11,6 +13,9 @@ import dagger.hilt.components.SingletonComponent
 @InstallIn(SingletonComponent::class)
 abstract class PostModule {
 
+    @Binds
+    abstract fun bindPostDataSource(postDataSourceImpl: PostDataSourceImpl): PostDataSource
+
     @Binds
     abstract fun bindPostRepository(postRepositoryImpl: PostRepositoryImpl): PostRepository
 }

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

@@ -0,0 +1,22 @@
+package com.whyranoid.data.post
+
+import com.whyranoid.domain.model.Post
+import kotlinx.coroutines.flow.Flow
+
+interface PostDataSource {
+
+    fun getAllPostFlow(): Flow<List<Post>>
+
+    fun getMyPostFlow(uid: String): Flow<List<Post>>
+
+    suspend fun createRecruitPost(
+        authorUid: String,
+        groupUid: String
+    ): Boolean
+
+    suspend fun createRunningPost(
+        authorUid: String,
+        runningHistoryId: String,
+        content: String
+    ): Result<Boolean>
+}

data/src/main/java/com/whyranoid/data/post/PostDataSourceImpl.kt

@@ -27,10 +27,10 @@ import kotlin.coroutines.resume
 
 class PostDataSourceImpl @Inject constructor(
     private val db: FirebaseFirestore
-) {
+) : PostDataSource {
 
     //  TODO : 조금 더 간결하게 처리 필요.
-    fun getAllPostFlow(): Flow<List<Post>> =
+    override fun getAllPostFlow(): Flow<List<Post>> =
         callbackFlow {
             db.collection(CollectionId.POST_COLLECTION)
                 .orderBy(UPDATED_AT, Query.Direction.DESCENDING)
@@ -122,7 +122,7 @@ class PostDataSourceImpl @Inject constructor(
             awaitClose()
         }
 
-    fun getMyPostFlow(uid: String): Flow<List<Post>> =
+    override fun getMyPostFlow(uid: String): Flow<List<Post>> =
         callbackFlow {
             db.collection(CollectionId.POST_COLLECTION)
                 .whereEqualTo(AUTHOR_ID, uid)
@@ -215,7 +215,7 @@ class PostDataSourceImpl @Inject constructor(
             awaitClose()
         }
 
-    suspend fun createRecruitPost(
+    override suspend fun createRecruitPost(
         authorUid: String,
         groupUid: String
     ): Boolean {
@@ -240,7 +240,7 @@ class PostDataSourceImpl @Inject constructor(
         }
     }
 
-    suspend fun createRunningPost(
+    override suspend fun createRunningPost(
         authorUid: String,
         runningHistoryId: String,
         content: String

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

@@ -6,7 +6,7 @@ import kotlinx.coroutines.flow.Flow
 import javax.inject.Inject
 
 class PostRepositoryImpl @Inject constructor(
-    private val postDataSourceImpl: PostDataSourceImpl
+    private val postDataSource: PostDataSource
 ) : PostRepository {
 
     // TODO : 페이징처리하기
@@ -15,26 +15,26 @@ class PostRepositoryImpl @Inject constructor(
     }
 
     override fun getAllPostFlow(): Flow<List<Post>> {
-        return postDataSourceImpl.getAllPostFlow()
+        return postDataSource.getAllPostFlow()
     }
 
     override fun getMyPostFlow(uid: String): Flow<List<Post>> {
-        return postDataSourceImpl.getMyPostFlow(uid)
+        return postDataSource.getMyPostFlow(uid)
     }
 
     override suspend fun createRunningPost(
         authorUid: String,
         runningHistoryId: String,
         content: String
     ): Result<Boolean> {
-        return postDataSourceImpl.createRunningPost(authorUid, runningHistoryId, content)
+        return postDataSource.createRunningPost(authorUid, runningHistoryId, content)
     }
 
     override suspend fun createRecruitPost(
         authorUid: String,
         groupUid: String
     ): Boolean {
-        return postDataSourceImpl.createRecruitPost(authorUid, groupUid)
+        return postDataSource.createRecruitPost(authorUid, groupUid)
     }
 
     override suspend fun deletePost(postId: String): Boolean {