diff --git a/API/Program.cs b/API/Program.cs index e76f53a..c507d4b 100644 --- a/API/Program.cs +++ b/API/Program.cs @@ -145,6 +145,8 @@ using (IServiceScope scope = app.Services.CreateScope()) Tranga.StartLogger(); +Tranga.AddDefaultWorkers(); + Tranga.PeriodicWorkerStarterThread.Start(app.Services); app.UseCors("AllowAll"); diff --git a/API/Tranga.cs b/API/Tranga.cs index 376b1f1..f50ac7a 100644 --- a/API/Tranga.cs +++ b/API/Tranga.cs @@ -40,7 +40,10 @@ public static class Tranga BasicConfigurator.Configure(); Log.Info("Logger Configured."); Log.Info(TRANGA); - + } + + internal static void AddDefaultWorkers() + { AddWorker(UpdateMetadataWorker); AddWorker(SendNotificationsWorker); AddWorker(UpdateChaptersDownloadedWorker); @@ -51,7 +54,12 @@ public static class Tranga } internal static HashSet AllWorkers { get; private set; } = new (); - public static void AddWorker(BaseWorker worker) => AllWorkers.Add(worker); + + public static void AddWorker(BaseWorker worker) + { + Log.Debug($"Adding {worker} to AllWorkers."); + AllWorkers.Add(worker); + } public static void AddWorkers(IEnumerable workers) { foreach (BaseWorker baseWorker in workers) @@ -67,6 +75,7 @@ public static class Tranga foreach (BaseWorker worker in baseWorkers) { StopWorker(worker); + Log.Debug($"Removing {removeWorker} from AllWorkers."); AllWorkers.Remove(worker); } }