aboutsummaryrefslogtreecommitdiff
path: root/MediaBrowser.Api/Sync/SyncJobsWebSocketListener.cs
diff options
context:
space:
mode:
Diffstat (limited to 'MediaBrowser.Api/Sync/SyncJobsWebSocketListener.cs')
-rw-r--r--MediaBrowser.Api/Sync/SyncJobsWebSocketListener.cs101
1 files changed, 0 insertions, 101 deletions
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
-{
- /// <summary>
- /// Class SessionInfoWebSocketListener
- /// </summary>
- class SyncJobsWebSocketListener : BasePeriodicWebSocketListener<IEnumerable<SyncJob>, WebSocketListenerState>
- {
- /// <summary>
- /// Gets the name.
- /// </summary>
- /// <value>The name.</value>
- 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<SyncJob> e)
- {
- SendData(false);
- }
-
- void _syncManager_SyncJobCreated(object sender, Model.Events.GenericEventArgs<SyncJobCreationResult> e)
- {
- SendData(true);
- }
-
- void _syncManager_SyncJobCancelled(object sender, Model.Events.GenericEventArgs<SyncJob> e)
- {
- SendData(true);
- }
-
- /// <summary>
- /// Gets the data to send.
- /// </summary>
- /// <param name="state">The state.</param>
- /// <returns>Task{SystemInfo}.</returns>
- protected override async Task<IEnumerable<SyncJob>> 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);
- }
- }
-}