using System; using System.Collections.Generic; using System.Linq; using System.Net.Http; using System.Text.Json; using System.Text.Json.Nodes; using System.Text.RegularExpressions; using System.Threading.Tasks; using Microsoft.Extensions.Logging; namespace Jellyfin.Plugin.JCoverXtremePro; public class MediuxDownloader { public static MediuxDownloader instance; private Regex contentRegex = new(@"]*>self\.__next_f\.push(.*?)"); private readonly HttpClient httpClientFactory; private string sentinel = "date"; public MediuxDownloader(IHttpClientFactory httpClientFactory) { this.httpClientFactory = httpClientFactory.CreateClient("MediuxDownloader"); } private List ExtractJsonNodes(string httpText) { List list = new(); foreach (Match match in contentRegex.Matches(httpText)) { var pushArg = match.Groups[1].Value; var strippedString = StripPushArg(pushArg); if (!strippedString.Contains(sentinel)) { Plugin.Logger.LogTrace("Ignoring chunk without sentinel {Sentinel}: {Chunk}", sentinel, strippedString); continue; } list.Add(ParseStrippedJsonChunk(strippedString)); } if (list.Count != 1) { Plugin.Logger.LogError("Found too many or too few chunks: {0}", list); } return list; } private JsonNode ParseStrippedJsonChunk(string text) { return JsonSerializer.Deserialize(text.Substring(text.IndexOf(':') + 1))[3]; } private string StripPushArg(string text) { var stringStart = text.IndexOf('"'); var stringEnd = text.LastIndexOf('"'); if (stringStart == stringEnd || stringStart == -1) { return ""; } // TODO: 1 is regular data, 3 is base64 partial data return JsonSerializer.Deserialize(text.Substring(stringStart, stringEnd + 1 - stringStart)) ?? ""; } private async Task GetString(string url) { return await (await httpClientFactory.GetAsync(url).ConfigureAwait(false)) .Content.ReadAsStringAsync().ConfigureAwait(false); } public async Task GetMediuxMetadata(string url) { Plugin.Logger.LogInformation("Loading data from {Url}", url); var text = await GetString(url).ConfigureAwait(false); return ExtractJsonNodes(text).First(); } public async Task DownloadFile(string url) { return await httpClientFactory.GetAsync(url).ConfigureAwait(false); } }