From 4f67fc4aefc11c1a4293227c70de922dbe03c652 Mon Sep 17 00:00:00 2001
From: LukePulverenti <luke.pulverenti@gmail.com>
Date: Thu, 7 Mar 2013 00:34:00 -0500
Subject: removed base kernel and ikernel

---
 .../WebSocket/AlchemyWebSocket.cs                  | 132 ---------------------
 1 file changed, 132 deletions(-)
 delete mode 100644 MediaBrowser.Common.Implementations/WebSocket/AlchemyWebSocket.cs

(limited to 'MediaBrowser.Common.Implementations/WebSocket/AlchemyWebSocket.cs')

diff --git a/MediaBrowser.Common.Implementations/WebSocket/AlchemyWebSocket.cs b/MediaBrowser.Common.Implementations/WebSocket/AlchemyWebSocket.cs
deleted file mode 100644
index 1ecc38f2c..000000000
--- a/MediaBrowser.Common.Implementations/WebSocket/AlchemyWebSocket.cs
+++ /dev/null
@@ -1,132 +0,0 @@
-using Alchemy.Classes;
-using MediaBrowser.Common.Net;
-using MediaBrowser.Model.Logging;
-using System;
-using System.Text;
-using System.Threading;
-using System.Threading.Tasks;
-
-namespace MediaBrowser.Common.Implementations.WebSocket
-{
-    /// <summary>
-    /// Class AlchemyWebSocket
-    /// </summary>
-    public class AlchemyWebSocket : IWebSocket
-    {
-        /// <summary>
-        /// The logger
-        /// </summary>
-        private readonly ILogger _logger;
-
-        /// <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(OnReceive);
-
-            _logger.Info("Client connected from {0}", context.ClientAddress);
-        }
-
-        /// <summary>
-        /// The _disconnected
-        /// </summary>
-        private bool _disconnected = false;
-        /// <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;
-        }
-
-        /// <summary>
-        /// Called when [receive].
-        /// </summary>
-        /// <param name="context">The context.</param>
-        private void OnReceive(UserContext context)
-        {
-            if (OnReceiveDelegate != null)
-            {
-                var json = context.DataFrame.ToString();
-
-                if (!string.IsNullOrWhiteSpace(json))
-                {
-                    try
-                    {
-                        var bytes = Encoding.UTF8.GetBytes(json);
-
-                        OnReceiveDelegate(bytes);
-                    }
-                    catch (Exception ex)
-                    {
-                        _logger.ErrorException("Error processing web socket message", ex);
-                    }
-                }
-            }
-        }
-        
-        /// <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)
-        {
-            return Task.Run(() => UserContext.Send(bytes));
-        }
-
-        /// <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[]> OnReceiveDelegate { get; set; }
-    }
-}
-- 
cgit v1.2.3