Change something

Core/build.gradle

@@ -8,6 +8,13 @@ java {
     targetCompatibility = JavaVersion.VERSION_1_7
 }
 
+compileKotlin {
+    kotlinOptions {
+        freeCompilerArgs = ["-Xallow-result-return-type"]
+    }
+}
+
 dependencies {
     implementation "org.jetbrains.kotlin:kotlin-stdlib:$kotlin_version"
+    implementation "org.jetbrains.kotlinx:kotlinx-coroutines-core:1.4.1"
 }

Core/src/main/java/com/mychefassistant/core/data/datasource/GroceryDataSource.kt

@@ -0,0 +1,15 @@
+package com.mychefassistant.core.data.datasource
+
+import com.mychefassistant.core.domain.Grocery
+import com.mychefassistant.core.domain.Kitchen
+import kotlinx.coroutines.flow.Flow
+
+interface GroceryDataSource {
+    suspend fun add(kitchen: Kitchen, grocery: Grocery)
+
+    fun getAll(kitchen: Kitchen): Flow<List<Grocery>>
+
+    suspend fun remove(kitchen: Kitchen, grocery: Grocery)
+
+    suspend fun update(kitchen: Kitchen, grocery: Grocery)
+}

Core/src/main/java/com/mychefassistant/core/data/datasource/KitchenDataSource.kt

@@ -1,6 +1,7 @@
 package com.mychefassistant.core.data.datasource
 
 import com.mychefassistant.core.domain.Kitchen
