using System.Globalization; using System.IO.Compression; using System.Net; using System.Runtime.InteropServices; using System.Text.RegularExpressions; using Tranga.TrangaTasks; using static System.IO.UnixFileMode; namespace Tranga.Connectors; /// /// Base-Class for all Connectors /// Provides some methods to be used by all Connectors, as well as a DownloadClient /// public abstract class Connector { protected TrangaSettings settings { get; } internal DownloadClient downloadClient { get; init; } = null!; protected Connector(TrangaSettings settings) { this.settings = settings; if (!Directory.Exists(settings.coverImageCache)) Directory.CreateDirectory(settings.coverImageCache); } public abstract string name { get; } //Name of the Connector (e.g. Website) public Publication[] GetPublications(ref HashSet publicationCollection, string publicationTitle = "") { Publication[] ret = GetPublicationsInternal(publicationTitle); foreach (Publication p in ret) publicationCollection.Add(p); return ret; } /// /// Returns all Publications with the given string. /// If the string is empty or null, returns all Publication of the Connector /// /// Search-Query /// Publications matching the query protected abstract Publication[] GetPublicationsInternal(string publicationTitle = ""); /// /// Returns all Chapters of the publication in the provided language. /// If the language is empty or null, returns all Chapters in all Languages. /// /// Publication to get Chapters for /// Language of the Chapters /// Array of Chapters matching Publication and Language public abstract Chapter[] GetChapters(Publication publication, string language = ""); /// /// Updates the available Chapters of a Publication /// /// Publication to check /// Language to receive chapters for /// /// List of Chapters that were previously not in collection public List GetNewChaptersList(Publication publication, string language, ref HashSet collection) { Chapter[] newChapters = this.GetChapters(publication, language); collection.Add(publication); NumberFormatInfo decimalPoint = new (){ NumberDecimalSeparator = "." }; settings.logger?.WriteLine(this.GetType().ToString(), "Checking for duplicates"); List newChaptersList = newChapters.Where(nChapter => float.Parse(nChapter.chapterNumber, decimalPoint) > publication.ignoreChaptersBelow && !nChapter.CheckChapterIsDownloaded(settings.downloadLocation)).ToList(); settings.logger?.WriteLine(this.GetType().ToString(), $"{newChaptersList.Count} new chapters."); return newChaptersList; } public Chapter[] SelectChapters(Publication publication, string searchTerm, string? language = null) { Chapter[] availableChapters = this.GetChapters(publication, language??"en"); Regex volumeRegex = new ("((v(ol)*(olume)*)+ *([0-9]+(-[0-9]+)?){1})", RegexOptions.IgnoreCase); Regex chapterRegex = new ("((c(h)*(hapter)*)+ *([0-9]+(-[0-9]+)?){1})", RegexOptions.IgnoreCase); Regex singleResultRegex = new("([0-9]+)", RegexOptions.IgnoreCase); Regex rangeResultRegex = new("([0-9]+(-[0-9]+))", RegexOptions.IgnoreCase); Regex allRegex = new("a(ll)?", RegexOptions.IgnoreCase); if (volumeRegex.IsMatch(searchTerm) && chapterRegex.IsMatch(searchTerm)) { string volume = singleResultRegex.Match(volumeRegex.Match(searchTerm).Value).Value; string chapter = singleResultRegex.Match(chapterRegex.Match(searchTerm).Value).Value; return availableChapters.Where(aCh => aCh.volumeNumber is not null && aCh.volumeNumber.Equals(volume, StringComparison.InvariantCultureIgnoreCase) && aCh.chapterNumber.Equals(chapter, StringComparison.InvariantCultureIgnoreCase)) .ToArray(); } else if (volumeRegex.IsMatch(searchTerm)) { string volume = volumeRegex.Match(searchTerm).Value; if (rangeResultRegex.IsMatch(volume)) { string range = rangeResultRegex.Match(volume).Value; int start = Convert.ToInt32(range.Split('-')[0]); int end = Convert.ToInt32(range.Split('-')[1]); return availableChapters.Where(aCh => aCh.volumeNumber is not null && Convert.ToInt32(aCh.volumeNumber) >= start && Convert.ToInt32(aCh.volumeNumber) <= end).ToArray(); } else if (singleResultRegex.IsMatch(volume)) { string volumeNumber = singleResultRegex.Match(volume).Value; return availableChapters.Where(aCh => aCh.volumeNumber is not null && aCh.volumeNumber.Equals(volumeNumber, StringComparison.InvariantCultureIgnoreCase)).ToArray(); } } else if (chapterRegex.IsMatch(searchTerm)) { string chapter = volumeRegex.Match(searchTerm).Value; if (rangeResultRegex.IsMatch(chapter)) { string range = rangeResultRegex.Match(chapter).Value; int start = Convert.ToInt32(range.Split('-')[0]); int end = Convert.ToInt32(range.Split('-')[1]); return availableChapters.Where(aCh => Convert.ToInt32(aCh.chapterNumber) >= start && Convert.ToInt32(aCh.chapterNumber) <= end).ToArray(); } else if (singleResultRegex.IsMatch(chapter)) { string chapterNumber = singleResultRegex.Match(chapter).Value; return availableChapters.Where(aCh => aCh.chapterNumber.Equals(chapterNumber, StringComparison.InvariantCultureIgnoreCase)).ToArray(); } } else { if (rangeResultRegex.IsMatch(searchTerm)) { int start = Convert.ToInt32(searchTerm.Split('-')[0]); int end = Convert.ToInt32(searchTerm.Split('-')[1]); return availableChapters[start..(end + 1)]; } else if(singleResultRegex.IsMatch(searchTerm)) return new [] { availableChapters[Convert.ToInt32(searchTerm)] }; else if (allRegex.IsMatch(searchTerm)) return availableChapters; } return Array.Empty(); } /// /// Retrieves the Chapter (+Images) from the website. /// Should later call DownloadChapterImages to retrieve the individual Images of the Chapter and create .cbz archive. /// /// Publication that contains Chapter /// Chapter with Images to retrieve /// Will be used for progress-tracking /// public abstract HttpStatusCode DownloadChapter(Publication publication, Chapter chapter, DownloadChapterTask parentTask, CancellationToken? cancellationToken = null); /// /// Copies the already downloaded cover from cache to downloadLocation /// /// Publication to retrieve Cover for /// TrangaSettings public void CopyCoverFromCacheToDownloadLocation(Publication publication, TrangaSettings settings) { settings.logger?.WriteLine(this.GetType().ToString(), $"Cloning cover {publication.sortName} -> {publication.internalId}"); //Check if Publication already has a Folder and cover string publicationFolder = publication.CreatePublicationFolder(settings.downloadLocation); DirectoryInfo dirInfo = new (publicationFolder); if (dirInfo.EnumerateFiles().Any(info => info.Name.Contains("cover", StringComparison.InvariantCultureIgnoreCase))) { settings.logger?.WriteLine(this.GetType().ToString(), $"Cover exists {publication.sortName}"); return; } string fileInCache = Path.Join(settings.coverImageCache, publication.coverFileNameInCache); string newFilePath = Path.Join(publicationFolder, $"cover.{Path.GetFileName(fileInCache).Split('.')[^1]}" ); settings.logger?.WriteLine(this.GetType().ToString(), $"Cloning cover {fileInCache} -> {newFilePath}"); File.Copy(fileInCache, newFilePath, true); if(RuntimeInformation.IsOSPlatform(OSPlatform.Linux)) File.SetUnixFileMode(newFilePath, GroupRead | GroupWrite | OtherRead | OtherWrite | UserRead | UserWrite); } /// /// Downloads Image from URL and saves it to the given path(incl. fileName) /// /// /// /// RequestType for Rate-Limit /// referrer used in html request header private HttpStatusCode DownloadImage(string imageUrl, string fullPath, byte requestType, string? referrer = null) { DownloadClient.RequestResult requestResult = downloadClient.MakeRequest(imageUrl, requestType, referrer); if ((int)requestResult.statusCode < 200 || (int)requestResult.statusCode >= 300 || requestResult.result == Stream.Null) return requestResult.statusCode; byte[] buffer = new byte[requestResult.result.Length]; requestResult.result.ReadExactly(buffer, 0, buffer.Length); File.WriteAllBytes(fullPath, buffer); return requestResult.statusCode; } /// /// Downloads all Images from URLs, Compresses to zip(cbz) and saves. /// /// List of URLs to download Images from /// Full path to save archive to (without file ending .cbz) /// Used for progress tracking /// Path of the generate Chapter ComicInfo.xml, if it was generated /// RequestType for RateLimits /// Used in http request header /// protected HttpStatusCode DownloadChapterImages(string[] imageUrls, string saveArchiveFilePath, byte requestType, DownloadChapterTask parentTask, string? comicInfoPath = null, string? referrer = null, CancellationToken? cancellationToken = null) { if (cancellationToken?.IsCancellationRequested ?? false) return HttpStatusCode.RequestTimeout; settings.logger?.WriteLine("Connector", $"Downloading Images for {saveArchiveFilePath}"); //Check if Publication Directory already exists string directoryPath = Path.GetDirectoryName(saveArchiveFilePath)!; if (!Directory.Exists(directoryPath)) Directory.CreateDirectory(directoryPath); if (File.Exists(saveArchiveFilePath)) //Don't download twice. return HttpStatusCode.OK; //Create a temporary folder to store images string tempFolder = Directory.CreateTempSubdirectory().FullName; int chapter = 0; //Download all Images to temporary Folder foreach (string imageUrl in imageUrls) { string[] split = imageUrl.Split('.'); string extension = split[^1]; settings.logger?.WriteLine("Connector", $"Downloading Image {chapter + 1:000}/{imageUrls.Length:000} {parentTask.publication.sortName} {parentTask.publication.internalId} Vol.{parentTask.chapter.volumeNumber} Ch.{parentTask.chapter.chapterNumber} {parentTask.progress:P2}"); HttpStatusCode status = DownloadImage(imageUrl, Path.Join(tempFolder, $"{chapter++}.{extension}"), requestType, referrer); if ((int)status < 200 || (int)status >= 300) return status; parentTask.IncrementProgress(1.0 / imageUrls.Length); if (cancellationToken?.IsCancellationRequested ?? false) return HttpStatusCode.RequestTimeout; } if(comicInfoPath is not null) File.Copy(comicInfoPath, Path.Join(tempFolder, "ComicInfo.xml")); settings.logger?.WriteLine("Connector", $"Creating archive {saveArchiveFilePath}"); //ZIP-it and ship-it ZipFile.CreateFromDirectory(tempFolder, saveArchiveFilePath); if(RuntimeInformation.IsOSPlatform(OSPlatform.Linux)) File.SetUnixFileMode(saveArchiveFilePath, GroupRead | GroupWrite | OtherRead | OtherWrite | UserRead | UserWrite); Directory.Delete(tempFolder, true); //Cleanup return HttpStatusCode.OK; } protected string SaveCoverImageToCache(string url, byte requestType) { string[] split = url.Split('/'); string filename = split[^1]; string saveImagePath = Path.Join(settings.coverImageCache, filename); if (File.Exists(saveImagePath)) return filename; DownloadClient.RequestResult coverResult = downloadClient.MakeRequest(url, requestType); using MemoryStream ms = new(); coverResult.result.CopyTo(ms); File.WriteAllBytes(saveImagePath, ms.ToArray()); settings.logger?.WriteLine(this.GetType().ToString(), $"Saving image to {saveImagePath}"); return filename; } }