Tranga/GlobalBase.cs

@@ -66,10 +66,10 @@ public abstract class GlobalBase
         Log(string.Format(fStr, replace));
     }
 
-    protected void SendNotifications(string title, string text, bool buffer = false)
+    protected void SendNotifications(string title, string text)
     {
         foreach (NotificationConnector nc in notificationConnectors)
-            nc.SendNotification(title, text, buffer);
+            nc.SendNotification(title, text);
     }
 
     protected void AddNotificationConnector(NotificationConnector notificationConnector)

Tranga/Jobs/DownloadChapter.cs

@@ -37,7 +37,7 @@ public class DownloadChapter : Job
             if (success == HttpStatusCode.OK)
             {
                 UpdateLibraries();
-                SendNotifications("Chapter downloaded", $"{chapter.parentManga.sortName} - {chapter.chapterNumber}", true);
+                SendNotifications("Chapter downloaded", $"{chapter.parentManga.sortName} - {chapter.chapterNumber}");
             }
         });
         downloadTask.Start();

Tranga/LibraryConnectors/Kavita.cs

@@ -61,7 +61,7 @@ public class Kavita : LibraryConnector
         return "";
     }
 
-    protected override void UpdateLibraryInternal()
+    public override void UpdateLibrary()
     {
         Log("Updating libraries.");
         foreach (KavitaLibrary lib in GetLibraries())

Tranga/LibraryConnectors/Komga.cs

@@ -25,7 +25,7 @@ public class Komga : LibraryConnector
         return $"Komga {baseUrl}";
     }
 
-    protected override void UpdateLibraryInternal()
+    public override void UpdateLibrary()
     {
         Log("Updating libraries.");
         foreach (KomgaLibrary lib in GetLibraries())

Tranga/LibraryConnectors/LibraryConnector.cs

@@ -17,9 +17,6 @@ public abstract class LibraryConnector : GlobalBase
     public string baseUrl { get; }
     // ReSharper disable once MemberCanBeProtected.Global
     public string auth { get; } //Base64 encoded, if you use your password everywhere, you have problems
-    private DateTime? _updateLibraryRequested = null;
-    private readonly Thread? _libraryBufferThread = null;
-    private const int NoChangeTimeout = 2, BiggestInterval = 20;
     
     protected LibraryConnector(GlobalBase clone, string baseUrl, string auth, LibraryType libraryType) : base(clone)
     {
@@ -31,47 +28,8 @@ public abstract class LibraryConnector : GlobalBase
         this.baseUrl = baseUrlRex.Match(baseUrl).Value;
         this.auth = auth;
         this.libraryType = libraryType;
-
-        if (TrangaSettings.bufferLibraryUpdates)
-        {
-            _libraryBufferThread = new(CheckLibraryBuffer);
-            _libraryBufferThread.Start();
-        }
     }
-
-    private void CheckLibraryBuffer()
-    {
-        while (true)
-        {
-            if (_updateLibraryRequested is not null && DateTime.Now.Subtract((DateTime)_updateLibraryRequested) > TimeSpan.FromMinutes(NoChangeTimeout)) //If no updates have been requested for NoChangeTimeout minutes, update library
-            {
-                UpdateLibraryInternal();
-                _updateLibraryRequested = null;
-            }
-            Thread.Sleep(100);
-        }
-    }
-
-    public void UpdateLibrary()
-    {
-        _updateLibraryRequested ??= DateTime.Now;
-        if (!TrangaSettings.bufferLibraryUpdates)
-        {
-            UpdateLibraryInternal();
-            return;
-        }else if (_updateLibraryRequested is not null &&
-                  DateTime.Now.Subtract((DateTime)_updateLibraryRequested) > TimeSpan.FromMinutes(BiggestInterval)) //If the last update has been more than BiggestInterval minutes ago, update library
-        {
-            UpdateLibraryInternal();
-            _updateLibraryRequested = null;
-        }
-        else if(_updateLibraryRequested is not null)
-        {
-            Log($"Buffering Library Updates (Updates in latest {((DateTime)_updateLibraryRequested).Add(TimeSpan.FromMinutes(BiggestInterval)).Subtract(DateTime.Now)} or {((DateTime)_updateLibraryRequested).Add(TimeSpan.FromMinutes(NoChangeTimeout)).Subtract(DateTime.Now)})");
-        }
-    }
-    
-    protected abstract void UpdateLibraryInternal();
+    public abstract void UpdateLibrary();
     internal abstract bool Test();
 
     protected static class NetClient

Tranga/NotificationConnectors/Gotify.cs

@@ -24,7 +24,7 @@ public class Gotify : NotificationConnector
         return $"Gotify {endpoint}";
     }
 
