Feat/#67 게시글 목록 기능 구현

app/src/main/java/com/withpeace/withpeace/MainBottomNavigation.kt

@@ -19,7 +19,6 @@ import com.withpeace.withpeace.feature.home.navigation.HOME_ROUTE
 import com.withpeace.withpeace.feature.home.navigation.navigateHome
 import com.withpeace.withpeace.feature.mypage.navigation.MY_PAGE_ROUTE
 import com.withpeace.withpeace.feature.mypage.navigation.navigateMyPage
-import com.withpeace.withpeace.feature.postlist.navigation.POST_LIST_ROUTE
 import com.withpeace.withpeace.navigation.POST_NESTED_ROUTE
 
 @Composable
@@ -34,19 +33,25 @@ fun MainBottomBar(
     ) {
         BottomTab.entries.forEach { tab ->
             NavigationBarItem(
-                colors = NavigationBarItemDefaults.colors(
-                    selectedTextColor = WithpeaceTheme.colors.SystemBlack,
-                    unselectedTextColor = WithpeaceTheme.colors.SystemGray2,
-                    indicatorColor = WithpeaceTheme.colors.SystemWhite,
-                ),
+                colors =
+                    NavigationBarItemDefaults.colors(
+                        selectedTextColor = WithpeaceTheme.colors.SystemBlack,
+                        unselectedTextColor = WithpeaceTheme.colors.SystemGray2,
+                        indicatorColor = WithpeaceTheme.colors.SystemWhite,
+                    ),
                 selected = currentDestination.route == tab.route,
                 onClick = { navController.navigateToTabScreen(tab) },
                 icon = {
                     Image(
-                        painter = painterResource(
-                            id = if (currentDestination.route == tab.route) tab.iconSelectedResId
-                            else tab.iconUnSelectedResId,
-                        ),
+                        painter =
+                            painterResource(
+                                id =
+                                    if (currentDestination.route == tab.route) {
+                                        tab.iconSelectedResId
+                                    } else {
+                                        tab.iconUnSelectedResId
+                                    },
+                            ),
                         contentDescription = context.getString(tab.contentDescription),
                     )
                 },
@@ -96,7 +101,8 @@ enum class BottomTab(
         iconSelectedResId = R.drawable.ic_bottom_my_page_select,
         contentDescription = R.string.my_page,
         MY_PAGE_ROUTE,
-    );
+    ),
+    ;
 
     companion object {
         operator fun contains(route: String): Boolean {

core/data/src/main/kotlin/com/withpeace/withpeace/core/data/mapper/DateMapper.kt

@@ -0,0 +1,11 @@
+package com.withpeace.withpeace.core.data.mapper
+
+import java.time.LocalDateTime
+import java.time.format.DateTimeFormatter
+
+fun String.toLocalDateTime(): LocalDateTime = LocalDateTime.parse(
+    this,
+    DateTimeFormatter.ofPattern(SERVER_DATE_FORMAT),
+)
+
+private const val SERVER_DATE_FORMAT = "yyyy/MM/dd HH:mm:ss"

core/data/src/main/kotlin/com/withpeace/withpeace/core/data/mapper/PostMapper.kt

@@ -0,0 +1,15 @@
+package com.withpeace.withpeace.core.data.mapper
+
+import com.withpeace.withpeace.core.domain.model.date.Date
+import com.withpeace.withpeace.core.domain.model.post.Post
+import com.withpeace.withpeace.core.network.di.response.post.PostResponse
+
+fun PostResponse.toDomain() =
+    Post(
+        postId = postId,
+        title = title,
+        content = content,
+        postTopic = type.toDomain(),
+        createDate = Date(createDate.toLocalDateTime()),
+        postImageUrl = postImageUrl,
+    )

core/data/src/main/kotlin/com/withpeace/withpeace/core/data/mapper/PostTopicMapper.kt

@@ -0,0 +1,21 @@
+package com.withpeace.withpeace.core.data.mapper
+
+import com.withpeace.withpeace.core.domain.model.post.PostTopic
+import com.withpeace.withpeace.core.network.di.response.post.PostTopicResponse
+import com.withpeace.withpeace.core.network.di.response.post.PostTopicResponse.ECONOMY
+import com.withpeace.withpeace.core.network.di.response.post.PostTopicResponse.FREEDOM
+import com.withpeace.withpeace.core.network.di.response.post.PostTopicResponse.HOBBY
+import com.withpeace.withpeace.core.network.di.response.post.PostTopicResponse.INFORMATION
+import com.withpeace.withpeace.core.network.di.response.post.PostTopicResponse.LIVING
+import com.withpeace.withpeace.core.network.di.response.post.PostTopicResponse.QUESTION
+
+fun PostTopicResponse.toDomain(): PostTopic {
+    return when (this) {
+        FREEDOM -> PostTopic.FREEDOM
+        INFORMATION -> PostTopic.INFORMATION
+        QUESTION -> PostTopic.QUESTION
+        LIVING -> PostTopic.LIVING
+        HOBBY -> PostTopic.HOBBY
+        ECONOMY -> PostTopic.ECONOMY
+    }
+}

core/data/src/main/kotlin/com/withpeace/withpeace/core/data/repository/DefaultPostRepository.kt

@@ -6,74 +6,111 @@ import com.skydoves.sandwich.messageOrNull
 import com.skydoves.sandwich.suspendMapSuccess
 import com.skydoves.sandwich.suspendOnError
 import com.skydoves.sandwich.suspendOnException
+import com.withpeace.withpeace.core.data.mapper.toDomain
 import com.withpeace.withpeace.core.data.util.convertToFile
 import com.withpeace.withpeace.core.domain.model.WithPeaceError
 import com.withpeace.withpeace.core.domain.model.WithPeaceError.GeneralError
 import com.withpeace.withpeace.core.domain.model.WithPeaceError.UnAuthorized
+import com.withpeace.withpeace.core.domain.model.post.Post
+import com.withpeace.withpeace.core.domain.model.post.PostTopic
 import com.withpeace.withpeace.core.domain.model.post.RegisterPost
 import com.withpeace.withpeace.core.domain.repository.PostRepository
 import com.withpeace.withpeace.core.network.di.service.PostService
 import dagger.hilt.android.qualifiers.ApplicationContext
+import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.flow
+import kotlinx.coroutines.flow.flowOn
 import okhttp3.MediaType.Companion.toMediaTypeOrNull
 import okhttp3.MultipartBody
 import okhttp3.RequestBody
 import okhttp3.RequestBody.Companion.asRequestBody
 import okhttp3.RequestBody.Companion.toRequestBody
 import javax.inject.Inject
 
-class DefaultPostRepository @Inject constructor(
-    @ApplicationContext private val context: Context,
-    private val postService: PostService,
-) : PostRepository {
-    override fun registerPost(
-        post: RegisterPost,
-        onError: suspend (WithPeaceError) -> Unit,
-    ): Flow<Long> =
-        flow {
-            val imageRequestBodies = getImageRequestBodies(post.images.urls)
-            val postRequestBodies = getPostRequestBodies(post)
-            postService.registerPost(postRequestBodies, imageRequestBodies)
-                .suspendMapSuccess {
-                    emit(data.postId)
+class DefaultPostRepository
+    @Inject
+    constructor(
+        @ApplicationContext private val context: Context,
+        private val postService: PostService,
+    ) : PostRepository {
+        override fun getPosts(
+            postTopic: PostTopic,
+            pageIndex: Int,
+            pageSize: Int,
+            onError: suspend (WithPeaceError) -> Unit,
+        ): Flow<List<Post>> =
+            flow {
+                postService.getPosts(
+                    postTopic = postTopic.name,
+                    pageIndex = pageIndex,
+                    pageSize = pageSize,
+                ).suspendMapSuccess {
+                    emit(data.map { it.toDomain() })
                 }.suspendOnError {
-                    if (statusCode.code == 401) onError(UnAuthorized())
-                    else onError(GeneralError(statusCode.code, messageOrNull))
+                    if (statusCode.code == 401) {
+                        onError(
+                            UnAuthorized(
+                                statusCode.code,
+                                message = null,
+                            ),
+                        )
+                    } else {
+                        onError(GeneralError(statusCode.code, messageOrNull))
+                    }
                 }.suspendOnException {
                     onError(GeneralError(message = messageOrNull))
                 }
-        }
+            }.flowOn(Dispatchers.IO)
+
+        override fun registerPost(
+            post: RegisterPost,
+            onError: suspend (WithPeaceError) -> Unit,
+        ): Flow<Long> =
+            flow {
+                val imageRequestBodies = getImageRequestBodies(post.images.urls)
+                val postRequestBodies = getPostRequestBodies(post)
+                postService.registerPost(postRequestBodies, imageRequestBodies)
+                    .suspendMapSuccess {
+                        emit(data.postId)
+                    }.suspendOnError {
+                        if (statusCode.code == 401) {
+                            onError(UnAuthorized())
+                        } else {
+                            onError(GeneralError(statusCode.code, messageOrNull))
+                        }
+                    }.suspendOnException {
+                        onError(GeneralError(message = messageOrNull))
+                    }
+            }.flowOn(Dispatchers.IO)
 
-    private fun getImageRequestBodies(
-        imageUris: List<String>,
-    ): List<MultipartBody.Part> {
-        val imageFiles = imageUris.map { Uri.parse(it).convertToFile(context) }
-        return imageFiles.map { file ->
-            val requestFile = file.asRequestBody("image/*".toMediaTypeOrNull())
-            MultipartBody.Part.createFormData(
-                IMAGES_COLUMN,
-                file.name,
-                requestFile,
-            )
+        private fun getImageRequestBodies(imageUris: List<String>): List<MultipartBody.Part> {
+            val imageFiles = imageUris.map { Uri.parse(it).convertToFile(context) }
+            return imageFiles.map { file ->
+                val requestFile = file.asRequestBody("image/*".toMediaTypeOrNull())
+                MultipartBody.Part.createFormData(
+                    IMAGES_COLUMN,
+                    file.name,
+                    requestFile,
+                )
+            }
         }
-    }
 
-    private fun getPostRequestBodies(post: RegisterPost): HashMap<String, RequestBody> {
-        return HashMap<String, RequestBody>().apply {
-            set(
-                TYPE_COLUMN,
-                post.topic.toString().toRequestBody("application/json".toMediaTypeOrNull()),
-            )
-            set(TITLE_COLUMN, post.title.toRequestBody("application/json".toMediaTypeOrNull()))
-            set(CONTENT_COLUMN, post.content.toRequestBody("application/json".toMediaTypeOrNull()))
+        private fun getPostRequestBodies(post: RegisterPost): HashMap<String, RequestBody> {
+            return HashMap<String, RequestBody>().apply {
+                set(
+                    TYPE_COLUMN,
+                    post.topic.toString().toRequestBody("application/json".toMediaTypeOrNull()),
+                )
+                set(TITLE_COLUMN, post.title.toRequestBody("application/json".toMediaTypeOrNull()))
+                set(CONTENT_COLUMN, post.content.toRequestBody("application/json".toMediaTypeOrNull()))
+            }
         }
-    }
 
-    companion object {
-        const val TITLE_COLUMN = "title"
-        const val CONTENT_COLUMN = "content"
-        const val TYPE_COLUMN = "type"
-        const val IMAGES_COLUMN = "images"
+        companion object {
+            const val TITLE_COLUMN = "title"
+            const val CONTENT_COLUMN = "content"
+            const val TYPE_COLUMN = "type"
+            const val IMAGES_COLUMN = "images"
+        }
     }
-}

core/domain/src/main/java/com/withpeace/withpeace/core/domain/model/post/PostPageInfo.kt

@@ -0,0 +1,16 @@
+package com.withpeace.withpeace.core.domain.model.post
+
+import androidx.paging.PagingConfig
+import androidx.paging.PagingSource
+
+data class PostPageInfo(
+    val pageSize: Int,
+    val enablePlaceholders: Boolean = true,
+    val pagingSource: PagingSource<Int, Post>,
+) {
+    val pagingConfig =
+        PagingConfig(
+            pageSize = pageSize,
+            enablePlaceholders = enablePlaceholders,
+        )
+}

core/domain/src/main/java/com/withpeace/withpeace/core/domain/paging/PostPagingSource.kt

@@ -0,0 +1,44 @@
+package com.withpeace.withpeace.core.domain.paging
+
+import androidx.paging.PagingSource
+import androidx.paging.PagingState
+import com.withpeace.withpeace.core.domain.model.WithPeaceError
+import com.withpeace.withpeace.core.domain.model.post.Post
+import com.withpeace.withpeace.core.domain.model.post.PostTopic
+import com.withpeace.withpeace.core.domain.repository.PostRepository
+import kotlinx.coroutines.flow.firstOrNull
+
+data class PostPagingSource(
+    private val postRepository: PostRepository,
+    private val postTopic: PostTopic,
+    private val pageSize: Int,
+    private val onError: suspend (WithPeaceError) -> Unit,
+) : PagingSource<Int, Post>() {
+
+    override suspend fun load(params: LoadParams<Int>): LoadResult<Int, Post> {
+        return try {
+            val currentPage = params.key ?: STARTING_PAGE_INDEX
+            val data = postRepository.getPosts(
+                postTopic = postTopic,
+                pageIndex = currentPage,
+                pageSize = params.loadSize,
+                onError = onError,
+            ).firstOrNull() ?: emptyList()
+            val endOfPaginationReached = data.isEmpty()
+            val prevKey = if (currentPage == STARTING_PAGE_INDEX) null else currentPage - 1
+            val nextKey =
+                if (endOfPaginationReached) null else currentPage + (params.loadSize / pageSize)
+            LoadResult.Page(data, prevKey, nextKey)
+        } catch (exception: Exception) {
+            LoadResult.Error(exception)
+        }
+    }
+
+    override fun getRefreshKey(state: PagingState<Int, Post>): Int? {
+        return state.anchorPosition
+    }
+
+    companion object {
+        const val STARTING_PAGE_INDEX = 0
+    }
+}

core/domain/src/main/java/com/withpeace/withpeace/core/domain/repository/PostRepository.kt

@@ -1,10 +1,19 @@
 package com.withpeace.withpeace.core.domain.repository
 
 import com.withpeace.withpeace.core.domain.model.WithPeaceError
+import com.withpeace.withpeace.core.domain.model.post.Post
+import com.withpeace.withpeace.core.domain.model.post.PostTopic
 import com.withpeace.withpeace.core.domain.model.post.RegisterPost
 import kotlinx.coroutines.flow.Flow
 
 interface PostRepository {
+    fun getPosts(
+        postTopic: PostTopic,
+        pageIndex: Int,
+        pageSize: Int,
+        onError: suspend (WithPeaceError) -> Unit,
+    ): Flow<List<Post>>
+
     fun registerPost(
         post: RegisterPost,
         onError: suspend (WithPeaceError) -> Unit,

core/domain/src/main/java/com/withpeace/withpeace/core/domain/usecase/GetPostsUseCase.kt

@@ -0,0 +1,26 @@
+package com.withpeace.withpeace.core.domain.usecase
+
+import com.withpeace.withpeace.core.domain.model.WithPeaceError
+import com.withpeace.withpeace.core.domain.model.post.PostPageInfo
+import com.withpeace.withpeace.core.domain.model.post.PostTopic
+import com.withpeace.withpeace.core.domain.paging.PostPagingSource
+import com.withpeace.withpeace.core.domain.repository.PostRepository
+import javax.inject.Inject
+
+class GetPostsUseCase @Inject constructor(
+    private val postRepository: PostRepository,
+) {
+    operator fun invoke(
+        postTopic: PostTopic,
+        pageSize: Int,
+        onError: suspend (WithPeaceError) -> Unit,
+    ): PostPageInfo = PostPageInfo(
+        pageSize = pageSize,
+        pagingSource = PostPagingSource(
+            postRepository = postRepository,
+            postTopic = postTopic,
+            pageSize = pageSize,
+            onError = onError,
+        ),
+    )
+}

core/network/src/main/java/com/withpeace/withpeace/core/network/di/response/PostResponse.kt → core/network/src/main/java/com/withpeace/withpeace/core/network/di/response/post/PostIdResponse.kt

@@ -1,4 +1,4 @@
-package com.withpeace.withpeace.core.network.di.response
+package com.withpeace.withpeace.core.network.di.response.post
 
 import kotlinx.serialization.Serializable
 

core/network/src/main/java/com/withpeace/withpeace/core/network/di/response/post/PostResponse.kt

@@ -0,0 +1,13 @@
+package com.withpeace.withpeace.core.network.di.response.post
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class PostResponse(
+    val postId: Long,
+    val title: String,
+    val content: String,
+    val type: PostTopicResponse,
+    val postImageUrl: String? = null,
+    val createDate: String,
+)

core/network/src/main/java/com/withpeace/withpeace/core/network/di/response/post/PostTopicResponse.kt

@@ -0,0 +1,10 @@
+package com.withpeace.withpeace.core.network.di.response.post;
+
+enum class PostTopicResponse {
+    FREEDOM,
+    INFORMATION,
+    QUESTION,
+    LIVING,
+    HOBBY,
+    ECONOMY
+}