Wrote my own Http-Server.

ASP-NET can **** my **** and *** :)

API/API.csproj

@@ -0,0 +1,21 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+    <PropertyGroup>
+        <OutputType>Exe</OutputType>
+        <TargetFramework>net7.0</TargetFramework>
+        <ImplicitUsings>enable</ImplicitUsings>
+        <Nullable>enable</Nullable>
+        <DockerDefaultTargetOS>Linux</DockerDefaultTargetOS>
+    </PropertyGroup>
+
+    <ItemGroup>
+      <Content Include="..\.dockerignore">
+        <Link>.dockerignore</Link>
+      </Content>
+    </ItemGroup>
+
+    <ItemGroup>
+      <ProjectReference Include="..\Tranga\Tranga.csproj" />
+    </ItemGroup>
+
+</Project>

API/Dockerfile

@@ -0,0 +1,13 @@
+# syntax=docker/dockerfile:1
+
+FROM mcr.microsoft.com/dotnet/sdk:7.0 as build-env
+WORKDIR /src
+COPY . /src/
+RUN dotnet restore API/API.csproj
+RUN dotnet publish -c Release -o /publish
+
+FROM glax/tranga-base:dev as runtime
+WORKDIR /publish
+COPY --from=build-env /publish .
+EXPOSE 6531
+ENTRYPOINT ["dotnet", "/publish/API.dll"]

API/Program.cs

@@ -0,0 +1,46 @@
+using System.Runtime.InteropServices;
+using Logging;
+using Tranga;
+
+namespace API;
+
+public class Program
+{
+    public static void Main(string[] args)
+    {
+        string applicationFolderPath = Path.Join(Environment.GetFolderPath(Environment.SpecialFolder.CommonApplicationData), "Tranga-API");
+        string downloadFolderPath = RuntimeInformation.IsOSPlatform(OSPlatform.Linux) ? "/Manga" : Path.Join(applicationFolderPath, "Manga");
+        string logsFolderPath = RuntimeInformation.IsOSPlatform(OSPlatform.Linux) ? "/var/logs/Tranga" : Path.Join(applicationFolderPath, "logs");
+        string logFilePath = Path.Join(logsFolderPath, $"log-{DateTime.Now:dd-M-yyyy-HH-mm-ss}.txt");
+        string settingsFilePath = Path.Join(applicationFolderPath, "settings.json");
+
+        Directory.CreateDirectory(logsFolderPath);
+        Logger logger = new(new[] { Logger.LoggerType.FileLogger, Logger.LoggerType.ConsoleLogger }, Console.Out, Console.Out.Encoding, logFilePath);
+
+        logger.WriteLine("Tranga", "Loading settings.");
+
+        TrangaSettings settings;
+        if (File.Exists(settingsFilePath))
+            settings = TrangaSettings.LoadSettings(settingsFilePath, logger);
+        else
+            settings = new TrangaSettings(downloadFolderPath, applicationFolderPath, new HashSet<LibraryManager>(), new HashSet<NotificationManager>());
+
+        Directory.CreateDirectory(settings.workingDirectory);
+        Directory.CreateDirectory(settings.downloadLocation);
+        Directory.CreateDirectory(settings.coverImageCache);
+
+        logger.WriteLine("Tranga",$"Application-Folder: {settings.workingDirectory}");
+        logger.WriteLine("Tranga",$"Settings-File-Path: {settings.settingsFilePath}");
+        logger.WriteLine("Tranga",$"Download-Folder-Path: {settings.downloadLocation}");
+        logger.WriteLine("Tranga",$"Logfile-Path: {logFilePath}");
+        logger.WriteLine("Tranga",$"Image-Cache-Path: {settings.coverImageCache}");
+
+        logger.WriteLine("Tranga", "Loading Taskmanager.");
+        TaskManager taskManager = new (settings, logger);
+        
+        Server server = new (6531, taskManager, logger);
+        foreach(NotificationManager nm in taskManager.settings.notificationManagers)
+            nm.SendNotification("Tranga-API", "Started Tranga-API");
+    }
+}
+

API/RequestHandler.cs

