recloudstream
/
cloudstream-extensions
mirror of https://github.com/recloudstream/cloudstream-extensions.git
2
2
Fork 0
Code Issues Projects Releases Wiki Activity

Merge f6eb96aea5 into 1fa527454c

This commit is contained in:
PokerFace 2023-03-20 02:48:31 +03:00 committed by GitHub
parent 1fa527454c f6eb96aea5
commit ca4e7244bf
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 83 additions and 54 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
StremioProvider/build.gradle.kts
View File

@ -1,5 +1,5 @@
// use an integer for version numbers // use an integer for version numbers
version = 2 version = 3
cloudstream { cloudstream {
@ -21,4 +21,4 @@ cloudstream {
tvTypes = listOf("Others") tvTypes = listOf("Others")
iconUrl = "https://www.google.com/s2/favicons?domain=www.stremio.com&sz=%size%" iconUrl = "https://www.google.com/s2/favicons?domain=www.stremio.com&sz=%size%"
} }

133
StremioProvider/src/main/kotlin/com/lagradost/StremioProvider.kt
View File

@ -1,26 +1,34 @@
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.*
import com.lagradost.cloudstream3.utils.AppUtils.parseJson
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.Qualities
import com.lagradost.cloudstream3.utils.loadExtractor
import org.json.JSONObject import org.json.JSONObject
import java.net.URI
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"
/** add this as default stream because we don't support torrent yet
and this add ons is the best for http stream */
private var streamUrl = "https://2ecbbd610840-cinestream.baby-beamup.club"
override var name = "Stremio example" override var name = "Stremio example"
override val supportedTypes = setOf(TvType.Others) override val supportedTypes = setOf(TvType.Others)
override val hasMainPage = true override val hasMainPage = true
// check if id is imdb/tmdb cause stremio addons like torrentio works base on imdbId
private fun isImdborTmdb(url: String?): Boolean {
return imdbUrlToIdNullable(url) != null || url?.startsWith("tmdb:") == true
}
override suspend fun getMainPage(page: Int, request: MainPageRequest): HomePageResponse? { override suspend fun getMainPage(page: Int, request: MainPageRequest): HomePageResponse? {
val res = tryParseJson<Manifest>(app.get("${mainUrl}/manifest.json").text) ?: return null val res = tryParseJson<Manifest>(app.get("${mainUrl}/manifest.json").text) ?: return null
val lists = mutableListOf<HomePageList>() val lists = mutableListOf<HomePageList>()
@ -45,8 +53,10 @@ 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 = parseJson<CatalogEntry>(url)
return res.toLoadResponse(this) val json = app.get("${mainUrl}/meta/${res.type}/${res.id}.json").parsedSafe<CatalogResponse>()?.meta ?: throw RuntimeException(url)
isMetaId = isImdborTmdb(res.id)
return json.toLoadResponse(this)
} }
override suspend fun loadLinks( override suspend fun loadLinks(
@ -77,8 +87,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 +101,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 +116,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,
@ -111,20 +127,21 @@ class StremioProvider : MainAPI() {
) { ) {
fun toSearchResponse(provider: StremioProvider): SearchResponse { fun toSearchResponse(provider: StremioProvider): SearchResponse {
return provider.newMovieSearchResponse( return provider.newMovieSearchResponse(
name, fixTitle(name),
this.toJson(), this.toJson(),
TvType.Others TvType.Others
) { ) {
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" if(isMetaId) "${provider.streamUrl}/stream/${type}/${id}.json" else "${provider.mainUrl}/stream/${type}/${id}.json"
) { ) {
posterUrl = poster posterUrl = poster
plot = description plot = description
@ -132,7 +149,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,60 +163,75 @@ 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 {
val ids = id.split(":")
return provider.newEpisode( return provider.newEpisode(
"${provider.mainUrl}/stream/${type?.encodeUri()}/${id.encodeUri()}.json" if(isMetaId) "${provider.streamUrl}/stream/${type}/${id}.json" else "${provider.mainUrl}/stream/${type}/${id}.json"
) { ) {
this.name = title this.name = title
this.posterUrl = thumbnail this.posterUrl = thumbnail
this.description = overview this.description = overview
this.episode = ids.lastOrNull()?.toIntOrNull()
this.season = ids.getOrNull(ids.lastIndex - 1)?.toIntOrNull()
} }
} }
} }
private data class StreamsResponse(val streams: List<Stream>) private data class StreamsResponse(val streams: List<Stream>)
private data class Subtitle(
val url: String?,
val lang: String?,
val id: String?,
)
private data class Stream( private data class Stream(
val name: String?, val name: String?,
val title: String?, val title: String?,
val url: String?, val url: String?,
val description: String?,
val ytId: String?, val ytId: String?,
val externalUrl: String?, val externalUrl: String?,
val behaviorHints: JSONObject?, val behaviorHints: JSONObject?,
val infoHash: String?, val infoHash: String?,
val sources: List<String> = emptyList() val sources: List<String> = emptyList(),
val subtitles: List<Subtitle> = 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))
} }
callback.invoke(
if (url.endsWith(".m3u8")) { ExtractorLink(
callback.invoke(
ExtractorLink(
name ?: "", name ?: "",
title ?: name ?: "", title ?: name ?: "",
url, url,
referer ?: "", referer ?: "",
Qualities.Unknown.value, getQualityFromName(description),
isM3u8 = true isM3u8 = URI(url).path.endsWith(".m3u8")
)) )
} else { )
callback.invoke( subtitles.map { sub ->
ExtractorLink( subtitleCallback.invoke(
name ?: "", SubtitleFile(
title ?: name ?: "", SubtitleHelper.fromThreeLettersToLanguage(sub.lang ?: "") ?: sub.lang ?: "",
url, sub.url ?: return@map
referer ?: "", )
Qualities.Unknown.value, )
isM3u8 = false
))
} }
} }
if (ytId != null) { if (ytId != null) {
@ -212,17 +244,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 +267,7 @@ class StremioProvider : MainAPI() {
} }
companion object { companion object {
fun String.encodeUri() = URLEncoder.encode(this, "utf8") private var isMetaId = false
fun String.encodeUri(): String = URLEncoder.encode(this, "utf8")
} }
} }