WebSocketController.cs 3.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122
  1. #pragma warning disable CS1591
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Linq;
  5. using System.Net.WebSockets;
  6. using System.Threading;
  7. using System.Threading.Tasks;
  8. using MediaBrowser.Controller.Net;
  9. using MediaBrowser.Controller.Session;
  10. using MediaBrowser.Model.Net;
  11. using MediaBrowser.Model.Session;
  12. using Microsoft.Extensions.Logging;
  13. namespace Emby.Server.Implementations.Session
  14. {
  15. public sealed class WebSocketController : ISessionController, IAsyncDisposable, IDisposable
  16. {
  17. private readonly ILogger<WebSocketController> _logger;
  18. private readonly ISessionManager _sessionManager;
  19. private readonly SessionInfo _session;
  20. private readonly List<IWebSocketConnection> _sockets;
  21. private bool _disposed = false;
  22. public WebSocketController(
  23. ILogger<WebSocketController> logger,
  24. SessionInfo session,
  25. ISessionManager sessionManager)
  26. {
  27. _logger = logger;
  28. _session = session;
  29. _sessionManager = sessionManager;
  30. _sockets = new List<IWebSocketConnection>();
  31. }
  32. private bool HasOpenSockets => GetActiveSockets().Any();
  33. /// <inheritdoc />
  34. public bool SupportsMediaControl => HasOpenSockets;
  35. /// <inheritdoc />
  36. public bool IsSessionActive => HasOpenSockets;
  37. private IEnumerable<IWebSocketConnection> GetActiveSockets()
  38. => _sockets.Where(i => i.State == WebSocketState.Open);
  39. public void AddWebSocket(IWebSocketConnection connection)
  40. {
  41. _logger.LogDebug("Adding websocket to session {Session}", _session.Id);
  42. _sockets.Add(connection);
  43. connection.Closed += OnConnectionClosed;
  44. }
  45. private async void OnConnectionClosed(object? sender, EventArgs e)
  46. {
  47. var connection = sender as IWebSocketConnection ?? throw new ArgumentException($"{nameof(sender)} is not of type {nameof(IWebSocketConnection)}", nameof(sender));
  48. _logger.LogDebug("Removing websocket from session {Session}", _session.Id);
  49. _sockets.Remove(connection);
  50. connection.Closed -= OnConnectionClosed;
  51. await _sessionManager.CloseIfNeededAsync(_session).ConfigureAwait(false);
  52. }
  53. /// <inheritdoc />
  54. public Task SendMessage<T>(
  55. SessionMessageType name,
  56. Guid messageId,
  57. T data,
  58. CancellationToken cancellationToken)
  59. {
  60. var socket = GetActiveSockets().MaxBy(i => i.LastActivityDate);
  61. if (socket is null)
  62. {
  63. return Task.CompletedTask;
  64. }
  65. return socket.SendAsync(
  66. new WebSocketMessage<T>
  67. {
  68. Data = data,
  69. MessageType = name,
  70. MessageId = messageId
  71. },
  72. cancellationToken);
  73. }
  74. /// <inheritdoc />
  75. public void Dispose()
  76. {
  77. if (_disposed)
  78. {
  79. return;
  80. }
  81. foreach (var socket in _sockets)
  82. {
  83. socket.Closed -= OnConnectionClosed;
  84. socket.Dispose();
  85. }
  86. _disposed = true;
  87. }
  88. public async ValueTask DisposeAsync()
  89. {
  90. if (_disposed)
  91. {
  92. return;
  93. }
  94. foreach (var socket in _sockets)
  95. {
  96. socket.Closed -= OnConnectionClosed;
  97. await socket.DisposeAsync().ConfigureAwait(false);
  98. }
  99. _disposed = true;
  100. }
  101. }
  102. }