moved jobs around again ;)

NzbDrone.Core/Jobs/Implementations/RssSyncJob.cs

@@ -0,0 +1,94 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using NLog;
+using NzbDrone.Core.Configuration;
+using NzbDrone.Core.DecisionEngine;
+using NzbDrone.Core.Download;
+using NzbDrone.Core.Indexers;
+using NzbDrone.Core.Model;
+using NzbDrone.Core.Model.Notification;
+
+namespace NzbDrone.Core.Jobs.Implementations
+{
+    public class RssSyncJob : IJob
+    {
+        private readonly DownloadProvider _downloadProvider;
+        private readonly IIndexerService _indexerService;
+        private readonly MonitoredEpisodeSpecification _isMonitoredEpisodeSpecification;
+        private readonly AllowedDownloadSpecification _allowedDownloadSpecification;
+        private readonly UpgradeHistorySpecification _upgradeHistorySpecification;
+        private readonly IConfigService _configService;
+
+
+        private static readonly Logger Logger = LogManager.GetCurrentClassLogger();
+
+        public RssSyncJob(DownloadProvider downloadProvider, IIndexerService indexerService,
+            MonitoredEpisodeSpecification isMonitoredEpisodeSpecification, AllowedDownloadSpecification allowedDownloadSpecification, 
+            UpgradeHistorySpecification upgradeHistorySpecification, IConfigService configService)
+        {
+            _downloadProvider = downloadProvider;
+            _indexerService = indexerService;
+            _isMonitoredEpisodeSpecification = isMonitoredEpisodeSpecification;
+            _allowedDownloadSpecification = allowedDownloadSpecification;
+            _upgradeHistorySpecification = upgradeHistorySpecification;
+            _configService = configService;
+        }
+
+        public string Name
+        {
+            get { return "RSS Sync"; }
+        }
+
+        public TimeSpan DefaultInterval
+        {
+            get { return TimeSpan.FromMinutes(_configService.RssSyncInterval); }
+        }
+
+        public void Start(ProgressNotification notification, dynamic options)
+        {
+            var reports = new List<EpisodeParseResult>();
+
+            notification.CurrentMessage = "Fetching RSS";
+
+            Parallel.ForEach(_indexerService.GetEnabledIndexers(), indexer =>
+            {
+                try
+                {
+                    reports.AddRange(indexer.FetchRss());
+                }
+                catch (Exception e)
+                {
+                    Logger.ErrorException("An error has occurred while fetching items from " + indexer.Name, e);
+                }
+            });
+
+            Logger.Debug("Finished fetching reports from all indexers. Total {0}", reports.Count);
+
+            notification.CurrentMessage = "Processing downloaded RSS";
+
+            foreach (var episodeParseResult in reports)
+            {
+                try
+                {
+                    if (_isMonitoredEpisodeSpecification.IsSatisfiedBy(episodeParseResult) &&
+                        _allowedDownloadSpecification.IsSatisfiedBy(episodeParseResult) == ReportRejectionType.None &&
+                        _upgradeHistorySpecification.IsSatisfiedBy(episodeParseResult))
+                    {
+                        _downloadProvider.DownloadReport(episodeParseResult);
+                    }
+                }
+                catch (Exception e)
+                {
+                    Logger.ErrorException("An error has occurred while processing parse result items from " + episodeParseResult, e);
+                }
+            }
+
+            notification.CurrentMessage = "RSS Sync Completed";
+
+            Logger.Info("RSS Sync completed");
+
+        }
+    }
+}