Removing CountryLocalDataSource

data/countries/src/main/java/com/toquete/boxbox/data/countries/repository/DefaultCountryRepository.kt

@@ -1,24 +1,24 @@
 package com.toquete.boxbox.data.countries.repository
 
 import com.toquete.boxbox.core.common.annotation.IoDispatcher
+import com.toquete.boxbox.core.database.dao.CountryDao
 import com.toquete.boxbox.core.network.model.CountryResponse
 import com.toquete.boxbox.data.countries.model.toEntity
-import com.toquete.boxbox.data.countries.source.local.CountryLocalDataSource
 import com.toquete.boxbox.data.countries.source.remote.CountryRemoteDataSource
 import kotlinx.coroutines.withContext
 import javax.inject.Inject
 import kotlin.coroutines.CoroutineContext
 
 internal class DefaultCountryRepository @Inject constructor(
     private val remoteDataSource: CountryRemoteDataSource,
-    private val localDataSource: CountryLocalDataSource,
+    private val countryDao: CountryDao,
     @IoDispatcher private val dispatcher: CoroutineContext
 ) : CountryRepository {
 
     override suspend fun sync() {
         withContext(dispatcher) {
             val list = remoteDataSource.getCountries()
-            localDataSource.insertAll(list.map(CountryResponse::toEntity))
+            countryDao.upsertAll(list.map(CountryResponse::toEntity))
         }
     }
 }

data/countries/src/test/java/com/toquete/boxbox/data/countries/repository/DefaultCountryRepositoryTest.kt

@@ -1,8 +1,8 @@
 package com.toquete.boxbox.data.countries.repository
 
+import com.toquete.boxbox.core.database.dao.CountryDao
 import com.toquete.boxbox.core.testing.data.countryEntities
 import com.toquete.boxbox.core.testing.data.countryResponses
-import com.toquete.boxbox.data.countries.source.local.CountryLocalDataSource
 import com.toquete.boxbox.data.countries.source.remote.CountryRemoteDataSource
 import io.mockk.coEvery
 import io.mockk.coVerify
@@ -15,20 +15,20 @@ import java.io.IOException
 class DefaultCountryRepositoryTest {
 
     private val remoteDataSource: CountryRemoteDataSource = mockk(relaxed = true)
-    private val localDataSource: CountryLocalDataSource = mockk(relaxed = true)
+    private val countryDao: CountryDao = mockk(relaxed = true)
     private val testDispatcher = UnconfinedTestDispatcher()
-    private val repository = DefaultCountryRepository(remoteDataSource, localDataSource, testDispatcher)
+    private val repository = DefaultCountryRepository(remoteDataSource, countryDao, testDispatcher)
 
     @Test
     fun `sync should insert data in database when remote data is gotten successfully`() = runTest {
         coEvery { remoteDataSource.getCountries() } returns countryResponses
-        coEvery { localDataSource.insertAll(any()) } returns Unit
+        coEvery { countryDao.upsertAll(any()) } returns Unit
 
         repository.sync()
 
         coVerify {
             remoteDataSource.getCountries()
-            localDataSource.insertAll(countryEntities)
+            countryDao.upsertAll(countryEntities)
         }
     }
 
@@ -38,6 +38,6 @@ class DefaultCountryRepositoryTest {
 
         repository.sync()
 
-        coVerify(exactly = 0) { localDataSource.insertAll(any()) }
+        coVerify(exactly = 0) { countryDao.upsertAll(any()) }
     }
 }