using MediaBrowser.Common; using MediaBrowser.Common.Configuration; using Microsoft.Extensions.Logging; using System; using System.Collections.Generic; using System.Threading; using System.Threading.Tasks; using MediaBrowser.Common.Progress; using MediaBrowser.Model.Tasks; namespace Emby.Server.Implementations.ScheduledTasks { /// /// Plugin Update Task /// public class SystemUpdateTask : IScheduledTask { /// /// The _app host /// private readonly IApplicationHost _appHost; /// /// Gets or sets the configuration manager. /// /// The configuration manager. private IConfigurationManager ConfigurationManager { get; set; } /// /// Gets or sets the logger. /// /// The logger. private ILogger Logger { get; set; } /// /// Initializes a new instance of the class. /// /// The app host. /// The configuration manager. /// The logger. public SystemUpdateTask(IApplicationHost appHost, IConfigurationManager configurationManager, ILogger logger) { _appHost = appHost; ConfigurationManager = configurationManager; Logger = logger; } /// /// Creates the triggers that define when the task will run /// /// IEnumerable{BaseTaskTrigger}. public IEnumerable GetDefaultTriggers() { return new[] { // At startup new TaskTriggerInfo {Type = TaskTriggerInfo.TriggerStartup}, // Every so often new TaskTriggerInfo { Type = TaskTriggerInfo.TriggerInterval, IntervalTicks = TimeSpan.FromHours(24).Ticks} }; } /// /// Returns the task to be executed /// /// The cancellation token. /// The progress. /// Task. public async Task Execute(CancellationToken cancellationToken, IProgress progress) { // Create a progress object for the update check var updateInfo = await _appHost.CheckForApplicationUpdate(cancellationToken, new SimpleProgress()).ConfigureAwait(false); if (!updateInfo.IsUpdateAvailable) { Logger.LogDebug("No application update available."); return; } cancellationToken.ThrowIfCancellationRequested(); if (!_appHost.CanSelfUpdate) return; if (ConfigurationManager.CommonConfiguration.EnableAutoUpdate) { Logger.LogInformation("Update Revision {0} available. Updating...", updateInfo.AvailableVersion); await _appHost.UpdateApplication(updateInfo.Package, cancellationToken, progress).ConfigureAwait(false); } else { Logger.LogInformation("A new version of " + _appHost.Name + " is available."); } } /// /// Gets the name of the task /// /// The name. public string Name { get { return "Check for application updates"; } } /// /// Gets the description. /// /// The description. public string Description { get { return "Downloads and installs application updates."; } } /// /// Gets the category. /// /// The category. public string Category { get { return "Application"; } } public string Key { get { return "SystemUpdateTask"; } } } }