Merge branch 'master' into jsdelivr

app/build.gradle.kts

@@ -184,8 +184,8 @@ dependencies {
     //implementation("com.github.TorrentStream:TorrentStream-Android:2.7.0")
 
     // Downloading
-    implementation("androidx.work:work-runtime:2.7.1")
+    implementation("androidx.work:work-runtime:2.8.0")
-    implementation("androidx.work:work-runtime-ktx:2.7.1")
+    implementation("androidx.work:work-runtime-ktx:2.8.0")
 
     // Networking
 //    implementation("com.squareup.okhttp3:okhttp:4.9.2")

app/src/androidTest/java/com/lagradost/cloudstream3/ExampleInstrumentedTest.kt

@@ -1,9 +1,8 @@
 package com.lagradost.cloudstream3
 
 import androidx.test.ext.junit.runners.AndroidJUnit4
-import com.lagradost.cloudstream3.mvvm.logError
-import com.lagradost.cloudstream3.utils.Qualities
 import com.lagradost.cloudstream3.utils.SubtitleHelper
+import com.lagradost.cloudstream3.utils.TestingUtils
 import kotlinx.coroutines.runBlocking
 import org.junit.Assert
 import org.junit.Test
@@ -16,142 +15,11 @@ import org.junit.runner.RunWith
  */
 @RunWith(AndroidJUnit4::class)
 class ExampleInstrumentedTest {
-    //@Test
-    //fun useAppContext() {
-    //    // Context of the app under test.
-    //    val appContext = InstrumentationRegistry.getInstrumentation().targetContext
-    //    assertEquals("com.lagradost.cloudstream3", appContext.packageName)
-    //}
-
     private fun getAllProviders(): List<MainAPI> {
+        println("Providers: ${APIHolder.allProviders.size}")
         return APIHolder.allProviders //.filter { !it.usesWebView }
     }
 
-    private suspend fun loadLinks(api: MainAPI, url: String?): Boolean {
-        Assert.assertNotNull("Api ${api.name} has invalid url on episode", url)
-        if (url == null) return true
-        var linksLoaded = 0
-        try {
-            val success = api.loadLinks(url, false, {}) { link ->
-                Assert.assertTrue(
-                    "Api ${api.name} returns link with invalid Quality",
-                    Qualities.values().map { it.value }.contains(link.quality)
-                )
-                Assert.assertTrue(
-                    "Api ${api.name} returns link with invalid url ${link.url}",
-                    link.url.length > 4
-                )
-                linksLoaded++
-            }
-            if (success) {
-                return linksLoaded > 0
-            }
-            Assert.assertTrue("Api ${api.name} has returns false on .loadLinks", success)
-        } catch (e: Exception) {
-            if (e.cause is NotImplementedError) {
-                Assert.fail("Provider has not implemented .loadLinks")
-            }
-            logError(e)
-        }
-        return true
-    }
-
-    private suspend fun testSingleProviderApi(api: MainAPI): Boolean {
-        val searchQueries = listOf("over", "iron", "guy")
-        var correctResponses = 0
-        var searchResult: List<SearchResponse>? = null
-        for (query in searchQueries) {
-            val response = try {
-                api.search(query)
-            } catch (e: Exception) {
-                if (e.cause is NotImplementedError) {
-                    Assert.fail("Provider has not implemented .search")
-                }
-                logError(e)
-                null
-            }
-            if (!response.isNullOrEmpty()) {
-                correctResponses++
-                if (searchResult == null) {
-                    searchResult = response
-                }
-            }
-        }
-
-        if (correctResponses == 0 || searchResult == null) {
-            System.err.println("Api ${api.name} did not return any valid search responses")
-            return false
-        }
-
-        try {
-            var validResults = false
-            for (result in searchResult) {
-                Assert.assertEquals(
-                    "Invalid apiName on response on ${api.name}",
-                    result.apiName,
-                    api.name
-                )
-                val load = api.load(result.url) ?: continue
-                Assert.assertEquals(
-                    "Invalid apiName on load on ${api.name}",
-                    load.apiName,
-                    result.apiName
-                )
-                Assert.assertTrue(
-                    "Api ${api.name} on load does not contain any of the supportedTypes",
-                    api.supportedTypes.contains(load.type)
-                )
-                when (load) {
-                    is AnimeLoadResponse -> {
-                        val gotNoEpisodes =
-                            load.episodes.keys.isEmpty() || load.episodes.keys.any { load.episodes[it].isNullOrEmpty() }
-
-                        if (gotNoEpisodes) {
-                            println("Api ${api.name} got no episodes on ${load.url}")
-                            continue
-                        }
-
-                        val url = (load.episodes[load.episodes.keys.first()])?.first()?.data
-                        validResults = loadLinks(api, url)
-                        if (!validResults) continue
-                    }
-                    is MovieLoadResponse -> {
-                        val gotNoEpisodes = load.dataUrl.isBlank()
-                        if (gotNoEpisodes) {
-                            println("Api ${api.name} got no movie on ${load.url}")
-                            continue
-                        }
-
-                        validResults = loadLinks(api, load.dataUrl)
-                        if (!validResults) continue
-                    }
-                    is TvSeriesLoadResponse -> {
-                        val gotNoEpisodes = load.episodes.isEmpty()
-                        if (gotNoEpisodes) {
-                            println("Api ${api.name} got no episodes on ${load.url}")
-                            continue
-                        }
-
-                        validResults = loadLinks(api, load.episodes.first().data)
-                        if (!validResults) continue
-                    }
-                }
-                break
-            }
-            if (!validResults) {
-                System.err.println("Api ${api.name} did not load on any")
-            }
-
-            return validResults
-        } catch (e: Exception) {
-            if (e.cause is NotImplementedError) {
-                Assert.fail("Provider has not implemented .load")
-            }
-            logError(e)
-            return false
-        }
-    }
-
     @Test
     fun providersExist() {
         Assert.assertTrue(getAllProviders().isNotEmpty())
@@ -159,6 +27,7 @@ class ExampleInstrumentedTest {
     }
 
     @Test
+    @Throws(AssertionError::class)
     fun providerCorrectData() {
         val isoNames = SubtitleHelper.languages.map { it.ISO_639_1 }
         Assert.assertFalse("ISO does not contain any languages", isoNames.isNullOrEmpty())
@@ -181,67 +50,20 @@ class ExampleInstrumentedTest {
     fun providerCorrectHomepage() {
         runBlocking {
             getAllProviders().amap { api ->
-                if (api.hasMainPage) {
+                TestingUtils.testHomepage(api, ::println)
-                    try {
-                        val f = api.mainPage.first()
-                        val homepage =
-                            api.getMainPage(1, MainPageRequest(f.name, f.data, f.horizontalImages))
-                        when {
-                            homepage == null -> {
-                                System.err.println("Homepage provider ${api.name} did not correctly load homepage!")
-                            }
-                            homepage.items.isEmpty() -> {
-                                System.err.println("Homepage provider ${api.name} does not contain any items!")
-                            }
-                            homepage.items.any { it.list.isEmpty() } -> {
-                                System.err.println("Homepage provider ${api.name} does not have any items on result!")
-                            }
-                        }
-                    } catch (e: Exception) {
-                        if (e.cause is NotImplementedError) {
-                            Assert.fail("Provider marked as hasMainPage, while in reality is has not been implemented")
-                        }
-                        logError(e)
-                    }
-                }
             }
         }
         println("Done providerCorrectHomepage")
     }
 
-//    @Test
-//    fun testSingleProvider() {
-//        testSingleProviderApi(ThenosProvider())
-//    }
-
     @Test
-    fun providerCorrect() {
+    fun testAllProvidersCorrect() {
         runBlocking {
-            val invalidProvider = ArrayList<Pair<MainAPI, Exception?>>()
+            TestingUtils.getDeferredProviderTests(
-            val providers = getAllProviders()
+                this,
-            providers.amap { api ->
+                getAllProviders(),
-                try {
+                ::println
-                    println("Trying $api")
+            ) { _, _ -> }
-                    if (testSingleProviderApi(api)) {
-                        println("Success $api")
-                    } else {
-                        System.err.println("Error $api")
-                        invalidProvider.add(Pair(api, null))
-                    }
-                } catch (e: Exception) {
-                    logError(e)
-                    invalidProvider.add(Pair(api, e))
-                }
-            }
-            if (invalidProvider.isEmpty()) {
-                println("No Invalid providers! :D")
-            } else {
-                println("Invalid providers are: ")
-                for (provider in invalidProvider) {
-                    println("${provider.first}")
-                }
-            }
         }
-        println("Done providerCorrect")
     }
 }

app/src/main/java/com/lagradost/cloudstream3/MainAPI.kt

@@ -17,8 +17,10 @@ import com.lagradost.cloudstream3.syncproviders.SyncIdName
 import com.lagradost.cloudstream3.ui.player.SubtitleData
 import com.lagradost.cloudstream3.utils.*
 import com.lagradost.cloudstream3.utils.AppUtils.toJson
+import com.lagradost.cloudstream3.utils.Coroutines.mainWork
 import com.lagradost.cloudstream3.utils.Coroutines.threadSafeListOf
 import okhttp3.Interceptor
+import org.mozilla.javascript.Scriptable
 import java.text.SimpleDateFormat
 import java.util.*
 import kotlin.math.absoluteValue
@@ -734,6 +736,19 @@ fun fixTitle(str: String): String {
             .replaceFirstChar { char -> if (char.isLowerCase()) char.titlecase(Locale.getDefault()) else it }
     }
 }
+/**
+ * Get rhino context in a safe way as it needs to be initialized on the main thread.
+ * Make sure you get the scope using: val scope: Scriptable = rhino.initSafeStandardObjects()
+ * Use like the following: rhino.evaluateString(scope, js, "JavaScript", 1, null)
+ **/
+suspend fun getRhinoContext(): org.mozilla.javascript.Context {
+    return Coroutines.mainWork {
+        val rhino = org.mozilla.javascript.Context.enter()
+        rhino.initSafeStandardObjects()
+        rhino.optimizationLevel = -1
+        rhino
+    }
+}
 
 /** https://www.imdb.com/title/tt2861424/ -> tt2861424 */
 fun imdbUrlToId(url: String): String? {
@@ -1312,7 +1327,7 @@ fun LoadResponse?.isAnimeBased(): Boolean {
 
 fun TvType?.isEpisodeBased(): Boolean {
     if (this == null) return false
-    return (this == TvType.TvSeries || this == TvType.Anime)
+    return (this == TvType.TvSeries || this == TvType.Anime || this == TvType.AsianDrama)
 }
 
 
@@ -1336,6 +1351,7 @@ interface EpisodeResponse {
     var showStatus: ShowStatus?
     var nextAiring: NextAiring?
     var seasonNames: List<SeasonData>?
+    fun getLatestEpisodes(): Map<DubStatus, Int?>
 }
 
 @JvmName("addSeasonNamesString")
@@ -1404,7 +1420,18 @@ data class AnimeLoadResponse(
     override var nextAiring: NextAiring? = null,
     override var seasonNames: List<SeasonData>? = null,
     override var backgroundPosterUrl: String? = null,
-) : LoadResponse, EpisodeResponse
+) : LoadResponse, EpisodeResponse {
+    override fun getLatestEpisodes(): Map<DubStatus, Int?> {
+        return episodes.map { (status, episodes) ->
+            val maxSeason = episodes.maxOfOrNull { it.season ?: Int.MIN_VALUE }
+                .takeUnless { it == Int.MIN_VALUE }
+            status to episodes
+                .filter { it.season == maxSeason }
+                .maxOfOrNull { it.episode ?: Int.MIN_VALUE }
+                .takeUnless { it == Int.MIN_VALUE }
+        }.toMap()
+    }
+}
 
 /**
  * If episodes already exist appends the list.
@@ -1602,7 +1629,17 @@ data class TvSeriesLoadResponse(
     override var nextAiring: NextAiring? = null,
     override var seasonNames: List<SeasonData>? = null,
     override var backgroundPosterUrl: String? = null,
-) : LoadResponse, EpisodeResponse
+) : LoadResponse, EpisodeResponse {
+    override fun getLatestEpisodes(): Map<DubStatus, Int?> {
+        val maxSeason =
+            episodes.maxOfOrNull { it.season ?: Int.MIN_VALUE }.takeUnless { it == Int.MIN_VALUE }
+        val max = episodes
+            .filter { it.season == maxSeason }
+            .maxOfOrNull { it.episode ?: Int.MIN_VALUE }
+            .takeUnless { it == Int.MIN_VALUE }
+        return mapOf(DubStatus.None to max)
+    }
+}
 
 suspend fun MainAPI.newTvSeriesLoadResponse(
     name: String,

app/src/main/java/com/lagradost/cloudstream3/MainActivity.kt

@@ -406,6 +406,7 @@ class MainActivity : AppCompatActivity(), ColorPickerDialogListener {
             R.id.navigation_settings_general,
             R.id.navigation_settings_extensions,
             R.id.navigation_settings_plugins,
+            R.id.navigation_test_providers,
         ).contains(destination.id)
 
 

app/src/main/java/com/lagradost/cloudstream3/extractors/Sendvid.kt

@@ -0,0 +1,28 @@
+package com.lagradost.cloudstream3.extractors
+
+import com.lagradost.cloudstream3.SubtitleFile
+import com.lagradost.cloudstream3.utils.*
+import com.lagradost.cloudstream3.app
+import com.lagradost.cloudstream3.utils.M3u8Helper.Companion.generateM3u8
+
+open class Sendvid : ExtractorApi() {
+    override var name = "Sendvid"
+    override val mainUrl = "https://sendvid.com"
+    override val requiresReferer = false
+    override suspend fun getUrl(
+        url: String,
+        referer: String?,
+        subtitleCallback: (SubtitleFile) -> Unit,
+        callback: (ExtractorLink) -> Unit
+    ) {
+        val doc = app.get(url).document
+        val urlString = doc.select("head meta[property=og:video:secure_url]").attr("content")
+        if (urlString.contains("m3u8"))  {
+            generateM3u8(
+                name,
+                urlString,
+                mainUrl,
+            ).forEach(callback)
+        }
+    }
+}

app/src/main/java/com/lagradost/cloudstream3/extractors/StreamSB.kt

@@ -130,7 +130,7 @@ open class StreamSB : ExtractorApi() {
             it.value.replace(Regex("(embed-|/e/)"), "")
         }.first()
 //        val master = "$mainUrl/sources48/6d6144797752744a454267617c7c${bytesToHex.lowercase()}7c7c4e61755a56456f34385243727c7c73747265616d7362/6b4a33767968506e4e71374f7c7c343837323439333133333462353935333633373836643638376337633462333634663539343137373761333635313533333835333763376333393636363133393635366136323733343435323332376137633763373337343732363536313664373336327c7c504d754478413835306633797c7c73747265616d7362"
-        val master = "$mainUrl/sources50/" + bytesToHex("||$id||||streamsb".toByteArray()) + "/"
+        val master = "$mainUrl/sources51/" + bytesToHex("||$id||||streamsb".toByteArray()) + "/"
         val headers = mapOf(
             "watchsb" to "sbstream",
         )
@@ -156,4 +156,4 @@ open class StreamSB : ExtractorApi() {
             )
         }
     }
-}
+}

app/src/main/java/com/lagradost/cloudstream3/mvvm/ArchComponentExt.kt

@@ -49,7 +49,7 @@ inline fun debugWarning(assert: () -> Boolean, message: () -> String) {
     }
 }
 
-fun <T> LifecycleOwner.observe(liveData: LiveData<T>, action: (t:  T) -> Unit) {
+fun <T> LifecycleOwner.observe(liveData: LiveData<T>, action: (t: T) -> Unit) {
     liveData.observe(this) { it?.let { t -> action(t) } }
 }
 
@@ -121,13 +121,21 @@ suspend fun <T> suspendSafeApiCall(apiCall: suspend () -> T): T? {
     }
 }
 
+fun Throwable.getAllMessages(): String {
+    return (this.localizedMessage ?: "") + (this.cause?.getAllMessages()?.let { "\n$it" } ?: "")
+}
+
+fun Throwable.getStackTracePretty(showMessage: Boolean = true): String {
+    val prefix = if (showMessage) this.localizedMessage?.let { "\n$it" } ?: "" else ""
+    return prefix + this.stackTrace.joinToString(
+        separator = "\n"
+    ) {
+        "${it.fileName} ${it.lineNumber}"
+    }
+}
+
 fun <T> safeFail(throwable: Throwable): Resource<T> {
-    val stackTraceMsg =
+    val stackTraceMsg = throwable.getStackTracePretty()
-        (throwable.localizedMessage ?: "") + "\n\n" + throwable.stackTrace.joinToString(
-            separator = "\n"
-        ) {
-            "${it.fileName} ${it.lineNumber}"
-        }
     return Resource.Failure(false, null, null, stackTraceMsg)
 }
 

app/src/main/java/com/lagradost/cloudstream3/plugins/PluginManager.kt

@@ -16,6 +16,7 @@ import com.google.gson.Gson
 import com.lagradost.cloudstream3.*
 import com.lagradost.cloudstream3.APIHolder.getApiProviderLangSettings
 import com.lagradost.cloudstream3.APIHolder.removePluginMapping
+import com.lagradost.cloudstream3.AcraApplication.Companion.getActivity
 import com.lagradost.cloudstream3.AcraApplication.Companion.getKey
 import com.lagradost.cloudstream3.AcraApplication.Companion.removeKey
 import com.lagradost.cloudstream3.AcraApplication.Companion.setKey
@@ -165,11 +166,11 @@ object PluginManager {
     private var loadedLocalPlugins = false
     private val gson = Gson()
 
-    private suspend fun maybeLoadPlugin(activity: Activity, file: File) {
+    private suspend fun maybeLoadPlugin(context: Context, file: File) {
         val name = file.name
         if (file.extension == "zip" || file.extension == "cs3") {
             loadPlugin(
-                activity,
+                context,
                 file,
                 PluginData(name, null, false, file.absolutePath, PLUGIN_VERSION_NOT_SET)
             )
@@ -199,7 +200,7 @@ object PluginManager {
 
     // var allCurrentOutDatedPlugins: Set<OnlinePluginData> = emptySet()
 
-    suspend fun loadSinglePlugin(activity: Activity, apiName: String): Boolean {
+    suspend fun loadSinglePlugin(context: Context, apiName: String): Boolean {
         return (getPluginsOnline().firstOrNull {
             // Most of the time the provider ends with Provider which isn't part of the api name
             it.internalName.replace("provider", "", ignoreCase = true) == apiName
@@ -209,7 +210,7 @@ object PluginManager {
             })?.let { savedData ->
             // OnlinePluginData(savedData, onlineData)
             loadPlugin(
-                activity,
+                context,
                 File(savedData.filePath),
                 savedData
             )
@@ -371,11 +372,11 @@ object PluginManager {
     /**
      * Use updateAllOnlinePluginsAndLoadThem
      * */
-    fun loadAllOnlinePlugins(activity: Activity) {
+    fun loadAllOnlinePlugins(context: Context) {
         // Load all plugins as fast as possible!
         (getPluginsOnline()).toList().apmap { pluginData ->
             loadPlugin(
-                activity,
+                context,
                 File(pluginData.filePath),
                 pluginData
             )
@@ -398,7 +399,7 @@ object PluginManager {
      * @param forceReload see afterPluginsLoadedEvent, basically a way to load all local plugins
      * and reload all pages even if they are previously valid
      **/
-    fun loadAllLocalPlugins(activity: Activity, forceReload: Boolean) {
+    fun loadAllLocalPlugins(context: Context, forceReload: Boolean) {
         val dir = File(LOCAL_PLUGINS_PATH)
         removeKey(PLUGINS_KEY_LOCAL)
 
@@ -416,7 +417,7 @@ object PluginManager {
         Log.d(TAG, "Files in '${LOCAL_PLUGINS_PATH}' folder: $sortedPlugins")
 
         sortedPlugins?.sortedBy { it.name }?.apmap { file ->
-            maybeLoadPlugin(activity, file)
+            maybeLoadPlugin(context, file)
         }
 
         loadedLocalPlugins = true
@@ -441,14 +442,14 @@ object PluginManager {
     /**
      * @return True if successful, false if not
      * */
-    private suspend fun loadPlugin(activity: Activity, file: File, data: PluginData): Boolean {
+    private suspend fun loadPlugin(context: Context, file: File, data: PluginData): Boolean {
         val fileName = file.nameWithoutExtension
         val filePath = file.absolutePath
         currentlyLoading = fileName
         Log.i(TAG, "Loading plugin: $data")
 
         return try {
-            val loader = PathClassLoader(filePath, activity.classLoader)
+            val loader = PathClassLoader(filePath, context.classLoader)
             var manifest: Plugin.Manifest
             loader.getResourceAsStream("manifest.json").use { stream ->
                 if (stream == null) {
@@ -492,22 +493,22 @@ object PluginManager {
                 addAssetPath.invoke(assets, file.absolutePath)
                 pluginInstance.resources = Resources(
                     assets,
-                    activity.resources.displayMetrics,
+                    context.resources.displayMetrics,
-                    activity.resources.configuration
+                    context.resources.configuration
                 )
             }
             plugins[filePath] = pluginInstance
             classLoaders[loader] = pluginInstance
             urlPlugins[data.url ?: filePath] = pluginInstance
-            pluginInstance.load(activity)
+            pluginInstance.load(context)
             Log.i(TAG, "Loaded plugin ${data.internalName} successfully")
             currentlyLoading = null
             true
         } catch (e: Throwable) {
             Log.e(TAG, "Failed to load $file: ${Log.getStackTraceString(e)}")
             showToast(
-                activity,
+                context.getActivity(),
-                activity.getString(R.string.plugin_load_fail).format(fileName),
+                context.getString(R.string.plugin_load_fail).format(fileName),
                 Toast.LENGTH_LONG
             )
             currentlyLoading = null

app/src/main/java/com/lagradost/cloudstream3/services/SubscriptionWorkManager.kt

@@ -0,0 +1,218 @@
+package com.lagradost.cloudstream3.services
+
+import android.app.NotificationManager
+import android.app.PendingIntent
+import android.content.Context
+import android.content.Intent
+import android.os.Build
+import androidx.core.app.NotificationCompat
+import androidx.core.net.toUri
+import androidx.work.*
+import com.lagradost.cloudstream3.*
+import com.lagradost.cloudstream3.APIHolder.getApiDubstatusSettings
+import com.lagradost.cloudstream3.APIHolder.getApiFromNameNull
+import com.lagradost.cloudstream3.R
+import com.lagradost.cloudstream3.mvvm.safeApiCall
+import com.lagradost.cloudstream3.plugins.PluginManager
+import com.lagradost.cloudstream3.ui.result.txt
+import com.lagradost.cloudstream3.utils.AppUtils.createNotificationChannel
+import com.lagradost.cloudstream3.utils.Coroutines.ioWork
+import com.lagradost.cloudstream3.utils.DataStoreHelper
+import com.lagradost.cloudstream3.utils.DataStoreHelper.getAllSubscriptions
+import com.lagradost.cloudstream3.utils.DataStoreHelper.getDub
+import com.lagradost.cloudstream3.utils.UIHelper.colorFromAttribute
+import com.lagradost.cloudstream3.utils.VideoDownloadManager.getImageBitmapFromUrl
+import kotlinx.coroutines.withTimeoutOrNull
+import java.util.concurrent.TimeUnit
+
+const val SUBSCRIPTION_CHANNEL_ID = "cloudstream3.subscriptions"
+const val SUBSCRIPTION_WORK_NAME = "work_subscription"
+const val SUBSCRIPTION_CHANNEL_NAME = "Subscriptions"
+const val SUBSCRIPTION_CHANNEL_DESCRIPTION = "Notifications for new episodes on subscribed shows"
+const val SUBSCRIPTION_NOTIFICATION_ID = 938712897 // Random unique
+
+class SubscriptionWorkManager(val context: Context, workerParams: WorkerParameters) :
+    CoroutineWorker(context, workerParams) {
+    companion object {
+        fun enqueuePeriodicWork(context: Context?) {
+            if (context == null) return
+
+            val constraints = Constraints.Builder()
+                .setRequiredNetworkType(NetworkType.CONNECTED)
+                .build()
+
+            val periodicSyncDataWork =
+                PeriodicWorkRequest.Builder(SubscriptionWorkManager::class.java, 6, TimeUnit.HOURS)
+                    .addTag(SUBSCRIPTION_WORK_NAME)
+                    .setConstraints(constraints)
+                    .build()
+
+            WorkManager.getInstance(context).enqueueUniquePeriodicWork(
+                SUBSCRIPTION_WORK_NAME,
+                ExistingPeriodicWorkPolicy.KEEP,
+                periodicSyncDataWork
+            )
+
+            // Uncomment below for testing
+
+//            val oneTimeSyncDataWork =
+//                OneTimeWorkRequest.Builder(SubscriptionWorkManager::class.java)
+//                    .addTag(SUBSCRIPTION_WORK_NAME)
+//                    .setConstraints(constraints)
+//                    .build()
+//
+//            WorkManager.getInstance(context).enqueue(oneTimeSyncDataWork)
+        }
+    }
+
+    private val progressNotificationBuilder =
+        NotificationCompat.Builder(context, SUBSCRIPTION_CHANNEL_ID)
+            .setAutoCancel(false)
+            .setColorized(true)
+            .setOnlyAlertOnce(true)
+            .setSilent(true)
+            .setPriority(NotificationCompat.PRIORITY_DEFAULT)
+            .setColor(context.colorFromAttribute(R.attr.colorPrimary))
+            .setContentTitle(context.getString(R.string.subscription_in_progress_notification))
+            .setSmallIcon(R.drawable.quantum_ic_refresh_white_24)
+            .setProgress(0, 0, true)
+
+    private val updateNotificationBuilder =
+        NotificationCompat.Builder(context, SUBSCRIPTION_CHANNEL_ID)
+            .setColorized(true)
+            .setOnlyAlertOnce(true)
+            .setAutoCancel(true)
+            .setPriority(NotificationCompat.PRIORITY_DEFAULT)
+            .setColor(context.colorFromAttribute(R.attr.colorPrimary))
+            .setSmallIcon(R.drawable.ic_cloudstream_monochrome_big)
+
+    private val notificationManager: NotificationManager =
+        context.getSystemService(Context.NOTIFICATION_SERVICE) as NotificationManager
+
+    private fun updateProgress(max: Int, progress: Int, indeterminate: Boolean) {
+        notificationManager.notify(
+            SUBSCRIPTION_NOTIFICATION_ID, progressNotificationBuilder
+                .setProgress(max, progress, indeterminate)
+                .build()
+        )
+    }
+
+    override suspend fun doWork(): Result {
+//        println("Update subscriptions!")
+        context.createNotificationChannel(
+            SUBSCRIPTION_CHANNEL_ID,
+            SUBSCRIPTION_CHANNEL_NAME,
+            SUBSCRIPTION_CHANNEL_DESCRIPTION
+        )
+
+        safeApiCall {
+            setForeground(
+                ForegroundInfo(
+                    SUBSCRIPTION_NOTIFICATION_ID,
+                    progressNotificationBuilder.build()
+                )
+            )
+        }
+
+        val subscriptions = getAllSubscriptions()
+
+        if (subscriptions.isEmpty()) {
+            WorkManager.getInstance(context).cancelWorkById(this.id)
+            return Result.success()
+        }
+
+        val max = subscriptions.size
+        var progress = 0
+
+        updateProgress(max, progress, true)
+
+        // We need all plugins loaded.
+        PluginManager.loadAllOnlinePlugins(context)
+        PluginManager.loadAllLocalPlugins(context, false)
+
+        subscriptions.apmap { savedData ->
+            try {
+                val id = savedData.id ?: return@apmap null
+                val api = getApiFromNameNull(savedData.apiName) ?: return@apmap null
+
+                // Reasonable timeout to prevent having this worker run forever.
+                val response = withTimeoutOrNull(60_000) {
+                    api.load(savedData.url) as? EpisodeResponse
+                } ?: return@apmap null
+
+                val dubPreference =
+                    getDub(id) ?: if (
+                        context.getApiDubstatusSettings().contains(DubStatus.Dubbed)
+                    ) {
+                        DubStatus.Dubbed
+                    } else {
+                        DubStatus.Subbed
+                    }
+
+                val latestEpisodes = response.getLatestEpisodes()
+                val latestPreferredEpisode = latestEpisodes[dubPreference]
+
+                val (shouldUpdate, latestEpisode) = if (latestPreferredEpisode != null) {
+                    val latestSeenEpisode =
+                        savedData.lastSeenEpisodeCount[dubPreference] ?: Int.MIN_VALUE
+                    val shouldUpdate = latestPreferredEpisode > latestSeenEpisode
+                    shouldUpdate to latestPreferredEpisode
+                } else {
+                    val latestEpisode = latestEpisodes[DubStatus.None] ?: Int.MIN_VALUE
+                    val latestSeenEpisode =
+                        savedData.lastSeenEpisodeCount[DubStatus.None] ?: Int.MIN_VALUE
+                    val shouldUpdate = latestEpisode > latestSeenEpisode
+                    shouldUpdate to latestEpisode
+                }
+
+                DataStoreHelper.updateSubscribedData(
+                    id,
+                    savedData,
+                    response
+                )
+
+                if (shouldUpdate) {
+                    val updateHeader = savedData.name
+                    val updateDescription = txt(
+                        R.string.subscription_episode_released,
+                        latestEpisode,
+                        savedData.name
+                    ).asString(context)
+
+                    val intent = Intent(context, MainActivity::class.java).apply {
+                        data = savedData.url.toUri()
+                        flags = Intent.FLAG_ACTIVITY_NEW_TASK or Intent.FLAG_ACTIVITY_CLEAR_TASK
+                    }
+
+                    val pendingIntent =
+                        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.M) {
+                            PendingIntent.getActivity(
+                                context,
+                                0,
+                                intent,
+                                PendingIntent.FLAG_IMMUTABLE
+                            )
+                        } else {
+                            PendingIntent.getActivity(context, 0, intent, 0)
+                        }
+
+                    val poster = ioWork { savedData.posterUrl?.let { url -> context.getImageBitmapFromUrl(url, savedData.posterHeaders) } }
+                    val updateNotification =
+                        updateNotificationBuilder.setContentTitle(updateHeader)
+                            .setContentText(updateDescription)
+                            .setContentIntent(pendingIntent)
+                            .setLargeIcon(poster)
+                            .build()
+
+                    notificationManager.notify(id, updateNotification)
+                }
+
+                // You can probably get some issues here since this is async but it does not matter much.
+                updateProgress(max, ++progress, false)
+            } catch (_: Throwable) {
+            }
+        }
+
+        return Result.success()
+    }
+}

app/src/main/java/com/lagradost/cloudstream3/services/VideoDownloadService.kt

@@ -1,11 +1,22 @@
 package com.lagradost.cloudstream3.services
-
+import android.app.Service
-import android.app.IntentService
 import android.content.Intent
+import android.os.IBinder
 import com.lagradost.cloudstream3.utils.VideoDownloadManager
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.cancel
+import kotlinx.coroutines.launch
 
-class VideoDownloadService : IntentService("VideoDownloadService") {
+class VideoDownloadService : Service() {
-    override fun onHandleIntent(intent: Intent?) {
+
+    private val downloadScope = CoroutineScope(Dispatchers.Default)
+
+    override fun onBind(intent: Intent?): IBinder? {
+        return null
+    }
+
+    override fun onStartCommand(intent: Intent?, flags: Int, startId: Int): Int {
         if (intent != null) {
             val id = intent.getIntExtra("id", -1)
             val type = intent.getStringExtra("type")
@@ -14,10 +25,36 @@ class VideoDownloadService : IntentService("VideoDownloadService") {
                     "resume" -> VideoDownloadManager.DownloadActionType.Resume
                     "pause" -> VideoDownloadManager.DownloadActionType.Pause
                     "stop" -> VideoDownloadManager.DownloadActionType.Stop
-                    else -> return
+                    else -> return START_NOT_STICKY
+                }
+
+                downloadScope.launch {
+                    VideoDownloadManager.downloadEvent.invoke(Pair(id, state))
                 }
-                VideoDownloadManager.downloadEvent.invoke(Pair(id, state))
             }
         }
+
+        return START_NOT_STICKY
     }
-}
+
+    override fun onDestroy() {
+        downloadScope.coroutineContext.cancel()
+        super.onDestroy()
+    }
+}
+//    override fun onHandleIntent(intent: Intent?) {
+//        if (intent != null) {
+//            val id = intent.getIntExtra("id", -1)
+//            val type = intent.getStringExtra("type")
+//            if (id != -1 && type != null) {
+//                val state = when (type) {
+//                    "resume" -> VideoDownloadManager.DownloadActionType.Resume
+//                    "pause" -> VideoDownloadManager.DownloadActionType.Pause
+//                    "stop" -> VideoDownloadManager.DownloadActionType.Stop
+//                    else -> return
+//                }
+//                VideoDownloadManager.downloadEvent.invoke(Pair(id, state))
+//            }
+//        }
+//    }
+//}

app/src/main/java/com/lagradost/cloudstream3/syncproviders/providers/AniListApi.kt

@@ -759,6 +759,11 @@ class AniListApi(index: Int) : AccountManager(index), SyncAPI {
         return data != ""
     }
 
+    /** Used to query a saved MediaItem on the list to get the id for removal */
+    data class MediaListItemRoot(@JsonProperty("data") val data: MediaListItem? = null)
+    data class MediaListItem(@JsonProperty("MediaList") val MediaList: MediaListId? = null)
+    data class MediaListId(@JsonProperty("id") val id: Long? = null)
+
     private suspend fun postDataAboutId(
         id: Int,
         type: AniListStatusType,
@@ -766,19 +771,43 @@ class AniListApi(index: Int) : AccountManager(index), SyncAPI {
         progress: Int?
     ): Boolean {
         val q =
-            """mutation (${'$'}id: Int = $id, ${'$'}status: MediaListStatus = ${
+            // Delete item if status type is None
-                aniListStatusString[maxOf(
+            if (type == AniListStatusType.None) {
-                    0,
+                val userID = getKey<AniListUser>(accountId, ANILIST_USER_KEY)?.id ?: return false
-                    type.value
+                // Get list ID for deletion
-                )]
+                val idQuery = """
-            }, ${if (score != null) "${'$'}scoreRaw: Int = ${score * 10}" else ""} , ${if (progress != null) "${'$'}progress: Int = $progress" else ""}) {
+                  query MediaList(${'$'}userId: Int = $userID, ${'$'}mediaId: Int = $id) {
-                SaveMediaListEntry (mediaId: ${'$'}id, status: ${'$'}status, scoreRaw: ${'$'}scoreRaw, progress: ${'$'}progress) {
+                    MediaList(userId: ${'$'}userId, mediaId: ${'$'}mediaId) {
-                    id
+                      id
-                    status
+                    }
-                    progress
+                  }
-                    score
+                """
-                }
+                val response = postApi(idQuery)
+                val listId =
+                    tryParseJson<MediaListItemRoot>(response)?.data?.MediaList?.id ?: return false
+                """
+                    mutation(${'$'}id: Int = $listId) {
+                        DeleteMediaListEntry(id: ${'$'}id) {
+                            deleted
+                        }
+                    }
+                """
+            } else {
+                """mutation (${'$'}id: Int = $id, ${'$'}status: MediaListStatus = ${
+                    aniListStatusString[maxOf(
+                        0,
+                        type.value
+                    )]
+                }, ${if (score != null) "${'$'}scoreRaw: Int = ${score * 10}" else ""} , ${if (progress != null) "${'$'}progress: Int = $progress" else ""}) {
+                    SaveMediaListEntry (mediaId: ${'$'}id, status: ${'$'}status, scoreRaw: ${'$'}scoreRaw, progress: ${'$'}progress) {
+                        id
+                        status
+                        progress
+                        score
+                    }
                 }"""
+            }
+
         val data = postApi(q)
         return data != ""
     }

app/src/main/java/com/lagradost/cloudstream3/syncproviders/providers/LocalList.kt

@@ -9,6 +9,7 @@ import com.lagradost.cloudstream3.ui.WatchType
 import com.lagradost.cloudstream3.ui.library.ListSorting
 import com.lagradost.cloudstream3.ui.result.txt
 import com.lagradost.cloudstream3.utils.Coroutines.ioWork
+import com.lagradost.cloudstream3.utils.DataStoreHelper.getAllSubscriptions
 import com.lagradost.cloudstream3.utils.DataStoreHelper.getAllWatchStateIds
 import com.lagradost.cloudstream3.utils.DataStoreHelper.getBookmarkedData
 import com.lagradost.cloudstream3.utils.DataStoreHelper.getResultWatchState
@@ -74,13 +75,16 @@ class LocalList : SyncAPI {
                 group.value.mapNotNull {
                     getBookmarkedData(it.first)?.toLibraryItem(it.first.toString())
                 }
-            }
+            } + mapOf(R.string.subscription_list_name to getAllSubscriptions().mapNotNull {
+                it.toLibraryItem()
+            })
         }
 
         val baseMap = WatchType.values().filter { it != WatchType.NONE }.associate {
             // None is not something to display
             it.stringRes to emptyList<SyncAPI.LibraryItem>()
-        }
+        } + mapOf(R.string.subscription_list_name to emptyList())
+
         return SyncAPI.LibraryMetadata(
             (baseMap + list).map { SyncAPI.LibraryList(txt(it.key), it.value) },
             setOf(

app/src/main/java/com/lagradost/cloudstream3/ui/result/ResultFragment.kt

@@ -15,6 +15,7 @@ import android.view.ViewGroup
 import android.widget.AbsListView
 import android.widget.ArrayAdapter
 import android.widget.ImageView
+import android.widget.Toast
 import androidx.appcompat.app.AlertDialog
 import androidx.core.view.isGone
 import androidx.core.view.isVisible
@@ -27,12 +28,14 @@ import com.google.android.material.chip.ChipDrawable
 import com.lagradost.cloudstream3.APIHolder.getApiDubstatusSettings
 import com.lagradost.cloudstream3.APIHolder.getApiFromNameNull
 import com.lagradost.cloudstream3.APIHolder.updateHasTrailers
+import com.lagradost.cloudstream3.CommonActivity.showToast
 import com.lagradost.cloudstream3.DubStatus
 import com.lagradost.cloudstream3.MainActivity.Companion.afterPluginsLoadedEvent
 import com.lagradost.cloudstream3.R
 import com.lagradost.cloudstream3.SearchResponse
 import com.lagradost.cloudstream3.TvType
 import com.lagradost.cloudstream3.mvvm.*
+import com.lagradost.cloudstream3.services.SubscriptionWorkManager
 import com.lagradost.cloudstream3.syncproviders.providers.Kitsu
 import com.lagradost.cloudstream3.ui.WatchType
 import com.lagradost.cloudstream3.ui.download.DOWNLOAD_ACTION_DOWNLOAD
@@ -850,7 +853,7 @@ open class ResultFragment : ResultTrailerPlayer() {
         }
 
         observe(viewModel.page) { data ->
-            if(data == null) return@observe
+            if (data == null) return@observe
             when (data) {
                 is Resource.Success -> {
                     val d = data.value
@@ -904,6 +907,36 @@ open class ResultFragment : ResultTrailerPlayer() {
                         updateList(d.actors ?: emptyList())
                     }
 
+                    observeNullable(viewModel.subscribeStatus) { isSubscribed ->
+                        result_subscribe?.isVisible = isSubscribed != null
+                        if (isSubscribed == null) return@observeNullable
+
+                        val drawable = if (isSubscribed) {
+                            R.drawable.ic_baseline_notifications_active_24
+                        } else {
+                            R.drawable.baseline_notifications_none_24
+                        }
+
+                        result_subscribe?.setImageResource(drawable)
+                    }
+
+                    result_subscribe?.setOnClickListener {
+                        val isSubscribed =
+                            viewModel.toggleSubscriptionStatus() ?: return@setOnClickListener
+
+                        val message = if (isSubscribed) {
+                            // Kinda icky to have this here, but it works.
+                            SubscriptionWorkManager.enqueuePeriodicWork(context)
+                            R.string.subscription_new
+                        } else {
+                            R.string.subscription_deleted
+                        }
+
+                        val name = (viewModel.page.value as? Resource.Success)?.value?.title
+                            ?: txt(R.string.no_data).asStringNull(context) ?: ""
+                        showToast(activity, txt(message, name), Toast.LENGTH_SHORT)
+                    }
+
                     result_open_in_browser?.isVisible = d.url.startsWith("http")
                     result_open_in_browser?.setOnClickListener {
                         val i = Intent(ACTION_VIEW)

app/src/main/java/com/lagradost/cloudstream3/ui/result/ResultFragmentPhone.kt

@@ -322,9 +322,7 @@ class ResultFragmentPhone : ResultFragment() {
                         //    it?.dismiss()
                         //}
                         builder.setCanceledOnTouchOutside(true)
-
                         builder.show()
-
                         builder
                     }
                 }

app/src/main/java/com/lagradost/cloudstream3/ui/result/ResultFragmentTv.kt

@@ -176,8 +176,7 @@ class ResultFragmentTv : ResultFragment() {
                         loadingDialog = null
                     }
                     loadingDialog = loadingDialog ?: context?.let { ctx ->
-                        val builder =
+                        val builder = BottomSheetDialog(ctx)
-                            BottomSheetDialog(ctx)
                         builder.setContentView(R.layout.bottom_loading)
                         builder.setOnDismissListener {
                             loadingDialog = null
@@ -187,9 +186,7 @@ class ResultFragmentTv : ResultFragment() {
                         //    it?.dismiss()
                         //}
                         builder.setCanceledOnTouchOutside(true)
-
                         builder.show()
-
                         builder
                     }
                 }

app/src/main/java/com/lagradost/cloudstream3/ui/result/ResultViewModel2.kt

@@ -16,6 +16,7 @@ import com.lagradost.cloudstream3.*
 import com.lagradost.cloudstream3.APIHolder.apis
 import com.lagradost.cloudstream3.APIHolder.getId
 import com.lagradost.cloudstream3.APIHolder.unixTime
+import com.lagradost.cloudstream3.APIHolder.unixTimeMS
 import com.lagradost.cloudstream3.AcraApplication.Companion.setKey
 import com.lagradost.cloudstream3.CommonActivity.getCastSession
 import com.lagradost.cloudstream3.CommonActivity.showToast
@@ -414,6 +415,9 @@ class ResultViewModel2 : ViewModel() {
     private val _episodeSynopsis: MutableLiveData<String?> = MutableLiveData(null)
     val episodeSynopsis: LiveData<String?> = _episodeSynopsis
 
+    private val _subscribeStatus: MutableLiveData<Boolean?> = MutableLiveData(null)
+    val subscribeStatus: LiveData<Boolean?> = _subscribeStatus
+
     companion object {
         const val TAG = "RVM2"
         private const val EPISODE_RANGE_SIZE = 20
@@ -815,6 +819,42 @@ class ResultViewModel2 : ViewModel() {
         }
     }
 
+    /**
+     * @return true if the new status is Subscribed, false if not. Null if not possible to subscribe.
+     **/
+    fun toggleSubscriptionStatus(): Boolean? {
+        val isSubscribed = _subscribeStatus.value ?: return null
+        val response = currentResponse ?: return null
+        if (response !is EpisodeResponse) return null
+
+        val currentId = response.getId()
+
+        if (isSubscribed) {
+            DataStoreHelper.removeSubscribedData(currentId)
+        } else {
+            val current = DataStoreHelper.getSubscribedData(currentId)
+
+            DataStoreHelper.setSubscribedData(
+                currentId,
+                DataStoreHelper.SubscribedData(
+                    currentId,
+                    current?.bookmarkedTime ?: unixTimeMS,
+                    unixTimeMS,
+                    response.getLatestEpisodes(),
+                    response.name,
+                    response.url,
+                    response.apiName,
+                    response.type,
+                    response.posterUrl,
+                    response.year
+                )
+            )
+        }
+
+        _subscribeStatus.postValue(!isSubscribed)
+        return !isSubscribed
+    }
+
     private fun startChromecast(
         activity: Activity?,
         result: ResultEpisode,
@@ -1473,7 +1513,8 @@ class ResultViewModel2 : ViewModel() {
                             this.engName,
                             this.name,
                             this.japName
-                        ).filter { it.length > 2 }.distinct(), // the reason why we filter is due to not wanting smth like " " or "?"
+                        ).filter { it.length > 2 }
+                            .distinct(), // the reason why we filter is due to not wanting smth like " " or "?"
                         TrackerType.getTypes(this.type),
                         this.year
                     )
@@ -1670,6 +1711,16 @@ class ResultViewModel2 : ViewModel() {
         postResume()
     }
 
+    private fun postSubscription(loadResponse: LoadResponse) {
+        if (loadResponse.isEpisodeBased()) {
+            val id = loadResponse.getId()
+            val data = DataStoreHelper.getSubscribedData(id)
+            DataStoreHelper.updateSubscribedData(id, data, loadResponse as? EpisodeResponse)
+            val isSubscribed = data != null
+            _subscribeStatus.postValue(isSubscribed)
+        }
+    }
+
     private fun postEpisodeRange(indexer: EpisodeIndexer?, range: EpisodeRange?) {
         if (range == null || indexer == null) {
             return
@@ -1806,6 +1857,7 @@ class ResultViewModel2 : ViewModel() {
     ) {
         currentResponse = loadResponse
         postPage(loadResponse, apiRepository)
+        postSubscription(loadResponse)
         if (updateEpisodes)
             postEpisodes(loadResponse, updateFillers)
     }

app/src/main/java/com/lagradost/cloudstream3/ui/settings/SettingsGeneral.kt

@@ -68,12 +68,12 @@ val appLanguages = arrayListOf(
     Triple("", "español", "es"),
     Triple("", "فارسی", "fa"),
     Triple("", "français", "fr"),
-    Triple("\uD83C\uDDEE\uD83C\uDDF1", "עברית", "iw"),
     Triple("", "हिन्दी", "hi"),
     Triple("", "hrvatski", "hr"),
     Triple("", "magyar", "hu"),
     Triple("\uD83C\uDDEE\uD83C\uDDE9", "Bahasa Indonesia", "in"),
     Triple("", "italiano", "it"),
+    Triple("\uD83C\uDDEE\uD83C\uDDF1", "עברית", "iw"),
     Triple("", "ಕನ್ನಡ", "kn"),
     Triple("", "македонски", "mk"),
     Triple("", "മലയാളം", "ml"),

app/src/main/java/com/lagradost/cloudstream3/ui/settings/SettingsProviders.kt

@@ -2,6 +2,8 @@ package com.lagradost.cloudstream3.ui.settings
 
 import android.os.Bundle
 import android.view.View
+import androidx.navigation.NavOptions
+import androidx.navigation.fragment.findNavController
 import androidx.preference.PreferenceFragmentCompat
 import androidx.preference.PreferenceManager
 import com.lagradost.cloudstream3.*
@@ -16,6 +18,7 @@ import com.lagradost.cloudstream3.utils.USER_SELECTED_HOMEPAGE_API
 import com.lagradost.cloudstream3.utils.SingleSelectionHelper.showMultiDialog
 import com.lagradost.cloudstream3.utils.SubtitleHelper
 import com.lagradost.cloudstream3.utils.UIHelper.hideKeyboard
+import com.lagradost.cloudstream3.utils.UIHelper.navigate
 
 class SettingsProviders : PreferenceFragmentCompat() {
     override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
@@ -56,6 +59,20 @@ class SettingsProviders : PreferenceFragmentCompat() {
             return@setOnPreferenceClickListener true
         }
 
+        getPref(R.string.test_providers_key)?.setOnPreferenceClickListener {
+            // Somehow animations do not work without this.
+            val options = NavOptions.Builder()
+                .setEnterAnim(R.anim.enter_anim)
+                .setExitAnim(R.anim.exit_anim)
+                .setPopEnterAnim(R.anim.pop_enter)
+                .setPopExitAnim(R.anim.pop_exit)
+                .build()
+
+            this@SettingsProviders.findNavController()
+                .navigate(R.id.navigation_test_providers, null, options)
+            true
+        }
+
         getPref(R.string.prefer_media_type_key)?.setOnPreferenceClickListener {
             val names = enumValues<TvType>().sorted().map { it.name }
             val default =

app/src/main/java/com/lagradost/cloudstream3/ui/settings/testing/TestFragment.kt

@@ -0,0 +1,97 @@
+package com.lagradost.cloudstream3.ui.settings.testing
+
+import android.os.Bundle
+import androidx.fragment.app.Fragment
+import android.view.LayoutInflater
+import android.view.View
+import android.view.ViewGroup
+import androidx.coordinatorlayout.widget.CoordinatorLayout
+import androidx.fragment.app.activityViewModels
+import com.lagradost.cloudstream3.R
+import com.lagradost.cloudstream3.mvvm.normalSafeApiCall
+import com.lagradost.cloudstream3.mvvm.observe
+import com.lagradost.cloudstream3.mvvm.observeNullable
+import com.lagradost.cloudstream3.ui.settings.SettingsFragment.Companion.isTrueTvSettings
+import com.lagradost.cloudstream3.ui.settings.SettingsFragment.Companion.setUpToolbar
+import kotlinx.android.synthetic.main.fragment_testing.*
+import kotlinx.android.synthetic.main.view_test.*
+
+
+class TestFragment : Fragment() {
+
+    private val testViewModel: TestViewModel by activityViewModels()
+
+    override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
+        setUpToolbar(R.string.category_provider_test)
+        super.onViewCreated(view, savedInstanceState)
+
+        provider_test_recycler_view?.adapter = TestResultAdapter(
+            mutableListOf()
+        )
+
+        testViewModel.init()
+        if (testViewModel.isRunningTest) {
+            provider_test?.setState(TestView.TestState.Running)
+        }
+
+        observe(testViewModel.providerProgress) { (passed, failed, total) ->
+            provider_test?.setProgress(passed, failed, total)
+        }
+
+        observeNullable(testViewModel.providerResults) {
+            normalSafeApiCall {
+                val newItems = it.sortedBy { api -> api.first.name }
+                (provider_test_recycler_view?.adapter as? TestResultAdapter)?.updateList(
+                    newItems
+                )
+            }
+        }
+
+        provider_test?.setOnPlayButtonListener { state ->
+            when (state) {
+                TestView.TestState.Stopped -> testViewModel.stopTest()
+                TestView.TestState.Running -> testViewModel.startTest()
+                TestView.TestState.None -> testViewModel.startTest()
+            }
+        }
+
+        if (isTrueTvSettings()) {
+            tests_play_pause?.isFocusableInTouchMode = true
+            tests_play_pause?.requestFocus()
+        }
+
+        provider_test?.playPauseButton?.setOnFocusChangeListener { _, hasFocus ->
+            if (hasFocus) {
+                provider_test_appbar?.setExpanded(true, true)
+            }
+        }
+
+        fun focusRecyclerView() {
+            // Hack to make it possible to focus the recyclerview.
+            if (isTrueTvSettings()) {
+                provider_test_recycler_view?.requestFocus()
+                provider_test_appbar?.setExpanded(false, true)
+            }
+        }
+
+        provider_test?.setOnMainClick {
+            testViewModel.setFilterMethod(TestViewModel.ProviderFilter.All)
+            focusRecyclerView()
+        }
+        provider_test?.setOnFailedClick {
+            testViewModel.setFilterMethod(TestViewModel.ProviderFilter.Failed)
+            focusRecyclerView()
+        }
+        provider_test?.setOnPassedClick {
+            testViewModel.setFilterMethod(TestViewModel.ProviderFilter.Passed)
+            focusRecyclerView()
+        }
+    }
+
+    override fun onCreateView(
+        inflater: LayoutInflater, container: ViewGroup?,
+        savedInstanceState: Bundle?
+    ): View? {
+        return inflater.inflate(R.layout.fragment_testing, container, false)
+    }
+}

app/src/main/java/com/lagradost/cloudstream3/ui/settings/testing/TestResultAdapter.kt

@@ -0,0 +1,80 @@
+package com.lagradost.cloudstream3.ui.settings.testing
+
+import android.app.AlertDialog
+import android.view.LayoutInflater
+import android.view.View
+import android.view.ViewGroup
+import android.widget.ImageView
+import android.widget.TextView
+import androidx.core.content.ContextCompat
+import androidx.recyclerview.widget.RecyclerView
+import com.lagradost.cloudstream3.MainAPI
+import com.lagradost.cloudstream3.R
+import com.lagradost.cloudstream3.mvvm.getAllMessages
+import com.lagradost.cloudstream3.mvvm.getStackTracePretty
+import com.lagradost.cloudstream3.utils.AppUtils
+import com.lagradost.cloudstream3.utils.SubtitleHelper.getFlagFromIso
+import com.lagradost.cloudstream3.utils.TestingUtils
+import kotlinx.android.synthetic.main.provider_test_item.view.*
+
+class TestResultAdapter(override val items: MutableList<Pair<MainAPI, TestingUtils.TestResultProvider>>) :
+    AppUtils.DiffAdapter<Pair<MainAPI, TestingUtils.TestResultProvider>>(items) {
+    override fun onCreateViewHolder(parent: ViewGroup, viewType: Int): RecyclerView.ViewHolder {
+        return ProviderTestViewHolder(
+            LayoutInflater.from(parent.context)
+                .inflate(R.layout.provider_test_item, parent, false),
+        )
+    }
+
+    override fun onBindViewHolder(holder: RecyclerView.ViewHolder, position: Int) {
+        when (holder) {
+            is ProviderTestViewHolder -> {
+                val item = items[position]
+                holder.bind(item.first, item.second)
+            }
+        }
+    }
+
+    inner class ProviderTestViewHolder(itemView: View) : RecyclerView.ViewHolder(itemView) {
+        private val languageText: TextView = itemView.lang_icon
+        private val providerTitle: TextView = itemView.main_text
+        private val statusText: TextView = itemView.passed_failed_marker
+        private val failDescription: TextView = itemView.fail_description
+        private val logButton: ImageView = itemView.action_button
+
+        private fun String.lastLine(): String? {
+            return this.lines().lastOrNull { it.isNotBlank() }
+        }
+
+        fun bind(api: MainAPI, result: TestingUtils.TestResultProvider) {
+            languageText.text = getFlagFromIso(api.lang)
+            providerTitle.text = api.name
+
+            val (resultText, resultColor) = if (result.success) {
+                R.string.test_passed to R.color.colorTestPass
+            } else {
+                R.string.test_failed to R.color.colorTestFail
+            }
+
+            statusText.setText(resultText)
+            statusText.setTextColor(ContextCompat.getColor(itemView.context, resultColor))
+
+            val stackTrace = result.exception?.getStackTracePretty(false)?.ifBlank { null }
+            val messages = result.exception?.getAllMessages()?.ifBlank { null }
+            val fullLog =
+                result.log + (messages?.let { "\n\n$it" } ?: "") + (stackTrace?.let { "\n\n$it" } ?: "")
+
+            failDescription.text = messages?.lastLine() ?: result.log.lastLine()
+
+            logButton.setOnClickListener {
+                val builder: AlertDialog.Builder =
+                    AlertDialog.Builder(it.context, R.style.AlertDialogCustom)
+                builder.setMessage(fullLog)
+                    .setTitle(R.string.test_log)
+                    .show()
+            }
+        }
+    }
+
+
+}

app/src/main/java/com/lagradost/cloudstream3/ui/settings/testing/TestView.kt

@@ -0,0 +1,119 @@
+package com.lagradost.cloudstream3.ui.settings.testing
+
+import android.content.Context
+import android.util.AttributeSet
+import android.view.LayoutInflater
+import android.view.View
+import android.widget.TextView
+import androidx.annotation.DrawableRes
+import androidx.annotation.StringRes
+import androidx.cardview.widget.CardView
+import androidx.core.content.ContextCompat
+import androidx.core.view.isVisible
+import androidx.core.widget.ContentLoadingProgressBar
+import com.google.android.material.button.MaterialButton
+import com.lagradost.cloudstream3.R
+import com.lagradost.cloudstream3.utils.AppUtils.animateProgressTo
+
+class TestView @JvmOverloads constructor(
+    context: Context,
+    attrs: AttributeSet? = null,
+    defStyleAttr: Int = 0
+) : CardView(context, attrs) {
+    enum class TestState(@StringRes val stringRes: Int, @DrawableRes val icon: Int) {
+        None(R.string.start, R.drawable.ic_baseline_play_arrow_24),
+
+        //        Paused(R.string.resume, R.drawable.ic_baseline_play_arrow_24),
+        Stopped(R.string.restart, R.drawable.ic_baseline_play_arrow_24),
+        Running(R.string.stop, R.drawable.pause_to_play),
+    }
+
+    var mainSection: View? = null
+    var testsPassedSection: View? = null
+    var testsFailedSection: View? = null
+
+    var mainSectionText: TextView? = null
+    var mainSectionHeader: TextView? = null
+    var testsPassedSectionText: TextView? = null
+    var testsFailedSectionText: TextView? = null
+    var totalProgressBar: ContentLoadingProgressBar? = null
+
+    var playPauseButton: MaterialButton? = null
+    var stateListener: (TestState) -> Unit = {}
+
+    private var state = TestState.None
+
+    init {
+        LayoutInflater.from(context).inflate(R.layout.view_test, this, true)
+
+        mainSection = findViewById(R.id.main_test_section)
+        testsPassedSection = findViewById(R.id.passed_test_section)
+        testsFailedSection = findViewById(R.id.failed_test_section)
+
+        mainSectionHeader = findViewById(R.id.main_test_header)
+        mainSectionText = findViewById(R.id.main_test_section_progress)
+        testsPassedSectionText = findViewById(R.id.passed_test_section_progress)
+        testsFailedSectionText = findViewById(R.id.failed_test_section_progress)
+
+        totalProgressBar = findViewById(R.id.test_total_progress)
+        playPauseButton = findViewById(R.id.tests_play_pause)
+
+        attrs?.let {
+            val typedArray = context.obtainStyledAttributes(it, R.styleable.TestView)
+            val headerText = typedArray.getString(R.styleable.TestView_header_text)
+            mainSectionHeader?.text = headerText
+            typedArray.recycle()
+        }
+
+        playPauseButton?.setOnClickListener {
+            val newState = when (state) {
+                TestState.None -> TestState.Running
+                TestState.Running -> TestState.Stopped
+                TestState.Stopped -> TestState.Running
+            }
+            setState(newState)
+        }
+    }
+
+    fun setOnPlayButtonListener(listener: (TestState) -> Unit) {
+        stateListener = listener
+    }
+
+    fun setState(newState: TestState) {
+        state = newState
+        stateListener.invoke(newState)
+        playPauseButton?.setText(newState.stringRes)
+        playPauseButton?.icon = ContextCompat.getDrawable(context, newState.icon)
+    }
+
+    fun setProgress(passed: Int, failed: Int, total: Int?) {
+        val totalProgress = passed + failed
+        mainSectionText?.text = "$totalProgress / ${total?.toString() ?: "?"}"
+        testsPassedSectionText?.text = passed.toString()
+        testsFailedSectionText?.text = failed.toString()
+
+        totalProgressBar?.max = (total ?: 0) * 1000
+        totalProgressBar?.animateProgressTo(totalProgress * 1000)
+
+        totalProgressBar?.isVisible = !(totalProgress == 0 || (total ?: 0) == 0)
+        if (totalProgress == total) {
+            setState(TestState.Stopped)
+        }
+    }
+
+    fun setMainHeader(@StringRes header: Int) {
+        mainSectionHeader?.setText(header)
+    }
+
+    fun setOnMainClick(listener: OnClickListener) {
+        mainSection?.setOnClickListener(listener)
+    }
+
+    fun setOnPassedClick(listener: OnClickListener) {
+        testsPassedSection?.setOnClickListener(listener)
+    }
+
+    fun setOnFailedClick(listener: OnClickListener) {
+        testsFailedSection?.setOnClickListener(listener)
+    }
+}

app/src/main/java/com/lagradost/cloudstream3/ui/settings/testing/TestViewModel.kt

@@ -0,0 +1,108 @@
+package com.lagradost.cloudstream3.ui.settings.testing
+
+import androidx.lifecycle.LiveData
+import androidx.lifecycle.MutableLiveData
+import androidx.lifecycle.ViewModel
+import com.lagradost.cloudstream3.APIHolder
+import com.lagradost.cloudstream3.MainAPI
+import com.lagradost.cloudstream3.utils.Coroutines.threadSafeListOf
+import com.lagradost.cloudstream3.utils.TestingUtils
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.cancel
+
+class TestViewModel : ViewModel() {
+    data class TestProgress(
+        val passed: Int,
+        val failed: Int,
+        val total: Int
+    )
+
+    enum class ProviderFilter {
+        All,
+        Passed,
+        Failed
+    }
+
+    private val _providerProgress = MutableLiveData<TestProgress>(null)
+    val providerProgress: LiveData<TestProgress> = _providerProgress
+
+    private val _providerResults =
+        MutableLiveData<List<Pair<MainAPI, TestingUtils.TestResultProvider>>>(
+            emptyList()
+        )
+
+    val providerResults: LiveData<List<Pair<MainAPI, TestingUtils.TestResultProvider>>> =
+        _providerResults
+
+    private var scope: CoroutineScope? = null
+    val isRunningTest
+        get() = scope != null
+
+    private var filter = ProviderFilter.All
+    private val providers = threadSafeListOf<Pair<MainAPI, TestingUtils.TestResultProvider>>()
+    private var passed = 0
+    private var failed = 0
+    private var total = 0
+
+    private fun updateProgress() {
+        _providerProgress.postValue(TestProgress(passed, failed, total))
+        postProviders()
+    }
+
+    private fun postProviders() {
+        synchronized(providers) {
+            val filtered = when (filter) {
+                ProviderFilter.All -> providers
+                ProviderFilter.Passed -> providers.filter { it.second.success }
+                ProviderFilter.Failed -> providers.filter { !it.second.success }
+            }
+            _providerResults.postValue(filtered)
+        }
+    }
+
+    fun setFilterMethod(filter: ProviderFilter) {
+        if (this.filter == filter) return
+        this.filter = filter
+        postProviders()
+    }
+
+    private fun addProvider(api: MainAPI, results: TestingUtils.TestResultProvider) {
+        synchronized(providers) {
+            val index = providers.indexOfFirst { it.first == api }
+            if (index == -1) {
+                providers.add(api to results)
+                if (results.success) passed++ else failed++
+            } else {
+                providers[index] = api to results
+            }
+            updateProgress()
+        }
+    }
+
+    fun init() {
+        val apis = APIHolder.allProviders
+        total = apis.size
+        updateProgress()
+    }
+
+    fun startTest() {
+        scope = CoroutineScope(Dispatchers.Default)
+
+        val apis = APIHolder.allProviders
+        total = apis.size
+        failed = 0
+        passed = 0
+        providers.clear()
+        updateProgress()
+
+        TestingUtils.getDeferredProviderTests(scope ?: return, apis, ::println) { api, result ->
+            addProvider(api, result)
+        }
+    }
+
+    fun stopTest() {
+        scope?.cancel()
+        scope = null
+    }
+}

app/src/main/java/com/lagradost/cloudstream3/utils/AppUtils.kt

@@ -1,8 +1,11 @@
 package com.lagradost.cloudstream3.utils
 
+import android.animation.ObjectAnimator
 import android.annotation.SuppressLint
 import android.app.Activity
 import android.app.Activity.RESULT_CANCELED
+import android.app.NotificationChannel
+import android.app.NotificationManager
 import android.content.*
 import android.content.pm.PackageManager
 import android.database.Cursor
@@ -17,6 +20,7 @@ import android.os.*
 import android.provider.MediaStore
 import android.text.Spanned
 import android.util.Log
+import android.view.animation.DecelerateInterpolator
 import android.widget.Toast
 import androidx.activity.result.contract.ActivityResultContracts
 import androidx.annotation.RequiresApi
@@ -25,6 +29,7 @@ import androidx.appcompat.app.AlertDialog
 import androidx.core.content.ContextCompat
 import androidx.core.text.HtmlCompat
 import androidx.core.text.toSpanned
+import androidx.core.widget.ContentLoadingProgressBar
 import androidx.fragment.app.Fragment
 import androidx.fragment.app.FragmentActivity
 import androidx.navigation.fragment.findNavController
@@ -179,6 +184,36 @@ object AppUtils {
         touchSlopField.set(recyclerView, touchSlop * f)       // "8" was obtained experimentally
     }
 
+    fun ContentLoadingProgressBar?.animateProgressTo(to: Int) {
+        if (this == null) return
+        val animation: ObjectAnimator = ObjectAnimator.ofInt(
+            this,
+            "progress",
+            this.progress,
+            to
+        )
+        animation.duration = 500
+        animation.setAutoCancel(true)
+        animation.interpolator = DecelerateInterpolator()
+        animation.start()
+    }
+
+    fun Context.createNotificationChannel(channelId: String, channelName: String, description: String) {
+        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
+            val importance = NotificationManager.IMPORTANCE_DEFAULT
+            val channel =
+                NotificationChannel(channelId, channelName, importance).apply {
+                    this.description = description
+                }
+
+            // Register the channel with the system.
+            val notificationManager: NotificationManager =
+                this.getSystemService(Context.NOTIFICATION_SERVICE) as NotificationManager
+
+            notificationManager.createNotificationChannel(channel)
+        }
+    }
+
     @SuppressLint("RestrictedApi")
     fun getAllWatchNextPrograms(context: Context): Set<Long> {
         val COLUMN_WATCH_NEXT_ID_INDEX = 0

app/src/main/java/com/lagradost/cloudstream3/utils/DataStoreHelper.kt

@@ -1,16 +1,13 @@
 package com.lagradost.cloudstream3.utils
 
 import com.fasterxml.jackson.annotation.JsonProperty
-import com.lagradost.cloudstream3.APIHolder.capitalize
+import com.lagradost.cloudstream3.*
+import com.lagradost.cloudstream3.APIHolder.unixTimeMS
 import com.lagradost.cloudstream3.AcraApplication.Companion.getKey
 import com.lagradost.cloudstream3.AcraApplication.Companion.getKeys
 import com.lagradost.cloudstream3.AcraApplication.Companion.removeKey
 import com.lagradost.cloudstream3.AcraApplication.Companion.removeKeys
 import com.lagradost.cloudstream3.AcraApplication.Companion.setKey
-import com.lagradost.cloudstream3.DubStatus
-import com.lagradost.cloudstream3.SearchQuality
-import com.lagradost.cloudstream3.SearchResponse
-import com.lagradost.cloudstream3.TvType
 import com.lagradost.cloudstream3.syncproviders.AccountManager
 import com.lagradost.cloudstream3.syncproviders.SyncAPI
 import com.lagradost.cloudstream3.ui.WatchType
@@ -20,6 +17,7 @@ const val VIDEO_POS_DUR = "video_pos_dur"
 const val VIDEO_WATCH_STATE = "video_watch_state"
 const val RESULT_WATCH_STATE = "result_watch_state"
 const val RESULT_WATCH_STATE_DATA = "result_watch_state_data"
+const val RESULT_SUBSCRIBED_STATE_DATA = "result_subscribed_state_data"
 const val RESULT_RESUME_WATCHING = "result_resume_watching_2" // changed due to id changes
 const val RESULT_RESUME_WATCHING_OLD = "result_resume_watching"
 const val RESULT_RESUME_WATCHING_HAS_MIGRATED = "result_resume_watching_migrated"
@@ -42,6 +40,37 @@ object DataStoreHelper {
         return this
     }
 
+    /**
+     * Used to display notifications on new episodes and posters in library.
+     **/
+    data class SubscribedData(
+        @JsonProperty("id") override var id: Int?,
+        @JsonProperty("subscribedTime") val bookmarkedTime: Long,
+        @JsonProperty("latestUpdatedTime") val latestUpdatedTime: Long,
+        @JsonProperty("lastSeenEpisodeCount") val lastSeenEpisodeCount: Map<DubStatus, Int?>,
+        @JsonProperty("name") override val name: String,
+        @JsonProperty("url") override val url: String,
+        @JsonProperty("apiName") override val apiName: String,
+        @JsonProperty("type") override var type: TvType? = null,
+        @JsonProperty("posterUrl") override var posterUrl: String?,
+        @JsonProperty("year") val year: Int?,
+        @JsonProperty("quality") override var quality: SearchQuality? = null,
+        @JsonProperty("posterHeaders") override var posterHeaders: Map<String, String>? = null,
+    ) : SearchResponse {
+        fun toLibraryItem(): SyncAPI.LibraryItem? {
+            return SyncAPI.LibraryItem(
+                name,
+                url,
+                id?.toString() ?: return null,
+                null,
+                null,
+                null,
+                latestUpdatedTime,
+                apiName, type, posterUrl, posterHeaders, quality, this.id
+            )
+        }
+    }
+
     data class BookmarkedData(
         @JsonProperty("id") override var id: Int?,
         @JsonProperty("bookmarkedTime") val bookmarkedTime: Long,
@@ -63,7 +92,7 @@ object DataStoreHelper {
                 null,
                 null,
                 null,
-                null,
+                latestUpdatedTime,
                 apiName, type, posterUrl, posterHeaders, quality, this.id
             )
         }
@@ -75,9 +104,7 @@ object DataStoreHelper {
         @JsonProperty("apiName") override val apiName: String,
         @JsonProperty("type") override var type: TvType? = null,
         @JsonProperty("posterUrl") override var posterUrl: String?,
-
         @JsonProperty("watchPos") val watchPos: PosDur?,
-
         @JsonProperty("id") override var id: Int?,
         @JsonProperty("parentId") val parentId: Int?,
         @JsonProperty("episode") val episode: Int?,
@@ -204,6 +231,41 @@ object DataStoreHelper {
         return getKey("$currentAccount/$RESULT_WATCH_STATE_DATA", id.toString())
     }
 
+    fun getAllSubscriptions(): List<SubscribedData> {
+        return getKeys("$currentAccount/$RESULT_SUBSCRIBED_STATE_DATA")?.mapNotNull {
+            getKey(it)
+        } ?: emptyList()
+    }
+
+    fun removeSubscribedData(id: Int?) {
+        if (id == null) return
+        AccountManager.localListApi.requireLibraryRefresh = true
+        removeKey("$currentAccount/$RESULT_SUBSCRIBED_STATE_DATA", id.toString())
+    }
+
+    /**
+     * Set new seen episodes and update time
+     **/
+    fun updateSubscribedData(id: Int?, data: SubscribedData?, episodeResponse: EpisodeResponse?) {
+        if (id == null || data == null || episodeResponse == null) return
+        val newData = data.copy(
+            latestUpdatedTime = unixTimeMS,
+            lastSeenEpisodeCount = episodeResponse.getLatestEpisodes()
+        )
+        setKey("$currentAccount/$RESULT_SUBSCRIBED_STATE_DATA", id.toString(), newData)
+    }
+
+    fun setSubscribedData(id: Int?, data: SubscribedData) {
+        if (id == null) return
+        setKey("$currentAccount/$RESULT_SUBSCRIBED_STATE_DATA", id.toString(), data)
+        AccountManager.localListApi.requireLibraryRefresh = true
+    }
+
+    fun getSubscribedData(id: Int?): SubscribedData? {
+        if (id == null) return null
+        return getKey("$currentAccount/$RESULT_SUBSCRIBED_STATE_DATA", id.toString())
+    }
+
     fun setViewPos(id: Int?, pos: Long, dur: Long) {
         if (id == null) return
         if (dur < 30_000) return // too short

app/src/main/java/com/lagradost/cloudstream3/utils/ExtractorApi.kt

@@ -265,6 +265,7 @@ val extractorApis: MutableList<ExtractorApi> = arrayListOf(
     OkRu(),
     OkRuHttps(),
     Okrulink(),
+    Sendvid(),
 
     // dood extractors
     DoodCxExtractor(),

app/src/main/java/com/lagradost/cloudstream3/utils/PackageInstallerService.kt

@@ -14,6 +14,7 @@ import androidx.core.app.NotificationCompat
 import com.lagradost.cloudstream3.MainActivity
 import com.lagradost.cloudstream3.R
 import com.lagradost.cloudstream3.app
+import com.lagradost.cloudstream3.utils.AppUtils.createNotificationChannel
 import com.lagradost.cloudstream3.utils.Coroutines.ioSafe
 import com.lagradost.cloudstream3.utils.UIHelper.colorFromAttribute
 import kotlinx.coroutines.delay
@@ -47,24 +48,12 @@ class PackageInstallerService : Service() {
             .setSmallIcon(R.drawable.rdload)
     }
 
-    private fun createNotificationChannel() {
-        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.O) {
-            val importance = NotificationManager.IMPORTANCE_DEFAULT
-            val channel =
-                NotificationChannel(UPDATE_CHANNEL_ID, UPDATE_CHANNEL_NAME, importance).apply {
-                    description = UPDATE_CHANNEL_DESCRIPTION
-                }
-
-            // Register the channel with the system
-            val notificationManager: NotificationManager =
-                this.getSystemService(Context.NOTIFICATION_SERVICE) as NotificationManager
-
-            notificationManager.createNotificationChannel(channel)
-        }
-    }
-
     override fun onCreate() {
-        createNotificationChannel()
+        this.createNotificationChannel(
+            UPDATE_CHANNEL_ID,
+            UPDATE_CHANNEL_NAME,
+            UPDATE_CHANNEL_DESCRIPTION
+        )
         startForeground(UPDATE_NOTIFICATION_ID, baseNotification.build())
     }
 

app/src/main/java/com/lagradost/cloudstream3/utils/TestingUtils.kt

@@ -0,0 +1,267 @@
+package com.lagradost.cloudstream3.utils
+
+import com.lagradost.cloudstream3.*
+import com.lagradost.cloudstream3.mvvm.logError
+import kotlinx.coroutines.*
+import org.junit.Assert
+
+object TestingUtils {
+    open class TestResult(val success: Boolean) {
+        companion object {
+            val Pass = TestResult(true)
+            val Fail = TestResult(false)
+        }
+    }
+
+    class TestResultSearch(val results: List<SearchResponse>) : TestResult(true)
+    class TestResultLoad(val extractorData: String) : TestResult(true)
+
+    class TestResultProvider(success: Boolean, val log: String, val exception: Throwable?) :
+        TestResult(success)
+
+    @Throws(AssertionError::class, CancellationException::class)
+    suspend fun testHomepage(
+        api: MainAPI,
+        logger: (String) -> Unit
+    ): TestResult {
+        if (api.hasMainPage) {
+            try {
+                val f = api.mainPage.first()
+                val homepage =
+                    api.getMainPage(1, MainPageRequest(f.name, f.data, f.horizontalImages))
+                when {
+                    homepage == null -> {
+                        logger.invoke("Homepage provider ${api.name} did not correctly load homepage!")
+                    }
+                    homepage.items.isEmpty() -> {
+                        logger.invoke("Homepage provider ${api.name} does not contain any items!")
+                    }
+                    homepage.items.any { it.list.isEmpty() } -> {
+                        logger.invoke("Homepage provider ${api.name} does not have any items on result!")
+                    }
+                }
+            } catch (e: Throwable) {
+                if (e is NotImplementedError) {
+                    Assert.fail("Provider marked as hasMainPage, while in reality is has not been implemented")
+                } else if (e is CancellationException) {
+                    throw e
+                }
+                logError(e)
+            }
+        }
+        return TestResult.Pass
+    }
+
+    @Throws(AssertionError::class, CancellationException::class)
+    private suspend fun testSearch(
+        api: MainAPI
+    ): TestResult {
+        val searchQueries = listOf("over", "iron", "guy")
+        val searchResults = searchQueries.firstNotNullOfOrNull { query ->
+            try {
+                api.search(query).takeIf { !it.isNullOrEmpty() }
+            } catch (e: Throwable) {
+                if (e is NotImplementedError) {
+                    Assert.fail("Provider has not implemented search()")
+                } else if (e is CancellationException) {
+                    throw e
+                }
+                logError(e)
+                null
+            }
+        }
+
+        return if (searchResults.isNullOrEmpty()) {
+            Assert.fail("Api ${api.name} did not return any valid search responses")
+            TestResult.Fail // Should not be reached
+        } else {
+            TestResultSearch(searchResults)
+        }
+
+    }
+
+
+    @Throws(AssertionError::class, CancellationException::class)
+    private suspend fun testLoad(
+        api: MainAPI,
+        result: SearchResponse,
+        logger: (String) -> Unit
+    ): TestResult {
+        try {
+            Assert.assertEquals(
+                "Invalid apiName on SearchResponse on ${api.name}",
+                result.apiName,
+                api.name
+            )
+
+            val loadResponse = api.load(result.url)
+
+            if (loadResponse == null) {
+                logger.invoke("Returned null loadResponse on ${result.url} on ${api.name}")
+                return TestResult.Fail
+            }
+
+            Assert.assertEquals(
+                "Invalid apiName on LoadResponse on ${api.name}",
+                loadResponse.apiName,
+                result.apiName
+            )
+            Assert.assertTrue(
+                "Api ${api.name} on load does not contain any of the supportedTypes: ${loadResponse.type}",
+                api.supportedTypes.contains(loadResponse.type)
+            )
+
+            val url = when (loadResponse) {
+                is AnimeLoadResponse -> {
+                    val gotNoEpisodes =
+                        loadResponse.episodes.keys.isEmpty() || loadResponse.episodes.keys.any { loadResponse.episodes[it].isNullOrEmpty() }
+
+                    if (gotNoEpisodes) {
+                        logger.invoke("Api ${api.name} got no episodes on ${loadResponse.url}")
+                        return TestResult.Fail
+                    }
+
+                    (loadResponse.episodes[loadResponse.episodes.keys.firstOrNull()])?.firstOrNull()?.data
+                }
+                is MovieLoadResponse -> {
+                    val gotNoEpisodes = loadResponse.dataUrl.isBlank()
+                    if (gotNoEpisodes) {
+                        logger.invoke("Api ${api.name} got no movie on ${loadResponse.url}")
+                        return TestResult.Fail
+                    }
+
+                    loadResponse.dataUrl
+                }
+                is TvSeriesLoadResponse -> {
+                    val gotNoEpisodes = loadResponse.episodes.isEmpty()
+                    if (gotNoEpisodes) {
+                        logger.invoke("Api ${api.name} got no episodes on ${loadResponse.url}")
+                        return TestResult.Fail
+                    }
+                    loadResponse.episodes.firstOrNull()?.data
+                }
+                is LiveStreamLoadResponse -> {
+                    loadResponse.dataUrl
+                }
+                else -> {
+                    logger.invoke("Unknown load response: ${loadResponse.javaClass.name}")
+                    return TestResult.Fail
+                }
+            } ?: return TestResult.Fail
+
+            return TestResultLoad(url)
+
+//            val loadTest = testLoadResponse(api, load, logger)
+//            if (loadTest is TestResultLoad) {
+//                testLinkLoading(api, loadTest.extractorData, logger).success
+//            } else {
+//                false
+//            }
+//            if (!validResults) {
+//                logger("Api ${api.name} did not load on the first search results: ${smallSearchResults.map { it.name }}")
+//            }
+
+//            return TestResult(validResults)
+        } catch (e: Throwable) {
+            if (e is NotImplementedError) {
+                Assert.fail("Provider has not implemented load()")
+            }
+            throw e
+        }
+    }
+
+    @Throws(AssertionError::class, CancellationException::class)
+    private suspend fun testLinkLoading(
+        api: MainAPI,
+        url: String?,
+        logger: (String) -> Unit
+    ): TestResult {
+        Assert.assertNotNull("Api ${api.name} has invalid url on episode", url)
+        if (url == null) return TestResult.Fail // Should never trigger
+
+        var linksLoaded = 0
+        try {
+            val success = api.loadLinks(url, false, {}) { link ->
+                logger.invoke("Video loaded: ${link.name}")
+                Assert.assertTrue(
+                    "Api ${api.name} returns link with invalid url ${link.url}",
+                    link.url.length > 4
+                )
+                linksLoaded++
+            }
+            if (success) {
+                logger.invoke("Links loaded: $linksLoaded")
+                return TestResult(linksLoaded > 0)
+            } else {
+                Assert.fail("Api ${api.name} returns false on loadLinks() with $linksLoaded links loaded")
+            }
+        } catch (e: Throwable) {
+            when (e) {
+                is NotImplementedError -> {
+                    Assert.fail("Provider has not implemented loadLinks()")
+                }
+                else -> {
+                    logger.invoke("Failed link loading on ${api.name} using data: $url")
+                    throw e
+                }
+            }
+        }
+        return TestResult.Pass
+    }
+
+    fun getDeferredProviderTests(
+        scope: CoroutineScope,
+        providers: List<MainAPI>,
+        logger: (String) -> Unit,
+        callback: (MainAPI, TestResultProvider) -> Unit
+    ) {
+        providers.forEach { api ->
+            scope.launch {
+                var log = ""
+                fun addToLog(string: String) {
+                    log += string + "\n"
+                    logger.invoke(string)
+                }
+                fun getLog(): String {
+                    return log.removeSuffix("\n")
+                }
+
+                val result = try {
+                    addToLog("Trying ${api.name}")
+
+                    // Test Homepage
+                    val homepage = testHomepage(api, logger).success
+                    Assert.assertTrue("Homepage failed to load", homepage)
+
+                    // Test Search Results
+                    val searchResults = testSearch(api)
+                    Assert.assertTrue("Failed to get search results", searchResults.success)
+                    searchResults as TestResultSearch
+
+                    // Test Load and LoadLinks
+                    // Only try the first 3 search results to prevent spamming
+                    val success = searchResults.results.take(3).any { searchResponse ->
+                        addToLog("Testing search result: ${searchResponse.url}")
+                        val loadResponse = testLoad(api, searchResponse, ::addToLog)
+                        if (loadResponse !is TestResultLoad) {
+                            false
+                        } else {
+                            testLinkLoading(api, loadResponse.extractorData, ::addToLog).success
+                        }
+                    }
+
+                    if (success) {
+                        logger.invoke("Success ${api.name}")
+                        TestResultProvider(true, getLog(), null)
+                    } else {
+                        logger.invoke("Error ${api.name}")
+                        TestResultProvider(false, getLog(), null)
+                    }
+                } catch (e: Throwable) {
+                    TestResultProvider(false, getLog(), e)
+                }
+                callback.invoke(api, result)
+            }
+        }
+    }
+}

app/src/main/java/com/lagradost/cloudstream3/utils/VideoDownloadManager.kt

@@ -20,6 +20,7 @@ import androidx.work.Data
 import androidx.work.ExistingWorkPolicy
 import androidx.work.OneTimeWorkRequest
 import androidx.work.WorkManager
+import com.bumptech.glide.load.model.GlideUrl
 import com.fasterxml.jackson.annotation.JsonProperty
 import com.hippo.unifile.UniFile
 import com.lagradost.cloudstream3.APIHolder.getApiFromNameNull
@@ -213,7 +214,7 @@ object VideoDownloadManager {
     }
 
     private val cachedBitmaps = hashMapOf<String, Bitmap>()
-    private fun Context.getImageBitmapFromUrl(url: String): Bitmap? {
+    fun Context.getImageBitmapFromUrl(url: String, headers: Map<String, String>? = null): Bitmap? {
         try {
             if (cachedBitmaps.containsKey(url)) {
                 return cachedBitmaps[url]
@@ -221,12 +222,14 @@ object VideoDownloadManager {
 
             val bitmap = GlideApp.with(this)
                 .asBitmap()
-                .load(url).into(720, 720)
+                .load(GlideUrl(url) { headers ?: emptyMap() })
+                .into(720, 720)
                 .get()
+
             if (bitmap != null) {
                 cachedBitmaps[url] = bitmap
             }
-            return null
+            return bitmap
         } catch (e: Exception) {
             logError(e)
             return null
@@ -426,7 +429,7 @@ object VideoDownloadManager {
     }
 
     private const val reservedChars = "|\\?*<\":>+[]/\'"
-    fun sanitizeFilename(name: String, removeSpaces: Boolean= false): String {
+    fun sanitizeFilename(name: String, removeSpaces: Boolean = false): String {
         var tempName = name
         for (c in reservedChars) {
             tempName = tempName.replace(c, ' ')
@@ -1612,7 +1615,7 @@ object VideoDownloadManager {
                     .mapIndexed { index, any -> DownloadQueueResumePackage(index, any) }
                     .toTypedArray()
             setKey(KEY_RESUME_QUEUE_PACKAGES, dQueue)
-        } catch (t : Throwable) {
+        } catch (t: Throwable) {
             logError(t)
         }
     }

app/src/main/res/drawable/baseline_network_ping_24.xml

@@ -0,0 +1,5 @@
+<vector android:height="24dp" android:tint="?attr/white"
+    android:viewportHeight="24" android:viewportWidth="24"
+    android:width="24dp" xmlns:android="http://schemas.android.com/apk/res/android">
+    <path android:fillColor="@android:color/white" android:pathData="M12,14.67L3.41,6.09L2,7.5l8.5,8.5H4v2h16v-2h-6.5l5.15,-5.15C18.91,10.95 19.2,11 19.5,11c1.38,0 2.5,-1.12 2.5,-2.5S20.88,6 19.5,6S17,7.12 17,8.5c0,0.35 0.07,0.67 0.2,0.97L12,14.67z"/>
+</vector>

app/src/main/res/drawable/baseline_notifications_none_24.xml

@@ -0,0 +1,5 @@
+<vector android:height="24dp" android:tint="?attr/white"
+    android:viewportHeight="24" android:viewportWidth="24"
+    android:width="24dp" xmlns:android="http://schemas.android.com/apk/res/android">
+    <path android:fillColor="@android:color/white" android:pathData="M12,22c1.1,0 2,-0.9 2,-2h-4c0,1.1 0.9,2 2,2zM18,16v-5c0,-3.07 -1.63,-5.64 -4.5,-6.32L13.5,4c0,-0.83 -0.67,-1.5 -1.5,-1.5s-1.5,0.67 -1.5,1.5v0.68C7.64,5.36 6,7.92 6,11v5l-2,2v1h16v-1l-2,-2zM16,17L8,17v-6c0,-2.48 1.51,-4.5 4,-4.5s4,2.02 4,4.5v6z"/>
+</vector>

app/src/main/res/drawable/baseline_text_snippet_24.xml

@@ -0,0 +1,5 @@
+<vector android:autoMirrored="true" android:height="24dp"
+    android:tint="?attr/white" android:viewportHeight="24"
+    android:viewportWidth="24" android:width="24dp" xmlns:android="http://schemas.android.com/apk/res/android">
+    <path android:fillColor="?attr/white" android:pathData="M20.41,8.41l-4.83,-4.83C15.21,3.21 14.7,3 14.17,3H5C3.9,3 3,3.9 3,5v14c0,1.1 0.9,2 2,2h14c1.1,0 2,-0.9 2,-2V9.83C21,9.3 20.79,8.79 20.41,8.41zM7,7h7v2H7V7zM17,17H7v-2h10V17zM17,13H7v-2h10V13z"/>
+</vector>

app/src/main/res/drawable/ic_cloudstream_monochrome_big.xml

@@ -0,0 +1,27 @@
+<?xml version="1.0" encoding="utf-8"?>
+<vector xmlns:android="http://schemas.android.com/apk/res/android"
+    xmlns:tools="http://schemas.android.com/tools"
+    android:width="108dp"
+    android:height="108dp"
+    android:viewportWidth="50"
+    android:viewportHeight="50"
+    android:name="vector">
+    <group android:scaleX="0.1755477"
+        android:scaleY="0.1755477"
+        android:translateX="0"
+        android:translateY="0">
+        <path android:name="path"
+
+            android:pathData="M 245.05 148.63 C 242.249 148.627 239.463 149.052 236.79 149.89 C 235.151 141.364 230.698 133.63 224.147 127.931 C 217.597 122.233 209.321 118.893 200.65 118.45 C 195.913 105.431 186.788 94.458 174.851 87.427 C 162.914 80.396 148.893 77.735 135.21 79.905 C 121.527 82.074 109.017 88.941 99.84 99.32 C 89.871 95.945 79.051 96.024 69.133 99.545 C 59.215 103.065 50.765 109.826 45.155 118.73 C 39.545 127.634 37.094 138.174 38.2 148.64 L 37.94 148.64 C 30.615 148.64 23.582 151.553 18.403 156.733 C 13.223 161.912 10.31 168.945 10.31 176.27 C 10.31 183.595 13.223 190.628 18.403 195.807 C 23.582 200.987 30.615 203.9 37.94 203.9 L 245.05 203.9 C 252.375 203.9 259.408 200.987 264.587 195.807 C 269.767 190.628 272.68 183.595 272.68 176.27 C 272.68 168.945 269.767 161.912 264.587 156.733 C 259.408 151.553 252.375 148.64 245.05 148.64 Z"
+            android:fillColor="#FFFFFF" android:strokeWidth="1"
+            tools:ignore="VectorPath"
+            android:fillAlpha="0.55"/>
+        <path android:name="path_1" android:pathData="M 208.61 125 C 208.61 123.22 208.55 121.45 208.48 119.69 C 205.919 119.01 203.296 118.595 200.65 118.45 C 195.913 105.431 186.788 94.458 174.851 87.427 C 162.914 80.396 148.893 77.735 135.21 79.905 C 121.527 82.074 109.017 88.941 99.84 99.32 C 89.871 95.945 79.051 96.024 69.133 99.545 C 59.215 103.065 50.765 109.826 45.155 118.73 C 39.545 127.634 37.094 138.174 38.2 148.64 L 37.94 148.64 C 30.615 148.64 23.582 151.553 18.403 156.733 C 13.223 161.912 10.31 168.945 10.31 176.27 C 10.31 183.595 13.223 190.628 18.403 195.807 C 23.582 200.987 30.615 203.9 37.94 203.9 L 179 203.9 C 198.116 182.073 208.646 154.015 208.61 125 Z"
+            android:fillColor="#FFFFFF" android:strokeWidth="1"
+            android:fillAlpha="0.55"/>
+        <path android:name="path_2" android:pathData="M 99.84 99.32 C 89.871 95.945 79.051 96.024 69.133 99.545 C 59.215 103.065 50.765 109.826 45.155 118.73 C 39.545 127.634 37.094 138.174 38.2 148.64 L 37.94 148.64 C 30.783 148.665 23.909 151.471 18.779 156.461 C 13.648 161.452 10.653 168.246 10.43 175.399 C 10.207 182.553 12.773 189.52 17.583 194.82 C 22.392 200.121 29.079 203.349 36.22 203.82 C 67.216 202.93 96.673 189.98 118.284 167.742 C 139.895 145.504 151.997 115.689 152 84.68 C 152 83 151.94 81.33 151.87 79.68 C 149.443 79.361 146.998 79.194 144.55 79.18 C 136.095 79.171 127.735 80.962 120.026 84.434 C 112.317 87.907 105.435 92.982 99.84 99.32 Z"
+            android:fillColor="#FFFFFF" android:strokeWidth="1"
+            android:fillAlpha="1"/>
+    </group>
+
+</vector>

app/src/main/res/layout/bottom_selection_dialog_direct.xml

@@ -1,34 +1,34 @@
 <?xml version="1.0" encoding="utf-8"?>
 <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
-        xmlns:tools="http://schemas.android.com/tools"
+    xmlns:tools="http://schemas.android.com/tools"
-        android:orientation="vertical"
+    android:layout_width="match_parent"
-        android:layout_width="match_parent"
+    android:layout_height="match_parent"
-        android:layout_height="match_parent">
+    android:orientation="vertical">
 
     <TextView
-            android:id="@+id/text1"
+        android:id="@+id/text1"
-            android:paddingStart="?android:attr/listPreferredItemPaddingStart"
+        android:layout_width="match_parent"
-            android:paddingEnd="?android:attr/listPreferredItemPaddingEnd"
+        android:layout_height="wrap_content"
-            android:layout_marginTop="20dp"
+        android:layout_rowWeight="1"
-            android:layout_marginBottom="10dp"
+        android:layout_marginTop="20dp"
-            android:textStyle="bold"
+        android:layout_marginBottom="10dp"
-            android:textSize="20sp"
+        android:paddingStart="?android:attr/listPreferredItemPaddingStart"
-            android:textColor="?attr/textColor"
+        android:paddingEnd="?android:attr/listPreferredItemPaddingEnd"
-            android:layout_width="match_parent"
+        android:textColor="?attr/textColor"
-            android:layout_rowWeight="1"
+        android:textSize="20sp"
-            tools:text="Test"
+        android:textStyle="bold"
-            android:layout_height="wrap_content" />
+        tools:text="Test" />
 
     <ListView
-            android:nextFocusRight="@id/cancel_btt"
+        android:id="@+id/listview1"
-            android:nextFocusLeft="@id/apply_btt"
+        android:layout_width="match_parent"
-
+        android:layout_height="match_parent"
-            android:id="@+id/listview1"
+        android:layout_rowWeight="1"
-            android:layout_marginBottom="60dp"
+        android:layout_marginBottom="60dp"
-            android:paddingTop="10dp"
+        android:nestedScrollingEnabled="true"
-            android:requiresFadingEdge="vertical"
+        android:nextFocusLeft="@id/apply_btt"
-            tools:listitem="@layout/sort_bottom_single_choice_no_checkmark"
+        android:nextFocusRight="@id/cancel_btt"
-            android:layout_width="match_parent"
+        android:paddingTop="10dp"
-            android:layout_height="match_parent"
+        android:requiresFadingEdge="vertical"
-            android:layout_rowWeight="1" />
+        tools:listitem="@layout/sort_bottom_single_choice_no_checkmark" />
 </LinearLayout>

app/src/main/res/layout/fragment_result.xml

@@ -129,9 +129,9 @@
         <androidx.core.widget.NestedScrollView
             android:id="@+id/result_scroll"
             android:layout_width="match_parent"
-            android:paddingBottom="100dp"
+            android:layout_height="wrap_content"
             android:clipToPadding="false"
-            android:layout_height="wrap_content">
+            android:paddingBottom="100dp">
 
             <LinearLayout
                 android:layout_width="match_parent"
@@ -326,13 +326,12 @@
 
                             <ImageView
                                 android:id="@+id/result_poster"
-
                                 android:layout_width="100dp"
                                 android:layout_height="140dp"
+                                android:layout_gravity="bottom"
                                 android:contentDescription="@string/result_poster_img_des"
                                 android:foreground="@drawable/outline_drawable"
                                 android:scaleType="centerCrop"
-                                android:layout_gravity="bottom"
                                 tools:src="@drawable/example_poster" />
                         </androidx.cardview.widget.CardView>
 
@@ -516,8 +515,8 @@
                         android:visibility="gone" />
 
                     <com.google.android.material.chip.ChipGroup
-                        style="@style/ChipParent"
                         android:id="@+id/result_tag"
+                        style="@style/ChipParent"
                         android:layout_width="match_parent"
                         android:layout_height="wrap_content" />
                     <!--<com.lagradost.cloudstream3.widget.FlowLayout
@@ -818,10 +817,13 @@
                                     android:layout_gravity="center_vertical"
                                     android:layout_marginStart="0dp"
                                     android:layout_marginEnd="10dp"
+                                    android:drawableEnd="@drawable/ic_baseline_keyboard_arrow_down_24"
                                     android:nextFocusLeft="@id/result_episode_select"
                                     android:nextFocusRight="@id/result_episode_select"
                                     android:nextFocusUp="@id/result_description"
                                     android:nextFocusDown="@id/result_episodes"
+                                    android:paddingStart="10dp"
+                                    android:paddingEnd="5dp"
                                     android:visibility="gone"
                                     tools:text="Season 1"
                                     tools:visibility="visible" />
@@ -829,16 +831,16 @@
                                 <com.google.android.material.button.MaterialButton
                                     android:id="@+id/result_episode_select"
                                     style="@style/MultiSelectButton"
-
                                     android:layout_gravity="center_vertical"
                                     android:layout_marginStart="0dp"
                                     android:layout_marginEnd="10dp"
-
+                                    android:drawableEnd="@drawable/ic_baseline_keyboard_arrow_down_24"
                                     android:nextFocusLeft="@id/result_season_button"
                                     android:nextFocusRight="@id/result_season_button"
-
                                     android:nextFocusUp="@id/result_description"
                                     android:nextFocusDown="@id/result_episodes"
+                                    android:paddingStart="10dp"
+                                    android:paddingEnd="5dp"
                                     android:visibility="gone"
                                     tools:text="50-100"
                                     tools:visibility="visible" />
@@ -846,15 +848,16 @@
                                 <com.google.android.material.button.MaterialButton
                                     android:id="@+id/result_dub_select"
                                     style="@style/MultiSelectButton"
-
                                     android:layout_gravity="center_vertical"
                                     android:layout_marginStart="0dp"
                                     android:layout_marginEnd="10dp"
+                                    android:drawableEnd="@drawable/ic_baseline_keyboard_arrow_down_24"
                                     android:nextFocusLeft="@id/result_season_button"
                                     android:nextFocusRight="@id/result_season_button"
-
                                     android:nextFocusUp="@id/result_description"
                                     android:nextFocusDown="@id/result_episodes"
+                                    android:paddingStart="10dp"
+                                    android:paddingEnd="5dp"
                                     android:visibility="gone"
                                     tools:text="Dubbed"
                                     tools:visibility="visible" />

app/src/main/res/layout/fragment_result_swipe.xml

@@ -57,6 +57,7 @@
                 android:layout_width="match_parent"
                 android:layout_height="50dp"
                 android:id="@+id/media_route_button_holder"
+                android:animateLayoutChanges="true"
                 android:layout_gravity="center_vertical|end">
 
             <androidx.mediarouter.app.MediaRouteButton
@@ -69,15 +70,35 @@
                     app:mediaRouteButtonTint="?attr/textColor" />
 
             <ImageView
+                    android:visibility="gone"
                     android:nextFocusUp="@id/result_back"
                     android:nextFocusDown="@id/result_description"
                     android:nextFocusLeft="@id/result_add_sync"
+                    android:nextFocusRight="@id/result_share"
+
+                    tools:visibility="visible"
+
+                    android:id="@+id/result_subscribe"
+                    android:layout_width="25dp"
+                    android:layout_height="25dp"
+                    android:layout_margin="5dp"
+                    android:elevation="10dp"
+
+                    android:background="?android:attr/selectableItemBackgroundBorderless"
+                    android:src="@drawable/baseline_notifications_none_24"
+                    android:layout_gravity="end|center_vertical"
+                    app:tint="?attr/textColor" />
+
+            <ImageView
+                    android:nextFocusUp="@id/result_back"
+                    android:nextFocusDown="@id/result_description"
+                    android:nextFocusLeft="@id/result_subscribe"
                     android:nextFocusRight="@id/result_open_in_browser"
 
                     android:id="@+id/result_share"
                     android:layout_width="25dp"
                     android:layout_height="25dp"
-                    android:layout_marginEnd="10dp"
+                    android:layout_margin="5dp"
                     android:elevation="10dp"
 
                     android:background="?android:attr/selectableItemBackgroundBorderless"

app/src/main/res/layout/fragment_testing.xml

@@ -0,0 +1,53 @@
+<?xml version="1.0" encoding="utf-8"?>
+<androidx.coordinatorlayout.widget.CoordinatorLayout xmlns:android="http://schemas.android.com/apk/res/android"
+    xmlns:app="http://schemas.android.com/apk/res-auto"
+    xmlns:tools="http://schemas.android.com/tools"
+    android:layout_width="match_parent"
+    android:layout_height="match_parent"
+    android:backgroundTint="?attr/primaryBlackBackground"
+    android:orientation="vertical">
+
+    <com.google.android.material.appbar.AppBarLayout
+        android:id="@+id/provider_test_appbar"
+        android:layout_width="match_parent"
+        android:layout_height="wrap_content">
+
+        <com.google.android.material.appbar.MaterialToolbar
+            android:id="@+id/settings_toolbar"
+            android:layout_width="match_parent"
+            android:layout_height="wrap_content"
+            android:background="?attr/primaryGrayBackground"
+            android:paddingTop="@dimen/navbar_height"
+            app:layout_scrollFlags="scroll|enterAlways"
+            app:navigationIconTint="?attr/iconColor"
+            app:titleTextColor="?attr/textColor"
+            tools:title="@string/category_provider_test">
+
+        </com.google.android.material.appbar.MaterialToolbar>
+
+        <com.lagradost.cloudstream3.ui.settings.testing.TestView
+            android:id="@+id/provider_test"
+            android:layout_width="match_parent"
+            android:layout_height="wrap_content"
+            android:nextFocusDown="@id/provider_test_recycler_view"
+            app:header_text="@string/category_provider_test"
+            app:layout_scrollFlags="scroll|enterAlways" />
+    </com.google.android.material.appbar.AppBarLayout>
+
+    <LinearLayout
+        android:layout_width="match_parent"
+        android:layout_height="wrap_content"
+        android:orientation="vertical"
+        app:layout_behavior="@string/appbar_scrolling_view_behavior">
+
+        <androidx.recyclerview.widget.RecyclerView
+            android:id="@+id/provider_test_recycler_view"
+            android:clipToPadding="false"
+            android:paddingBottom="60dp"
+            android:layout_width="match_parent"
+            android:layout_height="match_parent"
+            app:layoutManager="androidx.recyclerview.widget.LinearLayoutManager"
+            tools:listitem="@layout/provider_test_item" />
+
+    </LinearLayout>
+</androidx.coordinatorlayout.widget.CoordinatorLayout>

app/src/main/res/layout/provider_test_item.xml

@@ -0,0 +1,71 @@
+<?xml version="1.0" encoding="utf-8"?>
+<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
+    xmlns:app="http://schemas.android.com/apk/res-auto"
+    xmlns:tools="http://schemas.android.com/tools"
+    android:layout_width="match_parent"
+    android:layout_height="wrap_content"
+    android:background="?attr/selectableItemBackground"
+    android:nextFocusRight="@id/action_button"
+    android:orientation="horizontal"
+    android:padding="12dp">
+
+    <LinearLayout
+        android:layout_width="0dp"
+        android:layout_height="wrap_content"
+        android:layout_gravity="center_vertical"
+        android:layout_weight="1"
+        android:orientation="vertical">
+
+        <TextView
+            android:id="@+id/main_text"
+            android:layout_width="wrap_content"
+            android:layout_height="wrap_content"
+            android:textColor="?attr/textColor"
+            android:textSize="16sp"
+            tools:text="Test repository" />
+
+        <LinearLayout
+            android:layout_width="match_parent"
+            android:layout_height="match_parent"
+            android:layout_gravity="center_vertical"
+            android:orientation="horizontal">
+
+            <TextView
+                android:id="@+id/lang_icon"
+                android:layout_width="wrap_content"
+                android:layout_height="match_parent"
+                android:layout_marginEnd="5dp"
+                tools:text="🇷🇼"
+                android:textColor="?attr/grayTextColor"
+                tools:visibility="visible" />
+
+            <TextView
+                android:id="@+id/passed_failed_marker"
+                android:layout_width="wrap_content"
+                android:layout_height="wrap_content"
+                tools:text="Failed"
+                tools:visibility="visible" />
+        </LinearLayout>
+
+        <TextView
+            android:id="@+id/fail_description"
+            android:layout_width="wrap_content"
+            android:layout_height="wrap_content"
+            android:textColor="?attr/grayTextColor"
+            tools:text="Unable to load videos"
+            tools:visibility="visible" />
+    </LinearLayout>
+
+    <ImageView
+        android:id="@+id/action_button"
+        android:layout_width="wrap_content"
+        android:layout_height="wrap_content"
+        android:layout_gravity="center_vertical|end"
+        android:layout_marginStart="10dp"
+        android:background="?attr/selectableItemBackgroundBorderless"
+        android:clickable="true"
+        android:focusable="true"
+        android:padding="12dp"
+        android:src="@drawable/baseline_text_snippet_24"
+        app:tint="?attr/white" />
+</LinearLayout>

app/src/main/res/layout/view_test.xml

@@ -0,0 +1,138 @@
+<?xml version="1.0" encoding="utf-8"?>
+<androidx.cardview.widget.CardView xmlns:android="http://schemas.android.com/apk/res/android"
+    xmlns:app="http://schemas.android.com/apk/res-auto"
+    xmlns:tools="http://schemas.android.com/tools"
+    style="@style/Widget.Material3.CardView.Elevated"
+    android:layout_width="match_parent"
+    android:layout_height="wrap_content"
+    app:cardBackgroundColor="?attr/primaryBlackBackground">
+
+    <LinearLayout
+        android:layout_width="match_parent"
+        android:layout_height="wrap_content"
+        android:orientation="vertical"
+        android:paddingBottom="10dp">
+
+        <LinearLayout
+            android:id="@+id/main_test_section"
+            android:layout_width="match_parent"
+            android:layout_height="match_parent"
+            android:background="@drawable/outline_drawable_less"
+            android:gravity="center"
+            android:orientation="horizontal"
+            android:paddingHorizontal="10dp"
+            android:paddingVertical="10dp">
+
+            <TextView
+                android:id="@+id/main_test_header"
+                android:layout_width="0dp"
+                android:layout_height="wrap_content"
+                android:layout_weight="1"
+                android:textSize="17sp"
+                tools:text="Homepage test" />
+
+            <TextView
+                android:id="@+id/main_test_section_progress"
+                android:layout_width="0dp"
+                android:layout_height="wrap_content"
+                android:layout_weight="1"
+                android:gravity="end"
+                android:textSize="17sp"
+                tools:text="67 / 120 " />
+        </LinearLayout>
+
+        <androidx.cardview.widget.CardView
+            android:layout_width="match_parent"
+            android:layout_height="wrap_content"
+            android:layout_margin="10dp"
+            app:cardBackgroundColor="?attr/primaryGrayBackground"
+            app:cardCornerRadius="@dimen/rounded_image_radius">
+
+            <LinearLayout
+                android:layout_width="match_parent"
+                android:layout_height="match_parent"
+                android:orientation="vertical">
+
+                <LinearLayout
+                    android:id="@+id/passed_test_section"
+                    android:layout_width="match_parent"
+                    android:layout_height="match_parent"
+                    android:background="@drawable/outline_drawable_less"
+                    android:gravity="center"
+                    android:orientation="horizontal"
+                    android:padding="10dp">
+
+                    <TextView
+                        android:layout_width="0dp"
+                        android:layout_height="wrap_content"
+                        android:layout_weight="1"
+                        android:text="Tests passed"
+                        android:textSize="17sp" />
+
+                    <TextView
+                        android:id="@+id/passed_test_section_progress"
+                        android:layout_width="0dp"
+                        android:layout_height="wrap_content"
+                        android:layout_weight="1"
+                        android:gravity="end"
+                        android:textSize="17sp"
+                        tools:text="55" />
+                </LinearLayout>
+
+                <LinearLayout
+                    android:id="@+id/failed_test_section"
+                    android:layout_width="match_parent"
+                    android:layout_height="match_parent"
+                    android:background="@drawable/outline_drawable_less"
+                    android:gravity="center"
+                    android:orientation="horizontal"
+                    android:padding="10dp">
+
+                    <TextView
+                        android:layout_width="0dp"
+                        android:layout_height="wrap_content"
+                        android:layout_weight="1"
+                        android:text="Tests failed"
+                        android:textSize="17sp" />
+
+                    <TextView
+                        android:id="@+id/failed_test_section_progress"
+                        android:layout_width="0dp"
+                        android:layout_height="wrap_content"
+                        android:layout_weight="1"
+                        android:gravity="end"
+                        android:textSize="17sp"
+                        tools:text="12" />
+                </LinearLayout>
+
+            </LinearLayout>
+
+
+        </androidx.cardview.widget.CardView>
+
+        <com.google.android.material.button.MaterialButton
+            android:id="@+id/tests_play_pause"
+            style="@style/WhiteButton"
+            android:layout_width="wrap_content"
+            android:layout_margin="10dp"
+            android:text="@string/start"
+            app:icon="@drawable/ic_baseline_play_arrow_24">
+
+        </com.google.android.material.button.MaterialButton>
+
+    </LinearLayout>
+
+
+    <androidx.core.widget.ContentLoadingProgressBar
+        android:id="@+id/test_total_progress"
+        style="@android:style/Widget.Material.ProgressBar.Horizontal"
+        android:layout_width="match_parent"
+        android:layout_height="5dp"
+        android:layout_gravity="bottom"
+        android:layout_marginBottom="-1.5dp"
+        android:progressBackgroundTint="?attr/colorPrimary"
+        android:progressTint="?attr/colorPrimary"
+        android:visibility="gone"
+        tools:progress="50" />
+
+</androidx.cardview.widget.CardView>

app/src/main/res/navigation/mobile_navigation.xml

@@ -519,6 +519,23 @@
         app:popExitAnim="@anim/exit_anim"
         tools:layout="@layout/fragment_player" />
 
+    <fragment
+        android:id="@+id/navigation_test_providers"
+        android:name="com.lagradost.cloudstream3.ui.settings.testing.TestFragment"
+        android:layout_height="match_parent"
+        app:enterAnim="@anim/enter_anim"
+        app:exitAnim="@anim/exit_anim"
+        app:popEnterAnim="@anim/enter_anim"
+        app:popExitAnim="@anim/exit_anim"
+        tools:layout="@layout/fragment_testing">
+        <action
+            android:id="@+id/action_navigation_global_to_navigation_test_providers"
+            app:destination="@id/navigation_test_providers"
+            app:enterAnim="@anim/enter_anim"
+            app:exitAnim="@anim/exit_anim"
+            app:popEnterAnim="@anim/enter_anim"
+            app:popExitAnim="@anim/exit_anim" />
+    </fragment>
 
     <fragment
         android:id="@+id/navigation_setup_language"

app/src/main/res/values/attrs.xml

@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="utf-8"?>
 <resources>
     <declare-styleable name="FlowLayout_Layout">
-        <attr format="dimension" name="itemSpacing" />
+        <attr name="itemSpacing" format="dimension" />
     </declare-styleable>
     <declare-styleable name="FlowLayout_Layout_layout_space" />
 
@@ -13,6 +13,10 @@
         <item name="customCastBackgroundColor">?attr/colorPrimary</item>
     </style>
 
+    <declare-styleable name="TestView">
+        <attr name="header_text" format="string" />
+    </declare-styleable>
+
     <declare-styleable name="MainColors">
         <attr name="colorPrimary" format="color" />
         <attr name="colorSearch" format="color" />

app/src/main/res/values/colors.xml

@@ -82,4 +82,7 @@
     <color name="colorPrimaryGrey">#515151</color>
     <color name="colorPrimaryWhite">#FFFFFF</color>
     <color name="colorPrimaryBrown">#622C00</color>
+
+    <color name="colorTestPass">#48E484</color>
+    <color name="colorTestFail">#ea596e</color>
 </resources>

app/src/main/res/values/strings.xml

@@ -13,6 +13,7 @@
     <string name="fast_forward_button_time_key" translatable="false">fast_forward_button_time</string>
     <string name="benene_count" translatable="false">benene_count</string>
     <string name="subtitle_settings_key" translatable="false">subtitle_settings_key</string>
+    <string name="test_providers_key" translatable="false">test_providers_key</string>
     <string name="subtitle_settings_chromecast_key" translatable="false">subtitle_settings_chromecast_key</string>
     <string name="quality_pref_key" translatable="false">quality_pref_key</string>
     <string name="player_pref_key" translatable="false">player_pref_key</string>
@@ -196,6 +197,7 @@
     <string name="normal_no_plot">No Plot Found</string>
     <string name="torrent_no_plot">No Description Found</string>
     <string name="show_log_cat">Show Logcat 🐈</string>
+    <string name="test_log">Log</string>
     <string name="picture_in_picture">Picture-in-picture</string>
     <string name="picture_in_picture_des">Continues playback in a miniature player on top of other apps</string>
     <string name="player_size_settings">Player resize button</string>
@@ -283,6 +285,9 @@
     <string name="delete">Delete</string>
     <string name="cancel" translatable="false">@string/sort_cancel</string>
     <string name="pause">Pause</string>
+    <string name="start">Start</string>
+    <string name="test_failed">Failed</string>
+    <string name="test_passed">Passed</string>
     <string name="resume">Resume</string>
     <string name="go_back_30">-30</string>
     <string name="go_forward_30">+30</string>
@@ -428,6 +433,7 @@
     <string name="enable_nsfw_on_providers">Enable NSFW on supported providers</string>
     <string name="subtitles_encoding">Subtitle encoding</string>
     <string name="category_providers">Providers</string>
+    <string name="category_provider_test">Provider test</string>
     <string name="category_ui">Layout</string>
     <string name="automatic">Auto</string>
     <string name="tv_layout">TV layout</string>
@@ -584,6 +590,8 @@
     <string name="audio_tracks">Audio tracks</string>
     <string name="video_tracks">Video tracks</string>
     <string name="apply_on_restart">Apply on Restart</string>
+    <string name="restart">Restart</string>
+    <string name="stop">Stop</string>
     <string name="safe_mode_title">Safe mode on</string>
     <string name="safe_mode_description">All extensions were turned off due to a crash to help you find the one causing trouble.</string>
     <string name="safe_mode_crash_info">View crash info</string>
@@ -642,4 +650,9 @@
     <string name="empty_library_logged_in_message">Looks like this list is empty, try switching to another one</string>
     <string name="safe_mode_file">Safe mode file found!\nNot loading any extensions on startup until file is removed.</string>
     <string name="revert">Revert</string>
+    <string name="subscription_in_progress_notification">Updating subscribed shows</string>
+    <string name="subscription_list_name">Subscribed</string>
+    <string name="subscription_new">Subscribed to %s</string>
+    <string name="subscription_deleted">Unsubscribed from %s</string>
+    <string name="subscription_episode_released">Episode %d released!</string>
 </resources>

app/src/main/res/xml/settings_providers.xml

@@ -1,24 +1,30 @@
 <?xml version="1.0" encoding="utf-8"?>
 <PreferenceScreen xmlns:android="http://schemas.android.com/apk/res/android"
-        xmlns:app="http://schemas.android.com/apk/res-auto">
+    xmlns:app="http://schemas.android.com/apk/res-auto">
     <Preference
-            android:icon="@drawable/ic_baseline_language_24"
+        android:icon="@drawable/ic_baseline_language_24"
-            android:key="@string/provider_lang_key"
+        android:key="@string/provider_lang_key"
-            android:title="@string/provider_lang_settings" />
+        android:title="@string/provider_lang_settings" />
 
     <Preference
-            android:key="@string/prefer_media_type_key"
+        android:icon="@drawable/ic_baseline_play_arrow_24"
-            android:title="@string/preferred_media_settings"
+        android:key="@string/prefer_media_type_key"
-            android:icon="@drawable/ic_baseline_play_arrow_24" />
+        android:title="@string/preferred_media_settings" />
     <Preference
-            android:key="@string/display_sub_key"
+        android:icon="@drawable/ic_outline_voice_over_off_24"
-            android:title="@string/display_subbed_dubbed_settings"
+        android:key="@string/display_sub_key"
-            android:icon="@drawable/ic_outline_voice_over_off_24" />
+        android:title="@string/display_subbed_dubbed_settings" />
 
     <SwitchPreference
-            android:key="@string/enable_nsfw_on_providers_key"
+        android:icon="@drawable/ic_baseline_extension_24"
-            android:title="@string/enable_nsfw_on_providers"
+        android:key="@string/enable_nsfw_on_providers_key"
-            android:icon="@drawable/ic_baseline_extension_24"
+        android:summary="@string/apply_on_restart"
-            android:summary="@string/apply_on_restart"
+        android:title="@string/enable_nsfw_on_providers"
-            app:defaultValue="false"/>
+        app:defaultValue="false" />
+
+    <Preference
+        android:icon="@drawable/baseline_network_ping_24"
+        android:key="@string/test_providers_key"
+        android:title="Test all providers" />
+
 </PreferenceScreen>