2019-01-13 15:01:16 -05:00
|
|
|
using System.Collections.Generic;
|
2019-01-13 14:24:58 -05:00
|
|
|
using System.Threading.Tasks;
|
|
|
|
using MediaBrowser.Controller.Library;
|
2014-12-26 14:34:39 -05:00
|
|
|
using MediaBrowser.Controller.Net;
|
2013-05-30 23:38:46 -04:00
|
|
|
using MediaBrowser.Controller.Session;
|
2018-12-13 08:18:25 -05:00
|
|
|
using Microsoft.Extensions.Logging;
|
2013-05-30 23:38:46 -04:00
|
|
|
|
2020-08-03 15:09:32 -04:00
|
|
|
namespace Jellyfin.Api.WebSocketListeners
|
2013-05-30 23:38:46 -04:00
|
|
|
{
|
|
|
|
/// <summary>
|
2020-06-15 18:37:52 -04:00
|
|
|
/// Class SessionInfoWebSocketListener.
|
2013-05-30 23:38:46 -04:00
|
|
|
/// </summary>
|
2019-02-15 17:05:14 -05:00
|
|
|
public class SessionInfoWebSocketListener : BasePeriodicWebSocketListener<IEnumerable<SessionInfo>, WebSocketListenerState>
|
2013-05-30 23:38:46 -04:00
|
|
|
{
|
|
|
|
private readonly ISessionManager _sessionManager;
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
/// Initializes a new instance of the <see cref="SessionInfoWebSocketListener"/> class.
|
|
|
|
/// </summary>
|
2020-08-03 15:33:43 -04:00
|
|
|
/// <param name="logger">Instance of the <see cref="ILogger{SessionInfoWebSocketListener}"/> interface.</param>
|
|
|
|
/// <param name="sessionManager">Instance of the <see cref="ISessionManager"/> interface.</param>
|
2020-03-03 17:07:10 -05:00
|
|
|
public SessionInfoWebSocketListener(ILogger<SessionInfoWebSocketListener> logger, ISessionManager sessionManager)
|
2018-09-12 13:26:21 -04:00
|
|
|
: base(logger)
|
2013-05-30 23:38:46 -04:00
|
|
|
{
|
|
|
|
_sessionManager = sessionManager;
|
2014-05-13 20:46:45 -04:00
|
|
|
|
2019-12-17 17:15:02 -05:00
|
|
|
_sessionManager.SessionStarted += OnSessionManagerSessionStarted;
|
|
|
|
_sessionManager.SessionEnded += OnSessionManagerSessionEnded;
|
|
|
|
_sessionManager.PlaybackStart += OnSessionManagerPlaybackStart;
|
|
|
|
_sessionManager.PlaybackStopped += OnSessionManagerPlaybackStopped;
|
|
|
|
_sessionManager.PlaybackProgress += OnSessionManagerPlaybackProgress;
|
|
|
|
_sessionManager.CapabilitiesChanged += OnSessionManagerCapabilitiesChanged;
|
|
|
|
_sessionManager.SessionActivity += OnSessionManagerSessionActivity;
|
2014-05-13 20:46:45 -04:00
|
|
|
}
|
|
|
|
|
2020-08-03 15:33:43 -04:00
|
|
|
/// <inheritdoc />
|
|
|
|
protected override string Name => "Sessions";
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
/// Gets the data to send.
|
|
|
|
/// </summary>
|
|
|
|
/// <returns>Task{SystemInfo}.</returns>
|
|
|
|
protected override Task<IEnumerable<SessionInfo>> GetDataToSend()
|
|
|
|
{
|
|
|
|
return Task.FromResult(_sessionManager.Sessions);
|
|
|
|
}
|
|
|
|
|
|
|
|
/// <inheritdoc />
|
|
|
|
protected override void Dispose(bool dispose)
|
|
|
|
{
|
|
|
|
_sessionManager.SessionStarted -= OnSessionManagerSessionStarted;
|
|
|
|
_sessionManager.SessionEnded -= OnSessionManagerSessionEnded;
|
|
|
|
_sessionManager.PlaybackStart -= OnSessionManagerPlaybackStart;
|
|
|
|
_sessionManager.PlaybackStopped -= OnSessionManagerPlaybackStopped;
|
|
|
|
_sessionManager.PlaybackProgress -= OnSessionManagerPlaybackProgress;
|
|
|
|
_sessionManager.CapabilitiesChanged -= OnSessionManagerCapabilitiesChanged;
|
|
|
|
_sessionManager.SessionActivity -= OnSessionManagerSessionActivity;
|
|
|
|
|
|
|
|
base.Dispose(dispose);
|
|
|
|
}
|
|
|
|
|
2020-05-25 17:52:51 -04:00
|
|
|
private async void OnSessionManagerSessionActivity(object sender, SessionEventArgs e)
|
2014-05-13 20:46:45 -04:00
|
|
|
{
|
2020-05-25 17:52:51 -04:00
|
|
|
await SendData(false).ConfigureAwait(false);
|
2014-05-13 20:46:45 -04:00
|
|
|
}
|
|
|
|
|
2020-05-25 17:52:51 -04:00
|
|
|
private async void OnSessionManagerCapabilitiesChanged(object sender, SessionEventArgs e)
|
2014-05-13 20:46:45 -04:00
|
|
|
{
|
2020-05-25 17:52:51 -04:00
|
|
|
await SendData(true).ConfigureAwait(false);
|
2014-05-13 20:46:45 -04:00
|
|
|
}
|
|
|
|
|
2020-05-25 17:52:51 -04:00
|
|
|
private async void OnSessionManagerPlaybackProgress(object sender, PlaybackProgressEventArgs e)
|
2014-05-13 20:46:45 -04:00
|
|
|
{
|
2020-05-25 17:52:51 -04:00
|
|
|
await SendData(!e.IsAutomated).ConfigureAwait(false);
|
2014-05-13 20:46:45 -04:00
|
|
|
}
|
|
|
|
|
2020-05-25 17:52:51 -04:00
|
|
|
private async void OnSessionManagerPlaybackStopped(object sender, PlaybackStopEventArgs e)
|
2014-05-13 20:46:45 -04:00
|
|
|
{
|
2020-05-25 17:52:51 -04:00
|
|
|
await SendData(true).ConfigureAwait(false);
|
2014-05-13 20:46:45 -04:00
|
|
|
}
|
|
|
|
|
2020-05-25 17:52:51 -04:00
|
|
|
private async void OnSessionManagerPlaybackStart(object sender, PlaybackProgressEventArgs e)
|
2014-05-13 20:46:45 -04:00
|
|
|
{
|
2020-05-25 17:52:51 -04:00
|
|
|
await SendData(true).ConfigureAwait(false);
|
2014-05-13 20:46:45 -04:00
|
|
|
}
|
|
|
|
|
2020-05-25 17:52:51 -04:00
|
|
|
private async void OnSessionManagerSessionEnded(object sender, SessionEventArgs e)
|
2014-05-13 20:46:45 -04:00
|
|
|
{
|
2020-05-25 17:52:51 -04:00
|
|
|
await SendData(true).ConfigureAwait(false);
|
2014-05-13 20:46:45 -04:00
|
|
|
}
|
|
|
|
|
2020-05-25 17:52:51 -04:00
|
|
|
private async void OnSessionManagerSessionStarted(object sender, SessionEventArgs e)
|
2014-05-13 20:46:45 -04:00
|
|
|
{
|
2020-05-25 17:52:51 -04:00
|
|
|
await SendData(true).ConfigureAwait(false);
|
2013-05-30 23:38:46 -04:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|