diff options
| author | Luke Pulverenti <luke.pulverenti@gmail.com> | 2014-08-11 10:15:53 -0400 |
|---|---|---|
| committer | Luke Pulverenti <luke.pulverenti@gmail.com> | 2014-08-11 10:15:53 -0400 |
| commit | 7bff6661362e4a5959eec2cab5323ca880df2ad7 (patch) | |
| tree | 7df9077eb0d722813255cbe669ffd3013dfa8c99 /MediaBrowser.Api/System/ActivityLogWebSocketListener.cs | |
| parent | e84ba17b9f48a3bc8811b1a89c54c25bc6607599 (diff) | |
update translations
Diffstat (limited to 'MediaBrowser.Api/System/ActivityLogWebSocketListener.cs')
| -rw-r--r-- | MediaBrowser.Api/System/ActivityLogWebSocketListener.cs | 67 |
1 files changed, 67 insertions, 0 deletions
diff --git a/MediaBrowser.Api/System/ActivityLogWebSocketListener.cs b/MediaBrowser.Api/System/ActivityLogWebSocketListener.cs new file mode 100644 index 000000000..4629b2a8c --- /dev/null +++ b/MediaBrowser.Api/System/ActivityLogWebSocketListener.cs @@ -0,0 +1,67 @@ +using MediaBrowser.Common.Net; +using MediaBrowser.Controller.Activity; +using MediaBrowser.Model.Activity; +using MediaBrowser.Model.Events; +using MediaBrowser.Model.Logging; +using System.Collections.Generic; +using System.Threading.Tasks; + +namespace MediaBrowser.Api.System +{ + /// <summary> + /// Class SessionInfoWebSocketListener + /// </summary> + class ActivityLogWebSocketListener : BasePeriodicWebSocketListener<List<ActivityLogEntry>, WebSocketListenerState> + { + /// <summary> + /// Gets the name. + /// </summary> + /// <value>The name.</value> + protected override string Name + { + get { return "ActivityLogEntry"; } + } + + /// <summary> + /// The _kernel + /// </summary> + private readonly IActivityManager _activityManager; + + public ActivityLogWebSocketListener(ILogger logger, IActivityManager activityManager) + : base(logger) + { + _activityManager = activityManager; + _activityManager.EntryCreated += _activityManager_EntryCreated; + } + + void _activityManager_EntryCreated(object sender, GenericEventArgs<ActivityLogEntry> e) + { + SendData(true); + } + + /// <summary> + /// Gets the data to send. + /// </summary> + /// <param name="state">The state.</param> + /// <returns>Task{SystemInfo}.</returns> + protected override Task<List<ActivityLogEntry>> GetDataToSend(WebSocketListenerState state) + { + return Task.FromResult(new List<ActivityLogEntry>()); + } + + protected override bool SendOnTimer + { + get + { + return false; + } + } + + protected override void Dispose(bool dispose) + { + _activityManager.EntryCreated -= _activityManager_EntryCreated; + + base.Dispose(dispose); + } + } +} |
