using System; using System.Collections.Generic; using System.IO; using System.Linq; using System.Text; using NLog; using NzbDrone.Core.Helpers; using NzbDrone.Core.Model; using NzbDrone.Core.Repository; namespace NzbDrone.Core.Providers { public class RssItemProcessingProvider : IRssItemProcessingProvider { private ISeriesProvider _seriesProvider; private ISeasonProvider _seasonProvider; private IEpisodeProvider _episodeProvider; private IHistoryProvider _historyProvider; private IDownloadProvider _sabProvider; private IConfigProvider _configProvider; private IHttpProvider _httpProvider; private IDiskProvider _diskProvider; private static readonly Logger Logger = LogManager.GetCurrentClassLogger(); public RssItemProcessingProvider(ISeriesProvider seriesProvider, ISeasonProvider seasonProvider, IEpisodeProvider episodeProvider, IHistoryProvider historyProvider, IDownloadProvider sabProvider, IConfigProvider configProvider, IHttpProvider httpProvider, IDiskProvider diskProvider) { _seriesProvider = seriesProvider; _seasonProvider = seasonProvider; _episodeProvider = episodeProvider; _historyProvider = historyProvider; _sabProvider = sabProvider; _configProvider = configProvider; _httpProvider = httpProvider; _diskProvider = diskProvider; } #region IRssItemProcessingProvider Members public bool DownloadIfWanted(NzbInfoModel nzb, Indexer indexer) { //Do we want this item? try { if (nzb.IsPassworded()) { Logger.Debug("Skipping Passworded Report {0}", nzb.Title); return false; } var episodeParseResults = Parser.ParseEpisodeInfo(nzb.Title); if (episodeParseResults.Count() > 0) { ProcessStandardItem(nzb, indexer, episodeParseResults); return false; } //Todo: Try to handle Season X style naming if (episodeParseResults.Count() < 1) { Logger.Debug("Unsupported Title: {0}", nzb.Title); return false; } } catch (Exception ex) { Logger.Error("Unsupported Title: {0}", nzb.Title); Logger.ErrorException("Error Parsing NZB: " + ex.Message, ex); } return false; } public string GetTitleFix(List episodes, int seriesId) { var series = _seriesProvider.GetSeries(seriesId); int seasonNumber = 0; string episodeNumbers = String.Empty; string episodeTitles = String.Empty; foreach (var episode in episodes) { var episodeInDb = _episodeProvider.GetEpisode(seriesId, episode.SeasonNumber, episode.EpisodeNumber); if (episodeInDb == null) { //Todo: Handle this some other way? Logger.Debug("Episode Not found in Database, Fake it..."); //return String.Format("{0} - {1:00}x{2}", series.Title, episode.SeasonNumber, episode.EpisodeNumber); episodeInDb = new Episode { EpisodeNumber = episode.EpisodeNumber, Title = "TBA" }; } seasonNumber = episodeInDb.SeasonNumber; episodeNumbers = String.Format("{0}x{1:00}", episodeNumbers, episodeInDb.EpisodeNumber); episodeTitles = String.Format("{0} + {1}", episodeTitles, episodeInDb.Title); } episodeTitles = episodeTitles.Trim(' ', '+'); return String.Format("{0} - {1}{2} - {3}", series.Title, seasonNumber, episodeNumbers, episodeTitles); } #endregion private void ProcessStandardItem(NzbInfoModel nzb, Indexer indexer, List episodeParseResults) { //Will try to match via NormalizeTitle, if that fails it will look for a scene name and do a lookup for your shows var series = _seriesProvider.FindSeries(episodeParseResults[0].SeriesTitle); if (series == null) { //If we weren't able to find a title using the clean name, lets try again looking for a scene name series = _seriesProvider.GetSeries(SceneNameHelper.FindByName(episodeParseResults[0].SeriesTitle)); if (series == null) { Logger.Debug("Show is not being watched: {0}", episodeParseResults[0].SeriesTitle); return; } } Logger.Debug("Show is being watched: {0}", series.Title); nzb.TitleFix = GetTitleFix(episodeParseResults, series.SeriesId); //Get the TitleFix so we can use it later nzb.Proper = Parser.ParseProper(nzb.Title); nzb.Quality = Parser.ParseQuality(nzb.Title); nzb.TitleFix = String.Format("{0} [{1}]", nzb.TitleFix, nzb.Quality); //Add Quality to the titleFix //Loop through the list of the episodeParseResults to ensure that all the episodes are needed foreach (var episode in episodeParseResults) { //IsEpisodeWanted? var episodeModel = new EpisodeModel(); episodeModel.Proper = nzb.Proper; episodeModel.SeriesId = series.SeriesId; episodeModel.SeriesTitle = series.Title; episodeModel.Quality = nzb.Quality; episodeModel.SeasonNumber = episode.SeasonNumber; episodeModel.EpisodeNumber = episode.EpisodeNumber; if (!_episodeProvider.IsNeeded(episodeModel)) return; var titleFix = GetTitleFix(new List { episode }, episodeModel.SeriesId); titleFix = String.Format("{0} [{1}]", titleFix, nzb.Quality); //Add Quality to the titleFix if (!Convert.ToBoolean(_configProvider.GetValue("UseBlackhole", true, true))) if (_sabProvider.IsInQueue(titleFix)) return; } //If their is more than one episode in this NZB check to see if it has been added as a single NZB //Do we want to download the NZB Directly or Send to SABnzbd? if (Convert.ToBoolean(_configProvider.GetValue("UseBlackHole", true, true))) { var path = _configProvider.GetValue("BlackholeDirectory", String.Empty, true); if (String.IsNullOrEmpty(path)) { //Use the NZBDrone root Directory + /NZBs //path = CentralDispatch.StartupPath + "NZBs"; path = @"C:\Test\NZBs"; } if (_diskProvider.FolderExists(path)) { var filename = path + Path.DirectorySeparatorChar + nzb.TitleFix; if (_httpProvider.DownloadFile(nzb.Link.ToString(), filename)) AddToHistory(episodeParseResults, series, nzb, indexer); } else Logger.Error("Blackhole Directory doesn't exist, not saving NZB: '{0}'", path); } //Send it to SABnzbd else { if (episodeParseResults.Count > 1) { if (_sabProvider.IsInQueue(nzb.TitleFix)) return; } if (indexer.IndexerName != "Newzbin") { if (AddByUrl(nzb)) { AddToHistory(episodeParseResults, series, nzb, indexer); } } else { //AddById(episodeParseResults, series, nzb, indexer); } } } private bool AddByUrl(NzbInfoModel nzb) { return _sabProvider.AddByUrl(nzb.Link.ToString(), nzb.TitleFix); } private void AddToHistory(List episodeParseResults, Series series, NzbInfoModel nzb, Indexer indexer) { //We need to loop through the episodeParseResults so each episode in the NZB is properly handled foreach (var epr in episodeParseResults) { var episode = _episodeProvider.GetEpisode(series.SeriesId, epr.SeasonNumber, epr.EpisodeNumber); if (episode == null) { //Not sure how we got this far, so lets throw an exception throw new ArgumentOutOfRangeException(); } //Set episode status to grabbed episode.Status = EpisodeStatusType.Grabbed; //Add to History var history = new History(); history.Date = DateTime.Now; history.EpisodeId = episode.EpisodeId; history.IndexerId = indexer.IndexerId; history.IsProper = nzb.Proper; history.Quality = nzb.Quality; history.NzbTitle = nzb.Title; _historyProvider.Insert(history); } } } }