#183 state remastering

mvvm-state-core/build.gradle.kts

@@ -0,0 +1,9 @@
+/*
+ * Copyright 2019 IceRock MAG Inc. Use of this source code is governed by the Apache 2.0 license.
+ */
+
+plugins {
+    id("kmp-library-convention")
+    id("detekt-convention")
+    id("publication-convention")
+}

mvvm-state-core/src/androidMain/AndroidManifest.xml

@@ -0,0 +1,2 @@
+<?xml version="1.0" encoding="utf-8"?>
+<manifest package="dev.icerock.moko.mvvm.state.core" />

mvvm-state-core/src/commonMain/kotlin/dev/icerock/moko/mvvm/StateExt.kt

@@ -0,0 +1,56 @@
+/*
+ * Copyright 2022 IceRock MAG Inc. Use of this source code is governed by the Apache 2.0 license.
+ */
+
+package dev.icerock.moko.mvvm
+
+import dev.icerock.moko.mvvm.state.ResourceState
+import dev.icerock.moko.mvvm.state.asState
+import dev.icerock.moko.mvvm.state.nullAsEmpty
+import dev.icerock.moko.mvvm.state.nullAsLoading
+
+@Deprecated(
+    message = "deprecated due to package renaming",
+    replaceWith = ReplaceWith("asState", "dev.icerock.moko.mvvm.state"),
+    level = DeprecationLevel.WARNING
+)
+fun <T, E> T.asState(): ResourceState<T, E> = this.asState()
+
+@Deprecated(
+    message = "deprecated due to package renaming",
+    replaceWith = ReplaceWith("asState", "dev.icerock.moko.mvvm.state"),
+    level = DeprecationLevel.WARNING
+)
+fun <T, E> T?.asState(whenNull: () -> ResourceState<T, E>): ResourceState<T, E> =
+    this.asState(whenNull)
+
+@Deprecated(
+    message = "deprecated due to package renaming",
+    replaceWith = ReplaceWith("asState", "dev.icerock.moko.mvvm.state"),
+    level = DeprecationLevel.WARNING
+)
+fun <T, E> List<T>.asState(): ResourceState<List<T>, E> = this.asState()
+
+@Deprecated(
+    message = "deprecated due to package renaming",
+    replaceWith = ReplaceWith("asState", "dev.icerock.moko.mvvm.state"),
+    level = DeprecationLevel.WARNING
+)
+fun <T, E> List<T>?.asState(whenNull: () -> ResourceState<List<T>, E>): ResourceState<List<T>, E> =
+    this.asState(whenNull)
+
+@Deprecated(
+    message = "deprecated due to package renaming",
+    replaceWith = ReplaceWith("nullAsEmpty", "dev.icerock.moko.mvvm.state"),
+    level = DeprecationLevel.WARNING
+)
+inline fun <reified T, reified E> ResourceState<T, E>?.nullAsEmpty(): ResourceState<T, E> =
+    this.nullAsEmpty()
+
+@Deprecated(
+    message = "deprecated due to package renaming",
+    replaceWith = ReplaceWith("nullAsLoading", "dev.icerock.moko.mvvm.state"),
+    level = DeprecationLevel.WARNING
+)
+inline fun <reified T, reified E> ResourceState<T, E>?.nullAsLoading(): ResourceState<T, E> =
+    this.nullAsLoading()

mvvm-state/src/commonMain/kotlin/dev/icerock/moko/mvvm/ResourceState.kt → mvvm-state-core/src/commonMain/kotlin/dev/icerock/moko/mvvm/state/ResourceState.kt

@@ -1,8 +1,8 @@
 /*
- * Copyright 2019 IceRock MAG Inc. Use of this source code is governed by the Apache 2.0 license.
+ * Copyright 2022 IceRock MAG Inc. Use of this source code is governed by the Apache 2.0 license.
  */
 
