#region Copyright & License Information /* * Copyright 2007-2010 The OpenRA Developers (see AUTHORS) * This file is part of OpenRA, which is free software. It is made * available to you under the terms of the GNU General Public License * as published by the Free Software Foundation. For more information, * see LICENSE. */ #endregion using System; using System.Collections.Generic; using System.Linq; using OpenRA.Network; using OpenRA.FileFormats; using OpenRA.Server; using S = OpenRA.Server.Server; namespace OpenRA.Mods.RA.Server { public class LobbyCommands : ServerTrait, IInterpretCommand, INotifyServerStart, IClientJoined { public static int MaxSpectators = 4; // How many spectators to allow // @todo Expose this as an option public bool InterpretCommand(S server, Connection conn, Session.Client client, string cmd) { if (server.GameStarted) { server.SendChatTo(conn, "Cannot change state when game started. ({0})".F(cmd)); return false; } else if (client.State == Session.ClientState.Ready && !(cmd == "ready" || cmd == "startgame")) { server.SendChatTo(conn, "Cannot change state when marked as ready."); return false; } var dict = new Dictionary> { { "ready", s => { // if we're downloading, we can't ready up. if (client.State == Session.ClientState.NotReady) client.State = Session.ClientState.Ready; else if (client.State == Session.ClientState.Ready) client.State = Session.ClientState.NotReady; Log.Write("server", "Player @{0} is {1}", conn.socket.RemoteEndPoint, client.State); server.SyncLobbyInfo(); if (server.conns.Count > 0 && server.conns.All(c => server.GetClient(c).State == Session.ClientState.Ready)) InterpretCommand(server, conn, client, "startgame"); return true; }}, { "startgame", s => { server.StartGame(); return true; }}, { "lag", s => { int lag; if (!int.TryParse(s, out lag)) { Log.Write("server", "Invalid order lag: {0}", s); return false; } Log.Write("server", "Order lag is now {0} frames.", lag); server.lobbyInfo.GlobalSettings.OrderLatency = lag; server.SyncLobbyInfo(); return true; }}, { "spectator", s => { var slotData = server.lobbyInfo.Slots.Where(ax => ax.Spectator && !server.lobbyInfo.Clients.Any(l => l.Slot == ax.Index)).FirstOrDefault(); if (slotData == null) return true; client.Slot = slotData.Index; SyncClientToPlayerReference(client, slotData.MapPlayer != null ? server.Map.Players[slotData.MapPlayer] : null); server.SyncLobbyInfo(); return true; }}, { "slot", s => { int slot; if (!int.TryParse(s, out slot)) { Log.Write("server", "Invalid slot: {0}", s ); return false; } var slotData = server.lobbyInfo.Slots.FirstOrDefault( x => x.Index == slot ); if (slotData == null || slotData.Closed || slotData.Bot != null || server.lobbyInfo.Clients.Any( c => c.Slot == slot )) return false; client.Slot = slot; SyncClientToPlayerReference(client, slotData.MapPlayer != null ? server.Map.Players[slotData.MapPlayer] : null); server.SyncLobbyInfo(); return true; }}, { "slot_close", s => { int slot; if (!int.TryParse(s, out slot)) { Log.Write("server", "Invalid slot: {0}", s ); return false; } var slotData = server.lobbyInfo.Slots.FirstOrDefault( x => x.Index == slot ); if (slotData == null) return false; if (conn.PlayerIndex != 0) { server.SendChatTo( conn, "Only the host can alter slots" ); return true; } slotData.Closed = true; slotData.Bot = null; /* kick any player that's in the slot */ var occupant = server.lobbyInfo.Clients.FirstOrDefault( c => c.Slot == slotData.Index ); if (occupant != null) { var occupantConn = server.conns.FirstOrDefault( c => c.PlayerIndex == occupant.Index ); if (occupantConn != null) server.DropClient( occupantConn, new Exception() ); } server.SyncLobbyInfo(); return true; }}, { "slot_open", s => { int slot; if (!int.TryParse(s, out slot)) { Log.Write("server", "Invalid slot: {0}", s ); return false; } var slotData = server.lobbyInfo.Slots.FirstOrDefault( x => x.Index == slot ); if (slotData == null) return false; if (conn.PlayerIndex != 0) { server.SendChatTo( conn, "Only the host can alter slots" ); return true; } slotData.Closed = false; slotData.Bot = null; server.SyncLobbyInfo(); return true; }}, { "slot_bot", s => { var parts = s.Split(' '); if (parts.Length != 2) { server.SendChatTo( conn, "Malformed slot_bot command" ); return true; } int slot; if (!int.TryParse(parts[0], out slot)) { Log.Write("server", "Invalid slot: {0}", s ); return false; } var slotData = server.lobbyInfo.Slots.FirstOrDefault( x => x.Index == slot ); if (slotData == null) return false; if (conn.PlayerIndex != 0) { server.SendChatTo( conn, "Only the host can alter slots" ); return true; } slotData.Bot = parts[1]; server.SyncLobbyInfo(); return true; }}, { "map", s => { if (conn.PlayerIndex != 0) { server.SendChatTo( conn, "Only the host can change the map" ); return true; } server.lobbyInfo.GlobalSettings.Map = s; LoadMap(server); foreach(var c in server.lobbyInfo.Clients) { c.SpawnPoint = 0; var slotData = server.lobbyInfo.Slots.FirstOrDefault( x => x.Index == c.Slot ); if (slotData != null && slotData.MapPlayer != null) SyncClientToPlayerReference(c, server.Map.Players[slotData.MapPlayer]); c.State = Session.ClientState.NotReady; } server.SyncLobbyInfo(); return true; }}, { "lockteams", s => { if (conn.PlayerIndex != 0) { server.SendChatTo( conn, "Only the host can set that option" ); return true; } bool.TryParse(s, out server.lobbyInfo.GlobalSettings.LockTeams); server.SyncLobbyInfo(); return true; }}, }; var cmdName = cmd.Split(' ').First(); var cmdValue = string.Join(" ", cmd.Split(' ').Skip(1).ToArray()); Func a; if (!dict.TryGetValue(cmdName, out a)) return false; return a(cmdValue); } public void ServerStarted(S server) { LoadMap(server); } static Session.Slot MakeSlotFromPlayerReference(PlayerReference pr) { if (!pr.Playable) return null; return new Session.Slot { MapPlayer = pr.Name, Bot = null, /* todo: allow the map to specify a bot class? */ Closed = false, }; } public static void LoadMap(S server) { server.Map = new Map(server.ModData.AvailableMaps[server.lobbyInfo.GlobalSettings.Map]); server.lobbyInfo.Slots = server.Map.Players .Select(p => MakeSlotFromPlayerReference(p.Value)) .Where(s => s != null) .Select((s, i) => { s.Index = i; return s; }) .ToList(); // Generate slots for spectators for (int i = 0; i < MaxSpectators; i++) server.lobbyInfo.Slots.Add(new Session.Slot { Spectator = true, Index = server.lobbyInfo.Slots.Count(), MapPlayer = null, Bot = null }); } public void ClientJoined(S server, Connection newConn) { var defaults = new GameRules.PlayerSettings(); var client = new Session.Client() { Index = newConn.PlayerIndex, Color1 = defaults.Color1, Color2 = defaults.Color2, Name = defaults.Name, Country = "random", State = Session.ClientState.NotReady, SpawnPoint = 0, Team = 0, Slot = ChooseFreeSlot(server), }; var slotData = server.lobbyInfo.Slots.FirstOrDefault( x => x.Index == client.Slot ); if (slotData != null && slotData.MapPlayer != null) SyncClientToPlayerReference(client, server.Map.Players[slotData.MapPlayer]); server.lobbyInfo.Clients.Add(client); Log.Write("server", "Client {0}: Accepted connection from {1}", newConn.PlayerIndex, newConn.socket.RemoteEndPoint); server.SendChat(newConn, "has joined the game."); server.SyncLobbyInfo(); } static int ChooseFreeSlot(S server) { return server.lobbyInfo.Slots.First(s => !s.Closed && s.Bot == null && !server.lobbyInfo.Clients.Any( c => c.Slot == s.Index )).Index; } public static void SyncClientToPlayerReference(Session.Client c, PlayerReference pr) { if (pr == null) return; if (pr.LockColor) { c.Color1 = pr.Color; c.Color2 = pr.Color2; } if (pr.LockRace) c.Country = pr.Race; } } }