aboutsummaryrefslogtreecommitdiff
path: root/MediaBrowser.Server.Implementations/WebSocket
diff options
context:
space:
mode:
authorLuke Pulverenti <luke.pulverenti@gmail.com>2014-02-25 23:38:21 -0500
committerLuke Pulverenti <luke.pulverenti@gmail.com>2014-02-25 23:38:21 -0500
commit13563b604756152fe2f6630a4cb8fd2994e5bb62 (patch)
tree367a886bcb57360e635da48046c87eaff243625d /MediaBrowser.Server.Implementations/WebSocket
parent7767580a3bff0d3a6ddc36b32784c0d49bb6b5f7 (diff)
Add upnp configuration
Diffstat (limited to 'MediaBrowser.Server.Implementations/WebSocket')
-rw-r--r--MediaBrowser.Server.Implementations/WebSocket/FleckServer.cs54
-rw-r--r--MediaBrowser.Server.Implementations/WebSocket/FleckWebSocket.cs47
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; }
- }
-}