Server

Server/Client.cs

@@ -1,10 +1,65 @@
 using System;
 using System.Collections.Generic;
+using System.IO;
+using System.Net;
+using System.Net.Sockets;
 using System.Text;
+using Newtonsoft;
+using Newtonsoft.Json;
 
 namespace Server
 {
     class Client
     {
+        private Communication communication;
+        private TcpClient tcpClient;
+        private NetworkStream stream;
+        private byte[] buffer = new byte[1024];
+        private byte[] totalBuffer = new byte[1024];
+
+        public string Username { get; set; }
+
+        public Client(Communication communication, TcpClient tcpClient)
+        {
+            this.communication = communication;
+            this.tcpClient = tcpClient;
+            this.stream = this.tcpClient.GetStream();
+            stream.BeginRead(buffer, 0, buffer.Length, new AsyncCallback(OnRead), null);
+        }
+
+        private void OnRead(IAsyncResult ar)
+        {
+            try
+            {
+                int receivedBytes = stream.EndRead(ar);
+              
+            }
+            catch (IOException)
+            {
+                communication.Disconnect(this);
+                return;
+            }
+
+            int counter = 0;
+
+            while (buffer.Length > counter)
+            {
+                byte[] lenghtBytes = new byte[4];
+                Array.Copy(buffer, counter, lenghtBytes, 0, 4);
+                int length = Convert.ToInt32(lenghtBytes);
+                byte[] packet = new byte[length];
+                Array.Copy(buffer, counter + 4, packet, 0, length-4);
+                HandleData(Encoding.Default.GetString(packet));
+                counter += length;
+            }
+
+            stream.BeginRead(buffer, 0, buffer.Length, new AsyncCallback(OnRead), null);
+        }
+
+        private void HandleData(string packet)
+        {
+            Console.WriteLine(packet);
+            JsonConvert.DeserializeObject(packet);
+        }
     }
 }