#14 #4 #5 데이터베이스 싱크 처리 기능

f-lab-edu · Dec 9, 2024 · 8dd5e51 · 8dd5e51
1 parent 43c92b5
commit 8dd5e51
Show file tree

Hide file tree

Showing 8 changed files with 48 additions and 7 deletions.
diff --git a/data/src/main/java/ny/photomap/data/datasource/PhotoDataSource.kt b/data/src/main/java/ny/photomap/data/datasource/PhotoDataSource.kt
@@ -13,6 +13,10 @@ interface PhotoDataSource {
 
     suspend fun getLatestFetchTime(): Result<Long>
 
+    suspend fun saveAllPhotoLocation(list: List<PhotoLocationEntity>) : Result<Unit>
+
+    suspend fun deleteAllPhotoLocation() : Result<Unit>
+
     suspend fun getPhotoLocation(
         latitude: Double,
         longitude: Double,

diff --git a/data/src/main/java/ny/photomap/data/datasource/PhotoDataSourceImpl.kt b/data/src/main/java/ny/photomap/data/datasource/PhotoDataSourceImpl.kt
@@ -140,6 +140,18 @@ class PhotoDataSourceImpl @Inject constructor(
         }
     }
 
+    override suspend fun saveAllPhotoLocation(list: List<PhotoLocationEntity>): Result<Unit> {
+        return runCatching {
+            photoLocationDao.insertAll(list)
+        }
+    }
+
+    override suspend fun deleteAllPhotoLocation(): Result<Unit> {
+        return runCatching {
+            photoLocationDao.deleteAll()
+        }
+    }
+
     override suspend fun getPhotoLocation(
         latitude: Double,
         longitude: Double,

diff --git a/data/src/main/java/ny/photomap/data/db/PhotoLocationDao.kt b/data/src/main/java/ny/photomap/data/db/PhotoLocationDao.kt
@@ -60,7 +60,7 @@ interface PhotoLocationDao {
     @Delete
     suspend fun delete(entity: PhotoLocationEntity)
 
-    @Delete
-    suspend fun deleteAll(entityList: List<PhotoLocationEntity>)
+    @Query("DELETE FROM photo_location_table")
+    suspend fun deleteAll()
 
 }
diff --git a/data/src/main/java/ny/photomap/data/db/PhotoLocationEntity.kt b/data/src/main/java/ny/photomap/data/db/PhotoLocationEntity.kt
@@ -15,18 +15,28 @@ data class PhotoLocationEntity(
     val generatedTime: Long,
     val addedTime: Long,
     @ColumnInfo(typeAffinity = ColumnInfo.BLOB)
-    val thumbNail: ByteArray?
+    val thumbNail: ByteArray?,
 ) : ModelMapper<PhotoLocationModel> {
     @PrimaryKey(autoGenerate = true)
     var id: Long = 0
 
     override fun toModel(): PhotoLocationModel = PhotoLocationModel(
-        uriString = uri.toString(),
+        uri = uri,
         name = name,
         latitude = latitude,
         longitude = longitude,
         generatedTimeMillis = generatedTime,
         addedTimeMillis = addedTime,
         thumbNail = thumbNail
     )
-}
+}
+
+fun PhotoLocationModel.toEntity(): PhotoLocationEntity = PhotoLocationEntity(
+    uri = uri,
+    name = name,
+    latitude = latitude,
+    longitude = longitude,
+    generatedTime = generatedTimeMillis,
+    addedTime = addedTimeMillis,
+    thumbNail = thumbNail
+)
diff --git a/data/src/main/java/ny/photomap/data/model/PhotoLocationData.kt b/data/src/main/java/ny/photomap/data/model/PhotoLocationData.kt
@@ -13,7 +13,7 @@ data class PhotoLocationData(
     val thumbNail: ByteArray?,
 ) : ModelMapper<PhotoLocationModel> {
     override fun toModel(): PhotoLocationModel = PhotoLocationModel(
-        uriString = uri.toString(),
+        uri = this@PhotoLocationData.uri.toString(),
         name = name,
         latitude = latitude,
         longitude = longitude,

diff --git a/data/src/main/java/ny/photomap/data/repository/PhotoRepositoryImpl.kt b/data/src/main/java/ny/photomap/data/repository/PhotoRepositoryImpl.kt
@@ -2,6 +2,7 @@ package ny.photomap.data.repository
 
 import ny.photomap.data.datasource.PhotoDataSource
 import ny.photomap.data.db.PhotoLocationEntity
+import ny.photomap.data.db.toEntity
 import ny.photomap.data.model.PhotoLocationData
 import ny.photomap.domain.PhotoRepository
 import ny.photomap.domain.model.PhotoLocationModel
@@ -30,6 +31,16 @@ class PhotoRepositoryImpl @Inject constructor(private val dataSource: PhotoDataS
     override suspend fun getLatestFetchTime(): Result<Long> =
         dataSource.getLatestFetchTime()
 
+    override suspend fun saveAllPhotoLocation(list: List<PhotoLocationModel>): Result<Unit> {
+        return runCatching {
+            dataSource.saveAllPhotoLocation(
+                list.map(PhotoLocationModel::toEntity)
+            )
+        }
+    }
+
+    override suspend fun deleteAllPhotoLocation(): Result<Unit> =
+        dataSource.deleteAllPhotoLocation()
 
     override suspend fun getPhotoLocation(
         latitude: Double,

diff --git a/domain/src/main/java/ny/photomap/domain/PhotoRepository.kt b/domain/src/main/java/ny/photomap/domain/PhotoRepository.kt
@@ -12,6 +12,10 @@ interface PhotoRepository {
 
     suspend fun getLatestFetchTime(): Result<Long>
 
+    suspend fun saveAllPhotoLocation(list: List<PhotoLocationModel>) : Result<Unit>
+
+    suspend fun deleteAllPhotoLocation() : Result<Unit>
+
     suspend fun getPhotoLocation(
         latitude: Double,
         longitude: Double,

diff --git a/domain/src/main/java/ny/photomap/domain/model/PhotoLocationModel.kt b/domain/src/main/java/ny/photomap/domain/model/PhotoLocationModel.kt
@@ -1,7 +1,7 @@
 package ny.photomap.domain.model
 
 data class PhotoLocationModel(
-    val uriString: String,
+    val uri: String,
     val name: String?,
     val latitude: Double,
     val longitude: Double,