Skip to content

CommunityRepository의 반환값을 Flow에서 Result<Data>로 변경 #318

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
hegunhee merged 11 commits into from
Jul 26, 2025
Merged

CommunityRepository의 반환값을 Flow에서 Result<Data>로 변경 #318

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
8c51ec2
#317 - refactor : Post와 Review 둘 다 테스트
hegunhee Jul 26, 2025
71abc44
#317 - refactor : ViewModel도 변경
hegunhee Jul 26, 2025
493c360
#317 - refactor : 자신의 이미지 내역들을 불러오는 코드 flow에서 변경
hegunhee Jul 26, 2025
447bdda
#317 - refactor : 게시판 작성 코드 변경
hegunhee Jul 26, 2025
0895241
#317 - refactor : 게시판 조회 코드 변경
hegunhee Jul 26, 2025
d3880ff
#317 - refactor : 게시글 삭제 코드 변경
hegunhee Jul 26, 2025
babddd8
#317 - refactor : 게시판 스크랩 설정 코드 변경
hegunhee Jul 26, 2025
fed01e0
#317 - refactor : 유명한 포스트 불러오기 코드 수정
hegunhee Jul 26, 2025
cf83f5d
#317 - refactor: pager 수정
hegunhee Jul 26, 2025
b2f4196
#317 - feat : 게시글 갯수 코드 변경
hegunhee Jul 26, 2025
0f461b9
#317 - refactor : 게시글 수정 코드 변경
hegunhee Jul 26, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
287 changes: 106 additions & 181 deletions core/data/src/main/java/com/youthtalk/repository/CommunityRepositoryImpl.kt
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -15,186 +15,133 @@ import com.youthtalk.data.CommunityService
import com.youthtalk.datasource.post.MyPageRemoteMediator
import com.youthtalk.datasource.post.PostRemoteMediator
import com.youthtalk.datasource.room.YouthDatabase
import com.youthtalk.dto.MemberId
import com.youthtalk.mapper.toData
import com.youthtalk.mapper.toDomain
import com.youthtalk.model.Image
import com.youthtalk.model.post.CreatePost
import com.youthtalk.model.post.ModifyPost
import com.youthtalk.model.post.Post
import com.youthtalk.model.post.PostDetail
import com.youthtalk.model.post.PostSubject
import com.youthtalk.model.post.PostType
import com.youthtalk.model.typeenum.Category
import com.youthtalk.utils.ErrorUtils.throwableError
import com.youthtalk.utils.ErrorUtils.createResult
import javax.inject.Inject
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.flow
import kotlinx.coroutines.flow.flowOn
import kotlinx.coroutines.withContext
import timber.log.Timber

