Core: Added trait 'SurrenderOnDisconnect' and the core changes required to make this work

This commit is contained in:
geckosoft
2010-10-25 17:19:48 +02:00
committed by Chris Forbes
parent e7c61fac5c
commit f5b8b18d86
8 changed files with 256 additions and 184 deletions

View File

@@ -21,20 +21,21 @@ namespace OpenRA.Network
public List<Slot> Slots = new List<Slot>(); public List<Slot> Slots = new List<Slot>();
public Global GlobalSettings = new Global(); public Global GlobalSettings = new Global();
public Client ClientWithIndex( int clientID ) public Client ClientWithIndex(int clientID)
{ {
return Clients.SingleOrDefault( c => c.Index == clientID ); return Clients.SingleOrDefault(c => c.Index == clientID);
} }
public Client ClientInSlot( Slot slot ) public Client ClientInSlot(Slot slot)
{ {
return Clients.SingleOrDefault( c => c.Slot == slot.Index ); return Clients.SingleOrDefault(c => c.Slot == slot.Index);
} }
public enum ClientState public enum ClientState
{ {
NotReady, NotReady,
Ready Ready,
Disconnected = 1000
} }
public class Client public class Client
@@ -55,7 +56,7 @@ namespace OpenRA.Network
public int Index; public int Index;
public string Bot; // trait name of the bot to initialize in this slot, or null otherwise. public string Bot; // trait name of the bot to initialize in this slot, or null otherwise.
public bool Closed; // host has explicitly closed this slot. public bool Closed; // host has explicitly closed this slot.
public string MapPlayer; // playerReference to bind against. public string MapPlayer; // playerReference to bind against.
public bool Spectator = false; // Spectating or not public bool Spectator = false; // Spectating or not
// todo: more stuff? // todo: more stuff?
} }
@@ -71,7 +72,7 @@ namespace OpenRA.Network
public bool AllowCheats = false; public bool AllowCheats = false;
} }
public Session( string[] mods ) public Session(string[] mods)
{ {
this.GlobalSettings.Mods = mods.ToArray(); this.GlobalSettings.Mods = mods.ToArray();
} }
@@ -80,27 +81,27 @@ namespace OpenRA.Network
{ {
var clientData = new List<MiniYamlNode>(); var clientData = new List<MiniYamlNode>();
foreach( var client in Clients ) foreach (var client in Clients)
clientData.Add( new MiniYamlNode( "Client@{0}".F( client.Index ), FieldSaver.Save( client ) ) ); clientData.Add(new MiniYamlNode("Client@{0}".F(client.Index), FieldSaver.Save(client)));
foreach( var slot in Slots ) foreach (var slot in Slots)
clientData.Add( new MiniYamlNode( "Slot@{0}".F( slot.Index ), FieldSaver.Save( slot ) ) ); clientData.Add(new MiniYamlNode("Slot@{0}".F(slot.Index), FieldSaver.Save(slot)));
clientData.Add( new MiniYamlNode( "GlobalSettings", FieldSaver.Save( GlobalSettings ) ) ); clientData.Add(new MiniYamlNode("GlobalSettings", FieldSaver.Save(GlobalSettings)));
return clientData.WriteToString(); return clientData.WriteToString();
} }
public static Session Deserialize(string data) public static Session Deserialize(string data)
{ {
var session = new Session( Game.Settings.Game.Mods ); var session = new Session(Game.Settings.Game.Mods);
var ys = MiniYaml.FromString(data); var ys = MiniYaml.FromString(data);
foreach (var y in ys) foreach (var y in ys)
{ {
var yy = y.Key.Split('@'); var yy = y.Key.Split('@');
switch( yy[0] ) switch (yy[0])
{ {
case "GlobalSettings": case "GlobalSettings":
FieldLoader.Load(session.GlobalSettings, y.Value); FieldLoader.Load(session.GlobalSettings, y.Value);
@@ -111,7 +112,7 @@ namespace OpenRA.Network
break; break;
case "Slot": case "Slot":
session.Slots.Add(FieldLoader.Load<Session.Slot>(y.Value )); session.Slots.Add(FieldLoader.Load<Session.Slot>(y.Value));
break; break;
} }
} }

View File

@@ -16,7 +16,7 @@ namespace OpenRA.Network
{ {
static class UnitOrders static class UnitOrders
{ {
static Player FindPlayerByClient( this World world, Session.Client c) static Player FindPlayerByClient(this World world, Session.Client c)
{ {
/* todo: this is still a hack. /* todo: this is still a hack.
* the cases we're trying to avoid are the extra players on the host's client -- Neutral, other MapPlayers, * the cases we're trying to avoid are the extra players on the host's client -- Neutral, other MapPlayers,
@@ -25,7 +25,7 @@ namespace OpenRA.Network
p => p.ClientIndex == c.Index && p.PlayerName == c.Name); p => p.ClientIndex == c.Index && p.PlayerName == c.Name);
} }
public static void ProcessOrder( OrderManager orderManager, World world, int clientId, Order order ) public static void ProcessOrder(OrderManager orderManager, World world, int clientId, Order order)
{ {
if (world != null) if (world != null)
{ {
@@ -34,103 +34,118 @@ namespace OpenRA.Network
return; return;
} }
switch( order.OrderString ) switch (order.OrderString)
{ {
case "Chat": case "Chat":
{
var client = orderManager.LobbyInfo.ClientWithIndex( clientId );
if (Game.IsHost && Game.Settings.Server.Extension != null && !Game.Settings.Server.Extension.OnIngameChat(client, order.TargetString, false))
break;
if (client != null)
{ {
var player = world != null ? world.FindPlayerByClient(client) : null; var client = orderManager.LobbyInfo.ClientWithIndex(clientId);
var suffix = (player != null && player.WinState == WinState.Lost) ? " (Dead)" : "";
Game.AddChatLine(client.Color1, client.Name+suffix, order.TargetString);
}
else
Game.AddChatLine(Color.White, "(player {0})".F(clientId), order.TargetString);
break;
}
case "TeamChat":
{
var client = orderManager.LobbyInfo.ClientWithIndex(clientId);
if (Game.IsHost && Game.Settings.Server.Extension != null && !Game.Settings.Server.Extension.OnIngameChat(client, order.TargetString, true)) if (Game.IsHost && Game.Settings.Server.Extension != null && !Game.Settings.Server.Extension.OnIngameChat(client, order.TargetString, false))
break; break;
if (client != null)
{ if (client != null)
if (world == null)
{ {
if (client.Team == orderManager.LocalClient.Team) var player = world != null ? world.FindPlayerByClient(client) : null;
Game.AddChatLine(client.Color1, client.Name + " (Team)", var suffix = (player != null && player.WinState == WinState.Lost) ? " (Dead)" : "";
order.TargetString); Game.AddChatLine(client.Color1, client.Name + suffix, order.TargetString);
} }
else else
{ Game.AddChatLine(Color.White, "(player {0})".F(clientId), order.TargetString);
var player = world.FindPlayerByClient(client); break;
var display = player != null }
&& (world.LocalPlayer != null && player.Stances[world.LocalPlayer] == Stance.Ally
|| player.WinState == WinState.Lost);
if (display) case "Disconnected": /* reports that the target player disconnected */
{
var client = orderManager.LobbyInfo.ClientWithIndex(clientId);
if (client != null)
{
client.State = Session.ClientState.Disconnected;
}
break;
}
case "TeamChat":
{
var client = orderManager.LobbyInfo.ClientWithIndex(clientId);
if (Game.IsHost && Game.Settings.Server.Extension != null && !Game.Settings.Server.Extension.OnIngameChat(client, order.TargetString, true))
break;
if (client != null)
{
if (world == null)
{ {
var suffix = (player != null && player.WinState == WinState.Lost) ? " (Dead)" : " (Team)"; if (client.Team == orderManager.LocalClient.Team)
Game.AddChatLine(client.Color1, client.Name + suffix, order.TargetString); Game.AddChatLine(client.Color1, client.Name + " (Team)",
order.TargetString);
}
else
{
var player = world.FindPlayerByClient(client);
var display = player != null
&&
(world.LocalPlayer != null &&
player.Stances[world.LocalPlayer] == Stance.Ally
|| player.WinState == WinState.Lost);
if (display)
{
var suffix = (player != null && player.WinState == WinState.Lost)
? " (Dead)"
: " (Team)";
Game.AddChatLine(client.Color1, client.Name + suffix, order.TargetString);
}
} }
} }
break;
} }
break; case "StartGame":
}
case "StartGame":
{
Game.AddChatLine(Color.White, "Server", "The game has started.");
Game.StartGame(orderManager.LobbyInfo.GlobalSettings.Map);
break;
}
case "SyncInfo":
{
orderManager.LobbyInfo = Session.Deserialize( order.TargetString );
if( orderManager.FramesAhead != orderManager.LobbyInfo.GlobalSettings.OrderLatency
&& !orderManager.GameStarted )
{ {
orderManager.FramesAhead = orderManager.LobbyInfo.GlobalSettings.OrderLatency; Game.AddChatLine(Color.White, "Server", "The game has started.");
Game.Debug( "Order lag is now {0} frames.".F( orderManager.LobbyInfo.GlobalSettings.OrderLatency ) ); Game.StartGame(orderManager.LobbyInfo.GlobalSettings.Map);
break;
}
case "SyncInfo":
{
orderManager.LobbyInfo = Session.Deserialize(order.TargetString);
if (orderManager.FramesAhead != orderManager.LobbyInfo.GlobalSettings.OrderLatency
&& !orderManager.GameStarted)
{
orderManager.FramesAhead = orderManager.LobbyInfo.GlobalSettings.OrderLatency;
Game.Debug(
"Order lag is now {0} frames.".F(orderManager.LobbyInfo.GlobalSettings.OrderLatency));
}
Game.SyncLobbyInfo();
break;
} }
Game.SyncLobbyInfo(); case "SetStance":
break; {
} var targetPlayer = order.Player.World.players[order.TargetLocation.X];
case "SetStance": var newStance = (Stance)order.TargetLocation.Y;
{
var targetPlayer = order.Player.World.players[order.TargetLocation.X];
var newStance = (Stance)order.TargetLocation.Y;
if (Game.IsHost && Game.Settings.Server.Extension != null) if (Game.IsHost && Game.Settings.Server.Extension != null)
Game.Settings.Server.Extension.OnIngameSetStance(order.Player, targetPlayer, newStance); Game.Settings.Server.Extension.OnIngameSetStance(order.Player, targetPlayer, newStance);
SetPlayerStance(world, order.Player, targetPlayer, newStance);
// automatically declare war reciprocally SetPlayerStance(world, order.Player, targetPlayer, newStance);
if (newStance == Stance.Enemy)
SetPlayerStance(world, targetPlayer, order.Player, newStance);
Game.Debug("{0} has set diplomatic stance vs {1} to {2}".F( // automatically declare war reciprocally
order.Player.PlayerName, targetPlayer.PlayerName, newStance)); if (newStance == Stance.Enemy)
break; SetPlayerStance(world, targetPlayer, order.Player, newStance);
}
default: Game.Debug("{0} has set diplomatic stance vs {1} to {2}".F(
{ order.Player.PlayerName, targetPlayer.PlayerName, newStance));
if( !order.IsImmediate ) break;
foreach (var t in order.Subject.TraitsImplementing<IResolveOrder>()) }
t.ResolveOrder(order.Subject, order); default:
break; {
} if (!order.IsImmediate)
foreach (var t in order.Subject.TraitsImplementing<IResolveOrder>())
t.ResolveOrder(order.Subject, order);
break;
}
} }
} }

View File

@@ -13,85 +13,86 @@ using System.Drawing;
using System.Linq; using System.Linq;
using OpenRA.FileFormats; using OpenRA.FileFormats;
using OpenRA.Network; using OpenRA.Network;
using OpenRA.Traits; using OpenRA.Traits;
namespace OpenRA namespace OpenRA
{ {
public enum PowerState { Normal, Low, Critical }; public enum PowerState { Normal, Low, Critical };
public enum WinState { Won, Lost, Undefined }; public enum WinState { Won, Lost, Undefined };
public class Player public class Player
{ {
public Actor PlayerActor; public Actor PlayerActor;
public int Kills; public int Kills;
public int Deaths; public int Deaths;
public WinState WinState = WinState.Undefined; public WinState WinState = WinState.Undefined;
public readonly string Palette; public readonly string Palette;
public readonly Color Color; public readonly Color Color;
public readonly Color Color2; public readonly Color Color2;
public readonly string PlayerName; public readonly string PlayerName;
public readonly string InternalName; public readonly string InternalName;
public readonly CountryInfo Country; public readonly CountryInfo Country;
public readonly int Index; public readonly int Index;
public readonly bool NonCombatant = false; public readonly bool NonCombatant = false;
public readonly int ClientIndex; public readonly int ClientIndex;
public readonly PlayerReference PlayerRef; public readonly PlayerReference PlayerRef;
public bool IsBot; public bool IsBot;
public ShroudRenderer Shroud; public ShroudRenderer Shroud;
public World World { get; private set; } public World World { get; private set; }
public Player( World world, PlayerReference pr, int index ) public Player(World world, PlayerReference pr, int index)
{ {
World = world; World = world;
Shroud = new ShroudRenderer(this, world.Map); Shroud = new ShroudRenderer(this, world.Map);
Index = index; Index = index;
Palette = "player"+index; Palette = "player" + index;
Color = pr.Color; Color = pr.Color;
Color2 = pr.Color2; Color2 = pr.Color2;
ClientIndex = 0; /* it's a map player, "owned" by host */ ClientIndex = 0; /* it's a map player, "owned" by host */
PlayerName = InternalName = pr.Name; PlayerName = InternalName = pr.Name;
NonCombatant = pr.NonCombatant; NonCombatant = pr.NonCombatant;
Country = world.GetCountries() Country = world.GetCountries()
.FirstOrDefault(c => pr.Race == c.Race) .FirstOrDefault(c => pr.Race == c.Race)
?? world.GetCountries().Random(world.SharedRandom); ?? world.GetCountries().Random(world.SharedRandom);
PlayerRef = pr; PlayerRef = pr;
PlayerActor = world.CreateActor("Player", new TypeDictionary{ new OwnerInit( this ) }); PlayerActor = world.CreateActor("Player", new TypeDictionary { new OwnerInit(this) });
} }
public Player( World world, Session.Client client, PlayerReference pr, int index ) public Player(World world, Session.Client client, PlayerReference pr, int index)
{ {
World = world; World = world;
Shroud = new ShroudRenderer(this, world.Map); Shroud = new ShroudRenderer(this, world.Map);
Index = index; Index = index;
Palette = "player"+index; Palette = "player" + index;
Color = client.Color1; Color = client.Color1;
Color2 = client.Color2; Color2 = client.Color2;
PlayerName = client.Name; PlayerName = client.Name;
InternalName = pr.Name;
Country = world.GetCountries() InternalName = pr.Name;
.FirstOrDefault(c => client != null && client.Country == c.Race ) Country = world.GetCountries()
.FirstOrDefault(c => client != null && client.Country == c.Race)
?? world.GetCountries().Random(world.SharedRandom); ?? world.GetCountries().Random(world.SharedRandom);
ClientIndex = client.Index; ClientIndex = client.Index;
PlayerRef = pr; PlayerRef = pr;
PlayerActor = world.CreateActor("Player", new TypeDictionary{ new OwnerInit( this ) }); PlayerActor = world.CreateActor("Player", new TypeDictionary { new OwnerInit(this) });
} }
public void GiveAdvice(string advice) public void GiveAdvice(string advice)
{ {
Sound.PlayToPlayer(this, advice); Sound.PlayToPlayer(this, advice);
} }
public Dictionary<Player, Stance> Stances = new Dictionary<Player, Stance>(); public Dictionary<Player, Stance> Stances = new Dictionary<Player, Stance>();
} }
} }

View File

@@ -656,35 +656,41 @@ namespace OpenRA.Server
new ServerOrder("Chat", text).Serialize()); new ServerOrder("Chat", text).Serialize());
} }
static void SendChat(Connection asConn, string text) static void SendChat(Connection asConn, string text)
{ {
DispatchOrders(asConn, 0, new ServerOrder("Chat", text).Serialize()); DispatchOrders(asConn, 0, new ServerOrder("Chat", text).Serialize());
} }
static void SendDisconnected(Connection asConn)
{
DispatchOrders(asConn, 0, new ServerOrder("Disconnected", "").Serialize());
}
static void InterpretServerOrder(Connection conn, ServerOrder so) static void InterpretServerOrder(Connection conn, ServerOrder so)
{ {
switch (so.Name) switch (so.Name)
{ {
case "Command": case "Command":
{
if(GameStarted)
SendChatTo(conn, "Cannot change state when game started.");
else if (GetClient(conn).State == Session.ClientState.Ready && !(so.Data == "ready" || so.Data == "startgame") )
SendChatTo(conn, "Cannot change state when marked as ready.");
else if (!InterpretCommand(conn, so.Data))
{ {
Log.Write("server", "Bad server command: {0}", so.Data); if (GameStarted)
SendChatTo(conn, "Bad server command."); SendChatTo(conn, "Cannot change state when game started.");
}; else if (GetClient(conn).State == Session.ClientState.Ready && !(so.Data == "ready" || so.Data == "startgame"))
} SendChatTo(conn, "Cannot change state when marked as ready.");
break; else if (!InterpretCommand(conn, so.Data))
{
Log.Write("server", "Bad server command: {0}", so.Data);
SendChatTo(conn, "Bad server command.");
};
}
break;
case "Chat": case "Chat":
case "TeamChat": case "TeamChat":
if (E(e => e.OnChat(conn, so.Data, so.Name == "TeamChat"))) case "Disconnected":
foreach (var c in conns.Except(conn).ToArray()) if (E(e => e.OnChat(conn, so.Data, so.Name == "TeamChat")))
DispatchOrdersToClient(c, GetClient(conn).Index, 0, so.Serialize()); foreach (var c in conns.Except(conn).ToArray())
break; DispatchOrdersToClient(c, GetClient(conn).Index, 0, so.Serialize());
break;
} }
} }
@@ -698,6 +704,9 @@ namespace OpenRA.Server
conns.Remove(toDrop); conns.Remove(toDrop);
SendChat(toDrop, "Connection Dropped"); SendChat(toDrop, "Connection Dropped");
if (GameStarted)
SendDisconnected(toDrop); /* Report disconnection */
lobbyInfo.Clients.RemoveAll(c => c.Index == toDrop.PlayerIndex); lobbyInfo.Clients.RemoveAll(c => c.Index == toDrop.PlayerIndex);
DispatchOrders( toDrop, toDrop.MostRecentFrame, new byte[] { 0xbf } ); DispatchOrders( toDrop, toDrop.MostRecentFrame, new byte[] { 0xbf } );

