Refactor: renamed all episodes use case.

hypeapps · Apr 28, 2018 · 8956355 · 8956355
1 parent 23ed93c
commit 8956355
Show file tree

Hide file tree

Showing 5 changed files with 14 additions and 52 deletions.
diff --git a/domain/src/main/kotlin/pl/hypeapp/domain/usecase/allepisodes/AllEpisodesUseCase.kt b/domain/src/main/kotlin/pl/hypeapp/domain/usecase/allepisodes/AllEpisodesUseCase.kt
diff --git a/...in/src/main/kotlin/pl/hypeapp/domain/usecase/watchstate/UpdateEpisodeWatchStateUseCase.kt b/...in/src/main/kotlin/pl/hypeapp/domain/usecase/watchstate/UpdateEpisodeWatchStateUseCase.kt
@@ -6,20 +6,20 @@ import pl.hypeapp.domain.executor.ThreadExecutor
 import pl.hypeapp.domain.model.WatchState
 import pl.hypeapp.domain.model.tvshow.EpisodeModel
 import pl.hypeapp.domain.repository.WatchedShowRepository
-import pl.hypeapp.domain.usecase.allepisodes.AllEpisodesUseCase
 import pl.hypeapp.domain.usecase.base.AbsRxCompletableUseCase
+import pl.hypeapp.domain.usecase.gettvshow.GetTvShowExtendedUseCase
 import pl.hypeapp.domain.usecase.watchstate.mapwatched.MapTvShowWatchStateUseCase
 import javax.inject.Inject
 
 class UpdateEpisodeWatchStateUseCase @Inject constructor(threadExecutor: ThreadExecutor,
                                                          postExecutionThread: PostExecutionThread,
-                                                         private val allEpisodesUseCase: AllEpisodesUseCase,
+                                                         private val getTvShowExtendedUseCase: GetTvShowExtendedUseCase,
                                                          private val mapTvShowWatchStateUseCase: MapTvShowWatchStateUseCase,
                                                          private val showRepository: WatchedShowRepository)
     : AbsRxCompletableUseCase<UpdateEpisodeWatchStateUseCase.Params>(threadExecutor, postExecutionThread) {
 
     override fun createCompletable(params: Params): Completable {
-        return allEpisodesUseCase.execute(AllEpisodesUseCase.Params.createQuery(params.episodeModel.tvShowId!!, false))
+        return getTvShowExtendedUseCase.execute(GetTvShowExtendedUseCase.Params.createQuery(params.episodeModel.tvShowId!!, false))
                 .flatMap { mapTvShowWatchStateUseCase.execute(MapTvShowWatchStateUseCase.Params.createParams(it)) }
                 .flatMapCompletable {
                     with(params) {

diff --git a/domain/src/main/kotlin/pl/hypeapp/domain/usecase/watchstate/UpdateSeasonWatchStateUseCase.kt b/domain/src/main/kotlin/pl/hypeapp/domain/usecase/watchstate/UpdateSeasonWatchStateUseCase.kt
@@ -6,20 +6,20 @@ import pl.hypeapp.domain.executor.ThreadExecutor
 import pl.hypeapp.domain.model.WatchState
 import pl.hypeapp.domain.model.tvshow.SeasonModel
 import pl.hypeapp.domain.repository.WatchedShowRepository
-import pl.hypeapp.domain.usecase.allepisodes.AllEpisodesUseCase
 import pl.hypeapp.domain.usecase.base.AbsRxCompletableUseCase
+import pl.hypeapp.domain.usecase.gettvshow.GetTvShowExtendedUseCase
 import pl.hypeapp.domain.usecase.watchstate.mapwatched.MapTvShowWatchStateUseCase
 import javax.inject.Inject
 
 class UpdateSeasonWatchStateUseCase @Inject constructor(threadExecutor: ThreadExecutor,
                                                         postExecutionThread: PostExecutionThread,
-                                                        private val allEpisodesUseCase: AllEpisodesUseCase,
+                                                        private val getTvShowExtendedUseCase: GetTvShowExtendedUseCase,
                                                         private val mapTvShowWatchStateUseCase: MapTvShowWatchStateUseCase,
                                                         private val showRepository: WatchedShowRepository)
     : AbsRxCompletableUseCase<UpdateSeasonWatchStateUseCase.Params>(threadExecutor, postExecutionThread) {
 
     override fun createCompletable(params: Params): Completable {
-        return allEpisodesUseCase.execute(AllEpisodesUseCase.Params.createQuery(params.seasonModel.tvShowId!!, false))
+        return getTvShowExtendedUseCase.execute(GetTvShowExtendedUseCase.Params.createQuery(params.seasonModel.tvShowId!!, false))
                 .flatMap { mapTvShowWatchStateUseCase.execute(MapTvShowWatchStateUseCase.Params.createParams(it)) }
                 .flatMapCompletable {
                     if (params.addToWatched) {

diff --git a/...src/main/kotlin/pl/hypeapp/domain/usecase/watchstate/UpdateTvShowWatchStateByIdUseCase.kt b/...src/main/kotlin/pl/hypeapp/domain/usecase/watchstate/UpdateTvShowWatchStateByIdUseCase.kt
@@ -3,19 +3,19 @@ package pl.hypeapp.domain.usecase.watchstate
 import io.reactivex.Completable
 import pl.hypeapp.domain.executor.PostExecutionThread
 import pl.hypeapp.domain.executor.ThreadExecutor
-import pl.hypeapp.domain.usecase.allepisodes.AllEpisodesUseCase
 import pl.hypeapp.domain.usecase.base.AbsRxCompletableUseCase
+import pl.hypeapp.domain.usecase.gettvshow.GetTvShowExtendedUseCase
 import javax.inject.Inject
 
 class UpdateTvShowWatchStateByIdUseCase @Inject constructor(threadExecutor: ThreadExecutor,
                                                             postExecutionThread: PostExecutionThread,
-                                                            private val allEpisodesUseCase: AllEpisodesUseCase,
+                                                            private val getTvShowExtendedUseCase: GetTvShowExtendedUseCase,
                                                             private val updateTvShowWatchStateUseCase: UpdateTvShowWatchStateUseCase)
     : AbsRxCompletableUseCase<UpdateTvShowWatchStateByIdUseCase.Params>(threadExecutor, postExecutionThread) {
 
     override fun createCompletable(params: UpdateTvShowWatchStateByIdUseCase.Params): Completable {
-        return allEpisodesUseCase
-                .execute(AllEpisodesUseCase.Params.createQuery(params.tvShowId, update = false))
+        return getTvShowExtendedUseCase
+                .execute(GetTvShowExtendedUseCase.Params.createQuery(params.tvShowId, update = false))
                 .flatMapCompletable {
                     updateTvShowWatchStateUseCase.execute(UpdateTvShowWatchStateUseCase.Params.createParams(it, params.addToWatched))
                 }

diff --git a/domain/src/test/kotlin/pl/hypeapp/domain/usecase/allepisodes/AllEpisodesUseCaseTest.kt b/domain/src/test/kotlin/pl/hypeapp/domain/usecase/allepisodes/AllEpisodesUseCaseTest.kt
@@ -11,11 +11,12 @@ import pl.hypeapp.domain.executor.PostExecutionThread
 import pl.hypeapp.domain.executor.ThreadExecutor
 import pl.hypeapp.domain.model.tvshow.TvShowExtendedModel
 import pl.hypeapp.domain.repository.AllSeasonsRepository
+import pl.hypeapp.domain.usecase.gettvshow.GetTvShowExtendedUseCase
 import pl.hypeapp.domain.usecase.watchstate.mapwatched.WatchStateMapper
 
 class AllEpisodesUseCaseTest {
 
-    private lateinit var useCase: AllEpisodesUseCase
+    private lateinit var useCase: GetTvShowExtendedUseCase
 
     private val repository: AllSeasonsRepository = mock()
 
@@ -32,12 +33,12 @@ class AllEpisodesUseCaseTest {
 
     @Before
     fun setUp() {
-        useCase = AllEpisodesUseCase(threadExecutor, postExecutionThread, watchStateMapper, repository)
+        useCase = GetTvShowExtendedUseCase(threadExecutor, postExecutionThread, watchStateMapper, repository)
     }
 
     @Test
     fun `should get all seasons`() {
-        val params: AllEpisodesUseCase.Params = AllEpisodesUseCase.Params.createQuery(ID, UPDATE)
+        val params: GetTvShowExtendedUseCase.Params = GetTvShowExtendedUseCase.Params.createQuery(ID, UPDATE)
         val tvShowExtendedModel: TvShowExtendedModel = mock()
         val returnedSingle: Single<TvShowExtendedModel> = Single.just(tvShowExtendedModel)
         given(repository.getAllSeasonsAfterPremiereDate(ID, UPDATE)).willReturn(returnedSingle)