Add API

API/Schema/Jobs/DownloadNewChaptersJob.cs

@@ -0,0 +1,21 @@
+using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations.Schema;
+using API.Schema.MangaConnectors;
+using Newtonsoft.Json;
+
+namespace API.Schema.Jobs;
+
+public class DownloadNewChaptersJob(ulong recurrenceMs, string mangaId, string? parentJobId = null, string[]? dependsOnJobIds = null)
+    : Job(TokenGen.CreateToken(typeof(DownloadNewChaptersJob), 64), JobType.DownloadNewChaptersJob, recurrenceMs, parentJobId, dependsOnJobIds)
+{
+    [MaxLength(64)]
+    public string MangaId { get; init; } = mangaId;
+    public virtual Manga Manga { get; init; }
+    
+    public override IEnumerable<Job> Run()
+    {
+        MangaConnector connector = Manga.MangaConnector;
+        Chapter[] newChapters = connector.GetNewChapters(Manga);
+        return newChapters.Select(chapter => new DownloadSingleChapterJob(chapter.ChapterId, this.JobId));
+    }
+}

API/Schema/Jobs/DownloadSingleChapterJob.cs

@@ -0,0 +1,139 @@
+using System.ComponentModel.DataAnnotations;
+using System.IO.Compression;
+using System.Runtime.InteropServices;
+using API.MangaDownloadClients;
+using API.Schema.MangaConnectors;
+using SixLabors.ImageSharp;
+using SixLabors.ImageSharp.Formats.Jpeg;
+using SixLabors.ImageSharp.Processing;
+using SixLabors.ImageSharp.Processing.Processors.Binarization;
+using static System.IO.UnixFileMode;
+
+namespace API.Schema.Jobs;
+
+public class DownloadSingleChapterJob(string chapterId, string? parentJobId = null, string[]? dependsOnJobIds = null)
+    : Job(TokenGen.CreateToken(typeof(DownloadSingleChapterJob), 64), JobType.DownloadSingleChapterJob, 0, parentJobId, dependsOnJobIds)
+{
+    [MaxLength(64)]
+    public string ChapterId { get; init; } = chapterId;
+    public virtual Chapter Chapter { get; init; }
+    
+    public override IEnumerable<Job> Run()
+    {
+        MangaConnector connector = Chapter.ParentManga.MangaConnector;
+        DownloadChapterImages(Chapter);
+        return [];
+    }
+    
+    private bool DownloadChapterImages(Chapter chapter)
+    {
+        MangaConnector connector = Chapter.ParentManga.MangaConnector;
+        string[] imageUrls = connector.GetChapterImageUrls(Chapter);
+        string saveArchiveFilePath = chapter.GetArchiveFilePath();
+        
+        //Check if Publication Directory already exists
+        string directoryPath = Path.GetDirectoryName(saveArchiveFilePath)!;
+        if (!Directory.Exists(directoryPath))
+            if (RuntimeInformation.IsOSPlatform(OSPlatform.Linux))
+                Directory.CreateDirectory(directoryPath,
+                    UserRead | UserWrite | UserExecute | GroupRead | GroupWrite | GroupExecute );
+            else
+                Directory.CreateDirectory(directoryPath);
+
+        if (File.Exists(saveArchiveFilePath)) //Don't download twice. Redownload
+            File.Delete(saveArchiveFilePath);
+        
+        //Create a temporary folder to store images
+        string tempFolder = Directory.CreateTempSubdirectory("trangatemp").FullName;
+
+        int chapterNum = 0;
+        //Download all Images to temporary Folder
+        if (imageUrls.Length == 0)
+        {
+            if (RuntimeInformation.IsOSPlatform(OSPlatform.Linux))
+                File.SetUnixFileMode(saveArchiveFilePath, UserRead | UserWrite | UserExecute | GroupRead | GroupWrite | GroupExecute);
+            Directory.Delete(tempFolder, true);
+            return false;
+        }
+        
+        foreach (string imageUrl in imageUrls)
+        {
+            string extension = imageUrl.Split('.')[^1].Split('?')[0];
+            string imagePath = Path.Join(tempFolder, $"{chapterNum++}.{extension}");
+            bool status = DownloadImage(imageUrl, imagePath);
+            if (status is false)
+                return false;
+        }
+
+        CopyCoverFromCacheToDownloadLocation();
+        
+        File.WriteAllText(Path.Join(tempFolder, "ComicInfo.xml"), chapter.GetComicInfoXmlString());
+        
+        //ZIP-it and ship-it
+        ZipFile.CreateFromDirectory(tempFolder, saveArchiveFilePath);
+        if (RuntimeInformation.IsOSPlatform(OSPlatform.Linux))
+            File.SetUnixFileMode(saveArchiveFilePath, UserRead | UserWrite | UserExecute | GroupRead | GroupWrite | GroupExecute | OtherRead | OtherExecute);
+        Directory.Delete(tempFolder, true); //Cleanup
+        
+        return true;
+    }
+    
+    private void ProcessImage(string imagePath)
+    {
+        if (!TrangaSettings.bwImages && TrangaSettings.compression == 100)
+            return;
+        DateTime start = DateTime.Now;
+        using Image image = Image.Load(imagePath);
+        File.Delete(imagePath);
+        if(TrangaSettings.bwImages) 
+            image.Mutate(i => i.ApplyProcessor(new AdaptiveThresholdProcessor()));
+        image.SaveAsJpeg(imagePath, new JpegEncoder()
+        {
+            Quality = TrangaSettings.compression
+        });
+    }
+    
+    private void CopyCoverFromCacheToDownloadLocation(int? retries = 1)
+    {
+        //Check if Publication already has a Folder and cover
+        string publicationFolder = Chapter.ParentManga.CreatePublicationFolder();
+        DirectoryInfo dirInfo = new (publicationFolder);
+        if (dirInfo.EnumerateFiles().Any(info => info.Name.Contains("cover", StringComparison.InvariantCultureIgnoreCase)))
+        {
+            return;
+        }
+
+        string? fileInCache = Chapter.ParentManga.CoverFileNameInCache;
+        if (fileInCache is null || !File.Exists(fileInCache))
+        {
+            if (retries > 0 && Chapter.ParentManga.CoverUrl is not null)
+            {
+                Chapter.ParentManga.SaveCoverImageToCache();
+                CopyCoverFromCacheToDownloadLocation(--retries);
+            }
+
+            return;
+        }
+        string newFilePath = Path.Join(publicationFolder, $"cover.{Path.GetFileName(fileInCache).Split('.')[^1]}" );
+        File.Copy(fileInCache, newFilePath, true);
+        if(RuntimeInformation.IsOSPlatform(OSPlatform.Linux))
+            File.SetUnixFileMode(newFilePath, GroupRead | GroupWrite | UserRead | UserWrite);
+    }
+    
+    private bool DownloadImage(string imageUrl, string savePath)
+    {
+        HttpDownloadClient downloadClient = new();
+        RequestResult requestResult = downloadClient.MakeRequest(imageUrl, RequestType.MangaImage);
+        
+        if ((int)requestResult.statusCode < 200 || (int)requestResult.statusCode >= 300)
+            return false;
+        if (requestResult.result == Stream.Null)
+            return false;
+
+        FileStream fs = new (savePath, FileMode.Create);
+        requestResult.result.CopyTo(fs);
+        fs.Close();
+        ProcessImage(savePath);
+        return true;
+    }
+}

