Fixed bug for enqueued tasks constantly being triggered to execute

Added Logger to all relevant methods

Logging/FileLogger.cs

@@ -0,0 +1,19 @@
+using System.Text;
+using System.Text.Json.Serialization;
+
+namespace Logging;
+
+public class FileLogger : LoggerBase
+{
+    private string logFilePath { get; }
+
+    public FileLogger(string logFilePath, TextWriter? stdOut, Encoding? encoding = null) : base (stdOut, encoding)
+    {
+        this.logFilePath = logFilePath;
+    }
+    
+    protected override void Write(LogMessage logMessage)
+    {
+        File.AppendAllText(logFilePath, logMessage.ToString());
+    }
+}

Logging/FormattedConsoleLogger.cs

@@ -0,0 +1,17 @@
+using System.Text;
+
+namespace Logging;
+
+public class FormattedConsoleLogger : LoggerBase
+{
+    
+    public FormattedConsoleLogger(TextWriter? stdOut, Encoding? encoding = null) : base(stdOut, encoding)
+    {
+        
+    }
+
+    protected override void Write(LogMessage message)
+    {
+        //Nothing to do yet
+    }
+}

Logging/Logger.cs

@@ -0,0 +1,54 @@
+using System.Net.Mime;
+using System.Text;
+
+namespace Logging;
+
+public class Logger : TextWriter
+{
+    public override Encoding Encoding { get; }
+    public enum LoggerType
+    {
+        FileLogger,
+        ConsoleLogger,
+        MemoryLogger
+    }
+
+    private FileLogger? _fileLogger;
+    private FormattedConsoleLogger? _formattedConsoleLogger;
+    private MemoryLogger? _memoryLogger;
+    private TextWriter? stdOut;
+
+    public Logger(LoggerType[] enabledLoggers, TextWriter? stdOut, Encoding? encoding, string? logFilePath)
+    {
+        this.Encoding = encoding ?? Encoding.ASCII;
+        this.stdOut = stdOut ?? null;
+        if (enabledLoggers.Contains(LoggerType.FileLogger) && logFilePath is not null)
+            _fileLogger = new FileLogger(logFilePath, null, encoding);
+        else
+        {
+            _fileLogger = null;
+            throw new ArgumentException($"logFilePath can not be null for LoggerType {LoggerType.FileLogger}");
+        }
+        _formattedConsoleLogger = enabledLoggers.Contains(LoggerType.ConsoleLogger) ? new FormattedConsoleLogger(null, encoding) : null;
+        _memoryLogger = enabledLoggers.Contains(LoggerType.MemoryLogger) ? new MemoryLogger(null, encoding) : null;
+    }
+
+    public void WriteLine(string caller, string? value)
+    {
+        value = value is null ? Environment.NewLine : string.Concat(value, Environment.NewLine);
+
+        Write(caller, value);
+    }
+
+    public void Write(string caller, string? value)
+    {
+        if (value is null)
+            return;
+        
+        _fileLogger?.Write(caller, value);
+        _memoryLogger?.Write(caller, value);
+        _formattedConsoleLogger?.Write(caller, value);
+        
+        stdOut?.Write(value);
+    }
+}

Logging/LoggerBase.cs

@@ -0,0 +1,58 @@
+using System.Text;
+
+namespace Logging;
+
+public abstract class LoggerBase : TextWriter
+{
+    public override Encoding Encoding { get; }
+    private TextWriter? stdOut { get; }
+
+    public LoggerBase(TextWriter? stdOut, Encoding? encoding = null)
+    {
+        this.Encoding = encoding ?? Encoding.ASCII;
+        this.stdOut = stdOut;
+    }
+    
+    public void WriteLine(string caller, string? value)
+    {
+        value = value is null ? Environment.NewLine : string.Join(value, Environment.NewLine);
+
+        LogMessage message = new LogMessage(DateTime.Now, caller, value);
+        
+        Write(message);
+    }
+
+    public void Write(string caller, string? value)
+    {
+        if (value is null)
+            return;
+
+        LogMessage message = new LogMessage(DateTime.Now, caller, value);
+        
+        stdOut?.Write(message.ToString());
+        
+        Write(message);
+    }
+
+    protected abstract void Write(LogMessage message);
+
+    public class LogMessage
+    {
+        public DateTime logTime { get; }
+        public string caller { get; }
+        public string value { get; }
+
+        public LogMessage(DateTime now, string caller, string value)
+        {
+            this.logTime = now;
+            this.caller = caller;
+            this.value = value;
+        }
+
+        public override string ToString()
+        {
+            string dateTimeString = $"{logTime.ToShortDateString()} {logTime.ToLongTimeString()}";
+            return $"[{dateTimeString}] {caller,-30} | {value}";
+        }
+    }
+}

Logging/Logging.csproj

@@ -0,0 +1,9 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+    <PropertyGroup>
+        <TargetFramework>net7.0</TargetFramework>
+        <ImplicitUsings>enable</ImplicitUsings>
+        <Nullable>enable</Nullable>
+    </PropertyGroup>
+
+</Project>

Logging/MemoryLogger.cs

@@ -0,0 +1,42 @@
+using System.Text;
+
+namespace Logging;
+
+public class MemoryLogger : LoggerBase
+{
+    private SortedList<DateTime, LogMessage> logMessages = new();
+
+    public MemoryLogger(TextWriter? stdOut, Encoding? encoding = null) : base(stdOut, encoding)
+    {
+        
+    }
+
+    protected override void Write(LogMessage value)
+    {
+        logMessages.Add(value.logTime, value);
+    }
+
+    public string[] GetLogMessage()
+    {
+        string[] ret = new string[logMessages.Count];
+        for (int logMessageIndex = 0; logMessageIndex < ret.Length; logMessageIndex++)
+        {
+            DateTime logTime = logMessages.GetValueAtIndex(logMessageIndex).logTime;
+            string dateTimeString = $"{logTime.ToShortDateString()} {logTime.ToShortTimeString()}";
+            string callerString = logMessages.GetValueAtIndex(logMessageIndex).caller.ToString();
+            string value = $"[{dateTimeString}] {callerString} | {logMessages.GetValueAtIndex(logMessageIndex).value}";
+            ret[logMessageIndex] = value;
+        }
+
+        return ret;
+    }
+
+    public string[] Tail(uint length)
+    {
+        string[] ret = new string[length];
+        for (int logMessageIndex = logMessages.Count - 1; logMessageIndex > logMessageIndex - length; logMessageIndex--)
+            ret[logMessageIndex] = logMessages.GetValueAtIndex(logMessageIndex).ToString();
+
+        return ret.Reverse().ToArray();
+    }
+}

