Merge pull request #36 from THEOplayer/maintenance/uplynk-refactoring

Maintenance/uplynk refactoring
THEOplayer · Sep 27, 2024 · 38904d9 · 38904d9
2 parents e5bbec2 + ddd5ab5
commit 38904d9
Show file tree

Hide file tree

Showing 5 changed files with 349 additions and 61 deletions.
diff --git a/...ectors/uplynk/src/main/java/com/theoplayer/android/connector/uplynk/internal/AdHandler.kt b/...ectors/uplynk/src/main/java/com/theoplayer/android/connector/uplynk/internal/AdHandler.kt
@@ -10,24 +10,21 @@ import java.util.WeakHashMap
 import kotlin.time.Duration
 import kotlin.time.DurationUnit
 
-private val Duration.secToMs: Int
-    get() = this.toInt(DurationUnit.MILLISECONDS)
-
 @Suppress("UnstableApiUsage")
 internal class AdHandler(private val controller: ServerSideAdIntegrationController) {
     private val scheduledAds = WeakHashMap<UplynkAd, Ad>()
 
     fun createAdBreak(adBreak: UplynkAdBreak) {
         val adBreakInit = AdBreakInit(
-            timeOffset = adBreak.timeOffset.secToMs,
-            maxDuration = adBreak.duration.secToMs,
+            timeOffset = adBreak.timeOffset.inWholeSeconds.toInt(),
+            maxDuration = adBreak.duration.inWholeSeconds.toInt(),
             customData = adBreak
         )
         val currentAdBreak = controller.createAdBreak(adBreakInit)
         adBreak.ads.forEach {
             val adInit = AdInit(
                 type = adBreak.type,
-                duration = it.duration.secToMs,
+                duration = it.duration.inWholeSeconds.toInt(),
                 customData = it
             )
             scheduledAds[it] = controller.createAd(adInit, currentAdBreak)
@@ -61,5 +58,4 @@ internal class AdHandler(private val controller: ServerSideAdIntegrationControll
 
         controller.updateAdProgress(ad, progress)
     }
-
 }
diff --git a/...n/java/com/theoplayer/android/connector/uplynk/internal/UplynkSsaiDescriptionConverter.kt b/...n/java/com/theoplayer/android/connector/uplynk/internal/UplynkSsaiDescriptionConverter.kt
@@ -1,6 +1,5 @@
 package com.theoplayer.android.connector.uplynk.internal
 
-import com.theoplayer.android.connector.uplynk.UplynkAssetType
 import com.theoplayer.android.connector.uplynk.UplynkSsaiDescription
 import kotlin.time.Duration
 
@@ -10,59 +9,15 @@ internal class UplynkSsaiDescriptionConverter {
     fun buildPreplayVodUrl(ssaiDescription: UplynkSsaiDescription): String = with(ssaiDescription) {
         val prefix = prefix ?: DEFAULT_PREFIX
 
-        var url = "$prefix/preplay/$urlAssetId?v=2"
-        if (ssaiDescription.contentProtected) {
-            url += "&manifest=mpd"
-            url += "&rmt=wv"
-        }
-
-        url += "&$pingParameters&$urlParameters"
-
-        return url
+        return "$prefix/preplay/$urlAssetId?v=2$drmParameters$pingParameters$urlParameters"
     }
 
     fun buildPreplayLiveUrl(ssaiDescription: UplynkSsaiDescription): String = with(ssaiDescription) {
         val prefix = prefix ?: DEFAULT_PREFIX
 
-        var url = "$prefix/preplay/$urlAssetType/$urlAssetId?v=2"
-        if (ssaiDescription.contentProtected) {
-            url += "&manifest=mpd"
-            url += "&rmt=wv"
-        }
-
-        url += "&$pingParameters&$urlParameters"
-
-        return url
+        return "$prefix/preplay/$urlAssetType/$urlAssetId?v=2$drmParameters$pingParameters$urlParameters"
     }
 
-    private val UplynkSsaiDescription.urlParameters
-        get() = preplayParameters.map { "${it.key}=${it.value}" }.joinToString("&")
-
-    private val UplynkSsaiDescription.pingParameters: String
-        get() {
-            val feature = UplynkPingFeatures.from(this)
-            return if (feature == UplynkPingFeatures.NO_PING) {
-                "ad.pingc=0"
-            } else {
-                "ad.pingc=1&ad.pingf=${feature.pingfValue}"
-            }
-        }
-
-    private val UplynkSsaiDescription.urlAssetType
-        get() = when (assetType) {
-            UplynkAssetType.ASSET -> ""
-            UplynkAssetType.CHANNEL -> "channel"
-            UplynkAssetType.EVENT -> "event"
-        }
-
-    private val UplynkSsaiDescription.urlAssetId
-        get() = when {
-            assetIds.isEmpty() && externalIds.size == 1 -> "$userId/${externalIds.first()}.json"
-            assetIds.isEmpty() && externalIds.size > 1 -> "$userId/${externalIds.joinToString(",")}/multiple.json"
-            assetIds.size == 1 -> "${assetIds.first()}.json"
-            else -> assetIds.joinToString(separator = ",") + "/multiple.json"
-        }
-
     fun buildAssetInfoUrls(
         ssaiDescription: UplynkSsaiDescription,
         sessionId: String,

diff --git a/...va/com/theoplayer/android/connector/uplynk/internal/UplynkSsaiDescriptionUrlExtensions.kt b/...va/com/theoplayer/android/connector/uplynk/internal/UplynkSsaiDescriptionUrlExtensions.kt
@@ -0,0 +1,43 @@
+package com.theoplayer.android.connector.uplynk.internal
+
+import com.theoplayer.android.connector.uplynk.UplynkAssetType
+import com.theoplayer.android.connector.uplynk.UplynkSsaiDescription
+
+internal val UplynkSsaiDescription.drmParameters: String
+    get() = if (contentProtected) {
+        "&manifest=mpd&rmt=wv"
+    } else {
+        ""
+    }
+
+internal val UplynkSsaiDescription.urlParameters
+    get() = if (preplayParameters.isNotEmpty()) {
+        preplayParameters.map { "${it.key}=${it.value}" }.joinToString("&", prefix = "&")
+    } else {
+        ""
+    }
+
+internal val UplynkSsaiDescription.pingParameters: String
+    get() {
+        val feature = UplynkPingFeatures.from(this)
+        return if (feature == UplynkPingFeatures.NO_PING) {
+            "&ad.pingc=0"
+        } else {
+            "&ad.pingc=1&ad.pingf=${feature.pingfValue}"
+        }
+    }
+
+internal val UplynkSsaiDescription.urlAssetType
+    get() = when (assetType) {
+        UplynkAssetType.ASSET -> ""
+        UplynkAssetType.CHANNEL -> "channel"
+        UplynkAssetType.EVENT -> "event"
+    }
+
+internal val UplynkSsaiDescription.urlAssetId
+    get() = when {
+        assetIds.isEmpty() && externalIds.size == 1 -> "$userId/${externalIds.first()}.json"
+        assetIds.isEmpty() && externalIds.size > 1 -> "$userId/${externalIds.joinToString(",")}/multiple.json"
+        assetIds.size == 1 -> "${assetIds.first()}.json"
+        else -> assetIds.joinToString(separator = ",") + "/multiple.json"
+    }