API/Schema/Jobs/Job.cs

@@ -0,0 +1,40 @@
+using System.ComponentModel.DataAnnotations;
+using System.ComponentModel.DataAnnotations.Schema;
+using Microsoft.EntityFrameworkCore;
+using Newtonsoft.Json;
+
+namespace API.Schema.Jobs;
+
+[PrimaryKey("JobId")]
+public abstract class Job : APISerializable
+{
+    [MaxLength(64)]
+    public string JobId { get; init; }
+    
+    [MaxLength(64)]
+    public string? ParentJobId { get; internal set; }
+    internal virtual Job ParentJob { get; }
+    
+    [MaxLength(64)]
+    public string[]? DependsOnJobIds { get; init; }
+    public virtual Job[] DependsOnJobs { get; init; }
+    
+    public JobType JobType { get; init; }
+    public ulong RecurrenceMs { get; set; }
+    public DateTime LastExecution { get; internal set; } = DateTime.UnixEpoch;
+    public DateTime NextExecution { get; internal set; } 
+    public JobState state { get; internal set; } = JobState.Waiting;
+
+    public Job(string jobId, JobType jobType, ulong recurrenceMs, string? parentJobId = null,
+        string[]? dependsOnJobIds = null)
+    {
+        JobId = jobId;
+        ParentJobId = parentJobId;
+        DependsOnJobIds = dependsOnJobIds;
+        JobType = jobType;
+        RecurrenceMs = recurrenceMs;
+        NextExecution = LastExecution.AddMilliseconds(RecurrenceMs);
+    }
+
+    public abstract IEnumerable<Job> Run();
+}

