From fe8dc9a5b44a9fc37e6b789ad103322355019964 Mon Sep 17 00:00:00 2001
From: Ahmed gamal <12355.ahmedgamal.com@gmail.com>
Date: Mon, 7 Feb 2022 13:10:34 +0200
Subject: [PATCH] asianload, dramacool: fix streamsb extractor and other
 modifications (#309)

---
 src/en/asianload/build.gradle                 |   2 +-
 .../animeextension/en/asianload/AsianLoad.kt  | 160 +++++-------------
 .../en/asianload/extractors/DoodExtractor.kt  |  43 +++++
 .../asianload/extractors/FembedExtractor.kt   |  24 +++
 .../asianload/extractors/StreamSBExtractor.kt |  44 +++++
 .../extractors/StreamTapeExtractor.kt         |  19 +++
 src/en/dramacool/build.gradle                 |   2 +-
 .../animeextension/en/dramacool/DramaCool.kt  | 138 ++++-----------
 .../en/dramacool/extractors/DoodExtractor.kt  |  43 +++++
 .../dramacool/extractors/FembedExtractor.kt   |  24 +++
 .../dramacool/extractors/StreamSBExtractor.kt |  44 +++++
 .../extractors/StreamTapeExtractor.kt         |  19 +++
 12 files changed, 338 insertions(+), 224 deletions(-)
 create mode 100644 src/en/asianload/src/eu/kanade/tachiyomi/animeextension/en/asianload/extractors/DoodExtractor.kt
 create mode 100644 src/en/asianload/src/eu/kanade/tachiyomi/animeextension/en/asianload/extractors/FembedExtractor.kt
 create mode 100644 src/en/asianload/src/eu/kanade/tachiyomi/animeextension/en/asianload/extractors/StreamSBExtractor.kt
 create mode 100644 src/en/asianload/src/eu/kanade/tachiyomi/animeextension/en/asianload/extractors/StreamTapeExtractor.kt
 create mode 100644 src/en/dramacool/src/eu/kanade/tachiyomi/animeextension/en/dramacool/extractors/DoodExtractor.kt
 create mode 100644 src/en/dramacool/src/eu/kanade/tachiyomi/animeextension/en/dramacool/extractors/FembedExtractor.kt
 create mode 100644 src/en/dramacool/src/eu/kanade/tachiyomi/animeextension/en/dramacool/extractors/StreamSBExtractor.kt
 create mode 100644 src/en/dramacool/src/eu/kanade/tachiyomi/animeextension/en/dramacool/extractors/StreamTapeExtractor.kt

diff --git a/src/en/asianload/build.gradle b/src/en/asianload/build.gradle
index 656afe21d..cd90eb5ec 100644
--- a/src/en/asianload/build.gradle
+++ b/src/en/asianload/build.gradle
@@ -5,7 +5,7 @@ ext {
     extName = 'AsianLoad'
     pkgNameSuffix = 'en.asianload'
     extClass = '.AsianLoad'
-    extVersionCode = 2
+    extVersionCode = 3
     libVersion = '12'
 }
 
diff --git a/src/en/asianload/src/eu/kanade/tachiyomi/animeextension/en/asianload/AsianLoad.kt b/src/en/asianload/src/eu/kanade/tachiyomi/animeextension/en/asianload/AsianLoad.kt
index 4fcfad16b..53f764e47 100644
--- a/src/en/asianload/src/eu/kanade/tachiyomi/animeextension/en/asianload/AsianLoad.kt
+++ b/src/en/asianload/src/eu/kanade/tachiyomi/animeextension/en/asianload/AsianLoad.kt
@@ -2,10 +2,13 @@ package eu.kanade.tachiyomi.animeextension.en.asianload
 
 import android.app.Application
 import android.content.SharedPreferences
-import android.net.Uri
 import android.util.Log
 import androidx.preference.ListPreference
 import androidx.preference.PreferenceScreen
+import eu.kanade.tachiyomi.animeextension.en.asianload.extractors.DoodExtractor
+import eu.kanade.tachiyomi.animeextension.en.asianload.extractors.FembedExtractor
+import eu.kanade.tachiyomi.animeextension.en.asianload.extractors.StreamSBExtractor
+import eu.kanade.tachiyomi.animeextension.en.asianload.extractors.StreamTapeExtractor
 import eu.kanade.tachiyomi.animesource.ConfigurableAnimeSource
 import eu.kanade.tachiyomi.animesource.model.AnimeFilter
 import eu.kanade.tachiyomi.animesource.model.AnimeFilterList
@@ -14,7 +17,6 @@ import eu.kanade.tachiyomi.animesource.model.SEpisode
 import eu.kanade.tachiyomi.animesource.model.Video
 import eu.kanade.tachiyomi.animesource.online.ParsedAnimeHttpSource
 import eu.kanade.tachiyomi.network.GET
-import eu.kanade.tachiyomi.network.POST
 import eu.kanade.tachiyomi.util.asJsoup
 import okhttp3.Headers
 import okhttp3.HttpUrl.Companion.toHttpUrlOrNull
@@ -51,7 +53,7 @@ class AsianLoad : ConfigurableAnimeSource, ParsedAnimeHttpSource() {
 
     override fun popularAnimeSelector(): String = "ul.listing.items li a"
 
-    override fun popularAnimeRequest(page: Int): Request = GET("$baseUrl/popular?page=$page")
+    override fun popularAnimeRequest(page: Int): Request = GET("$baseUrl/popular?page=$page") // page/$page
 
     override fun popularAnimeFromElement(element: Element): SAnime {
         val anime = SAnime.create()
@@ -80,7 +82,7 @@ class AsianLoad : ConfigurableAnimeSource, ParsedAnimeHttpSource() {
         // episode.date_upload = element.select("div.meta span.date").text()
         return episode
     }
-    
+
     private fun getNumberFromEpsString(epsStr: String): String {
         return epsStr.filter { it.isDigit() }
     }
@@ -98,10 +100,7 @@ class AsianLoad : ConfigurableAnimeSource, ParsedAnimeHttpSource() {
         return videosFromElement(document)
     }
 
-    val srcVid = preferences.getString("preferred_server", "https://dood")
-
-    override fun videoListSelector() = "ul.list-server-items li[data-video*=$srcVid]"
-    // "ul.list-server-items li[data-video*=https://sbplay2.com], ul.list-server-items li[data-video*=https://dood], ul.list-server-items li[data-video*=https://streamtape], ul.list-server-items li[data-video*=https://fembed]"
+    override fun videoListSelector() = "ul.list-server-items li[data-video*=https://sbplay2.com], ul.list-server-items li[data-video*=https://dood], ul.list-server-items li[data-video*=https://streamtape], ul.list-server-items li[data-video*=https://fembed]"
 
     private fun videosFromElement(document: Document): List<Video> {
         val videoList = mutableListOf<Video>()
@@ -112,34 +111,42 @@ class AsianLoad : ConfigurableAnimeSource, ParsedAnimeHttpSource() {
             val location = element.ownerDocument().location()
             val videoHeaders = Headers.headersOf("Referer", location)
             when {
-                url.contains("https://sbplay") -> {
-                    val videos = sbplayUrlParse(url.substringBefore("?caption"), location)
+                url.contains("sbplay2") -> {
+                    /*val id = url.substringAfter("e/").substringBefore("?")
+                    Log.i("idtest", id)
+                    val bytes = id.toByteArray()
+                    Log.i("idencode", "$bytes")
+                    val bytesToHex = bytesToHex(bytes)
+                    Log.i("bytesToHex", bytesToHex)
+                    val nheaders = headers.newBuilder()
+                        .set("watchsb", "streamsb")
+                        .build()
+                    val master = "https://sbplay2.com/sourcesx38/7361696b6f757c7c${bytesToHex}7c7c7361696b6f757c7c73747265616d7362/7361696b6f757c7c363136653639366436343663363136653639366436343663376337633631366536393664363436633631366536393664363436633763376336313665363936643634366336313665363936643634366337633763373337343732363536313664373336327c7c7361696b6f757c7c73747265616d7362"
+                    Log.i("master", master)
+
+                    val callMaster = client.newCall(GET(master, nheaders)).execute().asJsoup()
+                    Log.i("testt", "$callMaster")*/
+                    val headers = headers.newBuilder()
+                        .set("watchsb", "streamsb")
+                        .build()
+                    val videos = StreamSBExtractor(client).videosFromUrl(url, headers)
                     videoList.addAll(videos)
                 }
-                url.contains("https://dood") -> {
-                    val newQuality = "Doodstream mirror"
-                    val video = Video(url, newQuality, doodUrlParse(url), null, videoHeaders)
-                    videoList.add(video)
-                }
-                url.contains("https://streamtape") -> {
-                    val newQuality = "StreamTape mirror"
-                    val video = Video(url, newQuality, streamTapeParse(url), null, videoHeaders)
-                    videoList.add(video)
-                }
-                url.contains("fembed") -> {
-                    val apiCall = client.newCall(POST(url.substringBefore("#").replace("/v/", "/api/source/"))).execute().body!!.string()
-                    Log.i("lol", "$apiCall")
-                    val data = apiCall.substringAfter("\"data\":[").substringBefore("],")
-                    val sources = data.split("\"file\":\"").drop(1)
-                    val videoList = mutableListOf<Video>()
-                    for (source in sources) {
-                        val src = source.substringAfter("\"file\":\"").substringBefore("\"").replace("\\/", "/")
-                        Log.i("lol", "$src")
-                        val quality = source.substringAfter("\"label\":\"").substringBefore("\"")
-                        val video = Video(url, quality, src, null)
+                url.contains("dood") -> {
+                    val video = DoodExtractor(client).videoFromUrl(url)
+                    if (video != null) {
+                        videoList.add(video)
+                    }
+                }
+                url.contains("fembed") -> {
+                    val videos = FembedExtractor().videosFromUrl(url)
+                    videoList.addAll(videos)
+                }
+                url.contains("streamtape") -> {
+                    val video = StreamTapeExtractor(client).videoFromUrl(url)
+                    if (video != null) {
                         videoList.add(video)
                     }
-                    return videoList
                 }
             }
         }
@@ -150,79 +157,6 @@ class AsianLoad : ConfigurableAnimeSource, ParsedAnimeHttpSource() {
 
     override fun videoUrlParse(document: Document) = throw Exception("not used")
 
-    private fun sbplayUrlParse(url: String, referer: String): List<Video> {
-        val videoList = mutableListOf<Video>()
-        val refererHeader = Headers.headersOf("Referer", referer)
-        val id = Uri.parse(url).pathSegments[1]
-        val noRedirectClient = client.newBuilder().followRedirects(false).build()
-        val respDownloadLinkSelector = noRedirectClient.newCall(GET(url, refererHeader)).execute()
-        val documentDownloadSelector = respDownloadLinkSelector.asJsoup()
-        val downloadElements = documentDownloadSelector.select("div.contentbox table tbody tr td a")
-        for (downloadElement in downloadElements) {
-            val videoData = downloadElement.attr("onclick")
-            val quality = downloadElement.text()
-            val hash = videoData.splitToSequence(",").last().replace("\'", "").replace(")", "")
-            val mode =
-                videoData.splitToSequence(",").elementAt(1).replace("\'", "").replace(")", "")
-            val downloadLink =
-                "https://sbplay2.com/dl?op=download_orig&id=$id&mode=$mode&hash=$hash"
-            respDownloadLinkSelector.close()
-            val video = sbplayVideoParser(downloadLink, quality)
-            if (video != null) videoList.add(video)
-        }
-        return videoList
-    }
-
-    private fun sbplayVideoParser(url: String, quality: String): Video? {
-        return try {
-            val noRedirectClient = client.newBuilder().followRedirects(false).build()
-            val refererHeader = Headers.headersOf("Referer", url)
-            val respDownloadLink = noRedirectClient.newCall(GET(url, refererHeader)).execute()
-            val documentDownloadLink = respDownloadLink.asJsoup()
-            val downloadLink = documentDownloadLink.selectFirst("div.contentbox span a").attr("href")
-            respDownloadLink.close()
-            Video(url, quality, downloadLink, null, refererHeader)
-        } catch (e: Exception) {
-            null
-        }
-    }
-
-    private fun doodUrlParse(url: String): String? {
-        val response = client.newCall(GET(url.replace("/d/", "/e/"))).execute()
-        val content = response.body!!.string()
-        if (!content.contains("'/pass_md5/")) return null
-        val md5 = content.substringAfter("'/pass_md5/").substringBefore("',")
-        val token = md5.substringAfterLast("/")
-        val doodTld = url.substringAfter("https://dood.").substringBefore("/")
-        val randomString = getRandomString()
-        val expiry = System.currentTimeMillis()
-        val videoUrlStart = client.newCall(
-            GET(
-                "https://dood.$doodTld/pass_md5/$md5",
-                Headers.headersOf("referer", url)
-            )
-        ).execute().body!!.string()
-        Log.i("lol", "$videoUrlStart$randomString?token=$token&expiry=$expiry")
-        return "$videoUrlStart$randomString?token=$token&expiry=$expiry"
-    }
-
-    private fun getRandomString(length: Int = 10): String {
-        val allowedChars = ('A'..'Z') + ('a'..'z') + ('0'..'9')
-        return (1..length)
-            .map { allowedChars.random() }
-            .joinToString("")
-    }
-
-    private fun streamTapeParse(url: String): String? {
-        val document = client.newCall(GET(url)).execute().asJsoup()
-        val script = document.select("script:containsData(document.getElementById('robotlink'))")
-            .firstOrNull()?.data()?.substringAfter("document.getElementById('robotlink').innerHTML = '")
-            ?: return null
-        val videoUrl = "https:" + script.substringBefore("'") +
-            script.substringAfter("+ ('xcd").substringBefore("'")
-        return "$videoUrl"
-    }
-
     override fun List<Video>.sort(): List<Video> {
         val quality = preferences.getString("preferred_quality", null)
         if (quality != null) {
@@ -318,21 +252,6 @@ class AsianLoad : ConfigurableAnimeSource, ParsedAnimeHttpSource() {
     // Preferences
 
     override fun setupPreferenceScreen(screen: PreferenceScreen) {
-        val serverPref = ListPreference(screen.context).apply {
-            key = "preferred_server"
-            title = "Preferred Server  (requires app restart)"
-            entries = arrayOf("Fembed", "StreamTape", "DooDStream", "StreamSB")
-            entryValues = arrayOf("https://fembed", "https://streamtape", "https://dood", "https://sbplay2.com")
-            setDefaultValue("https://dood")
-            summary = "%s"
-
-            setOnPreferenceChangeListener { _, newValue ->
-                val selected = newValue as String
-                val index = findIndexOfValue(selected)
-                val entry = entryValues[index] as String
-                preferences.edit().putString(key, entry).commit()
-            }
-        }
         val videoQualityPref = ListPreference(screen.context).apply {
             key = "preferred_quality"
             title = "Preferred quality"
@@ -348,7 +267,6 @@ class AsianLoad : ConfigurableAnimeSource, ParsedAnimeHttpSource() {
                 preferences.edit().putString(key, entry).commit()
             }
         }
-        screen.addPreference(serverPref)
         screen.addPreference(videoQualityPref)
     }
 }
diff --git a/src/en/asianload/src/eu/kanade/tachiyomi/animeextension/en/asianload/extractors/DoodExtractor.kt b/src/en/asianload/src/eu/kanade/tachiyomi/animeextension/en/asianload/extractors/DoodExtractor.kt
new file mode 100644
index 000000000..69a416519
--- /dev/null
+++ b/src/en/asianload/src/eu/kanade/tachiyomi/animeextension/en/asianload/extractors/DoodExtractor.kt
@@ -0,0 +1,43 @@
+package eu.kanade.tachiyomi.animeextension.en.asianload.extractors
+
+import eu.kanade.tachiyomi.animesource.model.Video
+import eu.kanade.tachiyomi.network.GET
+import okhttp3.Headers
+import okhttp3.OkHttpClient
+
+class DoodExtractor(private val client: OkHttpClient) {
+    fun videoFromUrl(url: String): Video? {
+        val response = client.newCall(GET(url)).execute()
+        // Overwrite url to the redirected one
+        val url = response.request.url.toString()
+        val doodTld = url.substringAfter("https://dood.").substringBefore("/")
+        val content = response.body!!.string()
+        if (!content.contains("'/pass_md5/")) return null
+        val md5 = content.substringAfter("'/pass_md5/").substringBefore("',")
+        val token = md5.substringAfterLast("/")
+        val randomString = getRandomString()
+        val expiry = System.currentTimeMillis()
+        val videoUrlStart = client.newCall(
+            GET(
+                "https://dood.$doodTld/pass_md5/$md5",
+                Headers.headersOf("referer", url)
+            )
+        ).execute().body!!.string()
+        val videoUrl = "$videoUrlStart$randomString?token=$token&expiry=$expiry"
+        val newQuality = "Doodstream mirror"
+
+        return Video(url, newQuality, videoUrl, null, doodHeaders(doodTld))
+    }
+
+    private fun getRandomString(length: Int = 10): String {
+        val allowedChars = ('A'..'Z') + ('a'..'z') + ('0'..'9')
+        return (1..length)
+            .map { allowedChars.random() }
+            .joinToString("")
+    }
+
+    private fun doodHeaders(tld: String) = Headers.Builder().apply {
+        add("User-Agent", "Aniyomi")
+        add("Referer", "https://dood.$tld/")
+    }.build()
+}
diff --git a/src/en/asianload/src/eu/kanade/tachiyomi/animeextension/en/asianload/extractors/FembedExtractor.kt b/src/en/asianload/src/eu/kanade/tachiyomi/animeextension/en/asianload/extractors/FembedExtractor.kt
new file mode 100644
index 000000000..9513b5149
--- /dev/null
+++ b/src/en/asianload/src/eu/kanade/tachiyomi/animeextension/en/asianload/extractors/FembedExtractor.kt
@@ -0,0 +1,24 @@
+package eu.kanade.tachiyomi.animeextension.en.asianload.extractors
+
+import eu.kanade.tachiyomi.animesource.model.Video
+import org.json.JSONObject
+import org.jsoup.Connection
+import org.jsoup.Jsoup
+
+class FembedExtractor {
+    fun videosFromUrl(url: String): List<Video> {
+        val videoApi = url.replace("/v/", "/api/source/")
+        val json = JSONObject(Jsoup.connect(videoApi).ignoreContentType(true).method(Connection.Method.POST).execute().body())
+        check(json.getBoolean("success")) { "Request was not succeeded" }
+        val videoList = mutableListOf<Video>()
+
+        val jsonArray = json.getJSONArray("data")
+        for (i in 0 until jsonArray.length()) {
+            val `object` = jsonArray.getJSONObject(i)
+            val videoUrl = `object`.getString("file")
+            val quality = "Fembed:" + `object`.getString("label")
+            videoList.add(Video(videoUrl, quality, videoUrl, null))
+        }
+        return videoList
+    }
+}
diff --git a/src/en/asianload/src/eu/kanade/tachiyomi/animeextension/en/asianload/extractors/StreamSBExtractor.kt b/src/en/asianload/src/eu/kanade/tachiyomi/animeextension/en/asianload/extractors/StreamSBExtractor.kt
new file mode 100644
index 000000000..e45375d64
--- /dev/null
+++ b/src/en/asianload/src/eu/kanade/tachiyomi/animeextension/en/asianload/extractors/StreamSBExtractor.kt
@@ -0,0 +1,44 @@
+package eu.kanade.tachiyomi.animeextension.en.asianload.extractors
+
+import eu.kanade.tachiyomi.animesource.model.Video
+import eu.kanade.tachiyomi.network.GET
+import kotlinx.serialization.decodeFromString
+import kotlinx.serialization.json.Json
+import kotlinx.serialization.json.JsonObject
+import kotlinx.serialization.json.jsonObject
+import okhttp3.Headers
+import okhttp3.OkHttpClient
+import org.jsoup.Jsoup
+
+class StreamSBExtractor(private val client: OkHttpClient) {
+
+    private val hexArray = "0123456789ABCDEF".toCharArray()
+
+    private fun bytesToHex(bytes: ByteArray): String {
+        val hexChars = CharArray(bytes.size * 2)
+        for (j in bytes.indices) {
+            val v = bytes[j].toInt() and 0xFF
+
+            hexChars[j * 2] = hexArray[v ushr 4]
+            hexChars[j * 2 + 1] = hexArray[v and 0x0F]
+        }
+        return String(hexChars)
+    }
+
+    fun videosFromUrl(url: String, headers: Headers): List<Video> {
+        val id = url.substringAfter("e/").substringBefore("?")
+        val bytes = id.toByteArray()
+        val bytesToHex = bytesToHex(bytes)
+        val master = "https://sbplay2.com/sourcesx38/7361696b6f757c7c${bytesToHex}7c7c7361696b6f757c7c73747265616d7362/7361696b6f757c7c363136653639366436343663363136653639366436343663376337633631366536393664363436633631366536393664363436633763376336313665363936643634366336313665363936643634366337633763373337343732363536313664373336327c7c7361696b6f757c7c73747265616d7362"
+        val json = Json.decodeFromString<JsonObject>(Jsoup.connect(master).ignoreContentType(true).header("watchsb", "streamsb").execute().body())
+        val masterUrl = json["stream_data"]!!.jsonObject["file"].toString().trim('"')
+        val masterPlaylist = client.newCall(GET(masterUrl)).execute().body!!.string()
+        val videoList = mutableListOf<Video>()
+        masterPlaylist.substringAfter("#EXT-X-STREAM-INF:").split("#EXT-X-STREAM-INF:").forEach {
+            val quality = "StreamSB:" + it.substringAfter("RESOLUTION=").substringAfter("x").substringBefore(",") + "p"
+            val videoUrl = it.substringAfter("\n").substringBefore("\n")
+            videoList.add(Video(videoUrl, quality, videoUrl, null))
+        }
+        return videoList
+    }
+}
diff --git a/src/en/asianload/src/eu/kanade/tachiyomi/animeextension/en/asianload/extractors/StreamTapeExtractor.kt b/src/en/asianload/src/eu/kanade/tachiyomi/animeextension/en/asianload/extractors/StreamTapeExtractor.kt
new file mode 100644
index 000000000..70371a3f0
--- /dev/null
+++ b/src/en/asianload/src/eu/kanade/tachiyomi/animeextension/en/asianload/extractors/StreamTapeExtractor.kt
@@ -0,0 +1,19 @@
+package eu.kanade.tachiyomi.animeextension.en.asianload.extractors
+
+import eu.kanade.tachiyomi.animesource.model.Video
+import eu.kanade.tachiyomi.network.GET
+import eu.kanade.tachiyomi.util.asJsoup
+import okhttp3.OkHttpClient
+
+class StreamTapeExtractor(private val client: OkHttpClient) {
+    fun videoFromUrl(url: String): Video? {
+        val document = client.newCall(GET(url)).execute().asJsoup()
+        val script = document.select("script:containsData(document.getElementById('robotlink'))")
+            .firstOrNull()?.data()?.substringAfter("document.getElementById('robotlink').innerHTML = '")
+            ?: return null
+        val videoUrl = "https:" + script.substringBefore("'") +
+            script.substringAfter("+ ('xcd").substringBefore("'")
+        val quality = "StreamTape"
+        return Video(url, quality, videoUrl, null)
+    }
+}
diff --git a/src/en/dramacool/build.gradle b/src/en/dramacool/build.gradle
index f25e7e036..a8ad35dfd 100644
--- a/src/en/dramacool/build.gradle
+++ b/src/en/dramacool/build.gradle
@@ -5,7 +5,7 @@ ext {
     extName = 'DramaCool'
     pkgNameSuffix = 'en.dramacool'
     extClass = '.DramaCool'
-    extVersionCode = 2
+    extVersionCode = 3
     libVersion = '12'
 }
 
diff --git a/src/en/dramacool/src/eu/kanade/tachiyomi/animeextension/en/dramacool/DramaCool.kt b/src/en/dramacool/src/eu/kanade/tachiyomi/animeextension/en/dramacool/DramaCool.kt
index 120e50c64..2999851ec 100644
--- a/src/en/dramacool/src/eu/kanade/tachiyomi/animeextension/en/dramacool/DramaCool.kt
+++ b/src/en/dramacool/src/eu/kanade/tachiyomi/animeextension/en/dramacool/DramaCool.kt
@@ -2,10 +2,13 @@ package eu.kanade.tachiyomi.animeextension.en.dramacool
 
 import android.app.Application
 import android.content.SharedPreferences
-import android.net.Uri
 import android.util.Log
 import androidx.preference.ListPreference
 import androidx.preference.PreferenceScreen
+import eu.kanade.tachiyomi.animeextension.en.dramacool.extractors.DoodExtractor
+import eu.kanade.tachiyomi.animeextension.en.dramacool.extractors.FembedExtractor
+import eu.kanade.tachiyomi.animeextension.en.dramacool.extractors.StreamSBExtractor
+import eu.kanade.tachiyomi.animeextension.en.dramacool.extractors.StreamTapeExtractor
 import eu.kanade.tachiyomi.animesource.ConfigurableAnimeSource
 import eu.kanade.tachiyomi.animesource.model.AnimeFilterList
 import eu.kanade.tachiyomi.animesource.model.SAnime
@@ -13,7 +16,6 @@ import eu.kanade.tachiyomi.animesource.model.SEpisode
 import eu.kanade.tachiyomi.animesource.model.Video
 import eu.kanade.tachiyomi.animesource.online.ParsedAnimeHttpSource
 import eu.kanade.tachiyomi.network.GET
-import eu.kanade.tachiyomi.network.POST
 import eu.kanade.tachiyomi.util.asJsoup
 import okhttp3.Headers
 import okhttp3.OkHttpClient
@@ -49,7 +51,7 @@ class DramaCool : ConfigurableAnimeSource, ParsedAnimeHttpSource() {
 
     override fun popularAnimeSelector(): String = "ul.list-episode-item li a"
 
-    override fun popularAnimeRequest(page: Int): Request = GET("$baseUrl/most-popular-drama?page=$page")
+    override fun popularAnimeRequest(page: Int): Request = GET("$baseUrl/most-popular-drama?page=$page") // page/$page
 
     override fun popularAnimeFromElement(element: Element): SAnime {
         val anime = SAnime.create()
@@ -88,6 +90,7 @@ class DramaCool : ConfigurableAnimeSource, ParsedAnimeHttpSource() {
     }
 
     override fun videoListSelector() = "ul.list-server-items li[data-video*=https://sbplay2.com], ul.list-server-items li[data-video*=https://dood], ul.list-server-items li[data-video*=https://streamtape], ul.list-server-items li[data-video*=https://fembed]"
+
     private fun videosFromElement(document: Document): List<Video> {
         val videoList = mutableListOf<Video>()
         val elements = document.select(videoListSelector())
@@ -97,32 +100,40 @@ class DramaCool : ConfigurableAnimeSource, ParsedAnimeHttpSource() {
             val location = element.ownerDocument().location()
             val videoHeaders = Headers.headersOf("Referer", location)
             when {
-                url.contains("https://sbplay") -> {
-                    val vidURL = url.substringBefore("?").replace("/e/", "/d/")
-                    val videos = sbplayUrlParse(vidURL, location)
+                url.contains("sbplay2") -> {
+                    /*val id = url.substringAfter("e/").substringBefore("?")
+                    Log.i("idtest", id)
+                    val bytes = id.toByteArray()
+                    Log.i("idencode", "$bytes")
+                    val bytesToHex = bytesToHex(bytes)
+                    Log.i("bytesToHex", bytesToHex)
+                    val nheaders = headers.newBuilder()
+                        .set("watchsb", "streamsb")
+                        .build()
+                    val master = "https://sbplay2.com/sourcesx38/7361696b6f757c7c${bytesToHex}7c7c7361696b6f757c7c73747265616d7362/7361696b6f757c7c363136653639366436343663363136653639366436343663376337633631366536393664363436633631366536393664363436633763376336313665363936643634366336313665363936643634366337633763373337343732363536313664373336327c7c7361696b6f757c7c73747265616d7362"
+                    Log.i("master", master)
+
+                    val callMaster = client.newCall(GET(master, nheaders)).execute().asJsoup()
+                    Log.i("testt", "$callMaster")*/
+                    val headers = headers.newBuilder()
+                        .set("watchsb", "streamsb")
+                        .build()
+                    val videos = StreamSBExtractor(client).videosFromUrl(url, headers)
                     videoList.addAll(videos)
                 }
-                url.contains("https://dood") -> {
-                    val newQuality = "Doodstream mirror"
-                    val video = Video(url, newQuality, doodUrlParse(url), null, videoHeaders)
-                    videoList.add(video)
-                }
-                url.contains("https://streamtape") -> {
-                    val newQuality = "StreamTape mirror"
-                    val video = Video(url, newQuality, streamTapeParse(url), null, videoHeaders)
-                    videoList.add(video)
+                url.contains("dood") -> {
+                    val video = DoodExtractor(client).videoFromUrl(url)
+                    if (video != null) {
+                        videoList.add(video)
+                    }
                 }
                 url.contains("fembed") -> {
-                    val apiCall = client.newCall(POST(url.substringBefore("#").replace("/v/", "/api/source/"))).execute().body!!.string()
-                    Log.i("lol", "TEST$apiCall")
-                    val data = apiCall.substringAfter("\"data\":[").substringBefore("],")
-                    val sources = data.split("\"file\":\"").drop(1)
-                    val videoList = mutableListOf<Video>()
-                    for (source in sources) {
-                        val src = source.substringAfter("\"file\":\"").substringBefore("\"").replace("\\/", "/")
-                        Log.i("lol", "Source:$src")
-                        val quality = source.substringAfter("\"label\":\"").substringBefore("\"")
-                        val video = Video(url, quality, src, null)
+                    val videos = FembedExtractor().videosFromUrl(url)
+                    videoList.addAll(videos)
+                }
+                url.contains("streamtape") -> {
+                    val video = StreamTapeExtractor(client).videoFromUrl(url)
+                    if (video != null) {
                         videoList.add(video)
                     }
                 }
@@ -135,81 +146,6 @@ class DramaCool : ConfigurableAnimeSource, ParsedAnimeHttpSource() {
 
     override fun videoUrlParse(document: Document) = throw Exception("not used")
 
-    private fun sbplayUrlParse(vidURL: String, referer: String): List<Video> {
-        val videoList = mutableListOf<Video>()
-        val refererHeader = Headers.headersOf("Referer", referer)
-        val id = Uri.parse(vidURL).pathSegments[1]
-        val noRedirectClient = client.newBuilder().followRedirects(false).build()
-        val respDownloadLinkSelector = noRedirectClient.newCall(GET(vidURL, refererHeader)).execute()
-        val documentDownloadSelector = respDownloadLinkSelector.asJsoup()
-        val downloadElements = documentDownloadSelector.select("div.contentbox table tbody tr td a")
-        for (downloadElement in downloadElements) {
-            val videoData = downloadElement.attr("onclick")
-            val quality = downloadElement.text()
-            val hash = videoData.splitToSequence(",").last().replace("\'", "").replace(")", "")
-            val mode =
-                videoData.splitToSequence(",").elementAt(1).replace("\'", "").replace(")", "")
-            val downloadLink =
-                "https://sbplay2.com/dl?op=download_orig&id=$id&mode=$mode&hash=$hash"
-            Log.i("lol", "aaaa $downloadLink")
-            respDownloadLinkSelector.close()
-            val video = sbplayVideoParser(downloadLink, quality)
-            if (video != null) videoList.add(video)
-        }
-        return videoList
-    }
-
-    private fun sbplayVideoParser(vidURL: String, quality: String): Video? {
-        return try {
-            val noRedirectClient = client.newBuilder().followRedirects(false).build()
-            val refererHeader = Headers.headersOf("Referer", vidURL)
-            val respDownloadLink = noRedirectClient.newCall(GET(vidURL, refererHeader)).execute()
-            val documentDownloadLink = respDownloadLink.asJsoup()
-            Log.i("lol1", "$documentDownloadLink")
-            val downloadLink = documentDownloadLink.selectFirst("div.contentbox span a").attr("href")
-            respDownloadLink.close()
-            Video(vidURL, quality, downloadLink, null, refererHeader)
-        } catch (e: Exception) {
-            null
-        }
-    }
-
-    private fun doodUrlParse(url: String): String? {
-        val response = client.newCall(GET(url.replace("/d/", "/e/"))).execute()
-        val content = response.body!!.string()
-        if (!content.contains("'/pass_md5/")) return null
-        val md5 = content.substringAfter("'/pass_md5/").substringBefore("',")
-        val token = md5.substringAfterLast("/")
-        val doodTld = url.substringAfter("https://dood.").substringBefore("/")
-        val randomString = getRandomString()
-        val expiry = System.currentTimeMillis()
-        val videoUrlStart = client.newCall(
-            GET(
-                "https://dood.$doodTld/pass_md5/$md5",
-                Headers.headersOf("referer", url)
-            )
-        ).execute().body!!.string()
-        Log.i("lol", "$videoUrlStart$randomString?token=$token&expiry=$expiry")
-        return "$videoUrlStart$randomString?token=$token&expiry=$expiry"
-    }
-
-    private fun getRandomString(length: Int = 10): String {
-        val allowedChars = ('A'..'Z') + ('a'..'z') + ('0'..'9')
-        return (1..length)
-            .map { allowedChars.random() }
-            .joinToString("")
-    }
-
-    private fun streamTapeParse(url: String): String? {
-        val document = client.newCall(GET(url)).execute().asJsoup()
-        val script = document.select("script:containsData(document.getElementById('robotlink'))")
-            .firstOrNull()?.data()?.substringAfter("document.getElementById('robotlink').innerHTML = '")
-            ?: return null
-        val videoUrl = "https:" + script.substringBefore("'") +
-            script.substringAfter("+ ('xcd").substringBefore("'")
-        return "$videoUrl"
-    }
-
     override fun List<Video>.sort(): List<Video> {
         val quality = preferences.getString("preferred_quality", null)
         if (quality != null) {
@@ -260,7 +196,7 @@ class DramaCool : ConfigurableAnimeSource, ParsedAnimeHttpSource() {
         return when (statusString) {
             "Ongoing" -> SAnime.ONGOING
             "Completed" -> SAnime.COMPLETED
-            else -> SAnime.COMPLETED
+            else -> SAnime.UNKNOWN
         }
     }
 
diff --git a/src/en/dramacool/src/eu/kanade/tachiyomi/animeextension/en/dramacool/extractors/DoodExtractor.kt b/src/en/dramacool/src/eu/kanade/tachiyomi/animeextension/en/dramacool/extractors/DoodExtractor.kt
new file mode 100644
index 000000000..8bbc2aa60
--- /dev/null
+++ b/src/en/dramacool/src/eu/kanade/tachiyomi/animeextension/en/dramacool/extractors/DoodExtractor.kt
@@ -0,0 +1,43 @@
+package eu.kanade.tachiyomi.animeextension.en.dramacool.extractors
+
+import eu.kanade.tachiyomi.animesource.model.Video
+import eu.kanade.tachiyomi.network.GET
+import okhttp3.Headers
+import okhttp3.OkHttpClient
+
+class DoodExtractor(private val client: OkHttpClient) {
+    fun videoFromUrl(url: String): Video? {
+        val response = client.newCall(GET(url)).execute()
+        // Overwrite url to the redirected one
+        val url = response.request.url.toString()
+        val doodTld = url.substringAfter("https://dood.").substringBefore("/")
+        val content = response.body!!.string()
+        if (!content.contains("'/pass_md5/")) return null
+        val md5 = content.substringAfter("'/pass_md5/").substringBefore("',")
+        val token = md5.substringAfterLast("/")
+        val randomString = getRandomString()
+        val expiry = System.currentTimeMillis()
+        val videoUrlStart = client.newCall(
+            GET(
+                "https://dood.$doodTld/pass_md5/$md5",
+                Headers.headersOf("referer", url)
+            )
+        ).execute().body!!.string()
+        val videoUrl = "$videoUrlStart$randomString?token=$token&expiry=$expiry"
+        val newQuality = "Doodstream mirror"
+
+        return Video(url, newQuality, videoUrl, null, doodHeaders(doodTld))
+    }
+
+    private fun getRandomString(length: Int = 10): String {
+        val allowedChars = ('A'..'Z') + ('a'..'z') + ('0'..'9')
+        return (1..length)
+            .map { allowedChars.random() }
+            .joinToString("")
+    }
+
+    private fun doodHeaders(tld: String) = Headers.Builder().apply {
+        add("User-Agent", "Aniyomi")
+        add("Referer", "https://dood.$tld/")
+    }.build()
+}
diff --git a/src/en/dramacool/src/eu/kanade/tachiyomi/animeextension/en/dramacool/extractors/FembedExtractor.kt b/src/en/dramacool/src/eu/kanade/tachiyomi/animeextension/en/dramacool/extractors/FembedExtractor.kt
new file mode 100644
index 000000000..e2de280e4
--- /dev/null
+++ b/src/en/dramacool/src/eu/kanade/tachiyomi/animeextension/en/dramacool/extractors/FembedExtractor.kt
@@ -0,0 +1,24 @@
+package eu.kanade.tachiyomi.animeextension.en.dramacool.extractors
+
+import eu.kanade.tachiyomi.animesource.model.Video
+import org.json.JSONObject
+import org.jsoup.Connection
+import org.jsoup.Jsoup
+
+class FembedExtractor {
+    fun videosFromUrl(url: String): List<Video> {
+        val videoApi = url.replace("/v/", "/api/source/")
+        val json = JSONObject(Jsoup.connect(videoApi).ignoreContentType(true).method(Connection.Method.POST).execute().body())
+        check(json.getBoolean("success")) { "Request was not succeeded" }
+        val videoList = mutableListOf<Video>()
+
+        val jsonArray = json.getJSONArray("data")
+        for (i in 0 until jsonArray.length()) {
+            val `object` = jsonArray.getJSONObject(i)
+            val videoUrl = `object`.getString("file")
+            val quality = "Fembed:" + `object`.getString("label")
+            videoList.add(Video(videoUrl, quality, videoUrl, null))
+        }
+        return videoList
+    }
+}
diff --git a/src/en/dramacool/src/eu/kanade/tachiyomi/animeextension/en/dramacool/extractors/StreamSBExtractor.kt b/src/en/dramacool/src/eu/kanade/tachiyomi/animeextension/en/dramacool/extractors/StreamSBExtractor.kt
new file mode 100644
index 000000000..37a3d7ef3
--- /dev/null
+++ b/src/en/dramacool/src/eu/kanade/tachiyomi/animeextension/en/dramacool/extractors/StreamSBExtractor.kt
@@ -0,0 +1,44 @@
+package eu.kanade.tachiyomi.animeextension.en.dramacool.extractors
+
+import eu.kanade.tachiyomi.animesource.model.Video
+import eu.kanade.tachiyomi.network.GET
+import kotlinx.serialization.decodeFromString
+import kotlinx.serialization.json.Json
+import kotlinx.serialization.json.JsonObject
+import kotlinx.serialization.json.jsonObject
+import okhttp3.Headers
+import okhttp3.OkHttpClient
+import org.jsoup.Jsoup
+
+class StreamSBExtractor(private val client: OkHttpClient) {
+
+    private val hexArray = "0123456789ABCDEF".toCharArray()
+
+    private fun bytesToHex(bytes: ByteArray): String {
+        val hexChars = CharArray(bytes.size * 2)
+        for (j in bytes.indices) {
+            val v = bytes[j].toInt() and 0xFF
+
+            hexChars[j * 2] = hexArray[v ushr 4]
+            hexChars[j * 2 + 1] = hexArray[v and 0x0F]
+        }
+        return String(hexChars)
+    }
+
+    fun videosFromUrl(url: String, headers: Headers): List<Video> {
+        val id = url.substringAfter("e/").substringBefore("?")
+        val bytes = id.toByteArray()
+        val bytesToHex = bytesToHex(bytes)
+        val master = "https://sbplay2.com/sourcesx38/7361696b6f757c7c${bytesToHex}7c7c7361696b6f757c7c73747265616d7362/7361696b6f757c7c363136653639366436343663363136653639366436343663376337633631366536393664363436633631366536393664363436633763376336313665363936643634366336313665363936643634366337633763373337343732363536313664373336327c7c7361696b6f757c7c73747265616d7362"
+        val json = Json.decodeFromString<JsonObject>(Jsoup.connect(master).ignoreContentType(true).header("watchsb", "streamsb").execute().body())
+        val masterUrl = json["stream_data"]!!.jsonObject["file"].toString().trim('"')
+        val masterPlaylist = client.newCall(GET(masterUrl)).execute().body!!.string()
+        val videoList = mutableListOf<Video>()
+        masterPlaylist.substringAfter("#EXT-X-STREAM-INF:").split("#EXT-X-STREAM-INF:").forEach {
+            val quality = "StreamSB:" + it.substringAfter("RESOLUTION=").substringAfter("x").substringBefore(",") + "p"
+            val videoUrl = it.substringAfter("\n").substringBefore("\n")
+            videoList.add(Video(videoUrl, quality, videoUrl, null))
+        }
+        return videoList
+    }
+}
diff --git a/src/en/dramacool/src/eu/kanade/tachiyomi/animeextension/en/dramacool/extractors/StreamTapeExtractor.kt b/src/en/dramacool/src/eu/kanade/tachiyomi/animeextension/en/dramacool/extractors/StreamTapeExtractor.kt
new file mode 100644
index 000000000..36db29ad9
--- /dev/null
+++ b/src/en/dramacool/src/eu/kanade/tachiyomi/animeextension/en/dramacool/extractors/StreamTapeExtractor.kt
@@ -0,0 +1,19 @@
+package eu.kanade.tachiyomi.animeextension.en.dramacool.extractors
+
+import eu.kanade.tachiyomi.animesource.model.Video
+import eu.kanade.tachiyomi.network.GET
+import eu.kanade.tachiyomi.util.asJsoup
+import okhttp3.OkHttpClient
+
+class StreamTapeExtractor(private val client: OkHttpClient) {
+    fun videoFromUrl(url: String): Video? {
+        val document = client.newCall(GET(url)).execute().asJsoup()
+        val script = document.select("script:containsData(document.getElementById('robotlink'))")
+            .firstOrNull()?.data()?.substringAfter("document.getElementById('robotlink').innerHTML = '")
+            ?: return null
+        val videoUrl = "https:" + script.substringBefore("'") +
+            script.substringAfter("+ ('xcd").substringBefore("'")
+        val quality = "StreamTape"
+        return Video(url, quality, videoUrl, null)
+    }
+}