recloudstream/cloudstream-extensions
2
2
Fork 0
mirror of https://github.com/recloudstream/cloudstream-extensions.git synced 2024-08-15 03:03:54 +00:00
Code Issues Projects Releases Wiki Activity

fixed stremio

Browse source
This commit is contained in:
PokerFace 2023-03-16 06:41:23 +07:00 • committed by GitHub
parent b1a9851fc0
commit 6522056cc6
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 48 additions and 35 deletions
Download patch file Download diff file Expand all files Collapse all files

81
StremioProvider/src/main/kotlin/com/lagradost/StremioProvider.kt
View file

@ -1,19 +1,17 @@
package com.lagradost package com.lagradost
import android.util.Log import android.util.Log
import com.lagradost.StremioProvider.Companion.encodeUri
import com.lagradost.cloudstream3.* import com.lagradost.cloudstream3.*
import com.lagradost.cloudstream3.utils.AppUtils.toJson import com.lagradost.cloudstream3.utils.AppUtils.toJson
import com.lagradost.cloudstream3.utils.AppUtils.tryParseJson import com.lagradost.cloudstream3.utils.AppUtils.tryParseJson
import com.lagradost.cloudstream3.utils.Coroutines.ioSafe
import com.lagradost.cloudstream3.utils.ExtractorLink import com.lagradost.cloudstream3.utils.ExtractorLink
import com.lagradost.cloudstream3.utils.Qualities import com.lagradost.cloudstream3.utils.Qualities
import com.lagradost.cloudstream3.utils.loadExtractor import com.lagradost.cloudstream3.utils.loadExtractor
import org.json.JSONObject import org.json.JSONObject
import java.net.URLEncoder import java.net.URLEncoder
private const val TRACKER_LIST_URL = "https://raw.githubusercontent.com/ngosang/trackerslist/master/trackers_best.txt" private const val TRACKER_LIST_URL =
"https://raw.githubusercontent.com/ngosang/trackerslist/master/trackers_best.txt"
class StremioProvider : MainAPI() { class StremioProvider : MainAPI() {
override var mainUrl = "https://stremio.github.io/stremio-static-addon-example" override var mainUrl = "https://stremio.github.io/stremio-static-addon-example"
@ -46,7 +44,8 @@ class StremioProvider : MainAPI() {
override suspend fun load(url: String): LoadResponse? { override suspend fun load(url: String): LoadResponse? {
val res = tryParseJson<CatalogEntry>(url) ?: throw RuntimeException(url) val res = tryParseJson<CatalogEntry>(url) ?: throw RuntimeException(url)
return res.toLoadResponse(this) val json = app.get("${mainUrl}/meta/${res.type}/${res.id}.json").parsedSafe<CatalogResponse>()?.meta ?: throw RuntimeException(url)
return json.toLoadResponse(this)
} }
override suspend fun loadLinks( override suspend fun loadLinks(
@ -77,8 +76,11 @@ class StremioProvider : MainAPI() {
suspend fun search(query: String, provider: StremioProvider): List<SearchResponse> { suspend fun search(query: String, provider: StremioProvider): List<SearchResponse> {
val entries = mutableListOf<SearchResponse>() val entries = mutableListOf<SearchResponse>()
types.forEach { type -> types.forEach { type ->
val res = tryParseJson<CatalogResponse>(app.get("${provider.mainUrl}/catalog/${type.encodeUri()}/${id.encodeUri()}/search=${query.encodeUri()}.json").text) ?: return@forEach val json = app.get("${provider.mainUrl}/catalog/${type}/${id}/search=${query}.json").text
res.metas.forEach { entry -> val res =
tryParseJson<CatalogResponse>(json)
?: return@forEach
res.metas?.forEach { entry ->
entries.add(entry.toSearchResponse(provider)) entries.add(entry.toSearchResponse(provider))
} }
} }
@ -88,8 +90,11 @@ class StremioProvider : MainAPI() {
suspend fun toHomePageList(provider: StremioProvider): HomePageList? { suspend fun toHomePageList(provider: StremioProvider): HomePageList? {
val entries = mutableListOf<SearchResponse>() val entries = mutableListOf<SearchResponse>()
types.forEach { type -> types.forEach { type ->
val res = tryParseJson<CatalogResponse>(app.get("${provider.mainUrl}/catalog/${type.encodeUri()}/${id.encodeUri()}.json").text) ?: return@forEach val json = app.get("${provider.mainUrl}/catalog/${type}/${id}.json").text
res.metas.forEach { entry -> val res =
tryParseJson<CatalogResponse>(json)
?: return@forEach
res.metas?.forEach { entry ->
entries.add(entry.toSearchResponse(provider)) entries.add(entry.toSearchResponse(provider))
} }
} }
@ -100,7 +105,7 @@ class StremioProvider : MainAPI() {
} }
} }
private data class CatalogResponse(val metas: List<CatalogEntry>) private data class CatalogResponse(val metas: List<CatalogEntry>?,val meta: CatalogEntry?)
private data class CatalogEntry( private data class CatalogEntry(
val name: String, val name: String,
val id: String, val id: String,
@ -118,13 +123,14 @@ class StremioProvider : MainAPI() {
posterUrl = poster posterUrl = poster
} }
} }
suspend fun toLoadResponse(provider: StremioProvider): LoadResponse { suspend fun toLoadResponse(provider: StremioProvider): LoadResponse {
if (videos == null || videos.isEmpty()) { if (videos == null || videos.isEmpty()) {
return provider.newMovieLoadResponse( return provider.newMovieLoadResponse(
name, name,
"${provider.mainUrl}/meta/${type?.encodeUri()}/${id.encodeUri()}.json", "${provider.mainUrl}/meta/${type}/${id}.json",
TvType.Others, TvType.Others,
"${provider.mainUrl}/stream/${type?.encodeUri()}/${id.encodeUri()}.json" "${provider.mainUrl}/stream/${type}/${id}.json"
) { ) {
posterUrl = poster posterUrl = poster
plot = description plot = description
@ -132,7 +138,7 @@ class StremioProvider : MainAPI() {
} else { } else {
return provider.newTvSeriesLoadResponse( return provider.newTvSeriesLoadResponse(
name, name,
"${provider.mainUrl}/meta/${type?.encodeUri()}/${id.encodeUri()}.json", "${provider.mainUrl}/meta/${type}/${id}.json",
TvType.Others, TvType.Others,
videos.map { videos.map {
it.toEpisode(provider, type) it.toEpisode(provider, type)
@ -146,10 +152,15 @@ class StremioProvider : MainAPI() {
} }
} }
private data class Video(val id: String, val title: String?, val thumbnail: String?, val overview: String?) { private data class Video(
val id: String,
val title: String?,
val thumbnail: String?,
val overview: String?
) {
fun toEpisode(provider: StremioProvider, type: String?): Episode { fun toEpisode(provider: StremioProvider, type: String?): Episode {
return provider.newEpisode( return provider.newEpisode(
"${provider.mainUrl}/stream/${type?.encodeUri()}/${id.encodeUri()}.json" "${provider.mainUrl}/stream/${type}/${id}.json"
) { ) {
this.name = title this.name = title
this.posterUrl = thumbnail this.posterUrl = thumbnail
@ -169,13 +180,17 @@ class StremioProvider : MainAPI() {
val infoHash: String?, val infoHash: String?,
val sources: List<String> = emptyList() val sources: List<String> = emptyList()
) { ) {
suspend fun runCallback(subtitleCallback: (SubtitleFile) -> Unit, callback: (ExtractorLink) -> Unit) { suspend fun runCallback(
subtitleCallback: (SubtitleFile) -> Unit,
callback: (ExtractorLink) -> Unit
) {
if (url != null) { if (url != null) {
var referer: String? = null var referer: String? = null
try { try {
val headers = ((behaviorHints?.get("proxyHeaders") as? JSONObject) val headers = ((behaviorHints?.get("proxyHeaders") as? JSONObject)
?.get("request") as? JSONObject) ?.get("request") as? JSONObject)
referer = headers?.get("referer") as? String ?: headers?.get("origin") as? String referer =
headers?.get("referer") as? String ?: headers?.get("origin") as? String
} catch (ex: Throwable) { } catch (ex: Throwable) {
Log.e("Stremio", Log.getStackTraceString(ex)) Log.e("Stremio", Log.getStackTraceString(ex))
} }
@ -183,13 +198,14 @@ class StremioProvider : MainAPI() {
if (url.endsWith(".m3u8")) { if (url.endsWith(".m3u8")) {
callback.invoke( callback.invoke(
ExtractorLink( ExtractorLink(
name ?: "", name ?: "",
title ?: name ?: "", title ?: name ?: "",
url, url,
referer ?: "", referer ?: "",
Qualities.Unknown.value, Qualities.Unknown.value,
isM3u8 = true isM3u8 = true
)) )
)
} else { } else {
callback.invoke( callback.invoke(
ExtractorLink( ExtractorLink(
@ -199,7 +215,8 @@ class StremioProvider : MainAPI() {
referer ?: "", referer ?: "",
Qualities.Unknown.value, Qualities.Unknown.value,
isM3u8 = false isM3u8 = false
)) )
)
} }
} }
if (ytId != null) { if (ytId != null) {
@ -212,17 +229,13 @@ class StremioProvider : MainAPI() {
val resp = app.get(TRACKER_LIST_URL).text val resp = app.get(TRACKER_LIST_URL).text
val otherTrackers = resp val otherTrackers = resp
.split("\n") .split("\n")
.filterIndexed{i, s -> i%2==0} .filterIndexed { i, s -> i % 2 == 0 }
.filter{s -> !s.isNullOrEmpty()} .filter { s -> s.isNotEmpty() }.joinToString("") { "&tr=$it" }
.map{it -> "&tr=$it"}
.joinToString("")
val sourceTrackers = sources val sourceTrackers = sources
.filter{it->it.startsWith("tracker:")} .filter { it -> it.startsWith("tracker:") }
.map{it->it.removePrefix("tracker:")} .map { it -> it.removePrefix("tracker:") }
.filter{s -> !s.isNullOrEmpty()} .filter { s -> s.isNotEmpty() }.joinToString("") { "&tr=$it" }
.map{it -> "&tr=$it"}
.joinToString("")
val magnet = "magnet:?xt=urn:btih:${infoHash}${sourceTrackers}${otherTrackers}" val magnet = "magnet:?xt=urn:btih:${infoHash}${sourceTrackers}${otherTrackers}"
callback.invoke( callback.invoke(
@ -239,6 +252,6 @@ class StremioProvider : MainAPI() {
} }
companion object { companion object {
fun String.encodeUri() = URLEncoder.encode(this, "utf8") fun String.encodeUri(): String = URLEncoder.encode(this, "utf8")
} }
} }