diff options
| author | Luke Pulverenti <luke.pulverenti@gmail.com> | 2016-08-19 18:56:32 -0400 |
|---|---|---|
| committer | Luke Pulverenti <luke.pulverenti@gmail.com> | 2016-08-19 18:56:32 -0400 |
| commit | f8b76758e67acc1dec673a03589e847fa561919b (patch) | |
| tree | b85041cab36e65a4f8cf4a3cbc8f6a793a9e7d3a /MediaBrowser.Server.Implementations/Sync/SyncNotificationEntryPoint.cs | |
| parent | f5ad9186ec3730b92cfdf06947ae6a85912867dc (diff) | |
remove fingerprintjs
Diffstat (limited to 'MediaBrowser.Server.Implementations/Sync/SyncNotificationEntryPoint.cs')
| -rw-r--r-- | MediaBrowser.Server.Implementations/Sync/SyncNotificationEntryPoint.cs | 48 |
1 files changed, 48 insertions, 0 deletions
diff --git a/MediaBrowser.Server.Implementations/Sync/SyncNotificationEntryPoint.cs b/MediaBrowser.Server.Implementations/Sync/SyncNotificationEntryPoint.cs new file mode 100644 index 000000000..7017b422e --- /dev/null +++ b/MediaBrowser.Server.Implementations/Sync/SyncNotificationEntryPoint.cs @@ -0,0 +1,48 @@ +using System.Threading; +using MediaBrowser.Controller.Plugins; +using MediaBrowser.Controller.Session; +using MediaBrowser.Controller.Sync; +using MediaBrowser.Model.Events; +using MediaBrowser.Model.Sync; + +namespace MediaBrowser.Server.Implementations.Sync +{ + public class SyncNotificationEntryPoint : IServerEntryPoint + { + private readonly ISessionManager _sessionManager; + private readonly ISyncManager _syncManager; + + public SyncNotificationEntryPoint(ISyncManager syncManager, ISessionManager sessionManager) + { + _syncManager = syncManager; + _sessionManager = sessionManager; + } + + public void Run() + { + _syncManager.SyncJobItemUpdated += _syncManager_SyncJobItemUpdated; + } + + private async void _syncManager_SyncJobItemUpdated(object sender, GenericEventArgs<SyncJobItem> e) + { + var item = e.Argument; + + if (item.Status == SyncJobItemStatus.ReadyToTransfer) + { + try + { + await _sessionManager.SendMessageToUserDeviceSessions(item.TargetId, "SyncJobItemReady", item, CancellationToken.None).ConfigureAwait(false); + } + catch + { + + } + } + } + + public void Dispose() + { + _syncManager.SyncJobItemUpdated -= _syncManager_SyncJobItemUpdated; + } + } +} |