-    protected override void SendNotificationInternal(string title, string notificationText)
+    public override void SendNotification(string title, string notificationText)
     {
         Log($"Sending notification: {title} - {notificationText}");
         MessageData message = new(title, notificationText);

Tranga/NotificationConnectors/LunaSea.cs

@@ -20,7 +20,7 @@ public class LunaSea : NotificationConnector
         return $"LunaSea {id}";
     }
 
-    protected override void SendNotificationInternal(string title, string notificationText)
+    public override void SendNotification(string title, string notificationText)
     {
         Log($"Sending notification: {title} - {notificationText}");
         MessageData message = new(title, notificationText);

Tranga/NotificationConnectors/NotificationConnector.cs

@@ -3,70 +3,14 @@
 public abstract class NotificationConnector : GlobalBase
 {
     public readonly NotificationConnectorType notificationConnectorType;
-    private DateTime? _notificationRequested = null;
-    private readonly Thread? _notificationBufferThread = null;
-    private const int NoChangeTimeout = 3, BiggestInterval = 30;
-    private List<KeyValuePair<string, string>> _notifications = new();
 
     protected NotificationConnector(GlobalBase clone, NotificationConnectorType notificationConnectorType) : base(clone)
     {
         Log($"Creating notificationConnector {Enum.GetName(notificationConnectorType)}");
         this.notificationConnectorType = notificationConnectorType;
-        
-        
-        if (TrangaSettings.bufferLibraryUpdates)
-        {
-            _notificationBufferThread = new(CheckNotificationBuffer);
-            _notificationBufferThread.Start();
-        }
-    }
-    
-    private void CheckNotificationBuffer()
-    {
-        while (true)
-        {
-            if (_notificationRequested is not null && DateTime.Now.Subtract((DateTime)_notificationRequested) > TimeSpan.FromMinutes(NoChangeTimeout)) //If no updates have been requested for NoChangeTimeout minutes, update library
-            {
-                string[] uniqueTitles = _notifications.DistinctBy(n => n.Key).Select(n => n.Key).ToArray();
-                Log($"Notification Buffer sending! Notifications: {string.Join(", ", uniqueTitles)}");
-                foreach (string ut in uniqueTitles)
-                {
-                    string[] texts = _notifications.Where(n => n.Key == ut).Select(n => n.Value).ToArray();
-                    SendNotificationInternal($"{ut} ({texts.Length})", string.Join('\n', texts));
-                }
-                _notificationRequested = null;
-            }
-            Thread.Sleep(100);
-        }
     }
     
     public enum NotificationConnectorType : byte { Gotify = 0, LunaSea = 1, Ntfy = 2 }
-
-    public void SendNotification(string title, string notificationText, bool buffer = false)
-    {
-        _notificationRequested ??= DateTime.Now;
-        if (!TrangaSettings.bufferLibraryUpdates || !buffer)
-        {
-            SendNotificationInternal(title, notificationText);
-            return;
-        }
-        _notifications.Add(new(title, notificationText));
-        if (_notificationRequested is not null &&
-                  DateTime.Now.Subtract((DateTime)_notificationRequested) > TimeSpan.FromMinutes(BiggestInterval)) //If the last update has been more than BiggestInterval minutes ago, update library
-        {
-            string[] uniqueTitles = _notifications.DistinctBy(n => n.Key).Select(n => n.Key).ToArray();
-            foreach (string ut in uniqueTitles)
-            {
-                string[] texts = _notifications.Where(n => n.Key == ut).Select(n => n.Value).ToArray();
-                SendNotificationInternal(ut, string.Join('\n', texts));
-            }
-            _notificationRequested = null;
-        }
-        else if(_notificationRequested is not null)
-        {
-            Log($"Buffering Notifications (Updates in latest {((DateTime)_notificationRequested).Add(TimeSpan.FromMinutes(BiggestInterval)).Subtract(DateTime.Now)} or {((DateTime)_notificationRequested).Add(TimeSpan.FromMinutes(NoChangeTimeout)).Subtract(DateTime.Now)})");
-        }
-    }
     
-    protected abstract void SendNotificationInternal(string title, string notificationText);
+    public abstract void SendNotification(string title, string notificationText);
 }

Tranga/NotificationConnectors/Ntfy.cs

@@ -54,7 +54,7 @@ public class Ntfy : NotificationConnector
         return $"Ntfy {endpoint} {topic}";
     }
 
