using System.Buffers; using System.Net; using System.Net.Sockets; using System.Runtime.InteropServices; using Shared; using Shared.Packet; using Shared.Packet.Packets; namespace Server; public class Server { public readonly List Clients = new List(); public readonly Logger Logger = new Logger("Server"); private readonly MemoryPool memoryPool = MemoryPool.Shared; public Func? PacketHandler = null!; public event Action ClientJoined = null!; public async Task Listen(CancellationToken? token = null) { Socket serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); serverSocket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReuseAddress, true); serverSocket.Bind(new IPEndPoint(IPAddress.Parse(Settings.Instance.Server.Address), Settings.Instance.Server.Port)); serverSocket.Listen(); Logger.Info($"Listening on {serverSocket.LocalEndPoint}"); try { while (true) { Socket socket = token.HasValue ? await serverSocket.AcceptAsync(token.Value) : await serverSocket.AcceptAsync(); socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.NoDelay, true); Logger.Warn($"Accepted connection for client {socket.RemoteEndPoint}"); try { if (Clients.Count == Settings.Instance.Server.MaxPlayers) { Logger.Warn("Turned away client due to max clients"); await socket.DisconnectAsync(false); continue; } Task.Run(() => HandleSocket(socket)); } catch (Exception e) { Logger.Error($"Error occured while setting up socket handler? {e}"); } } } catch (OperationCanceledException) { // ignore the exception, it's just for closing the server Logger.Info("Server closing"); try { serverSocket.Shutdown(SocketShutdown.Both); } catch { // ignored } finally { serverSocket.Close(); } Logger.Info("Server closed"); } } public static void FillPacket(PacketHeader header, T packet, Memory memory) where T : struct, IPacket { Span data = memory.Span; MemoryMarshal.Write(data, ref header); packet.Serialize(data[Constants.HeaderSize..]); } // broadcast packets to all clients public delegate void PacketReplacer(Client from, Client to, T value); // replacer must send public async Task BroadcastReplace(T packet, Client sender, PacketReplacer packetReplacer) where T : struct, IPacket { foreach (Client client in Clients.Where(client => sender.Id != client.Id)) packetReplacer(sender, client, packet); } public async Task Broadcast(T packet, Client sender) where T : struct, IPacket { IMemoryOwner memory = MemoryPool.Shared.RentZero(Constants.HeaderSize + packet.Size); PacketHeader header = new PacketHeader { Id = sender?.Id ?? Guid.Empty, Type = Constants.PacketMap[typeof(T)].Type, PacketSize = packet.Size }; FillPacket(header, packet, memory.Memory); await Broadcast(memory, sender); } public Task Broadcast(T packet) where T : struct, IPacket { return Task.WhenAll(Clients.Where(c => c.Connected).Select(async client => { IMemoryOwner memory = MemoryPool.Shared.RentZero(Constants.HeaderSize + packet.Size); PacketHeader header = new PacketHeader { Id = client.Id, Type = Constants.PacketMap[typeof(T)].Type, PacketSize = packet.Size }; FillPacket(header, packet, memory.Memory); await client.Send(memory.Memory, client); memory.Dispose(); })); } /// /// Takes ownership of data and disposes once done. /// /// Memory owner to dispose once done /// Optional sender to not broadcast data to public async Task Broadcast(IMemoryOwner data, Client? sender = null) { await Task.WhenAll(Clients.Where(c => c.Connected && c != sender).Select(client => client.Send(data.Memory, sender))); data.Dispose(); } /// /// Broadcasts memory whose memory shouldn't be disposed, should only be fired by server code. /// /// Memory to send to the clients /// Optional sender to not broadcast data to public async void Broadcast(Memory data, Client? sender = null) { await Task.WhenAll(Clients.Where(c => c.Connected && c != sender).Select(client => client.Send(data, sender))); } public Client? FindExistingClient(Guid id) { return Clients.Find(client => client.Id == id); } private async void HandleSocket(Socket socket) { Client client = new Client(socket) {Server = this}; IMemoryOwner memory = null!; bool first = true; try { while (true) { memory = memoryPool.Rent(Constants.HeaderSize); async Task Read(Memory readMem, int readSize, int readOffset) { readSize += readOffset; while (readOffset < readSize) { int size = await socket.ReceiveAsync(readMem[readOffset..readSize], SocketFlags.None); if (size == 0) { // treat it as a disconnect and exit Logger.Info($"Socket {socket.RemoteEndPoint} disconnected."); if (socket.Connected) await socket.DisconnectAsync(false); return false; } readOffset += size; } return true; } if (!await Read(memory.Memory[..Constants.HeaderSize], Constants.HeaderSize, 0)) break; PacketHeader header = GetHeader(memory.Memory.Span[..Constants.HeaderSize]); Range packetRange = Constants.HeaderSize..(Constants.HeaderSize + header.PacketSize); if (header.PacketSize > 0) { IMemoryOwner memTemp = memory; // header to copy to new memory memory = memoryPool.Rent(Constants.HeaderSize + header.PacketSize); memTemp.Memory.Span[..Constants.HeaderSize].CopyTo(memory.Memory.Span[..Constants.HeaderSize]); memTemp.Dispose(); if (!await Read(memory.Memory, header.PacketSize, Constants.HeaderSize)) break; } // if (header.Type is not PacketType.Player and not PacketType.Cap and not PacketType.Capture)Logger.Info($"Got your mom {header.Id} {header.Type} 0x{header.PacketSize:X} 0x{memory.Memory.Length:X} 0x{header.Size:X}"); // connection initialization if (first) { first = false; if (header.Type != PacketType.Connect) throw new Exception($"First packet was not init, instead it was {header.Type}"); ConnectPacket connect = new ConnectPacket(); connect.Deserialize(memory.Memory.Span[packetRange]); lock (Clients) { client.Name = connect.ClientName; bool firstConn = false; switch (connect.ConnectionType) { case ConnectPacket.ConnectionTypes.FirstConnection: { firstConn = true; break; } case ConnectPacket.ConnectionTypes.Reconnecting: { client.Id = header.Id; if (FindExistingClient(header.Id) is { } newClient) { // if (newClient.Connected) throw new Exception($"Tried to join as already connected user {header.Id}"); newClient.Socket = client.Socket; client = newClient; } else { firstConn = true; connect.ConnectionType = ConnectPacket.ConnectionTypes.FirstConnection; } break; } default: throw new Exception($"Invalid connection type {connect.ConnectionType}"); } client.Connected = true; if (firstConn) { // do any cleanup required when it comes to new clients List toDisconnect = Clients.FindAll(c => c.Id == header.Id && c.Connected && c.Socket != null); Clients.RemoveAll(c => c.Id == header.Id); client.Id = header.Id; Clients.Add(client); Parallel.ForEachAsync(toDisconnect, (c, token) => c.Socket!.DisconnectAsync(false, token)); // done disconnecting and removing stale clients with the same id ClientJoined?.Invoke(client, connect); } } List otherConnectedPlayers = Clients.FindAll(c => c.Id != header.Id && c.Connected && c.Socket != null); await Parallel.ForEachAsync(otherConnectedPlayers, async (other, _) => { IMemoryOwner tempBuffer = MemoryPool.Shared.RentZero(Constants.HeaderSize + (other.CurrentCostume.HasValue ? Math.Max(connect.Size, other.CurrentCostume.Value.Size) : connect.Size)); PacketHeader connectHeader = new PacketHeader { Id = other.Id, Type = PacketType.Connect, PacketSize = connect.Size }; MemoryMarshal.Write(tempBuffer.Memory.Span, ref connectHeader); ConnectPacket connectPacket = new ConnectPacket { ConnectionType = ConnectPacket.ConnectionTypes.FirstConnection, // doesn't matter what it is ClientName = other.Name }; connectPacket.Serialize(tempBuffer.Memory.Span[Constants.HeaderSize..]); await client.Send(tempBuffer.Memory[..(Constants.HeaderSize + connect.Size)], null); if (other.CurrentCostume.HasValue) { connectHeader.Type = PacketType.Costume; connectHeader.PacketSize = other.CurrentCostume.Value.Size; MemoryMarshal.Write(tempBuffer.Memory.Span, ref connectHeader); other.CurrentCostume.Value.Serialize(tempBuffer.Memory.Span[Constants.HeaderSize..(Constants.HeaderSize + connectHeader.PacketSize)]); await client.Send(tempBuffer.Memory[..(Constants.HeaderSize + connectHeader.PacketSize)], null); } tempBuffer.Dispose(); }); Logger.Info($"Client {client.Name} ({client.Id}/{socket.RemoteEndPoint}) connected."); } else if (header.Id != client.Id && client.Id != Guid.Empty) { throw new Exception($"Client {client.Name} sent packet with invalid client id {header.Id} instead of {client.Id}"); } if (header.Type == PacketType.Costume) { CostumePacket costumePacket = new CostumePacket { BodyName = "" }; costumePacket.Deserialize(memory.Memory.Span[Constants.HeaderSize..(Constants.HeaderSize + costumePacket.Size)]); client.CurrentCostume = costumePacket; } try { // if (header.Type is not PacketType.Cap and not PacketType.Player) client.Logger.Warn($"lol {header.Type}"); IPacket packet = (IPacket) Activator.CreateInstance(Constants.PacketIdMap[header.Type])!; packet.Deserialize(memory.Memory.Span[Constants.HeaderSize..(Constants.HeaderSize + packet.Size)]); if (PacketHandler?.Invoke(client, packet) is false) { memory.Dispose(); continue; } } catch (Exception e) { client.Logger.Error($"Packet handler warning: {e}"); } Broadcast(memory, client); } } catch (Exception e) { if (e is SocketException {SocketErrorCode: SocketError.ConnectionReset}) { client.Logger.Info($"Disconnected from the server: Connection reset"); } else { client.Logger.Error($"Disconnecting due to exception: {e}"); if (socket.Connected) Task.Run(() => socket.DisconnectAsync(false)); } memory?.Dispose(); } Logger.Info($"Client {socket.RemoteEndPoint} ({client.Name}/{client.Id}) disconnected from the server"); // Clients.Remove(client) client.Connected = false; try { client.Dispose(); } catch {/*lol*/} Task.Run(() => Broadcast(new DisconnectPacket(), client)); } private static PacketHeader GetHeader(Span data) { //no need to error check, the client will disconnect when the packet is invalid :) return MemoryMarshal.Read(data); } }