From d741f748e90fa4370da2b954abb7ef4aa529791e Mon Sep 17 00:00:00 2001
From: Petrus Nguyen Thai Hoc <hoc081098@gmail.com>
Date: Sat, 9 Oct 2021 15:57:34 +0700
Subject: [PATCH 01/14] :mvi-base

---
 .idea/gradle.xml                              |  1 +
 app/build.gradle.kts                          |  2 +-
 core/build.gradle.kts                         |  3 +-
 data/build.gradle.kts                         |  3 +-
 feature-add/build.gradle.kts                  |  3 +-
 feature-main/build.gradle.kts                 |  3 +-
 feature-search/build.gradle.kts               |  3 +-
 mvi-base/.gitignore                           |  1 +
 mvi-base/build.gradle.kts                     | 38 +++++++++++++++++++
 mvi-base/consumer-rules.pro                   |  0
 mvi-base/proguard-rules.pro                   | 21 ++++++++++
 .../mvi_base/ExampleInstrumentedTest.kt       | 24 ++++++++++++
 mvi-base/src/main/AndroidManifest.xml         |  5 +++
 .../hoc/flowmvi/mvi_base/ExampleUnitTest.kt   | 17 +++++++++
 settings.gradle.kts                           |  1 +
 15 files changed, 119 insertions(+), 6 deletions(-)
 create mode 100644 mvi-base/.gitignore
 create mode 100644 mvi-base/build.gradle.kts
 create mode 100644 mvi-base/consumer-rules.pro
 create mode 100644 mvi-base/proguard-rules.pro
 create mode 100644 mvi-base/src/androidTest/java/com/hoc/flowmvi/mvi_base/ExampleInstrumentedTest.kt
 create mode 100644 mvi-base/src/main/AndroidManifest.xml
 create mode 100644 mvi-base/src/test/java/com/hoc/flowmvi/mvi_base/ExampleUnitTest.kt

diff --git a/.idea/gradle.xml b/.idea/gradle.xml
index c22de178..a835ec66 100644
--- a/.idea/gradle.xml
+++ b/.idea/gradle.xml
@@ -19,6 +19,7 @@
             <option value="$PROJECT_DIR$/feature-add" />
             <option value="$PROJECT_DIR$/feature-main" />
             <option value="$PROJECT_DIR$/feature-search" />
+            <option value="$PROJECT_DIR$/mvi-base" />
           </set>
         </option>
         <option name="resolveModulePerSourceSet" value="false" />
