wip

Author: hoc081098

.idea/dictionaries/Admin.xml

@@ -18,7 +18,6 @@ interface DomainModule {
   @Binds
   fun provideCoroutinesDispatchersProvider(coroutinesDispatchersProviderImpl: CoroutinesDispatchersProviderImpl): CoroutinesDispatchersProvider
 
-
   @Binds
   fun providePhotoRepository(photoRepositoryImpl: PhotoRepositoryImpl): PhotoRepository
 }

app/src/main/java/com/hoc/pagination_mvi/di/modules/DomainModule.kt

@@ -8,13 +8,18 @@ import com.hoc.pagination_mvi.domain.dispatchers_schedulers.CoroutinesDispatcher
 import com.hoc.pagination_mvi.domain.dispatchers_schedulers.CoroutinesDispatchersProviderImpl
 import com.hoc.pagination_mvi.domain.dispatchers_schedulers.RxSchedulerProvider
 import com.hoc.pagination_mvi.domain.dispatchers_schedulers.RxSchedulerProviderImpl
+import com.hoc.pagination_mvi.ui.main.MainContract
+import com.hoc.pagination_mvi.ui.main.MainInteractorImpl
 import com.hoc.pagination_mvi.ui.main.MainVM
 import dagger.Binds
 import dagger.Module
 import dagger.multibindings.IntoMap
 
 @Module
 abstract class ViewModelModule {
+  @Binds
+  abstract fun provideMainInteractor(mainInteractorImpl: MainInteractorImpl): MainContract.Interactor
+
   @Binds
   abstract fun provideVMFactory(appViewModelFactory: AppViewModelFactory): ViewModelProvider.Factory
 

app/src/main/java/com/hoc/pagination_mvi/di/modules/ViewModelModule.kt

@@ -2,6 +2,7 @@ package com.hoc.pagination_mvi.ui.main
 
 import androidx.annotation.LayoutRes
 import com.hoc.pagination_mvi.R
+import io.reactivex.Observable
 import com.hoc.pagination_mvi.domain.entity.Photo as PhotoDomain
 
 interface MainContract {
@@ -158,4 +159,9 @@ interface MainContract {
   sealed class SingleEvent {
 
   }
+
+  interface Interactor {
+    fun photoNextPageChanges(start: Int, limit: Int): Observable<PartialStateChange.PhotoNextPage>
+    fun photoFirstPageChanges(limit: Int): Observable<PartialStateChange.PhotoFirstPage>
+  }
 }

app/src/main/java/com/hoc/pagination_mvi/ui/main/MainContract.kt

@@ -0,0 +1,48 @@
+package com.hoc.pagination_mvi.ui.main
+
+import com.hoc.pagination_mvi.domain.dispatchers_schedulers.CoroutinesDispatchersProvider
+import com.hoc.pagination_mvi.domain.usecase.GetPhotosUseCase
+import com.hoc.pagination_mvi.ui.main.MainContract.PhotoVS
+import io.reactivex.Observable
+import kotlinx.coroutines.ExperimentalCoroutinesApi
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.rx2.rxObservable
+import javax.inject.Inject
+
+@ExperimentalCoroutinesApi
+class MainInteractorImpl @Inject constructor(
+  private val getPhotosUseCase: GetPhotosUseCase,
+  private val dispatchers: CoroutinesDispatchersProvider
+) : MainContract.Interactor {
+  override fun photoNextPageChanges(
+    start: Int,
+    limit: Int
+  ): Observable<MainContract.PartialStateChange.PhotoNextPage> {
+    return rxObservable(dispatchers.main) {
+      send(MainContract.PartialStateChange.PhotoNextPage.Loading)
+      try {
+        getPhotosUseCase(start = start, limit = limit)
+          .map(MainContract::PhotoVS)
+          .let { MainContract.PartialStateChange.PhotoNextPage.Data(it) }
+          .let { send(it) }
+      } catch (e: Exception) {
+        delay(1_000)
+        send(MainContract.PartialStateChange.PhotoNextPage.Error(e))
+      }
+    }
+  }
+
+  override fun photoFirstPageChanges(limit: Int): Observable<MainContract.PartialStateChange.PhotoFirstPage> {
+    return rxObservable(dispatchers.main) {
+      send(MainContract.PartialStateChange.PhotoFirstPage.Loading)
+      try {
+        getPhotosUseCase(start = 0, limit = limit)
+          .map(::PhotoVS)
+          .let { MainContract.PartialStateChange.PhotoFirstPage.Data(it) }
+          .let { send(it) }
+      } catch (e: Exception) {
+        send(MainContract.PartialStateChange.PhotoFirstPage.Error(e))
+      }
+    }
+  }
+}

app/src/main/java/com/hoc/pagination_mvi/ui/main/MainInteractorImpl.kt

@@ -26,8 +26,7 @@ import javax.inject.Inject
 
 @ExperimentalCoroutinesApi
 class MainVM @Inject constructor(
-  private val getPhotosUseCase: GetPhotosUseCase,
-  private val dispatchers: CoroutinesDispatchersProvider
+  private val interactor: Interactor
 ) : ViewModel() {
   private val initial = ViewState.initial()
   private val _stateD = MutableLiveData<ViewState>().apply { value = initial }
@@ -46,19 +45,7 @@ class MainVM @Inject constructor(
       intents
         .withLatestFrom(stateObservable)
         .filter { (_, vs) -> vs.photoItems.isEmpty() }
-        .flatMap {
-          rxObservable(dispatchers.main) {
-            send(PartialStateChange.PhotoFirstPage.Loading)
-            try {
-              getPhotosUseCase(start = 0, limit = PAGE_SIZE)
-                .map(::PhotoVS)
-                .let { PartialStateChange.PhotoFirstPage.Data(it) }
-                .let { send(it) }
-            } catch (e: Exception) {
-              send(PartialStateChange.PhotoFirstPage.Error(e))
-            }
-          }
-        }
+        .flatMap { interactor.photoFirstPageChanges(limit = PAGE_SIZE) }
     }
 
   private val nextPageProcessor =
@@ -67,7 +54,7 @@ class MainVM @Inject constructor(
         .withLatestFrom(stateObservable)
         .filter { (_, vs) -> vs.canLoadNextPage() }
         .map { (_, vs) -> vs.photoItems.size }
-        .exhaustMap(::nextPageChanges)
+        .exhaustMap { interactor.photoNextPageChanges(start = it, limit = PAGE_SIZE) }
     }
 
   private val retryLoadPageProcessor =
@@ -76,7 +63,7 @@ class MainVM @Inject constructor(
         .withLatestFrom(stateObservable)
         .filter { (_, vs) -> vs.shouldRetry() }
         .map { (_, vs) -> vs.photoItems.size }
-        .exhaustMap(::nextPageChanges)
+        .exhaustMap { interactor.photoNextPageChanges(start = it, limit = PAGE_SIZE) }
     }
 
   private val toPartialStateChange =
@@ -109,21 +96,6 @@ class MainVM @Inject constructor(
     compositeDisposable.dispose()
   }
 
-  private fun nextPageChanges(start: Int): Observable<PartialStateChange.PhotoNextPage> {
-    return rxObservable(dispatchers.main) {
-      send(PartialStateChange.PhotoNextPage.Loading)
-      try {
-        getPhotosUseCase(start = start, limit = PAGE_SIZE)
-          .map(::PhotoVS)
-          .let { PartialStateChange.PhotoNextPage.Data(it) }
-          .let { send(it) }
-      } catch (e: Exception) {
-        delay(1_000)
-        send(PartialStateChange.PhotoNextPage.Error(e))
-      }
-    }
-  }
-
   private companion object {
     val intentFilter = ObservableTransformer<ViewIntent, ViewIntent> { intents ->
       intents.publish { shared ->