-    protected override void SendNotificationInternal(string title, string notificationText)
+    public override void SendNotification(string title, string notificationText)
     {
         Log($"Sending notification: {title} - {notificationText}");
         MessageData message = new(title, topic, notificationText);

Tranga/Tranga.cs

@@ -34,7 +34,6 @@ public partial class Tranga : GlobalBase
         this._server = new Server(this);
         string[] emojis = { "(•‿•)", "(づ \u25d5‿\u25d5 )づ", "( \u02d8\u25bd\u02d8)っ\u2668", "=\uff3e\u25cf \u22cf \u25cf\uff3e=", "（ΦωΦ）", "(\u272a\u3268\u272a)", "( ﾉ･o･ )ﾉ", "（〜^\u2207^ )〜", "~(\u2267ω\u2266)~","૮ \u00b4• ﻌ \u00b4• ა", "(\u02c3ᆺ\u02c2)", "(=\ud83d\udf66 \u0f1d \ud83d\udf66=)"};
         SendNotifications("Tranga Started", emojis[Random.Shared.Next(0,emojis.Length-1)]);
-        Log(TrangaSettings.AsJObject().ToString());
     }
 
     public MangaConnector? GetConnector(string name)

Tranga/TrangaSettings.cs

@@ -15,8 +15,6 @@ public static class TrangaSettings
     public static string workingDirectory { get; private set; } = Path.Join(RuntimeInformation.IsOSPlatform(OSPlatform.Linux) ? "/usr/share" : Environment.GetFolderPath(Environment.SpecialFolder.ApplicationData), "tranga-api");
     public static int apiPortNumber { get; private set; } = 6531;
     public static string userAgent { get; private set; } = DefaultUserAgent;
-    public static bool bufferLibraryUpdates { get; private set; } = false;
-    public static bool bufferNotifications { get; private set; } = false;
     [JsonIgnore] public static string settingsFilePath => Path.Join(workingDirectory, "settings.json");
     [JsonIgnore] public static string libraryConnectorsFilePath => Path.Join(workingDirectory, "libraryConnectors.json");
     [JsonIgnore] public static string notificationConnectorsFilePath => Path.Join(workingDirectory, "notificationConnectors.json");
@@ -48,17 +46,15 @@ public static class TrangaSettings
         ExportSettings();
     }
 
-    public static void CreateOrUpdate(string? downloadDirectory = null, string? pWorkingDirectory = null, int? pApiPortNumber = null, string? pUserAgent = null, bool? pAprilFoolsMode = null, bool? pBufferLibraryUpdates = null, bool? pBufferNotifications = null)
+    public static void CreateOrUpdate(string? downloadDirectory = null, string? pWorkingDirectory = null, int? pApiPortNumber = null, string? pUserAgent = null, bool? pAprilFoolsMode = null)
     {
         if(pWorkingDirectory is null && File.Exists(settingsFilePath))
             LoadFromWorkingDirectory(workingDirectory);
-        downloadLocation = downloadDirectory ?? downloadLocation;
-        workingDirectory = pWorkingDirectory ?? workingDirectory;
-        apiPortNumber = pApiPortNumber ?? apiPortNumber;
-        userAgent = pUserAgent ?? userAgent;
-        aprilFoolsMode = pAprilFoolsMode ?? aprilFoolsMode;
-        bufferLibraryUpdates = pBufferLibraryUpdates ?? bufferLibraryUpdates;
-        bufferNotifications = pBufferNotifications ?? bufferNotifications;
+        TrangaSettings.downloadLocation = downloadDirectory ?? TrangaSettings.downloadLocation;
+        TrangaSettings.workingDirectory = pWorkingDirectory ?? TrangaSettings.workingDirectory;
+        TrangaSettings.apiPortNumber = pApiPortNumber ?? TrangaSettings.apiPortNumber;
+        TrangaSettings.userAgent = pUserAgent ?? TrangaSettings.userAgent;
+        TrangaSettings.aprilFoolsMode = pAprilFoolsMode ?? TrangaSettings.aprilFoolsMode;
         Directory.CreateDirectory(downloadLocation);
         Directory.CreateDirectory(workingDirectory);
         ExportSettings();
@@ -94,7 +90,7 @@ public static class TrangaSettings
 
     public static void UpdateAprilFoolsMode(bool enabled)
     {
-        aprilFoolsMode = enabled;
+        TrangaSettings.aprilFoolsMode = enabled;
         ExportSettings();
     }
 
@@ -106,10 +102,10 @@ public static class TrangaSettings
         else
             Directory.CreateDirectory(newPath);
         
-        if (moveFiles && Directory.Exists(downloadLocation))
-            Directory.Move(downloadLocation, newPath);
+        if (moveFiles && Directory.Exists(TrangaSettings.downloadLocation))
+            Directory.Move(TrangaSettings.downloadLocation, newPath);
 
-        downloadLocation = newPath;
+        TrangaSettings.downloadLocation = newPath;
         ExportSettings();
     }
 
