diff --git a/src/NzbDrone.Core/Movies/Collections/MovieCollectionService.cs b/src/NzbDrone.Core/Movies/Collections/MovieCollectionService.cs index efcaab428..3797b2e92 100644 --- a/src/NzbDrone.Core/Movies/Collections/MovieCollectionService.cs +++ b/src/NzbDrone.Core/Movies/Collections/MovieCollectionService.cs @@ -21,13 +21,13 @@ public interface IMovieCollectionService public class MovieCollectionService : IMovieCollectionService, IHandleAsync { private readonly IMovieCollectionRepository _repo; - private readonly IMovieMetadataService _movieMetadataService; + private readonly IMovieService _movieService; private readonly IEventAggregator _eventAggregator; - public MovieCollectionService(IMovieCollectionRepository repo, IMovieMetadataService movieMetadataService, IEventAggregator eventAggregator) + public MovieCollectionService(IMovieCollectionRepository repo, IMovieService movieService, IEventAggregator eventAggregator) { _repo = repo; - _movieMetadataService = movieMetadataService; + _movieService = movieService; _eventAggregator = eventAggregator; } @@ -96,16 +96,16 @@ public void HandleAsync(MoviesDeletedEvent message) foreach (var collectionTmdbId in collections) { - if (collectionTmdbId == 0 || _movieMetadataService.GetMoviesByCollectionTmdbId(collectionTmdbId).Any()) + if (collectionTmdbId == 0 || _movieService.GetMoviesByCollectionTmdbId(collectionTmdbId).Any()) { continue; } var collection = FindByTmdbId(collectionTmdbId); - _eventAggregator.PublishEvent(new CollectionDeletedEvent(collection)); - _repo.Delete(collectionTmdbId); + + _eventAggregator.PublishEvent(new CollectionDeletedEvent(collection)); } }