muddesigner/MudEngine/WinPC.Engine/Directors/ServerDirector.cs

using System;
using System.Collections.Generic;
using System.Net.Sockets;
using System.Threading;
using WinPC.Engine.Abstract.Directors;
using WinPC.Engine.Abstract.Networking;
using WinPC.Engine.Core;
using WinPC.Engine.States;

namespace WinPC.Engine.Directors
{
    public class ServerDirector : IServerDirector
    {

        public List<Thread> ConnectionThreads { get; private set; }
        public List<Player> ConnectedPlayers { get; private set; }

        
        public IServer Server { get; set; }

        public ServerDirector(IServer server)
        {
            Server = server;
            ConnectedPlayers = new List<Player>(Server.MaxConnections);
            ConnectionThreads = new List<Thread>(Server.MaxConnections);

        }

        public void AddConnection(Socket connection)
        {
            var player = new Player(new ConnectState(this), connection);
            ConnectedPlayers.Add(player);


            ConnectionThreads.Add(new Thread(ReceiveDataThread));
            var index = ConnectionThreads.Count - 1;

            ConnectionThreads[index].Name = "Player";
            ConnectionThreads[index].Start(index);


        }

        public void ReceiveDataThread(object index)
        {
            var player = ConnectedPlayers[(int) index];

            while (Server.Enabled)
            {
                player.CurrentState.Render((int) index);
                var command = player.CurrentState.GetCommand();
                command.Execute();
            }
        }

        public void DisconnectAll()
        {
            foreach(var player in ConnectedPlayers)
            {
                player.Disconnect();
            }

            foreach (var thread in ConnectionThreads)
            {
                thread.Abort();

            }

            ConnectedPlayers.Clear();
            ConnectionThreads.Clear();
        }


        public String RecieveInput(int index)
        {
            string input = String.Empty;

            while (true)
            {
                try
                {
                    byte[] buf = new byte[1];
                    Int32 recved = ConnectedPlayers[index].Connection.Receive(buf);

                    if (recved > 0)
                    {
                        if (buf[0] == '\n' && ConnectedPlayers[index].buffer.Count > 0)
                        {
                            if (ConnectedPlayers[index].buffer[ConnectedPlayers[index].buffer.Count - 1] == '\r')
                                ConnectedPlayers[index].buffer.RemoveAt(ConnectedPlayers[index].buffer.Count - 1);

                            System.Text.UTF8Encoding enc = new System.Text.UTF8Encoding();
                            input = enc.GetString(ConnectedPlayers[index].buffer.ToArray());
                            ConnectedPlayers[index].buffer.Clear();
                            //Return a trimmed string.
                            return input;
                        }
                        else
                            ConnectedPlayers[index].buffer.Add(buf[0]);
                    }
                    else if (recved == 0) //Disconnected
                    {
                     //   ConnectedPlayers[index]. Connected = false;
                      //  this.LoggedIn = false;
                        return "Disconnected.";
                    }
                }
                catch (Exception e)
                {
                    //Flag as disabled 
                  //  this.Connected = false;
                  //  this.LoggedIn = false;
                    return e.Message;
                }
            }
        }
    }
}