- updates to LocalSource interface and implementations

Author: coderwise

Diff for: core-data/src/commonMain/kotlin/com/coderwise/core/data/arch/DataStoreLocalSource.kt

@@ -3,6 +3,7 @@ package com.coderwise.core.data.arch
 import androidx.datastore.core.DataStore
 import com.coderwise.core.domain.arch.Outcome
 import com.coderwise.core.domain.arch.dataOrNull
+import com.coderwise.core.domain.arch.tryOutcome
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.first
 import kotlinx.coroutines.flow.map
@@ -32,11 +33,15 @@ open class DataStoreLocalSource<Entity, Id, Record : Any>(
                 ?: throw NoSuchElementException()
 
             emit(Outcome.Success(entity))
-        } catch (_: NoSuchElementException) {
-            // NOOP Outcome.Error(NoSuchElementException())
+        } catch (e: NoSuchElementException) {
+            emit(Outcome.Error(e))
         }
     }
 
+    override suspend fun findById(id: Id): Outcome<Entity> = tryOutcome {
+        dataStore.data.first().list.findById(id, identify, recordToEntity)!!
+    }
+    
     override suspend fun update(entity: Entity): Outcome<Id> {
         val entityId = identify(entity)
         dataStore.updateData { data ->

Diff for: core-data/src/commonMain/kotlin/com/coderwise/core/data/arch/LocalSource.kt

@@ -6,10 +6,11 @@ import kotlinx.coroutines.flow.Flow
 interface LocalSource<Entity, Id> {
     val flow: Flow<Outcome<List<Entity>>>
     fun flowById(id: Id): Flow<Outcome<Entity>>
+    suspend fun findById(id: Id): Outcome<Entity>
     suspend fun update(entity: Entity): Outcome<Id>
     suspend fun delete(id: Id): Outcome<Unit>
     suspend fun merge(list: List<Entity>): Outcome<Unit>
     suspend fun reset(list: List<Entity>): Outcome<Unit>
     suspend fun isEmpty(): Boolean
-    suspend fun clear(): Outcome<Unit> = merge(emptyList())
+    suspend fun clear(): Outcome<Unit> = reset(emptyList())
 }

Diff for: core-data/src/commonMain/kotlin/com/coderwise/core/data/arch/MemoryLocalSource.kt

@@ -2,6 +2,7 @@ package com.coderwise.core.data.arch
 
 import com.coderwise.core.data.utils.MemCache
 import com.coderwise.core.domain.arch.Outcome
+import com.coderwise.core.domain.arch.tryOutcome
 import kotlinx.coroutines.flow.Flow
 import kotlinx.coroutines.flow.map
 import kotlinx.coroutines.flow.transform
@@ -25,6 +26,8 @@ open class MemoryLocalSource<Entity, Id>(
         emit(Outcome.Success(it))
     }
 
+    override suspend fun findById(id: Id): Outcome<Entity> = tryOutcome { memCache.find(id)!! }
+
     override suspend fun delete(id: Id): Outcome<Unit> {
         memCache.delete(id)
         return Outcome.Success(Unit)