Merge pull request #89 from boostcampwm-2022/feature/ui/globe-detail-moment

글로브 안에 모먼트 추가하기 UI 구현

Author: Choe-Ji-Hwan

data/src/main/java/com/wakeup/data/database/dao/GlobeDao.kt

@@ -36,4 +36,7 @@ interface GlobeDao {
 
     @Query("SELECT COUNT(moment_id) FROM moment_globe WHERE globe_id = :globeId")
     suspend fun getMomentCountByGlobe(globeId: Long): Int
+
+    @Query("SELECT * FROM moment WHERE moment_id NOT IN (SELECT moment_id FROM moment_globe WHERE globe_id = :globeId)")
+    fun getMomentsNotInGlobe(globeId: Long): PagingSource<Int, MomentWithGlobesAndPictures>
 }

data/src/main/java/com/wakeup/data/repository/GlobeRepositoryImpl.kt

@@ -13,7 +13,7 @@ import kotlinx.coroutines.flow.map
 import javax.inject.Inject
 
 class GlobeRepositoryImpl @Inject constructor(
-    private val globeLocalDataSource: GlobeLocalDataSource
+    private val globeLocalDataSource: GlobeLocalDataSource,
 ) : GlobeRepository {
 
     override suspend fun createGlobe(globe: Globe) {
@@ -46,4 +46,10 @@ class GlobeRepositoryImpl @Inject constructor(
     override suspend fun getMomentCountByGlobe(globeId: Long): Int {
         return globeLocalDataSource.getMomentCountByGlobe(globeId)
     }
+
+    override fun getMomentsNotInGlobe(globeId: Long): Flow<PagingData<Moment>> {
+        return globeLocalDataSource.getMomentsNotInGlobe(globeId).map { pagingData ->
+            pagingData.map { momentXRefs -> momentXRefs.toDomain() }
+        }
+    }
 }

data/src/main/java/com/wakeup/data/repository/MomentRepositoryImpl.kt

@@ -30,9 +30,7 @@ class MomentRepositoryImpl @Inject constructor(
 
     override fun getAllMoments(query: String): Flow<List<Moment>> =
         momentLocalDataSource.getAllMoments(query).map { momentInfoList ->
-            momentInfoList.map { momentInfo ->
-                momentInfo.toDomain()
-            }
+            momentInfoList.map { momentXRefs -> momentXRefs.toDomain() }
         }
 
     override suspend fun getMoment(id: Long): Moment {

data/src/main/java/com/wakeup/data/source/local/globe/GlobeLocalDataSource.kt

@@ -20,4 +20,6 @@ interface GlobeLocalDataSource {
     suspend fun getFirstMomentByGlobe(globeId: Long): MomentWithGlobesAndPictures?
 
     suspend fun getMomentCountByGlobe(globeId: Long): Int
+
+    fun getMomentsNotInGlobe(globeId: Long): Flow<PagingData<MomentWithGlobesAndPictures>>
 }

data/src/main/java/com/wakeup/data/source/local/globe/GlobeLocalDataSourceImpl.kt

@@ -47,6 +47,19 @@ class GlobeLocalDataSourceImpl @Inject constructor(
         return globeDao.getMomentCountByGlobe(globeId)
     }
 
+
+    override fun getMomentsNotInGlobe(globeId: Long): Flow<PagingData<MomentWithGlobesAndPictures>> =
+        Pager(
+            config = PagingConfig(
+                pageSize = PAGE_SIZE,
+                enablePlaceholders = false,
+                initialLoadSize = PAGE_SIZE,
+            ),
+            pagingSourceFactory = {
+                globeDao.getMomentsNotInGlobe(globeId)
+            }
+        ).flow
+
     companion object {
         const val PAGE_SIZE = 10
     }

data/src/main/java/com/wakeup/data/source/local/moment/MomentLocalDataSourceImpl.kt

@@ -70,6 +70,5 @@ class MomentLocalDataSourceImpl @Inject constructor(
     companion object {
         const val PREFETCH_PAGE = 2
         const val ITEMS_PER_PAGE = 10
-        const val EXIST_INSERT_ERROR_CODE = -1L
     }
 }

data/src/main/java/com/wakeup/data/source/local/picture/PictureLocalDataSourceImpl.kt

@@ -2,7 +2,6 @@ package com.wakeup.data.source.local.picture
 
 import com.wakeup.data.database.dao.PictureDao
 import com.wakeup.data.database.entity.PictureEntity
-import com.wakeup.data.source.local.moment.MomentLocalDataSourceImpl
 import javax.inject.Inject
 
 class PictureLocalDataSourceImpl @Inject constructor(
@@ -11,11 +10,15 @@ class PictureLocalDataSourceImpl @Inject constructor(
     override suspend fun savePictures(pictures: List<PictureEntity>): List<Long> {
         val indexResult = pictureDao.savePictures(pictures).toMutableList()
         indexResult.forEachIndexed { pictureIndex, id ->
-            if (id == MomentLocalDataSourceImpl.EXIST_INSERT_ERROR_CODE) {
+            if (id == EXIST_INSERT_ERROR_CODE) {
                 indexResult[pictureIndex] =
                     pictureDao.getPictureIdByByteArray(pictures[pictureIndex].path)
             }
         }
         return indexResult.toList()
     }
+
+    companion object {
+        const val EXIST_INSERT_ERROR_CODE = -1L
+    }
 }

domain/src/main/java/com/wakeup/domain/repository/GlobeRepository.kt

@@ -20,4 +20,6 @@ interface GlobeRepository {
     suspend fun getFirstMomentByGlobe(globeId: Long): Moment?
 
     suspend fun getMomentCountByGlobe(globeId: Long): Int
+
+    fun getMomentsNotInGlobe(globeId: Long): Flow<PagingData<Moment>>
 }

domain/src/main/java/com/wakeup/domain/usecase/GetAllMomentsUseCase.kt

@@ -0,0 +1,15 @@
+package com.wakeup.domain.usecase
+
+import androidx.paging.PagingData
+import com.wakeup.domain.model.Moment
+import com.wakeup.domain.repository.GlobeRepository
+import kotlinx.coroutines.flow.Flow
+import javax.inject.Inject
+
+class GetMomentsNotInGlobeUseCase @Inject constructor(
+    private val globeRepository: GlobeRepository
+) {
+    operator fun invoke(globeId: Long): Flow<PagingData<Moment>> {
+        return globeRepository.getMomentsNotInGlobe(globeId)
+    }
+}