diff options
| author | Luke Pulverenti <luke.pulverenti@gmail.com> | 2014-02-25 23:38:21 -0500 |
|---|---|---|
| committer | Luke Pulverenti <luke.pulverenti@gmail.com> | 2014-02-25 23:38:21 -0500 |
| commit | 13563b604756152fe2f6630a4cb8fd2994e5bb62 (patch) | |
| tree | 367a886bcb57360e635da48046c87eaff243625d /MediaBrowser.Server.Implementations/WebSocket | |
| parent | 7767580a3bff0d3a6ddc36b32784c0d49bb6b5f7 (diff) | |
Add upnp configuration
Diffstat (limited to 'MediaBrowser.Server.Implementations/WebSocket')
| -rw-r--r-- | MediaBrowser.Server.Implementations/WebSocket/FleckServer.cs | 54 | ||||
| -rw-r--r-- | MediaBrowser.Server.Implementations/WebSocket/FleckWebSocket.cs | 47 |
2 files changed, 0 insertions, 101 deletions
diff --git a/MediaBrowser.Server.Implementations/WebSocket/FleckServer.cs b/MediaBrowser.Server.Implementations/WebSocket/FleckServer.cs deleted file mode 100644 index 2c47a366e..000000000 --- a/MediaBrowser.Server.Implementations/WebSocket/FleckServer.cs +++ /dev/null @@ -1,54 +0,0 @@ -using Fleck; -using MediaBrowser.Common.Net; -using System; -using IWebSocketServer = MediaBrowser.Common.Net.IWebSocketServer; - -namespace MediaBrowser.Server.Implementations.WebSocket -{ - public class FleckServer : IWebSocketServer - { - private WebSocketServer _server; - - public void Start(int portNumber) - { - var server = new WebSocketServer("ws://localhost:" + portNumber); - - server.Start(socket => - { - socket.OnOpen = () => OnClientConnected(socket); - }); - - _server = server; - } - - public void Stop() - { - _server.Dispose(); - } - - private void OnClientConnected(Fleck.IWebSocketConnection context) - { - if (WebSocketConnected != null) - { - var socket = new FleckWebSocket(context); - - WebSocketConnected(this, new WebSocketConnectEventArgs - { - WebSocket = socket, - Endpoint = context.ConnectionInfo.ClientIpAddress + ":" + context.ConnectionInfo.ClientPort - }); - } - } - public event EventHandler<WebSocketConnectEventArgs> WebSocketConnected; - - public int Port - { - get { return _server.Port; } - } - - public void Dispose() - { - _server.Dispose(); - } - } -} diff --git a/MediaBrowser.Server.Implementations/WebSocket/FleckWebSocket.cs b/MediaBrowser.Server.Implementations/WebSocket/FleckWebSocket.cs deleted file mode 100644 index 3667fab07..000000000 --- a/MediaBrowser.Server.Implementations/WebSocket/FleckWebSocket.cs +++ /dev/null @@ -1,47 +0,0 @@ -using MediaBrowser.Common.Net; -using MediaBrowser.Model.Net; -using System; -using System.Threading; -using System.Threading.Tasks; -using IWebSocketConnection = Fleck.IWebSocketConnection; - -namespace MediaBrowser.Server.Implementations.WebSocket -{ - public class FleckWebSocket : IWebSocket - { - private readonly IWebSocketConnection _connection; - - public FleckWebSocket(IWebSocketConnection connection) - { - _connection = connection; - - _connection.OnMessage = OnReceiveData; - } - - public WebSocketState State - { - get { return _connection.IsAvailable ? WebSocketState.Open : WebSocketState.Closed; } - } - - private void OnReceiveData(string data) - { - if (OnReceive != null) - { - OnReceive(data); - } - } - - public Task SendAsync(byte[] bytes, WebSocketMessageType type, bool endOfMessage, CancellationToken cancellationToken) - { - return Task.Run(() => _connection.Send(bytes)); - } - - public void Dispose() - { - _connection.Close(); - } - - public Action<byte[]> OnReceiveBytes { get; set; } - public Action<string> OnReceive { get; set; } - } -} |