class CommunityRepositoryImpl @Inject constructor(
private val communityService: CommunityService,
private val youthDatabase: YouthDatabase,
private val context: Context
) : CommunityRepository {
override fun getPopularPosts(category: Category, postSubject: PostSubject): Flow<List<Post>> = flow {
override suspend fun getPopularPosts(category: Category, postSubject: PostSubject): Result<List<Post>> = createResult {
val categories = if (category == Category.ALL) {
Category.entries.filter { it != Category.ALL }.map { it.name }.toList()
} else {
listOf(
category.name
)
}
runCatching {
when (postSubject) {
PostSubject.REVIEW -> communityService.getReviewPosts(categories = categories, page = 0, size = 10)
PostSubject.POST -> communityService.getPosts(page = 0, size = 10)
}
}
.onSuccess { data ->
Timber.e("CommunityRepositoryImpl getPopularPosts Success $data")
data.data?.let { postResponse ->
emit(postResponse.popularPosts.map { it.toDomain() })
} ?: throw NoDataException()
}
.onFailure { error ->
Timber.e("CommunityRepositoryImpl getPopularPosts error : $error")
throwableError<MemberId>(error)
}
when (postSubject) {
PostSubject.REVIEW -> communityService.getReviewPosts(categories = categories, page = 0, size = 10)
PostSubject.POST -> communityService.getPosts(page = 0, size = 10)
}.data?.popularPosts?.map { it.toDomain() } ?: throw NoDataException()
}

@OptIn(ExperimentalPagingApi::class)
override fun getPosts(category: Category, postType: PostType, postSubject: PostSubject): Flow<Flow<PagingData<Post>>> = flow {
override fun getPosts(category: Category, postType: PostType, postSubject: PostSubject): Flow<PagingData<Post>> {
val categories = if (category == Category.ALL) {
Category.entries.filter { it != Category.ALL }.map { it.name }.toList()
} else {
listOf(
category.name
)
}
emit(
Pager(
config = PagingConfig(
pageSize = 10,
enablePlaceholders = true
),
remoteMediator = PostRemoteMediator(
communityService = communityService,
categories = categories,
postType = postType,
postSubject = postSubject,
youthDatabase = youthDatabase
)
) {
youthDatabase.postDao().getPagingSource(postType = postType)
}.flow
)
return Pager(
config = PagingConfig(
pageSize = 10,
enablePlaceholders = true
),
remoteMediator = PostRemoteMediator(
communityService = communityService,
categories = categories,
postType = postType,
postSubject = postSubject,
youthDatabase = youthDatabase
)
) {
youthDatabase.postDao().getPagingSource(postType = postType)
}.flow
}

override fun getListImage(): Flow<List<Image>> = flow {
val contentResolver = context.contentResolver
val projection = arrayOf(
Images.Media._ID,
Images.Media.DISPLAY_NAME,
Images.Media.SIZE,
Images.Media.MIME_TYPE
)

val collectionUri = if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.Q) {
Images.Media.getContentUri(MediaStore.VOLUME_EXTERNAL)
} else {
Images.Media.EXTERNAL_CONTENT_URI
}

val images = mutableListOf<Image>()

contentResolver.query(
collectionUri,
projection,
null,
null,
"${Images.Media.DATE_ADDED} DESC"
)?.use { cursor ->
val idColumn = cursor.getColumnIndexOrThrow(Images.Media._ID)
val displayNameColumn = cursor.getColumnIndexOrThrow(Images.Media.DISPLAY_NAME)
val sizeColumn = cursor.getColumnIndexOrThrow(Images.Media.SIZE)
val mimeTypeColumn = cursor.getColumnIndexOrThrow(Images.Media.MIME_TYPE)

while (cursor.moveToNext()) {
val uri = ContentUris.withAppendedId(collectionUri, cursor.getLong(idColumn))
val name = cursor.getString(displayNameColumn)
val size = cursor.getLong(sizeColumn)
val mimeType = cursor.getString(mimeTypeColumn)
override suspend fun getListImage(): Result<List<Image>> = runCatching {
withContext(Dispatchers.IO) {
val contentResolver = context.contentResolver
val projection = arrayOf(
Images.Media._ID,
Images.Media.DISPLAY_NAME,
Images.Media.SIZE,
Images.Media.MIME_TYPE
)

val image = Image(uri.toString(), name, size, mimeType)
images.add(image)
val collectionUri = if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.Q) {
Images.Media.getContentUri(MediaStore.VOLUME_EXTERNAL)
} else {
Images.Media.EXTERNAL_CONTENT_URI
}

val images = mutableListOf<Image>()

contentResolver.query(
collectionUri,
projection,
null,
null,
"${Images.Media.DATE_ADDED} DESC"
)?.use { cursor ->
val idColumn = cursor.getColumnIndexOrThrow(Images.Media._ID)
val displayNameColumn = cursor.getColumnIndexOrThrow(Images.Media.DISPLAY_NAME)
val sizeColumn = cursor.getColumnIndexOrThrow(Images.Media.SIZE)
val mimeTypeColumn = cursor.getColumnIndexOrThrow(Images.Media.MIME_TYPE)

while (cursor.moveToNext()) {
val uri = ContentUris.withAppendedId(collectionUri, cursor.getLong(idColumn))
val name = cursor.getString(displayNameColumn)
val size = cursor.getLong(sizeColumn)
val mimeType = cursor.getString(mimeTypeColumn)

val image = Image(uri.toString(), name, size, mimeType)
images.add(image)
}
}
images
}
}

emit(images)
}.flowOn(Dispatchers.IO)

override fun postCreatePost(createPost: CreatePost): Flow<Long> = flow {
runCatching {
communityService.postCreate(createPost.toData().toRequestBody())
}
.onSuccess { response ->
response.data?.let { post ->
emit(post.postId)
}
}
.onFailure {
Timber.e("postCreatePost error $it")
throwableError<Long>(it)
}
override suspend fun postCreatePost(createPost: CreatePost): Result<Long> = createResult {
communityService.postCreate(createPost.toData().toRequestBody()).data?.postId ?: throw NoDataException()
}

override fun getPostDetail(postId: Long) = flow {
runCatching {
communityService.getPostDetail(postId)
}
.onSuccess { response ->
response.data?.let { post ->
emit(post.toData())
}
}
.onFailure {
Timber.e("postCreatePost getPostDetail $it")
throwableError<PostDetail>(it)
}
override suspend fun getPostDetail(postId: Long) = createResult {
communityService.getPostDetail(postId).data?.toData() ?: throw NoDataException()
}

override fun deletePost(postId: Long): Flow<Long> = flow {
runCatching {
communityService.deletePost(postId)
}
.onSuccess {
youthDatabase.postDao().deletePost(postId)
emit(postId)
}
.onFailure {
Timber.e("postCreatePost deletePost $it")
throwableError<Long>(it)
}
override suspend fun deletePost(postId: Long): Result<Long> = createResult {
communityService.deletePost(postId)
youthDatabase.postDao().deletePost(postId)
postId
}

override fun postPostScrap(postId: Long, scrap: Boolean): Flow<Long> = flow {
runCatching {
communityService.postPostScrap(postId)
}
.onSuccess {
youthDatabase.postDao().updatePostScrap(postId, !scrap)
emit(postId)
}
.onFailure {
Timber.e("postCreatePost postPostScrap $it")
throwableError<Long>(it)
}
override suspend fun postPostScrap(postId: Long, scrap: Boolean): Result<Long> = createResult {
communityService.postPostScrap(postId)
youthDatabase.postDao().updatePostScrap(postId, !scrap)
postId
}

override fun syncPostScrap(reviews: List<Post>, frees: List<Post>): Flow<Pair<List<Post>, List<Post>>> = flow {
override suspend fun syncPostScrap(reviews: List<Post>, frees: List<Post>): Result<Pair<List<Post>, List<Post>>> = createResult {
val syncReviews = reviews
.map { post ->
val syncPost = youthDatabase.postDao().getPost(post.postId)?.copy(postType = post.postType)
Expand All @@ -204,66 +151,44 @@ class CommunityRepositoryImpl @Inject constructor(
val syncFrees = frees
.map { post -> youthDatabase.postDao().getPost(post.postId)?.copy(postType = post.postType) ?: post }

emit(Pair(syncReviews, syncFrees))
Pair(syncReviews, syncFrees)
}

@OptIn(ExperimentalPagingApi::class)
override fun getSettingPosts(isScrapType: Boolean): Flow<Flow<PagingData<Post>>> = flow {
emit(
Pager(
config = PagingConfig(
pageSize = 10,
enablePlaceholders = true
),
remoteMediator = MyPageRemoteMediator(
communityService = communityService,
postType = PostType.MY_PAGE,
youthDatabase = youthDatabase,
isScrap = isScrapType
)
) {
if (isScrapType) {
youthDatabase.postDao().getScrapPagingSource(postType = PostType.MY_PAGE)
} else {
youthDatabase.postDao().getPagingSource(postType = PostType.MY_PAGE)
}
}.flow
)
}

override fun getSettingPostCount(isScrapType: Boolean): Flow<Int> = flow {
runCatching {
override fun getSettingPosts(isScrapType: Boolean): Flow<PagingData<Post>> {
Comment thread
hegunhee marked this conversation as resolved.
return Pager(
config = PagingConfig(
pageSize = 10,
enablePlaceholders = true
),
remoteMediator = MyPageRemoteMediator(
communityService = communityService,
postType = PostType.MY_PAGE,
youthDatabase = youthDatabase,
isScrap = isScrapType
)
) {
if (isScrapType) {
communityService.getScrapPosts(0, 1)
youthDatabase.postDao().getScrapPagingSource(postType = PostType.MY_PAGE)
} else {
communityService.getMyPosts(0, 1)
}
}
.onSuccess { response ->
response.data?.let {
emit(it.total)
}
}
.onFailure {
Timber.e("CommunityRepositoryImpl getSettingPostCount $it")
throwableError<Int>(it)
youthDatabase.postDao().getPagingSource(postType = PostType.MY_PAGE)
}
}.flow
}

override suspend fun getSettingPostCount(isScrapType: Boolean): Result<Int> = createResult {
if (isScrapType) {
communityService.getScrapPosts(0, 1)
} else {
communityService.getMyPosts(0, 1)
}.data?.total ?: throw NoDataException()
}

override fun postModifyPost(postId: Long, modifyPost: ModifyPost): Flow<Long> = flow {
override suspend fun postModifyPost(postId: Long, modifyPost: ModifyPost): Result<Long> = createResult {
val requestBody = modifyPost.toData().toRequestBody()
runCatching {
communityService.postModifyPost(postId, requestBody)
}
.onSuccess { response ->
response.data?.let { postDetail ->
youthDatabase.postDao().updateModifyPost(postId, postDetail.title, postDetail.contentList[0].content.split("\n").first())
emit(postDetail.postId)
}
}
.onFailure {
Timber.e("CommunityRepositoryImpl postModifyPost error $it")
throwableError<Int>(it)
}

val postDetail = communityService.postModifyPost(postId, requestBody).data ?: throw NoDataException()
youthDatabase.postDao().updateModifyPost(postId, postDetail.title, postDetail.contentList[0].content.split("\n").first())
postDetail.postId
}
}
Loading