[#20] Add test: clear cache data

Author: luongvo

shared/src/commonMain/kotlin/vn/luongvo/kmm/survey/data/local/datasource/SurveyLocalDataSource.kt

@@ -11,7 +11,7 @@ interface SurveyLocalDataSource {
 
     fun getSurveys(): List<SurveyRealmObject>
 
-    fun deleteAllSurveys()
+    fun clear()
 }
 
 class SurveyLocalDataSourceImpl(private val realm: Realm) : SurveyLocalDataSource {
@@ -28,7 +28,7 @@ class SurveyLocalDataSourceImpl(private val realm: Realm) : SurveyLocalDataSourc
         return realm.query<SurveyRealmObject>().find()
     }
 
-    override fun deleteAllSurveys() {
+    override fun clear() {
         realm.writeBlocking {
             val surveys = query<SurveyRealmObject>().find()
             delete(surveys)

shared/src/commonMain/kotlin/vn/luongvo/kmm/survey/data/repository/SurveyRepositoryImpl.kt

@@ -17,7 +17,7 @@ class SurveyRepositoryImpl(
 
     override fun getSurveys(pageNumber: Int, pageSize: Int, isRefresh: Boolean): Flow<List<Survey>> = flowTransform {
         if (isRefresh) {
-            surveyLocalDataSource.deleteAllSurveys()
+            surveyLocalDataSource.clear()
         }
 
         val surveys = surveyRemoteDataSource

shared/src/commonTest/kotlin/vn/luongvo/kmm/survey/data/repository/SurveyRepositoryTest.kt

@@ -55,6 +55,23 @@ class SurveyRepositoryTest {
         }
     }
 
+    @Test
+    fun `when calling getSurveys with isRefresh = true - it clears the cache`() = runTest {
+        given(mockRemoteDataSource)
+            .suspendFunction(mockRemoteDataSource::getSurveys)
+            .whenInvokedWith(any(), any())
+            .thenReturn(surveyResponses)
+
+        repository.getSurveys(pageNumber = 1, pageSize = 10, isRefresh = true).test {
+            awaitItem() shouldBe surveys
+            awaitComplete()
+
+            verify(mockLocalDataSource)
+                .function(mockLocalDataSource::clear)
+                .wasInvoked(exactly = 1.time)
+        }
+    }
+
     @Test
     fun `when calling getSurveys fails - it does not cache and throws the corresponding error`() = runTest {
         val throwable = Throwable()