Refactored Cache Cleanup code.

This commit is contained in:
Joseph Milazzo 2021-02-02 09:40:26 -06:00
parent 0f82b45b9d
commit e60f795410
2 changed files with 4 additions and 5 deletions

View File

@ -177,13 +177,13 @@ namespace API.Controllers
var username = User.GetUsername(); var username = User.GetUsername();
_logger.LogInformation($"Library {libraryId} is being deleted by {username}."); _logger.LogInformation($"Library {libraryId} is being deleted by {username}.");
var series = await _unitOfWork.SeriesRepository.GetSeriesForLibraryIdAsync(libraryId); var series = await _unitOfWork.SeriesRepository.GetSeriesForLibraryIdAsync(libraryId);
var volumes = (await _unitOfWork.SeriesRepository.GetVolumesForSeriesAsync(series.Select(x => x.Id).ToArray())) var chapterIds =
.Select(x => x.Id).ToArray(); await _unitOfWork.SeriesRepository.GetChapterIdsForSeriesAsync(series.Select(x => x.Id).ToArray());
var result = await _unitOfWork.LibraryRepository.DeleteLibrary(libraryId); var result = await _unitOfWork.LibraryRepository.DeleteLibrary(libraryId);
if (result && volumes.Any()) if (result && chapterIds.Any())
{ {
_taskScheduler.CleanupVolumes(volumes); _taskScheduler.CleanupChapters(chapterIds);
} }
return Ok(result); return Ok(result);

View File

@ -36,7 +36,6 @@ namespace API.Controllers
public async Task<ActionResult<bool>> DeleteSeries(int seriesId) public async Task<ActionResult<bool>> DeleteSeries(int seriesId)
{ {
var username = User.GetUsername(); var username = User.GetUsername();
//var volumes = (await _unitOfWork.SeriesRepository.GetVolumesForSeriesAsync(new []{seriesId})).Select(x => x.Id).ToArray();
var chapterIds = (await _unitOfWork.SeriesRepository.GetChapterIdsForSeriesAsync(new []{seriesId})); var chapterIds = (await _unitOfWork.SeriesRepository.GetChapterIdsForSeriesAsync(new []{seriesId}));
_logger.LogInformation($"Series {seriesId} is being deleted by {username}."); _logger.LogInformation($"Series {seriesId} is being deleted by {username}.");
var result = await _unitOfWork.SeriesRepository.DeleteSeriesAsync(seriesId); var result = await _unitOfWork.SeriesRepository.DeleteSeriesAsync(seriesId);