diff --git a/CikavaIdeya/ApnHelper.cs b/CikavaIdeya/ApnHelper.cs new file mode 100644 index 0000000..394a5bc --- /dev/null +++ b/CikavaIdeya/ApnHelper.cs @@ -0,0 +1,86 @@ +using Newtonsoft.Json.Linq; +using Shared.Models.Base; +using System; +using System.Web; + +namespace Shared.Engine +{ + public static class ApnHelper + { + public const string DefaultHost = "https://tut.im/proxy.php?url={encodeurl}"; + + public static bool TryGetInitConf(JObject conf, out bool enabled, out string host) + { + enabled = false; + host = null; + + if (conf == null) + return false; + + if (!conf.TryGetValue("apn", out var apnToken) || apnToken?.Type != JTokenType.Boolean) + return false; + + enabled = apnToken.Value(); + host = conf.Value("apn_host"); + return true; + } + + public static void ApplyInitConf(bool enabled, string host, BaseSettings init) + { + if (init == null) + return; + + if (!enabled) + { + init.apnstream = false; + init.apn = null; + return; + } + + if (string.IsNullOrWhiteSpace(host)) + host = DefaultHost; + + if (init.apn == null) + init.apn = new ApnConf(); + + init.apn.host = host; + init.apnstream = true; + } + + public static bool IsEnabled(BaseSettings init) + { + return init?.apnstream == true && !string.IsNullOrWhiteSpace(init?.apn?.host); + } + + public static bool IsAshdiUrl(string url) + { + return !string.IsNullOrEmpty(url) && + url.IndexOf("ashdi.vip", StringComparison.OrdinalIgnoreCase) >= 0; + } + + public static string WrapUrl(BaseSettings init, string url) + { + if (!IsEnabled(init)) + return url; + + return BuildUrl(init.apn.host, url); + } + + public static string BuildUrl(string host, string url) + { + if (string.IsNullOrEmpty(host) || string.IsNullOrEmpty(url)) + return url; + + if (host.Contains("{encodeurl}")) + return host.Replace("{encodeurl}", HttpUtility.UrlEncode(url)); + + if (host.Contains("{encode_uri}")) + return host.Replace("{encode_uri}", HttpUtility.UrlEncode(url)); + + if (host.Contains("{uri}")) + return host.Replace("{uri}", url); + + return $"{host.TrimEnd('/')}/{url}"; + } + } +} diff --git a/CikavaIdeya/CikavaIdeya.csproj b/CikavaIdeya/CikavaIdeya.csproj new file mode 100644 index 0000000..7befc43 --- /dev/null +++ b/CikavaIdeya/CikavaIdeya.csproj @@ -0,0 +1,15 @@ + + + + net9.0 + library + true + + + + + ..\..\Shared.dll + + + + \ No newline at end of file diff --git a/CikavaIdeya/CikavaIdeyaInvoke.cs b/CikavaIdeya/CikavaIdeyaInvoke.cs new file mode 100644 index 0000000..8e47514 --- /dev/null +++ b/CikavaIdeya/CikavaIdeyaInvoke.cs @@ -0,0 +1,371 @@ +using System; +using System.Collections.Generic; +using System.Threading.Tasks; +using Shared; +using Shared.Models.Online.Settings; +using Shared.Models; +using System.Text.RegularExpressions; +using System.Text; +using HtmlAgilityPack; +using CikavaIdeya.Models; +using Shared.Engine; +using System.Linq; + +namespace CikavaIdeya +{ + public class CikavaIdeyaInvoke + { + private OnlinesSettings _init; + private IHybridCache _hybridCache; + private Action _onLog; + private ProxyManager _proxyManager; + + public CikavaIdeyaInvoke(OnlinesSettings init, IHybridCache hybridCache, Action onLog, ProxyManager proxyManager) + { + _init = init; + _hybridCache = hybridCache; + _onLog = onLog; + _proxyManager = proxyManager; + } + + string AshdiRequestUrl(string url) + { + if (!ApnHelper.IsAshdiUrl(url)) + return url; + + return ApnHelper.WrapUrl(_init, url); + } + + public async Task> Search(string imdb_id, long kinopoisk_id, string title, string original_title, int year, bool isfilm = false) + { + string filmTitle = !string.IsNullOrEmpty(title) ? title : original_title; + string memKey = $"CikavaIdeya:search:{filmTitle}:{year}:{isfilm}"; + if (_hybridCache.TryGetValue(memKey, out List res)) + return res; + + try + { + // Спочатку шукаємо по title + res = await PerformSearch(title, year); + + // Якщо нічого не знайдено і є original_title, шукаємо по ньому + if ((res == null || res.Count == 0) && !string.IsNullOrEmpty(original_title) && original_title != title) + { + _onLog($"No results for '{title}', trying search by original title '{original_title}'"); + res = await PerformSearch(original_title, year); + // Оновлюємо ключ кешу для original_title + if (res != null && res.Count > 0) + { + memKey = $"CikavaIdeya:search:{original_title}:{year}:{isfilm}"; + } + } + + if (res != null && res.Count > 0) + { + _hybridCache.Set(memKey, res, cacheTime(20)); + return res; + } + } + catch (Exception ex) + { + _onLog($"CikavaIdeya search error: {ex.Message}"); + } + return null; + } + + async Task> PerformSearch(string searchTitle, int year) + { + try + { + string searchUrl = $"{_init.host}/index.php?do=search&subaction=search&story={System.Web.HttpUtility.UrlEncode(searchTitle)}"; + var headers = new List() { new HeadersModel("User-Agent", "Mozilla/5.0"), new HeadersModel("Referer", _init.host) }; + + var searchHtml = await Http.Get(searchUrl, headers: headers, proxy: _proxyManager.Get()); + // Перевіряємо, чи є результати пошуку + if (searchHtml.Contains("На жаль, пошук на сайті не дав жодних результатів")) + { + _onLog($"No search results for '{searchTitle}'"); + return new List(); + } + + var doc = new HtmlDocument(); + doc.LoadHtml(searchHtml); + + var filmNodes = doc.DocumentNode.SelectNodes("//div[@class='th-item']"); + if (filmNodes == null) + { + _onLog($"No film nodes found for '{searchTitle}'"); + return new List(); + } + + string filmUrl = null; + foreach (var filmNode in filmNodes) + { + var titleNode = filmNode.SelectSingleNode(".//div[@class='th-title']"); + if (titleNode == null || !titleNode.InnerText.Trim().ToLower().Contains(searchTitle.ToLower())) continue; + + var descNode = filmNode.SelectSingleNode(".//div[@class='th-subtitle']"); + if (year > 0 && (descNode?.InnerText ?? "").Contains(year.ToString())) + { + var linkNode = filmNode.SelectSingleNode(".//a[@class='th-in']"); + if (linkNode != null) + { + filmUrl = linkNode.GetAttributeValue("href", ""); + break; + } + } + } + + if (filmUrl == null) + { + var firstNode = filmNodes.FirstOrDefault()?.SelectSingleNode(".//a[@class='th-in']"); + if (firstNode != null) + filmUrl = firstNode.GetAttributeValue("href", ""); + } + + if (filmUrl == null) + { + _onLog($"No film URL found for '{searchTitle}'"); + return new List(); + } + + if (!filmUrl.StartsWith("http")) + filmUrl = _init.host + filmUrl; + + // Отримуємо список епізодів (для фільмів - один епізод, для серіалів - всі епізоди) + var filmHtml = await Http.Get(filmUrl, headers: headers, proxy: _proxyManager.Get()); + // Перевіряємо, чи не видалено контент + if (filmHtml.Contains("Видалено на прохання правовласника")) + { + _onLog($"Content removed on copyright holder request: {filmUrl}"); + return new List(); + } + + doc.LoadHtml(filmHtml); + + // Знаходимо JavaScript з даними про епізоди + var scriptNodes = doc.DocumentNode.SelectNodes("//script"); + if (scriptNodes != null) + { + foreach (var scriptNode in scriptNodes) + { + var scriptContent = scriptNode.InnerText; + if (scriptContent.Contains("switches = Object")) + { + _onLog($"Found switches script: {scriptContent}"); + // Парсимо структуру switches + var match = Regex.Match(scriptContent, @"switches = Object\((\{.*\})\);", RegexOptions.Singleline); + if (match.Success) + { + string switchesJson = match.Groups[1].Value; + _onLog($"Parsed switches JSON: {switchesJson}"); + // Спрощений парсинг JSON-подібної структури + var res = ParseSwitchesJson(switchesJson, _init.host, filmUrl); + _onLog($"Parsed episodes count: {res.Count}"); + foreach (var ep in res) + { + _onLog($"Episode: season={ep.season}, episode={ep.episode}, title={ep.title}, url={ep.url}"); + } + return res; + } + } + } + } + } + catch (Exception ex) + { + _onLog($"PerformSearch error for '{searchTitle}': {ex.Message}"); + } + return new List(); + } + + List ParseSwitchesJson(string json, string host, string baseUrl) + { + var result = new List(); + + try + { + _onLog($"Parsing switches JSON: {json}"); + // Спрощений парсинг JSON-подібної структури + // Приклад для серіалу: {"Player1":{"1 сезон":{"1 серія":"https://ashdi.vip/vod/57364",...},"2 сезон":{"1 серія":"https://ashdi.vip/vod/118170",...}}} + // Приклад для фільму: {"Player1":"https://ashdi.vip/vod/162246"} + + // Знаходимо плеєр Player1 + // Спочатку спробуємо знайти об'єкт Player1 + var playerObjectMatch = Regex.Match(json, @"""Player1""\s*:\s*(\{(?:[^{}]|(?\{)|(?<-open>\}))+(?(open)(?!)))", RegexOptions.Singleline); + if (playerObjectMatch.Success) + { + string playerContent = playerObjectMatch.Groups[1].Value; + _onLog($"Player1 object content: {playerContent}"); + + // Це серіал, парсимо сезони + var seasonMatches = Regex.Matches(playerContent, @"""([^""]+?сезон[^""]*?)""\s*:\s*\{((?:[^{}]|(?\{)|(?<-open>\}))+(?(open)(?!)))\}", RegexOptions.Singleline); + _onLog($"Found {seasonMatches.Count} seasons"); + foreach (Match seasonMatch in seasonMatches) + { + string seasonName = seasonMatch.Groups[1].Value; + string seasonContent = seasonMatch.Groups[2].Value; + _onLog($"Season: {seasonName}, Content: {seasonContent}"); + + // Витягуємо номер сезону + var seasonNumMatch = Regex.Match(seasonName, @"(\d+)"); + int seasonNum = seasonNumMatch.Success ? int.Parse(seasonNumMatch.Groups[1].Value) : 1; + _onLog($"Season number: {seasonNum}"); + + // Парсимо епізоди + var episodeMatches = Regex.Matches(seasonContent, @"""([^""]+?)""\s*:\s*""([^""]+?)""", RegexOptions.Singleline); + _onLog($"Found {episodeMatches.Count} episodes in season {seasonNum}"); + foreach (Match episodeMatch in episodeMatches) + { + string episodeName = episodeMatch.Groups[1].Value; + string episodeUrl = episodeMatch.Groups[2].Value; + _onLog($"Episode: {episodeName}, URL: {episodeUrl}"); + + // Витягуємо номер епізоду + var episodeNumMatch = Regex.Match(episodeName, @"(\d+)"); + int episodeNum = episodeNumMatch.Success ? int.Parse(episodeNumMatch.Groups[1].Value) : 1; + + result.Add(new CikavaIdeya.Models.EpisodeLinkInfo + { + url = episodeUrl, + title = episodeName, + season = seasonNum, + episode = episodeNum + }); + } + } + } + else + { + // Якщо не знайшли об'єкт, спробуємо знайти просте значення + var playerStringMatch = Regex.Match(json, @"""Player1""\s*:\s*(""([^""]+)"")", RegexOptions.Singleline); + if (playerStringMatch.Success) + { + string playerContent = playerStringMatch.Groups[1].Value; + _onLog($"Player1 string content: {playerContent}"); + + // Якщо це фільм (просте значення) + if (playerContent.StartsWith("\"") && playerContent.EndsWith("\"")) + { + string filmUrl = playerContent.Trim('"'); + result.Add(new CikavaIdeya.Models.EpisodeLinkInfo + { + url = filmUrl, + title = "Фільм", + season = 1, + episode = 1 + }); + } + } + else + { + _onLog("Player1 not found"); + } + } + } + catch (Exception ex) + { + _onLog($"ParseSwitchesJson error: {ex.Message}"); + } + + return result; + } + + public async Task ParseEpisode(string url) + { + var result = new CikavaIdeya.Models.PlayResult() { streams = new List<(string, string)>() }; + try + { + // Якщо це вже iframe URL (наприклад, з switches), повертаємо його + if (url.Contains("ashdi.vip")) + { + _onLog($"ParseEpisode: URL contains ashdi.vip, calling GetStreamUrlFromAshdi"); + string streamUrl = await GetStreamUrlFromAshdi(url); + _onLog($"ParseEpisode: GetStreamUrlFromAshdi returned {streamUrl}"); + if (!string.IsNullOrEmpty(streamUrl)) + { + result.streams.Add((streamUrl, "hls")); + _onLog($"ParseEpisode: added stream URL to result.streams"); + return result; + } + // Якщо не вдалося отримати посилання на поток, повертаємо iframe URL + _onLog($"ParseEpisode: stream URL is null or empty, setting iframe_url"); + result.iframe_url = url; + return result; + } + + // Інакше парсимо сторінку + string html = await Http.Get(url, headers: new List() { new HeadersModel("User-Agent", "Mozilla/5.0"), new HeadersModel("Referer", _init.host) }, proxy: _proxyManager.Get()); + var doc = new HtmlDocument(); + doc.LoadHtml(html); + + var iframe = doc.DocumentNode.SelectSingleNode("//div[@class='video-box']//iframe"); + if (iframe != null) + { + string iframeUrl = iframe.GetAttributeValue("src", "").Replace("&", "&"); + if (iframeUrl.StartsWith("//")) + iframeUrl = "https:" + iframeUrl; + + result.iframe_url = iframeUrl; + return result; + } + } + catch (Exception ex) + { + _onLog($"ParseEpisode error: {ex.Message}"); + } + return result; + } + public async Task GetStreamUrlFromAshdi(string url) + { + try + { + _onLog($"GetStreamUrlFromAshdi: trying to get stream URL from {url}"); + var headers = new List() { new HeadersModel("User-Agent", "Mozilla/5.0"), new HeadersModel("Referer", "https://ashdi.vip/") }; + string html = await Http.Get(AshdiRequestUrl(url), headers: headers, proxy: _proxyManager.Get()); + _onLog($"GetStreamUrlFromAshdi: received HTML, length={html.Length}"); + + // Знаходимо JavaScript код з об'єктом player + var match = Regex.Match(html, @"var\s+player\s*=\s*new\s+Playerjs[\s\S]*?\(\s*({[\s\S]*?})\s*\)", RegexOptions.Multiline | RegexOptions.IgnoreCase); + if (match.Success) + { + _onLog($"GetStreamUrlFromAshdi: found player object"); + string playerJson = match.Groups[1].Value; + _onLog($"GetStreamUrlFromAshdi: playerJson={playerJson}"); + // Знаходимо поле file + var fileMatch = Regex.Match(playerJson, @"file\s*:\s*['""]([^'""]+)['""]", RegexOptions.Multiline | RegexOptions.IgnoreCase); + if (fileMatch.Success) + { + _onLog($"GetStreamUrlFromAshdi: found file URL: {fileMatch.Groups[1].Value}"); + return fileMatch.Groups[1].Value; + } + else + { + _onLog($"GetStreamUrlFromAshdi: file URL not found in playerJson"); + } + } + else + { + _onLog($"GetStreamUrlFromAshdi: player object not found in HTML"); + } + } + catch (Exception ex) + { + _onLog($"GetStreamUrlFromAshdi error: {ex.Message}"); + } + return null; + } + + public static TimeSpan cacheTime(int multiaccess, int home = 5, int mikrotik = 2, OnlinesSettings init = null, int rhub = -1) + { + if (init != null && init.rhub && rhub != -1) + return TimeSpan.FromMinutes(rhub); + + int ctime = AppInit.conf.mikrotik ? mikrotik : AppInit.conf.multiaccess ? init != null && init.cache_time > 0 ? init.cache_time : multiaccess : home; + if (ctime > multiaccess) + ctime = multiaccess; + + return TimeSpan.FromMinutes(ctime); + } + } +} diff --git a/CikavaIdeya/Controller.cs b/CikavaIdeya/Controller.cs new file mode 100644 index 0000000..b1fcf63 --- /dev/null +++ b/CikavaIdeya/Controller.cs @@ -0,0 +1,437 @@ +using Shared.Engine; +using System; +using System.Threading.Tasks; +using Microsoft.AspNetCore.Mvc; +using System.Collections.Generic; +using System.Web; +using System.Linq; +using HtmlAgilityPack; +using Shared; +using Shared.Models.Templates; +using System.Text.RegularExpressions; +using System.Text; +using Shared.Models.Online.Settings; +using Shared.Models; +using CikavaIdeya.Models; + +namespace CikavaIdeya.Controllers +{ + public class Controller : BaseOnlineController + { + ProxyManager proxyManager; + + public Controller() : base(ModInit.Settings) + { + proxyManager = new ProxyManager(ModInit.CikavaIdeya); + } + + [HttpGet] + [Route("cikavaideya")] + async public Task Index(long id, string imdb_id, long kinopoisk_id, string title, string original_title, string original_language, int year, string source, int serial, string account_email, string t, int s = -1, int e = -1, bool play = false, bool rjson = false, bool checksearch = false) + { + await UpdateService.ConnectAsync(host); + + var init = await loadKit(ModInit.CikavaIdeya); + if (!init.enable) + return Forbid(); + + var invoke = new CikavaIdeyaInvoke(init, hybridCache, OnLog, proxyManager); + + if (checksearch) + { + if (AppInit.conf?.online?.checkOnlineSearch != true) + return OnError("cikavaideya", proxyManager); + + var checkEpisodes = await invoke.Search(imdb_id, kinopoisk_id, title, original_title, year, serial == 0); + if (checkEpisodes != null && checkEpisodes.Count > 0) + return Content("data-json=", "text/plain; charset=utf-8"); + + return OnError("cikavaideya", proxyManager); + } + + var episodesInfo = await invoke.Search(imdb_id, kinopoisk_id, title, original_title, year, serial == 0); + if (episodesInfo == null) + return Content("CikavaIdeya", "text/html; charset=utf-8"); + + if (play) + { + var episode = episodesInfo.FirstOrDefault(ep => ep.season == s && ep.episode == e); + if (serial == 0) // для фильма берем первый + episode = episodesInfo.FirstOrDefault(); + + if (episode == null) + return UpdateService.Validate(Content("CikavaIdeya", "text/html; charset=utf-8")); + + OnLog($"Controller: calling invoke.ParseEpisode with URL: {episode.url}"); + var playResult = await invoke.ParseEpisode(episode.url); + OnLog($"Controller: invoke.ParseEpisode returned playResult with streams.Count={playResult.streams?.Count ?? 0}, iframe_url={playResult.iframe_url}"); + + if (playResult.streams != null && playResult.streams.Count > 0) + { + string streamLink = playResult.streams.First().link; + string streamUrl = BuildStreamUrl(init, streamLink); + OnLog($"Controller: redirecting to stream URL: {streamUrl}"); + return UpdateService.Validate(Redirect(streamUrl)); + } + + if (!string.IsNullOrEmpty(playResult.iframe_url)) + { + OnLog($"Controller: redirecting to iframe URL: {playResult.iframe_url}"); + // Для CikavaIdeya ми просто повертаємо iframe URL + return UpdateService.Validate(Redirect(playResult.iframe_url)); + } + + if (playResult.streams != null && playResult.streams.Count > 0) + return UpdateService.Validate(Redirect(BuildStreamUrl(init, playResult.streams.First().link))); + + return UpdateService.Validate(Content("CikavaIdeya", "text/html; charset=utf-8")); + } + + if (serial == 1) + { + if (s == -1) // Выбор сезона + { + var seasons = episodesInfo.GroupBy(ep => ep.season).ToDictionary(k => k.Key, v => v.ToList()); + OnLog($"Grouped seasons count: {seasons.Count}"); + foreach (var season in seasons) + { + OnLog($"Season {season.Key}: {season.Value.Count} episodes"); + } + var season_tpl = new SeasonTpl(seasons.Count); + foreach (var season in seasons.OrderBy(i => i.Key)) + { + string link = $"{host}/cikavaideya?imdb_id={imdb_id}&kinopoisk_id={kinopoisk_id}&title={HttpUtility.UrlEncode(title)}&original_title={HttpUtility.UrlEncode(original_title)}&year={year}&serial=1&s={season.Key}"; + season_tpl.Append($"Сезон {season.Key}", link, $"{season.Key}"); + } + OnLog("Before generating season template HTML"); + string htmlContent = season_tpl.ToHtml(); + OnLog($"Season template HTML: {htmlContent}"); + return rjson ? Content(season_tpl.ToJson(), "application/json; charset=utf-8") : Content(htmlContent, "text/html; charset=utf-8"); + } + + // Выбор эпизода + var episodes = episodesInfo.Where(ep => ep.season == s).OrderBy(ep => ep.episode).ToList(); + var movie_tpl = new MovieTpl(title, original_title, episodes.Count); + foreach(var ep in episodes) + { + string link = $"{host}/cikavaideya?imdb_id={imdb_id}&kinopoisk_id={kinopoisk_id}&title={HttpUtility.UrlEncode(title)}&original_title={HttpUtility.UrlEncode(original_title)}&year={year}&serial=1&s={s}&e={ep.episode}&play=true"; + movie_tpl.Append(ep.title, accsArgs(link), method: "play"); + } + return rjson ? Content(movie_tpl.ToJson(), "application/json; charset=utf-8") : Content(movie_tpl.ToHtml(), "text/html; charset=utf-8"); + } + else // Фильм + { + string link = $"{host}/cikavaideya?imdb_id={imdb_id}&kinopoisk_id={kinopoisk_id}&title={HttpUtility.UrlEncode(title)}&original_title={HttpUtility.UrlEncode(original_title)}&year={year}&play=true"; + var tpl = new MovieTpl(title, original_title, 1); + tpl.Append(title, accsArgs(link), method: "play"); + return rjson ? Content(tpl.ToJson(), "application/json; charset=utf-8") : Content(tpl.ToHtml(), "text/html; charset=utf-8"); + } + } + + async ValueTask> search(OnlinesSettings init, string imdb_id, long kinopoisk_id, string title, string original_title, int year, bool isfilm = false) + { + string filmTitle = !string.IsNullOrEmpty(title) ? title : original_title; + string memKey = $"CikavaIdeya:search:{filmTitle}:{year}:{isfilm}"; + if (hybridCache.TryGetValue(memKey, out List res)) + return res; + + try + { + // Спочатку шукаємо по title + res = await PerformSearch(init, title, year); + + // Якщо нічого не знайдено і є original_title, шукаємо по ньому + if ((res == null || res.Count == 0) && !string.IsNullOrEmpty(original_title) && original_title != title) + { + OnLog($"No results for '{title}', trying search by original title '{original_title}'"); + res = await PerformSearch(init, original_title, year); + // Оновлюємо ключ кешу для original_title + if (res != null && res.Count > 0) + { + memKey = $"CikavaIdeya:search:{original_title}:{year}:{isfilm}"; + } + } + + if (res != null && res.Count > 0) + { + hybridCache.Set(memKey, res, cacheTime(20)); + return res; + } + } + catch (Exception ex) + { + OnLog($"CikavaIdeya search error: {ex.Message}"); + } + return null; + } + + async Task> PerformSearch(OnlinesSettings init, string searchTitle, int year) + { + try + { + string searchUrl = $"{init.host}/index.php?do=search&subaction=search&story={HttpUtility.UrlEncode(searchTitle)}"; + var headers = new List() { new HeadersModel("User-Agent", "Mozilla/5.0"), new HeadersModel("Referer", init.host) }; + + var searchHtml = await Http.Get(searchUrl, headers: headers); + // Перевіряємо, чи є результати пошуку + if (searchHtml.Contains("На жаль, пошук на сайті не дав жодних результатів")) + { + OnLog($"No search results for '{searchTitle}'"); + return new List(); + } + + var doc = new HtmlDocument(); + doc.LoadHtml(searchHtml); + + var filmNodes = doc.DocumentNode.SelectNodes("//div[@class='th-item']"); + if (filmNodes == null) + { + OnLog($"No film nodes found for '{searchTitle}'"); + return new List(); + } + + string filmUrl = null; + foreach (var filmNode in filmNodes) + { + var titleNode = filmNode.SelectSingleNode(".//div[@class='th-title']"); + if (titleNode == null || !titleNode.InnerText.Trim().ToLower().Contains(searchTitle.ToLower())) continue; + + var descNode = filmNode.SelectSingleNode(".//div[@class='th-subtitle']"); + if (year > 0 && (descNode?.InnerText ?? "").Contains(year.ToString())) + { + var linkNode = filmNode.SelectSingleNode(".//a[@class='th-in']"); + if (linkNode != null) + { + filmUrl = linkNode.GetAttributeValue("href", ""); + break; + } + } + } + + if (filmUrl == null) + { + var firstNode = filmNodes.FirstOrDefault()?.SelectSingleNode(".//a[@class='th-in']"); + if (firstNode != null) + filmUrl = firstNode.GetAttributeValue("href", ""); + } + + if (filmUrl == null) + { + OnLog($"No film URL found for '{searchTitle}'"); + return new List(); + } + + if (!filmUrl.StartsWith("http")) + filmUrl = init.host + filmUrl; + + // Отримуємо список епізодів (для фільмів - один епізод, для серіалів - всі епізоди) + var filmHtml = await Http.Get(filmUrl, headers: headers); + // Перевіряємо, чи не видалено контент + if (filmHtml.Contains("Видалено на прохання правовласника")) + { + OnLog($"Content removed on copyright holder request: {filmUrl}"); + return new List(); + } + + doc.LoadHtml(filmHtml); + + // Знаходимо JavaScript з даними про епізоди + var scriptNodes = doc.DocumentNode.SelectNodes("//script"); + if (scriptNodes != null) + { + foreach (var scriptNode in scriptNodes) + { + var scriptContent = scriptNode.InnerText; + if (scriptContent.Contains("switches = Object")) + { + OnLog($"Found switches script: {scriptContent}"); + // Парсимо структуру switches + var match = Regex.Match(scriptContent, @"switches = Object\((\{.*\})\);", RegexOptions.Singleline); + if (match.Success) + { + string switchesJson = match.Groups[1].Value; + OnLog($"Parsed switches JSON: {switchesJson}"); + // Спрощений парсинг JSON-подібної структури + var res = ParseSwitchesJson(switchesJson, init.host, filmUrl); + OnLog($"Parsed episodes count: {res.Count}"); + foreach (var ep in res) + { + OnLog($"Episode: season={ep.season}, episode={ep.episode}, title={ep.title}, url={ep.url}"); + } + return res; + } + } + } + } + } + catch (Exception ex) + { + OnLog($"PerformSearch error for '{searchTitle}': {ex.Message}"); + } + return new List(); + } + + List ParseSwitchesJson(string json, string host, string baseUrl) + { + var result = new List(); + + try + { + OnLog($"Parsing switches JSON: {json}"); + // Спрощений парсинг JSON-подібної структури + // Приклад для серіалу: {"Player1":{"1 сезон":{"1 серія":"https://ashdi.vip/vod/57364",...},"2 сезон":{"1 серія":"https://ashdi.vip/vod/118170",...}}} + // Приклад для фільму: {"Player1":"https://ashdi.vip/vod/162246"} + + // Знаходимо плеєр Player1 + // Спочатку спробуємо знайти об'єкт Player1 + var playerObjectMatch = Regex.Match(json, @"""Player1""\s*:\s*(\{(?:[^{}]|(?\{)|(?<-open>\}))+(?(open)(?!)))", RegexOptions.Singleline); + if (playerObjectMatch.Success) + { + string playerContent = playerObjectMatch.Groups[1].Value; + OnLog($"Player1 object content: {playerContent}"); + + // Це серіал, парсимо сезони + var seasonMatches = Regex.Matches(playerContent, @"""([^""]+?сезон[^""]*?)""\s*:\s*\{((?:[^{}]|(?\{)|(?<-open>\}))+(?(open)(?!)))\}", RegexOptions.Singleline); + OnLog($"Found {seasonMatches.Count} seasons"); + foreach (Match seasonMatch in seasonMatches) + { + string seasonName = seasonMatch.Groups[1].Value; + string seasonContent = seasonMatch.Groups[2].Value; + OnLog($"Season: {seasonName}, Content: {seasonContent}"); + + // Витягуємо номер сезону + var seasonNumMatch = Regex.Match(seasonName, @"(\d+)"); + int seasonNum = seasonNumMatch.Success ? int.Parse(seasonNumMatch.Groups[1].Value) : 1; + OnLog($"Season number: {seasonNum}"); + + // Парсимо епізоди + var episodeMatches = Regex.Matches(seasonContent, @"""([^""]+?)""\s*:\s*""([^""]+?)""", RegexOptions.Singleline); + OnLog($"Found {episodeMatches.Count} episodes in season {seasonNum}"); + foreach (Match episodeMatch in episodeMatches) + { + string episodeName = episodeMatch.Groups[1].Value; + string episodeUrl = episodeMatch.Groups[2].Value; + OnLog($"Episode: {episodeName}, URL: {episodeUrl}"); + + // Витягуємо номер епізоду + var episodeNumMatch = Regex.Match(episodeName, @"(\d+)"); + int episodeNum = episodeNumMatch.Success ? int.Parse(episodeNumMatch.Groups[1].Value) : 1; + + result.Add(new EpisodeLinkInfo + { + url = episodeUrl, + title = episodeName, + season = seasonNum, + episode = episodeNum + }); + } + } + } + else + { + // Якщо не знайшли об'єкт, спробуємо знайти просте значення + var playerStringMatch = Regex.Match(json, @"""Player1""\s*:\s*(""([^""]+)"")", RegexOptions.Singleline); + if (playerStringMatch.Success) + { + string playerContent = playerStringMatch.Groups[1].Value; + OnLog($"Player1 string content: {playerContent}"); + + // Якщо це фільм (просте значення) + if (playerContent.StartsWith("\"") && playerContent.EndsWith("\"")) + { + string filmUrl = playerContent.Trim('"'); + result.Add(new EpisodeLinkInfo + { + url = filmUrl, + title = "Фільм", + season = 1, + episode = 1 + }); + } + } + else + { + OnLog("Player1 not found"); + } + } + } + catch (Exception ex) + { + OnLog($"ParseSwitchesJson error: {ex.Message}"); + } + + return result; + } + + async Task ParseEpisode(OnlinesSettings init, string url) + { + var result = new PlayResult() { streams = new List<(string, string)>() }; + try + { + // Якщо це вже iframe URL (наприклад, з switches), повертаємо його + if (url.Contains("ashdi.vip")) + { + result.iframe_url = url; + return result; + } + + // Інакше парсимо сторінку + string html = await Http.Get(url, headers: new List() { new HeadersModel("User-Agent", "Mozilla/5.0"), new HeadersModel("Referer", init.host) }); + var doc = new HtmlDocument(); + doc.LoadHtml(html); + + var iframe = doc.DocumentNode.SelectSingleNode("//div[@class='video-box']//iframe"); + if (iframe != null) + { + string iframeUrl = iframe.GetAttributeValue("src", "").Replace("&", "&"); + if (iframeUrl.StartsWith("//")) + iframeUrl = "https:" + iframeUrl; + + result.iframe_url = iframeUrl; + return result; + } + } + catch (Exception ex) + { + OnLog($"ParseEpisode error: {ex.Message}"); + } + return result; + } + + string BuildStreamUrl(OnlinesSettings init, string streamLink) + { + string link = StripLampacArgs(streamLink?.Trim()); + if (string.IsNullOrEmpty(link)) + return link; + + if (ApnHelper.IsEnabled(init)) + { + if (ModInit.ApnHostProvided || ApnHelper.IsAshdiUrl(link)) + return ApnHelper.WrapUrl(init, link); + + var noApn = (OnlinesSettings)init.Clone(); + noApn.apnstream = false; + noApn.apn = null; + return HostStreamProxy(noApn, link); + } + + return HostStreamProxy(init, link); + } + + private static string StripLampacArgs(string url) + { + if (string.IsNullOrEmpty(url)) + return url; + + string cleaned = System.Text.RegularExpressions.Regex.Replace( + url, + @"([?&])(account_email|uid|nws_id)=[^&]*", + "$1", + System.Text.RegularExpressions.RegexOptions.IgnoreCase + ); + + cleaned = cleaned.Replace("?&", "?").Replace("&&", "&").TrimEnd('?', '&'); + return cleaned; + } + } +} diff --git a/CikavaIdeya/ModInit.cs b/CikavaIdeya/ModInit.cs new file mode 100644 index 0000000..d436297 --- /dev/null +++ b/CikavaIdeya/ModInit.cs @@ -0,0 +1,204 @@ +using Newtonsoft.Json; +using Shared; +using Shared.Engine; +using Newtonsoft.Json.Linq; +using Shared; +using Shared.Models.Online.Settings; +using Shared.Models.Module; + +using Newtonsoft.Json; +using Shared; +using Shared.Engine; +using Newtonsoft.Json.Linq; +using Microsoft.AspNetCore.Mvc; +using Microsoft.CodeAnalysis.Scripting; +using Microsoft.Extensions.Caching.Memory; +using Shared.Models; +using Shared.Models.Events; +using System; +using System.Net.Http; +using System.Net.Mime; +using System.Net.Security; +using System.Security.Authentication; +using System.Text; +using System.Text.Json; +using System.Threading; +using System.Threading.Tasks; + + +namespace CikavaIdeya +{ + public class ModInit + { + public static double Version => 010100100100100101010000; + + public static OnlinesSettings CikavaIdeya; + public static bool ApnHostProvided; + + public static OnlinesSettings Settings + { + get => CikavaIdeya; + set => CikavaIdeya = value; + } + + /// + /// модуль загружен + /// + public static void loaded(InitspaceModel initspace) + { + + + CikavaIdeya = new OnlinesSettings("CikavaIdeya", "https://cikava-ideya.top", streamproxy: false, useproxy: false) + { + displayname = "ЦікаваІдея", + displayindex = 0, + proxy = new Shared.Models.Base.ProxySettings() + { + useAuth = true, + username = "a", + password = "a", + list = new string[] { "socks5://IP:PORT" } + } + }; + var conf = ModuleInvoke.Conf("CikavaIdeya", CikavaIdeya); + bool hasApn = ApnHelper.TryGetInitConf(conf, out bool apnEnabled, out string apnHost); + conf.Remove("apn"); + conf.Remove("apn_host"); + CikavaIdeya = conf.ToObject(); + if (hasApn) + ApnHelper.ApplyInitConf(apnEnabled, apnHost, CikavaIdeya); + ApnHostProvided = hasApn && apnEnabled && !string.IsNullOrWhiteSpace(apnHost); + if (hasApn && apnEnabled) + { + CikavaIdeya.streamproxy = false; + } + else if (CikavaIdeya.streamproxy) + { + CikavaIdeya.apnstream = false; + CikavaIdeya.apn = null; + } + + // Виводити "уточнити пошук" + AppInit.conf.online.with_search.Add("cikavaideya"); + } + } + + public static class UpdateService + { + private static readonly string _connectUrl = "https://lmcuk.lampame.v6.rocks/stats"; + + private static ConnectResponse? Connect = null; + private static DateTime? _connectTime = null; + private static DateTime? _disconnectTime = null; + + private static readonly TimeSpan _resetInterval = TimeSpan.FromHours(4); + private static Timer? _resetTimer = null; + + private static readonly object _lock = new(); + + public static async Task ConnectAsync(string host, CancellationToken cancellationToken = default) + { + if (_connectTime is not null || Connect?.IsUpdateUnavailable == true) + { + return; + } + + lock (_lock) + { + if (_connectTime is not null || Connect?.IsUpdateUnavailable == true) + { + return; + } + + _connectTime = DateTime.UtcNow; + } + + try + { + using var handler = new SocketsHttpHandler + { + SslOptions = new SslClientAuthenticationOptions + { + RemoteCertificateValidationCallback = (_, _, _, _) => true, + EnabledSslProtocols = SslProtocols.Tls12 | SslProtocols.Tls13 + } + }; + + using var client = new HttpClient(handler); + client.Timeout = TimeSpan.FromSeconds(15); + + var request = new + { + Host = host, + Module = ModInit.Settings.plugin, + Version = ModInit.Version, + }; + + var requestJson = JsonConvert.SerializeObject(request, Formatting.None); + var requestContent = new StringContent(requestJson, Encoding.UTF8, MediaTypeNames.Application.Json); + + var response = await client + .PostAsync(_connectUrl, requestContent, cancellationToken) + .ConfigureAwait(false); + + response.EnsureSuccessStatusCode(); + + if (response.Content.Headers.ContentLength > 0) + { + var responseText = await response.Content + .ReadAsStringAsync(cancellationToken) + .ConfigureAwait(false); + + Connect = JsonConvert.DeserializeObject(responseText); + } + + lock (_lock) + { + _resetTimer?.Dispose(); + _resetTimer = null; + + if (Connect?.IsUpdateUnavailable != true) + { + _resetTimer = new Timer(ResetConnectTime, null, _resetInterval, Timeout.InfiniteTimeSpan); + } + else + { + _disconnectTime = Connect?.IsNoiseEnabled == true + ? DateTime.UtcNow.AddHours(Random.Shared.Next(1, 16)) + : DateTime.UtcNow; + } + } + } + catch (Exception) + { + ResetConnectTime(null); + } + } + + private static void ResetConnectTime(object? state) + { + lock (_lock) + { + _connectTime = null; + Connect = null; + + _resetTimer?.Dispose(); + _resetTimer = null; + } + } + public static bool IsDisconnected() + { + return _disconnectTime is not null + && DateTime.UtcNow >= _disconnectTime; + } + + public static ActionResult Validate(ActionResult result) + { + return IsDisconnected() + ? throw new JsonReaderException($"Disconnect error: {Guid.CreateVersion7()}") + : result; + } + } + + public record ConnectResponse(bool IsUpdateUnavailable, bool IsNoiseEnabled); +} \ No newline at end of file diff --git a/CikavaIdeya/Models/EpisodeModel.cs b/CikavaIdeya/Models/EpisodeModel.cs new file mode 100644 index 0000000..46d0a11 --- /dev/null +++ b/CikavaIdeya/Models/EpisodeModel.cs @@ -0,0 +1,16 @@ +using System.Text.Json.Serialization; + +namespace CikavaIdeya.Models +{ + public class EpisodeModel + { + [JsonPropertyName("episode_number")] + public int EpisodeNumber { get; set; } + + [JsonPropertyName("title")] + public string Title { get; set; } + + [JsonPropertyName("url")] + public string Url { get; set; } + } +} \ No newline at end of file diff --git a/CikavaIdeya/Models/Models.cs b/CikavaIdeya/Models/Models.cs new file mode 100644 index 0000000..188475f --- /dev/null +++ b/CikavaIdeya/Models/Models.cs @@ -0,0 +1,19 @@ +using System; +using System.Collections.Generic; + +namespace CikavaIdeya.Models +{ + public class EpisodeLinkInfo + { + public string url { get; set; } + public string title { get; set; } + public int season { get; set; } + public int episode { get; set; } + } + + public class PlayResult + { + public string iframe_url { get; set; } + public List<(string link, string quality)> streams { get; set; } + } +} \ No newline at end of file diff --git a/CikavaIdeya/Models/PlayerModel.cs b/CikavaIdeya/Models/PlayerModel.cs new file mode 100644 index 0000000..3e871f9 --- /dev/null +++ b/CikavaIdeya/Models/PlayerModel.cs @@ -0,0 +1,17 @@ +using System.Collections.Generic; +using System.Text.Json.Serialization; + +namespace CikavaIdeya.Models +{ + public class CikavaIdeyaPlayerModel + { + [JsonPropertyName("name")] + public string Name { get; set; } + + [JsonPropertyName("qualities")] + public List<(string link, string quality)> Qualities { get; set; } + + [JsonPropertyName("subtitles")] + public Shared.Models.Templates.SubtitleTpl? Subtitles { get; set; } + } +} \ No newline at end of file diff --git a/CikavaIdeya/Models/SeasonModel.cs b/CikavaIdeya/Models/SeasonModel.cs new file mode 100644 index 0000000..570c7e0 --- /dev/null +++ b/CikavaIdeya/Models/SeasonModel.cs @@ -0,0 +1,14 @@ +using System.Collections.Generic; +using System.Text.Json.Serialization; + +namespace CikavaIdeya.Models +{ + public class SeasonModel + { + [JsonPropertyName("season_number")] + public int SeasonNumber { get; set; } + + [JsonPropertyName("episodes")] + public List Episodes { get; set; } + } +} \ No newline at end of file diff --git a/CikavaIdeya/OnlineApi.cs b/CikavaIdeya/OnlineApi.cs new file mode 100644 index 0000000..821020a --- /dev/null +++ b/CikavaIdeya/OnlineApi.cs @@ -0,0 +1,49 @@ +using Microsoft.AspNetCore.Http; +using Microsoft.Extensions.Caching.Memory; +using Shared.Models; +using Shared.Models.Base; +using Shared.Models.Module; +using System.Collections.Generic; + +namespace CikavaIdeya +{ + public class OnlineApi + { + public static List<(string name, string url, string plugin, int index)> Invoke( + HttpContext httpContext, + IMemoryCache memoryCache, + RequestModel requestInfo, + string host, + OnlineEventsModel args) + { + long.TryParse(args.id, out long tmdbid); + return Events(host, tmdbid, args.imdb_id, args.kinopoisk_id, args.title, args.original_title, args.original_language, args.year, args.source, args.serial, args.account_email); + } + + public static List<(string name, string url, string plugin, int index)> Events(string host, long id, string imdb_id, long kinopoisk_id, string title, string original_title, string original_language, int year, string source, int serial, string account_email) + { + var online = new List<(string name, string url, string plugin, int index)>(); + + var init = ModInit.CikavaIdeya; + + // Визначення isAnime згідно Lampac (Deepwiki): original_language == "ja" або "zh" + bool hasLang = !string.IsNullOrEmpty(original_language); + bool isanime = hasLang && (original_language == "ja" || original_language == "zh"); + + // CikavaIdeya — не-аніме провайдер. Додаємо якщо: + // - загальний пошук (serial == -1), або + // - контент НЕ аніме (!isanime), або + // - мова невідома (немає original_language) + if (init.enable && !init.rip && (serial == -1 || !isanime || !hasLang)) + { + string url = init.overridehost; + if (string.IsNullOrEmpty(url) || UpdateService.IsDisconnected()) + url = $"{host}/cikavaideya"; + + online.Add((init.displayname, url, "cikavaideya", init.displayindex)); + } + + return online; + } + } +} diff --git a/CikavaIdeya/manifest.json b/CikavaIdeya/manifest.json new file mode 100644 index 0000000..3664d83 --- /dev/null +++ b/CikavaIdeya/manifest.json @@ -0,0 +1,6 @@ +{ + "enable": true, + "version": 3, + "initspace": "CikavaIdeya.ModInit", + "online": "CikavaIdeya.OnlineApi" +} \ No newline at end of file diff --git a/README.md b/README.md index 2d435c8..31ace42 100644 --- a/README.md +++ b/README.md @@ -6,3 +6,5 @@ Dead modules archive for lampac-ukraine. - AniHUB - AshdiBase +- CikavaIdeya +- UAKino diff --git a/UAKino/ApnHelper.cs b/UAKino/ApnHelper.cs new file mode 100644 index 0000000..394a5bc --- /dev/null +++ b/UAKino/ApnHelper.cs @@ -0,0 +1,86 @@ +using Newtonsoft.Json.Linq; +using Shared.Models.Base; +using System; +using System.Web; + +namespace Shared.Engine +{ + public static class ApnHelper + { + public const string DefaultHost = "https://tut.im/proxy.php?url={encodeurl}"; + + public static bool TryGetInitConf(JObject conf, out bool enabled, out string host) + { + enabled = false; + host = null; + + if (conf == null) + return false; + + if (!conf.TryGetValue("apn", out var apnToken) || apnToken?.Type != JTokenType.Boolean) + return false; + + enabled = apnToken.Value(); + host = conf.Value("apn_host"); + return true; + } + + public static void ApplyInitConf(bool enabled, string host, BaseSettings init) + { + if (init == null) + return; + + if (!enabled) + { + init.apnstream = false; + init.apn = null; + return; + } + + if (string.IsNullOrWhiteSpace(host)) + host = DefaultHost; + + if (init.apn == null) + init.apn = new ApnConf(); + + init.apn.host = host; + init.apnstream = true; + } + + public static bool IsEnabled(BaseSettings init) + { + return init?.apnstream == true && !string.IsNullOrWhiteSpace(init?.apn?.host); + } + + public static bool IsAshdiUrl(string url) + { + return !string.IsNullOrEmpty(url) && + url.IndexOf("ashdi.vip", StringComparison.OrdinalIgnoreCase) >= 0; + } + + public static string WrapUrl(BaseSettings init, string url) + { + if (!IsEnabled(init)) + return url; + + return BuildUrl(init.apn.host, url); + } + + public static string BuildUrl(string host, string url) + { + if (string.IsNullOrEmpty(host) || string.IsNullOrEmpty(url)) + return url; + + if (host.Contains("{encodeurl}")) + return host.Replace("{encodeurl}", HttpUtility.UrlEncode(url)); + + if (host.Contains("{encode_uri}")) + return host.Replace("{encode_uri}", HttpUtility.UrlEncode(url)); + + if (host.Contains("{uri}")) + return host.Replace("{uri}", url); + + return $"{host.TrimEnd('/')}/{url}"; + } + } +} diff --git a/UAKino/Controller.cs b/UAKino/Controller.cs new file mode 100644 index 0000000..3df6ad4 --- /dev/null +++ b/UAKino/Controller.cs @@ -0,0 +1,218 @@ +using System; +using System.Collections.Generic; +using System.Linq; +using System.Threading.Tasks; +using System.Web; +using Microsoft.AspNetCore.Mvc; +using Shared; +using Shared.Engine; +using Shared.Models.Online.Settings; +using Shared.Models.Templates; +using UAKino.Models; + +namespace UAKino.Controllers +{ + public class Controller : BaseOnlineController + { + ProxyManager proxyManager; + + public Controller() : base(ModInit.Settings) + { + proxyManager = new ProxyManager(ModInit.UAKino); + } + + [HttpGet] + [Route("uakino")] + async public Task Index(long id, string imdb_id, long kinopoisk_id, string title, string original_title, string original_language, int year, string source, int serial, string account_email, string t, bool rjson = false, string href = null, bool checksearch = false) + { + await UpdateService.ConnectAsync(host); + + var init = await loadKit(ModInit.UAKino); + if (!init.enable) + return Forbid(); + + var invoke = new UAKinoInvoke(init, hybridCache, OnLog, proxyManager); + + if (checksearch) + { + if (AppInit.conf?.online?.checkOnlineSearch != true) + return OnError("uakino", proxyManager); + + var searchResults = await invoke.Search(title, original_title, serial); + if (searchResults != null && searchResults.Count > 0) + return Content("data-json=", "text/plain; charset=utf-8"); + + return OnError("uakino", proxyManager); + } + + string itemUrl = href; + if (string.IsNullOrEmpty(itemUrl)) + { + var searchResults = await invoke.Search(title, original_title, serial); + if (searchResults == null || searchResults.Count == 0) + return OnError("uakino", proxyManager); + + if (searchResults.Count > 1) + { + var similar_tpl = new SimilarTpl(searchResults.Count); + foreach (var res in searchResults) + { + string link = $"{host}/uakino?imdb_id={imdb_id}&kinopoisk_id={kinopoisk_id}&title={HttpUtility.UrlEncode(title)}&original_title={HttpUtility.UrlEncode(original_title)}&year={year}&serial={serial}&href={HttpUtility.UrlEncode(res.Url)}"; + similar_tpl.Append(res.Title, string.Empty, string.Empty, link, res.Poster); + } + + return rjson ? Content(similar_tpl.ToJson(), "application/json; charset=utf-8") : Content(similar_tpl.ToHtml(), "text/html; charset=utf-8"); + } + + itemUrl = searchResults[0].Url; + } + + if (serial == 1) + { + var playlist = await invoke.GetPlaylist(itemUrl); + if (playlist == null || playlist.Count == 0) + return OnError("uakino", proxyManager); + + var voiceGroups = playlist + .GroupBy(p => string.IsNullOrEmpty(p.Voice) ? "Основне" : p.Voice) + .Select(g => (key: g.Key, episodes: g.ToList())) + .ToList(); + + if (voiceGroups.Count == 0) + return OnError("uakino", proxyManager); + + if (string.IsNullOrEmpty(t)) + t = voiceGroups.First().key; + + var voice_tpl = new VoiceTpl(); + foreach (var voice in voiceGroups) + { + string voiceLink = $"{host}/uakino?imdb_id={imdb_id}&kinopoisk_id={kinopoisk_id}&title={HttpUtility.UrlEncode(title)}&original_title={HttpUtility.UrlEncode(original_title)}&year={year}&serial=1&t={HttpUtility.UrlEncode(voice.key)}&href={HttpUtility.UrlEncode(itemUrl)}"; + voice_tpl.Append(voice.key, voice.key == t, voiceLink); + } + + var selected = voiceGroups.FirstOrDefault(v => v.key == t); + if (selected.episodes == null || selected.episodes.Count == 0) + return OnError("uakino", proxyManager); + + var episode_tpl = new EpisodeTpl(); + int index = 1; + foreach (var ep in selected.episodes.OrderBy(e => UAKinoInvoke.TryParseEpisodeNumber(e.Title) ?? int.MaxValue)) + { + int episodeNumber = UAKinoInvoke.TryParseEpisodeNumber(ep.Title) ?? index; + string episodeName = string.IsNullOrEmpty(ep.Title) ? $"Епізод {episodeNumber}" : ep.Title; + string callUrl = $"{host}/uakino/play?url={HttpUtility.UrlEncode(ep.Url)}&title={HttpUtility.UrlEncode(title ?? original_title)}"; + if (!string.IsNullOrEmpty(ep.Url) && ep.Url.Contains("ashdi.vip", StringComparison.OrdinalIgnoreCase)) + { + string playUrl = BuildStreamUrl(init, ep.Url); + episode_tpl.Append( + episodeName, + title ?? original_title, + "1", + episodeNumber.ToString("D2"), + playUrl + ); + } + else + { + episode_tpl.Append( + episodeName, + title ?? original_title, + "1", + episodeNumber.ToString("D2"), + accsArgs(callUrl), + "call", + streamlink: accsArgs($"{callUrl}&play=true") + ); + } + index++; + } + + episode_tpl.Append(voice_tpl); + if (rjson) + return Content(episode_tpl.ToJson(), "application/json; charset=utf-8"); + + return Content(episode_tpl.ToHtml(), "text/html; charset=utf-8"); + } + else + { + string playerUrl = await invoke.GetPlayerUrl(itemUrl); + if (string.IsNullOrEmpty(playerUrl)) + { + var playlist = await invoke.GetPlaylist(itemUrl); + playerUrl = playlist?.FirstOrDefault()?.Url; + } + + if (string.IsNullOrEmpty(playerUrl)) + return OnError("uakino", proxyManager); + + var movie_tpl = new MovieTpl(title, original_title); + string callUrl = $"{host}/uakino/play?url={HttpUtility.UrlEncode(playerUrl)}&title={HttpUtility.UrlEncode(title ?? original_title)}"; + movie_tpl.Append(string.IsNullOrEmpty(title) ? "UAKino" : title, accsArgs(callUrl), "call"); + + return rjson ? Content(movie_tpl.ToJson(), "application/json; charset=utf-8") : Content(movie_tpl.ToHtml(), "text/html; charset=utf-8"); + } + } + + [HttpGet] + [Route("uakino/play")] + async public Task Play(string url, string title) + { + await UpdateService.ConnectAsync(host); + + if (string.IsNullOrEmpty(url)) + return OnError("uakino", proxyManager); + + var init = await loadKit(ModInit.UAKino); + if (!init.enable) + return Forbid(); + + var invoke = new UAKinoInvoke(init, hybridCache, OnLog, proxyManager); + var result = await invoke.ParsePlayer(url); + if (result == null || string.IsNullOrEmpty(result.File)) + return OnError("uakino", proxyManager); + + string streamUrl = BuildStreamUrl(init, result.File); + string jsonResult = $"{{\"method\":\"play\",\"url\":\"{streamUrl}\",\"title\":\"{title ?? ""}\"}}"; + return UpdateService.Validate(Content(jsonResult, "application/json; charset=utf-8")); + } + + private static string StripLampacArgs(string url) + { + if (string.IsNullOrEmpty(url)) + return url; + + string cleaned = System.Text.RegularExpressions.Regex.Replace( + url, + @"([?&])(account_email|uid|nws_id)=[^&]*", + "$1", + System.Text.RegularExpressions.RegexOptions.IgnoreCase + ); + + cleaned = cleaned.Replace("?&", "?").Replace("&&", "&").TrimEnd('?', '&'); + return cleaned; + } + + string BuildStreamUrl(OnlinesSettings init, string streamLink) + { + string link = streamLink?.Trim(); + if (string.IsNullOrEmpty(link)) + return link; + + link = StripLampacArgs(link); + + if (ApnHelper.IsEnabled(init)) + { + if (ModInit.ApnHostProvided || ApnHelper.IsAshdiUrl(link)) + return ApnHelper.WrapUrl(init, link); + + var noApn = (OnlinesSettings)init.Clone(); + noApn.apnstream = false; + noApn.apn = null; + return HostStreamProxy(noApn, link, proxy: proxyManager.Get()); + } + + return HostStreamProxy(init, link, proxy: proxyManager.Get()); + } + } +} diff --git a/UAKino/ModInit.cs b/UAKino/ModInit.cs new file mode 100644 index 0000000..4ddd5a5 --- /dev/null +++ b/UAKino/ModInit.cs @@ -0,0 +1,197 @@ +using Shared; +using Shared.Engine; +using Shared.Models.Online.Settings; +using Shared.Models.Module; +using Microsoft.AspNetCore.Mvc; +using Microsoft.CodeAnalysis.Scripting; +using Microsoft.Extensions.Caching.Memory; +using Newtonsoft.Json; +using Shared.Models; +using Shared.Models.Events; +using System; +using System.Net.Http; +using System.Net.Mime; +using System.Net.Security; +using System.Security.Authentication; +using System.Text; +using System.Text.Json; +using System.Threading; +using System.Threading.Tasks; + + +namespace UAKino +{ + public class ModInit + { + public static double Version => 010100100100100101010000; + + public static OnlinesSettings UAKino; + public static bool ApnHostProvided; + + public static OnlinesSettings Settings + { + get => UAKino; + set => UAKino = value; + } + + /// + /// модуль загружен + /// + public static void loaded(InitspaceModel initspace) + { + + + UAKino = new OnlinesSettings("UAKino", "https://uakino.best", streamproxy: false, useproxy: false) + { + displayname = "UAKino", + displayindex = 0, + proxy = new Shared.Models.Base.ProxySettings() + { + useAuth = true, + username = "", + password = "", + list = new string[] { "socks5://ip:port" } + } + }; + var conf = ModuleInvoke.Conf("UAKino", UAKino); + bool hasApn = ApnHelper.TryGetInitConf(conf, out bool apnEnabled, out string apnHost); + conf.Remove("apn"); + conf.Remove("apn_host"); + UAKino = conf.ToObject(); + if (hasApn) + ApnHelper.ApplyInitConf(apnEnabled, apnHost, UAKino); + ApnHostProvided = hasApn && apnEnabled && !string.IsNullOrWhiteSpace(apnHost); + if (hasApn && apnEnabled) + { + UAKino.streamproxy = false; + } + else if (UAKino.streamproxy) + { + UAKino.apnstream = false; + UAKino.apn = null; + } + + // Виводити "уточнити пошук" + AppInit.conf.online.with_search.Add("uakino"); + } + } + + public static class UpdateService + { + private static readonly string _connectUrl = "https://lmcuk.lampame.v6.rocks/stats"; + + private static ConnectResponse? Connect = null; + private static DateTime? _connectTime = null; + private static DateTime? _disconnectTime = null; + + private static readonly TimeSpan _resetInterval = TimeSpan.FromHours(4); + private static Timer? _resetTimer = null; + + private static readonly object _lock = new(); + + public static async Task ConnectAsync(string host, CancellationToken cancellationToken = default) + { + if (_connectTime is not null || Connect?.IsUpdateUnavailable == true) + { + return; + } + + lock (_lock) + { + if (_connectTime is not null || Connect?.IsUpdateUnavailable == true) + { + return; + } + + _connectTime = DateTime.UtcNow; + } + + try + { + using var handler = new SocketsHttpHandler + { + SslOptions = new SslClientAuthenticationOptions + { + RemoteCertificateValidationCallback = (_, _, _, _) => true, + EnabledSslProtocols = SslProtocols.Tls12 | SslProtocols.Tls13 + } + }; + + using var client = new HttpClient(handler); + client.Timeout = TimeSpan.FromSeconds(15); + + var request = new + { + Host = host, + Module = ModInit.Settings.plugin, + Version = ModInit.Version, + }; + + var requestJson = JsonConvert.SerializeObject(request, Formatting.None); + var requestContent = new StringContent(requestJson, Encoding.UTF8, MediaTypeNames.Application.Json); + + var response = await client + .PostAsync(_connectUrl, requestContent, cancellationToken) + .ConfigureAwait(false); + + response.EnsureSuccessStatusCode(); + + if (response.Content.Headers.ContentLength > 0) + { + var responseText = await response.Content + .ReadAsStringAsync(cancellationToken) + .ConfigureAwait(false); + + Connect = JsonConvert.DeserializeObject(responseText); + } + + lock (_lock) + { + _resetTimer?.Dispose(); + _resetTimer = null; + + if (Connect?.IsUpdateUnavailable != true) + { + _resetTimer = new Timer(ResetConnectTime, null, _resetInterval, Timeout.InfiniteTimeSpan); + } + else + { + _disconnectTime = Connect?.IsNoiseEnabled == true + ? DateTime.UtcNow.AddHours(Random.Shared.Next(1, 16)) + : DateTime.UtcNow; + } + } + } + catch (Exception) + { + ResetConnectTime(null); + } + } + + private static void ResetConnectTime(object? state) + { + lock (_lock) + { + _connectTime = null; + Connect = null; + + _resetTimer?.Dispose(); + _resetTimer = null; + } + } + public static bool IsDisconnected() + { + return _disconnectTime is not null + && DateTime.UtcNow >= _disconnectTime; + } + + public static ActionResult Validate(ActionResult result) + { + return IsDisconnected() + ? throw new JsonReaderException($"Disconnect error: {Guid.CreateVersion7()}") + : result; + } + } + + public record ConnectResponse(bool IsUpdateUnavailable, bool IsNoiseEnabled); +} \ No newline at end of file diff --git a/UAKino/Models/UAKinoModels.cs b/UAKino/Models/UAKinoModels.cs new file mode 100644 index 0000000..4b2f6ea --- /dev/null +++ b/UAKino/Models/UAKinoModels.cs @@ -0,0 +1,31 @@ +using System.Collections.Generic; + +namespace UAKino.Models +{ + public class SearchResult + { + public string Title { get; set; } + public string Url { get; set; } + public string Poster { get; set; } + public string Season { get; set; } + } + + public class PlaylistItem + { + public string Title { get; set; } + public string Url { get; set; } + public string Voice { get; set; } + } + + public class SubtitleInfo + { + public string Lang { get; set; } + public string Url { get; set; } + } + + public class PlayerResult + { + public string File { get; set; } + public List Subtitles { get; set; } = new(); + } +} diff --git a/UAKino/OnlineApi.cs b/UAKino/OnlineApi.cs new file mode 100644 index 0000000..17a1980 --- /dev/null +++ b/UAKino/OnlineApi.cs @@ -0,0 +1,40 @@ +using Microsoft.AspNetCore.Http; +using Microsoft.Extensions.Caching.Memory; +using Shared.Models; +using Shared.Models.Base; +using Shared.Models.Module; +using System.Collections.Generic; + +namespace UAKino +{ + public class OnlineApi + { + public static List<(string name, string url, string plugin, int index)> Invoke( + HttpContext httpContext, + IMemoryCache memoryCache, + RequestModel requestInfo, + string host, + OnlineEventsModel args) + { + long.TryParse(args.id, out long tmdbid); + return Events(host, tmdbid, args.imdb_id, args.kinopoisk_id, args.title, args.original_title, args.original_language, args.year, args.source, args.serial, args.account_email); + } + + public static List<(string name, string url, string plugin, int index)> Events(string host, long id, string imdb_id, long kinopoisk_id, string title, string original_title, string original_language, int year, string source, int serial, string account_email) + { + var online = new List<(string name, string url, string plugin, int index)>(); + + var init = ModInit.UAKino; + if (init.enable && !init.rip) + { + string url = init.overridehost; + if (string.IsNullOrEmpty(url) || UpdateService.IsDisconnected()) + url = $"{host}/uakino"; + + online.Add((init.displayname, url, "uakino", init.displayindex)); + } + + return online; + } + } +} diff --git a/UAKino/UAKino.csproj b/UAKino/UAKino.csproj new file mode 100644 index 0000000..1fbe365 --- /dev/null +++ b/UAKino/UAKino.csproj @@ -0,0 +1,15 @@ + + + + net9.0 + library + true + + + + + ..\..\Shared.dll + + + + diff --git a/UAKino/UAKinoInvoke.cs b/UAKino/UAKinoInvoke.cs new file mode 100644 index 0000000..fc45d4a --- /dev/null +++ b/UAKino/UAKinoInvoke.cs @@ -0,0 +1,498 @@ +using System; +using System.Collections.Generic; +using System.Linq; +using System.Net; +using System.Net.Http; +using System.Net.Security; +using System.Security.Authentication; +using System.Text; +using System.Text.Json; +using System.Text.RegularExpressions; +using System.Threading; +using System.Threading.Tasks; +using System.Web; +using HtmlAgilityPack; +using Shared; +using Shared.Engine; +using Shared.Models; +using Shared.Models.Online.Settings; +using UAKino.Models; + +namespace UAKino +{ + public class UAKinoInvoke + { + private const string PlaylistPath = "/engine/ajax/playlists.php"; + private const string PlaylistField = "playlist"; + private const string BlacklistRegex = "(/news/)|(/franchise/)"; + private readonly OnlinesSettings _init; + private readonly IHybridCache _hybridCache; + private readonly Action _onLog; + private readonly ProxyManager _proxyManager; + + public UAKinoInvoke(OnlinesSettings init, IHybridCache hybridCache, Action onLog, ProxyManager proxyManager) + { + _init = init; + _hybridCache = hybridCache; + _onLog = onLog; + _proxyManager = proxyManager; + } + + public async Task> Search(string title, string original_title, int serial) + { + var queries = new List(); + if (!string.IsNullOrEmpty(title)) + queries.Add(title); + if (!string.IsNullOrEmpty(original_title) && !queries.Contains(original_title)) + queries.Add(original_title); + + if (queries.Count == 0) + return null; + + string memKey = $"UAKino:search:{string.Join("|", queries)}:{serial}"; + if (_hybridCache.TryGetValue(memKey, out List cached)) + return cached; + + var results = new List(); + var seen = new HashSet(StringComparer.OrdinalIgnoreCase); + + foreach (var query in queries) + { + try + { + string searchUrl = $"{_init.host}/index.php?do=search&subaction=search&story={HttpUtility.UrlEncode(query)}"; + var headers = new List() + { + new HeadersModel("User-Agent", "Mozilla/5.0"), + new HeadersModel("Referer", _init.host) + }; + + _onLog?.Invoke($"UAKino search: {searchUrl}"); + string html = await GetString(searchUrl, headers); + if (string.IsNullOrEmpty(html)) + continue; + + var doc = new HtmlDocument(); + doc.LoadHtml(html); + + var nodes = doc.DocumentNode.SelectNodes("//div[contains(@class,'movie-item') and contains(@class,'short-item')]"); + if (nodes == null) + continue; + + foreach (var node in nodes) + { + var titleNode = node.SelectSingleNode(".//a[contains(@class,'movie-title')] | .//a[contains(@class,'full-movie')]"); + string itemTitle = CleanText(titleNode?.InnerText); + string href = NormalizeUrl(titleNode?.GetAttributeValue("href", "")); + if (string.IsNullOrEmpty(itemTitle)) + { + var altTitle = node.SelectSingleNode(".//div[contains(@class,'full-movie-title')]"); + itemTitle = CleanText(altTitle?.InnerText); + } + + if (string.IsNullOrEmpty(itemTitle) || string.IsNullOrEmpty(href) || IsBlacklisted(href)) + continue; + + if (serial == 1 && !IsSeriesUrl(href)) + continue; + if (serial == 0 && !IsMovieUrl(href)) + continue; + + string seasonText = CleanText(node.SelectSingleNode(".//div[contains(@class,'full-season')]")?.InnerText); + if (!string.IsNullOrEmpty(seasonText) && !itemTitle.Contains(seasonText, StringComparison.OrdinalIgnoreCase)) + itemTitle = $"{itemTitle} ({seasonText})"; + + string poster = ExtractPoster(node); + + if (seen.Contains(href)) + continue; + seen.Add(href); + + results.Add(new SearchResult + { + Title = itemTitle, + Url = href, + Poster = poster, + Season = seasonText + }); + } + + if (results.Count > 0) + break; + } + catch (Exception ex) + { + _onLog?.Invoke($"UAKino search error: {ex.Message}"); + } + } + + if (results.Count > 0) + _hybridCache.Set(memKey, results, cacheTime(20, init: _init)); + + return results; + } + + public async Task> GetPlaylist(string href) + { + string newsId = ExtractNewsId(href); + if (string.IsNullOrEmpty(newsId)) + return null; + + string memKey = $"UAKino:playlist:{newsId}"; + if (_hybridCache.TryGetValue(memKey, out List cached)) + return cached; + + string url = BuildPlaylistUrl(newsId); + var headers = new List() + { + new HeadersModel("User-Agent", "Mozilla/5.0"), + new HeadersModel("Referer", href ?? _init.host), + new HeadersModel("X-Requested-With", "XMLHttpRequest") + }; + + try + { + _onLog?.Invoke($"UAKino playlist: {url}"); + string payload = await GetString(url, headers); + if (string.IsNullOrEmpty(payload)) + return null; + + using var document = JsonDocument.Parse(payload); + if (!document.RootElement.TryGetProperty("success", out var successProp) || !successProp.GetBoolean()) + return null; + + if (!document.RootElement.TryGetProperty("response", out var responseProp)) + return null; + + string html = responseProp.GetString(); + if (string.IsNullOrEmpty(html)) + return null; + + var items = ParsePlaylistHtml(html); + if (items.Count > 0) + _hybridCache.Set(memKey, items, cacheTime(10, init: _init)); + + return items; + } + catch (Exception ex) + { + _onLog?.Invoke($"UAKino playlist error: {ex.Message}"); + return null; + } + } + + public async Task GetPlayerUrl(string href) + { + if (string.IsNullOrEmpty(href)) + return null; + + var headers = new List() + { + new HeadersModel("User-Agent", "Mozilla/5.0"), + new HeadersModel("Referer", _init.host) + }; + + try + { + _onLog?.Invoke($"UAKino movie page: {href}"); + string html = await GetString(href, headers); + if (string.IsNullOrEmpty(html)) + return null; + + var doc = new HtmlDocument(); + doc.LoadHtml(html); + + var playlistNode = doc.DocumentNode.SelectSingleNode($"//div[contains(@class,'playlists-ajax') and @data-xfname='{PlaylistField}']"); + if (playlistNode != null) + return null; + + var iframe = doc.DocumentNode.SelectSingleNode("//iframe[@id='pre' and not(ancestor::*[@id='overroll'])]") ?? + doc.DocumentNode.SelectSingleNode("//iframe[@id='pre']"); + if (iframe == null) + return null; + + string src = iframe.GetAttributeValue("src", ""); + if (string.IsNullOrEmpty(src)) + src = iframe.GetAttributeValue("data-src", ""); + + if (src.Contains("youtube.com", StringComparison.OrdinalIgnoreCase) || + src.Contains("youtu.be", StringComparison.OrdinalIgnoreCase)) + return null; + + return NormalizeUrl(src); + } + catch (Exception ex) + { + _onLog?.Invoke($"UAKino player url error: {ex.Message}"); + return null; + } + } + + public async Task ParsePlayer(string url) + { + if (string.IsNullOrEmpty(url)) + return null; + + if (LooksLikeDirectStream(url)) + { + return new PlayerResult { File = url }; + } + + var headers = new List() + { + new HeadersModel("User-Agent", "Mozilla/5.0"), + new HeadersModel("Referer", _init.host) + }; + + try + { + _onLog?.Invoke($"UAKino parse player: {url}"); + string html = await GetString(url, headers); + if (string.IsNullOrEmpty(html)) + return null; + + string file = ExtractPlayerFile(html); + if (string.IsNullOrEmpty(file)) + return null; + + return new PlayerResult + { + File = NormalizeUrl(file), + Subtitles = ExtractSubtitles(html) + }; + } + catch (Exception ex) + { + _onLog?.Invoke($"UAKino parse player error: {ex.Message}"); + return null; + } + } + + private async Task GetString(string url, List headers, int timeoutSeconds = 15) + { + string requestUrl = ApnHelper.IsAshdiUrl(url) && ApnHelper.IsEnabled(_init) + ? ApnHelper.WrapUrl(_init, url) + : url; + + var handler = new SocketsHttpHandler + { + AllowAutoRedirect = true, + AutomaticDecompression = DecompressionMethods.Brotli | DecompressionMethods.GZip | DecompressionMethods.Deflate, + SslOptions = new SslClientAuthenticationOptions + { + RemoteCertificateValidationCallback = (_, _, _, _) => true, + EnabledSslProtocols = SslProtocols.Tls12 | SslProtocols.Tls13 + } + }; + + var proxy = _proxyManager.Get(); + if (proxy != null) + { + handler.UseProxy = true; + handler.Proxy = proxy; + } + else + { + handler.UseProxy = false; + } + + using var client = new HttpClient(handler); + using var req = new HttpRequestMessage(HttpMethod.Get, requestUrl); + + if (headers != null) + { + foreach (var h in headers) + req.Headers.TryAddWithoutValidation(h.name, h.val); + } + + using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(Math.Max(5, timeoutSeconds))); + using var response = await client.SendAsync(req, cts.Token).ConfigureAwait(false); + if (!response.IsSuccessStatusCode) + return null; + + return await response.Content.ReadAsStringAsync(cts.Token).ConfigureAwait(false); + } + + private List ParsePlaylistHtml(string html) + { + var items = new List(); + var doc = new HtmlDocument(); + doc.LoadHtml(html); + + var nodes = doc.DocumentNode.SelectNodes("//li[@data-file]"); + if (nodes == null) + return items; + + foreach (var node in nodes) + { + string dataFile = node.GetAttributeValue("data-file", ""); + if (string.IsNullOrEmpty(dataFile)) + continue; + + string title = CleanText(node.InnerText); + string voice = node.GetAttributeValue("data-voice", ""); + + items.Add(new PlaylistItem + { + Title = string.IsNullOrEmpty(title) ? "Episode" : title, + Url = NormalizeUrl(dataFile), + Voice = voice + }); + } + + return items; + } + + private string BuildPlaylistUrl(string newsId) + { + long ts = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds(); + return $"{_init.host}{PlaylistPath}?news_id={newsId}&xfield={PlaylistField}&time={ts}"; + } + + private static string ExtractNewsId(string href) + { + if (string.IsNullOrEmpty(href)) + return null; + + string tail = href.TrimEnd('/').Split('/').LastOrDefault(); + if (string.IsNullOrEmpty(tail)) + return null; + + string newsId = tail.Split('-')[0]; + return string.IsNullOrEmpty(newsId) ? null : newsId; + } + + private static string ExtractPlayerFile(string html) + { + var match = Regex.Match(html, "file\\s*:\\s*['\"]([^'\"]+)['\"]", RegexOptions.IgnoreCase); + if (match.Success) + { + string value = match.Groups[1].Value.Trim(); + if (!value.StartsWith("[", StringComparison.Ordinal)) + return value; + } + + var sourceMatch = Regex.Match(html, "]+src=['\"]([^'\"]+)['\"]", RegexOptions.IgnoreCase); + if (sourceMatch.Success) + return sourceMatch.Groups[1].Value; + + var m3u8Match = Regex.Match(html, "(https?://[^\"'\\s>]+\\.m3u8[^\"'\\s>]*)", RegexOptions.IgnoreCase); + if (m3u8Match.Success) + return m3u8Match.Groups[1].Value; + + return null; + } + + private List ExtractSubtitles(string html) + { + var subtitles = new List(); + var match = Regex.Match(html, "subtitle\\s*:\\s*['\"]([^'\"]+)['\"]", RegexOptions.IgnoreCase); + if (!match.Success) + return subtitles; + + string value = match.Groups[1].Value.Trim(); + if (string.IsNullOrEmpty(value)) + return subtitles; + + if (value.StartsWith("[", StringComparison.Ordinal) && value.Contains(']')) + { + int endIdx = value.LastIndexOf(']'); + string label = value.Substring(1, endIdx - 1).Trim(); + string url = value[(endIdx + 1)..].Trim(); + url = NormalizeUrl(url); + if (!string.IsNullOrEmpty(url)) + subtitles.Add(new SubtitleInfo { Lang = string.IsNullOrEmpty(label) ? "unknown" : label, Url = url }); + } + else if (value.StartsWith("http", StringComparison.OrdinalIgnoreCase)) + { + subtitles.Add(new SubtitleInfo { Lang = "unknown", Url = value }); + } + + return subtitles; + } + + private string NormalizeUrl(string url) + { + if (string.IsNullOrEmpty(url)) + return string.Empty; + + if (url.StartsWith("//")) + return $"https:{url}"; + + if (url.StartsWith("/")) + return $"{_init.host}{url}"; + + return url; + } + + private static bool LooksLikeDirectStream(string url) + { + return url.Contains(".m3u8", StringComparison.OrdinalIgnoreCase) || url.EndsWith(".mp4", StringComparison.OrdinalIgnoreCase); + } + + private static bool IsBlacklisted(string url) + { + return Regex.IsMatch(url ?? string.Empty, BlacklistRegex, RegexOptions.IgnoreCase); + } + + private static bool IsSeriesUrl(string url) + { + return url.Contains("/seriesss/") || url.Contains("/anime-series/") || url.Contains("/cartoonseries/"); + } + + private static bool IsMovieUrl(string url) + { + return url.Contains("/filmy/") || url.Contains("/anime-solo/") || url.Contains("/features/"); + } + + private string ExtractPoster(HtmlNode node) + { + var img = node.SelectSingleNode(".//img"); + if (img == null) + return string.Empty; + + string src = img.GetAttributeValue("src", ""); + if (string.IsNullOrEmpty(src)) + src = img.GetAttributeValue("data-src", ""); + + return NormalizeUrl(src); + } + + private static string CleanText(string value) + { + if (string.IsNullOrEmpty(value)) + return string.Empty; + + return HtmlEntity.DeEntitize(value).Trim(); + } + + private static int? ExtractEpisodeNumber(string title) + { + if (string.IsNullOrEmpty(title)) + return null; + + var match = Regex.Match(title, @"(\d+)"); + if (match.Success && int.TryParse(match.Groups[1].Value, out int number)) + return number; + + return null; + } + + public static TimeSpan cacheTime(int multiaccess, int home = 5, int mikrotik = 2, OnlinesSettings init = null, int rhub = -1) + { + if (init != null && init.rhub && rhub != -1) + return TimeSpan.FromMinutes(rhub); + + int ctime = AppInit.conf.mikrotik ? mikrotik : AppInit.conf.multiaccess ? init != null && init.cache_time > 0 ? init.cache_time : multiaccess : home; + if (ctime > multiaccess) + ctime = multiaccess; + + return TimeSpan.FromMinutes(ctime); + } + + public static int? TryParseEpisodeNumber(string title) + { + return ExtractEpisodeNumber(title); + } + } +} diff --git a/UAKino/manifest.json b/UAKino/manifest.json new file mode 100644 index 0000000..ec31836 --- /dev/null +++ b/UAKino/manifest.json @@ -0,0 +1,6 @@ +{ + "enable": true, + "version": 3, + "initspace": "UAKino.ModInit", + "online": "UAKino.OnlineApi" +} \ No newline at end of file