[ISSUE-68] Adding new endpoint to fetch youtube video meta data

Author: gabrielbmoro

build.gradle.kts

@@ -1,3 +1,5 @@
+import java.net.URI
+
 @Suppress("DSL_SCOPE_VIOLATION")
 plugins {
     alias(libs.plugins.android.application) apply false
@@ -13,5 +15,8 @@ allprojects {
     repositories {
         google()
         mavenCentral()
+        maven {
+            url = URI.create("https://jitpack.io")
+        }
     }
 }

feature-list-streams/src/main/java/com/codandotv/streamplayerapp/feature_list_streams/detail/data/DetailStreamRepository.kt

@@ -2,17 +2,23 @@ package com.codandotv.streamplayerapp.feature_list_streams.detail.data
 
 import com.codandotv.streamplayerapp.core_networking.handleError.toFlow
 import com.codandotv.streamplayerapp.feature_list_streams.detail.domain.DetailStream
+import com.codandotv.streamplayerapp.feature_list_streams.detail.domain.VideoStream
 import com.codandotv.streamplayerapp.feature_list_streams.detail.domain.toDetailStream
+import com.codandotv.streamplayerapp.feature_list_streams.detail.domain.toVideoStreams
 import kotlinx.coroutines.flow.Flow
+import kotlinx.coroutines.flow.first
+import kotlinx.coroutines.flow.firstOrNull
 import kotlinx.coroutines.flow.map
 
 interface DetailStreamRepository {
-    suspend fun getMovie() : Flow<DetailStream>
+    suspend fun getMovie(): Flow<DetailStream>
+
+    suspend fun getVideoStreams(): Flow<List<VideoStream>>
 }
 
 class DetailStreamRepositoryImpl(
     private val movieId: String,
-    private val service : DetailStreamService
+    private val service: DetailStreamService
 ) : DetailStreamRepository {
 
     override suspend fun getMovie(): Flow<DetailStream> =
@@ -21,4 +27,11 @@ class DetailStreamRepositoryImpl(
             .map {
                 it.toDetailStream()
             }
+
+    override suspend fun getVideoStreams(): Flow<List<VideoStream>> =
+        service.getVideoStreams(movieId)
+            .toFlow()
+            .map {
+                it.toVideoStreams()
+            }
 }

feature-list-streams/src/main/java/com/codandotv/streamplayerapp/feature_list_streams/detail/data/DetailStreamService.kt

@@ -2,10 +2,14 @@ package com.codandotv.streamplayerapp.feature_list_streams.detail.data
 
 import com.codandotv.streamplayerapp.core_networking.handleError.NetworkResponse
 import com.codandotv.streamplayerapp.feature_list_streams.detail.data.model.DetailStreamResponse
+import com.codandotv.streamplayerapp.feature_list_streams.detail.data.model.VideoStreamsResponse
 import retrofit2.http.GET
 import retrofit2.http.Path
 
 interface DetailStreamService {
     @GET("movie/{movie_id}")
-    suspend fun getMovie(@Path("movie_id") movieId: String) : NetworkResponse<DetailStreamResponse>
+    suspend fun getMovie(@Path("movie_id") movieId: String): NetworkResponse<DetailStreamResponse>
+
+    @GET("movie/{movie_id}/videos")
+    suspend fun getVideoStreams(@Path("movie_id") movieId: String): NetworkResponse<VideoStreamsResponse>
 }

feature-list-streams/src/main/java/com/codandotv/streamplayerapp/feature_list_streams/detail/data/model/VideoStreamResponse.kt

@@ -0,0 +1,16 @@
+package com.codandotv.streamplayerapp.feature_list_streams.detail.data.model
+
+data class VideoStreamResponse(
+    val id: String,
+    val name: String,
+    val key: String,
+    val site: String,
+    val size: Int,
+    val official: Boolean,
+    val type: String,
+)
+
+data class VideoStreamsResponse(
+    val id: Long,
+    val results: List<VideoStreamResponse>
+)

feature-list-streams/src/main/java/com/codandotv/streamplayerapp/feature_list_streams/detail/di/DetailStreamModule.kt

@@ -5,6 +5,8 @@ import com.codandotv.streamplayerapp.feature_list_streams.detail.data.DetailStre
 import com.codandotv.streamplayerapp.feature_list_streams.detail.data.DetailStreamService
 import com.codandotv.streamplayerapp.feature_list_streams.detail.domain.DetailStreamUseCase
 import com.codandotv.streamplayerapp.feature_list_streams.detail.domain.DetailStreamUseCaseImpl
+import com.codandotv.streamplayerapp.feature_list_streams.detail.domain.VideoStreamsUseCase
+import com.codandotv.streamplayerapp.feature_list_streams.detail.domain.VideoStreamsUseCaseImpl
 import com.codandotv.streamplayerapp.feature_list_streams.detail.presentation.screens.DetailStreamViewModel
 import org.koin.androidx.viewmodel.dsl.viewModel
 import org.koin.core.parameter.parametersOf
@@ -15,7 +17,10 @@ object DetailStreamModule {
     val module = module {
         viewModel { (id: String) ->
             DetailStreamViewModel(
-                useCase = get {
+                detailStreamUseCase = get {
+                    parametersOf(id)
+                },
+                videoStreamsUseCase = get {
                     parametersOf(id)
                 }
             )
@@ -27,6 +32,13 @@ object DetailStreamModule {
                 }
             )
         }
+        factory<VideoStreamsUseCase> { (id: String) ->
+            VideoStreamsUseCaseImpl(
+                detailStreamRepository = get {
+                    parametersOf(id)
+                }
+            )
+        }
         factory<DetailStreamRepository> { (id: String) ->
             DetailStreamRepositoryImpl(
                 service = get(),

feature-list-streams/src/main/java/com/codandotv/streamplayerapp/feature_list_streams/detail/domain/DetailStreamMapper.kt

@@ -2,6 +2,7 @@ package com.codandotv.streamplayerapp.feature_list_streams.detail.domain
 
 import com.codandotv.streamplayerapp.core_networking.Url.IMAGE_URL_SIZE_500
 import com.codandotv.streamplayerapp.feature_list_streams.detail.data.model.DetailStreamResponse
+import com.codandotv.streamplayerapp.feature_list_streams.detail.data.model.VideoStreamsResponse
 
 fun DetailStreamResponse.toDetailStream(): DetailStream =
     DetailStream(
@@ -11,4 +12,12 @@ fun DetailStreamResponse.toDetailStream(): DetailStream =
         tagline = this.tagline,
         url = "$IMAGE_URL_SIZE_500${this.backdrop_path}",
         releaseYear = this.release_date.substring(0, 4)
-    )
+    )
+
+fun VideoStreamsResponse.toVideoStreams(): List<VideoStream> =
+    results.map {
+        VideoStream(
+            youtubeUrl = "http://youtube.com/watch?v=".plus(it.key),
+            movieId = this.id
+        )
+    }

feature-list-streams/src/main/java/com/codandotv/streamplayerapp/feature_list_streams/detail/domain/VideoStream.kt

@@ -0,0 +1,6 @@
+package com.codandotv.streamplayerapp.feature_list_streams.detail.domain
+
+data class VideoStream(
+    val movieId: Long,
+    val youtubeUrl: String,
+)

feature-list-streams/src/main/java/com/codandotv/streamplayerapp/feature_list_streams/detail/domain/VideoStreamsUseCase.kt

@@ -0,0 +1,16 @@
+package com.codandotv.streamplayerapp.feature_list_streams.detail.domain
+
+import com.codandotv.streamplayerapp.feature_list_streams.detail.data.DetailStreamRepository
+import kotlinx.coroutines.flow.Flow
+
+interface VideoStreamsUseCase {
+    suspend fun getVideoStreams(): Flow<List<VideoStream>>
+}
+
+class VideoStreamsUseCaseImpl(
+    private val detailStreamRepository: DetailStreamRepository
+) : VideoStreamsUseCase {
+    override suspend fun getVideoStreams(): Flow<List<VideoStream>> {
+        return detailStreamRepository.getVideoStreams()
+    }
+}

feature-list-streams/src/main/java/com/codandotv/streamplayerapp/feature_list_streams/detail/presentation/screens/DetailStreamViewModel.kt

@@ -6,21 +6,24 @@ import androidx.lifecycle.ViewModel
 import androidx.lifecycle.viewModelScope
 import com.codandotv.streamplayerapp.core_networking.handleError.catchFailure
 import com.codandotv.streamplayerapp.feature_list_streams.detail.domain.DetailStreamUseCase
+import com.codandotv.streamplayerapp.feature_list_streams.detail.domain.VideoStreamsUseCase
 import com.codandotv.streamplayerapp.feature_list_streams.detail.presentation.screens.DetailStreamsUIState.*
 import kotlinx.coroutines.flow.MutableStateFlow
 import kotlinx.coroutines.flow.SharingStarted
 import kotlinx.coroutines.flow.StateFlow
 import kotlinx.coroutines.flow.onStart
 import kotlinx.coroutines.flow.stateIn
 import kotlinx.coroutines.flow.update
+import kotlinx.coroutines.flow.zip
 import kotlinx.coroutines.launch
 
 class DetailStreamViewModel(
-    private val useCase: DetailStreamUseCase,
+    private val detailStreamUseCase: DetailStreamUseCase,
+    private val videoStreamsUseCase: VideoStreamsUseCase,
 ) : ViewModel(), DefaultLifecycleObserver {
 
     private val _uiState = MutableStateFlow<DetailStreamsUIState>(LoadingStreamUIState)
-    val uiState : StateFlow<DetailStreamsUIState> = _uiState.stateIn(
+    val uiState: StateFlow<DetailStreamsUIState> = _uiState.stateIn(
         viewModelScope,
         SharingStarted.Eagerly,
         initialValue = _uiState.value
@@ -30,16 +33,20 @@ class DetailStreamViewModel(
         super.onCreate(owner)
 
         viewModelScope.launch {
-            useCase.getMovie()
+            detailStreamUseCase.getMovie()
+                .zip(videoStreamsUseCase.getVideoStreams()) { detailStream, videoUrl ->
+                    DetailStreamsLoadedUIState(
+                        detailStream = detailStream,
+                        videoUrl = videoUrl.firstOrNull()?.youtubeUrl
+                    )
+                }
                 .onStart { onLoading() }
                 .catchFailure {
                     println(">>>> ${it.errorMessage}")
                 }
-                .collect { detailStream ->
+                .collect { result ->
                     _uiState.update {
-                        DetailStreamsLoadedUIState(
-                            detailStream = detailStream
-                        )
+                        result
                     }
                 }
         }

feature-list-streams/src/main/java/com/codandotv/streamplayerapp/feature_list_streams/detail/presentation/screens/DetailStreamsUIState.kt

@@ -5,6 +5,7 @@ import com.codandotv.streamplayerapp.feature_list_streams.detail.domain.DetailSt
 sealed class DetailStreamsUIState {
     data class DetailStreamsLoadedUIState(
         val detailStream: DetailStream,
+        val videoUrl: String?,
     ) : DetailStreamsUIState()
 
     object LoadingStreamUIState : DetailStreamsUIState()