ServerSideClient.TCP Class Reference

Class for managing TCP connection. More...

Public Member Functions
	TCP (int id)
	Initializes a new TCP object with the given client ID.
void	Connect (TcpClient TcpSocket)
	Connects a TCP client and starts listening for data. Optionally initializes TLS, HMAC, and auth token.
void	Send (Packet sendPacket)
	Sends a packet over the TCP stream to the connected client.
void	Disconnect ()
	Closes the TCP connection and releases related resources.

Public Attributes
TcpClient	Socket
byte[]	hmacKey

Private Member Functions
bool	HandleData (byte[] Data)
	Handles received raw data and calls PacketAction() to manage packet type.
void	ReceiveCallback (IAsyncResult result)
	Callback function for receiving TCP data asynchronously.

Private Attributes
Stream	Stream
byte[]	receiveBuffer
readonly int	Id
Packet	receivedPacket

Detailed Description

Class for managing TCP connection.

Definition at line 209 of file ServerSideClient.cs.

Constructor & Destructor Documentation

TCP()

ServerSideClient.TCP.TCP

(

int

id

)

Initializes a new TCP object with the given client ID.

Definition at line 220 of file ServerSideClient.cs.

        {
            Id = id;
        }

Member Function Documentation

Connect()

void ServerSideClient.TCP.Connect

(

TcpClient

TcpSocket

)

Connects a TCP client and starts listening for data. Optionally initializes TLS, HMAC, and auth token.

Definition at line 227 of file ServerSideClient.cs.

        {
            Socket = TcpSocket; 
            Socket.ReceiveBufferSize = BufferSize;
            Socket.SendBufferSize = BufferSize;
            if (ServerLogic.GetSettings().useTLS == true)
            {
                SslStream SslStream = new SslStream(Socket.GetStream(), false); 
                try
                {
                    SslStream.AuthenticateAsServer(
                        ServerLogic.serverCertificate, 
                        false,                        
                        SslProtocols.Tls12,            
                        false                          
                    );
                    Stream = SslStream;
                }
                catch (Exception ex)
                {
                    ServerLogic.clientsList[Id].DisconnectRequest();
                    return;
                }
            } else
            {
                Stream = Socket.GetStream();
            }
            receiveBuffer = new byte[BufferSize]; 
            receivedPacket = new Packet();
            hmacKey = GenerateHmacKey();
            ServerLogic.clientsList[Id].hmacKey = hmacKey;
            ServerLogic.clientsList[Id].SetToken();
            Stream.BeginRead(receiveBuffer, 0, BufferSize, ReceiveCallback, null); 
            if(ServerLogic.GetServerSettings().sendWelcomeToServerMesage == true)
            {
                ServerSendHandler.WelcomePacket(Id, ServerLogic.GetServerSettings().welcomeToServerMessage);
            } else
            {
                ServerSendHandler.WelcomePacket(Id, "");
            }
            
            if(ServerLogic.GetSettings().useHMAC == true)
            {
                ServerSendHandler.SendHmacKeyPacket(Id, hmacKey);
            }
            if(ServerLogic.GetSettings().useAuthentificationTokens == true)
            {
                Console.WriteLine($"Sending auth token {ServerLogic.clientsList[Id].auth_token}");
                ServerSendHandler.SendAuthPacket(Id, ServerLogic.clientsList[Id].GetToken());
            }
        }

Disconnect()

void ServerSideClient.TCP.Disconnect

(

)

Closes the TCP connection and releases related resources.

Definition at line 342 of file ServerSideClient.cs.

        {
            Socket.Close();
            Stream = null;
            receivedPacket = null;
            receiveBuffer = null;
            Socket = null;
        }

HandleData()

bool ServerSideClient.TCP.HandleData ( byte[] Data )

private

Handles received raw data and calls PacketAction() to manage packet type.

Definition at line 298 of file ServerSideClient.cs.

        {
            if (ServerLogic.clientsList[Id].isDisconnected)
            {
                return false;
            }
            int packetLength = 0;
            receivedPacket.AddBytesToBuffers(Data);
            if (receivedPacket.UnreadLength() >= 4)
            {
                packetLength = receivedPacket.ReadInt();
                if (packetLength <= 0)
                {
                    return true;
                }
            }
            while (packetLength > 0 && packetLength <= receivedPacket.UnreadLength())
            {
                byte[] packetBytes = receivedPacket.ReadBytes(packetLength);
                ThreadsController.StartOnMainThread(() =>
                {
                    Packet packet = new Packet(packetBytes);
                    int packetId = packet.ReadInt();
                    ServerLogic.PacketAction(packetId, packet, Id);
                });
                packetLength = 0;
                if (receivedPacket.UnreadLength() >= 4)
                {
                    packetLength = receivedPacket.ReadInt();
                    if (packetLength <= 0)
                    {
                        return true;
                    }
                }
            }
            if (packetLength <= 1)
            {
                return true;
            }
            return false;
        }

ReceiveCallback()

void ServerSideClient.TCP.ReceiveCallback ( IAsyncResult result )

private

Callback function for receiving TCP data asynchronously.

Definition at line 353 of file ServerSideClient.cs.

        {
            try
            {
                if (Stream == null)
                {
                    return;
                }
                int ByteLength = Stream.EndRead(result); 
                if (ByteLength <= 0) 
                {
                    ServerLogic.clientsList[Id].Disconnect();
                    return;
                }
                byte[] Data = new byte[ByteLength];
                Array.Copy(receiveBuffer, Data, ByteLength);                                         
                receivedPacket.ClearPacket(HandleData(Data));
                Stream.BeginRead(receiveBuffer, 0, BufferSize, ReceiveCallback, null);
            }
            catch (Exception ex) 
            {
                ConsoleLog($"Error receiving TCP {ex}");
                ServerLogic.clientsList[Id].Disconnect();
            }
        }

Send()

void ServerSideClient.TCP.Send

(

Packet

sendPacket

)

Sends a packet over the TCP stream to the connected client.

Definition at line 281 of file ServerSideClient.cs.

        {
            try
            {
                if (Socket != null && Stream != null)
                {
                    Stream.Write(sendPacket.ConvertToArray());
                }
            }
            catch (Exception ex)
            {
                ConsoleLog($"Error, cannot send data to client {Id}: {ex}");
            }
        }

Member Data Documentation

hmacKey

byte [] ServerSideClient.TCP.hmacKey

Definition at line 216 of file ServerSideClient.cs.

Id

readonly int ServerSideClient.TCP.Id

private

Definition at line 214 of file ServerSideClient.cs.

receiveBuffer

byte [] ServerSideClient.TCP.receiveBuffer

private

Definition at line 212 of file ServerSideClient.cs.

receivedPacket

Packet ServerSideClient.TCP.receivedPacket

private

Definition at line 215 of file ServerSideClient.cs.

Socket

TcpClient ServerSideClient.TCP.Socket

Definition at line 213 of file ServerSideClient.cs.

Stream

Stream ServerSideClient.TCP.Stream

private

Definition at line 211 of file ServerSideClient.cs.