diff --git a/app/Service/MediaProcessing/MovieProcessingService.php b/app/Service/MediaProcessing/MovieProcessingService.php index d380930..03937b0 100644 --- a/app/Service/MediaProcessing/MovieProcessingService.php +++ b/app/Service/MediaProcessing/MovieProcessingService.php @@ -617,13 +617,15 @@ class MovieProcessingService implements ProcessingInterface $this->getDetails($itemToFetch); $movie = Movie::where('tmdb_id', $item->tmdb_id)->first(); - $recommendedMovie = Movie::where('tmdb_id', $tmdbSimilarMovie['id'])->first(); + $similarMovie = Movie::where('tmdb_id', $tmdbSimilarMovie['id'])->first(); MovieSimilar::create([ 'movie_id' => $movie->id, - 'similar_movie_id' => $recommendedMovie->id, + 'similar_movie_id' => $similarMovie->id, ]); } + + $this->removeElementFromRemainingJobs($item->tmdb_id, ItemToFetchJobs::JOB_SIMILAR); } private function processMovieCollection(int $movieId, $belongsToCollection)