Implement LobbyServer

2019-05-03 20:24:02 +02:00
parent e3a7e37411
commit ed1771664b
10 changed files with 306 additions and 1 deletions
--- a/LobbyServer/LobbyServer.cs
+++ b/LobbyServer/LobbyServer.cs
@@ -0,0 +1,108 @@
+using System.Linq;
+using System.Net;
+using System.Net.Sockets;
+using System;
+namespace LobbyServer
+{
+    class LobbyServer
+    {
+        public static LobbyServer Instance { get; private set; }
+
+        public ChatManager ChatManager { get; }
+        public ScoresManager ScoresManager { get; }
+
+        public LobbyServer()
+        {
+            Instance = this;
+
+            Console.WriteLine("Starting LobbyServer...");
+
+            ChatManager = new ChatManager();
+            ScoresManager = new ScoresManager();
+
+            Console.WriteLine("LobbyServer started");
+        }
+
+        public void Start()
+        {
+            var listener = new TcpListener(IPAddress.Any, 1409);
+            listener.Start();
+
+            while (true)
+            {
+                Console.WriteLine("Waiting client...");
+                using (var client = listener.AcceptTcpClient())
+                {
+                    ClientLoop(client);
+                }
+            }
+        }
+
+        public void ClientLoop(TcpClient client)
+        {
+            Console.WriteLine($"Client connected: {client.Client.RemoteEndPoint}");
+
+            var stream = new CommandStream(client.GetStream());
+
+            while (true)
+            {
+                try
+                {
+                    var packet = stream.Receive();
+
+                    switch (packet.Command)
+                    {
+                        case Command.ChatAdd:
+                            ChatAdd(packet);
+                            break;
+                        case Command.ChatRequest:
+                            ChatRequest(stream, packet);
+                            break;
+                        case Command.ScoreAdd:
+                            ScoreAdd(packet);
+                            break;
+                        case Command.ScoreRequest:
+                            ScoreRequest(stream, packet);
+                            break;
+                        case Command.Invalid:
+                            throw new InvalidOperationException("Received invalid command");
+                    }
+                }
+                catch (Exception e)
+                {
+                    Console.WriteLine($"Client disconnected: {e.Message}");
+                }
+            }
+        }
+
+        private void ChatAdd(CommandPacket packet)
+        {
+            var message = new Message(packet.Content);
+
+            ChatManager.Add(message);
+        }
+
+        private void ChatRequest(CommandStream stream, CommandPacket packet)
+        {
+            var messages = ChatManager.Messages.Reverse().Take(10).Reverse().Select(x => x.ToString());
+            string data = string.Join('@', messages);
+
+            stream.Send(new CommandPacket(Command.ChatRequest, data));
+        }
+
+        private void ScoreAdd(CommandPacket packet)
+        {
+            var score = new ScoreEntry(packet.Content);
+
+            ScoresManager.Add(score);
+        }
+
+        private void ScoreRequest(CommandStream stream, CommandPacket packet)
+        {
+            var scores = ScoresManager.Scores.Take(10).Select(x => x.ToString());
+            string data = string.Join('@', scores);
+
+            stream.Send(new CommandPacket(Command.ScoreRequest, data));
+        }
+    }
+}