From 8b3e8ad478e96543aa437f5a416e7db48ce90a63 Mon Sep 17 00:00:00 2001 From: LukePulverenti Date: Fri, 22 Feb 2013 10:16:48 -0500 Subject: created IWebSocketListener --- .../WebSocket/LogFileWebSocketListener.cs | 33 ++++++++++------------ 1 file changed, 15 insertions(+), 18 deletions(-) (limited to 'MediaBrowser.Api/WebSocket/LogFileWebSocketListener.cs') 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 /// [Export(typeof(IWebSocketListener))] - public class LogFileWebSocketListener : BasePeriodicWebSocketListener, LogFileWebSocketState> + public class LogFileWebSocketListener : BasePeriodicWebSocketListener, LogFileWebSocketState> { /// /// Gets the name. @@ -25,26 +26,22 @@ namespace MediaBrowser.Api.WebSocket get { return "LogFile"; } } + /// + /// The _kernel + /// + private readonly IKernel _kernel; + /// /// Initializes a new instance of the class. /// /// The logger. + /// The kernel. [ImportingConstructor] - public LogFileWebSocketListener([Import("logger")] ILogger logger) + public LogFileWebSocketListener([Import("logger")] ILogger logger, [Import("kernel")] Kernel kernel) : base(logger) { - - } - - /// - /// Initializes the specified kernel. - /// - /// The kernel. - public override void Initialize(IKernel kernel) - { - base.Initialize(kernel); - - kernel.LoggerLoaded += kernel_LoggerLoaded; + _kernel = kernel; + _kernel.LoggerLoaded += kernel_LoggerLoaded; } /// @@ -54,9 +51,9 @@ namespace MediaBrowser.Api.WebSocket /// IEnumerable{System.String}. protected override async Task> 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); } -- cgit v1.2.3