diff --git a/MediaBrowser.Common.Implementations/MediaBrowser.Common.Implementations.csproj b/MediaBrowser.Common.Implementations/MediaBrowser.Common.Implementations.csproj
index 70d92edb5..a8dfe33cf 100644
--- a/MediaBrowser.Common.Implementations/MediaBrowser.Common.Implementations.csproj
+++ b/MediaBrowser.Common.Implementations/MediaBrowser.Common.Implementations.csproj
@@ -129,6 +129,7 @@
+
@@ -163,9 +164,7 @@
-
-
-
+
diff --git a/MediaBrowser.Common.Implementations/Updates/PackageManager.cs b/MediaBrowser.Common.Implementations/Updates/PackageManager.cs
new file mode 100644
index 000000000..3f09615e7
--- /dev/null
+++ b/MediaBrowser.Common.Implementations/Updates/PackageManager.cs
@@ -0,0 +1,47 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;
+using MediaBrowser.Common.Kernel;
+using MediaBrowser.Common.Net;
+using MediaBrowser.Common.Security;
+using MediaBrowser.Common.Updates;
+using MediaBrowser.Model.Serialization;
+using MediaBrowser.Model.Updates;
+
+namespace MediaBrowser.Common.Implementations.Updates
+{
+ public class PackageManager : IPackageManager
+ {
+ public async Task> GetAvailablePackages(IHttpClient client,
+ INetworkManager networkManager,
+ ISecurityManager securityManager,
+ ResourcePool resourcePool,
+ IJsonSerializer serializer,
+ CancellationToken cancellationToken)
+ {
+ var data = new Dictionary { { "key", securityManager.SupporterKey }, { "mac", networkManager.GetMacAddress() } };
+
+ using (var json = await client.Post(Constants.Constants.MBAdminUrl + "service/package/retrieveall", data, resourcePool.Mb, cancellationToken).ConfigureAwait(false))
+ {
+ cancellationToken.ThrowIfCancellationRequested();
+
+ var packages = serializer.DeserializeFromStream>(json).ToList();
+ foreach (var package in packages)
+ {
+ package.versions = package.versions.Where(v => !string.IsNullOrWhiteSpace(v.sourceUrl))
+ .OrderByDescending(v => v.version).ToList();
+ }
+
+ return packages;
+ }
+
+ }
+
+ public Task InstallPackage(PackageVersionInfo package, CancellationToken cancellationToken)
+ {
+ throw new NotImplementedException();
+ }
+ }
+}
diff --git a/MediaBrowser.Common/Constants/Constants.cs b/MediaBrowser.Common/Constants/Constants.cs
new file mode 100644
index 000000000..e8a347829
--- /dev/null
+++ b/MediaBrowser.Common/Constants/Constants.cs
@@ -0,0 +1,13 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace MediaBrowser.Common.Constants
+{
+ public static class Constants
+ {
+ public const string MBAdminUrl = "http://mb3admin.com/admin/";
+ }
+}
diff --git a/MediaBrowser.Common/MediaBrowser.Common.csproj b/MediaBrowser.Common/MediaBrowser.Common.csproj
index 50ca0e5bc..1b63f936f 100644
--- a/MediaBrowser.Common/MediaBrowser.Common.csproj
+++ b/MediaBrowser.Common/MediaBrowser.Common.csproj
@@ -47,6 +47,7 @@
Properties\SharedVersion.cs
+
@@ -104,7 +105,7 @@
-
+
diff --git a/MediaBrowser.Common/Updates/IInstallationManager.cs b/MediaBrowser.Common/Updates/IInstallationManager.cs
deleted file mode 100644
index 23c147748..000000000
--- a/MediaBrowser.Common/Updates/IInstallationManager.cs
+++ /dev/null
@@ -1,119 +0,0 @@
-using System;
-using System.Collections.Concurrent;
-using System.Collections.Generic;
-using System.Threading;
-using System.Threading.Tasks;
-using MediaBrowser.Common.Events;
-using MediaBrowser.Common.Plugins;
-using MediaBrowser.Model.Updates;
-
-namespace MediaBrowser.Common.Updates
-{
- public interface IInstallationManager
- {
- ///
- /// The current installations
- ///
- List> CurrentInstallations { get; set; }
-
- ///
- /// The completed installations
- ///
- ConcurrentBag CompletedInstallations { get; set; }
-
- ///
- /// Occurs when [plugin uninstalled].
- ///
- event EventHandler> PluginUninstalled;
-
- ///
- /// Occurs when [plugin updated].
- ///
- event EventHandler>> PluginUpdated;
-
- ///
- /// Called when [plugin updated].
- ///
- /// The plugin.
- /// The new version.
- void OnPluginUpdated(IPlugin plugin, PackageVersionInfo newVersion);
-
- ///
- /// Occurs when [plugin updated].
- ///
- event EventHandler> PluginInstalled;
-
- ///
- /// Called when [plugin installed].
- ///
- /// The package.
- void OnPluginInstalled(PackageVersionInfo package);
-
- ///
- /// Gets all available packages.
- ///
- /// The cancellation token.
- /// Type of the package.
- /// The application version.
- /// Task{List{PackageInfo}}.
- Task> GetAvailablePackages(CancellationToken cancellationToken,
- PackageType? packageType = null,
- Version applicationVersion = null);
-
- ///
- /// Gets the package.
- ///
- /// The name.
- /// The classification.
- /// The version.
- /// Task{PackageVersionInfo}.
- Task GetPackage(string name, PackageVersionClass classification, Version version);
-
- ///
- /// Gets the latest compatible version.
- ///
- /// The name.
- /// The classification.
- /// Task{PackageVersionInfo}.
- Task GetLatestCompatibleVersion(string name, PackageVersionClass classification = PackageVersionClass.Release);
-
- ///
- /// Gets the latest compatible version.
- ///
- /// The available packages.
- /// The name.
- /// The classification.
- /// PackageVersionInfo.
- PackageVersionInfo GetLatestCompatibleVersion(IEnumerable availablePackages, string name, PackageVersionClass classification = PackageVersionClass.Release);
-
- ///
- /// Gets the available plugin updates.
- ///
- /// if set to true [with auto update enabled].
- /// The cancellation token.
- /// Task{IEnumerable{PackageVersionInfo}}.
- Task> GetAvailablePluginUpdates(bool withAutoUpdateEnabled, CancellationToken cancellationToken);
-
- ///
- /// Installs the package.
- ///
- /// The package.
- /// The progress.
- /// The cancellation token.
- /// Task.
- /// package
- Task InstallPackage(PackageVersionInfo package, IProgress progress, CancellationToken cancellationToken);
-
- ///
- /// Uninstalls a plugin
- ///
- /// The plugin.
- ///
- void UninstallPlugin(IPlugin plugin);
-
- ///
- /// Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
- ///
- void Dispose();
- }
-}
\ No newline at end of file
diff --git a/MediaBrowser.Common/Updates/IPackageManager.cs b/MediaBrowser.Common/Updates/IPackageManager.cs
new file mode 100644
index 000000000..d5a8a59b1
--- /dev/null
+++ b/MediaBrowser.Common/Updates/IPackageManager.cs
@@ -0,0 +1,42 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+using MediaBrowser.Common.Kernel;
+using MediaBrowser.Common.Net;
+using MediaBrowser.Common.Security;
+using MediaBrowser.Model.Serialization;
+using MediaBrowser.Model.Updates;
+
+namespace MediaBrowser.Common.Updates
+{
+ public interface IPackageManager
+ {
+ ///
+ /// Gets all available packages.
+ ///
+ ///
+ ///
+ ///
+ ///
+ ///
+ /// The cancellation token.
+ /// Task{List{PackageInfo}}.
+ Task> GetAvailablePackages(IHttpClient client,
+ INetworkManager networkManager,
+ ISecurityManager securityManager,
+ ResourcePool resourcePool,
+ IJsonSerializer serializer,
+ CancellationToken cancellationToken);
+
+ ///
+ /// Installs a package.
+ ///
+ /// The package.
+ /// The cancellation token.
+ /// Task.
+ Task InstallPackage(PackageVersionInfo package, CancellationToken cancellationToken);
+ }
+}
diff --git a/MediaBrowser.Controller/Kernel.cs b/MediaBrowser.Controller/Kernel.cs
index 6faa20012..6703012be 100644
--- a/MediaBrowser.Controller/Kernel.cs
+++ b/MediaBrowser.Controller/Kernel.cs
@@ -33,11 +33,6 @@ namespace MediaBrowser.Controller
///
public class Kernel : BaseKernel
{
- ///
- /// The MB admin URL
- ///
- public const string MBAdminUrl = "http://mb3admin.com/admin/";
-
///
/// Gets the instance.
///
@@ -72,7 +67,7 @@ namespace MediaBrowser.Controller
/// Gets the installation manager.
///
/// The installation manager.
- public IInstallationManager InstallationManager { get; private set; }
+ public InstallationManager InstallationManager { get; private set; }
///
/// Gets or sets the file system manager.
diff --git a/MediaBrowser.Controller/Updates/InstallationManager.cs b/MediaBrowser.Controller/Updates/InstallationManager.cs
index 633cc6bc3..ebd644a82 100644
--- a/MediaBrowser.Controller/Updates/InstallationManager.cs
+++ b/MediaBrowser.Controller/Updates/InstallationManager.cs
@@ -22,7 +22,7 @@ namespace MediaBrowser.Controller.Updates
///
/// Manages all install, uninstall and update operations (both plugins and system)
///
- public class InstallationManager : BaseManager, IInstallationManager
+ public class InstallationManager : BaseManager
{
///
/// The current installations
@@ -109,6 +109,11 @@ namespace MediaBrowser.Controller.Updates
///
private readonly INetworkManager _networkManager;
+ ///
+ /// The package manager
+ ///
+ private readonly IPackageManager _packageManager;
+
///
/// Gets the json serializer.
///
@@ -134,11 +139,12 @@ namespace MediaBrowser.Controller.Updates
/// The HTTP client.
/// The zip client.
/// The network manager.
+ /// The package manager.
/// The json serializer.
/// The logger.
/// The app host.
/// zipClient
- public InstallationManager(Kernel kernel, IHttpClient httpClient, IZipClient zipClient, INetworkManager networkManager, IJsonSerializer jsonSerializer, ILogger logger, IApplicationHost appHost)
+ public InstallationManager(Kernel kernel, IHttpClient httpClient, IZipClient zipClient, INetworkManager networkManager, IPackageManager packageManager, IJsonSerializer jsonSerializer, ILogger logger, IApplicationHost appHost)
: base(kernel)
{
if (zipClient == null)
@@ -149,6 +155,10 @@ namespace MediaBrowser.Controller.Updates
{
throw new ArgumentNullException("networkManager");
}
+ if (packageManager == null)
+ {
+ throw new ArgumentNullException("packageManager");
+ }
if (logger == null)
{
throw new ArgumentNullException("logger");
@@ -168,6 +178,7 @@ namespace MediaBrowser.Controller.Updates
HttpClient = httpClient;
ApplicationHost = appHost;
_networkManager = networkManager;
+ _packageManager = packageManager;
_logger = logger;
ZipClient = zipClient;
}
@@ -183,39 +194,26 @@ namespace MediaBrowser.Controller.Updates
PackageType? packageType = null,
Version applicationVersion = null)
{
- var data = new Dictionary { { "key", Kernel.SecurityManager.SupporterKey }, { "mac", _networkManager.GetMacAddress() } };
+ var packages = (await _packageManager.GetAvailablePackages(HttpClient, _networkManager, Kernel.SecurityManager, Kernel.ResourcePools, JsonSerializer, cancellationToken).ConfigureAwait(false)).ToList();
- using (var json = await HttpClient.Post(Controller.Kernel.MBAdminUrl + "service/package/retrieveall", data, Kernel.ResourcePools.Mb, cancellationToken).ConfigureAwait(false))
+ if (packageType.HasValue)
{
- cancellationToken.ThrowIfCancellationRequested();
-
- var packages = JsonSerializer.DeserializeFromStream>(json).ToList();
+ packages = packages.Where(p => p.type == packageType.Value).ToList();
+ }
+ // If an app version was supplied, filter the versions for each package to only include supported versions
+ if (applicationVersion != null)
+ {
foreach (var package in packages)
{
- package.versions = package.versions.Where(v => !string.IsNullOrWhiteSpace(v.sourceUrl))
- .OrderByDescending(v => v.version).ToList();
+ package.versions = package.versions.Where(v => IsPackageVersionUpToDate(v, applicationVersion)).ToList();
}
-
- if (packageType.HasValue)
- {
- packages = packages.Where(p => p.type == packageType.Value).ToList();
- }
-
- // If an app version was supplied, filter the versions for each package to only include supported versions
- if (applicationVersion != null)
- {
- foreach (var package in packages)
- {
- package.versions = package.versions.Where(v => IsPackageVersionUpToDate(v, applicationVersion)).ToList();
- }
- }
-
- // Remove packages with no versions
- packages = packages.Where(p => p.versions.Any()).ToList();
-
- return packages;
}
+
+ // Remove packages with no versions
+ packages = packages.Where(p => p.versions.Any()).ToList();
+
+ return packages;
}
///
diff --git a/MediaBrowser.ServerApplication/ApplicationHost.cs b/MediaBrowser.ServerApplication/ApplicationHost.cs
index a252d92a6..2aa24dabf 100644
--- a/MediaBrowser.ServerApplication/ApplicationHost.cs
+++ b/MediaBrowser.ServerApplication/ApplicationHost.cs
@@ -7,13 +7,15 @@ using MediaBrowser.Common.Implementations.Logging;
using MediaBrowser.Common.Implementations.NetworkManagement;
using MediaBrowser.Common.Implementations.ScheduledTasks;
using MediaBrowser.Common.Implementations.Serialization;
+using MediaBrowser.Common.IO;
using MediaBrowser.Common.Implementations.ServerManager;
using MediaBrowser.Common.Implementations.Udp;
+using MediaBrowser.Common.Implementations.Updates;
using MediaBrowser.Common.Implementations.WebSocket;
-using MediaBrowser.Common.IO;
using MediaBrowser.Common.Kernel;
using MediaBrowser.Common.Net;
using MediaBrowser.Common.ScheduledTasks;
+using MediaBrowser.Common.Updates;
using MediaBrowser.Controller;
using MediaBrowser.IsoMounter;
using MediaBrowser.Model.IO;
@@ -72,7 +74,6 @@ namespace MediaBrowser.ServerApplication
public ApplicationHost()
: base()
{
- Logger.Info("ApplicationHost!!!!!!!!!!!!!!!!!!!!");
Kernel = new Kernel(this, ServerApplicationPaths, _xmlSerializer, Logger);
var networkManager = new NetworkManager();
@@ -81,13 +82,15 @@ namespace MediaBrowser.ServerApplication
var taskManager = new TaskManager(ApplicationPaths, _jsonSerializer, Logger, serverManager);
+ var packageManager = new PackageManager();
+
LogManager.ReloadLogger(Kernel.Configuration.EnableDebugLevelLogging ? LogSeverity.Debug : LogSeverity.Info);
Logger.Info("Version {0} initializing", ApplicationVersion);
var httpServer = ServerFactory.CreateServer(this, ProtobufSerializer, Logger, "Media Browser", "index.html");
- RegisterResources(taskManager, httpServer, networkManager, serverManager);
+ RegisterResources(taskManager, httpServer, networkManager, serverManager, packageManager);
FindParts(taskManager, httpServer);
}
@@ -113,7 +116,7 @@ namespace MediaBrowser.ServerApplication
///
/// Registers resources that classes will depend on
///
- private void RegisterResources(ITaskManager taskManager, IHttpServer httpServer, INetworkManager networkManager, IServerManager serverManager)
+ private void RegisterResources(ITaskManager taskManager, IHttpServer httpServer, INetworkManager networkManager, IServerManager serverManager, IPackageManager packageManager)
{
RegisterSingleInstance(Kernel);
RegisterSingleInstance(Kernel);
@@ -137,8 +140,8 @@ namespace MediaBrowser.ServerApplication
RegisterSingleInstance(httpServer, false);
RegisterSingleInstance(networkManager);
-
RegisterSingleInstance(serverManager);
+ RegisterSingleInstance(packageManager);
}
///