🔀 #55 from boostcampwm-2022/feat/community_create_running_post

운동 기록 선택 후 인증글 작성 구현 및 uid Flow에서 한번만 받아오도록 수정

Author: peter-j0y

data/src/main/java/com/whyranoid/data/account/AccountDataSource.kt

@@ -5,7 +5,7 @@ import kotlinx.coroutines.flow.Flow
 interface AccountDataSource {
     fun getUserNickName(): Flow<String>
     fun getUserProfileImgUri(): Flow<String>
-    fun getUserUid(): Flow<String>
+    suspend fun getUserUid(): String
     fun getEmail(): Flow<Result<String>>
     suspend fun updateUserNickName(uid: String, newNickName: String): Result<String>
     suspend fun signOut(): Result<Boolean>

data/src/main/java/com/whyranoid/data/account/AccountDataSourceImpl.kt

@@ -11,6 +11,7 @@ import com.whyranoid.data.account.AccountDataSourceImpl.PreferenceKeys.nickName
 import com.whyranoid.data.account.AccountDataSourceImpl.PreferenceKeys.profileImgUri
 import com.whyranoid.data.account.AccountDataSourceImpl.PreferenceKeys.uid
 import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.first
 import kotlinx.coroutines.flow.map
 import javax.inject.Inject
 
@@ -39,10 +40,10 @@ class AccountDataSourceImpl @Inject constructor(
             preferences[profileImgUri] ?: EMPTY_STRING
         }
 
-    override fun getUserUid() = dataStoreDb.data
+    override suspend fun getUserUid(): String = dataStoreDb.data
         .map { preferences ->
             preferences[uid] ?: EMPTY_STRING
-        }
+        }.first()
 
     override fun getEmail(): Flow<Result<String>> {
         return dataStoreDb.data

data/src/main/java/com/whyranoid/data/account/AccountRepositoryImpl.kt

@@ -17,7 +17,7 @@ class AccountRepositoryImpl @Inject constructor(
         return true
     }
 
-    override fun getUid(): Flow<String> {
+    override suspend fun getUid(): String {
         return accountDataSource.getUserUid()
     }
 

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

@@ -1,6 +1,6 @@
 package com.whyranoid.data.di
 
-import com.whyranoid.data.Post.PostRepositoryImpl
+import com.whyranoid.data.post.PostRepositoryImpl
 import com.whyranoid.domain.repository.PostRepository
 import dagger.Binds
 import dagger.Module

data/src/main/java/com/whyranoid/data/Post/PostDataSource.kt renamed to data/src/main/java/com/whyranoid/data/post/PostDataSourceImpl.kt

@@ -1,4 +1,4 @@
-package com.whyranoid.data.Post
+package com.whyranoid.data.post
 
 import com.google.firebase.firestore.FirebaseFirestore
 import com.google.firebase.firestore.Query
@@ -24,7 +24,7 @@ import java.util.*
 import javax.inject.Inject
 import kotlin.coroutines.resume
 
-class PostDataSource @Inject constructor(
+class PostDataSourceImpl @Inject constructor(
     private val db: FirebaseFirestore
 ) {
 
@@ -145,4 +145,33 @@ class PostDataSource @Inject constructor(
                 }
         }
     }
+
+    suspend fun createRunningPost(
+        authorUid: String,
+        runningHistoryId: String,
+        content: String
+    ): Result<Boolean> {
+        val postId = UUID.randomUUID().toString()
+
+        return runCatching {
+            suspendCancellableCoroutine { cancellableContinuation ->
+
+                db.collection(CollectionId.POST_COLLECTION)
+                    .document(postId)
+                    .set(
+                        RunningPostResponse(
+                            postId = postId,
+                            authorId = authorUid,
+                            updatedAt = System.currentTimeMillis(),
+                            runningHistoryId = runningHistoryId,
+                            content = content
+                        )
+                    ).addOnSuccessListener {
+                        cancellableContinuation.resume(true)
+                    }.addOnFailureListener {
+                        cancellableContinuation.resume(false)
+                    }
+            }
+        }
+    }
 }

data/src/main/java/com/whyranoid/data/Post/PostRepositoryImpl.kt renamed to data/src/main/java/com/whyranoid/data/post/PostRepositoryImpl.kt

@@ -1,14 +1,12 @@
-package com.whyranoid.data.Post
+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
+    private val postDataSourceImpl: PostDataSourceImpl
 ) : PostRepository {
 
     // TODO : 페이징처리하기
@@ -17,23 +15,22 @@ class PostRepositoryImpl @Inject constructor(
     }
 
     override fun getAllPostFlow(): Flow<List<Post>> {
-        return postDataSource.getAllPostFlow()
+        return postDataSourceImpl.getAllPostFlow()
     }
 
-    override suspend fun createPost(
-        user: User,
-        postContent: String,
-        runningHistory: RunningHistory,
-        updatedAt: Long
-    ): Boolean {
-        TODO("Not yet implemented")
+    override suspend fun createRunningPost(
+        authorUid: String,
+        runningHistoryId: String,
+        content: String
+    ): Result<Boolean> {
+        return postDataSourceImpl.createRunningPost(authorUid, runningHistoryId, content)
     }
 
     override suspend fun createRecruitPost(
         authorUid: String,
         groupUid: String
     ): Boolean {
-        return postDataSource.createRecruitPost(authorUid, groupUid)
+        return postDataSourceImpl.createRecruitPost(authorUid, groupUid)
     }
 
     override suspend fun deletePost(postId: String): Boolean {

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

@@ -12,7 +12,7 @@ interface AccountRepository {
     suspend fun loginUser(): Boolean
 
     // 데이터스토어에서 uid 가져오기
-    fun getUid(): Flow<String>
+    suspend fun getUid(): String
 
     // 데이터스토어에서 닉네임 가져오기
     fun getNickname(): Flow<String>

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

@@ -1,8 +1,6 @@
 package com.whyranoid.domain.repository
 
 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 {
@@ -14,12 +12,11 @@ interface PostRepository {
     fun getAllPostFlow(): Flow<List<Post>>
 
     // 글 작성하기 - 리모트
-    suspend fun createPost(
-        user: User,
-        postContent: String,
-        runningHistory: RunningHistory,
-        updatedAt: Long
-    ): Boolean
+    suspend fun createRunningPost(
+        authorUid: String,
+        runningHistoryId: String,
+        content: String
+    ): Result<Boolean>
 
     suspend fun createRecruitPost(
         authorUid: String,

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

@@ -0,0 +1,21 @@
+package com.whyranoid.domain.usecase
+
+import com.whyranoid.domain.repository.AccountRepository
+import com.whyranoid.domain.repository.PostRepository
+import javax.inject.Inject
+
+class CreateRunningPostUseCase @Inject constructor(
+    private val postRepository: PostRepository,
+    private val accountRepository: AccountRepository
+) {
+    suspend operator fun invoke(
+        postContent: String,
+        runningHistoryId: String
+    ): Result<Boolean> {
+        return postRepository.createRunningPost(
+            accountRepository.getUid(),
+            runningHistoryId,
+            postContent
+        )
+    }
+}