@@ -0,0 +1,361 @@
+using System.Net;
+using System.Text.RegularExpressions;
+using Tranga;
+using Tranga.TrangaTasks;
+
+namespace API;
+
+public class RequestHandler
+{
+    private TaskManager _taskManager;
+    private Server _parent;
+
+    private List<ValueTuple<HttpMethod, string, string[]>> _validRequestPaths = new()
+    {
+        new(HttpMethod.Get, "/", Array.Empty<string>()),
+        new(HttpMethod.Get, "/Connectors", Array.Empty<string>()),
+        new(HttpMethod.Get, "/Publications/Known", new[] { "internalId?" }),
+        new(HttpMethod.Get, "/Publications/FromConnector", new[] { "connectorName", "title" }),
+        new(HttpMethod.Get, "/Publications/Chapters",
+            new[] { "connectorName", "internalId", "onlyNew?", "onlyExisting?", "language?" }),
+        new(HttpMethod.Get, "/Tasks/Types", Array.Empty<string>()),
+        new(HttpMethod.Post, "/Tasks/CreateMonitorTask",
+            new[] { "connectorName", "internalId", "reoccurrenceTime", "language?" }),
+        new(HttpMethod.Post, "/Tasks/CreateUpdateLibraryTask", new[] { "reoccurrenceTime" }),
+        new(HttpMethod.Post, "/Tasks/CreateDownloadChaptersTask",
+            new[] { "connectorName", "internalId", "chapters", "language?" }),
+        new(HttpMethod.Get, "/Tasks", new[] { "taskType", "connectorName?", "publicationId?" }),
+        new(HttpMethod.Delete, "/Tasks", new[] { "taskType", "connectorName?", "searchString?" }),
+        new(HttpMethod.Get, "/Tasks/Progress",
+            new[] { "taskType", "connectorName", "publicationId", "chapterSortNumber?" }),
+        new(HttpMethod.Post, "/Tasks/Start", new[] { "taskType", "connectorName?", "internalId?" }),
+        new(HttpMethod.Get, "/Tasks/RunningTasks", Array.Empty<string>()),
+        new(HttpMethod.Get, "/Queue/List", Array.Empty<string>()),
+        new(HttpMethod.Post, "/Queue/Enqueue", new[] { "taskType", "connectorName?", "publicationId?" }),
+        new(HttpMethod.Delete, "/Queue/Dequeue", new[] { "taskType", "connectorName?", "publicationId?" }),
+        new(HttpMethod.Get, "/Settings", Array.Empty<string>()),
+        new(HttpMethod.Post, "/Settings/Update", new[]
+        {
+            "downloadLocation?", "komgaUrl?", "komgaAuth?", "kavitaUrl?", "kavitaUsername?",
+            "kavitaPassword?", "gotifyUrl?", "gotifyAppToken?", "lunaseaWebhook?"
+        })
+    };
+
+    public RequestHandler(TaskManager taskManager, Server parent)
+    {
+        this._taskManager = taskManager;
+        this._parent = parent;
+    }
+
+    internal void HandleRequest(HttpListenerRequest request, HttpListenerResponse response)
+    {
+        string requestPath = request.Url!.LocalPath;
+        if (requestPath.Contains("favicon"))
+        {
+            _parent.SendResponse(HttpStatusCode.NoContent, response);
+            return;
+        }
+        if (!this._validRequestPaths.Any(path => path.Item1.Method == request.HttpMethod && path.Item2 == requestPath))
+        {
+            _parent.SendResponse(HttpStatusCode.BadRequest, response);
+            return;
+        }
+        Dictionary<string, string> variables = GetRequestVariables(request.Url!.Query);
+        object? responseObject = null;
+        switch (request.HttpMethod)
+        {
+            case "GET":
+                responseObject = this.HandleGet(requestPath, variables);
+                break;
+            case "POST":
+                this.HandlePost(requestPath, variables);
+                break;
+            case "DELETE":
+                this.HandleDelete(requestPath, variables);
+                break;
+        }
+        _parent.SendResponse(HttpStatusCode.OK, response, responseObject);
+    }
+
+    private Dictionary<string, string> GetRequestVariables(string query)
+    {
+        Dictionary<string, string> ret = new();
+        Regex queryRex = new (@"\?{1}([A-z]+=[A-z]+)+(&[A-z]+=[A-z]+)*");
+        if (!queryRex.IsMatch(query))
+            return ret;
+        query = query.Substring(1);
+        foreach(string kvpair in query.Split('&'))
+            ret.Add(kvpair.Split('=')[0], kvpair.Split('=')[1]);
+        return ret;
+    }
+
+    private void HandleDelete(string requestPath, Dictionary<string, string> variables)
+    {
+        switch (requestPath)
+        {
+            case "/Tasks":
+                variables.TryGetValue("taskType", out string? taskType1);
+                variables.TryGetValue("connectorName", out string? connectorName1);
+                variables.TryGetValue("publicationId", out string? publicationId1);
+                if(taskType1 is null)
+                    return;
+
+                try
+                {
+                    TrangaTask.Task task = Enum.Parse<TrangaTask.Task>(taskType1);
+                    foreach(TrangaTask tTask in _taskManager.GetTasksMatching(task, connectorName1, internalId: publicationId1))
+                        _taskManager.DeleteTask(tTask);
+                }
+                catch (ArgumentException)
+                {
+                    return;
+                }
+                break;
+            case "/Queue/Dequeue":
+                variables.TryGetValue("taskType", out string? taskType2);
+                variables.TryGetValue("connectorName", out string? connectorName2);
+                variables.TryGetValue("publicationId", out string? publicationId2);
+                if(taskType2 is null)
+                    return;
+                
+                try
+                {
+                    TrangaTask.Task pTask = Enum.Parse<TrangaTask.Task>(taskType2);
+                    TrangaTask? task = _taskManager
+                        .GetTasksMatching(pTask, connectorName: connectorName2, internalId: publicationId2).FirstOrDefault();
+            
+                    if (task is null)
+                        return;
+                    _taskManager.RemoveTaskFromQueue(task);
+                }
+                catch (ArgumentException)
+                {
+                    return;
+                }
+                break;
+        }
+    }
+
+    private void HandlePost(string requestPath, Dictionary<string, string> variables)
+    {
+        switch (requestPath)
+        {
+                
+            case "/Tasks/CreateMonitorTask":
+                variables.TryGetValue("connectorName", out string? connectorName1);
+                variables.TryGetValue("internalId", out string? internalId1);
+                variables.TryGetValue("reoccurrenceTime", out string? reoccurrenceTime1);
+                variables.TryGetValue("language", out string? language1);
+                if (connectorName1 is null || internalId1 is null || reoccurrenceTime1 is null)
+                    return;
+                Connector? connector1 =
+                    _taskManager.GetAvailableConnectors().FirstOrDefault(con => con.Key == connectorName1).Value;
+                if (connector1 is null)
+                    return;
+                Publication? publication1 = _taskManager.GetAllPublications().FirstOrDefault(pub => pub.internalId == internalId1);
+                if (publication1 is null)
+                    return;
+                _taskManager.AddTask(new MonitorPublicationTask(connectorName1, (Publication)publication1, TimeSpan.Parse(reoccurrenceTime1), language1 ?? "en"));
+                break;
+            case "/Tasks/CreateUpdateLibraryTask":
+                variables.TryGetValue("reoccurrenceTime", out string? reoccurrenceTime2);
+                if (reoccurrenceTime2 is null)
+                    return;
+                _taskManager.AddTask(new UpdateLibrariesTask(TimeSpan.Parse(reoccurrenceTime2)));
+                break;
+            case "/Tasks/CreateDownloadChaptersTask":
+                variables.TryGetValue("connectorName", out string? connectorName2);
+                variables.TryGetValue("internalId", out string? internalId2);
+                variables.TryGetValue("chapters", out string? chapters);
+                variables.TryGetValue("language", out string? language2);
+                if (connectorName2 is null || internalId2 is null || chapters is null)
+                    return;
+                Connector? connector2 =
+                    _taskManager.GetAvailableConnectors().FirstOrDefault(con => con.Key == connectorName2).Value;
+                if (connector2 is null)
+                    return;
+                Publication? publication2 = _taskManager.GetAllPublications().FirstOrDefault(pub => pub.internalId == internalId2);
+                if (publication2 is null)
+                    return;
+    
+                IEnumerable<Chapter> toDownload = connector2.SearchChapters((Publication)publication2, chapters, language2 ?? "en");
+                foreach(Chapter chapter in toDownload)
+                    _taskManager.AddTask(new DownloadChapterTask(connectorName2, (Publication)publication2, chapter, "en"));
+                break;
+            case "/Tasks/Start":
+                variables.TryGetValue("taskType", out string? taskType1);
+                variables.TryGetValue("connectorName", out string? connectorName3);
+                variables.TryGetValue("internalId", out string? internalId3);
+                if (taskType1 is null)
+                    return;
+                try
+                {
+                    TrangaTask.Task pTask = Enum.Parse<TrangaTask.Task>(taskType1);
+                    TrangaTask? task = _taskManager
+                        .GetTasksMatching(pTask, connectorName: connectorName3, internalId: internalId3).FirstOrDefault();
+            
+                    if (task is null)
+                        return;
+                    _taskManager.ExecuteTaskNow(task);
+                }
+                catch (ArgumentException)
+                {
+                    return;
+                }
+                break;
+            case "/Queue/Enqueue":
+                variables.TryGetValue("taskType", out string? taskType2);
+                variables.TryGetValue("connectorName", out string? connectorName4);
+                variables.TryGetValue("publicationId", out string? publicationId);
+                if (taskType2 is null)
+                    return;
+                try
+                {
+                    TrangaTask.Task pTask = Enum.Parse<TrangaTask.Task>(taskType2);
+                    TrangaTask? task = _taskManager
+                        .GetTasksMatching(pTask, connectorName: connectorName4, internalId: publicationId).FirstOrDefault();
+            
+                    if (task is null)
+                        return;
+                    _taskManager.AddTaskToQueue(task);
+                }
+                catch (ArgumentException)
+                {
+                    return;
+                }
+                break;
+            case "/Settings/Update":
+                variables.TryGetValue("downloadLocation", out string? downloadLocation);
+                variables.TryGetValue("komgaUrl", out string? komgaUrl);
+                variables.TryGetValue("komgaAuth", out string? komgaAuth);
+                variables.TryGetValue("kavitaUrl", out string? kavitaUrl);
+                variables.TryGetValue("kavitaUsername", out string? kavitaUsername);
+                variables.TryGetValue("kavitaPassword", out string? kavitaPassword);
+                variables.TryGetValue("gotifyUrl", out string? gotifyUrl);
+                variables.TryGetValue("gotifyAppToken", out string? gotifyAppToken);
+                variables.TryGetValue("lunaseaWebhook", out string? lunaseaWebhook);
+                
+                if (downloadLocation is not null && downloadLocation.Length > 0)
+                    _taskManager.settings.UpdateSettings(TrangaSettings.UpdateField.DownloadLocation, _parent.logger, downloadLocation);
+                if (komgaUrl is not null && komgaAuth is not null && komgaUrl.Length > 5 && komgaAuth.Length > 0)
+                    _taskManager.settings.UpdateSettings(TrangaSettings.UpdateField.Komga, _parent.logger, komgaUrl, komgaAuth);
+                if (kavitaUrl is not null && kavitaPassword is not null && kavitaUsername is not null && kavitaUrl.Length > 5 &&
+                    kavitaUsername.Length > 0 && kavitaPassword.Length > 0)
+                    _taskManager.settings.UpdateSettings(TrangaSettings.UpdateField.Kavita, _parent.logger, kavitaUrl, kavitaUsername,
+                        kavitaPassword);
+                if (gotifyUrl is not null && gotifyAppToken is not null && gotifyUrl.Length > 5 && gotifyAppToken.Length > 0)
+                    _taskManager.settings.UpdateSettings(TrangaSettings.UpdateField.Gotify, _parent.logger, gotifyUrl, gotifyAppToken);
+                if(lunaseaWebhook is not null && lunaseaWebhook.Length > 5)
+                    _taskManager.settings.UpdateSettings(TrangaSettings.UpdateField.LunaSea, _parent.logger, lunaseaWebhook);
+                break;
+        }
+    }
+
+    private object? HandleGet(string requestPath, Dictionary<string, string> variables)
+    {
+        switch (requestPath)
+        {
+            case "/Connectors":
+                return this._taskManager.GetAvailableConnectors().Keys.ToArray();
+            case "/Publications/Known":
+                variables.TryGetValue("internalId", out string? internalId1);
+                if(internalId1 is null)
+                    return _taskManager.GetAllPublications();
+                return new [] { _taskManager.GetAllPublications().FirstOrDefault(pub => pub.internalId == internalId1) };
+            case "/Publications/FromConnector":
+                variables.TryGetValue("connectorName", out string? connectorName1);
+                variables.TryGetValue("title", out string? title);
+                if (connectorName1 is null || title is null)
+                    return null;
+                Connector? connector1 = _taskManager.GetAvailableConnectors().FirstOrDefault(con => con.Key == connectorName1).Value;
+                if (connector1 is null)
+                    return null;
+                if(title.Length < 4)
+                    return null;
+                return _taskManager.GetPublicationsFromConnector(connector1, title);
+            case "/Publications/Chapters":
+                string[] yes = { "true", "yes", "1", "y" };
+                variables.TryGetValue("connectorName", out string? connectorName2);
+                variables.TryGetValue("internalId", out string? internalId2);
+                variables.TryGetValue("onlyNew", out string? onlyNew);
+                variables.TryGetValue("onlyExisting", out string? onlyExisting);
+                variables.TryGetValue("language", out string? language);
+                if (connectorName2 is null || internalId2 is null)
+                    return null;
+                bool newOnly = onlyNew is not null && yes.Contains(onlyNew);
+                bool existingOnly = onlyExisting is not null && yes.Contains(onlyExisting);
+        
+                Connector? connector2 = _taskManager.GetAvailableConnectors().FirstOrDefault(con => con.Key == connectorName2).Value;
+                if (connector2 is null)
+                    return null;
+                Publication? publication = _taskManager.GetAllPublications().FirstOrDefault(pub => pub.internalId == internalId2);
+                if (publication is null)
+                    return null;
+        
+                if(newOnly)
+                    return _taskManager.GetNewChaptersList(connector2, (Publication)publication, language??"en").ToArray();
+                else if (existingOnly)
+                    return _taskManager.GetExistingChaptersList(connector2, (Publication)publication, language ?? "en").ToArray();
+                else
+                    return connector2.GetChapters((Publication)publication, language??"en");
+            case "/Tasks/Types":
+                return Enum.GetNames(typeof(TrangaTask.Task));
+            case "/Tasks":
+                variables.TryGetValue("taskType", out string? taskType1);
+                variables.TryGetValue("connectorName", out string? connectorName3);
+                variables.TryGetValue("searchString", out string? searchString);
+                if (taskType1 is null)
+                    return null;
+                try
+                {
+                    TrangaTask.Task task = Enum.Parse<TrangaTask.Task>(taskType1);
+                    return _taskManager.GetTasksMatching(task, connectorName:connectorName3, searchString:searchString);
+                }
+                catch (ArgumentException)
+                {
+                    return null;
+                }
+            case "/Tasks/Progress":
+                variables.TryGetValue("taskType", out string? taskType2);
+                variables.TryGetValue("connectorName", out string? connectorName4);
+                variables.TryGetValue("publicationId", out string? publicationId);
+                variables.TryGetValue("chapterSortNumber", out string? chapterSortNumber);
+                if (taskType2 is null || connectorName4 is null || publicationId is null)
+                    return null;
+                Connector? connector =
+                    _taskManager.GetAvailableConnectors().FirstOrDefault(con => con.Key == connectorName4).Value;
+                if (connector is null)
+                    return null;
+                try
+                {
+                    TrangaTask? task = null;
+                    TrangaTask.Task pTask = Enum.Parse<TrangaTask.Task>(taskType2);
+                    if (pTask is TrangaTask.Task.MonitorPublication)
+                    {
+                        task = _taskManager.GetTasksMatching(pTask, connectorName: connectorName4, internalId: publicationId).FirstOrDefault();
+                    }else if (pTask is TrangaTask.Task.DownloadChapter && chapterSortNumber is not null)
+                    {
+                        task = _taskManager.GetTasksMatching(pTask, connectorName: connectorName4, internalId: publicationId,
+                            chapterSortNumber: chapterSortNumber).FirstOrDefault();
+                    }
+                    if (task is null)
+                        return null;
+
+                    return task.progress;
+                }
+                catch (ArgumentException)
+                {
+                    return null;
+                }
+            case "/Tasks/RunningTasks":
+                return _taskManager.GetAllTasks().Where(task => task.state is TrangaTask.ExecutionState.Running);
+            case "/Queue/List":
+                return _taskManager.GetAllTasks().Where(task => task.state is TrangaTask.ExecutionState.Enqueued).OrderBy(task => task.nextExecution);
+            case "/Settings":
+                return _taskManager.settings;
+            case "/":
+            default:
+                return this._validRequestPaths;
+        }
+    }
+}

