Tai/Aberwyn
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

More torrent and omdb

Browse Source
This commit is contained in:
Elias Jansson
2025-08-20 00:39:19 +02:00
parent a97f31e405
commit f53c87c50c
12 changed files with 1703 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
Aberwyn/Data/RssProcessor.cs
View File

@@ -12,14 +12,16 @@ namespace Aberwyn.Data
private readonly ILogger<RssProcessor> _logger;
private readonly HttpClient _httpClient;
private readonly HdTorrentsTrackerScraper _trackerScraper;
private readonly MovieMetadataService _movieMetadataService;
public RssProcessor(ApplicationDbContext context, ILogger<RssProcessor> logger,
HttpClient httpClient, HdTorrentsTrackerScraper trackerScraper)
HttpClient httpClient, HdTorrentsTrackerScraper trackerScraper, MovieMetadataService movieMetadataService)
{
_context = context;
_logger = logger;
_httpClient = httpClient;
_trackerScraper = trackerScraper;
_movieMetadataService = movieMetadataService;
}
public async Task ProcessRssFeeds()
@@ -77,6 +79,13 @@ namespace Aberwyn.Data
Console.WriteLine($"Scraped stats for {torrentItem.Title}: S:{seeders} L:{leechers} C:{completed}");
}
var metadata = await _movieMetadataService.GetMovieAsync(torrentItem.MovieName, torrentItem.Year);
if (metadata != null)
{
torrentItem.Metadata = metadata;
}
_context.TorrentItems.Add(torrentItem);
var savedChanges = await _context.SaveChangesAsync();
Console.WriteLine($"SaveChanges returned: {savedChanges}");
@@ -87,6 +96,7 @@ namespace Aberwyn.Data
}
} else
{
var howLongAgo = DateTime.UtcNow.AddHours(-6);
if (torrentItem.PublishDate >= howLongAgo)
{