Job Run pass context to add new Data

This commit is contained in:
Glax 2024-12-17 17:24:25 +01:00
parent 16dd1ffa97
commit 80190e1286

View File

@ -12,10 +12,11 @@ public class DownloadNewChaptersJob(ulong recurrenceMs, string mangaId, string?
public string MangaId { get; init; } = mangaId; public string MangaId { get; init; } = mangaId;
public virtual Manga Manga { get; init; } public virtual Manga Manga { get; init; }
protected override IEnumerable<Job> RunInternal() protected override IEnumerable<Job> RunInternal(PgsqlContext context)
{ {
MangaConnector connector = Manga.MangaConnector; MangaConnector connector = Manga.MangaConnector;
Chapter[] newChapters = connector.GetNewChapters(Manga); Chapter[] newChapters = connector.GetNewChapters(Manga);
context.Chapters.AddRangeAsync(newChapters).Wait();
return newChapters.Select(chapter => new DownloadSingleChapterJob(chapter.ChapterId, this.JobId)); return newChapters.Select(chapter => new DownloadSingleChapterJob(chapter.ChapterId, this.JobId));
} }
} }