API/Server.cs

@@ -0,0 +1,72 @@
+using System.Net;
+using System.Text;
+using System.Text.RegularExpressions;
+using Logging;
+using Newtonsoft.Json;
+using Tranga;
+
+namespace API;
+
+public class Server
+{
+    private readonly HttpListener _listener = new ();
+    private readonly RequestHandler _requestHandler;
+    internal readonly Logger? logger;
+
+    private readonly Regex _validUrl =
+        new (@"https?:\/\/(www\.)?[-A-z0-9]{1,256}(\.[-a-zA-Z0-9]{1,6})?(:[0-9]{1,5})?(\/{1}[A-z0-9()@:%_\+.~#?&=]+)*\/?");
+    public Server(int port, TaskManager taskManager, Logger? logger = null)
+    {
+        this.logger = logger;
+        this._listener.Prefixes.Add($"http://*:{port}/");
+        this._requestHandler = new RequestHandler(taskManager, this);
+        Listen();
+    }
+
+    private void Listen()
+    {
+        this._listener.Start();
+        foreach (string prefix in this._listener.Prefixes)
+            this.logger?.WriteLine(this.GetType().ToString(), $"Listening on {prefix}");
+        while (this._listener.IsListening)
+        {
+            HttpListenerContext context = this._listener.GetContextAsync().Result;
+            Task t = new (() =>
+            {
+                HandleContext(context);
+            });
+            t.Start();
+        }
+    }
+
+    private void HandleContext(HttpListenerContext context)
+    {
+        HttpListenerRequest request = context.Request;
+        HttpListenerResponse response = context.Response;
+        //logger?.WriteLine(this.GetType().ToString(), $"New request: {request.HttpMethod} {request.Url}");
+
+        if (!_validUrl.IsMatch(request.Url!.ToString()))
+        {
+            SendResponse(HttpStatusCode.BadRequest, response);
+            return;
+        }
+        
+        _requestHandler.HandleRequest(request, response);
+    }
+
+    internal void SendResponse(HttpStatusCode statusCode, HttpListenerResponse response, object? content = null)
+    {
+        //logger?.WriteLine(this.GetType().ToString(), $"Sending response: {statusCode}");
+        response.StatusCode = (int)statusCode;
+        response.AddHeader("Access-Control-Allow-Headers", "Content-Type, Accept, X-Requested-With");
+        response.AddHeader("Access-Control-Allow-Methods", "GET, POST, DELETE");
+        response.AddHeader("Access-Control-Max-Age", "1728000");
+        response.AppendHeader("Access-Control-Allow-Origin", "*");
+        response.ContentType = "application/json";
+        response.OutputStream.Write(content is not null
+            ? Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(content))
+            : Array.Empty<byte>());
+        response.OutputStream.Close();
+        
+    }
+}