@@ -120,26 +116,26 @@ public static class TrangaSettings
                 GroupRead | GroupWrite | None | OtherRead | OtherWrite | UserRead | UserWrite);
         else
             Directory.CreateDirectory(newPath);
-        Directory.Move(workingDirectory, newPath);
-        workingDirectory = newPath;
+        Directory.Move(TrangaSettings.workingDirectory, newPath);
+        TrangaSettings.workingDirectory = newPath;
         ExportSettings();
     }
 
     public static void UpdateUserAgent(string? customUserAgent)
     {
-        userAgent = customUserAgent ?? DefaultUserAgent;
+        TrangaSettings.userAgent = customUserAgent ?? DefaultUserAgent;
         ExportSettings();
     }
 
     public static void UpdateRateLimit(RequestType requestType, int newLimit)
     {
-        requestLimits[requestType] = newLimit;
+        TrangaSettings.requestLimits[requestType] = newLimit;
         ExportSettings();
     }
 
     public static void ResetRateLimits()
     {
-        requestLimits = DefaultRequestLimits;
+        TrangaSettings.requestLimits = DefaultRequestLimits;
         ExportSettings();
     }
 
@@ -158,15 +154,13 @@ public static class TrangaSettings
     public static JObject AsJObject()
     {
         JObject jobj = new JObject();
-        jobj.Add("downloadLocation", JToken.FromObject(downloadLocation));
-        jobj.Add("workingDirectory", JToken.FromObject(workingDirectory));
-        jobj.Add("apiPortNumber", JToken.FromObject(apiPortNumber));
-        jobj.Add("userAgent", JToken.FromObject(userAgent));
-        jobj.Add("aprilFoolsMode", JToken.FromObject(aprilFoolsMode));
-        jobj.Add("version", JToken.FromObject(version));
-        jobj.Add("requestLimits", JToken.FromObject(requestLimits));
-        jobj.Add("bufferLibraryUpdates", JToken.FromObject(bufferLibraryUpdates));
-        jobj.Add("bufferNotifications", JToken.FromObject(bufferNotifications));
+        jobj.Add("downloadLocation", JToken.FromObject(TrangaSettings.downloadLocation));
+        jobj.Add("workingDirectory", JToken.FromObject(TrangaSettings.workingDirectory));
+        jobj.Add("apiPortNumber", JToken.FromObject(TrangaSettings.apiPortNumber));
+        jobj.Add("userAgent", JToken.FromObject(TrangaSettings.userAgent));
+        jobj.Add("aprilFoolsMode", JToken.FromObject(TrangaSettings.aprilFoolsMode));
+        jobj.Add("version", JToken.FromObject(TrangaSettings.version));
+        jobj.Add("requestLimits", JToken.FromObject(TrangaSettings.requestLimits));
         return jobj;
     }
 
@@ -176,20 +170,16 @@ public static class TrangaSettings
     {
         JObject jobj = JObject.Parse(serialized);
         if (jobj.TryGetValue("downloadLocation", out JToken? dl))
-            downloadLocation = dl.Value<string>()!;
+            TrangaSettings.downloadLocation = dl.Value<string>()!;
         if (jobj.TryGetValue("workingDirectory", out JToken? wd))
-            workingDirectory = wd.Value<string>()!;
+            TrangaSettings.workingDirectory = wd.Value<string>()!;
         if (jobj.TryGetValue("apiPortNumber", out JToken? apn))
-            apiPortNumber = apn.Value<int>();
+            TrangaSettings.apiPortNumber = apn.Value<int>();
         if (jobj.TryGetValue("userAgent", out JToken? ua))
-            userAgent = ua.Value<string>()!;
+            TrangaSettings.userAgent = ua.Value<string>()!;
         if (jobj.TryGetValue("aprilFoolsMode", out JToken? afm))
-            aprilFoolsMode = afm.Value<bool>()!;
+            TrangaSettings.aprilFoolsMode = afm.Value<bool>()!;
         if (jobj.TryGetValue("requestLimits", out JToken? rl))
-            requestLimits = rl.ToObject<Dictionary<RequestType, int>>()!;
-        if (jobj.TryGetValue("bufferLibraryUpdates", out JToken? blu))
-            bufferLibraryUpdates = blu.Value<bool>()!;
-        if (jobj.TryGetValue("bufferNotifications", out JToken? bn))
-            bufferNotifications = bn.Value<bool>()!;
+            TrangaSettings.requestLimits = rl.ToObject<Dictionary<RequestType, int>>()!;
     }
 }