diff --git a/app/build.gradle.kts b/app/build.gradle.kts
index 19e762b8..893eed36 100644
--- a/app/build.gradle.kts
+++ b/app/build.gradle.kts
@@ -19,7 +19,7 @@ android {
   }
 
   buildTypes {
-    getByName("release") {
+    release {
       isMinifyEnabled = true
       isShrinkResources = true
       proguardFiles(
diff --git a/core/build.gradle.kts b/core/build.gradle.kts
index d15aa08f..25ef57b0 100644
--- a/core/build.gradle.kts
+++ b/core/build.gradle.kts
@@ -12,10 +12,11 @@ android {
     targetSdk = appConfig.targetSdkVersion
 
     testInstrumentationRunner = "androidx.test.runner.AndroidJUnitRunner"
+    consumerProguardFiles("consumer-rules.pro")
   }
 
   buildTypes {
-    getByName("release") {
+    release {
       isMinifyEnabled = true
       proguardFiles(
         getDefaultProguardFile("proguard-android-optimize.txt"),
diff --git a/data/build.gradle.kts b/data/build.gradle.kts
index ea7c8251..06ab8ed1 100644
--- a/data/build.gradle.kts
+++ b/data/build.gradle.kts
@@ -12,10 +12,11 @@ android {
     targetSdk = appConfig.targetSdkVersion
 
     testInstrumentationRunner = "androidx.test.runner.AndroidJUnitRunner"
+    consumerProguardFiles("consumer-rules.pro")
   }
 
   buildTypes {
-    getByName("release") {
+    release {
       isMinifyEnabled = true
       proguardFiles(
         getDefaultProguardFile("proguard-android-optimize.txt"),
diff --git a/feature-add/build.gradle.kts b/feature-add/build.gradle.kts
index af74ddcc..abdce6d9 100644
--- a/feature-add/build.gradle.kts
+++ b/feature-add/build.gradle.kts
@@ -12,10 +12,11 @@ android {
     targetSdk = appConfig.targetSdkVersion
 
     testInstrumentationRunner = "androidx.test.runner.AndroidJUnitRunner"
+    consumerProguardFiles("consumer-rules.pro")
   }
 
   buildTypes {
-    getByName("release") {
+    release {
       isMinifyEnabled = true
       proguardFiles(
         getDefaultProguardFile("proguard-android-optimize.txt"),
diff --git a/feature-main/build.gradle.kts b/feature-main/build.gradle.kts
index a47fb278..8f2c9c6f 100644
--- a/feature-main/build.gradle.kts
+++ b/feature-main/build.gradle.kts
@@ -12,10 +12,11 @@ android {
     targetSdk = appConfig.targetSdkVersion
 
     testInstrumentationRunner = "androidx.test.runner.AndroidJUnitRunner"
+    consumerProguardFiles("consumer-rules.pro")
   }
 
   buildTypes {
-    getByName("release") {
+    release {
       isMinifyEnabled = true
       proguardFiles(
         getDefaultProguardFile("proguard-android-optimize.txt"),
diff --git a/feature-search/build.gradle.kts b/feature-search/build.gradle.kts
index c403df2c..cb026192 100644
--- a/feature-search/build.gradle.kts
+++ b/feature-search/build.gradle.kts
@@ -13,10 +13,11 @@ android {
     targetSdk = appConfig.targetSdkVersion
 
     testInstrumentationRunner = "androidx.test.runner.AndroidJUnitRunner"
+    consumerProguardFiles("consumer-rules.pro")
   }
 
   buildTypes {
-    getByName("release") {
+    release {
       isMinifyEnabled = true
       proguardFiles(
         getDefaultProguardFile("proguard-android-optimize.txt"),
diff --git a/mvi-base/.gitignore b/mvi-base/.gitignore
new file mode 100644
index 00000000..42afabfd
--- /dev/null
+++ b/mvi-base/.gitignore
@@ -0,0 +1 @@
+/build
\ No newline at end of file
diff --git a/mvi-base/build.gradle.kts b/mvi-base/build.gradle.kts
new file mode 100644
index 00000000..48d66865
--- /dev/null
+++ b/mvi-base/build.gradle.kts
@@ -0,0 +1,38 @@
+plugins {
+  androidLib
+  kotlinAndroid
+}
+
+android {
+  compileSdk = appConfig.compileSdkVersion
+  buildToolsVersion = appConfig.buildToolsVersion
+
+  defaultConfig {
+    minSdk = appConfig.minSdkVersion
+    targetSdk = appConfig.targetSdkVersion
+
+    testInstrumentationRunner = "androidx.test.runner.AndroidJUnitRunner"
+    consumerProguardFiles("consumer-rules.pro")
+  }
+
+  buildTypes {
+    release {
+      isMinifyEnabled = false
+      proguardFiles(
+        getDefaultProguardFile("proguard-android-optimize.txt"),
+        "proguard-rules.pro"
+      )
+    }
+  }
+  compileOptions {
+    sourceCompatibility = JavaVersion.VERSION_1_8
+    targetCompatibility = JavaVersion.VERSION_1_8
+  }
+  kotlinOptions { jvmTarget = JavaVersion.VERSION_1_8.toString() }
+}
+
+dependencies {
+  implementation(deps.lifecycle.viewModelKtx)
+
+  addUnitTest()
+}
diff --git a/mvi-base/consumer-rules.pro b/mvi-base/consumer-rules.pro
new file mode 100644
index 00000000..e69de29b
diff --git a/mvi-base/proguard-rules.pro b/mvi-base/proguard-rules.pro
new file mode 100644
index 00000000..481bb434
--- /dev/null
+++ b/mvi-base/proguard-rules.pro
@@ -0,0 +1,21 @@
+# Add project specific ProGuard rules here.
+# You can control the set of applied configuration files using the
+# proguardFiles setting in build.gradle.
+#
+# For more details, see
+#   http://developer.android.com/guide/developing/tools/proguard.html
+
+# If your project uses WebView with JS, uncomment the following
+# and specify the fully qualified class name to the JavaScript interface
+# class:
+#-keepclassmembers class fqcn.of.javascript.interface.for.webview {
+#   public *;
+#}
+
+# Uncomment this to preserve the line number information for
+# debugging stack traces.
+#-keepattributes SourceFile,LineNumberTable
+
+# If you keep the line number information, uncomment this to
+# hide the original source file name.
+#-renamesourcefileattribute SourceFile
\ No newline at end of file
diff --git a/mvi-base/src/androidTest/java/com/hoc/flowmvi/mvi_base/ExampleInstrumentedTest.kt b/mvi-base/src/androidTest/java/com/hoc/flowmvi/mvi_base/ExampleInstrumentedTest.kt
new file mode 100644
index 00000000..ef167c3f
--- /dev/null
+++ b/mvi-base/src/androidTest/java/com/hoc/flowmvi/mvi_base/ExampleInstrumentedTest.kt
@@ -0,0 +1,24 @@
+package com.hoc.flowmvi.mvi_base
+
+import androidx.test.platform.app.InstrumentationRegistry
+import androidx.test.ext.junit.runners.AndroidJUnit4
+
+import org.junit.Test
+import org.junit.runner.RunWith
+
+import org.junit.Assert.*
+
+/**
+ * Instrumented test, which will execute on an Android device.
+ *
+ * See [testing documentation](http://d.android.com/tools/testing).
+ */
+@RunWith(AndroidJUnit4::class)
+class ExampleInstrumentedTest {
+  @Test
+  fun useAppContext() {
+    // Context of the app under test.
+    val appContext = InstrumentationRegistry.getInstrumentation().targetContext
+    assertEquals("com.hoc.flowmvi.mvi_base.test", appContext.packageName)
+  }
+}
diff --git a/mvi-base/src/main/AndroidManifest.xml b/mvi-base/src/main/AndroidManifest.xml
new file mode 100644
index 00000000..e49ccc80
--- /dev/null
+++ b/mvi-base/src/main/AndroidManifest.xml
@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="utf-8"?>
+<manifest xmlns:android="http://schemas.android.com/apk/res/android"
+    package="com.hoc.flowmvi.mvi_base">
+
+</manifest>
diff --git a/mvi-base/src/test/java/com/hoc/flowmvi/mvi_base/ExampleUnitTest.kt b/mvi-base/src/test/java/com/hoc/flowmvi/mvi_base/ExampleUnitTest.kt
new file mode 100644
index 00000000..9c97ebc1
--- /dev/null
+++ b/mvi-base/src/test/java/com/hoc/flowmvi/mvi_base/ExampleUnitTest.kt
@@ -0,0 +1,17 @@
+package com.hoc.flowmvi.mvi_base
+
+import org.junit.Test
+
+import org.junit.Assert.*
+
+/**
+ * Example local unit test, which will execute on the development machine (host).
+ *
+ * See [testing documentation](http://d.android.com/tools/testing).
+ */
+class ExampleUnitTest {
+  @Test
+  fun addition_isCorrect() {
+    assertEquals(4, 2 + 2)
+  }
+}
diff --git a/settings.gradle.kts b/settings.gradle.kts
index 48b6f148..0e03fb2c 100644
--- a/settings.gradle.kts
+++ b/settings.gradle.kts
@@ -7,3 +7,4 @@ include(":feature-search")
 include(":domain")
 include(":data")
 include(":core")
+include(":mvi-base")

From b2048fa7619d3f7ed246b4274e9e07cc59bea3cb Mon Sep 17 00:00:00 2001
From: Petrus Nguyen Thai Hoc <hoc081098@gmail.com>
Date: Sat, 9 Oct 2021 16:04:39 +0700
Subject: [PATCH 02/14] implements

---
 buildSrc/src/main/kotlin/deps.kt | 1 +
 feature-add/build.gradle.kts     | 1 +
 feature-main/build.gradle.kts    | 1 +
 feature-search/build.gradle.kts  | 5 +++--
 4 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/buildSrc/src/main/kotlin/deps.kt b/buildSrc/src/main/kotlin/deps.kt
index 886b0d7a..6d1a2117 100644
--- a/buildSrc/src/main/kotlin/deps.kt
+++ b/buildSrc/src/main/kotlin/deps.kt
@@ -93,6 +93,7 @@ inline val DependencyHandler.data get() = project(":data")
 inline val DependencyHandler.featureMain get() = project(":feature-main")
 inline val DependencyHandler.featureAdd get() = project(":feature-add")
 inline val DependencyHandler.featureSearch get() = project(":feature-search")
+inline val DependencyHandler.mviBase get() = project(":mvi-base")
 
 fun DependencyHandler.addUnitTest() {
   add("testImplementation", deps.test.junit)
diff --git a/feature-add/build.gradle.kts b/feature-add/build.gradle.kts
index abdce6d9..9869db2c 100644
--- a/feature-add/build.gradle.kts
+++ b/feature-add/build.gradle.kts
@@ -41,6 +41,7 @@ android {
 dependencies {
   implementation(domain)
   implementation(core)
+  implementation(mviBase)
 
   implementation(deps.androidx.appCompat)
   implementation(deps.androidx.coreKtx)
diff --git a/feature-main/build.gradle.kts b/feature-main/build.gradle.kts
index 8f2c9c6f..1ee27743 100644
--- a/feature-main/build.gradle.kts
+++ b/feature-main/build.gradle.kts
@@ -48,6 +48,7 @@ android {
 dependencies {
   implementation(domain)
   implementation(core)
+  implementation(mviBase)
 
   implementation(deps.androidx.appCompat)
   implementation(deps.androidx.coreKtx)
diff --git a/feature-search/build.gradle.kts b/feature-search/build.gradle.kts
index cb026192..ca469d7e 100644
--- a/feature-search/build.gradle.kts
+++ b/feature-search/build.gradle.kts
@@ -40,8 +40,9 @@ android {
 }
 
 dependencies {
-  api(domain)
-  api(core)
+  implementation(domain)
+  implementation(core)
+  implementation(mviBase)
 
   implementation(deps.androidx.appCompat)
   implementation(deps.androidx.coreKtx)

From cfc3151a35eeca6703d8ba84ebe5834d8f7f447c Mon Sep 17 00:00:00 2001
From: Petrus Nguyen Thai Hoc <hoc081098@gmail.com>
Date: Sat, 9 Oct 2021 16:22:53 +0700
Subject: [PATCH 03/14] implements

---
 .../java/com/hoc/flowmvi/core/Extensions.kt   |  5 +++
 .../com/hoc/flowmvi/ui/main/MainActivity.kt   | 14 ++++---
 .../com/hoc/flowmvi/ui/main/MainContract.kt   | 13 ++++---
 .../java/com/hoc/flowmvi/ui/main/MainVM.kt    | 11 +++---
 mvi-base/build.gradle.kts                     |  1 +
 .../mvi_base/ExampleInstrumentedTest.kt       |  6 +--
 .../com/hoc/flowmvi/mvi_base/MviIntent.kt     |  6 +++
 .../hoc/flowmvi/mvi_base/MviSingleEvent.kt    |  6 +++
 .../java/com/hoc/flowmvi/mvi_base/MviView.kt  | 37 +++++++++++++++++++
 .../com/hoc/flowmvi/mvi_base/MviViewModel.kt  | 20 ++++++++++
 .../com/hoc/flowmvi/mvi_base/MviViewState.kt  |  6 +++
 .../hoc/flowmvi/mvi_base/ExampleUnitTest.kt   |  5 +--
 12 files changed, 107 insertions(+), 23 deletions(-)
 create mode 100644 core/src/main/java/com/hoc/flowmvi/core/Extensions.kt
 create mode 100644 mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviIntent.kt
 create mode 100644 mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviSingleEvent.kt
 create mode 100644 mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviView.kt
 create mode 100644 mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviViewModel.kt
 create mode 100644 mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviViewState.kt

diff --git a/core/src/main/java/com/hoc/flowmvi/core/Extensions.kt b/core/src/main/java/com/hoc/flowmvi/core/Extensions.kt
new file mode 100644
index 00000000..d1235768
--- /dev/null
+++ b/core/src/main/java/com/hoc/flowmvi/core/Extensions.kt
@@ -0,0 +1,5 @@
+package com.hoc.flowmvi.core
+
+@Suppress("unused")
+inline val Any?.unit
+  get() = Unit
diff --git a/feature-main/src/main/java/com/hoc/flowmvi/ui/main/MainActivity.kt b/feature-main/src/main/java/com/hoc/flowmvi/ui/main/MainActivity.kt
index 73116d4b..27615a50 100644
--- a/feature-main/src/main/java/com/hoc/flowmvi/ui/main/MainActivity.kt
+++ b/feature-main/src/main/java/com/hoc/flowmvi/ui/main/MainActivity.kt
@@ -17,6 +17,7 @@ import com.hoc.flowmvi.core.collectIn
 import com.hoc.flowmvi.core.navigator.Navigator
 import com.hoc.flowmvi.core.refreshes
 import com.hoc.flowmvi.core.toast
+import com.hoc.flowmvi.mvi_base.MviView
 import com.hoc.flowmvi.ui.main.databinding.ActivityMainBinding
 import com.hoc081098.viewbindingdelegate.viewBinding
 import kotlinx.coroutines.ExperimentalCoroutinesApi
@@ -34,7 +35,9 @@ import org.koin.androidx.viewmodel.ext.android.viewModel
 
 @FlowPreview
 @ExperimentalCoroutinesApi
-class MainActivity : AppCompatActivity(R.layout.activity_main) {
+class MainActivity :
+  AppCompatActivity(R.layout.activity_main),
+  MviView<ViewIntent, ViewState, SingleEvent> {
   private val mainVM by viewModel<MainVM>()
   private val navigator by inject<Navigator>()
 
@@ -93,20 +96,19 @@ class MainActivity : AppCompatActivity(R.layout.activity_main) {
       .collectIn(this) { handleSingleEvent(it) }
 
     // pass view intent to view model
-    intents()
+    viewIntents()
       .onEach { mainVM.processIntent(it) }
       .launchIn(lifecycleScope)
   }
 
-  @Suppress("NOTHING_TO_INLINE")
-  private inline fun intents(): Flow<ViewIntent> = merge(
+  override fun viewIntents(): Flow<ViewIntent> = merge(
     flowOf(ViewIntent.Initial),
     mainBinding.swipeRefreshLayout.refreshes().map { ViewIntent.Refresh },
     mainBinding.retryButton.clicks().map { ViewIntent.Retry },
     removeChannel.consumeAsFlow().map { ViewIntent.RemoveUser(it) }
   )
 
-  private fun handleSingleEvent(event: SingleEvent) {
+  override fun handleSingleEvent(event: SingleEvent) {
     Log.d("MainActivity", "handleSingleEvent $event")
     return when (event) {
       SingleEvent.Refresh.Success -> toast("Refresh success")
@@ -117,7 +119,7 @@ class MainActivity : AppCompatActivity(R.layout.activity_main) {
     }
   }
 
-  private fun render(viewState: ViewState) {
+  override fun render(viewState: ViewState) {
     Log.d("MainActivity", "render $viewState")
 
     userAdapter.submitList(viewState.userItems)
diff --git a/feature-main/src/main/java/com/hoc/flowmvi/ui/main/MainContract.kt b/feature-main/src/main/java/com/hoc/flowmvi/ui/main/MainContract.kt
index f26d3188..dccd67d7 100644
--- a/feature-main/src/main/java/com/hoc/flowmvi/ui/main/MainContract.kt
+++ b/feature-main/src/main/java/com/hoc/flowmvi/ui/main/MainContract.kt
@@ -1,8 +1,11 @@
 package com.hoc.flowmvi.ui.main
 
 import com.hoc.flowmvi.domain.entity.User
+import com.hoc.flowmvi.mvi_base.MviIntent
+import com.hoc.flowmvi.mvi_base.MviSingleEvent
+import com.hoc.flowmvi.mvi_base.MviViewState
 
-internal data class UserItem(
+data class UserItem(
   val id: String,
   val email: String,
   val avatar: String,
@@ -28,19 +31,19 @@ internal data class UserItem(
   )
 }
 
-internal sealed interface ViewIntent {
+sealed interface ViewIntent : MviIntent {
   object Initial : ViewIntent
   object Refresh : ViewIntent
   object Retry : ViewIntent
   data class RemoveUser(val user: UserItem) : ViewIntent
 }
 
-internal data class ViewState(
+data class ViewState(
   val userItems: List<UserItem>,
   val isLoading: Boolean,
   val error: Throwable?,
   val isRefreshing: Boolean
-) {
+) : MviViewState {
   companion object {
     fun initial() = ViewState(
       userItems = emptyList(),
@@ -100,7 +103,7 @@ internal sealed interface PartialChange {
   }
 }
 
-internal sealed interface SingleEvent {
+sealed interface SingleEvent : MviSingleEvent {
   sealed interface Refresh : SingleEvent {
     object Success : Refresh
     data class Failure(val error: Throwable) : Refresh
diff --git a/feature-main/src/main/java/com/hoc/flowmvi/ui/main/MainVM.kt b/feature-main/src/main/java/com/hoc/flowmvi/ui/main/MainVM.kt
index b8d092f4..9dd143b8 100644
--- a/feature-main/src/main/java/com/hoc/flowmvi/ui/main/MainVM.kt
+++ b/feature-main/src/main/java/com/hoc/flowmvi/ui/main/MainVM.kt
@@ -3,9 +3,11 @@ package com.hoc.flowmvi.ui.main
 import android.util.Log
 import androidx.lifecycle.ViewModel
 import androidx.lifecycle.viewModelScope
+import com.hoc.flowmvi.core.unit
 import com.hoc.flowmvi.domain.usecase.GetUsersUseCase
 import com.hoc.flowmvi.domain.usecase.RefreshGetUsersUseCase
 import com.hoc.flowmvi.domain.usecase.RemoveUserUseCase
+import com.hoc.flowmvi.mvi_base.MviViewModel
 import com.hoc081098.flowext.flatMapFirst
 import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.FlowPreview
@@ -40,14 +42,13 @@ internal class MainVM(
   private val getUsersUseCase: GetUsersUseCase,
   private val refreshGetUsers: RefreshGetUsersUseCase,
   private val removeUser: RemoveUserUseCase,
-) : ViewModel() {
+) : ViewModel(), MviViewModel<ViewIntent, ViewState, SingleEvent> {
   private val _eventChannel = Channel<SingleEvent>(Channel.BUFFERED)
   private val _intentFlow = MutableSharedFlow<ViewIntent>(extraBufferCapacity = 64)
 
-  val viewState: StateFlow<ViewState>
-  val singleEvent: Flow<SingleEvent> get() = _eventChannel.receiveAsFlow()
-
-  fun processIntent(intent: ViewIntent) = _intentFlow.tryEmit(intent)
+  override val viewState: StateFlow<ViewState>
+  override val singleEvent: Flow<SingleEvent> get() = _eventChannel.receiveAsFlow()
+  override fun processIntent(intent: ViewIntent) = _intentFlow.tryEmit(intent).unit
 
   init {
     val initialVS = ViewState.initial()
diff --git a/mvi-base/build.gradle.kts b/mvi-base/build.gradle.kts
index 48d66865..eaa84e13 100644
--- a/mvi-base/build.gradle.kts
+++ b/mvi-base/build.gradle.kts
@@ -33,6 +33,7 @@ android {
 
 dependencies {
   implementation(deps.lifecycle.viewModelKtx)
+  implementation(deps.coroutines.core)
 
   addUnitTest()
 }
diff --git a/mvi-base/src/androidTest/java/com/hoc/flowmvi/mvi_base/ExampleInstrumentedTest.kt b/mvi-base/src/androidTest/java/com/hoc/flowmvi/mvi_base/ExampleInstrumentedTest.kt
index ef167c3f..53dd6e35 100644
--- a/mvi-base/src/androidTest/java/com/hoc/flowmvi/mvi_base/ExampleInstrumentedTest.kt
+++ b/mvi-base/src/androidTest/java/com/hoc/flowmvi/mvi_base/ExampleInstrumentedTest.kt
@@ -1,12 +1,10 @@
 package com.hoc.flowmvi.mvi_base
 
-import androidx.test.platform.app.InstrumentationRegistry
 import androidx.test.ext.junit.runners.AndroidJUnit4
-
+import androidx.test.platform.app.InstrumentationRegistry
 import org.junit.Test
 import org.junit.runner.RunWith
-
-import org.junit.Assert.*
+import kotlin.test.assertEquals
 
 /**
  * Instrumented test, which will execute on an Android device.
diff --git a/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviIntent.kt b/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviIntent.kt
new file mode 100644
index 00000000..fbe97b08
--- /dev/null
+++ b/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviIntent.kt
@@ -0,0 +1,6 @@
+package com.hoc.flowmvi.mvi_base
+
+/**
+ * Immutable object which represent an view's intent.
+ */
+interface MviIntent
diff --git a/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviSingleEvent.kt b/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviSingleEvent.kt
new file mode 100644
index 00000000..f234d50d
--- /dev/null
+++ b/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviSingleEvent.kt
@@ -0,0 +1,6 @@
+package com.hoc.flowmvi.mvi_base
+/**
+ * Immutable object which represents a single event
+ * like snack bar message, navigation event, a dialog trigger, etc...
+ */
+interface MviSingleEvent
diff --git a/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviView.kt b/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviView.kt
new file mode 100644
index 00000000..c0859ee3
--- /dev/null
+++ b/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviView.kt
@@ -0,0 +1,37 @@
+package com.hoc.flowmvi.mvi_base
+
+import androidx.annotation.CheckResult
+import kotlinx.coroutines.flow.Flow
+
+/**
+ * Object representing a UI that will
+ * a) emit its intents to a view model,
+ * b) subscribes to a view model for rendering its UI.
+ * c) subscribes to a view model for handling single UI event.
+ *
+ * @param I Top class of the [MviIntent] that the [MviView] will be emitting.
+ * @param S Top class of the [MviViewState] the [MviView] will be subscribing to.
+ * @param E Top class of the [MviSingleEvent] the [MviView] will be subscribing to.
+ */
+interface MviView<
+  I : MviIntent,
+  S : MviViewState,
+  E : MviSingleEvent,
+  > {
+  /**
+   * Entry point for the [MviView] to render itself based on a [MviViewState].
+   */
+  fun render(viewState: S)
+
+  /**
+   * Entry point for the [MviView] to handle single event.
+   */
+  fun handleSingleEvent(event: E)
+
+  /**
+   * Unique [Flow] used by the [MviViewModel] to listen to the [MviView].
+   * All the [MviView]'s [MviIntent]s must go through this [Flow].
+   */
+  @CheckResult
+  fun viewIntents(): Flow<I>
+}
diff --git a/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviViewModel.kt b/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviViewModel.kt
new file mode 100644
index 00000000..cf046f03
--- /dev/null
+++ b/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviViewModel.kt
@@ -0,0 +1,20 @@
+package com.hoc.flowmvi.mvi_base
+
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.StateFlow
+
+/**
+ * Object that will subscribes to a MviView's [MviIntent]s,
+ * process it and emit a [MviViewState] back.
+ *
+ * @param I Top class of the [MviIntent] that the [MviViewModel] will be subscribing to.
+ * @param S Top class of the [MviViewState] the [MviViewModel] will be emitting.
+ * @param E Top class of the [MviSingleEvent] that the [MviViewModel] will be emitting.
+ */
+interface MviViewModel<I : MviIntent, S : MviViewState, E : MviSingleEvent> {
+  val viewState: StateFlow<S>
+
+  val singleEvent: Flow<E>
+
+  fun processIntent(intent: I)
+}
diff --git a/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviViewState.kt b/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviViewState.kt
new file mode 100644
index 00000000..703d5b9b
--- /dev/null
+++ b/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviViewState.kt
@@ -0,0 +1,6 @@
+package com.hoc.flowmvi.mvi_base
+
+/**
+ * Immutable object which contains all the required information to render a [MviView].
+ */
+interface MviViewState
diff --git a/mvi-base/src/test/java/com/hoc/flowmvi/mvi_base/ExampleUnitTest.kt b/mvi-base/src/test/java/com/hoc/flowmvi/mvi_base/ExampleUnitTest.kt
index 9c97ebc1..b1afee36 100644
--- a/mvi-base/src/test/java/com/hoc/flowmvi/mvi_base/ExampleUnitTest.kt
+++ b/mvi-base/src/test/java/com/hoc/flowmvi/mvi_base/ExampleUnitTest.kt
@@ -1,8 +1,7 @@
 package com.hoc.flowmvi.mvi_base
 
-import org.junit.Test
-
-import org.junit.Assert.*
+import kotlin.test.Test
+import kotlin.test.assertEquals
 
 /**
  * Example local unit test, which will execute on the development machine (host).

From 7509cbc3077626f05f04fd67068f80b4b069ccdf Mon Sep 17 00:00:00 2001
From: Petrus Nguyen Thai Hoc <hoc081098@gmail.com>
Date: Sat, 9 Oct 2021 22:22:45 +0700
Subject: [PATCH 04/14] refactor tests

---
 .idea/gradle.xml                              |   3 +-
 build.gradle.kts                              |   2 +-
 buildSrc/src/main/kotlin/deps.kt              |  13 +-
 feature-main/build.gradle.kts                 |   1 +
 .../java/com/hoc/flowmvi/ui/main/MainVM.kt    |   2 +-
 .../com/hoc/flowmvi/ui/main/MainVMTest.kt     | 177 ++++++------------
 {mvi-base => mvi/mvi-base}/.gitignore         |   0
 {mvi-base => mvi/mvi-base}/build.gradle.kts   |   0
 {mvi-base => mvi/mvi-base}/consumer-rules.pro |   0
 {mvi-base => mvi/mvi-base}/proguard-rules.pro |   0
 .../mvi_base/ExampleInstrumentedTest.kt       |   0
 .../mvi-base}/src/main/AndroidManifest.xml    |   0
 .../com/hoc/flowmvi/mvi_base/MviIntent.kt     |   0
 .../hoc/flowmvi/mvi_base/MviSingleEvent.kt    |   0
 .../java/com/hoc/flowmvi/mvi_base/MviView.kt  |   0
 .../com/hoc/flowmvi/mvi_base/MviViewModel.kt  |   0
 .../com/hoc/flowmvi/mvi_base/MviViewState.kt  |   0
 .../hoc/flowmvi/mvi_base/ExampleUnitTest.kt   |   0
 mvi/mvi-testing/.gitignore                    |   1 +
 mvi/mvi-testing/build.gradle.kts              |  41 ++++
 mvi/mvi-testing/consumer-rules.pro            |   0
 mvi/mvi-testing/proguard-rules.pro            |  21 +++
 .../mvi_testing/ExampleInstrumentedTest.kt    |  22 +++
 mvi/mvi-testing/src/main/AndroidManifest.xml  |   5 +
 .../mvi_testing/BaseMviViewModelTest.kt       |  86 +++++++++
 .../flowmvi/mvi_testing/ExampleUnitTest.kt    |  16 ++
 settings.gradle.kts                           |   8 +-
 27 files changed, 273 insertions(+), 125 deletions(-)
 rename {mvi-base => mvi/mvi-base}/.gitignore (100%)
 rename {mvi-base => mvi/mvi-base}/build.gradle.kts (100%)
 rename {mvi-base => mvi/mvi-base}/consumer-rules.pro (100%)
 rename {mvi-base => mvi/mvi-base}/proguard-rules.pro (100%)
 rename {mvi-base => mvi/mvi-base}/src/androidTest/java/com/hoc/flowmvi/mvi_base/ExampleInstrumentedTest.kt (100%)
 rename {mvi-base => mvi/mvi-base}/src/main/AndroidManifest.xml (100%)
 rename {mvi-base => mvi/mvi-base}/src/main/java/com/hoc/flowmvi/mvi_base/MviIntent.kt (100%)
 rename {mvi-base => mvi/mvi-base}/src/main/java/com/hoc/flowmvi/mvi_base/MviSingleEvent.kt (100%)
 rename {mvi-base => mvi/mvi-base}/src/main/java/com/hoc/flowmvi/mvi_base/MviView.kt (100%)
 rename {mvi-base => mvi/mvi-base}/src/main/java/com/hoc/flowmvi/mvi_base/MviViewModel.kt (100%)
 rename {mvi-base => mvi/mvi-base}/src/main/java/com/hoc/flowmvi/mvi_base/MviViewState.kt (100%)
 rename {mvi-base => mvi/mvi-base}/src/test/java/com/hoc/flowmvi/mvi_base/ExampleUnitTest.kt (100%)
 create mode 100644 mvi/mvi-testing/.gitignore
 create mode 100644 mvi/mvi-testing/build.gradle.kts
 create mode 100644 mvi/mvi-testing/consumer-rules.pro
 create mode 100644 mvi/mvi-testing/proguard-rules.pro
 create mode 100644 mvi/mvi-testing/src/androidTest/java/com/flowmvi/mvi_testing/ExampleInstrumentedTest.kt
 create mode 100644 mvi/mvi-testing/src/main/AndroidManifest.xml
 create mode 100644 mvi/mvi-testing/src/main/java/com/flowmvi/mvi_testing/BaseMviViewModelTest.kt
 create mode 100644 mvi/mvi-testing/src/test/java/com/flowmvi/mvi_testing/ExampleUnitTest.kt

diff --git a/.idea/gradle.xml b/.idea/gradle.xml
index a835ec66..ce97a058 100644
--- a/.idea/gradle.xml
+++ b/.idea/gradle.xml
@@ -19,7 +19,8 @@
             <option value="$PROJECT_DIR$/feature-add" />
             <option value="$PROJECT_DIR$/feature-main" />
             <option value="$PROJECT_DIR$/feature-search" />
-            <option value="$PROJECT_DIR$/mvi-base" />
+            <option value="$PROJECT_DIR$/mvi/mvi-base" />
+            <option value="$PROJECT_DIR$/mvi/mvi-testing" />
           </set>
         </option>
         <option name="resolveModulePerSourceSet" value="false" />
diff --git a/build.gradle.kts b/build.gradle.kts
index 7406e070..8a7ea8bd 100644
--- a/build.gradle.kts
+++ b/build.gradle.kts
@@ -11,7 +11,7 @@ buildscript {
   }
   dependencies {
     classpath("com.android.tools.build:gradle:7.0.2")
-    classpath("org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlinVersion")
+    classpath("org.jetbrains.kotlin:kotlin-gradle-plugin:1.5.30")
     classpath("com.diffplug.spotless:spotless-plugin-gradle:5.16.0")
     classpath("dev.ahmedmourad.nocopy:nocopy-gradle-plugin:1.4.0")
     classpath("org.jacoco:org.jacoco.core:0.8.7")
diff --git a/buildSrc/src/main/kotlin/deps.kt b/buildSrc/src/main/kotlin/deps.kt
index 6d1a2117..bb3b224f 100644
--- a/buildSrc/src/main/kotlin/deps.kt
+++ b/buildSrc/src/main/kotlin/deps.kt
@@ -94,10 +94,13 @@ inline val DependencyHandler.featureMain get() = project(":feature-main")
 inline val DependencyHandler.featureAdd get() = project(":feature-add")
 inline val DependencyHandler.featureSearch get() = project(":feature-search")
 inline val DependencyHandler.mviBase get() = project(":mvi-base")
+inline val DependencyHandler.mviTesting get() = project(":mvi-testing")
 
-fun DependencyHandler.addUnitTest() {
-  add("testImplementation", deps.test.junit)
-  add("testImplementation", deps.test.mockk)
-  add("testImplementation", deps.test.kotlinJUnit)
-  add("testImplementation", deps.coroutines.test)
+fun DependencyHandler.addUnitTest(testImplementation: Boolean = true) {
+  val configName = if (testImplementation) "testImplementation" else "implementation"
+
+  add(configName, deps.test.junit)
+  add(configName, deps.test.mockk)
+  add(configName, deps.test.kotlinJUnit)
+  add(configName, deps.coroutines.test)
 }
diff --git a/feature-main/build.gradle.kts b/feature-main/build.gradle.kts
index 1ee27743..3b4e355f 100644
--- a/feature-main/build.gradle.kts
+++ b/feature-main/build.gradle.kts
@@ -68,4 +68,5 @@ dependencies {
   implementation(deps.flowExt)
 
   addUnitTest()
+  testImplementation(mviTesting)
 }
diff --git a/feature-main/src/main/java/com/hoc/flowmvi/ui/main/MainVM.kt b/feature-main/src/main/java/com/hoc/flowmvi/ui/main/MainVM.kt
index 9dd143b8..fcf11a1a 100644
--- a/feature-main/src/main/java/com/hoc/flowmvi/ui/main/MainVM.kt
+++ b/feature-main/src/main/java/com/hoc/flowmvi/ui/main/MainVM.kt
@@ -38,7 +38,7 @@ import kotlinx.coroutines.flow.take
 @Suppress("USELESS_CAST")
 @FlowPreview
 @ExperimentalCoroutinesApi
-internal class MainVM(
+class MainVM(
   private val getUsersUseCase: GetUsersUseCase,
   private val refreshGetUsers: RefreshGetUsersUseCase,
   private val removeUser: RemoveUserUseCase,
diff --git a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
index 5145d156..9afa2e32 100644
--- a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
+++ b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
@@ -1,37 +1,23 @@
 package com.hoc.flowmvi.ui.main
 
+import com.flowmvi.mvi_testing.BaseMviViewModelTest
 import com.hoc.flowmvi.domain.entity.User
 import com.hoc.flowmvi.domain.usecase.GetUsersUseCase
 import com.hoc.flowmvi.domain.usecase.RefreshGetUsersUseCase
 import com.hoc.flowmvi.domain.usecase.RemoveUserUseCase
-import io.mockk.clearAllMocks
 import io.mockk.every
 import io.mockk.mockk
 import io.mockk.verify
-import kotlinx.coroutines.CoroutineStart
-import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.FlowPreview
-import kotlinx.coroutines.cancel
 import kotlinx.coroutines.delay
-import kotlinx.coroutines.flow.collect
 import kotlinx.coroutines.flow.flow
-import kotlinx.coroutines.flow.take
-import kotlinx.coroutines.flow.toList
-import kotlinx.coroutines.launch
-import kotlinx.coroutines.test.TestCoroutineDispatcher
-import kotlinx.coroutines.test.resetMain
-import kotlinx.coroutines.test.runBlockingTest
-import kotlinx.coroutines.test.setMain
+import kotlinx.coroutines.flow.flowOf
+import org.junit.Test
 import java.io.IOException
-import java.util.concurrent.atomic.AtomicBoolean
-import java.util.concurrent.atomic.AtomicReference
-import kotlin.test.AfterTest
-import kotlin.test.BeforeTest
-import kotlin.test.Test
-import kotlin.test.assertContentEquals
-import kotlin.test.assertEquals
-import kotlin.test.assertFalse
+import java.util.concurrent.TimeUnit
+import kotlin.time.ExperimentalTime
+import kotlin.time.toDuration
 
 val users = listOf(
   User(
@@ -59,128 +45,87 @@ val users = listOf(
 
 internal val usersItems = users.map { UserItem(it) }
 
+@ExperimentalTime
 @ExperimentalCoroutinesApi
 @FlowPreview
-class MainVMTest {
-  private val testDispatcher = TestCoroutineDispatcher()
-
+class MainVMTest : BaseMviViewModelTest<
+  ViewIntent,
+  ViewState,
+  SingleEvent,
+  MainVM
+  >() {
   private lateinit var vm: MainVM
   private val getUserUseCase: GetUsersUseCase = mockk(relaxed = true)
   private val refreshGetUsersUseCase: RefreshGetUsersUseCase = mockk(relaxed = true)
   private val removeUser: RemoveUserUseCase = mockk(relaxed = true)
 
-  @BeforeTest
-  fun setup() {
-    Dispatchers.setMain(testDispatcher)
+  override fun setup() {
+    super.setup()
 
     vm = MainVM(
       getUsersUseCase = getUserUseCase,
       refreshGetUsers = refreshGetUsersUseCase,
       removeUser = removeUser,
     )
+    println("DONE setup $vm")
   }
 
-  @AfterTest
-  fun teardown() {
-    Dispatchers.resetMain()
-    testDispatcher.cleanupTestCoroutines()
-    clearAllMocks()
+  override fun tearDown() {
+    super.tearDown()
+    println("DONE tearDown")
   }
 
   @Test
-  fun `ViewIntent_Initial returns success`() = testDispatcher.runBlockingTest {
-    every { getUserUseCase() } returns flow {
-      delay(100)
-      emit(users)
-    }
-
-    val hasEvent = AtomicBoolean(false)
-    val eventJob = launch(start = CoroutineStart.UNDISPATCHED) {
-      vm.singleEvent.collect {
-        hasEvent.set(true)
+  fun `ViewIntent_Initial returns success`() = test(
+    vmProducer = {
+      every { getUserUseCase() } returns flow {
+        delay(50)
+        emit(users)
       }
-    }
-
-    launch(start = CoroutineStart.UNDISPATCHED) {
-      vm.viewState
-        .take(2)
-        .toList()
-        .let {
-          assertContentEquals(
-            it,
-            listOf(
-              ViewState.initial(),
-              ViewState(
-                userItems = usersItems,
-                isLoading = false,
-                error = null,
-                isRefreshing = false
-              )
-            )
-          )
-        }
-
-      eventJob.cancel()
-      assertFalse(hasEvent.get())
-      verify(exactly = 1) { getUserUseCase() }
-
-      print("DONE")
-      cancel()
-    }
-
-    vm.processIntent(ViewIntent.Initial)
-  }
+      vm
+    },
+    intents = flowOf(ViewIntent.Initial),
+    expectedStates = listOf(
+      ViewState.initial(),
+      ViewState(
+        userItems = usersItems,
+        isLoading = false,
+        error = null,
+        isRefreshing = false
+      )
+    ),
+    expectedEvents = emptyList(),
+    delayAfterDispatchingIntents = 100.toDuration(TimeUnit.MILLISECONDS)
+  ) { verify(exactly = 1) { getUserUseCase() } }
 
   @Test
-  fun `ViewIntent_Initial returns failure`() = testDispatcher.runBlockingTest {
+  fun `ViewIntent_Initial returns failure`() {
     val ioException = IOException()
 
-    every { getUserUseCase() } returns flow {
-      delay(100)
-      throw ioException
-    }
-
-    val events = AtomicReference(emptyList<SingleEvent>())
-    val eventJob = launch(start = CoroutineStart.UNDISPATCHED) {
-      vm.singleEvent.collect { e ->
-        events.updateAndGet { it + e }
-      }
-    }
-
-    launch(start = CoroutineStart.UNDISPATCHED) {
-      vm.viewState
-        .take(2)
-        .toList()
-        .let {
-          assertContentEquals(
-            it,
-            listOf(
-              ViewState.initial(),
-              ViewState(
-                userItems = emptyList(),
-                isLoading = false,
-                error = ioException,
-                isRefreshing = false
-              )
-            )
-          )
+    test(
+      vmProducer = {
+        every { getUserUseCase() } returns flow {
+          delay(100)
+          throw ioException
         }
-
-      eventJob.cancel()
-
-      assertEquals(
-        events.get().single(),
+        vm
+      },
+      intents = flowOf(ViewIntent.Initial),
+      expectedStates = listOf(
+        ViewState.initial(),
+        ViewState(
+          userItems = emptyList(),
+          isLoading = false,
+          error = ioException,
+          isRefreshing = false
+        )
+      ),
+      expectedEvents = listOf(
         SingleEvent.GetUsersError(
           error = ioException,
         ),
-      )
-
-      verify(exactly = 1) { getUserUseCase() }
-
-      print("DONE")
-      cancel()
-    }
-
-    vm.processIntent(ViewIntent.Initial)
+      ),
+      delayAfterDispatchingIntents = 100.toDuration(TimeUnit.MILLISECONDS)
+    ) { verify(exactly = 1) { getUserUseCase() } }
   }
 }
diff --git a/mvi-base/.gitignore b/mvi/mvi-base/.gitignore
similarity index 100%
rename from mvi-base/.gitignore
rename to mvi/mvi-base/.gitignore
diff --git a/mvi-base/build.gradle.kts b/mvi/mvi-base/build.gradle.kts
similarity index 100%
rename from mvi-base/build.gradle.kts
rename to mvi/mvi-base/build.gradle.kts
diff --git a/mvi-base/consumer-rules.pro b/mvi/mvi-base/consumer-rules.pro
similarity index 100%
rename from mvi-base/consumer-rules.pro
rename to mvi/mvi-base/consumer-rules.pro
diff --git a/mvi-base/proguard-rules.pro b/mvi/mvi-base/proguard-rules.pro
similarity index 100%
rename from mvi-base/proguard-rules.pro
rename to mvi/mvi-base/proguard-rules.pro
diff --git a/mvi-base/src/androidTest/java/com/hoc/flowmvi/mvi_base/ExampleInstrumentedTest.kt b/mvi/mvi-base/src/androidTest/java/com/hoc/flowmvi/mvi_base/ExampleInstrumentedTest.kt
similarity index 100%
rename from mvi-base/src/androidTest/java/com/hoc/flowmvi/mvi_base/ExampleInstrumentedTest.kt
rename to mvi/mvi-base/src/androidTest/java/com/hoc/flowmvi/mvi_base/ExampleInstrumentedTest.kt
diff --git a/mvi-base/src/main/AndroidManifest.xml b/mvi/mvi-base/src/main/AndroidManifest.xml
similarity index 100%
rename from mvi-base/src/main/AndroidManifest.xml
rename to mvi/mvi-base/src/main/AndroidManifest.xml
diff --git a/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviIntent.kt b/mvi/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviIntent.kt
similarity index 100%
rename from mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviIntent.kt
rename to mvi/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviIntent.kt
diff --git a/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviSingleEvent.kt b/mvi/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviSingleEvent.kt
similarity index 100%
rename from mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviSingleEvent.kt
rename to mvi/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviSingleEvent.kt
diff --git a/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviView.kt b/mvi/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviView.kt
similarity index 100%
rename from mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviView.kt
rename to mvi/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviView.kt
diff --git a/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviViewModel.kt b/mvi/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviViewModel.kt
similarity index 100%
rename from mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviViewModel.kt
rename to mvi/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviViewModel.kt
diff --git a/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviViewState.kt b/mvi/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviViewState.kt
similarity index 100%
rename from mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviViewState.kt
rename to mvi/mvi-base/src/main/java/com/hoc/flowmvi/mvi_base/MviViewState.kt
diff --git a/mvi-base/src/test/java/com/hoc/flowmvi/mvi_base/ExampleUnitTest.kt b/mvi/mvi-base/src/test/java/com/hoc/flowmvi/mvi_base/ExampleUnitTest.kt
similarity index 100%
rename from mvi-base/src/test/java/com/hoc/flowmvi/mvi_base/ExampleUnitTest.kt
rename to mvi/mvi-base/src/test/java/com/hoc/flowmvi/mvi_base/ExampleUnitTest.kt
diff --git a/mvi/mvi-testing/.gitignore b/mvi/mvi-testing/.gitignore
new file mode 100644
index 00000000..42afabfd
--- /dev/null
+++ b/mvi/mvi-testing/.gitignore
@@ -0,0 +1 @@
+/build
\ No newline at end of file
diff --git a/mvi/mvi-testing/build.gradle.kts b/mvi/mvi-testing/build.gradle.kts
new file mode 100644
index 00000000..e8b54ff1
--- /dev/null
+++ b/mvi/mvi-testing/build.gradle.kts
@@ -0,0 +1,41 @@
+plugins {
+  androidLib
+  kotlinAndroid
+}
+
+android {
+  compileSdk = appConfig.compileSdkVersion
+  buildToolsVersion = appConfig.buildToolsVersion
+
+  defaultConfig {
+    minSdk = appConfig.minSdkVersion
+    targetSdk = appConfig.targetSdkVersion
+
+    testInstrumentationRunner = "androidx.test.runner.AndroidJUnitRunner"
+    consumerProguardFiles("consumer-rules.pro")
+  }
+
+  buildTypes {
+    release {
+      isMinifyEnabled = false
+      proguardFiles(
+        getDefaultProguardFile("proguard-android-optimize.txt"),
+        "proguard-rules.pro"
+      )
+    }
+  }
+  compileOptions {
+    sourceCompatibility = JavaVersion.VERSION_1_8
+    targetCompatibility = JavaVersion.VERSION_1_8
+  }
+  kotlinOptions { jvmTarget = JavaVersion.VERSION_1_8.toString() }
+}
+
+dependencies {
+  implementation(deps.lifecycle.viewModelKtx)
+  implementation(deps.coroutines.core)
+
+  implementation(mviBase)
+
+  addUnitTest(testImplementation = false)
+}
diff --git a/mvi/mvi-testing/consumer-rules.pro b/mvi/mvi-testing/consumer-rules.pro
new file mode 100644
index 00000000..e69de29b
diff --git a/mvi/mvi-testing/proguard-rules.pro b/mvi/mvi-testing/proguard-rules.pro
new file mode 100644
index 00000000..481bb434
--- /dev/null
+++ b/mvi/mvi-testing/proguard-rules.pro
@@ -0,0 +1,21 @@
+# Add project specific ProGuard rules here.
+# You can control the set of applied configuration files using the
+# proguardFiles setting in build.gradle.
+#
+# For more details, see
+#   http://developer.android.com/guide/developing/tools/proguard.html
+
+# If your project uses WebView with JS, uncomment the following
+# and specify the fully qualified class name to the JavaScript interface
+# class:
+#-keepclassmembers class fqcn.of.javascript.interface.for.webview {
+#   public *;
+#}
+
+# Uncomment this to preserve the line number information for
+# debugging stack traces.
+#-keepattributes SourceFile,LineNumberTable
+
+# If you keep the line number information, uncomment this to
+# hide the original source file name.
+#-renamesourcefileattribute SourceFile
\ No newline at end of file
diff --git a/mvi/mvi-testing/src/androidTest/java/com/flowmvi/mvi_testing/ExampleInstrumentedTest.kt b/mvi/mvi-testing/src/androidTest/java/com/flowmvi/mvi_testing/ExampleInstrumentedTest.kt
new file mode 100644
index 00000000..bde64a57
--- /dev/null
+++ b/mvi/mvi-testing/src/androidTest/java/com/flowmvi/mvi_testing/ExampleInstrumentedTest.kt
@@ -0,0 +1,22 @@
+package com.flowmvi.mvi_testing
+
+import androidx.test.ext.junit.runners.AndroidJUnit4
+import androidx.test.platform.app.InstrumentationRegistry
+import org.junit.runner.RunWith
+import kotlin.test.Test
+import kotlin.test.assertEquals
+
+/**
+ * Instrumented test, which will execute on an Android device.
+ *
+ * See [testing documentation](http://d.android.com/tools/testing).
+ */
+@RunWith(AndroidJUnit4::class)
+class ExampleInstrumentedTest {
+  @Test
+  fun useAppContext() {
+    // Context of the app under test.
+    val appContext = InstrumentationRegistry.getInstrumentation().targetContext
+    assertEquals("com.flowmvi.mvi_testing.test", appContext.packageName)
+  }
+}
diff --git a/mvi/mvi-testing/src/main/AndroidManifest.xml b/mvi/mvi-testing/src/main/AndroidManifest.xml
new file mode 100644
index 00000000..453f85db
--- /dev/null
+++ b/mvi/mvi-testing/src/main/AndroidManifest.xml
@@ -0,0 +1,5 @@
+<?xml version="1.0" encoding="utf-8"?>
+<manifest xmlns:android="http://schemas.android.com/apk/res/android"
+    package="com.flowmvi.mvi_testing">
+
+</manifest>
diff --git a/mvi/mvi-testing/src/main/java/com/flowmvi/mvi_testing/BaseMviViewModelTest.kt b/mvi/mvi-testing/src/main/java/com/flowmvi/mvi_testing/BaseMviViewModelTest.kt
new file mode 100644
index 00000000..8da47edb
--- /dev/null
+++ b/mvi/mvi-testing/src/main/java/com/flowmvi/mvi_testing/BaseMviViewModelTest.kt
@@ -0,0 +1,86 @@
+package com.flowmvi.mvi_testing
+
+import androidx.annotation.CallSuper
+import com.hoc.flowmvi.mvi_base.MviIntent
+import com.hoc.flowmvi.mvi_base.MviSingleEvent
+import com.hoc.flowmvi.mvi_base.MviViewModel
+import com.hoc.flowmvi.mvi_base.MviViewState
+import io.mockk.clearAllMocks
+import kotlinx.coroutines.CoroutineStart
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.ExperimentalCoroutinesApi
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.collect
+import kotlinx.coroutines.flow.toList
+import kotlinx.coroutines.launch
+import kotlinx.coroutines.test.TestCoroutineDispatcher
+import kotlinx.coroutines.test.resetMain
+import kotlinx.coroutines.test.runBlockingTest
+import kotlinx.coroutines.test.setMain
+import kotlin.test.AfterTest
+import kotlin.test.BeforeTest
+import kotlin.test.assertContentEquals
+import kotlin.test.assertEquals
+import kotlin.time.Duration
+import kotlin.time.ExperimentalTime
+
+@ExperimentalTime
+@ExperimentalCoroutinesApi
+abstract class BaseMviViewModelTest<
+  I : MviIntent,
+  S : MviViewState,
+  E : MviSingleEvent,
+  VM : MviViewModel<I, S, E>,
+  > {
+  private val testDispatcher = TestCoroutineDispatcher()
+
+  @CallSuper
+  @BeforeTest
+  open fun setup() {
+    Dispatchers.setMain(testDispatcher)
+  }
+
+  protected fun test(
+    vmProducer: () -> VM,
+    intents: Flow<I>,
+    expectedStates: List<S>,
+    expectedEvents: List<E>,
+    delayAfterDispatchingIntents: Duration = Duration.ZERO,
+    otherAssertions: (suspend () -> Unit)? = null,
+  ) = testDispatcher.runBlockingTest {
+    val vm = vmProducer()
+    val states = mutableListOf<S>()
+    val events = mutableListOf<E>()
+
+    val stateJob = launch(start = CoroutineStart.UNDISPATCHED) { vm.viewState.toList(states) }
+    val eventJob = launch(start = CoroutineStart.UNDISPATCHED) { vm.singleEvent.toList(events) }
+
+    intents.collect { vm.processIntent(it) }
+    delay(delayAfterDispatchingIntents)
+
+    assertEquals(expectedStates.size, states.size)
+    assertContentEquals(
+      expectedStates,
+      states,
+    )
+
+    assertEquals(expectedEvents.size, events.size)
+    assertContentEquals(
+      expectedEvents,
+      events,
+    )
+
+    otherAssertions?.invoke()
+    stateJob.cancel()
+    eventJob.cancel()
+  }
+
+  @CallSuper
+  @AfterTest
+  open fun tearDown() {
+    Dispatchers.resetMain()
+    testDispatcher.cleanupTestCoroutines()
+    clearAllMocks()
+  }
+}
diff --git a/mvi/mvi-testing/src/test/java/com/flowmvi/mvi_testing/ExampleUnitTest.kt b/mvi/mvi-testing/src/test/java/com/flowmvi/mvi_testing/ExampleUnitTest.kt
new file mode 100644
index 00000000..18589121
--- /dev/null
+++ b/mvi/mvi-testing/src/test/java/com/flowmvi/mvi_testing/ExampleUnitTest.kt
@@ -0,0 +1,16 @@
+package com.flowmvi.mvi_testing
+
+import kotlin.test.Test
+import kotlin.test.assertEquals
+
+/**
+ * Example local unit test, which will execute on the development machine (host).
+ *
+ * See [testing documentation](http://d.android.com/tools/testing).
+ */
+class ExampleUnitTest {
+  @Test
+  fun addition_isCorrect() {
+    assertEquals(4, 2 + 2)
+  }
+}
diff --git a/settings.gradle.kts b/settings.gradle.kts
index 0e03fb2c..b7dfdfed 100644
--- a/settings.gradle.kts
+++ b/settings.gradle.kts
@@ -7,4 +7,10 @@ include(":feature-search")
 include(":domain")
 include(":data")
 include(":core")
-include(":mvi-base")
+includeProject(":mvi-base", "mvi/mvi-base")
+includeProject(":mvi-testing", "mvi/mvi-testing")
+
+fun includeProject(name: String, filePath: String) {
+  include(name)
+  project(name).projectDir = File(filePath)
+}

From 87f8e183adada8a45b2418473620c747b0b0e3bd Mon Sep 17 00:00:00 2001
From: Petrus Nguyen Thai Hoc <hoc081098@gmail.com>
Date: Sat, 9 Oct 2021 22:39:19 +0700
Subject: [PATCH 05/14] up

---
 .../com/hoc/flowmvi/ui/main/MainVMTest.kt     | 37 +++++++++----------
 .../mvi_testing/BaseMviViewModelTest.kt       |  2 +-
 2 files changed, 19 insertions(+), 20 deletions(-)

diff --git a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
index 9afa2e32..ccc6797c 100644
--- a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
+++ b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
@@ -8,18 +8,15 @@ import com.hoc.flowmvi.domain.usecase.RemoveUserUseCase
 import io.mockk.every
 import io.mockk.mockk
 import io.mockk.verify
+import java.io.IOException
+import kotlin.test.Test
+import kotlin.time.ExperimentalTime
 import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.FlowPreview
-import kotlinx.coroutines.delay
 import kotlinx.coroutines.flow.flow
 import kotlinx.coroutines.flow.flowOf
-import org.junit.Test
-import java.io.IOException
-import java.util.concurrent.TimeUnit
-import kotlin.time.ExperimentalTime
-import kotlin.time.toDuration
 
-val users = listOf(
+private val USERS = listOf(
   User(
     id = "1",
     email = "email1@gmail.com",
@@ -43,7 +40,7 @@ val users = listOf(
   ),
 )
 
-internal val usersItems = users.map { UserItem(it) }
+private val USER_ITEMS = USERS.map(::UserItem)
 
 @ExperimentalTime
 @ExperimentalCoroutinesApi
@@ -78,24 +75,20 @@ class MainVMTest : BaseMviViewModelTest<
   @Test
   fun `ViewIntent_Initial returns success`() = test(
     vmProducer = {
-      every { getUserUseCase() } returns flow {
-        delay(50)
-        emit(users)
-      }
+      every { getUserUseCase() } returns flowOf(USERS)
       vm
     },
     intents = flowOf(ViewIntent.Initial),
     expectedStates = listOf(
       ViewState.initial(),
       ViewState(
-        userItems = usersItems,
+        userItems = USER_ITEMS,
         isLoading = false,
         error = null,
         isRefreshing = false
       )
     ),
     expectedEvents = emptyList(),
-    delayAfterDispatchingIntents = 100.toDuration(TimeUnit.MILLISECONDS)
   ) { verify(exactly = 1) { getUserUseCase() } }
 
   @Test
@@ -104,10 +97,7 @@ class MainVMTest : BaseMviViewModelTest<
 
     test(
       vmProducer = {
-        every { getUserUseCase() } returns flow {
-          delay(100)
-          throw ioException
-        }
+        every { getUserUseCase() } returns flow { throw ioException }
         vm
       },
       intents = flowOf(ViewIntent.Initial),
@@ -125,7 +115,16 @@ class MainVMTest : BaseMviViewModelTest<
           error = ioException,
         ),
       ),
-      delayAfterDispatchingIntents = 100.toDuration(TimeUnit.MILLISECONDS)
     ) { verify(exactly = 1) { getUserUseCase() } }
   }
+
+  @Test
+  fun `ViewIntent_Refresh returns success`() {
+    test(
+      vmProducer = { vm },
+      intents = flowOf(ViewIntent.Refresh),
+      expectedStates = listOf(ViewState.initial()),
+      expectedEvents = emptyList(),
+    )
+  }
 }
diff --git a/mvi/mvi-testing/src/main/java/com/flowmvi/mvi_testing/BaseMviViewModelTest.kt b/mvi/mvi-testing/src/main/java/com/flowmvi/mvi_testing/BaseMviViewModelTest.kt
index 8da47edb..3c4c78d6 100644
--- a/mvi/mvi-testing/src/main/java/com/flowmvi/mvi_testing/BaseMviViewModelTest.kt
+++ b/mvi/mvi-testing/src/main/java/com/flowmvi/mvi_testing/BaseMviViewModelTest.kt
@@ -46,7 +46,7 @@ abstract class BaseMviViewModelTest<
     intents: Flow<I>,
     expectedStates: List<S>,
     expectedEvents: List<E>,
-    delayAfterDispatchingIntents: Duration = Duration.ZERO,
+    delayAfterDispatchingIntents: Duration = Duration.milliseconds(50),
     otherAssertions: (suspend () -> Unit)? = null,
   ) = testDispatcher.runBlockingTest {
     val vm = vmProducer()

From 4ca38aff130853145df8ab78db1b7d11f3bf21b5 Mon Sep 17 00:00:00 2001
From: Petrus Nguyen Thai Hoc <hoc081098@gmail.com>
Date: Sun, 10 Oct 2021 23:00:48 +0700
Subject: [PATCH 06/14] up

---
 .../com/hoc/flowmvi/ui/main/MainVMTest.kt     | 86 ++++++++++++++++---
 .../mvi_testing/BaseMviViewModelTest.kt       |  6 ++
 2 files changed, 82 insertions(+), 10 deletions(-)

diff --git a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
index ccc6797c..bc763c35 100644
--- a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
+++ b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
@@ -5,16 +5,18 @@ import com.hoc.flowmvi.domain.entity.User
 import com.hoc.flowmvi.domain.usecase.GetUsersUseCase
 import com.hoc.flowmvi.domain.usecase.RefreshGetUsersUseCase
 import com.hoc.flowmvi.domain.usecase.RemoveUserUseCase
+import io.mockk.coEvery
+import io.mockk.coVerify
 import io.mockk.every
 import io.mockk.mockk
 import io.mockk.verify
-import java.io.IOException
-import kotlin.test.Test
-import kotlin.time.ExperimentalTime
 import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.FlowPreview
 import kotlinx.coroutines.flow.flow
 import kotlinx.coroutines.flow.flowOf
+import java.io.IOException
+import kotlin.test.Test
+import kotlin.time.ExperimentalTime
 
 private val USERS = listOf(
   User(
@@ -73,7 +75,7 @@ class MainVMTest : BaseMviViewModelTest<
   }
 
   @Test
-  fun `ViewIntent_Initial returns success`() = test(
+  fun test_withInitialIntentWhenSuccess_returnsUserItems() = test(
     vmProducer = {
       every { getUserUseCase() } returns flowOf(USERS)
       vm
@@ -92,7 +94,7 @@ class MainVMTest : BaseMviViewModelTest<
   ) { verify(exactly = 1) { getUserUseCase() } }
 
   @Test
-  fun `ViewIntent_Initial returns failure`() {
+  fun test_withInitialIntentWhenError_returnsErrorState() {
     val ioException = IOException()
 
     test(
@@ -119,12 +121,76 @@ class MainVMTest : BaseMviViewModelTest<
   }
 
   @Test
-  fun `ViewIntent_Refresh returns success`() {
+  fun test_withRefreshIntentWhenSuccess_isNotRefreshing() {
     test(
-      vmProducer = { vm },
+      vmProducer = {
+        every { getUserUseCase() } returns flowOf(USERS)
+        coEvery { refreshGetUsersUseCase() } returns Unit
+        vm
+      },
+      intentsBeforeCollecting = flowOf(ViewIntent.Initial),
       intents = flowOf(ViewIntent.Refresh),
-      expectedStates = listOf(ViewState.initial()),
-      expectedEvents = emptyList(),
-    )
+      expectedStates = listOf(
+        ViewState(
+          userItems = USER_ITEMS,
+          isLoading = false,
+          error = null,
+          isRefreshing = false
+        ),
+        ViewState(
+          userItems = USER_ITEMS,
+          isLoading = false,
+          error = null,
+          isRefreshing = true,
+        ),
+        ViewState(
+          userItems = USER_ITEMS,
+          isLoading = false,
+          error = null,
+          isRefreshing = false
+        ),
+      ),
+      expectedEvents = listOf(
+        SingleEvent.Refresh.Success
+      ),
+    ) { coVerify(exactly = 1) { refreshGetUsersUseCase() } }
+  }
+
+  @Test
+  fun test_withRefreshIntentWhenFailure_isNotRefreshing() {
+    val ioException = IOException()
+
+    test(
+      vmProducer = {
+        coEvery { getUserUseCase() } returns flowOf(USERS)
+        coEvery { refreshGetUsersUseCase() } throws ioException
+        vm
+      },
+      intentsBeforeCollecting = flowOf(ViewIntent.Initial),
+      intents = flowOf(ViewIntent.Refresh),
+      expectedStates = listOf(
+        ViewState(
+          userItems = USER_ITEMS,
+          isLoading = false,
+          error = null,
+          isRefreshing = false
+        ),
+        ViewState(
+          userItems = USER_ITEMS,
+          isLoading = false,
+          error = null,
+          isRefreshing = true,
+        ),
+        ViewState(
+          userItems = USER_ITEMS,
+          isLoading = false,
+          error = null,
+          isRefreshing = false
+        ),
+      ),
+      expectedEvents = listOf(
+        SingleEvent.Refresh.Failure(ioException)
+      ),
+    ) { coVerify(exactly = 1) { refreshGetUsersUseCase() } }
   }
 }
diff --git a/mvi/mvi-testing/src/main/java/com/flowmvi/mvi_testing/BaseMviViewModelTest.kt b/mvi/mvi-testing/src/main/java/com/flowmvi/mvi_testing/BaseMviViewModelTest.kt
index 3c4c78d6..f892a2bb 100644
--- a/mvi/mvi-testing/src/main/java/com/flowmvi/mvi_testing/BaseMviViewModelTest.kt
+++ b/mvi/mvi-testing/src/main/java/com/flowmvi/mvi_testing/BaseMviViewModelTest.kt
@@ -47,9 +47,12 @@ abstract class BaseMviViewModelTest<
     expectedStates: List<S>,
     expectedEvents: List<E>,
     delayAfterDispatchingIntents: Duration = Duration.milliseconds(50),
+    intentsBeforeCollecting: Flow<I>? = null,
     otherAssertions: (suspend () -> Unit)? = null,
   ) = testDispatcher.runBlockingTest {
     val vm = vmProducer()
+    intentsBeforeCollecting?.collect { vm.processIntent(it) }
+
     val states = mutableListOf<S>()
     val events = mutableListOf<E>()
 
@@ -59,6 +62,9 @@ abstract class BaseMviViewModelTest<
     intents.collect { vm.processIntent(it) }
     delay(delayAfterDispatchingIntents)
 
+    println(states)
+    println(events)
+
     assertEquals(expectedStates.size, states.size)
     assertContentEquals(
       expectedStates,

From 4aae8f776d4535cad9c99f3d540415fd76e214f2 Mon Sep 17 00:00:00 2001
From: Petrus Nguyen Thai Hoc <hoc081098@gmail.com>
Date: Sun, 10 Oct 2021 23:12:30 +0700
Subject: [PATCH 07/14] up

---
 .../com/hoc/flowmvi/ui/main/MainVMTest.kt     | 62 +++++++++----------
 1 file changed, 30 insertions(+), 32 deletions(-)

diff --git a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
index bc763c35..cf0ec42f 100644
--- a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
+++ b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
@@ -121,40 +121,38 @@ class MainVMTest : BaseMviViewModelTest<
   }
 
   @Test
-  fun test_withRefreshIntentWhenSuccess_isNotRefreshing() {
-    test(
-      vmProducer = {
-        every { getUserUseCase() } returns flowOf(USERS)
-        coEvery { refreshGetUsersUseCase() } returns Unit
-        vm
-      },
-      intentsBeforeCollecting = flowOf(ViewIntent.Initial),
-      intents = flowOf(ViewIntent.Refresh),
-      expectedStates = listOf(
-        ViewState(
-          userItems = USER_ITEMS,
-          isLoading = false,
-          error = null,
-          isRefreshing = false
-        ),
-        ViewState(
-          userItems = USER_ITEMS,
-          isLoading = false,
-          error = null,
-          isRefreshing = true,
-        ),
-        ViewState(
-          userItems = USER_ITEMS,
-          isLoading = false,
-          error = null,
-          isRefreshing = false
-        ),
+  fun test_withRefreshIntentWhenSuccess_isNotRefreshing() = test(
+    vmProducer = {
+      every { getUserUseCase() } returns flowOf(USERS)
+      coEvery { refreshGetUsersUseCase() } returns Unit
+      vm
+    },
+    intentsBeforeCollecting = flowOf(ViewIntent.Initial),
+    intents = flowOf(ViewIntent.Refresh),
+    expectedStates = listOf(
+      ViewState(
+        userItems = USER_ITEMS,
+        isLoading = false,
+        error = null,
+        isRefreshing = false
       ),
-      expectedEvents = listOf(
-        SingleEvent.Refresh.Success
+      ViewState(
+        userItems = USER_ITEMS,
+        isLoading = false,
+        error = null,
+        isRefreshing = true,
       ),
-    ) { coVerify(exactly = 1) { refreshGetUsersUseCase() } }
-  }
+      ViewState(
+        userItems = USER_ITEMS,
+        isLoading = false,
+        error = null,
+        isRefreshing = false
+      ),
+    ),
+    expectedEvents = listOf(
+      SingleEvent.Refresh.Success
+    ),
+  ) { coVerify(exactly = 1) { refreshGetUsersUseCase() } }
 
   @Test
   fun test_withRefreshIntentWhenFailure_isNotRefreshing() {

From df5daf82cb86068aabaef9d5e5567df670fc7ce7 Mon Sep 17 00:00:00 2001
From: Petrus Nguyen Thai Hoc <hoc081098@gmail.com>
Date: Mon, 11 Oct 2021 13:33:17 +0700
Subject: [PATCH 08/14] addtests

---
 .../java/com/hoc/flowmvi/ui/main/MainVMTest.kt    | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
index cf0ec42f..e748375d 100644
--- a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
+++ b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
@@ -16,6 +16,7 @@ import kotlinx.coroutines.flow.flow
 import kotlinx.coroutines.flow.flowOf
 import java.io.IOException
 import kotlin.test.Test
+import kotlin.time.Duration
 import kotlin.time.ExperimentalTime
 
 private val USERS = listOf(
@@ -191,4 +192,18 @@ class MainVMTest : BaseMviViewModelTest<
       ),
     ) { coVerify(exactly = 1) { refreshGetUsersUseCase() } }
   }
+
+  @Test
+  fun test_withRefreshIntent_ignoredWhenIsLoading() {
+    test(
+      vmProducer = {
+        coEvery { refreshGetUsersUseCase() } returns Unit
+        vm
+      },
+      intents = flowOf(ViewIntent.Refresh),
+      expectedStates = listOf(ViewState.initial()),
+      expectedEvents = emptyList(),
+      delayAfterDispatchingIntents = Duration.milliseconds(100),
+    ) { coVerify(exactly = 0) { refreshGetUsersUseCase() } }
+  }
 }

From a341f8a139fcb3d65e03f816de7109155b364129 Mon Sep 17 00:00:00 2001
From: Petrus Nguyen Thai Hoc <hoc081098@gmail.com>
Date: Mon, 11 Oct 2021 13:53:42 +0700
Subject: [PATCH 09/14] addtests

---
 .../com/hoc/flowmvi/ui/main/MainVMTest.kt     | 26 +++++++++++++++++++
 1 file changed, 26 insertions(+)

diff --git a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
index e748375d..084be8fd 100644
--- a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
+++ b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
@@ -206,4 +206,30 @@ class MainVMTest : BaseMviViewModelTest<
       delayAfterDispatchingIntents = Duration.milliseconds(100),
     ) { coVerify(exactly = 0) { refreshGetUsersUseCase() } }
   }
+
+  @Test
+  fun test_withRefreshIntent_ignoredWhenHavingError() {
+    val ioException = IOException()
+    test(
+      vmProducer = {
+        every { getUserUseCase() } returns flow { throw ioException }
+        coEvery { refreshGetUsersUseCase() } returns Unit
+        vm
+      },
+      intentsBeforeCollecting = flowOf(ViewIntent.Initial),
+      intents = flowOf(ViewIntent.Refresh),
+      expectedStates = listOf(
+        ViewState(
+          userItems = emptyList(),
+          isLoading = false,
+          error = ioException,
+          isRefreshing = false,
+        )
+      ),
+      expectedEvents = listOf(
+        SingleEvent.GetUsersError(ioException),
+      ),
+      delayAfterDispatchingIntents = Duration.milliseconds(100),
+    ) { coVerify(exactly = 0) { refreshGetUsersUseCase() } }
+  }
 }

From 53db8fca1861a28952e81ca59ac973d0983fc315 Mon Sep 17 00:00:00 2001
From: Petrus Nguyen Thai Hoc <hoc081098@gmail.com>
Date: Mon, 11 Oct 2021 14:04:24 +0700
Subject: [PATCH 10/14] addtests

---
 .../java/com/hoc/flowmvi/ui/main/MainVMTest.kt    | 15 +++++++++++++++
 .../flowmvi/mvi_testing/BaseMviViewModelTest.kt   |  9 ++++++---
 2 files changed, 21 insertions(+), 3 deletions(-)

diff --git a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
index 084be8fd..e1cf43f6 100644
--- a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
+++ b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
@@ -12,6 +12,7 @@ import io.mockk.mockk
 import io.mockk.verify
 import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.FlowPreview
+import kotlinx.coroutines.flow.emptyFlow
 import kotlinx.coroutines.flow.flow
 import kotlinx.coroutines.flow.flowOf
 import java.io.IOException
@@ -232,4 +233,18 @@ class MainVMTest : BaseMviViewModelTest<
       delayAfterDispatchingIntents = Duration.milliseconds(100),
     ) { coVerify(exactly = 0) { refreshGetUsersUseCase() } }
   }
+
+  @Test
+  fun test_withRetryIntent_ignoredWhenHavingNoError() {
+    test(
+      vmProducer = {
+        every { getUserUseCase() } returns emptyFlow()
+        vm
+      },
+      intents = flowOf(ViewIntent.Retry),
+      expectedStates = listOf(ViewState.initial()),
+      expectedEvents = emptyList(),
+      delayAfterDispatchingIntents = Duration.milliseconds(100),
+    ) { coVerify(exactly = 0) { getUserUseCase() } }
+  }
 }
diff --git a/mvi/mvi-testing/src/main/java/com/flowmvi/mvi_testing/BaseMviViewModelTest.kt b/mvi/mvi-testing/src/main/java/com/flowmvi/mvi_testing/BaseMviViewModelTest.kt
index f892a2bb..b807af47 100644
--- a/mvi/mvi-testing/src/main/java/com/flowmvi/mvi_testing/BaseMviViewModelTest.kt
+++ b/mvi/mvi-testing/src/main/java/com/flowmvi/mvi_testing/BaseMviViewModelTest.kt
@@ -46,7 +46,8 @@ abstract class BaseMviViewModelTest<
     intents: Flow<I>,
     expectedStates: List<S>,
     expectedEvents: List<E>,
-    delayAfterDispatchingIntents: Duration = Duration.milliseconds(50),
+    delayAfterDispatchingIntents: Duration = Duration.ZERO,
+    logging: Boolean = true,
     intentsBeforeCollecting: Flow<I>? = null,
     otherAssertions: (suspend () -> Unit)? = null,
   ) = testDispatcher.runBlockingTest {
@@ -62,8 +63,10 @@ abstract class BaseMviViewModelTest<
     intents.collect { vm.processIntent(it) }
     delay(delayAfterDispatchingIntents)
 
-    println(states)
-    println(events)
+    if (logging) {
+      println(states)
+      println(events)
+    }
 
     assertEquals(expectedStates.size, states.size)
     assertContentEquals(

From fc5a2d6a7a13fc076b2f8b3cc4beff493a3de60d Mon Sep 17 00:00:00 2001
From: Petrus Nguyen Thai Hoc <hoc081098@gmail.com>
Date: Mon, 11 Oct 2021 14:15:14 +0700
Subject: [PATCH 11/14] addtests

---
 .../com/hoc/flowmvi/ui/main/MainVMTest.kt     | 39 +++++++++++++++++++
 1 file changed, 39 insertions(+)

diff --git a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
index e1cf43f6..c5ac9347 100644
--- a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
+++ b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
@@ -247,4 +247,43 @@ class MainVMTest : BaseMviViewModelTest<
       delayAfterDispatchingIntents = Duration.milliseconds(100),
     ) { coVerify(exactly = 0) { getUserUseCase() } }
   }
+
+  @Test
+  fun test_withRetryIntentWhenSuccess_returnsUserItems() {
+    val ioException = IOException()
+    test(
+      vmProducer = {
+        every { getUserUseCase() } returnsMany listOf(
+          flow { throw ioException },
+          flowOf(USERS),
+        )
+        vm
+      },
+      intentsBeforeCollecting = flowOf(ViewIntent.Initial),
+      intents = flowOf(ViewIntent.Retry),
+      expectedStates = listOf(
+        ViewState(
+          userItems = emptyList(),
+          isLoading = false,
+          error = ioException,
+          isRefreshing = false,
+        ),
+        ViewState(
+          userItems = emptyList(),
+          isLoading = true,
+          error = null,
+          isRefreshing = false,
+        ),
+        ViewState(
+          userItems = USER_ITEMS,
+          isLoading = false,
+          error = null,
+          isRefreshing = false,
+        )
+      ),
+      expectedEvents = listOf(
+        SingleEvent.GetUsersError(ioException),
+      ),
+    ) { verify(exactly = 2) { getUserUseCase() } }
+  }
 }

From 0f0b254aced91644cc97eab427e7155849511a72 Mon Sep 17 00:00:00 2001
From: Petrus Nguyen Thai Hoc <hoc081098@gmail.com>
Date: Mon, 11 Oct 2021 14:17:08 +0700
Subject: [PATCH 12/14] addtests

---
 .../com/hoc/flowmvi/ui/main/MainVMTest.kt     | 41 +++++++++++++++++++
 1 file changed, 41 insertions(+)

diff --git a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
index c5ac9347..9015b665 100644
--- a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
+++ b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
@@ -286,4 +286,45 @@ class MainVMTest : BaseMviViewModelTest<
       ),
     ) { verify(exactly = 2) { getUserUseCase() } }
   }
+
+  @Test
+  fun test_withRetryIntentWhenSuccess_returnsErrorState() {
+    val ioException1 = IOException()
+    val ioException2 = IOException()
+    test(
+      vmProducer = {
+        every { getUserUseCase() } returnsMany listOf(
+          flow { throw ioException1 },
+          flow { throw ioException2 },
+        )
+        vm
+      },
+      intentsBeforeCollecting = flowOf(ViewIntent.Initial),
+      intents = flowOf(ViewIntent.Retry),
+      expectedStates = listOf(
+        ViewState(
+          userItems = emptyList(),
+          isLoading = false,
+          error = ioException1,
+          isRefreshing = false,
+        ),
+        ViewState(
+          userItems = emptyList(),
+          isLoading = true,
+          error = null,
+          isRefreshing = false,
+        ),
+        ViewState(
+          userItems = emptyList(),
+          isLoading = false,
+          error = ioException2,
+          isRefreshing = false,
+        )
+      ),
+      expectedEvents = listOf(
+        SingleEvent.GetUsersError(ioException1),
+        SingleEvent.GetUsersError(ioException2),
+      ),
+    ) { verify(exactly = 2) { getUserUseCase() } }
+  }
 }

From 76f10a72d99c29a3f0bd7811fb6b71381b640775 Mon Sep 17 00:00:00 2001
From: Petrus Nguyen Thai Hoc <hoc081098@gmail.com>
Date: Mon, 11 Oct 2021 15:02:13 +0700
Subject: [PATCH 13/14] add tests

---
 .../com/hoc/flowmvi/ui/main/MainVMTest.kt     | 91 +++++++++++++++++++
 1 file changed, 91 insertions(+)

diff --git a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
index 9015b665..ee394c2e 100644
--- a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
+++ b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
@@ -7,14 +7,17 @@ import com.hoc.flowmvi.domain.usecase.RefreshGetUsersUseCase
 import com.hoc.flowmvi.domain.usecase.RemoveUserUseCase
 import io.mockk.coEvery
 import io.mockk.coVerify
+import io.mockk.coVerifySequence
 import io.mockk.every
 import io.mockk.mockk
 import io.mockk.verify
 import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.FlowPreview
+import kotlinx.coroutines.flow.MutableStateFlow
 import kotlinx.coroutines.flow.emptyFlow
 import kotlinx.coroutines.flow.flow
 import kotlinx.coroutines.flow.flowOf
+import kotlinx.coroutines.flow.update
 import java.io.IOException
 import kotlin.test.Test
 import kotlin.time.Duration
@@ -327,4 +330,92 @@ class MainVMTest : BaseMviViewModelTest<
       ),
     ) { verify(exactly = 2) { getUserUseCase() } }
   }
+
+  @Test
+  fun test_withRemoveUserIntentWhenSuccess_returnsUserItemsExceptRemovedUserItems() {
+    val user1 = USERS[0]
+    val user2 = USERS[1]
+    val item1 = USER_ITEMS[0]
+    val item2 = USER_ITEMS[1]
+    val usersFlow = MutableStateFlow(USERS)
+
+    test(
+      vmProducer = {
+        every { getUserUseCase() } returns usersFlow
+        coEvery { removeUser(any()) } coAnswers {
+          usersFlow.update { users ->
+            users.filter { it.id != firstArg<User>().id }
+          }
+        }
+        vm
+      },
+      intentsBeforeCollecting = flowOf(ViewIntent.Initial),
+      intents = flowOf(
+        ViewIntent.RemoveUser(item1),
+        ViewIntent.RemoveUser(item2),
+      ),
+      expectedStates = listOf(
+        ViewState(
+          userItems = USER_ITEMS,
+          isLoading = false,
+          error = null,
+          isRefreshing = false,
+        ),
+        ViewState(
+          userItems = USER_ITEMS.toMutableList().apply { remove(item1) },
+          isLoading = false,
+          error = null,
+          isRefreshing = false,
+        ),
+        ViewState(
+          userItems = USER_ITEMS.toMutableList().apply {
+            remove(item1)
+            remove(item2)
+          },
+          isLoading = false,
+          error = null,
+          isRefreshing = false,
+        ),
+      ),
+      expectedEvents = listOf(
+        SingleEvent.RemoveUser.Success(item1),
+        SingleEvent.RemoveUser.Success(item2),
+      )
+    ) {
+      coVerifySequence {
+        removeUser(user1)
+        removeUser(user2)
+      }
+    }
+  }
+
+  @Test
+  fun test_withRemoveUserIntentWhenError_stateDoNotChange() {
+    val user = USERS[0]
+    val item = USER_ITEMS[0]
+    val ioException = IOException()
+
+    test(
+      vmProducer = {
+        every { getUserUseCase() } returns flowOf(USERS)
+        coEvery { removeUser(any()) } throws ioException
+        vm
+      },
+      intentsBeforeCollecting = flowOf(ViewIntent.Initial),
+      intents = flowOf(ViewIntent.RemoveUser(item)),
+      expectedStates = listOf(
+        ViewState(
+          userItems = USER_ITEMS,
+          isLoading = false,
+          error = null,
+          isRefreshing = false,
+        ),
+      ),
+      expectedEvents = listOf(
+        SingleEvent.RemoveUser.Failure(item, ioException),
+      )
+    ) {
+      coVerify(exactly = 1) { removeUser(user) }
+    }
+  }
 }

From adff41513e94283e05f727bcf94c94869feefe4e Mon Sep 17 00:00:00 2001
From: Petrus Nguyen Thai Hoc <hoc081098@gmail.com>
Date: Mon, 11 Oct 2021 15:12:52 +0700
Subject: [PATCH 14/14] add tests

---
 .../hoc/flowmvi/ui/main/MainContractTest.kt   | 103 ++++++++++++++++++
 .../com/hoc/flowmvi/ui/main/MainVMTest.kt     |  26 -----
 .../java/com/hoc/flowmvi/ui/main/TestData.kt  |  29 +++++
 .../mvi_testing/BaseMviViewModelTest.kt       |   6 +-
 4 files changed, 136 insertions(+), 28 deletions(-)
 create mode 100644 feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainContractTest.kt
 create mode 100644 feature-main/src/test/java/com/hoc/flowmvi/ui/main/TestData.kt

diff --git a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainContractTest.kt b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainContractTest.kt
new file mode 100644
index 00000000..c01dfba5
--- /dev/null
+++ b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainContractTest.kt
@@ -0,0 +1,103 @@
+package com.hoc.flowmvi.ui.main
+
+import com.hoc.flowmvi.domain.entity.User
+import kotlin.test.Test
+import kotlin.test.assertEquals
+
+class MainContractTest {
+  @Test
+  fun test_userItem_equals() {
+    assertEquals(
+      UserItem(
+        id = "0",
+        email = "test@gmail.com",
+        avatar = "avatar.png",
+        firstName = "first",
+        lastName = "last"
+      ),
+      UserItem(
+        id = "0",
+        email = "test@gmail.com",
+        avatar = "avatar.png",
+        firstName = "first",
+        lastName = "last"
+      )
+    )
+  }
+
+  @Test
+  fun test_userItem_hashCode() {
+    assertEquals(
+      UserItem(
+        id = "0",
+        email = "test@gmail.com",
+        avatar = "avatar.png",
+        firstName = "first",
+        lastName = "last"
+      ).hashCode(),
+      UserItem(
+        id = "0",
+        email = "test@gmail.com",
+        avatar = "avatar.png",
+        firstName = "first",
+        lastName = "last"
+      ).hashCode()
+    )
+  }
+
+  @Test
+  fun test_userItem_fullName() {
+    assertEquals(
+      UserItem(
+        id = "0",
+        email = "test@gmail.com",
+        avatar = "avatar.png",
+        firstName = "first",
+        lastName = "last"
+      ).fullName,
+      "first last",
+    )
+  }
+
+  @Test
+  fun test_userItem_toDomain() {
+    assertEquals(
+      UserItem(
+        id = "0",
+        email = "test@gmail.com",
+        avatar = "avatar.png",
+        firstName = "first",
+        lastName = "last"
+      ).toDomain(),
+      User(
+        id = "0",
+        email = "test@gmail.com",
+        firstName = "first",
+        lastName = "last",
+        avatar = "avatar.png",
+      )
+    )
+  }
+
+  @Test
+  fun test_userItem_fromDomain() {
+    assertEquals(
+      UserItem(
+        domain = User(
+          id = "0",
+          email = "test@gmail.com",
+          firstName = "first",
+          lastName = "last",
+          avatar = "avatar.png",
+        )
+      ),
+      UserItem(
+        id = "0",
+        email = "test@gmail.com",
+        avatar = "avatar.png",
+        firstName = "first",
+        lastName = "last"
+      ),
+    )
+  }
+}
diff --git a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
index ee394c2e..6275ddd5 100644
--- a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
+++ b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/MainVMTest.kt
@@ -23,32 +23,6 @@ import kotlin.test.Test
 import kotlin.time.Duration
 import kotlin.time.ExperimentalTime
 
-private val USERS = listOf(
-  User(
-    id = "1",
-    email = "email1@gmail.com",
-    firstName = "first1",
-    lastName = "last1",
-    avatar = "1.png"
-  ),
-  User(
-    id = "2",
-    email = "email1@gmail.com",
-    firstName = "first2",
-    lastName = "last2",
-    avatar = "2.png"
-  ),
-  User(
-    id = "3",
-    email = "email1@gmail.com",
-    firstName = "first3",
-    lastName = "last3",
-    avatar = "3.png"
-  ),
-)
-
-private val USER_ITEMS = USERS.map(::UserItem)
-
 @ExperimentalTime
 @ExperimentalCoroutinesApi
 @FlowPreview
diff --git a/feature-main/src/test/java/com/hoc/flowmvi/ui/main/TestData.kt b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/TestData.kt
new file mode 100644
index 00000000..5d473401
--- /dev/null
+++ b/feature-main/src/test/java/com/hoc/flowmvi/ui/main/TestData.kt
@@ -0,0 +1,29 @@
+package com.hoc.flowmvi.ui.main
+
+import com.hoc.flowmvi.domain.entity.User
+
+internal val USERS = listOf(
+  User(
+    id = "1",
+    email = "email1@gmail.com",
+    firstName = "first1",
+    lastName = "last1",
+    avatar = "1.png"
+  ),
+  User(
+    id = "2",
+    email = "email1@gmail.com",
+    firstName = "first2",
+    lastName = "last2",
+    avatar = "2.png"
+  ),
+  User(
+    id = "3",
+    email = "email1@gmail.com",
+    firstName = "first3",
+    lastName = "last3",
+    avatar = "3.png"
+  ),
+)
+
+internal val USER_ITEMS = USERS.map(::UserItem)
diff --git a/mvi/mvi-testing/src/main/java/com/flowmvi/mvi_testing/BaseMviViewModelTest.kt b/mvi/mvi-testing/src/main/java/com/flowmvi/mvi_testing/BaseMviViewModelTest.kt
index b807af47..a31f0b28 100644
--- a/mvi/mvi-testing/src/main/java/com/flowmvi/mvi_testing/BaseMviViewModelTest.kt
+++ b/mvi/mvi-testing/src/main/java/com/flowmvi/mvi_testing/BaseMviViewModelTest.kt
@@ -68,16 +68,18 @@ abstract class BaseMviViewModelTest<
       println(events)
     }
 
-    assertEquals(expectedStates.size, states.size)
+    assertEquals(expectedStates.size, states.size, "States size")
     assertContentEquals(
       expectedStates,
       states,
+      "States content"
     )
 
-    assertEquals(expectedEvents.size, events.size)
+    assertEquals(expectedEvents.size, events.size, "Events size")
     assertContentEquals(
       expectedEvents,
       events,
+      "Evens content",
     )
 
     otherAssertions?.invoke()