diff --git a/MediaBrowser.Common.Implementations/HttpServer/BaseRestService.cs b/MediaBrowser.Common.Implementations/HttpServer/BaseRestService.cs
index 65195c52ba..1c64194a62 100644
--- a/MediaBrowser.Common.Implementations/HttpServer/BaseRestService.cs
+++ b/MediaBrowser.Common.Implementations/HttpServer/BaseRestService.cs
@@ -11,7 +11,6 @@ using System;
using System.Globalization;
using System.IO;
using System.Linq;
-using System.Net;
using System.Threading.Tasks;
using MimeTypes = MediaBrowser.Common.Net.MimeTypes;
@@ -94,7 +93,8 @@ namespace MediaBrowser.Common.Implementations.HttpServer
if (result != null)
{
- return result;
+ // Return null so that service stack won't do anything
+ return null;
}
return ToOptimizedResult(factoryFn());
@@ -129,7 +129,8 @@ namespace MediaBrowser.Common.Implementations.HttpServer
if (result != null)
{
- return result;
+ // Return null so that service stack won't do anything
+ return null;
}
return factoryFn();
@@ -192,7 +193,8 @@ namespace MediaBrowser.Common.Implementations.HttpServer
if (result != null)
{
- return result;
+ // Return null so that service stack won't do anything
+ return null;
}
var compress = ShouldCompressResponse(contentType);
@@ -299,7 +301,9 @@ namespace MediaBrowser.Common.Implementations.HttpServer
Response.ContentType = contentType;
}
- return new HttpResult(new byte[] { }, HttpStatusCode.NotModified);
+ Response.StatusCode = 304;
+
+ return new byte[]{};
}
SetCachingHeaders(cacheKeyString, lastDateModified, cacheDuration);
diff --git a/MediaBrowser.Common.Implementations/ScheduledTasks/ScheduledTaskWorker.cs b/MediaBrowser.Common.Implementations/ScheduledTasks/ScheduledTaskWorker.cs
index e618b6f552..eada385564 100644
--- a/MediaBrowser.Common.Implementations/ScheduledTasks/ScheduledTaskWorker.cs
+++ b/MediaBrowser.Common.Implementations/ScheduledTasks/ScheduledTaskWorker.cs
@@ -367,6 +367,12 @@ namespace MediaBrowser.Common.Implementations.ScheduledTasks
OnTaskCompleted(startTime, endTime, status);
}
+ ///
+ /// Executes the task.
+ ///
+ /// The cancellation token.
+ /// The progress.
+ /// Task.
private Task ExecuteTask(CancellationToken cancellationToken, IProgress progress)
{
return Task.Run(async () => await ScheduledTask.Execute(cancellationToken, progress).ConfigureAwait(false));
diff --git a/MediaBrowser.Common.Implementations/ScheduledTasks/TaskManager.cs b/MediaBrowser.Common.Implementations/ScheduledTasks/TaskManager.cs
index 335820e1cd..efd3478a1e 100644
--- a/MediaBrowser.Common.Implementations/ScheduledTasks/TaskManager.cs
+++ b/MediaBrowser.Common.Implementations/ScheduledTasks/TaskManager.cs
@@ -100,7 +100,7 @@ namespace MediaBrowser.Common.Implementations.ScheduledTasks
QueueScheduledTask(scheduledTask);
}
-
+
///
/// Queues the scheduled task.
///
diff --git a/MediaBrowser.Common/Kernel/BaseKernel.cs b/MediaBrowser.Common/Kernel/BaseKernel.cs
index 6183c28396..85d541f097 100644
--- a/MediaBrowser.Common/Kernel/BaseKernel.cs
+++ b/MediaBrowser.Common/Kernel/BaseKernel.cs
@@ -23,6 +23,11 @@ namespace MediaBrowser.Common.Kernel
where TConfigurationType : BaseApplicationConfiguration, new()
where TApplicationPathsType : IApplicationPaths
{
+ ///
+ /// Occurs when [has pending restart changed].
+ ///
+ public event EventHandler HasPendingRestartChanged;
+
#region ConfigurationUpdated Event
///
/// Occurs when [configuration updated].
@@ -126,7 +131,7 @@ namespace MediaBrowser.Common.Kernel
/// Gets or sets the TCP manager.
///
/// The TCP manager.
- public IServerManager ServerManager { get; private set; }
+ private IServerManager ServerManager { get; set; }
///
/// Gets the plug-in security manager.
@@ -284,7 +289,7 @@ namespace MediaBrowser.Common.Kernel
{
HasPendingRestart = true;
- ServerManager.SendWebSocketMessage("HasPendingRestartChanged", GetSystemInfo());
+ EventHelper.QueueEventIfNotNull(HasPendingRestartChanged, this, EventArgs.Empty, Logger);
}
///
diff --git a/MediaBrowser.Common/Kernel/IKernel.cs b/MediaBrowser.Common/Kernel/IKernel.cs
index dac94cee26..d02f0af209 100644
--- a/MediaBrowser.Common/Kernel/IKernel.cs
+++ b/MediaBrowser.Common/Kernel/IKernel.cs
@@ -13,6 +13,11 @@ namespace MediaBrowser.Common.Kernel
///
public interface IKernel : IDisposable
{
+ ///
+ /// Occurs when [has pending restart changed].
+ ///
+ event EventHandler HasPendingRestartChanged;
+
///
/// Gets the application paths.
///
@@ -84,12 +89,6 @@ namespace MediaBrowser.Common.Kernel
/// The HTTP server URL prefix.
string HttpServerUrlPrefix { get; }
- ///
- /// Gets the TCP manager.
- ///
- /// The TCP manager.
- IServerManager ServerManager { get; }
-
///
/// Gets the plug-in security manager.
///
diff --git a/MediaBrowser.Common/MediaBrowser.Common.csproj b/MediaBrowser.Common/MediaBrowser.Common.csproj
index 30718ab4b9..c8543168f5 100644
--- a/MediaBrowser.Common/MediaBrowser.Common.csproj
+++ b/MediaBrowser.Common/MediaBrowser.Common.csproj
@@ -79,7 +79,6 @@
-
diff --git a/MediaBrowser.Common/Plugins/BasePlugin.cs b/MediaBrowser.Common/Plugins/BasePlugin.cs
index 72c83a5cee..56da543f05 100644
--- a/MediaBrowser.Common/Plugins/BasePlugin.cs
+++ b/MediaBrowser.Common/Plugins/BasePlugin.cs
@@ -251,18 +251,6 @@ namespace MediaBrowser.Common.Plugins
}
}
- ///
- /// Returns true or false indicating if the plugin should be downloaded and run within the Ui.
- ///
- /// true if [download to UI]; otherwise, false.
- public virtual bool DownloadToUi
- {
- get
- {
- return false;
- }
- }
-
///
/// Gets the logger.
///
@@ -422,7 +410,7 @@ namespace MediaBrowser.Common.Plugins
var info = new PluginInfo
{
Name = Name,
- DownloadToUI = DownloadToUi,
+ DownloadToUI = this is IUIPlugin,
Version = Version.ToString(),
AssemblyFileName = AssemblyFileName,
ConfigurationDateLastModified = ConfigurationDateLastModified,
diff --git a/MediaBrowser.Common/Plugins/BaseUiPlugin.cs b/MediaBrowser.Common/Plugins/BaseUiPlugin.cs
deleted file mode 100644
index 070f56983f..0000000000
--- a/MediaBrowser.Common/Plugins/BaseUiPlugin.cs
+++ /dev/null
@@ -1,30 +0,0 @@
-using MediaBrowser.Model.Plugins;
-using System;
-
-namespace MediaBrowser.Common.Plugins
-{
- ///
- /// Represents a common base class for any plugin that has ui components
- ///
- public abstract class BaseUiPlugin : BasePlugin, IUIPlugin
- where TConfigurationType : BasePluginConfiguration
- {
- ///
- /// Returns true or false indicating if the plugin should be downloaded and run within the Ui.
- ///
- /// true if [download to UI]; otherwise, false.
- public sealed override bool DownloadToUi
- {
- get
- {
- return true;
- }
- }
-
- ///
- /// Gets the minimum required UI version.
- ///
- /// The minimum required UI version.
- public abstract Version MinimumRequiredUIVersion { get; }
- }
-}
diff --git a/MediaBrowser.Common/Plugins/IPlugin.cs b/MediaBrowser.Common/Plugins/IPlugin.cs
index 1b25cdcb18..7d5fddb9ae 100644
--- a/MediaBrowser.Common/Plugins/IPlugin.cs
+++ b/MediaBrowser.Common/Plugins/IPlugin.cs
@@ -92,12 +92,6 @@ namespace MediaBrowser.Common.Plugins
/// The data folder path.
string DataFolderPath { get; }
- ///
- /// Returns true or false indicating if the plugin should be downloaded and run within the Ui.
- ///
- /// true if [download to UI]; otherwise, false.
- bool DownloadToUi { get; }
-
///
/// Gets the logger.
///
diff --git a/MediaBrowser.Controller/Kernel.cs b/MediaBrowser.Controller/Kernel.cs
index 46f4a33293..275b7868b1 100644
--- a/MediaBrowser.Controller/Kernel.cs
+++ b/MediaBrowser.Controller/Kernel.cs
@@ -10,7 +10,6 @@ using MediaBrowser.Controller.Persistence;
using MediaBrowser.Controller.Playback;
using MediaBrowser.Controller.Plugins;
using MediaBrowser.Controller.Providers;
-using MediaBrowser.Controller.Resolvers;
using MediaBrowser.Controller.Updates;
using MediaBrowser.Controller.Weather;
using MediaBrowser.Model.Configuration;
@@ -52,7 +51,7 @@ namespace MediaBrowser.Controller
/// Gets the installation manager.
///
/// The installation manager.
- public InstallationManager InstallationManager { get; private set; }
+ public InstallationManager InstallationManager { get; set; }
///
/// Gets or sets the file system manager.
@@ -112,18 +111,6 @@ namespace MediaBrowser.Controller
/// The image enhancers.
public IEnumerable ImageEnhancers { get; private set; }
- ///
- /// Gets the list of currently registered entity resolvers
- ///
- /// The entity resolvers enumerable.
- public IEnumerable EntityResolvers { get; private set; }
-
- ///
- /// Gets the list of BasePluginFolders added by plugins
- ///
- /// The plugin folders.
- public IEnumerable PluginFolderCreators { get; private set; }
-
///
/// Gets the list of available user repositories
///
@@ -154,12 +141,6 @@ namespace MediaBrowser.Controller
/// The item repository.
public IItemRepository ItemRepository { get; private set; }
- ///
- /// Gets the list of available item repositories
- ///
- /// The user data repositories.
- private IEnumerable UserDataRepositories { get; set; }
-
///
/// Gets the list of available DisplayPreferencesRepositories
///
@@ -167,10 +148,10 @@ namespace MediaBrowser.Controller
private IEnumerable DisplayPreferencesRepositories { get; set; }
///
- /// Gets the list of entity resolution ignore rules
+ /// Gets the list of available item repositories
///
- /// The entity resolution ignore rules.
- public IEnumerable EntityResolutionIgnoreRules { get; private set; }
+ /// The user data repositories.
+ private IEnumerable UserDataRepositories { get; set; }
///
/// Gets the active user data repository
@@ -217,7 +198,6 @@ namespace MediaBrowser.Controller
BaseItem.LibraryManager = ApplicationHost.Resolve();
User.UserManager = ApplicationHost.Resolve();
- InstallationManager = (InstallationManager)ApplicationHost.CreateInstance(typeof(InstallationManager));
FFMpegManager = (FFMpegManager)ApplicationHost.CreateInstance(typeof(FFMpegManager));
ImageManager = (ImageManager)ApplicationHost.CreateInstance(typeof(ImageManager));
ProviderManager = (ProviderManager)ApplicationHost.CreateInstance(typeof(ProviderManager));
@@ -225,7 +205,6 @@ namespace MediaBrowser.Controller
base.FindParts();
- EntityResolutionIgnoreRules = ApplicationHost.GetExports();
UserDataRepositories = ApplicationHost.GetExports();
UserRepositories = ApplicationHost.GetExports();
DisplayPreferencesRepositories = ApplicationHost.GetExports();
@@ -234,9 +213,7 @@ namespace MediaBrowser.Controller
IntroProviders = ApplicationHost.GetExports();
PluginConfigurationPages = ApplicationHost.GetExports();
ImageEnhancers = ApplicationHost.GetExports().OrderBy(e => e.Priority).ToArray();
- PluginFolderCreators = ApplicationHost.GetExports();
StringFiles = ApplicationHost.GetExports();
- EntityResolvers = ApplicationHost.GetExports().OrderBy(e => e.Priority).ToArray();
MetadataProviders = ApplicationHost.GetExports().OrderBy(e => e.Priority).ToArray();
}
diff --git a/MediaBrowser.Controller/Library/DtoBuilder.cs b/MediaBrowser.Controller/Library/DtoBuilder.cs
index c3fa38ebfa..0a892cbfb8 100644
--- a/MediaBrowser.Controller/Library/DtoBuilder.cs
+++ b/MediaBrowser.Controller/Library/DtoBuilder.cs
@@ -24,11 +24,11 @@ namespace MediaBrowser.Controller.Library
///
const string IndexFolderDelimeter = "-index-";
- private ILogger Logger;
+ private readonly ILogger _logger;
public DtoBuilder(ILogger logger)
{
- Logger = logger;
+ _logger = logger;
}
///
@@ -62,7 +62,7 @@ namespace MediaBrowser.Controller.Library
catch (Exception ex)
{
// Have to use a catch-all unfortunately because some .net image methods throw plain Exceptions
- Logger.ErrorException("Error generating PrimaryImageAspectRatio for {0}", ex, item.Name);
+ _logger.ErrorException("Error generating PrimaryImageAspectRatio for {0}", ex, item.Name);
}
}
@@ -124,7 +124,7 @@ namespace MediaBrowser.Controller.Library
catch (Exception ex)
{
// Have to use a catch-all unfortunately because some .net image methods throw plain Exceptions
- Logger.ErrorException("Error generating PrimaryImageAspectRatio for {0}", ex, item.Name);
+ _logger.ErrorException("Error generating PrimaryImageAspectRatio for {0}", ex, item.Name);
}
}
@@ -219,7 +219,7 @@ namespace MediaBrowser.Controller.Library
}
catch (FileNotFoundException)
{
- Logger.Error("Image file does not exist: {0}", path);
+ _logger.Error("Image file does not exist: {0}", path);
return;
}
@@ -581,7 +581,7 @@ namespace MediaBrowser.Controller.Library
}
catch (IOException ex)
{
- Logger.ErrorException("Error getting person {0}", ex, c.Name);
+ _logger.ErrorException("Error getting person {0}", ex, c.Name);
return null;
}
})
diff --git a/MediaBrowser.Controller/Library/ILibraryManager.cs b/MediaBrowser.Controller/Library/ILibraryManager.cs
index a013b2b47c..721b5c216e 100644
--- a/MediaBrowser.Controller/Library/ILibraryManager.cs
+++ b/MediaBrowser.Controller/Library/ILibraryManager.cs
@@ -4,6 +4,7 @@ using System.Threading;
using System.Threading.Tasks;
using MediaBrowser.Controller.Entities;
using MediaBrowser.Controller.IO;
+using MediaBrowser.Controller.Resolvers;
using MediaBrowser.Model.Entities;
namespace MediaBrowser.Controller.Library
@@ -141,5 +142,14 @@ namespace MediaBrowser.Controller.Library
/// The user id.
/// BaseItem.
BaseItem GetItemById(Guid id, Guid userId);
+
+ ///
+ /// Adds the parts.
+ ///
+ /// The rules.
+ /// The plugin folders.
+ /// The resolvers.
+ void AddParts(IEnumerable rules, IEnumerable pluginFolders,
+ IEnumerable resolvers);
}
}
\ No newline at end of file
diff --git a/MediaBrowser.Controller/Updates/InstallationManager.cs b/MediaBrowser.Controller/Updates/InstallationManager.cs
index 7765b8aeff..f248c6d44f 100644
--- a/MediaBrowser.Controller/Updates/InstallationManager.cs
+++ b/MediaBrowser.Controller/Updates/InstallationManager.cs
@@ -13,7 +13,6 @@ using System.Collections.Concurrent;
using System.Collections.Generic;
using System.IO;
using System.Linq;
-using System.Security.Cryptography;
using System.Threading;
using System.Threading.Tasks;
@@ -24,12 +23,16 @@ namespace MediaBrowser.Controller.Updates
///
public class InstallationManager : BaseManager
{
+ public event EventHandler> PackageInstalling;
+ public event EventHandler> PackageInstallationCompleted;
+ public event EventHandler> PackageInstallationFailed;
+ public event EventHandler> PackageInstallationCancelled;
+
///
/// The current installations
///
public List> CurrentInstallations { get; set; }
-
///
/// The completed installations
///
@@ -48,9 +51,6 @@ namespace MediaBrowser.Controller.Updates
private void OnPluginUninstalled(IPlugin plugin)
{
EventHelper.QueueEventIfNotNull(PluginUninstalled, this, new GenericEventArgs { Argument = plugin }, _logger);
-
- // Notify connected ui's
- Kernel.ServerManager.SendWebSocketMessage("PluginUninstalled", plugin.GetPluginInfo());
}
#endregion
@@ -372,7 +372,7 @@ namespace MediaBrowser.Controller.Updates
var linkedToken = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken, innerCancellationTokenSource.Token).Token;
- Kernel.ServerManager.SendWebSocketMessage("PackageInstalling", installationInfo);
+ EventHelper.QueueEventIfNotNull(PackageInstalling, this, new GenericEventArgs() { Argument = installationInfo }, _logger);
try
{
@@ -385,7 +385,7 @@ namespace MediaBrowser.Controller.Updates
CompletedInstallations.Add(installationInfo);
- Kernel.ServerManager.SendWebSocketMessage("PackageInstallationCompleted", installationInfo);
+ EventHelper.QueueEventIfNotNull(PackageInstallationCompleted, this, new GenericEventArgs() { Argument = installationInfo }, _logger);
}
catch (OperationCanceledException)
{
@@ -396,7 +396,7 @@ namespace MediaBrowser.Controller.Updates
_logger.Info("Package installation cancelled: {0} {1}", package.name, package.versionStr);
- Kernel.ServerManager.SendWebSocketMessage("PackageInstallationCancelled", installationInfo);
+ EventHelper.QueueEventIfNotNull(PackageInstallationCancelled, this, new GenericEventArgs() { Argument = installationInfo }, _logger);
throw;
}
@@ -407,7 +407,7 @@ namespace MediaBrowser.Controller.Updates
CurrentInstallations.Remove(tuple);
}
- Kernel.ServerManager.SendWebSocketMessage("PackageInstallationFailed", installationInfo);
+ EventHelper.QueueEventIfNotNull(PackageInstallationFailed, this, new GenericEventArgs() { Argument = installationInfo }, _logger);
throw;
}
diff --git a/MediaBrowser.Server.Implementations/Library/LibraryManager.cs b/MediaBrowser.Server.Implementations/Library/LibraryManager.cs
index 73eed018dd..d2d79db451 100644
--- a/MediaBrowser.Server.Implementations/Library/LibraryManager.cs
+++ b/MediaBrowser.Server.Implementations/Library/LibraryManager.cs
@@ -26,6 +26,24 @@ namespace MediaBrowser.Server.Implementations.Library
///
public class LibraryManager : ILibraryManager
{
+ ///
+ /// Gets the list of entity resolution ignore rules
+ ///
+ /// The entity resolution ignore rules.
+ public IEnumerable EntityResolutionIgnoreRules { get; private set; }
+
+ ///
+ /// Gets the list of BasePluginFolders added by plugins
+ ///
+ /// The plugin folders.
+ public IEnumerable PluginFolderCreators { get; set; }
+
+ ///
+ /// Gets the list of currently registered entity resolvers
+ ///
+ /// The entity resolvers enumerable.
+ public IEnumerable EntityResolvers { get; private set; }
+
#region LibraryChanged Event
///
/// Fires whenever any validation routine adds or removes items. The added and removed items are properties of the args.
@@ -40,19 +58,6 @@ namespace MediaBrowser.Server.Implementations.Library
public void ReportLibraryChanged(ChildrenChangedEventArgs args)
{
EventHelper.QueueEventIfNotNull(LibraryChanged, this, args, _logger);
-
- // Had to put this in a separate method to avoid an implicitly captured closure
- SendLibraryChangedWebSocketMessage(args);
- }
-
- ///
- /// Sends the library changed web socket message.
- ///
- /// The instance containing the event data.
- private void SendLibraryChangedWebSocketMessage(ChildrenChangedEventArgs args)
- {
- // Notify connected ui's
- Kernel.ServerManager.SendWebSocketMessage("LibraryChanged", () => DtoBuilder.GetLibraryUpdateInfo(args));
}
#endregion
@@ -94,6 +99,19 @@ namespace MediaBrowser.Server.Implementations.Library
kernel.ConfigurationUpdated += kernel_ConfigurationUpdated;
}
+ ///
+ /// Adds the parts.
+ ///
+ /// The rules.
+ /// The plugin folders.
+ /// The resolvers.
+ public void AddParts(IEnumerable rules, IEnumerable pluginFolders, IEnumerable resolvers)
+ {
+ EntityResolutionIgnoreRules = rules;
+ PluginFolderCreators = pluginFolders;
+ EntityResolvers = resolvers;
+ }
+
///
/// The _root folder
///
@@ -162,7 +180,7 @@ namespace MediaBrowser.Server.Implementations.Library
/// BaseItem.
public BaseItem ResolveItem(ItemResolveArgs args)
{
- return Kernel.EntityResolvers.Select(r => r.ResolvePath(args)).FirstOrDefault(i => i != null);
+ return EntityResolvers.Select(r => r.ResolvePath(args)).FirstOrDefault(i => i != null);
}
///
@@ -195,7 +213,7 @@ namespace MediaBrowser.Server.Implementations.Library
};
// Return null if ignore rules deem that we should do so
- if (Kernel.EntityResolutionIgnoreRules.Any(r => r.ShouldIgnore(args)))
+ if (EntityResolutionIgnoreRules.Any(r => r.ShouldIgnore(args)))
{
return null;
}
@@ -269,7 +287,7 @@ namespace MediaBrowser.Server.Implementations.Library
var rootFolder = Kernel.ItemRepository.RetrieveItem(rootFolderPath.GetMBId(typeof(AggregateFolder))) as AggregateFolder ?? (AggregateFolder)ResolvePath(rootFolderPath);
// Add in the plug-in folders
- foreach (var child in Kernel.PluginFolderCreators)
+ foreach (var child in PluginFolderCreators)
{
rootFolder.AddVirtualChild(child.GetFolder());
}
diff --git a/MediaBrowser.Server.Implementations/Library/UserManager.cs b/MediaBrowser.Server.Implementations/Library/UserManager.cs
index b8b3fc82e2..0490a9cf03 100644
--- a/MediaBrowser.Server.Implementations/Library/UserManager.cs
+++ b/MediaBrowser.Server.Implementations/Library/UserManager.cs
@@ -83,6 +83,10 @@ namespace MediaBrowser.Server.Implementations.Library
///
private readonly ILogger _logger;
+ ///
+ /// Gets or sets the kernel.
+ ///
+ /// The kernel.
private Kernel Kernel { get; set; }
///
@@ -124,9 +128,6 @@ namespace MediaBrowser.Server.Implementations.Library
private void OnUserUpdated(User user)
{
EventHelper.QueueEventIfNotNull(UserUpdated, this, new GenericEventArgs { Argument = user }, _logger);
-
- // Notify connected ui's
- Kernel.ServerManager.SendWebSocketMessage("UserUpdated", new DtoBuilder(_logger).GetDtoUser(user));
}
#endregion
@@ -142,9 +143,6 @@ namespace MediaBrowser.Server.Implementations.Library
private void OnUserDeleted(User user)
{
EventHelper.QueueEventIfNotNull(UserDeleted, this, new GenericEventArgs { Argument = user }, _logger);
-
- // Notify connected ui's
- Kernel.ServerManager.SendWebSocketMessage("UserDeleted", user.Id.ToString());
}
#endregion
diff --git a/MediaBrowser.ServerApplication/ApplicationHost.cs b/MediaBrowser.ServerApplication/ApplicationHost.cs
index 894f7cc756..9034434838 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
///
private readonly IXmlSerializer _xmlSerializer = new XmlSerializer();
+ private WebSocketEvents _webSocketEvents;
+
///
/// Gets the server application paths.
///
/// The server application paths.
protected IServerApplicationPaths ServerApplicationPaths
{
- get { return (IServerApplicationPaths) ApplicationPaths; }
+ get { return (IServerApplicationPaths)ApplicationPaths; }
}
///
@@ -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);
@@ -135,6 +139,20 @@ namespace MediaBrowser.ServerApplication
RegisterSingleInstance(new LibraryManager(Kernel, Logger, taskManager, userManager));
}
+ ///
+ /// Finds the parts.
+ ///
+ protected override void FindParts()
+ {
+ base.FindParts();
+
+ Resolve().AddParts(GetExports(), GetExports(), GetExports());
+
+ Kernel.InstallationManager = (InstallationManager)CreateInstance(typeof(InstallationManager));
+
+ _webSocketEvents = new WebSocketEvents(Resolve(), Resolve(), Resolve(), Resolve(), Resolve(), Kernel.InstallationManager);
+ }
+
///
/// Restarts this instance.
///
@@ -164,8 +182,8 @@ namespace MediaBrowser.ServerApplication
var availablePackages = await pkgManager.GetAvailablePackages(Resolve(), Resolve(), Kernel.SecurityManager, Kernel.ResourcePools, Resolve(), 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 };
}
///
@@ -228,5 +246,22 @@ namespace MediaBrowser.ServerApplication
{
App.Instance.Dispatcher.Invoke(App.Instance.Shutdown);
}
+
+ ///
+ /// Releases unmanaged and - optionally - managed resources.
+ ///
+ /// true to release both managed and unmanaged resources; false to release only unmanaged resources.
+ 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 bc69c96648..a55b49b659 100644
--- a/MediaBrowser.ServerApplication/MediaBrowser.ServerApplication.csproj
+++ b/MediaBrowser.ServerApplication/MediaBrowser.ServerApplication.csproj
@@ -162,6 +162,7 @@
+
MSBuild:Compile
Designer
diff --git a/MediaBrowser.ServerApplication/WebSocketEvents.cs b/MediaBrowser.ServerApplication/WebSocketEvents.cs
new file mode 100644
index 0000000000..6ffd077f8d
--- /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
+{
+ ///
+ /// Class WebSocketEvents
+ ///
+ public class WebSocketEvents : IDisposable
+ {
+ ///
+ /// The _server manager
+ ///
+ private readonly IServerManager _serverManager;
+ ///
+ /// The _logger
+ ///
+ private readonly ILogger _logger;
+
+ ///
+ /// The _user manager
+ ///
+ private readonly IUserManager _userManager;
+
+ ///
+ /// The _library manager
+ ///
+ private readonly ILibraryManager _libraryManager;
+
+ ///
+ /// The _installation manager
+ ///
+ private readonly InstallationManager _installationManager;
+
+ ///
+ /// The _kernel
+ ///
+ private readonly IKernel _kernel;
+
+ ///
+ /// Initializes a new instance of the class.
+ ///
+ /// The server manager.
+ /// The logger.
+ /// The user manager.
+ 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;
+ }
+
+ ///
+ /// Installations the manager_ package installation failed.
+ ///
+ /// The sender.
+ /// The e.
+ void installationManager_PackageInstallationFailed(object sender, GenericEventArgs e)
+ {
+ _serverManager.SendWebSocketMessage("PackageInstallationFailed", e.Argument);
+ }
+
+ ///
+ /// Installations the manager_ package installation completed.
+ ///
+ /// The sender.
+ /// The e.
+ void installationManager_PackageInstallationCompleted(object sender, GenericEventArgs e)
+ {
+ _serverManager.SendWebSocketMessage("PackageInstallationCompleted", e.Argument);
+ }
+
+ ///
+ /// Installations the manager_ package installation cancelled.
+ ///
+ /// The sender.
+ /// The e.
+ void installationManager_PackageInstallationCancelled(object sender, GenericEventArgs e)
+ {
+ _serverManager.SendWebSocketMessage("PackageInstallationCancelled", e.Argument);
+ }
+
+ ///
+ /// Installations the manager_ package installing.
+ ///
+ /// The sender.
+ /// The e.
+ void installationManager_PackageInstalling(object sender, GenericEventArgs e)
+ {
+ _serverManager.SendWebSocketMessage("PackageInstalling", e.Argument);
+ }
+
+ ///
+ /// Handles the LibraryChanged event of the libraryManager control.
+ ///
+ /// The source of the event.
+ /// The instance containing the event data.
+ void libraryManager_LibraryChanged(object sender, ChildrenChangedEventArgs e)
+ {
+ _serverManager.SendWebSocketMessage("LibraryChanged", () => DtoBuilder.GetLibraryUpdateInfo(e));
+ }
+
+ ///
+ /// Installations the manager_ plugin uninstalled.
+ ///
+ /// The sender.
+ /// The e.
+ void InstallationManager_PluginUninstalled(object sender, GenericEventArgs e)
+ {
+ _serverManager.SendWebSocketMessage("PluginUninstalled", e.Argument.GetPluginInfo());
+ }
+
+ ///
+ /// Handles the HasPendingRestartChanged event of the kernel control.
+ ///
+ /// The source of the event.
+ /// The instance containing the event data.
+ void kernel_HasPendingRestartChanged(object sender, EventArgs e)
+ {
+ var kernel = (IKernel)sender;
+
+ _serverManager.SendWebSocketMessage("HasPendingRestartChanged", kernel.GetSystemInfo());
+ }
+
+ ///
+ /// Users the manager_ user updated.
+ ///
+ /// The sender.
+ /// The e.
+ void userManager_UserUpdated(object sender, GenericEventArgs e)
+ {
+ _serverManager.SendWebSocketMessage("UserUpdated", new DtoBuilder(_logger).GetDtoUser(e.Argument));
+ }
+
+ ///
+ /// Users the manager_ user deleted.
+ ///
+ /// The sender.
+ /// The e.
+ void userManager_UserDeleted(object sender, GenericEventArgs e)
+ {
+ _serverManager.SendWebSocketMessage("UserDeleted", e.Argument.Id.ToString());
+ }
+
+ ///
+ /// Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
+ ///
+ public void Dispose()
+ {
+ Dispose(true);
+ }
+
+ ///
+ /// Releases unmanaged and - optionally - managed resources.
+ ///
+ /// true to release both managed and unmanaged resources; false to release only unmanaged resources.
+ 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;
+ }
+ }
+ }
+}
diff --git a/MediaBrowser.WebDashboard/Html/css/images/mblogoicon.png b/MediaBrowser.WebDashboard/Html/css/images/mblogoicon.png
index be2de69d14..058d09ee51 100644
Binary files a/MediaBrowser.WebDashboard/Html/css/images/mblogoicon.png and b/MediaBrowser.WebDashboard/Html/css/images/mblogoicon.png differ
diff --git a/MediaBrowser.WebDashboard/Html/css/site.css b/MediaBrowser.WebDashboard/Html/css/site.css
index 3e32d4e1fc..e6bd5f7c55 100644
--- a/MediaBrowser.WebDashboard/Html/css/site.css
+++ b/MediaBrowser.WebDashboard/Html/css/site.css
@@ -107,6 +107,7 @@ pre, textarea.pre {
.imgLogoText {
height: 45px;
display: none;
+ margin-left: 5px;
}