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

Fix new Workers not getting added.

Browse Source
This commit is contained in:
glax
2025-09-04 23:02:24 +02:00
parent c8be88d645
commit 2d662c269b
2 changed files with 10 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
API/Tranga.cs
View File

@@ -145,6 +145,12 @@ public static class Tranga
private static Action AfterWork(BaseWorker worker, Action? callback = null) => () =>
{
Log.Debug($"AfterWork {worker}");
if (RunningWorkers.TryGetValue(worker, out Task<BaseWorker[]>? task))
{
BaseWorker[] newWorkers = task.Result;
Log.Debug($"Resulted in {newWorkers.Length} new Workers.");
AddWorkers(newWorkers);
}
RunningWorkers.Remove(worker, out _);
callback?.Invoke();
};

4
API/Workers/PeriodicWorkers/StartNewChapterDownloadsWorker.cs
View File

@@ -14,12 +14,16 @@ public class StartNewChapterDownloadsWorker(TimeSpan? interval = null, IEnumerab
public TimeSpan Interval { get; set; } = interval ?? TimeSpan.FromMinutes(1);
protected override async Task<BaseWorker[]> DoWorkInternal()
{
Log.Debug("Checking for missing chapters...");
// Get missing chapters
List<MangaConnectorId<Chapter>> missingChapters = await DbContext.MangaConnectorToChapter
.Include(id => id.Obj)
.Where(id => id.Obj.Downloaded == false && id.UseForDownload)
.ToListAsync(CancellationToken);
Log.Debug($"Found {missingChapters.Count} missing downloads.");
// Create new jobs
List<BaseWorker> newWorkers = missingChapters.Select(mcId => new DownloadChapterFromMangaconnectorWorker(mcId)).ToList<BaseWorker>();