[APT-9543] Add support for DASH streams

Armadillo/build.gradle

@@ -51,6 +51,7 @@ dependencies {
 
     implementation "com.google.android.exoplayer:exoplayer-core:${EXOPLAYER_VERSION}"
     implementation "com.google.android.exoplayer:exoplayer-hls:${EXOPLAYER_VERSION}"
+    implementation "com.google.android.exoplayer:exoplayer-dash:${EXOPLAYER_VERSION}"
     implementation "com.google.android.exoplayer:extension-mediasession:${EXOPLAYER_VERSION}"
 
     implementation "io.reactivex.rxjava2:rxjava:${RXJAVA_VERSION}"

Armadillo/src/main/java/com/scribd/armadillo/download/DownloadEngine.kt

@@ -96,6 +96,8 @@ internal class ExoplayerDownloadEngine @Inject constructor(private val context:
         return when (@C.ContentType val type = Util.inferContentType(uri)) {
             C.TYPE_HLS ->
                 DownloadHelper.forMediaItem(context, mediaItem, renderersFactory, DefaultDataSource.Factory(context, dataSourceFactory))
+            C.TYPE_DASH ->
+                DownloadHelper.forMediaItem(context, mediaItem, renderersFactory, DefaultDataSource.Factory(context, dataSourceFactory))
             C.TYPE_OTHER -> DownloadHelper.forMediaItem(context, mediaItem)
             else -> throw IllegalStateException("Unsupported type: $type")
         }

Armadillo/src/main/java/com/scribd/armadillo/playback/ExoplayerExt.kt

@@ -11,6 +11,7 @@ import com.google.android.exoplayer2.audio.DefaultAudioSink
 import com.google.android.exoplayer2.audio.DefaultAudioSink.DefaultAudioProcessorChain
 import com.google.android.exoplayer2.audio.MediaCodecAudioRenderer
 import com.google.android.exoplayer2.mediacodec.MediaCodecSelector
+import com.google.android.exoplayer2.source.dash.manifest.DashManifest
 import com.google.android.exoplayer2.source.hls.HlsManifest
 import com.scribd.armadillo.Milliseconds
 import com.scribd.armadillo.time.milliseconds
@@ -20,13 +21,12 @@ import com.scribd.armadillo.time.milliseconds
  * During setup, [ExoPlayer.getCurrentManifest] will be null.
  */
 internal fun ExoPlayer.hasProgressAvailable(): Boolean {
-    return (isPlayingHls() && (currentManifest as HlsManifest).mediaPlaylist.durationUs != C.TIME_UNSET)
-        ||
-        (currentManifest == null && !currentTimeline.isEmpty)
+    return when (val m = currentManifest) {
+        is HlsManifest -> m.mediaPlaylist.durationUs != C.TIME_UNSET
+        is DashManifest -> m.durationMs != C.TIME_UNSET
+        else -> m == null && !currentTimeline.isEmpty
+    }
 }
-
-internal fun ExoPlayer.isPlayingHls(): Boolean = currentManifest is HlsManifest
-
 /**
  * Current position in relation to all audio files.
  */

Armadillo/src/main/java/com/scribd/armadillo/playback/mediasource/DashMediaSourceGenerator.kt

@@ -0,0 +1,74 @@
+package com.scribd.armadillo.playback.mediasource
+
+import android.content.Context
+import com.google.android.exoplayer2.MediaItem
+import com.google.android.exoplayer2.offline.Download
+import com.google.android.exoplayer2.offline.DownloadHelper
+import com.google.android.exoplayer2.source.MediaSource
+import com.google.android.exoplayer2.source.dash.DashMediaSource
+import com.google.android.exoplayer2.upstream.DataSource
+import com.google.android.exoplayer2.upstream.DefaultDataSource
+import com.google.android.exoplayer2.upstream.DefaultHttpDataSource
+import com.scribd.armadillo.Constants
+import com.scribd.armadillo.HeadersStore
+import com.scribd.armadillo.download.CacheManager
+import com.scribd.armadillo.download.DownloadTracker
+import com.scribd.armadillo.extensions.toUri
+import com.scribd.armadillo.models.AudioPlayable
+import javax.inject.Inject
+
+internal class DashMediaSourceGenerator @Inject constructor(
+    private val cacheManager: CacheManager,
+    private val headersStore: HeadersStore,
+    private val downloadTracker: DownloadTracker) : MediaSourceGenerator {
+
+    private val previousRequests = mutableMapOf<String, DefaultHttpDataSource.Factory>()
+
+    override fun generateMediaSource(context: Context, request: AudioPlayable.MediaRequest): MediaSource {
+        downloadTracker.getDownload(request.url.toUri())?.let {
+            if (it.state != Download.STATE_FAILED) {
+                return DownloadHelper.createMediaSource(it.request, buildDataSourceFactory(context, request))
+            }
+        }
+
+        val mediaItem = MediaItem.Builder()
+            .setUri(request.url)
+
+            .build()
+
+        return DashMediaSource.Factory(buildDataSourceFactory(context, request))
+            .createMediaSource(mediaItem)
+    }
+
+    override fun updateMediaSourceHeaders(request: AudioPlayable.MediaRequest) {
+        previousRequests[request.url]?.let { factory ->
+            if (request.headers.isNotEmpty()) {
+                headersStore.keyForUrl(request.url)?.let {
+                    headersStore.setHeaders(it, request.headers)
+                }
+                // Updating the factory instance updates future requests generated from this factory by ExoPlayer
+                factory.setDefaultRequestProperties(request.headers)
+            }
+        }
+    }
+
+    private fun buildDataSourceFactory(context: Context, request: AudioPlayable.MediaRequest): DataSource.Factory {
+        val httpDataSourceFactory = DefaultHttpDataSource.Factory()
+            .setUserAgent(Constants.getUserAgent(context))
+            .setConnectTimeoutMs(DefaultHttpDataSource.DEFAULT_CONNECT_TIMEOUT_MILLIS)
+            .setReadTimeoutMs(DefaultHttpDataSource.DEFAULT_READ_TIMEOUT_MILLIS)
+            .setAllowCrossProtocolRedirects(true)
+
+        previousRequests[request.url] = httpDataSourceFactory
+        if (request.headers.isNotEmpty()) {
+            headersStore.keyForUrl(request.url)?.let {
+                headersStore.setHeaders(it, request.headers)
+            }
+            httpDataSourceFactory.setDefaultRequestProperties(request.headers)
+        }
+
+        val upstreamFactory = DefaultDataSource.Factory(context, httpDataSourceFactory)
+        return cacheManager.playbackDataSourceFactory(context, upstreamFactory)
+    }
+
+}

Armadillo/src/main/java/com/scribd/armadillo/playback/mediasource/MediaSourceRetriever.kt

@@ -22,6 +22,9 @@ class MediaSourceRetrieverImpl @Inject constructor(): MediaSourceRetriever {
     @Inject
     internal lateinit var hlsGenerator: HlsMediaSourceGenerator
 
+    @Inject
+    internal lateinit var dashGenerator: DashMediaSourceGenerator
+
     @Inject
     internal lateinit var progressiveMediaSourceGenerator: ProgressiveMediaSourceGenerator
 
@@ -46,6 +49,7 @@ class MediaSourceRetrieverImpl @Inject constructor(): MediaSourceRetriever {
 
         return when (@C.ContentType val type = Util.inferContentType(uri, overrideExtension)) {
             C.TYPE_HLS -> hlsGenerator
+            C.TYPE_DASH -> dashGenerator
             C.TYPE_OTHER -> progressiveMediaSourceGenerator
             else -> throw IllegalStateException("Unsupported type: $type")
         }