README.md

@@ -56,11 +56,9 @@ and automatically start updates in [Komga](https://komga.org/) to import them.
 
 ### Inspiration:
 
-Because [Kaizoku](https://github.com/oae/kaizoku) was relying on [mangal](https://github.com/metafates/mangal) on hasn't
-received bugfixes for it's issues with Titles not showing up, or throwing errors because of illegal characters, there
-were no alternatives for automatic downloads.
-
-[Kaizoku](https://github.com/oae/kaizoku) certainly had a great Web-UI, but just wasn't working.
+Because [Kaizoku](https://github.com/oae/kaizoku) was relying on [mangal](https://github.com/metafates/mangal) and mangal
+hasn't received bugfixes for it's issues with Titles not showing up, or throwing errors because of illegal characters,
+there were no alternatives for automatic downloads. However [Kaizoku](https://github.com/oae/kaizoku) certainly had a great Web-UI.
 
 That is why I wanted to create my own project, in a language I understand, and that I am able to maintain myself.
 
@@ -135,8 +133,6 @@ Distributed under the GNU GPLv3  License. See `LICENSE.txt` for more information
 <!-- ACKNOWLEDGMENTS -->
 ## Acknowledgments
 
-Use this space to list resources you find helpful and would like to give credit to. I've included a few of my favorites to kick things off!
-
 * [Choose an Open Source License](https://choosealicense.com)
 * [Font Awesome](https://fontawesome.com)
 * [Best-README-Template](https://github.com/othneildrew/Best-README-Template/tree/master)

Tranga-API/Program.cs

@@ -1,20 +1,19 @@
 using System.Text.Json;
 using Tranga;
-using Tranga.Connectors;
 
-TaskManager taskManager = new TaskManager(Directory.GetCurrentDirectory());
+TaskManager taskManager = new (Directory.GetCurrentDirectory());
 var builder = WebApplication.CreateBuilder(args);
 var app = builder.Build();
 
 app.MapGet("/GetConnectors", () => JsonSerializer.Serialize(taskManager.GetAvailableConnectors().Values.ToArray()));
 
-app.MapGet("/GetPublications", (string connectorName, string? title) =>
+app.MapGet("/GetPublications", (string connectorName, string? publicationName) =>
 {
     Connector connector = taskManager.GetConnector(connectorName);
 
     Publication[] publications;
-    if (title is not null)
-        publications = connector.GetPublications(title);
+    if (publicationName is not null)
+        publications = connector.GetPublications(publicationName);
     else
         publications = connector.GetPublications();
 
@@ -24,26 +23,60 @@ app.MapGet("/GetPublications", (string connectorName, string? title) =>
 app.MapGet("/ListTasks", () => JsonSerializer.Serialize(taskManager.GetAllTasks()));
 
 app.MapGet("/CreateTask",
-    (TrangaTask.Task task, string connectorName, string? publicationName, TimeSpan reoccurrence, string language) =>
+    (TrangaTask.Task task, string? connectorName, string? publicationName, TimeSpan reoccurrence, string? language) =>
     {
-        Publication? publication =
-            taskManager.GetAllPublications().FirstOrDefault(pub => pub.downloadUrl == publicationName);
+        switch (task)
+        {
+            case TrangaTask.Task.UpdateKomgaLibrary:
+                taskManager.AddTask(TrangaTask.Task.UpdateKomgaLibrary, null, null, reoccurrence);
+                break;
+            case TrangaTask.Task.DownloadNewChapters:
+                try
+                {
+                    Connector connector = taskManager.GetConnector(connectorName);
+                    
+                    Publication[] publications;
+                    if (publicationName is not null)
+                        publications = connector.GetPublications(publicationName);
+                    else
+                        publications = connector.GetPublications();
+                    
+                    Publication? publication = publications.FirstOrDefault(pub => pub.downloadUrl == publicationName);
                     if (publication is null)
                         JsonSerializer.Serialize($"Publication {publicationName} is unknown.");
+                    taskManager.AddTask(TrangaTask.Task.DownloadNewChapters, connectorName, publication, reoccurrence, language ?? "");
+                    return JsonSerializer.Serialize("Success");
+                }
+                catch (Exception e)
+                {
+                    return JsonSerializer.Serialize(e.Message);
+                }
 
-        taskManager.AddTask(task, connectorName, publication, reoccurrence, language);
-        JsonSerializer.Serialize("Success");
+            default: return JsonSerializer.Serialize("Not Implemented");
+        }
+
+        return JsonSerializer.Serialize("Not Implemented");
     });
 
-app.MapGet("/RemoveTask", (TrangaTask.Task task, string connector, string? publicationName) =>
+app.MapGet("/RemoveTask", (TrangaTask.Task task, string? connectorName, string? publicationName) =>
 {
-    Publication? publication =
-        taskManager.GetAllPublications().FirstOrDefault(pub => pub.downloadUrl == publicationName);
+    switch (task)
+    {
+        case TrangaTask.Task.UpdateKomgaLibrary:
+            taskManager.RemoveTask(TrangaTask.Task.UpdateKomgaLibrary, null, null);
+            return JsonSerializer.Serialize("Success");
+            break;
+        case TrangaTask.Task.DownloadNewChapters:
+            Publication? publication = taskManager.GetAllPublications().FirstOrDefault(pub => pub.downloadUrl == publicationName);
             if (publication is null)
                 JsonSerializer.Serialize($"Publication {publicationName} is unknown.");
             
-    taskManager.RemoveTask(task, connector, publication);
-    JsonSerializer.Serialize("Success");
+            taskManager.RemoveTask(TrangaTask.Task.DownloadNewChapters, connectorName, publication);
+            
+            return JsonSerializer.Serialize("Success");
+        
+        default: return JsonSerializer.Serialize("Not Implemented");
+    }
 });
 
 app.Run();

Tranga-CLI/Tranga_Cli.cs

@@ -1,6 +1,6 @@
 using System.Globalization;
+using Logging;
 using Tranga;
-using Tranga.Connectors;
 
 namespace Tranga_CLI;
 
@@ -14,6 +14,10 @@ public static class Tranga_Cli
 {
     public static void Main(string[] args)
     {
+        Logger logger = new(new[] { Logger.LoggerType.FileLogger, Logger.LoggerType.MemoryLogger }, null, null,
+            Path.Join(Directory.GetCurrentDirectory(), $"log-{DateTime.Now:dd-M-yyyy-HH-mm-ss}.txt"));
+        
+        logger.WriteLine("Tranga_CLI", "Loading Settings.");
         TaskManager.SettingsData settings;
         string settingsPath = Path.Join(Directory.GetCurrentDirectory(), "data.json");
         if (File.Exists(settingsPath))
@@ -22,6 +26,7 @@ public static class Tranga_Cli
             settings = new TaskManager.SettingsData(Directory.GetCurrentDirectory(), null, new HashSet<TrangaTask>());
 
             
+        logger.WriteLine("Tranga_CLI", "User Input");
         Console.WriteLine($"Output folder path [{settings.downloadLocation}]:");
         string? tmpPath = Console.ReadLine();
         while(tmpPath is null)
@@ -60,44 +65,56 @@ public static class Tranga_Cli
                 }
             } while (key != ConsoleKey.Enter);
 
-            settings.komga = new Komga(tmpUrl, tmpUser, tmpPass);
+            settings.komga = new Komga(tmpUrl, tmpUser, tmpPass, logger);
         }
         
-        TaskMode(settings);
+        logger.WriteLine("Tranga_CLI", "Loaded.");
+        TaskMode(settings, logger);
     }
 
-    private static void TaskMode(TaskManager.SettingsData settings)
+    private static void TaskMode(TaskManager.SettingsData settings, Logger logger)
     {
-        TaskManager taskManager = new (settings);
-        ConsoleKey selection = PrintMenu(taskManager, settings.downloadLocation);
+        TaskManager taskManager = new (settings, logger);
+        ConsoleKey selection = PrintMenu(taskManager, settings.downloadLocation, logger);
         while (selection != ConsoleKey.Q)
         {
             switch (selection)
             {
                 case ConsoleKey.L:
-                    PrintTasks(taskManager.GetAllTasks());
-                    break;
-                case ConsoleKey.C:
-                    CreateTask(taskManager, settings);
-                    break;
-                case ConsoleKey.D:
-                    RemoveTask (taskManager);
-                    break;
-                case ConsoleKey.E:
-                    ExecuteTaskNow(taskManager);
-                    break;
-                case ConsoleKey.S:
-                    SearchTasks(taskManager);
-                    break;
-                case ConsoleKey.R:
-                    PrintTasks(taskManager.GetAllTasks().Where(eTask => eTask.state == TrangaTask.ExecutionState.Running).ToArray());
-                    break;
-            }
+                    PrintTasks(taskManager.GetAllTasks(), logger);
                     Console.WriteLine("Press any key.");
                     Console.ReadKey();
-            selection = PrintMenu(taskManager, settings.downloadLocation);
+                    break;
+                case ConsoleKey.C:
+                    CreateTask(taskManager, settings, logger);
+                    Console.WriteLine("Press any key.");
+                    Console.ReadKey();
+                    break;
+                case ConsoleKey.D:
+                    RemoveTask (taskManager, logger);
+                    Console.WriteLine("Press any key.");
+                    Console.ReadKey();
+                    break;
+                case ConsoleKey.E:
+                    ExecuteTaskNow(taskManager, logger);
+                    Console.WriteLine("Press any key.");
+                    Console.ReadKey();
+                    break;
+                case ConsoleKey.S:
+                    SearchTasks(taskManager, logger);
+                    Console.WriteLine("Press any key.");
+                    Console.ReadKey();
+                    break;
+                case ConsoleKey.R:
+                    PrintTasks(taskManager.GetAllTasks().Where(eTask => eTask.state == TrangaTask.ExecutionState.Running).ToArray(), logger);
+                    Console.WriteLine("Press any key.");
+                    Console.ReadKey();
+                    break;
+            }
+            selection = PrintMenu(taskManager, settings.downloadLocation, logger);
         }
 
+        logger.WriteLine("Tranga_CLI", "Exiting.");
         if (taskManager.GetAllTasks().Any(task => task.state == TrangaTask.ExecutionState.Running))
         {
             Console.WriteLine("Force quit (Even with running tasks?) y/N");
@@ -110,42 +127,47 @@ public static class Tranga_Cli
             taskManager.Shutdown(false);
     }
 
-    private static ConsoleKey PrintMenu(TaskManager taskManager, string folderPath)
+    private static ConsoleKey PrintMenu(TaskManager taskManager, string folderPath, Logger logger)
     {
         int taskCount = taskManager.GetAllTasks().Length;
         int taskRunningCount = taskManager.GetAllTasks().Count(task => task.state == TrangaTask.ExecutionState.Running);
         int taskEnqueuedCount =
             taskManager.GetAllTasks().Count(task => task.state == TrangaTask.ExecutionState.Enqueued);
         Console.Clear();
-        Console.WriteLine($"Download Folder: {folderPath} Tasks (Running/Queue/Total): {taskRunningCount}/{taskEnqueuedCount}/{taskCount}");
-        Console.WriteLine("U: Update this Screen");
-        Console.WriteLine("L: List tasks");
-        Console.WriteLine("C: Create Task");
-        Console.WriteLine("D: Delete Task");
-        Console.WriteLine("E: Execute Task now");
-        Console.WriteLine("S: Search Task");
-        Console.WriteLine("R: Running Tasks");
-        Console.WriteLine("Q: Exit");
-        ConsoleKey selection = Console.ReadKey().Key;
+        Console.WriteLine($"Download Folder: {folderPath}");
+        Console.WriteLine($"Tasks (Running/Queue/Total));: {taskRunningCount}/{taskEnqueuedCount}/{taskCount}");
         Console.WriteLine();
+        Console.WriteLine($"{"C: Create Task",-30}{"L: List tasks",-30}");
+        Console.WriteLine($"{"D: Delete Task",-30}{"R: List Running Tasks", -30}");
+        Console.WriteLine($"{"E: Execute Task now",-30}{"S: Search Tasks", -30}");
+        Console.WriteLine();
+        Console.WriteLine($"{"U: Update this Screen",-30}{"Q: Exit",-30}");
+        ConsoleKey selection = Console.ReadKey().Key;
+        logger.WriteLine("Tranga_CLI", $"Menu selection: {selection}");
         return selection;
     }
 
-    private static void PrintTasks(TrangaTask[] tasks)
+    private static void PrintTasks(TrangaTask[] tasks, Logger logger)
     {
+        logger.WriteLine("Tranga_CLI", "Printing Tasks");
         int taskCount = tasks.Length;
         int taskRunningCount = tasks.Count(task => task.state == TrangaTask.ExecutionState.Running);
         int taskEnqueuedCount = tasks.Count(task => task.state == TrangaTask.ExecutionState.Enqueued);
         Console.Clear();
         int tIndex = 0;
         Console.WriteLine($"Tasks (Running/Queue/Total): {taskRunningCount}/{taskEnqueuedCount}/{taskCount}");
+        string header =
+            $"{"",-5}{"Task",-20} | {"Last Executed",-20} | {"Reoccurrence",-12} | {"State",-10} | {"Connector",-15} | Publication/Manga";
+        Console.WriteLine(header);
+        Console.WriteLine(new string('-', header.Length));
         foreach(TrangaTask trangaTask in tasks)
             Console.WriteLine($"{tIndex++:000}: {trangaTask}");
     }
 
-    private static void CreateTask(TaskManager taskManager, TaskManager.SettingsData settings)
+    private static void CreateTask(TaskManager taskManager, TaskManager.SettingsData settings, Logger logger)
     {
-        TrangaTask.Task? tmpTask = SelectTaskType();
+        logger.WriteLine("Tranga_CLI", "Menu: Creating Task");
+        TrangaTask.Task? tmpTask = SelectTaskType(logger);
         if (tmpTask is null)
             return;
         TrangaTask.Task task = (TrangaTask.Task)tmpTask!;
@@ -153,7 +175,7 @@ public static class Tranga_Cli
         Connector? connector = null;
         if (task != TrangaTask.Task.UpdateKomgaLibrary)
         {
-            connector = SelectConnector(settings.downloadLocation, taskManager.GetAvailableConnectors().Values.ToArray());
+            connector = SelectConnector(settings.downloadLocation, taskManager.GetAvailableConnectors().Values.ToArray(), logger);
             if (connector is null)
                 return;
         }
@@ -161,27 +183,31 @@ public static class Tranga_Cli
         Publication? publication = null;
         if (task != TrangaTask.Task.UpdatePublications && task != TrangaTask.Task.UpdateKomgaLibrary)
         {
-            publication = SelectPublication(connector!);
+            publication = SelectPublication(connector!, logger);
             if (publication is null)
                 return;
         }
         
-        TimeSpan reoccurrence = SelectReoccurrence();
+        TimeSpan reoccurrence = SelectReoccurrence(logger);
+        logger.WriteLine("Tranga_CLI", "Sending Task to TaskManager");
         TrangaTask newTask = taskManager.AddTask(task, connector?.name, publication, reoccurrence, "en");
         Console.WriteLine(newTask);
     }
 
-    private static void ExecuteTaskNow(TaskManager taskManager)
+    private static void ExecuteTaskNow(TaskManager taskManager, Logger logger)
     {
+        logger.WriteLine("Tranga_CLI", "Menu: Executing Task");
         TrangaTask[] tasks = taskManager.GetAllTasks();
         if (tasks.Length < 1)
         {
             Console.Clear();
             Console.WriteLine("There are no available Tasks.");
+            logger.WriteLine("Tranga_CLI", "No available Tasks.");
             return;
         }
-        PrintTasks(tasks);
+        PrintTasks(tasks, logger);
         
+        logger.WriteLine("Tranga_CLI", "Selecting Task to Execute");
         Console.WriteLine("Enter q to abort");
         Console.WriteLine($"Select Task (0-{tasks.Length - 1}):");
 
@@ -191,33 +217,40 @@ public static class Tranga_Cli
         
         if (selectedTask.Length == 1 && selectedTask.ToLower() == "q")
         {
+            Console.Clear();
             Console.WriteLine("aborted.");
+            logger.WriteLine("Tranga_CLI", "aborted");
             return;
         }
         
         try
         {
             int selectedTaskIndex = Convert.ToInt32(selectedTask);
+            logger.WriteLine("Tranga_CLI", "Sending Task to TaskManager");
             taskManager.ExecuteTaskNow(tasks[selectedTaskIndex]);
         }
         catch (Exception e)
         {
             Console.WriteLine($"Exception: {e.Message}");
+            logger.WriteLine("Tranga_CLI", e.Message);
         }
         
     }
 
-    private static void RemoveTask(TaskManager taskManager)
+    private static void RemoveTask(TaskManager taskManager, Logger logger)
     {
+        logger.WriteLine("Tranga_CLI", "Menu: Remove Task");
         TrangaTask[] tasks = taskManager.GetAllTasks();
         if (tasks.Length < 1)
         {
             Console.Clear();
             Console.WriteLine("There are no available Tasks.");
+            logger.WriteLine("Tranga_CLI", "No available Tasks");
             return;
         }
-        PrintTasks(tasks);
+        PrintTasks(tasks, logger);
         
+        logger.WriteLine("Tranga_CLI", "Selecting Task");
         Console.WriteLine("Enter q to abort");
         Console.WriteLine($"Select Task (0-{tasks.Length - 1}):");
 
@@ -227,23 +260,28 @@ public static class Tranga_Cli
 
         if (selectedTask.Length == 1 && selectedTask.ToLower() == "q")
         {
+            Console.Clear();
             Console.WriteLine("aborted.");
+            logger.WriteLine("Tranga_CLI", "aborted.");
             return;
         }
         
         try
         {
             int selectedTaskIndex = Convert.ToInt32(selectedTask);
+            logger.WriteLine("Tranga_CLI", "Sending Task to TaskManager");
             taskManager.RemoveTask(tasks[selectedTaskIndex].task, tasks[selectedTaskIndex].connectorName, tasks[selectedTaskIndex].publication);
         }
         catch (Exception e)
         {
             Console.WriteLine($"Exception: {e.Message}");
+            logger.WriteLine("Tranga_CLI", e.Message);
         }
     }
 
-    private static TrangaTask.Task? SelectTaskType()
+    private static TrangaTask.Task? SelectTaskType(Logger logger)
     {
+        logger.WriteLine("Tranga_CLI", "Menu: Select TaskType");
         Console.Clear();
         string[] taskNames = Enum.GetNames<TrangaTask.Task>();
         
@@ -261,7 +299,9 @@ public static class Tranga_Cli
 
         if (selectedTask.Length == 1 && selectedTask.ToLower() == "q")
         {
+            Console.Clear();
             Console.WriteLine("aborted.");
+            logger.WriteLine("Tranga_CLI", "aborted.");
             return null;
         }
         
@@ -274,19 +314,22 @@ public static class Tranga_Cli
         catch (Exception e)
         {
             Console.WriteLine($"Exception: {e.Message}");
+            logger.WriteLine("Tranga_CLI", e.Message);
         }
 
         return null;
     }
 
-    private static TimeSpan SelectReoccurrence()
+    private static TimeSpan SelectReoccurrence(Logger logger)
     {
+        logger.WriteLine("Tranga_CLI", "Menu: Select Reoccurrence");
         Console.WriteLine("Select reoccurrence Timer (Format hh:mm:ss):");
         return TimeSpan.Parse(Console.ReadLine()!, new CultureInfo("en-US"));
     }
 
-    private static Connector? SelectConnector(string folderPath, Connector[] connectors)
+    private static Connector? SelectConnector(string folderPath, Connector[] connectors, Logger logger)
     {
+        logger.WriteLine("Tranga_CLI", "Menu: Select Connector");
         Console.Clear();
         
         int cIndex = 0;
@@ -303,7 +346,9 @@ public static class Tranga_Cli
 
         if (selectedConnector.Length == 1 && selectedConnector.ToLower() == "q")
         {
+            Console.Clear();
             Console.WriteLine("aborted.");
+            logger.WriteLine("Tranga_CLI", "aborted.");
             return null;
         }
         
@@ -315,13 +360,16 @@ public static class Tranga_Cli
         catch (Exception e)
         {
             Console.WriteLine($"Exception: {e.Message}");
+            logger.WriteLine("Tranga_CLI", e.Message);
         }
 
         return null;
     }
 
-    private static Publication? SelectPublication(Connector connector)
+    private static Publication? SelectPublication(Connector connector, Logger logger)
     {
+        logger.WriteLine("Tranga_CLI", "Menu: Select Publication");
+        
         Console.Clear();
         Console.WriteLine($"Connector: {connector.name}");
         Console.WriteLine("Publication search query (leave empty for all):");
@@ -343,7 +391,9 @@ public static class Tranga_Cli
 
         if (selectedPublication.Length == 1 && selectedPublication.ToLower() == "q")
         {
+            Console.Clear();
             Console.WriteLine("aborted.");
+            logger.WriteLine("Tranga_CLI", "aborted.");
             return null;
         }
         
@@ -355,17 +405,19 @@ public static class Tranga_Cli
         catch (Exception e)
         {
             Console.WriteLine($"Exception: {e.Message}");
+            logger.WriteLine("Tranga_CLI", e.Message);
         }
 
         return null;
     }
 
-    private static void SearchTasks(TaskManager taskManager)
+    private static void SearchTasks(TaskManager taskManager, Logger logger)
     {
+        logger.WriteLine("Tranga_CLI", "Menu: Search task");
         string? query = Console.ReadLine();
         while (query is null || query.Length < 1)
             query = Console.ReadLine();
         PrintTasks(taskManager.GetAllTasks().Where(qTask =>
-            qTask.ToString().ToLower().Contains(query, StringComparison.OrdinalIgnoreCase)).ToArray());
+            qTask.ToString().ToLower().Contains(query, StringComparison.OrdinalIgnoreCase)).ToArray(), logger);
     }
 }

Tranga.sln

@@ -6,6 +6,8 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Tranga-CLI", "Tranga-CLI\Tr
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Tranga-API", "Tranga-API\Tranga-API.csproj", "{6284C936-4E90-486B-BC46-0AFAD85AD8EE}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Logging", "Logging\Logging.csproj", "{415BE889-BB7D-426F-976F-8D977876A462}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -24,5 +26,9 @@ Global
 		{6284C936-4E90-486B-BC46-0AFAD85AD8EE}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{6284C936-4E90-486B-BC46-0AFAD85AD8EE}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{6284C936-4E90-486B-BC46-0AFAD85AD8EE}.Release|Any CPU.Build.0 = Release|Any CPU
+		{415BE889-BB7D-426F-976F-8D977876A462}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{415BE889-BB7D-426F-976F-8D977876A462}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{415BE889-BB7D-426F-976F-8D977876A462}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{415BE889-BB7D-426F-976F-8D977876A462}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 EndGlobal

Tranga/Connector.cs

@@ -1,6 +1,7 @@
 using System.IO.Compression;
 using System.Net;
 using System.Xml.Linq;
+using Logging;
 
 namespace Tranga;
 
@@ -13,10 +14,13 @@ public abstract class Connector
     internal string downloadLocation { get; }  //Location of local files
     protected DownloadClient downloadClient { get; }
 
-    protected Connector(string downloadLocation, uint downloadDelay)
+    protected Logger? logger;
+
+    protected Connector(string downloadLocation, uint downloadDelay, Logger? logger)
     {
         this.downloadLocation = downloadLocation;
         this.downloadClient = new DownloadClient(downloadDelay);
+        this.logger = logger;
     }
     
     public abstract string name { get; } //Name of the Connector (e.g. Website)
@@ -58,6 +62,7 @@ public abstract class Connector
     /// <param name="publication">Publication to save series.json for</param>
     public void SaveSeriesInfo(Publication publication)
     {
+        logger?.WriteLine(this.GetType().ToString(), $"Saving series.json for {publication.sortName}");
         //Check if Publication already has a Folder and a series.json
         string publicationFolder = Path.Join(downloadLocation, publication.folderName);
         if(!Directory.Exists(publicationFolder))
@@ -73,8 +78,9 @@ public abstract class Connector
     /// See ComicInfo.xml
     /// </summary>
     /// <returns>XML-string</returns>
-    protected static string CreateComicInfo(Publication publication, Chapter chapter)
+    protected static string CreateComicInfo(Publication publication, Chapter chapter, Logger? logger)
     {
+        logger?.WriteLine("Connector", $"Creating ComicInfo.Xml for {publication.sortName} Chapter {chapter.sortNumber}");
         XElement comicInfo = new XElement("ComicInfo",
             new XElement("Tags", string.Join(',',publication.tags)),
             new XElement("LanguageISO", publication.originalLanguage),
@@ -124,8 +130,9 @@ public abstract class Connector
     /// <param name="saveArchiveFilePath">Full path to save archive to (without file ending .cbz)</param>
     /// <param name="downloadClient">DownloadClient of the connector</param>
     /// <param name="comicInfoPath">Path of the generate Chapter ComicInfo.xml, if it was generated</param>
-    protected static void DownloadChapterImages(string[] imageUrls, string saveArchiveFilePath, DownloadClient downloadClient, string? comicInfoPath = null)
+    protected static void DownloadChapterImages(string[] imageUrls, string saveArchiveFilePath, DownloadClient downloadClient, Logger? logger, string? comicInfoPath = null)
     {
+        logger?.WriteLine("Connector", "Downloading Images");
         //Check if Publication Directory already exists
         string[] splitPath = saveArchiveFilePath.Split(Path.DirectorySeparatorChar);
         string directoryPath = Path.Combine(splitPath.Take(splitPath.Length - 1).ToArray());
@@ -151,6 +158,7 @@ public abstract class Connector
         if(comicInfoPath is not null)
             File.Copy(comicInfoPath, Path.Join(tempFolder, "ComicInfo.xml"));
         
+        logger?.WriteLine("Connector", "Creating archive");
         //ZIP-it and ship-it
         ZipFile.CreateFromDirectory(tempFolder, fullPath);
         Directory.Delete(tempFolder, true); //Cleanup

Tranga/Connectors/MangaDex.cs

@@ -2,24 +2,26 @@
 using System.Net;
 using System.Text.Json;
 using System.Text.Json.Nodes;
+using Logging;
 
 namespace Tranga.Connectors;
 public class MangaDex : Connector
 {
     public override string name { get; }
 
-    public MangaDex(string downloadLocation, uint downloadDelay) : base(downloadLocation, downloadDelay)
+    public MangaDex(string downloadLocation, uint downloadDelay, Logger? logger) : base(downloadLocation, downloadDelay, logger)
     {
         name = "MangaDex";
     }
     
-    public MangaDex(string downloadLocation) : base(downloadLocation, 750)
+    public MangaDex(string downloadLocation, Logger? logger) : base(downloadLocation, 750, logger)
     {
         name = "MangaDex";
     }
 
     public override Publication[] GetPublications(string publicationTitle = "")
     {
+        logger?.WriteLine(this.GetType().ToString(), $"Getting Publications");
         const int limit = 100; //How many values we want returned at once
         int offset = 0; //"Page"
         int total = int.MaxValue; //How many total results are there, is updated on first request
@@ -126,6 +128,7 @@ public class MangaDex : Connector
 
     public override Chapter[] GetChapters(Publication publication, string language = "")
     {
+        logger?.WriteLine(this.GetType().ToString(), $"Getting Chapters");
         const int limit = 100; //How many values we want returned at once
         int offset = 0; //"Page"
         int total = int.MaxValue; //How many total results are there, is updated on first request
@@ -180,6 +183,7 @@ public class MangaDex : Connector
 
     public override void DownloadChapter(Publication publication, Chapter chapter)
     {
+        logger?.WriteLine(this.GetType().ToString(), $"Download Chapter {publication.sortName} {chapter.sortNumber}");
         //Request URLs for Chapter-Images
         DownloadClient.RequestResult requestResult =
             downloadClient.MakeRequest($"https://api.mangadex.org/at-home/server/{chapter.url}?forcePort443=false'");
@@ -198,14 +202,15 @@ public class MangaDex : Connector
             imageUrls.Add($"{baseUrl}/data/{hash}/{image!.GetValue<string>()}");
 
         string comicInfoPath = Path.GetTempFileName();
-        File.WriteAllText(comicInfoPath, CreateComicInfo(publication, chapter));
+        File.WriteAllText(comicInfoPath, CreateComicInfo(publication, chapter, logger));
         
         //Download Chapter-Images
-        DownloadChapterImages(imageUrls.ToArray(), CreateFullFilepath(publication, chapter), downloadClient, comicInfoPath);
+        DownloadChapterImages(imageUrls.ToArray(), CreateFullFilepath(publication, chapter), downloadClient, logger, comicInfoPath);
     }
 
     public override void DownloadCover(Publication publication)
     {
+        logger?.WriteLine(this.GetType().ToString(), $"Download cover {publication.sortName}");
         //Check if Publication already has a Folder and cover
         string publicationFolder = Path.Join(downloadLocation, publication.folderName);
         if(!Directory.Exists(publicationFolder))

Tranga/Komga.cs

@@ -1,5 +1,6 @@
 using System.Net.Http.Headers;
 using System.Text.Json.Nodes;
+using Logging;
 using Newtonsoft.Json;
 using JsonSerializer = System.Text.Json.JsonSerializer;
 
@@ -14,22 +15,26 @@ public class Komga
     public string baseUrl { get; }
     public string auth { get; } //Base64 encoded, if you use your password everywhere, you have problems
 
+    private Logger? logger;
+    
     /// <param name="baseUrl">Base-URL of Komga instance, no trailing slashes(/)</param>
     /// <param name="username">Komga Username</param>
     /// <param name="password">Komga password, will be base64 encoded. yea</param>
-    public Komga(string baseUrl, string username, string password)
+    public Komga(string baseUrl, string username, string password, Logger? logger)
     {
         this.baseUrl = baseUrl;
         this.auth = Convert.ToBase64String(System.Text.Encoding.ASCII.GetBytes($"{username}:{password}"));
+        this.logger = logger;
     }
     
     /// <param name="baseUrl">Base-URL of Komga instance, no trailing slashes(/)</param>
     /// <param name="auth">Base64 string of username and password (username):(password)</param>
     [JsonConstructor]
-    public Komga(string baseUrl, string auth)
+    public Komga(string baseUrl, string auth, Logger? logger)
     {
         this.baseUrl = baseUrl;
         this.auth = auth;
+        this.logger = logger;
     }
 
     /// <summary>
@@ -38,6 +43,7 @@ public class Komga
     /// <returns>Array of KomgaLibraries</returns>
     public KomgaLibrary[] GetLibraries()
     {
+        logger?.WriteLine(this.GetType().ToString(), $"Getting Libraries");
         Stream data = NetClient.MakeRequest($"{baseUrl}/api/v1/libraries", auth);
         JsonArray? result = JsonSerializer.Deserialize<JsonArray>(data);
         if (result is null)
@@ -63,6 +69,7 @@ public class Komga
     /// <returns>true if successful</returns>
     public bool UpdateLibrary(string libraryId)
     {
+        logger?.WriteLine(this.GetType().ToString(), $"Updating Libraries");
         return NetClient.MakePost($"{baseUrl}/api/v1/libraries/{libraryId}/scan", auth);
     }
 

Tranga/TaskExecutor.cs

@@ -1,4 +1,6 @@
-namespace Tranga;
+using Logging;
+
+namespace Tranga;
 
 /// <summary>
 /// Executes TrangaTasks
@@ -14,12 +16,16 @@ public static class TaskExecutor
     /// <param name="trangaTask">Task to execute</param>
     /// <param name="chapterCollection">Current chapterCollection to update</param>
     /// <exception cref="ArgumentException">Is thrown when there is no Connector available with the name of the TrangaTask.connectorName</exception>
-    public static void Execute(TaskManager taskManager, TrangaTask trangaTask, Dictionary<Publication, List<Chapter>> chapterCollection)
+    public static void Execute(TaskManager taskManager, TrangaTask trangaTask, Dictionary<Publication, List<Chapter>> chapterCollection, Logger? logger)
     {
         //Only execute task if it is not already being executed.
         if (trangaTask.state == TrangaTask.ExecutionState.Running)
+        {
+            logger?.WriteLine("TaskExecutor", $"Task already running {trangaTask}");
             return;
+        }
         trangaTask.state = TrangaTask.ExecutionState.Running;
+        logger?.WriteLine("TaskExecutor", $"Executing Task {trangaTask}");
         
         //Connector is not needed for all tasks
         Connector? connector = null;
@@ -43,6 +49,7 @@ public static class TaskExecutor
                 break;
         }
         
+        logger?.WriteLine("TaskExecutor", $"Task executed! {trangaTask}");
         trangaTask.state = TrangaTask.ExecutionState.Waiting;
         trangaTask.lastExecuted = DateTime.Now;
     }

Tranga/TaskManager.cs

@@ -1,4 +1,5 @@
-using Newtonsoft.Json;
+using Logging;
+using Newtonsoft.Json;
 using Tranga.Connectors;
 
 namespace Tranga;
@@ -15,20 +16,23 @@ public class TaskManager
     private readonly Connector[] _connectors;
     private Dictionary<Connector, List<TrangaTask>> tasksToExecute = new();
     private string downloadLocation { get; }
+    private Logger? logger { get; }
     
-    public Komga? komga { get; private set; }
+    public Komga? komga { get; }
 
     /// <param name="folderPath">Local path to save data (Manga) to</param>
     /// <param name="komgaBaseUrl">The Url of the Komga-instance that you want to update</param>
     /// <param name="komgaUsername">The Komga username</param>
     /// <param name="komgaPassword">The Komga password</param>
-    public TaskManager(string folderPath, string? komgaBaseUrl = null, string? komgaUsername = null, string? komgaPassword = null)
+    /// <param name="logger"></param>
+    public TaskManager(string folderPath, string? komgaBaseUrl = null, string? komgaUsername = null, string? komgaPassword = null, Logger? logger = null)
     {
+        this.logger = logger;
         this.downloadLocation = folderPath;
 
         if (komgaBaseUrl != null && komgaUsername != null && komgaPassword != null)
-            this.komga = new Komga(komgaBaseUrl, komgaUsername, komgaPassword);
-        this._connectors = new Connector[]{ new MangaDex(folderPath) };
+            this.komga = new Komga(komgaBaseUrl, komgaUsername, komgaPassword, logger);
+        this._connectors = new Connector[]{ new MangaDex(folderPath, logger) };
         foreach(Connector cConnector in this._connectors)
             tasksToExecute.Add(cConnector, new List<TrangaTask>());
         _allTasks = new HashSet<TrangaTask>();
@@ -37,9 +41,10 @@ public class TaskManager
         taskChecker.Start();
     }
 
-    public TaskManager(SettingsData settings)
+    public TaskManager(SettingsData settings, Logger? logger = null)
     {
-        this._connectors = new Connector[]{ new MangaDex(settings.downloadLocation) };
+        this.logger = logger;
+        this._connectors = new Connector[]{ new MangaDex(settings.downloadLocation, logger) };
         foreach(Connector cConnector in this._connectors)
             tasksToExecute.Add(cConnector, new List<TrangaTask>());
         this.downloadLocation = settings.downloadLocation;
@@ -61,7 +66,7 @@ public class TaskManager
             foreach (KeyValuePair<Connector, List<TrangaTask>> connectorTaskQueue in tasksToExecute)
             {
                 connectorTaskQueue.Value.RemoveAll(task => task.state == TrangaTask.ExecutionState.Waiting);
-                if (connectorTaskQueue.Value.Count > 0 && !connectorTaskQueue.Value.All(task => task.state is TrangaTask.ExecutionState.Running or TrangaTask.ExecutionState.Waiting))
+                if (connectorTaskQueue.Value.Count > 0 && !connectorTaskQueue.Value.All(task => task.state is TrangaTask.ExecutionState.Running or TrangaTask.ExecutionState.Enqueued))
                     ExecuteTaskNow(connectorTaskQueue.Value.First());
             }
             
@@ -74,6 +79,7 @@ public class TaskManager
                     ExecuteTaskNow(task);
                 else
                 {
+                    logger?.WriteLine(this.GetType().ToString(), $"Task due: {task}");
                     tasksToExecute[GetConnector(task.connectorName!)].Add(task);
                 }
             }
@@ -90,9 +96,10 @@ public class TaskManager
         if (!this._allTasks.Contains(task))
             return;
         
+        logger?.WriteLine(this.GetType().ToString(), $"Forcing Execution: {task}");
         Task t = new Task(() =>
         {
-            TaskExecutor.Execute(this, task, this._chapterCollection);
+            TaskExecutor.Execute(this, task, this._chapterCollection, logger);
         });
         t.Start();
     }
@@ -109,6 +116,7 @@ public class TaskManager
     public TrangaTask AddTask(TrangaTask.Task task, string? connectorName, Publication? publication, TimeSpan reoccurrence,
         string language = "")
     {
+        logger?.WriteLine(this.GetType().ToString(), $"Adding new Task");
         if (task != TrangaTask.Task.UpdateKomgaLibrary && connectorName is null)
             throw new ArgumentException($"connectorName can not be null for task {task}");
 
@@ -142,6 +150,7 @@ public class TaskManager
                 _allTasks.Add(newTask);
             }
         }
+        logger?.WriteLine(this.GetType().ToString(), newTask.ToString());
         ExportData(Directory.GetCurrentDirectory());
         
         return newTask;
@@ -155,6 +164,7 @@ public class TaskManager
     /// <param name="publication">Publication that was used</param>
     public void RemoveTask(TrangaTask.Task task, string? connectorName, Publication? publication)
     {
+        logger?.WriteLine(this.GetType().ToString(), $"Removing Task {task}");
         if (task == TrangaTask.Task.UpdateKomgaLibrary)
             _allTasks.RemoveWhere(uTask => uTask.task == TrangaTask.Task.UpdateKomgaLibrary);
         else if (connectorName is null)
@@ -193,6 +203,8 @@ public class TaskManager
     /// <exception cref="Exception">If Connector is not available</exception>
     public Connector GetConnector(string connectorName)
     {
+        if(connectorName is null)
+            throw new Exception($"connectorName can not be null");
         Connector? ret = this._connectors.FirstOrDefault(connector => connector.name == connectorName);
         if (ret is null)
             throw new Exception($"Connector {connectorName} is not an available Connector.");
@@ -205,6 +217,7 @@ public class TaskManager
     /// <param name="force">If force is true, tasks are aborted.</param>
     public void Shutdown(bool force = false)
     {
+        logger?.WriteLine(this.GetType().ToString(), $"Shutting down (forced={force})");
         _continueRunning = false;
         ExportData(Directory.GetCurrentDirectory());
         
@@ -239,6 +252,7 @@ public class TaskManager
     /// <param name="exportFolderPath">Folder path, filename will be data.json</param>
     private void ExportData(string exportFolderPath)
     {
+        logger?.WriteLine(this.GetType().ToString(), $"Exporting data to data.json");
         SettingsData data = new SettingsData(this.downloadLocation, this.komga, this._allTasks);
 
         string exportPath = Path.Join(exportFolderPath, "data.json");

Tranga/Tranga.csproj

@@ -10,4 +10,8 @@
       <PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
     </ItemGroup>
 
+    <ItemGroup>
+      <ProjectReference Include="..\Logging\Logging.csproj" />
+    </ItemGroup>
+
 </Project>

Tranga/TrangaTask.cs

@@ -56,6 +56,6 @@ public class TrangaTask
 
     public override string ToString()
     {
-        return $"{task}\t{lastExecuted}\t{reoccurrence}\t{state}\t{connectorName}\t{publication?.sortName}";
+        return $"{task,-20} | {lastExecuted,-20} | {reoccurrence,-12} | {state,-10} | {connectorName,-15} | {publication?.sortName}";
     }
 }