API/Schema/Jobs/JobJsonDeserializer.cs

@@ -0,0 +1,29 @@
+using Newtonsoft.Json;
+using Newtonsoft.Json.Linq;
+using JsonSerializer = Newtonsoft.Json.JsonSerializer;
+
+namespace API.Schema.Jobs;
+
+public class JobJsonDeserializer : JsonConverter<Job>
+{
+    public override bool CanWrite { get; } = false;
+
+    public override void WriteJson(JsonWriter writer, Job? value, JsonSerializer serializer)
+    {
+        throw new NotImplementedException();
+    }
+
+    public override Job? ReadJson(JsonReader reader, Type objectType, Job? existingValue, bool hasExistingValue, JsonSerializer serializer)
+    {
+        JObject j = JObject.Load(reader);
+        JobType? type = Enum.Parse<JobType>(j.GetValue("jobType")!.Value<string>()!);
+        return type switch
+        {
+            JobType.DownloadSingleChapterJob => j.ToObject<DownloadSingleChapterJob>(),
+            JobType.DownloadNewChaptersJob => j.ToObject<DownloadNewChaptersJob>(), 
+            JobType.UpdateMetaDataJob => j.ToObject<UpdateMetadataJob>(),
+            JobType.MoveFileOrFolderJob => j.ToObject<MoveFileOrFolderJob>(),
+            _ => null
+        };
+    }
+}

API/Schema/Jobs/JobState.cs

@@ -0,0 +1,8 @@
+namespace API.Schema.Jobs;
+
+public enum JobState
+{
+    Waiting,
+    Running,
+    Completed
+}

API/Schema/Jobs/JobType.cs

@@ -0,0 +1,10 @@
+namespace API.Schema.Jobs;
+
+
+public enum JobType : byte
+{
+    DownloadSingleChapterJob = 0, 
+    DownloadNewChaptersJob = 1, 
+    UpdateMetaDataJob = 2,
+    MoveFileOrFolderJob = 3
+}

API/Schema/Jobs/MoveFileOrFolderJob.cs

@@ -0,0 +1,13 @@
+namespace API.Schema.Jobs;
+
+public class MoveFileOrFolderJob(string fromLocation, string toLocation, string? parentJobId = null, string[]? dependsOnJobIds = null)
+    : Job(TokenGen.CreateToken(typeof(MoveFileOrFolderJob), 64), JobType.MoveFileOrFolderJob, 0, parentJobId, dependsOnJobIds)
+{
+    public string FromLocation { get; init; } = fromLocation;
+    public string ToLocation { get; init; } = toLocation;
+    
+    public override IEnumerable<Job> Run()
+    {
+        throw new NotImplementedException();
+    }
+}

API/Schema/Jobs/UpdateMetadataJob.cs

@@ -0,0 +1,16 @@
+using System.ComponentModel.DataAnnotations;
+
+namespace API.Schema.Jobs;
+
+public class UpdateMetadataJob(ulong recurrenceMs, string mangaId, string? parentJobId = null, string[]? dependsOnJobIds = null)
+    : Job(TokenGen.CreateToken(typeof(UpdateMetadataJob), 64), JobType.UpdateMetaDataJob, recurrenceMs, parentJobId, dependsOnJobIds)
+{
+    [MaxLength(64)]
+    public string MangaId { get; init; } = mangaId;
+    public virtual Manga Manga { get; init; }
+    
+    public override IEnumerable<Job> Run()
+    {
+        throw new NotImplementedException();
+    }
+}