1 files changed, 101 insertions, 0 deletions
diff --git a/Emby.Server.Implementations/FileOrganization/OrganizerScheduledTask.cs b/Emby.Server.Implementations/FileOrganization/OrganizerScheduledTask.cs
new file mode 100644
index 000000000..5be7ba7ad
--- /dev/null
+++ b/Emby.Server.Implementations/FileOrganization/OrganizerScheduledTask.cs
@@ -0,0 +1,101 @@
+using MediaBrowser.Controller.Configuration;
+using MediaBrowser.Controller.FileOrganization;
+using MediaBrowser.Controller.Library;
+using MediaBrowser.Controller.Providers;
+using MediaBrowser.Model.FileOrganization;
+using MediaBrowser.Model.Logging;
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using MediaBrowser.Common.IO;
+using MediaBrowser.Controller.IO;
+using MediaBrowser.Model.IO;
+using MediaBrowser.Model.Tasks;
+
+namespace Emby.Server.Implementations.FileOrganization
+{
+    public class OrganizerScheduledTask : IScheduledTask, IConfigurableScheduledTask
+    {
+        private readonly ILibraryMonitor _libraryMonitor;
+        private readonly ILibraryManager _libraryManager;
+        private readonly ILogger _logger;
+        private readonly IFileSystem _fileSystem;
+        private readonly IServerConfigurationManager _config;
+        private readonly IFileOrganizationService _organizationService;
+        private readonly IProviderManager _providerManager;
+
+        public OrganizerScheduledTask(ILibraryMonitor libraryMonitor, ILibraryManager libraryManager, ILogger logger, IFileSystem fileSystem, IServerConfigurationManager config, IFileOrganizationService organizationService, IProviderManager providerManager)
+        {
+            _libraryMonitor = libraryMonitor;
+            _libraryManager = libraryManager;
+            _logger = logger;
+            _fileSystem = fileSystem;
+            _config = config;
+            _organizationService = organizationService;
+            _providerManager = providerManager;
+        }
+
+        public string Name
+        {
+            get { return "Organize new media files"; }
+        }
+
+        public string Description
+        {
+            get { return "Processes new files available in the configured watch folder."; }
+        }
+
+        public string Category
+        {
+            get { return "Library"; }
+        }
+
+        private AutoOrganizeOptions GetAutoOrganizeOptions()
+        {
+            return _config.GetAutoOrganizeOptions();
+        }
+
+        public async Task Execute(CancellationToken cancellationToken, IProgress<double> progress)
+        {
+            if (GetAutoOrganizeOptions().TvOptions.IsEnabled)
+            {
+                await new TvFolderOrganizer(_libraryManager, _logger, _fileSystem, _libraryMonitor, _organizationService, _config, _providerManager)
+                    .Organize(GetAutoOrganizeOptions(), cancellationToken, progress).ConfigureAwait(false);
+            }
+        }
+
+        /// <summary>
+        /// Creates the triggers that define when the task will run
+        /// </summary>
+        /// <returns>IEnumerable{BaseTaskTrigger}.</returns>
+        public IEnumerable<TaskTriggerInfo> GetDefaultTriggers()
+        {
+            return new[] { 
+            
+                // Every so often
+                new TaskTriggerInfo { Type = TaskTriggerInfo.TriggerInterval, IntervalTicks = TimeSpan.FromMinutes(5).Ticks}
+            };
+        }
+
+        public bool IsHidden
+        {
+            get { return !GetAutoOrganizeOptions().TvOptions.IsEnabled; }
+        }
+
+        public bool IsEnabled
+        {
+            get { return GetAutoOrganizeOptions().TvOptions.IsEnabled; }
+        }
+
+        public bool IsLogged
+        {
+            get { return false; }
+        }
+
+        public string Key
+        {
+            get { return "AutoOrganize"; }
+        }
+    }
+}