Add posts

Author: hoc081098

app/src/main/java/com/hoc/pagination_mvi/data/PostRepositoryImpl.kt

@@ -0,0 +1,31 @@
+package com.hoc.pagination_mvi.data
+
+import com.hoc.pagination_mvi.data.remote.ApiService
+import com.hoc.pagination_mvi.di.ApplicationScope
+import com.hoc.pagination_mvi.domain.dispatchers_schedulers.CoroutinesDispatchersProvider
+import com.hoc.pagination_mvi.domain.entity.Photo
+import com.hoc.pagination_mvi.domain.entity.Post
+import com.hoc.pagination_mvi.domain.repository.PhotoRepository
+import com.hoc.pagination_mvi.domain.repository.PostRepository
+import kotlinx.coroutines.withContext
+import javax.inject.Inject
+
+@ApplicationScope
+class PostRepositoryImpl @Inject constructor(
+  private val apiService: ApiService,
+  private val dispatchersProvider: CoroutinesDispatchersProvider
+) : PostRepository {
+  override suspend fun getPosts(start: Int, limit: Int): List<Post> {
+    return withContext(dispatchersProvider.io) {
+      apiService.getPosts(start = start, limit = limit).map {
+        Post(
+          body = it.body,
+          title = it.title,
+          id = it.id,
+          userId = it.userId
+        )
+      }
+    }
+  }
+
+}

app/src/main/java/com/hoc/pagination_mvi/data/remote/ApiService.kt

@@ -14,6 +14,12 @@ interface ApiService {
     @Query("_limit") limit: Int
   ): List<PhotoResponse>
 
+  @GET("posts")
+  suspend fun getPosts(
+    @Query("_start") start: Int,
+    @Query("_limit") limit: Int
+  ): List<PostResponse>
+
   companion object {
     operator fun invoke(retrofit: Retrofit) = retrofit.create<ApiService>()
   }

app/src/main/java/com/hoc/pagination_mvi/data/remote/PostResponse.kt

@@ -0,0 +1,14 @@
+package com.hoc.pagination_mvi.data.remote
+
+import com.squareup.moshi.Json
+
+data class PostResponse(
+  @Json(name = "body")
+  val body: String, // cupiditate quo est a modi nesciunt solutaipsa voluptas error itaque dicta inautem qui minus magnam et distinctio eumaccusamus ratione error aut
+  @Json(name = "id")
+  val id: Int, // 100
+  @Json(name = "title")
+  val title: String, // at nam consequatur ea labore ea harum
+  @Json(name = "userId")
+  val userId: Int // 10
+)

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

@@ -1,11 +1,13 @@
 package com.hoc.pagination_mvi.di.modules
 
 import com.hoc.pagination_mvi.data.PhotoRepositoryImpl
+import com.hoc.pagination_mvi.data.PostRepositoryImpl
 import com.hoc.pagination_mvi.domain.dispatchers_schedulers.CoroutinesDispatchersProvider
 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.domain.repository.PhotoRepository
+import com.hoc.pagination_mvi.domain.repository.PostRepository
 import dagger.Binds
 import dagger.Module
 
@@ -20,4 +22,7 @@ interface DomainModule {
 
   @Binds
   fun providePhotoRepository(photoRepositoryImpl: PhotoRepositoryImpl): PhotoRepository
+
+  @Binds
+  fun providePostRepository(postRepositoryImpl: PostRepositoryImpl): PostRepository
 }

app/src/main/java/com/hoc/pagination_mvi/domain/entity/Post.kt

@@ -0,0 +1,8 @@
+package com.hoc.pagination_mvi.domain.entity
+
+data class Post(
+  val body: String, // cupiditate quo est a modi nesciunt solutaipsa voluptas error itaque dicta inautem qui minus magnam et distinctio eumaccusamus ratione error aut
+  val id: Int, // 100
+  val title: String, // at nam consequatur ea labore ea harum
+  val userId: Int // 10
+)

app/src/main/java/com/hoc/pagination_mvi/domain/repository/PostRepository.kt

@@ -0,0 +1,10 @@
+package com.hoc.pagination_mvi.domain.repository
+
+import com.hoc.pagination_mvi.domain.entity.Post
+
+interface PostRepository {
+  suspend fun getPosts(
+    start: Int,
+    limit: Int
+  ): List<Post>
+}

app/src/main/java/com/hoc/pagination_mvi/domain/usecase/GetPostsUseCase.kt

@@ -0,0 +1,17 @@
+package com.hoc.pagination_mvi.domain.usecase
+
+import com.hoc.pagination_mvi.di.ApplicationScope
+import com.hoc.pagination_mvi.domain.entity.Photo
+import com.hoc.pagination_mvi.domain.entity.Post
+import com.hoc.pagination_mvi.domain.repository.PhotoRepository
+import com.hoc.pagination_mvi.domain.repository.PostRepository
+import javax.inject.Inject
+
+@ApplicationScope
+class GetPostsUseCase @Inject constructor(
+  private val postRepository: PostRepository
+) {
+  suspend operator fun invoke(start: Int, limit: Int): List<Post> {
+    return postRepository.getPosts(start = start, limit = limit)
+  }
+}

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

@@ -1,17 +1,21 @@
 package com.hoc.pagination_mvi.ui.main
 
+import com.hoc.pagination_mvi.di.ApplicationScope
 import com.hoc.pagination_mvi.domain.dispatchers_schedulers.CoroutinesDispatchersProvider
 import com.hoc.pagination_mvi.domain.usecase.GetPhotosUseCase
+import com.hoc.pagination_mvi.domain.usecase.GetPostsUseCase
 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
 
+@ApplicationScope
 @ExperimentalCoroutinesApi
 class MainInteractorImpl @Inject constructor(
   private val getPhotosUseCase: GetPhotosUseCase,
+  private val getPostsUseCase: GetPostsUseCase,
   private val dispatchers: CoroutinesDispatchersProvider
 ) : MainContract.Interactor {
   override fun photoNextPageChanges(

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

@@ -6,6 +6,7 @@ import androidx.lifecycle.ViewModel
 import androidx.lifecycle.distinctUntilChanged
 import com.hoc.pagination_mvi.asObservable
 import com.hoc.pagination_mvi.domain.dispatchers_schedulers.CoroutinesDispatchersProvider
+import com.hoc.pagination_mvi.domain.dispatchers_schedulers.RxSchedulerProvider
 import com.hoc.pagination_mvi.domain.usecase.GetPhotosUseCase
 import com.hoc.pagination_mvi.exhaustMap
 import com.hoc.pagination_mvi.ui.main.MainContract.*
@@ -26,7 +27,8 @@ import javax.inject.Inject
 
 @ExperimentalCoroutinesApi
 class MainVM @Inject constructor(
-  private val interactor: Interactor
+  private val interactor: Interactor,
+  private val rxSchedulerProvider: RxSchedulerProvider
 ) : ViewModel() {
   private val initial = ViewState.initial()
   private val _stateD = MutableLiveData<ViewState>().apply { value = initial }
@@ -85,7 +87,7 @@ class MainVM @Inject constructor(
     intentS
       .compose(intentFilter)
       .compose(toPartialStateChange)
-      .observeOn(AndroidSchedulers.mainThread())
+      .observeOn(rxSchedulerProvider.main)
       .scan(initial) { vs, change -> change.reduce(vs) }
       .subscribe(stateS::onNext)
       .addTo(compositeDisposable)