refactor and chat base

Mau/Game.cs

@@ -1,5 +1,6 @@
 using System.Net.WebSockets;
 using System.Text.Json;
+using MauMau_Server.Websockets;
 
 namespace MauMau_Server.Mau;
 
@@ -17,9 +18,9 @@ public class Game
         Deck.AddCardToUsedDeck(CurrentCard);
     }
 
-    public void AddPlayerToGame(string playerId, WebSocket socket)
+    public void AddPlayerToGame(ConnectionInstance connection)
     {
-        var player = new Player("Koetje " + playerId.Split('-')[0], playerId, socket)
+        var player = new Player(connection)
         {
             Hand = Deck.DrawCards(8)
         };

Mau/GameState.cs

@@ -11,7 +11,7 @@ public class GameState
     public GameState(Game game, string playerId)
     {
         var p = game.GetPlayer(playerId);
-        PlayerName = p.Name;
+        PlayerName = p.Connection.ConnectionId;
         foreach (var card in p.Hand)
         {
             Hand.Add(card.ToString());
@@ -19,10 +19,10 @@ public class GameState
         
         foreach (var player in game.Players)
         {
-            Players.Add(player.Name);
+            Players.Add(p.Connection.ConnectionId);
         }
         
         CurrentCard = game.CurrentCard.ToString();
-        CurrentPlayer = game.CurrentPlayer.Name;
+        CurrentPlayer = game.CurrentPlayer.Connection.ConnectionId;;
     }
 }

Mau/Player.cs

@@ -1,20 +1,17 @@
 using System.Net.WebSockets;
+using MauMau_Server.Websockets;
 
 namespace MauMau_Server.Mau;
 
 public class Player
 {
-    public string Name { get; set; }
-    public string PlayerId { get; set; }
-    public WebSocket Socket { get; set; }
+    public ConnectionInstance Connection { get; set; }
     public List<Card> Hand { get; set; } = new();
     
-    public Player(string name, string playerId, WebSocket socket)
+    public Player(ConnectionInstance connection)
     {
-        Name = name;
-        PlayerId = playerId;
-        Socket = socket;
+        Connection = connection;
     }
     
-    public bool IsMe(string playerId) => PlayerId == playerId;
+    public bool IsMe(string playerId) => Connection.ConnectionId == playerId;
 }

Room/Chat/Chat.cs

@@ -0,0 +1,22 @@
+using System.Net.WebSockets;
+using System.Text.Json;
+using MauMau_Server.Websockets;
+
+namespace MauMau_Server.Mau;
+
+public class Chat
+{
+    private readonly Room _room;
+    
+    public Chat(Room room)
+    {
+        _room = room;
+    }
+    
+    public void SendChatMessage(string connectionId, string message)
+    {
+        var chatMessage = new ChatOutput(connectionId, message);
+        var formattedMessage = new MessageDTO("CHAT", JsonSerializer.Serialize(chatMessage));
+        WebsocketManager.BroadcastAsync(_room.GetWebsockets(), JsonSerializer.Serialize(formattedMessage));
+    }
+}

Room/Chat/ChatOutput.cs

@@ -0,0 +1,18 @@
+namespace MauMau_Server.Mau;
+
+public class ChatOutput
+{
+    public string Playername { get; set; }
+    public string Message { get; set; }
+    
+    public ChatOutput(string playername, string message)
+    {
+        Playername = playername;
+        Message = message;
+    }
+    
+    public ChatOutput()
+    {
+        
+    }
+}

Room/MessageDTO.cs

@@ -0,0 +1,18 @@
+namespace MauMau_Server.Mau;
+
+public class MessageDTO
+{
+    public string Type { get; set; }
+    public string Payload { get; set; }
+    
+    public MessageDTO(string type, string payload)
+    {
+        Type = type;
+        Payload = payload;
+    }
+    
+    public MessageDTO()
+    {
+        
+    }
+}

Room/Room.cs

@@ -0,0 +1,125 @@
+using System.Collections;
+using System.Net.WebSockets;
+using System.Text;
+using System.Text.Json;
+using MauMau_Server.Mau;
+
+namespace MauMau_Server.Websockets;
+
+public class Room
+{
+    private readonly IRoomManager _roomManager;
+    private readonly string _roomId;
+    private readonly List<ConnectionInstance> _connections = new();
+    private ConnectionInstance _host;
+    private readonly Chat _chat;
+    private readonly Game _game = new();
+
+    public Room(IRoomManager roomManager, string roomId)
+    {
+        _roomManager = roomManager;
+        _chat = new Chat(this);
+        _roomId = roomId;
+    }
+
+    public async Task InstantiateConnection(WebSocket socket)
+    {
+        var connection = AddConnection(socket);
+        if (IsEmpty()) _host = connection;
+        _game.AddPlayerToGame(connection);
+        await HandleConnection(connection.Socket, connection.ConnectionId);
+    }
+
+    private async Task HandleConnection(WebSocket webSocket, string connectionId)
+    {
+        BroadcastGameState();
+        var buffer = EmptyBuffer();
+        var result = await ReceiveAsync(webSocket, buffer);
+        while (!result.CloseStatus.HasValue)
+        {
+            var slicedBuffer = buffer[0..result.Count];
+            Console.WriteLine(Encoding.UTF8.GetString(slicedBuffer));
+            var message = JsonSerializer.Deserialize<MessageDTO>(slicedBuffer);
+            switch (message.Type)
+            {
+                case "GAME":
+                {
+                    var gameInput = JsonSerializer.Deserialize<ActionDTO>(message.Payload);
+                    _game.HandleAction(connectionId, gameInput);
+                    break;
+                }
+                case "CHAT":
+                {
+                    _chat.SendChatMessage(connectionId, message.Payload);
+                    break;
+                }
+            }
+            BroadcastGameState();
+            buffer = EmptyBuffer();
+            result = await ReceiveAsync(webSocket, buffer);
+        }
+
+        await webSocket.CloseAsync(result.CloseStatus.Value, result.CloseStatusDescription,
+            CancellationToken.None);
+        HandleDisconnect(connectionId);
+    }
+
+    private ConnectionInstance AddConnection(WebSocket socket)
+    {
+        var connectionId = Guid.NewGuid().ToString();
+        var connection = new ConnectionInstance(connectionId, socket);
+        _connections.Add(connection);
+        return connection;
+    }
+
+    public void RemoveConnection(string socketId)
+    {
+        _connections.RemoveAll(connection => connection.ConnectionId == socketId);
+    }
+
+    private static async Task<WebSocketReceiveResult?> ReceiveAsync(WebSocket webSocket, byte[] buffer)
+    {
+        var arraySegment = new ArraySegment<byte>(buffer);
+        var result = await webSocket.ReceiveAsync(arraySegment, CancellationToken.None);
+        return result;
+    }
+
+    private void BroadcastGameState()
+    {
+        foreach (var connection in _connections)
+        {
+            var gameState = new GameState(_game, connection.ConnectionId);
+            var message = new MessageDTO("GAME", JsonSerializer.Serialize(gameState));
+            WebsocketManager.SendAsync(connection.Socket, JsonSerializer.Serialize(message));
+        }
+    }
+
+    private void HandleDisconnect(string socketId)
+    {
+        RemoveConnection(socketId);
+        _game.RemovePlayer(socketId);
+        if (IsEmpty())
+        {
+            _roomManager.RemoveRoom(_roomId);
+        }
+        else if (socketId == _host.ConnectionId)
+        {
+            _host = _connections.First();
+        }
+    }
+    
+    public List<WebSocket> GetWebsockets()
+    {
+        return _connections.Select(connection => connection.Socket).ToList();
+    }
+
+    private static byte[] EmptyBuffer()
+    {
+        return new byte[4096];
+    }
+
+    public bool IsEmpty()
+    {
+        return _connections.Count == 0;
+    }
+}

Websockets/ConnectionInstance.cs

@@ -0,0 +1,15 @@
+using System.Net.WebSockets;
+
+namespace MauMau_Server.Websockets;
+
+public class ConnectionInstance
+{
+    public string ConnectionId { get; set; }
+    public WebSocket Socket { get; set; }
+    
+    public ConnectionInstance(string connectionId, WebSocket socket)
+    {
+        ConnectionId = connectionId;
+        Socket = socket;
+    }
+}

Websockets/Room.cs

@@ -1,131 +0,0 @@
-using System.Collections;
-using System.Net.WebSockets;
-using System.Text;
-using System.Text.Json;
-using MauMau_Server.Mau;
-
-namespace MauMau_Server.Websockets;
-
-public class Room
-{
-    private readonly IRoomManager _roomManager;
-    private readonly string _roomId;
-    private readonly Dictionary<string, WebSocket> _connections = new();
-    private string _host;
-    private readonly Game _game = new();
-
-    public Room(IRoomManager roomManager, string roomId)
-    {
-        _roomManager = roomManager;
-        _roomId = roomId;
-    }
-
-    public async Task InstantiateConnection(WebSocket socket)
-    {
-        var socketId = AddConnection(socket);
-        await HandleConnection(socket, socketId);
-    }
-
-    private async Task HandleConnection(WebSocket socket, string socketId)
-    {
-        BroadcastGameState();
-        var buffer = EmptyBuffer();
-        var result = await ReceiveAsync(socket, buffer);
-        while (!result.CloseStatus.HasValue)
-        {
-            var slicedBuffer = buffer[0..result.Count];
-            var action = JsonSerializer.Deserialize<ActionDTO>(slicedBuffer);
-            _game.HandleAction(socketId, action);
-            BroadcastGameState();
-            buffer = EmptyBuffer();
-            result = await ReceiveAsync(socket, buffer);
-        }
-
-        await socket.CloseAsync(result.CloseStatus.Value, result.CloseStatusDescription, CancellationToken.None);
-        HandleDisconnect(socketId);
-    }
-
-    private string AddConnection(WebSocket socket)
-    {
-        var socketId = Guid.NewGuid().ToString();
-        if (_connections.Count == 0)
-        {
-            _host = socketId;
-        }
-
-        _connections.Add(socketId, socket);
-        _game.AddPlayerToGame(socketId, socket);
-        return socketId;
-    }
-
-    public WebSocket GetConnection(string socketId)
-    {
-        return _connections[socketId];
-    }
-
-    public Dictionary<string, WebSocket> GetAllConnections()
-    {
-        return _connections;
-    }
-
-    public void RemoveConnection(string socketId)
-    {
-        _connections.Remove(socketId);
-    }
-
-    private static async Task<WebSocketReceiveResult?> ReceiveAsync(WebSocket webSocket, byte[] buffer)
-    {
-        var arraySegment = new ArraySegment<byte>(buffer);
-        var result = await webSocket.ReceiveAsync(arraySegment, CancellationToken.None);
-        return result;
-    }
-
-    private void BroadcastGameState()
-    {
-        foreach (var (id, socket) in GetAllConnections())
-        {
-            var gameState = new GameState(_game, id);
-            var message = JsonSerializer.Serialize(gameState);
-            SendAsync(socket, message);
-        }
-    }
-
-    private void BroadcastAsync(string message)
-    {
-        foreach (var (id, socket) in GetAllConnections())
-        {
-            SendAsync(socket, message);
-        }
-    }
-
-    private static void SendAsync(WebSocket socket, string message)
-    {
-        var bytes = Encoding.Default.GetBytes(message);
-        var arraySegment = new ArraySegment<byte>(bytes);
-        socket.SendAsync(arraySegment, WebSocketMessageType.Text, true, CancellationToken.None);
-    }
-
-    private void HandleDisconnect(string socketId)
-    {
-        RemoveConnection(socketId);
-        _game.RemovePlayer(socketId);
-        if (IsEmpty())
-        {
-            _roomManager.RemoveRoom(_roomId);
-        }
-        else if (socketId == _host)
-        {
-            _host = _connections.First().Key;
-        }
-    }
-
-    private static byte[] EmptyBuffer()
-    {
-        return new byte[4096];
-    }
-
-    public bool IsEmpty()
-    {
-        return _connections.Count == 0;
-    }
-}

Websockets/WebsocketManager.cs

@@ -0,0 +1,22 @@
+using System.Net.WebSockets;
+using System.Text;
+
+namespace MauMau_Server.Websockets;
+
+public static class WebsocketManager
+{
+    public static void SendAsync(WebSocket socket, string message)
+    {
+        var bytes = Encoding.Default.GetBytes(message);
+        var arraySegment = new ArraySegment<byte>(bytes);
+        socket.SendAsync(arraySegment, WebSocketMessageType.Text, true, CancellationToken.None);
+    }
+    
+    public static void BroadcastAsync(List<WebSocket> sockets, string message)
+    {
+        foreach (var socket in sockets)
+        {
+            SendAsync(socket, message);
+        }
+    }
+}