-package dev.icerock.moko.mvvm
+package dev.icerock.moko.mvvm.state
 
 sealed class ResourceState<out T, out E> {
     data class Success<out T, out E>(val data: T) : ResourceState<T, E>()

mvvm-state/src/commonMain/kotlin/dev/icerock/moko/mvvm/StateExt.kt → mvvm-state-core/src/commonMain/kotlin/dev/icerock/moko/mvvm/state/StateExt.kt

@@ -1,8 +1,8 @@
 /*
- * Copyright 2019 IceRock MAG Inc. Use of this source code is governed by the Apache 2.0 license.
+ * Copyright 2022 IceRock MAG Inc. Use of this source code is governed by the Apache 2.0 license.
  */
 
-package dev.icerock.moko.mvvm
+package dev.icerock.moko.mvvm.state
 
 fun <T, E> T.asState(): ResourceState<T, E> =
     ResourceState.Success(this)

mvvm-state-flow/build.gradle.kts

@@ -0,0 +1,19 @@
+/*
+ * Copyright 2019 IceRock MAG Inc. Use of this source code is governed by the Apache 2.0 license.
+ */
+
+plugins {
+    id("kmp-library-convention")
+    id("detekt-convention")
+    id("publication-convention")
+}
+
+dependencies {
+    commonMainApi(projects.mvvmStateCore)
+
+    commonMainApi(libs.coroutines)
+
+    commonTestApi(libs.mokoTest)
+    commonTestApi(libs.coroutines)
+    commonTestApi(projects.mvvmTest)
+}

mvvm-state-flow/src/androidMain/AndroidManifest.xml

@@ -0,0 +1,2 @@
+<?xml version="1.0" encoding="utf-8"?>
+<manifest package="dev.icerock.moko.mvvm.state.flow" />

mvvm-state-flow/src/commonMain/kotlin/dev/icerock/moko/mvvm/state/flow/StateLiveDataConditions.kt

@@ -0,0 +1,38 @@
+/*
+ * Copyright 2021 IceRock MAG Inc. Use of this source code is governed by the Apache 2.0 license.
+ */
+
+package dev.icerock.moko.mvvm.state.flow
+
+import dev.icerock.moko.mvvm.state.ResourceState
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.combine
+import kotlinx.coroutines.flow.map
+
+fun <T, E> Flow<ResourceState<T, E>>.isSuccessState(): Flow<Boolean> = map { it.isSuccess() }
+
+fun <T, E> Flow<ResourceState<T, E>>.isLoadingState(): Flow<Boolean> = map { it.isLoading() }
+
+fun <T, E> Flow<ResourceState<T, E>>.isErrorState(): Flow<Boolean> = map { it.isFailed() }
+
+fun <T, E> Flow<ResourceState<T, E>>.isEmptyState(): Flow<Boolean> = map { it.isEmpty() }
+
+inline fun <T, E, reified ST : ResourceState<T, E>, FL : Flow<ST>> List<FL>.isSuccessState(): Flow<Boolean> =
+    combine(this) { list ->
+        list.firstOrNull { it !is ResourceState.Success<*, *> } == null
+    }
+
+inline fun <T, E, reified ST : ResourceState<T, E>, FL : Flow<ST>> List<FL>.isLoadingState(): Flow<Boolean> =
+    combine(this) { list ->
+        list.firstOrNull() { it is ResourceState.Loading<*, *> } != null
+    }
+
+inline fun <T, E, reified ST : ResourceState<T, E>, FL : Flow<ST>> List<FL>.isErrorState(): Flow<Boolean> =
+    combine(this) { list ->
+        list.firstOrNull { it is ResourceState.Failed<*, *> } != null
+    }
+
+inline fun <T, E, reified ST : ResourceState<T, E>, FL : Flow<ST>> List<FL>.isEmptyState(): Flow<Boolean> =
+    combine(this) { list ->
+        list.firstOrNull { it is ResourceState.Empty<*, *> } != null
+    }

mvvm-state-flow/src/commonMain/kotlin/dev/icerock/moko/mvvm/state/flow/StateLiveDataExt.kt

@@ -0,0 +1,35 @@
+/*
+ * Copyright 2019 IceRock MAG Inc. Use of this source code is governed by the Apache 2.0 license.
+ */
+
+package dev.icerock.moko.mvvm.state.flow
+
+import dev.icerock.moko.mvvm.state.ResourceState
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.StateFlow
+import kotlinx.coroutines.flow.combine
+import kotlinx.coroutines.flow.lastOrNull
+import kotlinx.coroutines.flow.map
+
+fun <T, E> Flow<ResourceState<T, E>>.data(): Flow<T?> = map { it.dataValue() }
+
+fun <T, E> StateFlow<ResourceState<T, E>>.dataValue(): T? = value.dataValue()
+
+suspend fun <T, E> Flow<ResourceState<T, E>>.dataValue(): T? =
+    lastOrNull()?.dataValue()
+
+fun <T, E> Flow<ResourceState<T, E>>.error(): Flow<E?> = map { it.errorValue() }
+
+fun <T, E> StateFlow<ResourceState<T, E>>.errorValue(): E? = value.errorValue()
+
+suspend fun <T, E> Flow<ResourceState<T, E>>.errorValue(): E? =
+    lastOrNull()?.errorValue()
+
+inline fun <T, E, reified ST : ResourceState<T, E>, FL : Flow<ST>> List<FL>.error(): Flow<E?> =
+    combine(this) { list ->
+        @Suppress("UNCHECKED_CAST")
+        val errorItem = list.firstOrNull {
+            (it is ResourceState.Failed<*, *>)
+        } as? ResourceState.Failed<T, E>
+        errorItem?.error
+    }

mvvm-state-flow/src/commonMain/kotlin/dev/icerock/moko/mvvm/state/flow/StateLiveDataMerges.kt

@@ -0,0 +1,30 @@
+/*
+ * Copyright 2021 IceRock MAG Inc. Use of this source code is governed by the Apache 2.0 license.
+ */
+
+package dev.icerock.moko.mvvm.state.flow
+
+import dev.icerock.moko.mvvm.state.ResourceState
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.combine
+
+fun <T1, E, T2, OT> Flow<ResourceState<T1, E>>.concatData(
+    flow: Flow<ResourceState<T2, E>>,
+    function: (T1, T2) -> OT
+): Flow<ResourceState<OT, E>> = combine(
+    this, flow
+) { firstState, secondState ->
+    when {
+        (firstState is ResourceState.Loading || secondState is ResourceState.Loading) -> ResourceState.Loading()
+        (firstState is ResourceState.Failed) -> ResourceState.Failed(firstState.error)
+        (secondState is ResourceState.Failed) -> ResourceState.Failed(secondState.error)
+        (firstState is ResourceState.Empty || secondState is ResourceState.Empty) -> ResourceState.Empty()
+        (firstState is ResourceState.Success && secondState is ResourceState.Success) -> ResourceState.Success(
+            function(
+                firstState.data,
+                secondState.data
+            )
+        )
+        else -> ResourceState.Empty()
+    }
+}

mvvm-state-flow/src/commonMain/kotlin/dev/icerock/moko/mvvm/state/flow/StateLiveDataTransforms.kt

@@ -0,0 +1,64 @@
+/*
+ * Copyright 2021 IceRock MAG Inc. Use of this source code is governed by the Apache 2.0 license.
+ */
+@file:OptIn(ExperimentalCoroutinesApi::class)
+
+package dev.icerock.moko.mvvm.state.flow
+
+import dev.icerock.moko.mvvm.state.ResourceState
+import kotlinx.coroutines.ExperimentalCoroutinesApi
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.flatMapLatest
+import kotlinx.coroutines.flow.flowOf
+import kotlinx.coroutines.flow.map
+
+fun <IT, E, OT> Flow<ResourceState<IT, E>>.dataTransform(
+    transform: Flow<IT>.() -> Flow<OT>
+): Flow<ResourceState<OT, E>> = flatMapLatest { state ->
+    when (state) {
+        is ResourceState.Success -> transform.invoke(flowOf(state.data))
+            .map { ResourceState.Success(it) }
+        is ResourceState.Empty -> flowOf(ResourceState.Empty())
+        is ResourceState.Failed -> flowOf(ResourceState.Failed(state.error))
+        is ResourceState.Loading -> flowOf(ResourceState.Loading())
+    }
+}
+
+fun <T, IE, OE> Flow<ResourceState<T, IE>>.errorTransform(
+    transform: Flow<IE>.() -> Flow<OE>
+): Flow<ResourceState<T, OE>> = flatMapLatest { state ->
+    when (state) {
+        is ResourceState.Success -> flowOf(ResourceState.Success(state.data))
+        is ResourceState.Loading -> flowOf(ResourceState.Loading())
+        is ResourceState.Empty -> flowOf(ResourceState.Empty())
+        is ResourceState.Failed -> transform.invoke(flowOf(state.error))
+            .map { ResourceState.Failed(it) }
+    }
+}
+
+fun <T, E> Flow<ResourceState<T, E>>.emptyAsError(
+    errorBuilder: () -> E
+): Flow<ResourceState<T, E>> = map {
+    when (it) {
+        is ResourceState.Empty -> ResourceState.Failed(errorBuilder())
+        else -> it
+    }
+}
+
+fun <T, E> Flow<ResourceState<T, E>>.emptyAsData(
+    dataBuilder: () -> T
+): Flow<ResourceState<T, E>> = map {
+    when (it) {
+        is ResourceState.Empty -> ResourceState.Success(dataBuilder())
+        else -> it
+    }
+}
+
+fun <T, E> Flow<ResourceState<T, E>>.emptyIf(
+    emptyPredicate: (T) -> Boolean
+): Flow<ResourceState<T, E>> = map {
+    when {
+        it is ResourceState.Success && emptyPredicate(it.data) -> ResourceState.Empty()
+        else -> it
+    }
+}