From 5fa3817a7667b5de8822ed436b8a66bd05a1afde Mon Sep 17 00:00:00 2001 From: Luke Pulverenti Date: Sun, 26 Feb 2017 16:47:52 -0500 Subject: update components --- MediaBrowser.Api/Sync/SyncJobsWebSocketListener.cs | 101 --------------------- 1 file changed, 101 deletions(-) delete mode 100644 MediaBrowser.Api/Sync/SyncJobsWebSocketListener.cs (limited to 'MediaBrowser.Api/Sync/SyncJobsWebSocketListener.cs') diff --git a/MediaBrowser.Api/Sync/SyncJobsWebSocketListener.cs b/MediaBrowser.Api/Sync/SyncJobsWebSocketListener.cs deleted file mode 100644 index 5f9d1ff0e..000000000 --- a/MediaBrowser.Api/Sync/SyncJobsWebSocketListener.cs +++ /dev/null @@ -1,101 +0,0 @@ -using MediaBrowser.Controller.Sync; -using MediaBrowser.Model.Logging; -using MediaBrowser.Model.Sync; -using System.Collections.Generic; -using System.Threading.Tasks; -using MediaBrowser.Model.Threading; - -namespace MediaBrowser.Api.Sync -{ - /// - /// Class SessionInfoWebSocketListener - /// - class SyncJobsWebSocketListener : BasePeriodicWebSocketListener, WebSocketListenerState> - { - /// - /// Gets the name. - /// - /// The name. - protected override string Name - { - get { return "SyncJobs"; } - } - - private readonly ISyncManager _syncManager; - private string _userId; - private string _targetId; - - public SyncJobsWebSocketListener(ILogger logger, ISyncManager syncManager, ITimerFactory timerFactory) - : base(logger, timerFactory) - { - _syncManager = syncManager; - _syncManager.SyncJobCancelled += _syncManager_SyncJobCancelled; - _syncManager.SyncJobCreated += _syncManager_SyncJobCreated; - _syncManager.SyncJobUpdated += _syncManager_SyncJobUpdated; - } - - protected override void ParseMessageParams(string[] values) - { - base.ParseMessageParams(values); - - if (values.Length > 0) - { - _userId = values[0]; - } - - if (values.Length > 1) - { - _targetId = values[1]; - } - } - - void _syncManager_SyncJobUpdated(object sender, Model.Events.GenericEventArgs e) - { - SendData(false); - } - - void _syncManager_SyncJobCreated(object sender, Model.Events.GenericEventArgs e) - { - SendData(true); - } - - void _syncManager_SyncJobCancelled(object sender, Model.Events.GenericEventArgs e) - { - SendData(true); - } - - /// - /// Gets the data to send. - /// - /// The state. - /// Task{SystemInfo}. - protected override async Task> GetDataToSend(WebSocketListenerState state) - { - var jobs = await _syncManager.GetJobs(new SyncJobQuery - { - UserId = _userId, - TargetId = _targetId - - }).ConfigureAwait(false); - - return jobs.Items; - } - - protected override bool SendOnTimer - { - get - { - return false; - } - } - - protected override void Dispose(bool dispose) - { - _syncManager.SyncJobCancelled -= _syncManager_SyncJobCancelled; - _syncManager.SyncJobCreated -= _syncManager_SyncJobCreated; - _syncManager.SyncJobUpdated -= _syncManager_SyncJobUpdated; - - base.Dispose(dispose); - } - } -} -- cgit v1.2.3