diff --git a/code/Executable/appsettings.Development.json b/code/Executable/appsettings.Development.json index b2dcdb67..8da7fb77 100644 --- a/code/Executable/appsettings.Development.json +++ b/code/Executable/appsettings.Development.json @@ -4,5 +4,8 @@ "Default": "Information", "Microsoft.Hosting.Lifetime": "Information" } + }, + "QuartzConfig": { + "BlockedTorrentTrigger": "0 0/1 * * * ?" } } diff --git a/code/Infrastructure/Verticals/BlockedTorrent/BlockedTorrentHandler.cs b/code/Infrastructure/Verticals/BlockedTorrent/BlockedTorrentHandler.cs index ca70605f..9fa7d5be 100644 --- a/code/Infrastructure/Verticals/BlockedTorrent/BlockedTorrentHandler.cs +++ b/code/Infrastructure/Verticals/BlockedTorrent/BlockedTorrentHandler.cs @@ -49,6 +49,15 @@ public sealed class BlockedTorrentHandler { QueueListResponse queueResponse = await ListQueuedTorrentsAsync(sonarrInstance, page); + if (totalRecords is 0) + { + totalRecords = queueResponse.TotalRecords; + + _logger.LogInformation( + "{items} items found in queue | {url}", + queueResponse.TotalRecords, sonarrInstance.Url); + } + foreach (Record record in queueResponse.Records) { var torrent = (await qBitClient.GetTorrentListAsync(new TorrentListQuery { Hashes = [record.DownloadId] })) @@ -69,11 +78,6 @@ public sealed class BlockedTorrentHandler { break; } - - if (totalRecords is 0) - { - totalRecords = queueResponse.TotalRecords; - } processedRecords += queueResponse.Records.Count; @@ -133,6 +137,8 @@ public sealed class BlockedTorrentHandler try { response.EnsureSuccessStatusCode(); + + _logger.LogInformation("queue item deleted | {record}", record.Title); } catch { @@ -157,6 +163,8 @@ public sealed class BlockedTorrentHandler try { response.EnsureSuccessStatusCode(); + + _logger.LogInformation("series search triggered | series id: {id}", seriesId); } catch {