GameServer.cs

Go to the documentation of this file.

using System;
using Lidgren.Network;

namespace FBServer.Host
{
    partial class GameServer
    {
        # region Variables/Properties

        bool hostStarted = false;

        NetServer server;

        int clientId = 1;
        public ClientCollection Clients;

        #region DisconnectedClientEvent
        public delegate void DisconnectedClientEventHandler(Client sender, EventArgs e);
        public event DisconnectedClientEventHandler DisconnectedClient;
        protected virtual void OnDisconnectedClient(Client sender, EventArgs e)
        {
            if (DisconnectedClient != null)
                DisconnectedClient(sender, e);
        }
        #endregion
        #region ConnectedClientEvent
        public delegate void ConnectedClientEventHandler(Client sender, EventArgs e);
        public event ConnectedClientEventHandler ConnectedClient;
        protected virtual void OnConnectedClient(Client sender, EventArgs e)
        {
            if (ConnectedClient != null)
                ConnectedClient(sender, e);
        }
        #endregion

        public bool HostStarted
        {
            get { return hostStarted; }
        }

        #endregion

        public void StartServer()
        {
            var config = new NetPeerConfiguration("Final-Bomber")
            {
                MaximumConnections = ServerSettings.MaxConnection, 
                Port = ServerSettings.Port
            };

#if DEBUG
            config.PingInterval = 1f;
            //config.SimulatedLoss = 0.5f;
            config.SimulatedMinimumLatency = 0.05f;
#endif
            config.SetMessageTypeEnabled(NetIncomingMessageType.ConnectionLatencyUpdated, true);

            bool checkPort;
            do
            {
                checkPort = false;
                try
                {
                    server = new NetServer(config);
                    server.Start();
                }
                catch (NetException)
                {
                    checkPort = true;
                    config.Port++;
                    WriteOutput("Can't use old port, trying with Port: " + config.Port);
                    if (config.Port > 6800)
                    {
                        checkPort = false;
                    }
                }
            } while (checkPort);

            Clients = new ClientCollection();

            hostStarted = true;
            WriteOutput("[START]Game server has started");
            WriteOutput("[PORT]: " + config.Port);
        }

        public void RunServer()
        {
            NetIncomingMessage message;

            while ((message = server.ReadMessage()) != null)
            {
                NetConnection sender = message.SenderConnection;
                Client currentClient = Clients.GetClientFromConnection(sender);

                switch (message.MessageType)
                {
                    #region StatusChanged
                    case NetIncomingMessageType.StatusChanged:
                        if (sender.Status == NetConnectionStatus.Connected)
                        {
                            if (currentClient == null)
                            {
                                var con = new Client(ref sender, clientId);
                                WriteOutput("[Connected]Client " + con.ClientId + " connected with ip: " + sender.RemoteEndPoint.ToString());
                                Clients.AddClient(con);
                                clientId++;
                                OnConnectedClient(con, new EventArgs());
                            }
                        }
                        else
                        {
                            if (sender.Status != NetConnectionStatus.Connected)
                            {
                                if (currentClient != null)
                                {
                                    message.ReadByte(); // the message type
                                    WriteOutput("[Disconnected]Client " + currentClient.ClientId + " has disconnected (" + message.ReadString() + ")");

                                    Clients.RemoveClient(currentClient);
                                    OnDisconnectedClient(currentClient, new EventArgs());
                                }
                            }
                        }
                        break;
                    #endregion

                    case NetIncomingMessageType.Data:
                        if (message.LengthBytes > 0)
                        {
                            try
                            {
                                DataProcessing(message, ref currentClient);
                            }
                            catch (Exception e)
                            {
                                WriteOutput("[ERROR]Client Id: " + '\"' + currentClient.ClientId + '\"' +
                                    " Ip: " + sender.RemoteEndPoint.ToString() + " caused server exception");
                                WriteOutput("EXCEPTION: " + e.ToString());
                                sender.Disconnect("Caused server error");
                            }
                        }
                        break;

                    case NetIncomingMessageType.ConnectionLatencyUpdated:
                        float ping = message.ReadFloat() * 1000;
                        Program.Log.Info("Player #" + currentClient.Player.Id + " ping: " + ping + "ms");
                        currentClient.Ping = ping;

                        // TODO: Send this client's ping to everyone

                        break;

                }
            }
        }

        public void EndServer(string reson)
        {
            WriteOutput("[END]Server has ended at " + System.DateTime.Now.ToString());
            server.Shutdown(reson);
            hostStarted = false;
        }

        #region Private

        public void WriteOutput(string msg)
        {
            Program.Log.Info(msg);
        }

        #endregion
    }
}