diff options
Diffstat (limited to 'MediaBrowser.ServerApplication')
3 files changed, 240 insertions, 5 deletions
diff --git a/MediaBrowser.ServerApplication/ApplicationHost.cs b/MediaBrowser.ServerApplication/ApplicationHost.cs index e4405d123..654fce42e 100644 --- a/MediaBrowser.ServerApplication/ApplicationHost.cs +++ b/MediaBrowser.ServerApplication/ApplicationHost.cs @@ -1,5 +1,4 @@ using MediaBrowser.Api; -using MediaBrowser.ClickOnce; using MediaBrowser.Common.Implementations; using MediaBrowser.Common.Implementations.HttpServer; using MediaBrowser.Common.Implementations.Logging; @@ -13,7 +12,10 @@ using MediaBrowser.Common.Net; using MediaBrowser.Common.ScheduledTasks; using MediaBrowser.Common.Updates; using MediaBrowser.Controller; +using MediaBrowser.Controller.Entities; using MediaBrowser.Controller.Library; +using MediaBrowser.Controller.Resolvers; +using MediaBrowser.Controller.Updates; using MediaBrowser.IsoMounter; using MediaBrowser.Model.IO; using MediaBrowser.Model.Logging; @@ -57,13 +59,15 @@ namespace MediaBrowser.ServerApplication /// </summary> private readonly IXmlSerializer _xmlSerializer = new XmlSerializer(); + private WebSocketEvents _webSocketEvents; + /// <summary> /// Gets the server application paths. /// </summary> /// <value>The server application paths.</value> protected IServerApplicationPaths ServerApplicationPaths { - get { return (IServerApplicationPaths) ApplicationPaths; } + get { return (IServerApplicationPaths)ApplicationPaths; } } /// <summary> @@ -74,7 +78,7 @@ namespace MediaBrowser.ServerApplication : base() { Kernel = new Kernel(this, ServerApplicationPaths, _xmlSerializer, Logger); - + var networkManager = new NetworkManager(); var serverManager = new ServerManager(this, Kernel, networkManager, _jsonSerializer, Logger); @@ -136,6 +140,20 @@ namespace MediaBrowser.ServerApplication } /// <summary> + /// Finds the parts. + /// </summary> + protected override void FindParts() + { + base.FindParts(); + + Resolve<ILibraryManager>().AddParts(GetExports<IResolutionIgnoreRule>(), GetExports<IVirtualFolderCreator>(), GetExports<IBaseItemResolver>()); + + Kernel.InstallationManager = (InstallationManager)CreateInstance(typeof(InstallationManager)); + + _webSocketEvents = new WebSocketEvents(Resolve<IServerManager>(), Resolve<IKernel>(), Resolve<ILogger>(), Resolve<IUserManager>(), Resolve<ILibraryManager>(), Kernel.InstallationManager); + } + + /// <summary> /// Restarts this instance. /// </summary> public void Restart() @@ -164,8 +182,8 @@ namespace MediaBrowser.ServerApplication var availablePackages = await pkgManager.GetAvailablePackages(Resolve<IHttpClient>(), Resolve<INetworkManager>(), Kernel.SecurityManager, Kernel.ResourcePools, Resolve<IJsonSerializer>(), CancellationToken.None).ConfigureAwait(false); var version = Kernel.InstallationManager.GetLatestCompatibleVersion(availablePackages, "MBServer", Kernel.Configuration.SystemUpdateLevel); - return version != null ? new CheckForUpdateResult {AvailableVersion = version.version, IsUpdateAvailable = version.version > ApplicationVersion, Package = version} : - new CheckForUpdateResult {AvailableVersion = ApplicationVersion, IsUpdateAvailable = false}; + return version != null ? new CheckForUpdateResult { AvailableVersion = version.version, IsUpdateAvailable = version.version > ApplicationVersion, Package = version } : + new CheckForUpdateResult { AvailableVersion = ApplicationVersion, IsUpdateAvailable = false }; } /// <summary> @@ -228,5 +246,22 @@ namespace MediaBrowser.ServerApplication { App.Instance.Dispatcher.Invoke(App.Instance.Shutdown); } + + /// <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 override void Dispose(bool dispose) + { + if (dispose) + { + if (_webSocketEvents != null) + { + _webSocketEvents.Dispose(); + } + } + + base.Dispose(dispose); + } } } diff --git a/MediaBrowser.ServerApplication/MediaBrowser.ServerApplication.csproj b/MediaBrowser.ServerApplication/MediaBrowser.ServerApplication.csproj index bc69c9664..a55b49b65 100644 --- a/MediaBrowser.ServerApplication/MediaBrowser.ServerApplication.csproj +++ b/MediaBrowser.ServerApplication/MediaBrowser.ServerApplication.csproj @@ -162,6 +162,7 @@ <Reference Include="PresentationFramework" /> </ItemGroup> <ItemGroup> + <Compile Include="WebSocketEvents.cs" /> <Page Include="App.xaml"> <Generator>MSBuild:Compile</Generator> <SubType>Designer</SubType> diff --git a/MediaBrowser.ServerApplication/WebSocketEvents.cs b/MediaBrowser.ServerApplication/WebSocketEvents.cs new file mode 100644 index 000000000..6ffd077f8 --- /dev/null +++ b/MediaBrowser.ServerApplication/WebSocketEvents.cs @@ -0,0 +1,199 @@ +using MediaBrowser.Common.Events; +using MediaBrowser.Common.Kernel; +using MediaBrowser.Common.Plugins; +using MediaBrowser.Controller.Entities; +using MediaBrowser.Controller.Library; +using MediaBrowser.Controller.Updates; +using MediaBrowser.Model.Logging; +using MediaBrowser.Model.Updates; +using System; + +namespace MediaBrowser.ServerApplication +{ + /// <summary> + /// Class WebSocketEvents + /// </summary> + public class WebSocketEvents : IDisposable + { + /// <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 InstallationManager _installationManager; + + /// <summary> + /// The _kernel + /// </summary> + private readonly IKernel _kernel; + + /// <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, IKernel kernel, ILogger logger, IUserManager userManager, ILibraryManager libraryManager, InstallationManager installationManager) + { + _serverManager = serverManager; + _logger = logger; + _userManager = userManager; + _libraryManager = libraryManager; + _installationManager = installationManager; + _kernel = kernel; + + _userManager.UserDeleted += userManager_UserDeleted; + _userManager.UserUpdated += userManager_UserUpdated; + + _libraryManager.LibraryChanged += libraryManager_LibraryChanged; + + kernel.HasPendingRestartChanged += kernel_HasPendingRestartChanged; + + installationManager.PluginUninstalled += InstallationManager_PluginUninstalled; + installationManager.PackageInstalling += installationManager_PackageInstalling; + installationManager.PackageInstallationCancelled += installationManager_PackageInstallationCancelled; + installationManager.PackageInstallationCompleted += installationManager_PackageInstallationCompleted; + installationManager.PackageInstallationFailed += installationManager_PackageInstallationFailed; + } + + /// <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) + { + var kernel = (IKernel)sender; + + _serverManager.SendWebSocketMessage("HasPendingRestartChanged", kernel.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; + + _kernel.HasPendingRestartChanged -= kernel_HasPendingRestartChanged; + } + } + } +} |