diff options
Diffstat (limited to 'MediaBrowser.Api/WebSocket/LogFileWebSocketListener.cs')
| -rw-r--r-- | MediaBrowser.Api/WebSocket/LogFileWebSocketListener.cs | 33 |
1 files changed, 15 insertions, 18 deletions
diff --git a/MediaBrowser.Api/WebSocket/LogFileWebSocketListener.cs b/MediaBrowser.Api/WebSocket/LogFileWebSocketListener.cs index f725b0222..144997c73 100644 --- a/MediaBrowser.Api/WebSocket/LogFileWebSocketListener.cs +++ b/MediaBrowser.Api/WebSocket/LogFileWebSocketListener.cs @@ -1,12 +1,13 @@ using MediaBrowser.Common.IO; using MediaBrowser.Common.Kernel; +using MediaBrowser.Controller; +using MediaBrowser.Model.Logging; using System; using System.Collections.Generic; using System.ComponentModel.Composition; using System.IO; using System.Linq; using System.Threading.Tasks; -using MediaBrowser.Model.Logging; namespace MediaBrowser.Api.WebSocket { @@ -14,7 +15,7 @@ namespace MediaBrowser.Api.WebSocket /// Class ScheduledTasksWebSocketListener /// </summary> [Export(typeof(IWebSocketListener))] - public class LogFileWebSocketListener : BasePeriodicWebSocketListener<IKernel, IEnumerable<string>, LogFileWebSocketState> + public class LogFileWebSocketListener : BasePeriodicWebSocketListener<IEnumerable<string>, LogFileWebSocketState> { /// <summary> /// Gets the name. @@ -26,25 +27,21 @@ namespace MediaBrowser.Api.WebSocket } /// <summary> + /// The _kernel + /// </summary> + private readonly IKernel _kernel; + + /// <summary> /// Initializes a new instance of the <see cref="LogFileWebSocketListener" /> class. /// </summary> /// <param name="logger">The logger.</param> + /// <param name="kernel">The kernel.</param> [ImportingConstructor] - public LogFileWebSocketListener([Import("logger")] ILogger logger) + public LogFileWebSocketListener([Import("logger")] ILogger logger, [Import("kernel")] Kernel kernel) : base(logger) { - - } - - /// <summary> - /// Initializes the specified kernel. - /// </summary> - /// <param name="kernel">The kernel.</param> - public override void Initialize(IKernel kernel) - { - base.Initialize(kernel); - - kernel.LoggerLoaded += kernel_LoggerLoaded; + _kernel = kernel; + _kernel.LoggerLoaded += kernel_LoggerLoaded; } /// <summary> @@ -54,9 +51,9 @@ namespace MediaBrowser.Api.WebSocket /// <returns>IEnumerable{System.String}.</returns> protected override async Task<IEnumerable<string>> GetDataToSend(LogFileWebSocketState state) { - if (!string.Equals(Kernel.LogFilePath, state.LastLogFilePath)) + if (!string.Equals(_kernel.LogFilePath, state.LastLogFilePath)) { - state.LastLogFilePath = Kernel.LogFilePath; + state.LastLogFilePath = _kernel.LogFilePath; state.StartLine = 0; } @@ -75,7 +72,7 @@ namespace MediaBrowser.Api.WebSocket { if (dispose) { - Kernel.LoggerLoaded -= kernel_LoggerLoaded; + _kernel.LoggerLoaded -= kernel_LoggerLoaded; } base.Dispose(dispose); } |
