glax/Tranga
1
0
Fork 0
mirror of https://github.com/C9Glax/tranga.git synced 2025-09-10 03:48:19 +02:00
Code Issues Actions Packages Projects Releases Wiki Activity

Move Configuration of Workers to separate method

Browse Source
This commit is contained in:
glax
2025-07-20 19:19:06 +02:00
parent 9d84716278
commit fb004657eb
2 changed files with 13 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
API/Program.cs
View File

@@ -145,6 +145,8 @@ using (IServiceScope scope = app.Services.CreateScope())
Tranga.StartLogger(); Tranga.StartLogger();
Tranga.AddDefaultWorkers();
Tranga.PeriodicWorkerStarterThread.Start(app.Services); Tranga.PeriodicWorkerStarterThread.Start(app.Services);
app.UseCors("AllowAll"); app.UseCors("AllowAll");

13
API/Tranga.cs
View File

@@ -40,7 +40,10 @@ public static class Tranga
BasicConfigurator.Configure(); BasicConfigurator.Configure();
Log.Info("Logger Configured."); Log.Info("Logger Configured.");
Log.Info(TRANGA); Log.Info(TRANGA);
}
internal static void AddDefaultWorkers()
{
AddWorker(UpdateMetadataWorker); AddWorker(UpdateMetadataWorker);
AddWorker(SendNotificationsWorker); AddWorker(SendNotificationsWorker);
AddWorker(UpdateChaptersDownloadedWorker); AddWorker(UpdateChaptersDownloadedWorker);
@@ -51,7 +54,12 @@ public static class Tranga
} }
internal static HashSet<BaseWorker> AllWorkers { get; private set; } = new (); internal static HashSet<BaseWorker> 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<BaseWorker> workers) public static void AddWorkers(IEnumerable<BaseWorker> workers)
{ {
foreach (BaseWorker baseWorker in workers) foreach (BaseWorker baseWorker in workers)
@@ -67,6 +75,7 @@ public static class Tranga
foreach (BaseWorker worker in baseWorkers) foreach (BaseWorker worker in baseWorkers)
{ {
StopWorker(worker); StopWorker(worker);
Log.Debug($"Removing {removeWorker} from AllWorkers.");
AllWorkers.Remove(worker); AllWorkers.Remove(worker);
} }
} }