From dcd06597a7cc1d4a7829ed75e0a6b1e52fd5c10e Mon Sep 17 00:00:00 2001 From: Luke Pulverenti Date: Tue, 13 Dec 2016 13:41:36 -0500 Subject: add missing files --- .../Migrations/LibraryScanMigration.cs | 49 ++++++++++++++++++++++ 1 file changed, 49 insertions(+) create mode 100644 Emby.Server.Implementations/Migrations/LibraryScanMigration.cs (limited to 'Emby.Server.Implementations/Migrations/LibraryScanMigration.cs') diff --git a/Emby.Server.Implementations/Migrations/LibraryScanMigration.cs b/Emby.Server.Implementations/Migrations/LibraryScanMigration.cs new file mode 100644 index 000000000..c494abc0b --- /dev/null +++ b/Emby.Server.Implementations/Migrations/LibraryScanMigration.cs @@ -0,0 +1,49 @@ +using System; +using System.Collections.Generic; +using System.Threading; +using System.Threading.Tasks; +using MediaBrowser.Common.Net; +using MediaBrowser.Common.Updates; +using MediaBrowser.Controller; +using MediaBrowser.Controller.Configuration; +using MediaBrowser.Model.Logging; +using MediaBrowser.Model.Serialization; +using MediaBrowser.Model.Tasks; +using MediaBrowser.Model.Updates; +using System.Linq; + +namespace Emby.Server.Implementations.Migrations +{ + public class LibraryScanMigration : IVersionMigration + { + private readonly IServerConfigurationManager _config; + private readonly ITaskManager _taskManager; + + public LibraryScanMigration(IServerConfigurationManager config, ITaskManager taskManager) + { + _config = config; + _taskManager = taskManager; + } + + public async Task Run() + { + var name = "LibraryScan6"; + + if (!_config.Configuration.Migrations.Contains(name, StringComparer.OrdinalIgnoreCase)) + { + Task.Run(() => + { + var task = _taskManager.ScheduledTasks.Select(i => i.ScheduledTask) + .First(i => string.Equals(i.Key, "RefreshLibrary", StringComparison.OrdinalIgnoreCase)); + + _taskManager.QueueScheduledTask(task); + }); + + var list = _config.Configuration.Migrations.ToList(); + list.Add(name); + _config.Configuration.Migrations = list.ToArray(); + _config.SaveConfiguration(); + } + } + } +} -- cgit v1.2.3