using MediaBrowser.Common; using MediaBrowser.Common.Updates; using MediaBrowser.Model.Net; using System; using System.Collections.Generic; using System.IO; using System.Linq; using System.Threading; using System.Threading.Tasks; using MediaBrowser.Common.Progress; using MediaBrowser.Model.Tasks; using Microsoft.Extensions.Logging; namespace Emby.Server.Implementations.ScheduledTasks { /// /// Plugin Update Task /// public class PluginUpdateTask : IScheduledTask, IConfigurableScheduledTask { /// /// The _logger /// private readonly ILogger _logger; private readonly IInstallationManager _installationManager; private readonly IApplicationHost _appHost; public PluginUpdateTask(ILogger logger, IInstallationManager installationManager, IApplicationHost appHost) { _logger = logger; _installationManager = installationManager; _appHost = appHost; } /// /// 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} }; } /// /// Update installed plugins /// /// The cancellation token. /// The progress. /// Task. public async Task Execute(CancellationToken cancellationToken, IProgress progress) { progress.Report(0); var packagesToInstall = (await _installationManager.GetAvailablePluginUpdates(typeof(PluginUpdateTask).Assembly.GetName().Version, true, cancellationToken).ConfigureAwait(false)).ToList(); progress.Report(10); var numComplete = 0; foreach (var package in packagesToInstall) { cancellationToken.ThrowIfCancellationRequested(); try { await _installationManager.InstallPackage(package, true, new SimpleProgress(), cancellationToken).ConfigureAwait(false); } catch (OperationCanceledException) { // InstallPackage has it's own inner cancellation token, so only throw this if it's ours if (cancellationToken.IsCancellationRequested) { throw; } } catch (HttpException ex) { _logger.LogError(ex, "Error downloading {0}", package.name); } catch (IOException ex) { _logger.LogError(ex, "Error updating {0}", package.name); } // Update progress lock (progress) { numComplete++; double percent = numComplete; percent /= packagesToInstall.Count; progress.Report(90 * percent + 10); } } progress.Report(100); } /// /// Gets the name of the task /// /// The name. public string Name => "Check for plugin updates"; /// /// Gets the description. /// /// The description. public string Description => "Downloads and installs updates for plugins that are configured to update automatically."; public string Category => "Application"; public string Key => "PluginUpdates"; public bool IsHidden => false; public bool IsEnabled => true; public bool IsLogged => true; } }