+import kotlinx.coroutines.flow.Flow
 
 interface KitchenDataSource {
     suspend fun add(kitchen: Kitchen)
@@ -9,7 +10,9 @@ interface KitchenDataSource {
 
     suspend fun update(kitchen: Kitchen)
 
-    suspend fun getAll(): List<Kitchen>
+    fun getAll(): Flow<List<Kitchen>>
 
     suspend fun getById(id: Int): Kitchen
+
+    suspend fun find(kitchen: Kitchen): List<Kitchen>
 }

Core/src/main/java/com/mychefassistant/core/data/repository/GroceryRepository.kt

@@ -0,0 +1,17 @@
+package com.mychefassistant.core.data.repository
+
+import com.mychefassistant.core.data.datasource.GroceryDataSource
+import com.mychefassistant.core.domain.Grocery
+import com.mychefassistant.core.domain.Kitchen
+
+class GroceryRepository(private val dataSource: GroceryDataSource) {
+    suspend fun addGrocery(kitchen: Kitchen, grocery: Grocery) = dataSource.add(kitchen, grocery)
+
+    fun getGroceries(kitchen: Kitchen) = dataSource.getAll(kitchen)
+
+    suspend fun removeGrocery(kitchen: Kitchen, grocery: Grocery) =
+        dataSource.remove(kitchen, grocery)
+
+    suspend fun updateGrocery(kitchen: Kitchen, grocery: Grocery) =
+        dataSource.update(kitchen, grocery)
+}

Core/src/main/java/com/mychefassistant/core/data/repository/KitchenRepository.kt

@@ -10,7 +10,9 @@ class KitchenRepository(private val dataSource: KitchenDataSource) {
 
     suspend fun updateKitchen(kitchen: Kitchen) = dataSource.update(kitchen)
 
-    suspend fun getKitchens() = dataSource.getAll()
+    fun getKitchens() = dataSource.getAll()
 
     suspend fun getKitchenById(id: Int) = dataSource.getById(id)
+
+    suspend fun findKitchen(kitchen: Kitchen) = dataSource.find(kitchen)
 }

Core/src/main/java/com/mychefassistant/core/domain/Grocery.kt

@@ -0,0 +1,9 @@
+package com.mychefassistant.core.domain
+
+data class Grocery(
+    val id: Int = 0,
+    val kitchen: Int,
+    val title: String,
+    val value: String = "",
+    val status: Boolean = false
+)

Core/src/main/java/com/mychefassistant/core/interactors/AddGroceryUseCase.kt

@@ -0,0 +1,13 @@
+package com.mychefassistant.core.interactors
+
+import com.mychefassistant.core.data.repository.GroceryRepository
+import com.mychefassistant.core.domain.Grocery
+import com.mychefassistant.core.domain.Kitchen
+import com.mychefassistant.core.utils.BaseSuspendUseCase
+
+class AddGroceryUseCase(private val groceryRepository: GroceryRepository) :
+    BaseSuspendUseCase<Pair<Kitchen, Grocery>, Unit>() {
+    override suspend fun execute(parameter: Pair<Kitchen, Grocery>): Result<Unit> {
+        return Result.success(groceryRepository.addGrocery(parameter.first, parameter.second))
+    }
+}

Core/src/main/java/com/mychefassistant/core/interactors/AddKitchenUseCase.kt

@@ -0,0 +1,12 @@
+package com.mychefassistant.core.interactors
+
+import com.mychefassistant.core.data.repository.KitchenRepository
+import com.mychefassistant.core.domain.Kitchen
+import com.mychefassistant.core.utils.BaseSuspendUseCase
+
+class AddKitchenUseCase(private val kitchenRepository: KitchenRepository) :
+    BaseSuspendUseCase<Kitchen, Unit>() {
+    override suspend fun execute(parameter: Kitchen): Result<Unit> {
+        return Result.success(kitchenRepository.addKitchen(parameter))
+    }
+}

Core/src/main/java/com/mychefassistant/core/interactors/FindKitchenUseCase.kt

@@ -0,0 +1,12 @@
+package com.mychefassistant.core.interactors
+
+import com.mychefassistant.core.data.repository.KitchenRepository
+import com.mychefassistant.core.domain.Kitchen
+import com.mychefassistant.core.utils.BaseSuspendUseCase
+
+class FindKitchenUseCase(private val kitchenRepository: KitchenRepository) :
+    BaseSuspendUseCase<Kitchen, List<Kitchen>>() {
+    override suspend fun execute(parameter: Kitchen): Result<List<Kitchen>> {
+        return Result.success(kitchenRepository.findKitchen(parameter))
+    }
+}

Core/src/main/java/com/mychefassistant/core/interactors/GetGroceriesUseCase.kt

@@ -0,0 +1,14 @@
+package com.mychefassistant.core.interactors
+
+import com.mychefassistant.core.data.repository.GroceryRepository
+import com.mychefassistant.core.domain.Grocery
+import com.mychefassistant.core.domain.Kitchen
+import com.mychefassistant.core.utils.BaseSuspendUseCase
+import kotlinx.coroutines.flow.Flow
+
+class GetGroceriesUseCase(private val groceryRepository: GroceryRepository) :
+    BaseSuspendUseCase<Kitchen, Flow<List<Grocery>>>() {
+    override suspend fun execute(parameter: Kitchen): Result<Flow<List<Grocery>>> {
+        return Result.success(groceryRepository.getGroceries(parameter))
+    }
+}

Core/src/main/java/com/mychefassistant/core/interactors/GetKitchenByIdUseCase.kt

@@ -0,0 +1,12 @@
+package com.mychefassistant.core.interactors
+
+import com.mychefassistant.core.data.repository.KitchenRepository
+import com.mychefassistant.core.domain.Kitchen
+import com.mychefassistant.core.utils.BaseSuspendUseCase
+
+class GetKitchenByIdUseCase(private val kitchenRepository: KitchenRepository) :
+    BaseSuspendUseCase<Int, Kitchen>() {
+    override suspend fun execute(parameter: Int): Result<Kitchen> {
+        return Result.success(kitchenRepository.getKitchenById(parameter))
+    }
+}

Core/src/main/java/com/mychefassistant/core/interactors/GetKitchensUseCase.kt

@@ -0,0 +1,13 @@
+package com.mychefassistant.core.interactors
+
+import com.mychefassistant.core.data.repository.KitchenRepository
+import com.mychefassistant.core.domain.Kitchen
+import com.mychefassistant.core.utils.BaseUseCase
+import kotlinx.coroutines.flow.Flow
+
+class GetKitchensUseCase(private val kitchenRepository: KitchenRepository) :
+    BaseUseCase<Boolean, Flow<List<Kitchen>>>() {
+    override fun execute(parameter: Boolean): Result<Flow<List<Kitchen>>> {
+        return Result.success(kitchenRepository.getKitchens())
+    }
+}

Core/src/main/java/com/mychefassistant/core/interactors/RemoveGroceryUseCase.kt

@@ -0,0 +1,13 @@
+package com.mychefassistant.core.interactors
+
+import com.mychefassistant.core.data.repository.GroceryRepository
+import com.mychefassistant.core.domain.Grocery
+import com.mychefassistant.core.domain.Kitchen
+import com.mychefassistant.core.utils.BaseSuspendUseCase
+
+class RemoveGroceryUseCase(private val groceryRepository: GroceryRepository) :
+    BaseSuspendUseCase<Pair<Kitchen, Grocery>, Unit>() {
+    override suspend fun execute(parameter: Pair<Kitchen, Grocery>): Result<Unit> {
+        return Result.success(groceryRepository.removeGrocery(parameter.first, parameter.second))
+    }
+}

Core/src/main/java/com/mychefassistant/core/interactors/RemoveKitchenUseCase.kt

@@ -0,0 +1,12 @@
+package com.mychefassistant.core.interactors
+
+import com.mychefassistant.core.data.repository.KitchenRepository
+import com.mychefassistant.core.domain.Kitchen
+import com.mychefassistant.core.utils.BaseSuspendUseCase
+
+class RemoveKitchenUseCase(private val kitchenRepository: KitchenRepository) :
+    BaseSuspendUseCase<Kitchen, Unit>() {
+    override suspend fun execute(parameter: Kitchen): Result<Unit> {
+        return Result.success(kitchenRepository.removeKitchen(parameter))
+    }
+}

Core/src/main/java/com/mychefassistant/core/interactors/UpdateGroceryUseCase.kt

@@ -0,0 +1,13 @@
+package com.mychefassistant.core.interactors
+
+import com.mychefassistant.core.data.repository.GroceryRepository
+import com.mychefassistant.core.domain.Grocery
+import com.mychefassistant.core.domain.Kitchen
+import com.mychefassistant.core.utils.BaseSuspendUseCase
+
+class UpdateGroceryUseCase(private val groceryRepository: GroceryRepository) :
+    BaseSuspendUseCase<Pair<Kitchen, Grocery>, Unit>() {
+    override suspend fun execute(parameter: Pair<Kitchen, Grocery>): Result<Unit> {
+        return Result.success(groceryRepository.updateGrocery(parameter.first, parameter.second))
+    }
+}

Core/src/main/java/com/mychefassistant/core/interactors/UpdateKitchenUseCase.kt

@@ -0,0 +1,12 @@
+package com.mychefassistant.core.interactors
+
+import com.mychefassistant.core.data.repository.KitchenRepository
+import com.mychefassistant.core.domain.Kitchen
+import com.mychefassistant.core.utils.BaseSuspendUseCase
+
+class UpdateKitchenUseCase(private val kitchenRepository: KitchenRepository) :
+    BaseSuspendUseCase<Kitchen, Unit>() {
+    override suspend fun execute(parameter: Kitchen): Result<Unit> {
+        return Result.success(kitchenRepository.updateKitchen(parameter))
+    }
+}

Core/src/main/java/com/mychefassistant/core/utils/BaseSuspendUseCase.kt

@@ -0,0 +1,12 @@
+package com.mychefassistant.core.utils
+
+abstract class BaseSuspendUseCase<in Request, Response> {
+    suspend operator fun invoke(parameter: Request): Result<Response> = try {
+        execute(parameter)
+    } catch (e: Exception) {
+        Result.failure(e)
+    }
+
+    @Throws(RuntimeException::class)
+    protected abstract suspend fun execute(parameter: Request): Result<Response>
+}