From 98992ca580a3e921d57653161c7a27f2442e4dd3 Mon Sep 17 00:00:00 2001
From: Luke Pulverenti <luke.pulverenti@gmail.com>
Date: Sun, 8 Mar 2015 14:49:51 -0400
Subject: [PATCH] simplify message parsing

---
 .../HttpServer/SocketSharp/SharpWebSocket.cs  |  3 ++-
 .../ServerManager/WebSocketConnection.cs      | 24 +++++++++----------
 2 files changed, 14 insertions(+), 13 deletions(-)

diff --git a/MediaBrowser.Server.Implementations/HttpServer/SocketSharp/SharpWebSocket.cs b/MediaBrowser.Server.Implementations/HttpServer/SocketSharp/SharpWebSocket.cs
index 9dcb679f4d..583b8809d9 100644
--- a/MediaBrowser.Server.Implementations/HttpServer/SocketSharp/SharpWebSocket.cs
+++ b/MediaBrowser.Server.Implementations/HttpServer/SocketSharp/SharpWebSocket.cs
@@ -65,9 +65,10 @@ namespace MediaBrowser.Server.Implementations.HttpServer.SocketSharp
 
         void socket_OnMessage(object sender, SocketHttpListener.MessageEventArgs e)
         {
-            if (OnReceive != null)
+            if (OnReceiveBytes != null)
             {
                 OnReceiveBytes(e.RawData);
+                //OnReceive(e.Data);
             }
         }
 
diff --git a/MediaBrowser.Server.Implementations/ServerManager/WebSocketConnection.cs b/MediaBrowser.Server.Implementations/ServerManager/WebSocketConnection.cs
index 9f75d522c9..08e4c2ec2e 100644
--- a/MediaBrowser.Server.Implementations/ServerManager/WebSocketConnection.cs
+++ b/MediaBrowser.Server.Implementations/ServerManager/WebSocketConnection.cs
@@ -1,4 +1,5 @@
-using MediaBrowser.Common.Events;
+using System.Text;
+using MediaBrowser.Common.Events;
 using MediaBrowser.Controller.Net;
 using MediaBrowser.Model.Logging;
 using MediaBrowser.Model.Net;
@@ -122,22 +123,21 @@ namespace MediaBrowser.Server.Implementations.ServerManager
             }
             try
             {
-                WebSocketMessageInfo info;
-
+                //_logger.Debug(Encoding.UTF8.GetString(bytes));
                 using (var memoryStream = new MemoryStream(bytes))
                 {
-                    var stub = (WebSocketMessage<object>)_jsonSerializer.DeserializeFromStream(memoryStream, typeof(WebSocketMessage<object>));
+                    var info = (WebSocketMessageInfo)_jsonSerializer.DeserializeFromStream(memoryStream, typeof(WebSocketMessageInfo));
 
-                    info = new WebSocketMessageInfo
-                    {
-                        MessageType = stub.MessageType,
-                        Data = stub.Data == null ? null : stub.Data.ToString()
-                    };
+                    //info = new WebSocketMessageInfo
+                    //{
+                    //    MessageType = stub.MessageType,
+                    //    Data = stub.Data == null ? null : stub.Data.ToString()
+                    //};
+                    info.Connection = this;
+
+                    OnReceive(info);
                 }
 
-                info.Connection = this;
-
-                OnReceive(info);
             }
             catch (Exception ex)
             {