aboutsummaryrefslogtreecommitdiff
path: root/MediaBrowser.Server.Implementations/WebSocket
diff options
context:
space:
mode:
Diffstat (limited to 'MediaBrowser.Server.Implementations/WebSocket')
-rw-r--r--MediaBrowser.Server.Implementations/WebSocket/AlchemyServer.cs165
-rw-r--r--MediaBrowser.Server.Implementations/WebSocket/AlchemyWebSocket.cs134
2 files changed, 0 insertions, 299 deletions
diff --git a/MediaBrowser.Server.Implementations/WebSocket/AlchemyServer.cs b/MediaBrowser.Server.Implementations/WebSocket/AlchemyServer.cs
deleted file mode 100644
index 454dff4b9..000000000
--- a/MediaBrowser.Server.Implementations/WebSocket/AlchemyServer.cs
+++ /dev/null
@@ -1,165 +0,0 @@
-using Alchemy;
-using Alchemy.Classes;
-using MediaBrowser.Common.Net;
-using MediaBrowser.Model.Logging;
-using System;
-using System.Net;
-#if __MonoCS__
-using Mono.Unix.Native;
-#endif
-
-namespace MediaBrowser.Server.Implementations.WebSocket
-{
- /// <summary>
- /// Class AlchemyServer
- /// </summary>
- public class AlchemyServer : IWebSocketServer
- {
- /// <summary>
- /// Occurs when [web socket connected].
- /// </summary>
- public event EventHandler<WebSocketConnectEventArgs> WebSocketConnected;
-
- /// <summary>
- /// Gets or sets the web socket server.
- /// </summary>
- /// <value>The web socket server.</value>
- private WebSocketServer WebSocketServer { get; set; }
-
- /// <summary>
- /// The _logger
- /// </summary>
- private readonly ILogger _logger;
-
- private bool _hasStopped;
-
- /// <summary>
- /// Initializes a new instance of the <see cref="AlchemyServer" /> class.
- /// </summary>
- /// <param name="logger">The logger.</param>
- /// <exception cref="System.ArgumentNullException">logger</exception>
- public AlchemyServer(ILogger logger)
- {
- if (logger == null)
- {
- throw new ArgumentNullException("logger");
- }
- _logger = logger;
- }
-
- /// <summary>
- /// Gets the port.
- /// </summary>
- /// <value>The port.</value>
- public int Port { get; private set; }
-
- /// <summary>
- /// Starts the specified port number.
- /// </summary>
- /// <param name="portNumber">The port number.</param>
- public void Start(int portNumber)
- {
- _logger.Info("Starting Alchemy web socket server on port {0}", portNumber);
-
- try
- {
- WebSocketServer = new WebSocketServer(portNumber, IPAddress.Any)
- {
- OnConnected = OnAlchemyWebSocketClientConnected,
- TimeOut = TimeSpan.FromHours(24)
- };
-
- #if __MonoCS__
- //Linux: port below 1024 require root or cap_net_bind_service
- if (Environment.OSVersion.Platform == PlatformID.Unix || Environment.OSVersion.Platform == PlatformID.MacOSX)
- {
- if (Syscall.getuid() == 0)
- {
- WebSocketServer.FlashAccessPolicyEnabled = true;
- }
- else
- {
- WebSocketServer.FlashAccessPolicyEnabled = false;
- }
- }
- #endif
- WebSocketServer.Start();
- }
- catch (Exception ex)
- {
- _logger.ErrorException("The web socket server is unable to start on port {0} due to a Socket error. This can occasionally happen when the operating system takes longer than usual to release the IP bindings from the previous session. This can take up to five minutes. Please try waiting or rebooting the system.", ex, portNumber);
-
- throw;
- }
-
- Port = portNumber;
-
- _logger.Info("Alchemy Web Socket Server started");
- }
-
- /// <summary>
- /// Called when [alchemy web socket client connected].
- /// </summary>
- /// <param name="context">The context.</param>
- private void OnAlchemyWebSocketClientConnected(UserContext context)
- {
- if (_hasStopped)
- {
- return;
- }
-
- if (WebSocketConnected != null)
- {
- var socket = new AlchemyWebSocket(context, _logger);
-
- WebSocketConnected(this, new WebSocketConnectEventArgs
- {
- WebSocket = socket,
- Endpoint = context.ClientAddress.ToString()
- });
- }
- }
-
- /// <summary>
- /// Stops this instance.
- /// </summary>
- public void Stop()
- {
- if (WebSocketServer != null)
- {
- WebSocketServer.Stop();
- }
- }
-
- /// <summary>
- /// Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
- /// </summary>
- public void Dispose()
- {
- Dispose(true);
- GC.SuppressFinalize(this);
- }
-
- private readonly object _syncLock = new object();
-
- /// <summary>
- /// Releases unmanaged and - optionally - managed resources.
- /// </summary>
- /// <param name="dispose"><c>true</c> to release both managed and unmanaged resources; <c>false</c> to release only unmanaged resources.</param>
- protected virtual void Dispose(bool dispose)
- {
- _hasStopped = true;
-
- lock (_syncLock)
- {
- if (WebSocketServer != null)
- {
- _logger.Debug("Disposing alchemy server");
-
- WebSocketServer.Dispose();
- WebSocketServer = null;
- }
- }
- }
- }
-}
diff --git a/MediaBrowser.Server.Implementations/WebSocket/AlchemyWebSocket.cs b/MediaBrowser.Server.Implementations/WebSocket/AlchemyWebSocket.cs
deleted file mode 100644
index 35c5e780b..000000000
--- a/MediaBrowser.Server.Implementations/WebSocket/AlchemyWebSocket.cs
+++ /dev/null
@@ -1,134 +0,0 @@
-using Alchemy.Classes;
-using MediaBrowser.Common.Events;
-using MediaBrowser.Common.Net;
-using MediaBrowser.Model.Logging;
-using MediaBrowser.Model.Net;
-using System;
-using System.Threading;
-using System.Threading.Tasks;
-
-namespace MediaBrowser.Server.Implementations.WebSocket
-{
- /// <summary>
- /// Class AlchemyWebSocket
- /// </summary>
- public class AlchemyWebSocket : IWebSocket
- {
- /// <summary>
- /// The logger
- /// </summary>
- private readonly ILogger _logger;
-
- public event EventHandler<EventArgs> Closed;
-
- /// <summary>
- /// Gets or sets the web socket.
- /// </summary>
- /// <value>The web socket.</value>
- private UserContext UserContext { get; set; }
-
- /// <summary>
- /// Initializes a new instance of the <see cref="AlchemyWebSocket" /> class.
- /// </summary>
- /// <param name="context">The context.</param>
- /// <param name="logger">The logger.</param>
- /// <exception cref="System.ArgumentNullException">context</exception>
- public AlchemyWebSocket(UserContext context, ILogger logger)
- {
- if (context == null)
- {
- throw new ArgumentNullException("context");
- }
-
- _logger = logger;
- UserContext = context;
-
- context.SetOnDisconnect(OnDisconnected);
- context.SetOnReceive(OnReceiveContext);
-
- _logger.Info("Client connected from {0}", context.ClientAddress);
- }
-
- /// <summary>
- /// The _disconnected
- /// </summary>
- private bool _disconnected;
- /// <summary>
- /// Gets or sets the state.
- /// </summary>
- /// <value>The state.</value>
- public WebSocketState State
- {
- get { return _disconnected ? WebSocketState.Closed : WebSocketState.Open; }
- }
-
- /// <summary>
- /// Called when [disconnected].
- /// </summary>
- /// <param name="context">The context.</param>
- private void OnDisconnected(UserContext context)
- {
- _disconnected = true;
-
- EventHelper.FireEventIfNotNull(Closed, this, EventArgs.Empty, _logger);
- }
-
- /// <summary>
- /// Called when [receive].
- /// </summary>
- /// <param name="context">The context.</param>
- private void OnReceiveContext(UserContext context)
- {
- if (OnReceive != null)
- {
- var json = context.DataFrame.ToString();
-
- OnReceive(json);
- }
- }
-
- private readonly Task _cachedTask = Task.FromResult(true);
- /// <summary>
- /// Sends the async.
- /// </summary>
- /// <param name="bytes">The bytes.</param>
- /// <param name="type">The type.</param>
- /// <param name="endOfMessage">if set to <c>true</c> [end of message].</param>
- /// <param name="cancellationToken">The cancellation token.</param>
- /// <returns>Task.</returns>
- public Task SendAsync(byte[] bytes, WebSocketMessageType type, bool endOfMessage, CancellationToken cancellationToken)
- {
- UserContext.Send(bytes);
-
- return _cachedTask;
- }
-
- /// <summary>
- /// Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
- /// </summary>
- public void Dispose()
- {
- Dispose(true);
- }
-
- /// <summary>
- /// Releases unmanaged and - optionally - managed resources.
- /// </summary>
- /// <param name="dispose"><c>true</c> to release both managed and unmanaged resources; <c>false</c> to release only unmanaged resources.</param>
- protected virtual void Dispose(bool dispose)
- {
- }
-
- /// <summary>
- /// Gets or sets the receive action.
- /// </summary>
- /// <value>The receive action.</value>
- public Action<byte[]> OnReceiveBytes { get; set; }
-
- /// <summary>
- /// Gets or sets the on receive.
- /// </summary>
- /// <value>The on receive.</value>
- public Action<string> OnReceive { get; set; }
- }
-}
generated by cgit v1.2.3 (git 2.46.0) at 2025-12-07 23:32:49 +0000