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(@"");
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);
}
}