View File

@@ -84,6 +84,7 @@
<Compile Include="AttackMove.cs" /> <Compile Include="AttackMove.cs" />
<Compile Include="Buildable.cs" /> <Compile Include="Buildable.cs" />
<Compile Include="Combat.cs" /> <Compile Include="Combat.cs" />
<Compile Include="Player\SurrenderOnDisconnect.cs" />
<Compile Include="Crates\CloakCrateAction.cs" /> <Compile Include="Crates\CloakCrateAction.cs" />
<Compile Include="Crates\GiveMcvCrateAction.cs" /> <Compile Include="Crates\GiveMcvCrateAction.cs" />
<Compile Include="Crates\GiveUnitCrateAction.cs" /> <Compile Include="Crates\GiveUnitCrateAction.cs" />

View File

@@ -0,0 +1,44 @@
#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 OpenRA.Network;
using OpenRA.Traits;
namespace OpenRA.Mods.RA
{
class SurrenderOnDisconnectInfo : TraitInfo<SurrenderOnDisconnect>
{
}
class SurrenderOnDisconnect : ITick
{
private bool Disconnected = false;
public void Tick(Actor self)
{
if (Disconnected) return;
var p = self.Owner;
if (p.WinState == WinState.Lost || p.WinState == WinState.Won) return; /* already won or lost */
var client = p.World.LobbyInfo.ClientWithIndex(p.ClientIndex);
if (client == null)
return;
if (client.State == Session.ClientState.Disconnected)
{
Disconnected = true; /* dont call this multiple times! */
self.World.IssueOrder(new Order("Surrender", self));
}
}
}
}

View File

@@ -68,7 +68,7 @@ Player:
PlayerColorPalette: PlayerColorPalette:
BasePalette: terrain BasePalette: terrain
PaletteFormat: cnc PaletteFormat: cnc
SurrenderOnDisconnect:
World: World:
OpenWidgetAtGameStart: OpenWidgetAtGameStart:
Widget: INGAME_ROOT Widget: INGAME_ROOT

View File

@@ -124,6 +124,7 @@ Player:
3tnk: 0% 3tnk: 0%
PlayerColorPalette: PlayerColorPalette:
BasePalette: terrain BasePalette: terrain
SurrenderOnDisconnect:
World: World:
OpenWidgetAtGameStart: OpenWidgetAtGameStart: