New Extension: Ripcrabbyanime (#1522)

* New extension

* Add error message

* Refractor + fix for broken links

src/en/ripcrabbyanime/AndroidManifest.xml

@@ -0,0 +1,2 @@
+<?xml version="1.0" encoding="utf-8"?>
+<manifest package="eu.kanade.tachiyomi.animeextension" />

src/en/ripcrabbyanime/build.gradle

@@ -0,0 +1,13 @@
+apply plugin: 'com.android.application'
+apply plugin: 'kotlin-android'
+apply plugin: 'kotlinx-serialization'
+
+ext {
+    extName = 'Ripcrabbyanime'
+    pkgNameSuffix = 'en.ripcrabbyanime'
+    extClass = '.Ripcrabbyanime'
+    extVersionCode = 1
+    libVersion = '13'
+}
+
+apply from: "$rootDir/common.gradle"

src/en/ripcrabbyanime/src/eu/kanade/tachiyomi/animeextension/en/ripcrabbyanime/Ripcrabbyanime.kt

@@ -0,0 +1,471 @@
+package eu.kanade.tachiyomi.animeextension.en.ripcrabbyanime
+
+import android.app.Application
+import android.content.SharedPreferences
+import androidx.preference.PreferenceScreen
+import androidx.preference.SwitchPreferenceCompat
+import eu.kanade.tachiyomi.animeextension.en.ripcrabbyanime.extractors.GoogleDriveExtractor
+import eu.kanade.tachiyomi.animesource.ConfigurableAnimeSource
+import eu.kanade.tachiyomi.animesource.model.AnimeFilter
+import eu.kanade.tachiyomi.animesource.model.AnimeFilterList
+import eu.kanade.tachiyomi.animesource.model.AnimesPage
+import eu.kanade.tachiyomi.animesource.model.SAnime
+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.network.asObservableSuccess
+import eu.kanade.tachiyomi.util.asJsoup
+import kotlinx.serialization.Serializable
+import kotlinx.serialization.decodeFromString
+import kotlinx.serialization.json.Json
+import okhttp3.HttpUrl.Companion.toHttpUrl
+import okhttp3.MediaType.Companion.toMediaType
+import okhttp3.OkHttpClient
+import okhttp3.Request
+import okhttp3.RequestBody.Companion.toRequestBody
+import okhttp3.Response
+import org.jsoup.nodes.Document
+import org.jsoup.nodes.Element
+import rx.Observable
+import uy.kohesive.injekt.Injekt
+import uy.kohesive.injekt.api.get
+import uy.kohesive.injekt.injectLazy
+import java.security.MessageDigest
+import java.text.CharacterIterator
+import java.text.StringCharacterIterator
+
+class Ripcrabbyanime : ConfigurableAnimeSource, ParsedAnimeHttpSource() {
+
+    override val name = "Ripcrabbyanime (Experimental)"
+
+    override val baseUrl = "https://ripcrabbyanime.in"
+
+    override val lang = "en"
+
+    override val supportsLatest = false
+
+    override val client: OkHttpClient = network.cloudflareClient
+
+    private val MAX_RECURSION_DEPTH = 2
+
+    private val json: Json by injectLazy()
+
+    private val preferences: SharedPreferences by lazy {
+        Injekt.get<Application>().getSharedPreferences("source_$id", 0x0000)
+    }
+
+    // ============================== Popular ===============================
+
+    override fun popularAnimeRequest(page: Int): Request = GET("$baseUrl/ongoing-series/")
+
+    override fun popularAnimeSelector(): String = "section#movies-list > div.movies-box"
+
+    override fun popularAnimeNextPageSelector(): String? = null
+
+    override fun popularAnimeFromElement(element: Element): SAnime {
+        return SAnime.create().apply {
+            setUrlWithoutDomain(element.selectFirst("a")!!.attr("href").toHttpUrl().encodedPath)
+            thumbnail_url = element.selectFirst("img[src]")?.attr("src") ?: ""
+            title = element.selectFirst("a:matches(.)")!!.text().substringBefore(" | Episode").trimEnd()
+        }
+    }
+
+    // =============================== Latest ===============================
+
+    override fun latestUpdatesRequest(page: Int): Request = throw Exception("Not Used")
+
+    override fun latestUpdatesSelector(): String = throw Exception("Not Used")
+
+    override fun latestUpdatesNextPageSelector(): String = throw Exception("Not Used")
+
+    override fun latestUpdatesFromElement(element: Element): SAnime = throw Exception("Not Used")
+
+    // =============================== Search ===============================
+
+    override fun searchAnimeRequest(page: Int, query: String, filters: AnimeFilterList): Request {
+        val filterList = if (filters.isEmpty()) getFilterList() else filters
+        val genreFilter = filterList.find { it is GenreFilter } as GenreFilter
+        val subPageFilter = filterList.find { it is SubPageFilter } as SubPageFilter
+
+        return when {
+            query.isNotBlank() -> {
+                val cleanQuery = query.replace(" ", "+")
+                GET("$baseUrl/search/?s=$cleanQuery")
+            }
+            genreFilter.state != 0 -> {
+                val url = "$baseUrl${genreFilter.toUriPart()}"
+                val body = "start=${(page - 1) * 40}&limit=40".toRequestBody("application/x-www-form-urlencoded".toMediaType())
+                POST(url, body = body)
+            }
+            subPageFilter.state != 0 -> {
+                val url = "$baseUrl${subPageFilter.toUriPart()}"
+                val body = "start=${(page - 1) * 40}&limit=40".toRequestBody("application/x-www-form-urlencoded".toMediaType())
+                POST(url, body = body)
+            }
+            else -> popularAnimeRequest(page)
+        }
+    }
+
+    override fun searchAnimeParse(response: Response): AnimesPage {
+        return if (response.request.url.encodedPath.startsWith("/search/")) {
+            popularAnimeParse(response)
+        } else {
+            val document = response.asJsoup()
+
+            val animes = document.select(searchAnimeSelector()).map { element ->
+                popularAnimeFromElement(element)
+            }
+
+            return AnimesPage(animes, animes.size == 40)
+        }
+    }
+
+    override fun searchAnimeSelector(): String = "div#infinite-list"
+
+    override fun searchAnimeNextPageSelector(): String? = popularAnimeNextPageSelector()
+
+    override fun searchAnimeFromElement(element: Element): SAnime = popularAnimeFromElement(element)
+
+    // ============================== Filters ===============================
+
+    override fun getFilterList(): AnimeFilterList = AnimeFilterList(
+        AnimeFilter.Header("Text search ignores filters"),
+        SubPageFilter(),
+        GenreFilter(),
+    )
+
+    private class SubPageFilter : UriPartFilter(
+        "Sub-page",
+        arrayOf(
+            Pair("<select>", ""),
+            Pair("Anime Series", "/Get/get-animeserise/"),
+            Pair("Anime Movie", "/Get/get-movies/"),
+        ),
+    )
+
+    private class GenreFilter : UriPartFilter(
+        "Genres",
+        arrayOf(
+            Pair("<select>", ""),
+            Pair("Action", "/Get/get-action/"),
+            Pair("Adventure", "/Get/get-adventure/"),
+            Pair("Comedy", "/Get/get-comedy/"),
+            Pair("Demons", "/Get/get-demons/"),
+            Pair("Drama", "/Get/get-drama/"),
+            Pair("Ecchi", "/Get/get-ecchi/"),
+            Pair("Fantasy", "/Get/get-fantasy/"),
+            Pair("Harem", "/Get/get-harem/"),
+            Pair("Horror", "/Get/get-horror/"),
+            Pair("Mecha", "/Get/get-mecha/"),
+            Pair("Magic", "/Get/get-magic/"),
+            Pair("Romance", "/Get/get-romance/"),
+            Pair("School", "/Get/get-school/"),
+            Pair("Sci-Fi", "/Get/get-sci-fi/"),
+            Pair("Shounen", "/Get/get-shounen/"),
+            Pair("Slice of Life", "/Get/get-slice-of-life/"),
+            Pair("Sports", "/Get/get-sports/"),
+            Pair("Super Power", "/Get/get-superpower/"),
+            Pair("Supernatural", "/Get/get-supernatural/"),
+        ),
+    )
+
+    private open class UriPartFilter(displayName: String, val vals: Array<Pair<String, String>>) :
+        AnimeFilter.Select<String>(displayName, vals.map { it.first }.toTypedArray()) {
+        fun toUriPart() = vals[state].second
+    }
+
+    // =========================== Anime Details ============================
+
+    override fun fetchAnimeDetails(anime: SAnime): Observable<SAnime> {
+        return client.newCall(animeDetailsRequest(anime))
+            .asObservableSuccess()
+            .map { response ->
+                animeDetailsParse(response, anime).apply { initialized = true }
+            }
+    }
+
+    override fun animeDetailsParse(document: Document): SAnime = throw Exception("Not used")
+
+    private fun animeDetailsParse(response: Response, anime: SAnime): SAnime {
+        val document = response.asJsoup()
+        val moreInfo = document.select("div.summery:not(:has(h2:contains(Summary))) ul li").joinToString("\n") { it.ownText().trim() }
+        val realDesc = document.selectFirst("div.summery:has(h2:contains(Summary)) ul")?.let { "${it.text()}\n\n" } ?: ""
+
+        return SAnime.create().apply {
+            title = anime.title
+            thumbnail_url = anime.thumbnail_url
+            status = document.selectFirst("div.summery:not(:has(h2:contains(Summary))) ul li:contains(Status)")?.let {
+                parseStatus(it.text().substringAfter("Status: "))
+            } ?: SAnime.UNKNOWN
+            description = realDesc + "\n\n$moreInfo"
+            genre = document.selectFirst("div.summery:not(:has(h2:contains(Summary))) ul li:contains(Genres)")?.let {
+                it.text().substringAfter("Genres: ")
+            }
+            author = document.selectFirst("div.summery:not(:has(h2:contains(Summary))) ul li:contains(Studios)")?.let {
+                it.text().substringAfter("Studios: ").substringAfter("Studios ")
+            }
+        }
+    }
+
+    // ============================== Episodes ==============================
+
+    // Lots of code borrowed from https://github.com/yt-dlp/yt-dlp/blob/master/yt_dlp/extractor/googledrive.py under the `GoogleDriveFolderIE` class
+    override fun episodeListParse(response: Response): List<SEpisode> {
+        val document = response.asJsoup()
+        val episodeList = mutableListOf<SEpisode>()
+
+        val keyRegex = """"(\w{39})"""".toRegex()
+        val versionRegex = """"([^"]+web-frontend[^"]+)"""".toRegex()
+        val jsonRegex = """(?:)\s*(\{(.+)\})\s*(?:)""".toRegex(RegexOption.DOT_MATCHES_ALL)
+        val boundary = "=====vc17a3rwnndj====="
+
+        fun traverseFolder(url: String, path: String, recursionDepth: Int = 0) {
+            if (recursionDepth == MAX_RECURSION_DEPTH) return
+
+            val folderId = url.substringAfter("/folders/")
+            val driveHeaders = headers.newBuilder()
+                .add("Accept", "*/*")
+                .add("Connection", "keep-alive")
+                .add("Cookie", getCookie("https://drive.google.com"))
+                .add("Host", "drive.google.com")
+                .build()
+
+            val driveDocument = client.newCall(
+                GET(url, headers = driveHeaders),
+            ).execute().asJsoup()
+            if (driveDocument.selectFirst("title:contains(Error 404 \\(Not found\\))") != null) return
+
+            val keyScript = driveDocument.select("script").first { script ->
+                keyRegex.find(script.data()) != null
+            }.data()
+            val key = keyRegex.find(keyScript)?.groupValues?.get(1) ?: ""
+
+            val versionScript = driveDocument.select("script").first { script ->
+                keyRegex.find(script.data()) != null
+            }.data()
+            val driveVersion = versionRegex.find(versionScript)?.groupValues?.get(1) ?: ""
+            val sapisid = client.cookieJar.loadForRequest("https://drive.google.com".toHttpUrl()).firstOrNull {
+                it.name == "SAPISID" || it.name == "__Secure-3PAPISID"
+            }?.value ?: ""
+
+            var pageToken: String? = ""
+            while (pageToken != null) {
+                val requestUrl = "/drive/v2beta/files?openDrive=true&reason=102&syncType=0&errorRecovery=false&q=trashed%20%3D%20false%20and%20'$folderId'%20in%20parents&fields=kind%2CnextPageToken%2Citems(kind%2CmodifiedDate%2CmodifiedByMeDate%2ClastViewedByMeDate%2CfileSize%2Cowners(kind%2CpermissionId%2Cid)%2ClastModifyingUser(kind%2CpermissionId%2Cid)%2ChasThumbnail%2CthumbnailVersion%2Ctitle%2Cid%2CresourceKey%2Cshared%2CsharedWithMeDate%2CuserPermission(role)%2CexplicitlyTrashed%2CmimeType%2CquotaBytesUsed%2Ccopyable%2CfileExtension%2CsharingUser(kind%2CpermissionId%2Cid)%2Cspaces%2Cversion%2CteamDriveId%2ChasAugmentedPermissions%2CcreatedDate%2CtrashingUser(kind%2CpermissionId%2Cid)%2CtrashedDate%2Cparents(id)%2CshortcutDetails(targetId%2CtargetMimeType%2CtargetLookupStatus)%2Ccapabilities(canCopy%2CcanDownload%2CcanEdit%2CcanAddChildren%2CcanDelete%2CcanRemoveChildren%2CcanShare%2CcanTrash%2CcanRename%2CcanReadTeamDrive%2CcanMoveTeamDriveItem)%2Clabels(starred%2Ctrashed%2Crestricted%2Cviewed))%2CincompleteSearch&appDataFilter=NO_APP_DATA&spaces=drive&pageToken=$pageToken&maxResults=50&supportsTeamDrives=true&includeItemsFromAllDrives=true&corpora=default&orderBy=folder%2Ctitle_natural%20asc&retryCount=0&key=$key HTTP/1.1"
+                val body = """--$boundary
+                    |content-type: application/http
+                    |content-transfer-encoding: binary
+                    |
+                    |GET $requestUrl
+                    |X-Goog-Drive-Client-Version: $driveVersion
+                    |authorization: ${generateSapisidhashHeader(sapisid)}
+                    |x-goog-authuser: 0
+                    |
+                    |--$boundary
+                    |
+                    """.trimMargin("|").toRequestBody("multipart/mixed; boundary=\"$boundary\"".toMediaType())
+
+                val postUrl = "https://clients6.google.com/batch/drive/v2beta".toHttpUrl().newBuilder()
+                    .addQueryParameter("${'$'}ct", "multipart/mixed;boundary=\"$boundary\"")
+                    .addQueryParameter("key", key)
+                    .build()
+                    .toString()
+
+                val postHeaders = headers.newBuilder()
+                    .add("Content-Type", "text/plain; charset=UTF-8")
+                    .add("Origin", "https://drive.google.com")
+                    .add("Cookie", getCookie("https://drive.google.com"))
+                    .build()
+
+                val response = client.newCall(
+                    POST(postUrl, body = body, headers = postHeaders),
+                ).execute()
+                val parsed = json.decodeFromString<PostResponse>(
+                    jsonRegex.find(response.body.string())!!.groupValues[1],
+                )
+                if (parsed.items == null) throw Exception("Failed to load items, please log in through webview")
+                parsed.items.forEachIndexed { index, it ->
+                    if (it.mimeType.startsWith("video")) {
+                        val episode = SEpisode.create()
+                        val size = formatBytes(it.fileSize?.toLongOrNull())
+                        val pathName = if (preferences.getBoolean("trim_info", false)) {
+                            path.trimInfo()
+                        } else {
+                            path
+                        }
+
+                        val itemNumberRegex = """ - (?:S\d+E)?(\d+)""".toRegex()
+                        episode.scanlator = if (preferences.getBoolean("scanlator_order", false)) {
+                            "/$pathName • $size"
+                        } else {
+                            "$size • /$pathName"
+                        }
+                        episode.name = if (preferences.getBoolean("trim_episode", false)) {
+                            it.title.trimInfo()
+                        } else {
+                            it.title
+                        }
+                        episode.url = "https://drive.google.com/uc?id=${it.id}"
+                        episode.episode_number = itemNumberRegex.find(it.title.trimInfo())?.groupValues?.get(1)?.toFloatOrNull() ?: index.toFloat()
+                        episode.date_upload = -1L
+                        episodeList.add(episode)
+                    }
+                    if (it.mimeType.endsWith(".folder")) {
+                        traverseFolder(
+                            "https://drive.google.com/drive/folders/${it.id}",
+                            "$path/${it.title}",
+                            recursionDepth + 1,
+                        )
+                    }
+                }
+
+                pageToken = parsed.nextPageToken
+            }
+        }
+
+        document.select("div.tokha > div > a[href]").distinctBy { t ->
+            t.text()
+        }.forEach {
+            val url = it.attr("href").toHttpUrl()
+            val noRedirectClient = client.newBuilder().followRedirects(false).build()
+
+            if (url.host.contains("drive.google.com")) {
+                traverseFolder(url.toString().substringBeforeLast("?usp=shar"), it.text())
+            }
+            if (url.host.contains("tinyurl")) {
+                val redirected = noRedirectClient.newCall(GET(url.toString())).execute()
+                redirected.headers["location"]?.let { location ->
+                    if (location.toHttpUrl().host.contains("drive.google.com")) {
+                        traverseFolder(location.substringBeforeLast("?usp=shar"), it.text())
+                    }
+                }
+            }
+        }
+
+        return episodeList.reversed()
+    }
+
+    override fun episodeListSelector(): String = throw Exception("Not used")
+
+    override fun episodeFromElement(element: Element): SEpisode = throw Exception("Not used")
+
+    // ============================ Video Links =============================
+
+    override fun fetchVideoList(episode: SEpisode): Observable<List<Video>> {
+        val videoList = GoogleDriveExtractor(client, headers).videosFromUrl(episode.url)
+        return Observable.just(videoList)
+    }
+
+    override fun videoFromElement(element: Element): Video = throw Exception("Not Used")
+
+    override fun videoListSelector(): String = throw Exception("Not Used")
+
+    override fun videoUrlParse(document: Document): String = throw Exception("Not Used")
+
+    // ============================= Utilities ==============================
+
+    // https://github.com/yt-dlp/yt-dlp/blob/8f0be90ecb3b8d862397177bb226f17b245ef933/yt_dlp/extractor/youtube.py#L573
+    private fun generateSapisidhashHeader(SAPISID: String, origin: String = "https://drive.google.com"): String {
+        val timeNow = System.currentTimeMillis() / 1000
+        // SAPISIDHASH algorithm from https://stackoverflow.com/a/32065323
+        val sapisidhash = MessageDigest
+            .getInstance("SHA-1")
+            .digest("$timeNow $SAPISID $origin".toByteArray())
+            .joinToString("") { "%02x".format(it) }
+        return "SAPISIDHASH ${timeNow}_$sapisidhash"
+    }
+
+    @Serializable
+    data class PostResponse(
+        val nextPageToken: String? = null,
+        val items: List<ResponseItem>? = null,
+    ) {
+        @Serializable
+        data class ResponseItem(
+            val id: String,
+            val title: String,
+            val mimeType: String,
+            val fileSize: String? = null,
+        )
+    }
+
+    private fun String.trimInfo(): String {
+        var newString = this.replaceFirst("""^\[\w+\] """.toRegex(), "")
+        val regex = """( ?\[[\s\w-]+\]| ?\([\s\w-]+\))(\.mkv|\.mp4|\.avi)?${'$'}""".toRegex()
+
+        while (regex.containsMatchIn(newString)) {
+            newString = regex.replace(newString) { matchResult ->
+                matchResult.groups[2]?.value ?: ""
+            }
+        }
+
+        return newString.trim()
+    }
+
+    private fun formatBytes(bytes: Long?): String? {
+        if (bytes == null) return null
+        val absB = if (bytes == Long.MIN_VALUE) Long.MAX_VALUE else Math.abs(bytes)
+        if (absB < 1024) {
+            return "$bytes B"
+        }
+        var value = absB
+        val ci: CharacterIterator = StringCharacterIterator("KMGTPE")
+        var i = 40
+        while (i >= 0 && absB > 0xfffccccccccccccL shr i) {
+            value = value shr 10
+            ci.next()
+            i -= 10
+        }
+        value *= java.lang.Long.signum(bytes).toLong()
+        return java.lang.String.format("%.1f %cB", value / 1024.0, ci.current())
+    }
+
+    private fun getCookie(url: String): String {
+        val cookieList = client.cookieJar.loadForRequest(url.toHttpUrl())
+        return if (cookieList.isNotEmpty()) {
+            cookieList.joinToString("; ") { "${it.name}=${it.value}" }
+        } else {
+            ""
+        }
+    }
+
+    private fun parseStatus(statusString: String): Int {
+        return when (statusString) {
+            "Currently Airing" -> SAnime.ONGOING
+            "Finished Airing" -> SAnime.COMPLETED
+            else -> SAnime.UNKNOWN
+        }
+    }
+
+    override fun setupPreferenceScreen(screen: PreferenceScreen) {
+        val scanlatorOrder = SwitchPreferenceCompat(screen.context).apply {
+            key = "scanlator_order"
+            title = "Switch order of file path and size"
+            setDefaultValue(false)
+            setOnPreferenceChangeListener { _, newValue ->
+                preferences.edit().putBoolean(key, newValue as Boolean).commit()
+            }
+        }
+        val trimEpisodeName = SwitchPreferenceCompat(screen.context).apply {
+            key = "trim_episode"
+            title = "Trim info from episode name"
+            setDefaultValue(true)
+            setOnPreferenceChangeListener { _, newValue ->
+                preferences.edit().putBoolean(key, newValue as Boolean).commit()
+            }
+        }
+        val trimEpisodeInfo = SwitchPreferenceCompat(screen.context).apply {
+            key = "trim_info"
+            title = "Trim info from episode info"
+            setDefaultValue(false)
+            setOnPreferenceChangeListener { _, newValue ->
+                preferences.edit().putBoolean(key, newValue as Boolean).commit()
+            }
+        }
+
+        screen.addPreference(scanlatorOrder)
+        screen.addPreference(trimEpisodeName)
+        screen.addPreference(trimEpisodeInfo)
+    }
+}

src/en/ripcrabbyanime/src/eu/kanade/tachiyomi/animeextension/en/ripcrabbyanime/extractors/GoogleDriveExtractor.kt

@@ -0,0 +1,95 @@
+package eu.kanade.tachiyomi.animeextension.en.ripcrabbyanime.extractors
+
+import eu.kanade.tachiyomi.animesource.model.Video
+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.toHttpUrl
+import okhttp3.MediaType.Companion.toMediaType
+import okhttp3.OkHttpClient
+import okhttp3.RequestBody.Companion.toRequestBody
+
+class GoogleDriveExtractor(private val client: OkHttpClient, private val headers: Headers) {
+    // Needs to be the form of `https://drive.google.com/uc?id=GOOGLEDRIVEITEMID`
+    fun videosFromUrl(itemUrl: String, videoName: String = "Video"): List<Video> {
+        val itemHeaders = headers.newBuilder()
+            .add("Accept", "*/*")
+            .add("Accept-Language", "en-US,en;q=0.5")
+            .add("Connection", "keep-alive")
+            .add("Cookie", getCookie(itemUrl))
+            .add("Host", "drive.google.com")
+            .build()
+
+        val itemResponse = client.newCall(
+            GET(itemUrl, headers = itemHeaders),
+        ).execute()
+
+        val noRedirectClient = OkHttpClient().newBuilder().followRedirects(false).build()
+        val document = itemResponse.asJsoup()
+
+        val url = document.selectFirst("form#download-form")?.attr("action") ?: return emptyList()
+        val redirectHeaders = headers.newBuilder()
+            .add("Accept", "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,*/*;q=0.8")
+            .add("Connection", "keep-alive")
+            .add("Content-Length", "0")
+            .add("Content-Type", "application/x-www-form-urlencoded")
+            .add("Cookie", getCookie(url))
+            .add("Host", "drive.google.com")
+            .add("Origin", "https://drive.google.com")
+            .add("Referer", url.substringBeforeLast("&at="))
+            .build()
+
+        val response = noRedirectClient.newCall(
+            POST(url, headers = redirectHeaders, body = "".toRequestBody("application/x-www-form-urlencoded".toMediaType())),
+        ).execute()
+        val redirected = response.headers["location"] ?: return listOf(Video(url, videoName, url))
+
+        val redirectedHeaders = headers.newBuilder()
+            .add("Accept", "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,*/*;q=0.8")
+            .add("Connection", "keep-alive")
+            .add("Host", redirected.toHttpUrl().host)
+            .add("Referer", "https://drive.google.com/")
+            .build()
+
+        val redirectedResponseHeaders = noRedirectClient.newCall(
+            GET(redirected, headers = redirectedHeaders),
+        ).execute().headers
+        val authCookie = redirectedResponseHeaders.first {
+            it.first == "set-cookie" && it.second.startsWith("AUTH_")
+        }.second.substringBefore(";")
+        val newRedirected = redirectedResponseHeaders["location"] ?: return listOf(Video(redirected, videoName, redirected))
+
+        val googleDriveRedirectHeaders = headers.newBuilder()
+            .add("Accept", "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,*/*;q=0.8")
+            .add("Connection", "keep-alive")
+            .add("Cookie", getCookie(newRedirected))
+            .add("Host", "drive.google.com")
+            .add("Referer", "https://drive.google.com/")
+            .build()
+        val googleDriveRedirectUrl = noRedirectClient.newCall(
+            GET(newRedirected, headers = googleDriveRedirectHeaders),
+        ).execute().headers["location"]!!
+
+        val videoHeaders = headers.newBuilder()
+            .add("Accept", "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,*/*;q=0.8")
+            .add("Connection", "keep-alive")
+            .add("Cookie", authCookie)
+            .add("Host", googleDriveRedirectUrl.toHttpUrl().host)
+            .add("Referer", "https://drive.google.com/")
+            .build()
+
+        return listOf(
+            Video(googleDriveRedirectUrl, videoName, googleDriveRedirectUrl, headers = videoHeaders),
+        )
+    }
+
+    private fun getCookie(url: String): String {
+        val cookieList = client.cookieJar.loadForRequest(url.toHttpUrl())
+        return if (cookieList.isNotEmpty()) {
+            cookieList.joinToString("; ") { "${it.name}=${it.value}" }
+        } else {
+            ""
+        }
+    }
+}