diff options
Diffstat (limited to 'MediaBrowser.ServerApplication/EntryPoints')
4 files changed, 475 insertions, 0 deletions
diff --git a/MediaBrowser.ServerApplication/EntryPoints/NewItemNotifier.cs b/MediaBrowser.ServerApplication/EntryPoints/NewItemNotifier.cs new file mode 100644 index 000000000..4a1f0ac74 --- /dev/null +++ b/MediaBrowser.ServerApplication/EntryPoints/NewItemNotifier.cs @@ -0,0 +1,148 @@ +using System.Windows; +using MediaBrowser.Controller.Entities; +using MediaBrowser.Controller.Library; +using MediaBrowser.Controller.Plugins; +using MediaBrowser.Model.Logging; +using MediaBrowser.ServerApplication.Controls; +using System.Collections.Generic; +using System.Linq; +using System.Threading; +using System.Windows.Controls.Primitives; + +namespace MediaBrowser.ServerApplication.EntryPoints +{ + /// <summary> + /// Class NewItemNotifier + /// </summary> + public class NewItemNotifier : IServerEntryPoint + { + /// <summary> + /// Holds the list of new items to display when the NewItemTimer expires + /// </summary> + private readonly List<BaseItem> _newlyAddedItems = new List<BaseItem>(); + + /// <summary> + /// The amount of time to wait before showing a new item notification + /// This allows us to group items together into one notification + /// </summary> + private const int NewItemDelay = 60000; + + /// <summary> + /// The current new item timer + /// </summary> + /// <value>The new item timer.</value> + private Timer NewItemTimer { get; set; } + + /// <summary> + /// The _library manager + /// </summary> + private readonly ILibraryManager _libraryManager; + + /// <summary> + /// The _logger + /// </summary> + private readonly ILogger _logger; + + /// <summary> + /// Initializes a new instance of the <see cref="NewItemNotifier" /> class. + /// </summary> + /// <param name="libraryManager">The library manager.</param> + /// <param name="logManager">The log manager.</param> + public NewItemNotifier(ILibraryManager libraryManager, ILogManager logManager) + { + _logger = logManager.GetLogger("NewItemNotifier"); + _libraryManager = libraryManager; + } + + /// <summary> + /// Runs this instance. + /// </summary> + public void Run() + { + _libraryManager.LibraryChanged += libraryManager_LibraryChanged; + } + + /// <summary> + /// Handles the LibraryChanged event of the libraryManager control. + /// </summary> + /// <param name="sender">The source of the event.</param> + /// <param name="e">The <see cref="ChildrenChangedEventArgs" /> instance containing the event data.</param> + void libraryManager_LibraryChanged(object sender, ChildrenChangedEventArgs e) + { + var newItems = e.ItemsAdded.Where(i => !i.IsFolder).ToList(); + + // Use a timer to prevent lots of these notifications from showing in a short period of time + if (newItems.Count > 0) + { + lock (_newlyAddedItems) + { + _newlyAddedItems.AddRange(newItems); + + if (NewItemTimer == null) + { + NewItemTimer = new Timer(NewItemTimerCallback, null, NewItemDelay, Timeout.Infinite); + } + else + { + NewItemTimer.Change(NewItemDelay, Timeout.Infinite); + } + } + } + } + + /// <summary> + /// Called when the new item timer expires + /// </summary> + /// <param name="state">The state.</param> + private void NewItemTimerCallback(object state) + { + List<BaseItem> newItems; + + // Lock the list and release all resources + lock (_newlyAddedItems) + { + newItems = _newlyAddedItems.ToList(); + _newlyAddedItems.Clear(); + + NewItemTimer.Dispose(); + NewItemTimer = null; + } + + // Show the notification + if (newItems.Count == 1) + { + Application.Current.Dispatcher.InvokeAsync(() => + { + var window = (MainWindow)Application.Current.MainWindow; + + window.Dispatcher.InvokeAsync(() => window.MbTaskbarIcon.ShowCustomBalloon(new ItemUpdateNotification(_logger) + { + DataContext = newItems[0] + + }, PopupAnimation.Slide, 6000)); + }); + } + else if (newItems.Count > 1) + { + Application.Current.Dispatcher.InvokeAsync(() => + { + var window = (MainWindow)Application.Current.MainWindow; + + window.Dispatcher.InvokeAsync(() => window.MbTaskbarIcon.ShowCustomBalloon(new MultiItemUpdateNotification(_logger) + { + DataContext = newItems + + }, PopupAnimation.Slide, 6000)); + }); + } + } + + /// <summary> + /// Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources. + /// </summary> + public void Dispose() + { + _libraryManager.LibraryChanged -= libraryManager_LibraryChanged; + } + } +} diff --git a/MediaBrowser.ServerApplication/EntryPoints/RefreshUsersMetadata.cs b/MediaBrowser.ServerApplication/EntryPoints/RefreshUsersMetadata.cs new file mode 100644 index 000000000..735a1f655 --- /dev/null +++ b/MediaBrowser.ServerApplication/EntryPoints/RefreshUsersMetadata.cs @@ -0,0 +1,41 @@ +using MediaBrowser.Controller.Library; +using MediaBrowser.Controller.Plugins; +using System.Threading; + +namespace MediaBrowser.ServerApplication.EntryPoints +{ + /// <summary> + /// Class RefreshUsersMetadata + /// </summary> + public class RefreshUsersMetadata : IServerEntryPoint + { + /// <summary> + /// The _user manager + /// </summary> + private readonly IUserManager _userManager; + + /// <summary> + /// Initializes a new instance of the <see cref="RefreshUsersMetadata" /> class. + /// </summary> + /// <param name="userManager">The user manager.</param> + public RefreshUsersMetadata(IUserManager userManager) + { + _userManager = userManager; + } + + /// <summary> + /// Runs this instance. + /// </summary> + public async void Run() + { + await _userManager.RefreshUsersMetadata(CancellationToken.None).ConfigureAwait(false); + } + + /// <summary> + /// Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources. + /// </summary> + public void Dispose() + { + } + } +} diff --git a/MediaBrowser.ServerApplication/EntryPoints/StartupWizard.cs b/MediaBrowser.ServerApplication/EntryPoints/StartupWizard.cs new file mode 100644 index 000000000..43d9018a1 --- /dev/null +++ b/MediaBrowser.ServerApplication/EntryPoints/StartupWizard.cs @@ -0,0 +1,65 @@ +using MediaBrowser.Common; +using MediaBrowser.Controller.Configuration; +using MediaBrowser.Controller.Library; +using MediaBrowser.Controller.Plugins; +using System.Linq; + +namespace MediaBrowser.ServerApplication.EntryPoints +{ + /// <summary> + /// Class StartupWizard + /// </summary> + public class StartupWizard : IServerEntryPoint + { + /// <summary> + /// The _app host + /// </summary> + private readonly IApplicationHost _appHost; + /// <summary> + /// The _user manager + /// </summary> + private readonly IUserManager _userManager; + + private readonly IServerConfigurationManager _configurationManager; + + /// <summary> + /// Initializes a new instance of the <see cref="StartupWizard" /> class. + /// </summary> + /// <param name="appHost">The app host.</param> + /// <param name="userManager">The user manager.</param> + public StartupWizard(IApplicationHost appHost, IUserManager userManager, IServerConfigurationManager configurationManager) + { + _appHost = appHost; + _userManager = userManager; + _configurationManager = configurationManager; + } + + /// <summary> + /// Runs this instance. + /// </summary> + public void Run() + { + if (_appHost.IsFirstRun) + { + LaunchStartupWizard(); + } + } + + /// <summary> + /// Launches the startup wizard. + /// </summary> + private void LaunchStartupWizard() + { + var user = _userManager.Users.FirstOrDefault(u => u.Configuration.IsAdministrator); + + App.OpenDashboardPage("wizardStart.html", user, _configurationManager); + } + + /// <summary> + /// Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources. + /// </summary> + public void Dispose() + { + } + } +} diff --git a/MediaBrowser.ServerApplication/EntryPoints/WebSocketEvents.cs b/MediaBrowser.ServerApplication/EntryPoints/WebSocketEvents.cs new file mode 100644 index 000000000..13359fced --- /dev/null +++ b/MediaBrowser.ServerApplication/EntryPoints/WebSocketEvents.cs @@ -0,0 +1,221 @@ +using MediaBrowser.Common.Events; +using MediaBrowser.Common.Net; +using MediaBrowser.Common.Plugins; +using MediaBrowser.Common.ScheduledTasks; +using MediaBrowser.Controller; +using MediaBrowser.Controller.Entities; +using MediaBrowser.Controller.Library; +using MediaBrowser.Controller.Plugins; +using MediaBrowser.Controller.Updates; +using MediaBrowser.Model.Logging; +using MediaBrowser.Model.Tasks; +using MediaBrowser.Model.Updates; +using System; + +namespace MediaBrowser.ServerApplication.EntryPoints +{ + /// <summary> + /// Class WebSocketEvents + /// </summary> + public class WebSocketEvents : IServerEntryPoint + { + /// <summary> + /// The _server manager + /// </summary> + private readonly IServerManager _serverManager; + /// <summary> + /// The _logger + /// </summary> + private readonly ILogger _logger; + + /// <summary> + /// The _user manager + /// </summary> + private readonly IUserManager _userManager; + + /// <summary> + /// The _library manager + /// </summary> + private readonly ILibraryManager _libraryManager; + + /// <summary> + /// The _installation manager + /// </summary> + private readonly IInstallationManager _installationManager; + + /// <summary> + /// The _kernel + /// </summary> + private readonly IServerApplicationHost _appHost; + + private readonly ITaskManager _taskManager; + + /// <summary> + /// Initializes a new instance of the <see cref="WebSocketEvents" /> class. + /// </summary> + /// <param name="serverManager">The server manager.</param> + /// <param name="logger">The logger.</param> + /// <param name="userManager">The user manager.</param> + public WebSocketEvents(IServerManager serverManager, IServerApplicationHost appHost, ILogger logger, IUserManager userManager, ILibraryManager libraryManager, IInstallationManager installationManager, ITaskManager taskManager) + { + _serverManager = serverManager; + _logger = logger; + _userManager = userManager; + _libraryManager = libraryManager; + _installationManager = installationManager; + _appHost = appHost; + _taskManager = taskManager; + } + + public void Run() + { + _userManager.UserDeleted += userManager_UserDeleted; + _userManager.UserUpdated += userManager_UserUpdated; + + _libraryManager.LibraryChanged += libraryManager_LibraryChanged; + + _appHost.HasPendingRestartChanged += kernel_HasPendingRestartChanged; + + _installationManager.PluginUninstalled += InstallationManager_PluginUninstalled; + _installationManager.PackageInstalling += installationManager_PackageInstalling; + _installationManager.PackageInstallationCancelled += installationManager_PackageInstallationCancelled; + _installationManager.PackageInstallationCompleted += installationManager_PackageInstallationCompleted; + _installationManager.PackageInstallationFailed += installationManager_PackageInstallationFailed; + + _taskManager.TaskExecuting += _taskManager_TaskExecuting; + _taskManager.TaskCompleted += _taskManager_TaskCompleted; + } + + void _taskManager_TaskCompleted(object sender, GenericEventArgs<TaskResult> e) + { + _serverManager.SendWebSocketMessage("ScheduledTaskEndExecute", e.Argument); + } + + void _taskManager_TaskExecuting(object sender, EventArgs e) + { + var task = (IScheduledTask) sender; + _serverManager.SendWebSocketMessage("ScheduledTaskBeginExecute", task.Name); + } + + /// <summary> + /// Installations the manager_ package installation failed. + /// </summary> + /// <param name="sender">The sender.</param> + /// <param name="e">The e.</param> + void installationManager_PackageInstallationFailed(object sender, GenericEventArgs<InstallationInfo> e) + { + _serverManager.SendWebSocketMessage("PackageInstallationFailed", e.Argument); + } + + /// <summary> + /// Installations the manager_ package installation completed. + /// </summary> + /// <param name="sender">The sender.</param> + /// <param name="e">The e.</param> + void installationManager_PackageInstallationCompleted(object sender, GenericEventArgs<InstallationInfo> e) + { + _serverManager.SendWebSocketMessage("PackageInstallationCompleted", e.Argument); + } + + /// <summary> + /// Installations the manager_ package installation cancelled. + /// </summary> + /// <param name="sender">The sender.</param> + /// <param name="e">The e.</param> + void installationManager_PackageInstallationCancelled(object sender, GenericEventArgs<InstallationInfo> e) + { + _serverManager.SendWebSocketMessage("PackageInstallationCancelled", e.Argument); + } + + /// <summary> + /// Installations the manager_ package installing. + /// </summary> + /// <param name="sender">The sender.</param> + /// <param name="e">The e.</param> + void installationManager_PackageInstalling(object sender, GenericEventArgs<InstallationInfo> e) + { + _serverManager.SendWebSocketMessage("PackageInstalling", e.Argument); + } + + /// <summary> + /// Handles the LibraryChanged event of the libraryManager control. + /// </summary> + /// <param name="sender">The source of the event.</param> + /// <param name="e">The <see cref="ChildrenChangedEventArgs" /> instance containing the event data.</param> + void libraryManager_LibraryChanged(object sender, ChildrenChangedEventArgs e) + { + _serverManager.SendWebSocketMessage("LibraryChanged", () => DtoBuilder.GetLibraryUpdateInfo(e)); + } + + /// <summary> + /// Installations the manager_ plugin uninstalled. + /// </summary> + /// <param name="sender">The sender.</param> + /// <param name="e">The e.</param> + void InstallationManager_PluginUninstalled(object sender, GenericEventArgs<IPlugin> e) + { + _serverManager.SendWebSocketMessage("PluginUninstalled", e.Argument.GetPluginInfo()); + } + + /// <summary> + /// Handles the HasPendingRestartChanged event of the kernel control. + /// </summary> + /// <param name="sender">The source of the event.</param> + /// <param name="e">The <see cref="EventArgs" /> instance containing the event data.</param> + void kernel_HasPendingRestartChanged(object sender, EventArgs e) + { + _serverManager.SendWebSocketMessage("HasPendingRestartChanged", _appHost.GetSystemInfo()); + } + + /// <summary> + /// Users the manager_ user updated. + /// </summary> + /// <param name="sender">The sender.</param> + /// <param name="e">The e.</param> + void userManager_UserUpdated(object sender, GenericEventArgs<User> e) + { + _serverManager.SendWebSocketMessage("UserUpdated", new DtoBuilder(_logger).GetDtoUser(e.Argument)); + } + + /// <summary> + /// Users the manager_ user deleted. + /// </summary> + /// <param name="sender">The sender.</param> + /// <param name="e">The e.</param> + void userManager_UserDeleted(object sender, GenericEventArgs<User> e) + { + _serverManager.SendWebSocketMessage("UserDeleted", e.Argument.Id.ToString()); + } + + /// <summary> + /// Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources. + /// </summary> + public void Dispose() + { + Dispose(true); + } + + /// <summary> + /// Releases unmanaged and - optionally - managed resources. + /// </summary> + /// <param name="dispose"><c>true</c> to release both managed and unmanaged resources; <c>false</c> to release only unmanaged resources.</param> + protected virtual void Dispose(bool dispose) + { + if (dispose) + { + _userManager.UserDeleted -= userManager_UserDeleted; + _userManager.UserUpdated -= userManager_UserUpdated; + + _libraryManager.LibraryChanged -= libraryManager_LibraryChanged; + + _installationManager.PluginUninstalled -= InstallationManager_PluginUninstalled; + _installationManager.PackageInstalling -= installationManager_PackageInstalling; + _installationManager.PackageInstallationCancelled -= installationManager_PackageInstallationCancelled; + _installationManager.PackageInstallationCompleted -= installationManager_PackageInstallationCompleted; + _installationManager.PackageInstallationFailed -= installationManager_PackageInstallationFailed; + + _appHost.HasPendingRestartChanged -= kernel_HasPendingRestartChanged; + } + } + } +} |