feat(src/es): New source: Beatzanime (#3111)

Signed-off-by: Secozzi <[email protected]>

src/es/beatzanime/build.gradle

@@ -0,0 +1,7 @@
+ext {
+    extName = 'BeatZ Anime'
+    extClass = '.BeatZAnime'
+    extVersionCode = 1
+}
+
+apply from: "$rootDir/common.gradle"

src/es/beatzanime/src/eu/kanade/tachiyomi/animeextension/es/beatzanime/BeatZAnime.kt

@@ -0,0 +1,281 @@
+package eu.kanade.tachiyomi.animeextension.es.beatzanime
+
+import eu.kanade.tachiyomi.animesource.model.AnimeFilterList
+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.util.asJsoup
+import eu.kanade.tachiyomi.util.parseAs
+import kotlinx.serialization.Serializable
+import kotlinx.serialization.json.JsonObject
+import okhttp3.FormBody
+import okhttp3.HttpUrl.Companion.toHttpUrl
+import okhttp3.Request
+import okhttp3.Response
+import org.jsoup.nodes.Document
+import org.jsoup.nodes.Element
+
+class BeatZAnime : ParsedAnimeHttpSource() {
+
+    override val name = "BeatZ Anime"
+
+    override val baseUrl = "https://www.beatz-anime.net"
+
+    private val indexHost = "dd.beatz-anime.net"
+    private val indexHttpUrl = "https://$indexHost".toHttpUrl()
+
+    override val lang = "es"
+
+    override val supportsLatest = true
+
+    // ============================== Popular ===============================
+
+    override fun popularAnimeRequest(page: Int): Request {
+        val url = if (page > 1) {
+            "$baseUrl/emision/pagina=$page"
+        } else {
+            "$baseUrl/emision/"
+        }
+
+        return GET(url, headers)
+    }
+
+    override fun popularAnimeSelector(): String = ".row > div:has(a.titulo-largo)"
+
+    override fun popularAnimeFromElement(element: Element): SAnime = SAnime.create().apply {
+        thumbnail_url = element.selectFirst("img")!!.imgAttr()
+        with(element.selectFirst("a.titulo-largo")!!) {
+            setUrlWithoutDomain(attr("abs:href"))
+            title = text()
+        }
+    }
+
+    override fun popularAnimeNextPageSelector(): String = "ul.pagination > li.active + li:not(.disabled)"
+
+    // =============================== Latest ===============================
+
+    override fun latestUpdatesRequest(page: Int): Request {
+        val url = if (page > 1) {
+            "$baseUrl/index.php?pagina=$page"
+        } else {
+            "$baseUrl/"
+        }
+
+        return GET(url, headers)
+    }
+    override fun latestUpdatesSelector(): String = popularAnimeSelector()
+
+    override fun latestUpdatesFromElement(element: Element): SAnime = popularAnimeFromElement(element)
+
+    override fun latestUpdatesNextPageSelector(): String = popularAnimeNextPageSelector()
+
+    // =============================== Search ===============================
+
+    override fun searchAnimeRequest(page: Int, query: String, filters: AnimeFilterList): Request {
+        val source = filters.filterIsInstance<SourceFilter>().first().getValue()
+        val status = filters.filterIsInstance<StatusFilter>().first().getValue()
+        val type = filters.filterIsInstance<TypeFilter>().first().getValue()
+
+        val url = "$baseUrl/lista-animes/index.php"
+
+        val formBody = FormBody.Builder().apply {
+            add("buscar", query)
+            add("fuente", source)
+            add("estado", status)
+            add("tipo-anime", type)
+        }.build()
+
+        val formHeaders = headersBuilder().apply {
+            add("Accept", "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,*/*;q=0.8")
+            add("Host", baseUrl.toHttpUrl().host)
+            add("Origin", baseUrl)
+            add("Referer", url)
+        }.build()
+
+        return POST(url, formHeaders, formBody)
+    }
+
+    override fun searchAnimeSelector(): String = ".row > div:has(span.titulo)"
+
+    override fun searchAnimeFromElement(element: Element): SAnime = SAnime.create().apply {
+        thumbnail_url = element.selectFirst("img")!!.imgAttr()
+        with(element.selectFirst("a:has(span)")!!) {
+            setUrlWithoutDomain(attr("abs:href"))
+            title = text()
+        }
+    }
+
+    override fun searchAnimeNextPageSelector(): String? = null
+
+    // ============================== Filters ===============================
+
+    override fun getFilterList(): AnimeFilterList = AnimeFilterList(
+        SourceFilter(),
+        StatusFilter(),
+        TypeFilter(),
+    )
+
+    // =========================== Anime Details ============================
+
+    override fun animeDetailsParse(document: Document): SAnime = SAnime.create().apply {
+        title = document.selectFirst("h1")!!.text()
+        thumbnail_url = document.selectFirst(".row > div > img")?.imgAttr()
+        genre = document.selectFirst("p.post-text span:has(b:contains(Generos))")?.ownText()
+        status = document.selectFirst("div:has(>h5:contains(Estado)) a").parseStatus()
+        description = buildString {
+            document.selectFirst("p.post-text")?.textNodes()?.let {
+                append(it.joinToString("\n\n") { it.text() })
+            }
+            append("\n\n")
+            document.selectFirst("p.post-text span:has(b:contains(Sinónimos))")?.let {
+                append("Sinónimos: ")
+                append(it.ownText())
+            }
+        }.trim()
+    }
+
+    private fun Element?.parseStatus(): Int = when (this?.text()?.lowercase()) {
+        "finalizado" -> SAnime.COMPLETED
+        "en emisión", "en emsión" -> SAnime.ONGOING
+        else -> SAnime.UNKNOWN
+    }
+
+    // ============================== Episodes ==============================
+
+    override fun episodeListSelector(): String = throw UnsupportedOperationException()
+
+    override fun episodeFromElement(element: Element): SEpisode =
+        throw UnsupportedOperationException()
+
+    override fun episodeListParse(response: Response): List<SEpisode> {
+        val document = response.asJsoup()
+        val episodeList = mutableListOf<SEpisode>()
+
+        val indexUrlRaw = document.selectFirst("a[href*=$indexHost]")!!.attr("abs:href").toHttpUrl()
+        val indexUrl = if (indexUrlRaw.encodedPath.contains("api/raw/")) {
+            val path = indexUrlRaw.queryParameter("path")!!.substringAfter("/")
+                .substringBefore("/")
+            "https://$indexHost/$path/"
+        } else {
+            indexUrlRaw.toString()
+        }
+
+        fun traverseFolder(basePath: String, relativePath: String, recursionDepth: Int = 0) {
+            if (recursionDepth == 2) return
+
+            val apiHeaders = headersBuilder().apply {
+                add("Accept", "application/json, text/plain, */*")
+                add("Host", indexHost)
+                add(
+                    "Referer",
+                    indexHttpUrl.newBuilder()
+                        .addPathSegments(basePath)
+                        .build()
+                        .toString(),
+                )
+            }.build()
+
+            val apiUrl = indexHttpUrl.newBuilder().apply {
+                addPathSegment("api")
+                addPathSegment("")
+                addQueryParameter("path", basePath)
+            }.build()
+
+            val data = client.newCall(
+                GET(apiUrl, apiHeaders),
+            ).execute().parseAs<IndexResponseDto>()
+
+            data.folder.value.forEach { item ->
+                if (item.folder != null) {
+                    traverseFolder("$basePath/${item.name}", item.name, recursionDepth + 1)
+                } else if (item.file != null) {
+                    val fileExt = item.name.substringAfterLast(".")
+                    if (!SUPPORTED_FORMATS.any { it.equals(fileExt, true) }) return@forEach
+
+                    episodeList.add(
+                        SEpisode.create().apply {
+                            name = item.name
+                            url = "$basePath/${item.name}"
+                            scanlator = buildList {
+                                if (relativePath != "") add(relativePath)
+                                add(item.size.formatBytes())
+                            }.joinToString(" • ")
+                        },
+                    )
+                }
+            }
+        }
+
+        traverseFolder("/${indexUrl.toHttpUrl().pathSegments.first()}", "")
+
+        return episodeList.reversed()
+    }
+
+    @Serializable
+    class IndexResponseDto(
+        val folder: FolderDto,
+    ) {
+        @Serializable
+        class FolderDto(
+            val value: List<ItemDto>,
+        ) {
+            @Serializable
+            class ItemDto(
+                val name: String,
+                val size: Long,
+                val folder: JsonObject? = null,
+                val file: JsonObject? = null,
+            )
+        }
+    }
+
+    private fun Long.formatBytes(): String = when {
+        this >= 1_000_000_000 -> "%.2f GB".format(this / 1_000_000_000.0)
+        this >= 1_000_000 -> "%.2f MB".format(this / 1_000_000.0)
+        this >= 1_000 -> "%.2f KB".format(this / 1_000.0)
+        this > 1 -> "$this bytes"
+        this == 1L -> "$this byte"
+        else -> ""
+    }
+
+    // ============================ Video Links =============================
+
+    override suspend fun getVideoList(episode: SEpisode): List<Video> {
+        val url = indexHttpUrl.newBuilder().apply {
+            addPathSegment("api")
+            addPathSegment("raw")
+            addPathSegment("")
+            addQueryParameter("path", episode.url)
+        }.build().toString()
+
+        val path = episode.url.substringAfter("/").substringBeforeLast("/") + "/"
+
+        val videoHeaders = headersBuilder().apply {
+            add("Accept", "text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,*/*;q=0.8")
+            add("Referer", indexHttpUrl.newBuilder().addPathSegments(path).build().toString())
+        }.build()
+
+        return listOf(Video(url, "Video", url, videoHeaders))
+    }
+
+    override fun videoListSelector() = throw UnsupportedOperationException()
+
+    override fun videoFromElement(element: Element) = throw UnsupportedOperationException()
+
+    override fun videoUrlParse(document: Document) = throw UnsupportedOperationException()
+
+    // ============================= Utilities ==============================
+
+    private fun Element.imgAttr(): String = when {
+        hasAttr("data-lazy-src") -> attr("abs:data-lazy-src")
+        hasAttr("data-src") -> attr("abs:data-src")
+        else -> attr("abs:src")
+    }
+
+    companion object {
+        private val SUPPORTED_FORMATS = listOf("mp4", "mkv")
+    }
+}

src/es/beatzanime/src/eu/kanade/tachiyomi/animeextension/es/beatzanime/Filters.kt

@@ -0,0 +1,45 @@
+package eu.kanade.tachiyomi.animeextension.es.beatzanime
+
+import eu.kanade.tachiyomi.animesource.model.AnimeFilter
+
+open class UriPartFilter(
+    name: String,
+    private val vals: Array<Pair<String, String>>,
+    defaultValue: String? = null,
+) : AnimeFilter.Select<String>(
+    name,
+    vals.map { it.first }.toTypedArray(),
+    vals.indexOfFirst { it.second == defaultValue }.takeIf { it != -1 } ?: 0,
+) {
+    fun getValue(): String {
+        return vals[state].second
+    }
+}
+
+class SourceFilter : UriPartFilter(
+    "Status",
+    arrayOf(
+        Pair("Todos", ""),
+        Pair("BDRip", "BDRip"),
+        Pair("WebRip", "WebRip"),
+    ),
+)
+
+class StatusFilter : UriPartFilter(
+    "Estado",
+    arrayOf(
+        Pair("Todos", ""),
+        Pair("En Emision", "En Emision"),
+        Pair("Finalizado", "Finalizado"),
+        Pair("En Proceso", "En Proceso"),
+    ),
+)
+
+class TypeFilter : UriPartFilter(
+    "Tipo",
+    arrayOf(
+        Pair("Todos", ""),
+        Pair("Serie", "Serie"),
+        Pair("Pelicula", "Pelicula"),
+    ),
+)