WriteCharacterData/ReadCharacterData methods can be used for any type of character (less duplicate code)

This commit is contained in:
Regalis
2016-08-26 20:48:57 +03:00
parent fda251898b
commit 3d2d06d2e5
3 changed files with 119 additions and 140 deletions
+79 -86
View File
@@ -697,7 +697,7 @@ namespace Barotrauma.Networking
Item.Spawner.ReadNetworkData(inc); Item.Spawner.ReadNetworkData(inc);
break; break;
case (byte)PacketTypes.NewCharacter: case (byte)PacketTypes.NewCharacter:
ReadCharacterSpawnMessage(inc); ReadCharacterData(inc);
break; break;
case (byte)PacketTypes.RemoveItem: case (byte)PacketTypes.RemoveItem:
Item.Remover.ReadNetworkData(inc); Item.Remover.ReadNetworkData(inc);
@@ -764,43 +764,7 @@ namespace Barotrauma.Networking
byte characterCount = inc.ReadByte(); byte characterCount = inc.ReadByte();
for (int i = 0; i < characterCount; i++) for (int i = 0; i < characterCount; i++)
{ {
bool isAiCharacter = inc.ReadBoolean(); ReadCharacterData(inc);
ushort id = inc.ReadUInt16();
if (isAiCharacter)
{
string configPath = inc.ReadString();
Vector2 position = new Vector2(inc.ReadFloat(), inc.ReadFloat());
var existingEntity = Entity.FindEntityByID(id);
if (existingEntity is AICharacter && existingEntity.ID == id)
{
continue;
}
var character = Character.Create(configPath, position, null, true);
if (character != null) character.ID = id;
}
else
{
bool hasOwner = inc.ReadBoolean();
int ownerId = -1;
if (hasOwner)
{
ownerId = inc.ReadByte();
}
Character newCharacter = ReadCharacterData(inc, ownerId == myID);
if (ownerId != myID)
{
var characterOwner = otherClients.Find(c => c.ID == ownerId);
if (characterOwner != null) characterOwner.Character = newCharacter;
}
crew.Add(newCharacter);
}
} }
gameStarted = true; gameStarted = true;
@@ -903,15 +867,23 @@ namespace Barotrauma.Networking
GUI.DrawRectangle(spriteBatch, new Rectangle(x, y, width, height), Color.Black * 0.7f, true); GUI.DrawRectangle(spriteBatch, new Rectangle(x, y, width, height), Color.Black * 0.7f, true);
spriteBatch.DrawString(GUI.Font, "Network statistics:", new Vector2(x + 10, y + 10), Color.White); spriteBatch.DrawString(GUI.Font, "Network statistics:", new Vector2(x + 10, y + 10), Color.White);
spriteBatch.DrawString(GUI.Font, "Ping: " + (int)(client.ServerConnection.AverageRoundtripTime * 1000.0f) + " ms", new Vector2(x + 10, y + 25), Color.White); if (client.ServerConnection != null)
{
spriteBatch.DrawString(GUI.Font, "Ping: " + (int)(client.ServerConnection.AverageRoundtripTime * 1000.0f) + " ms", new Vector2(x + 10, y + 25), Color.White);
y += 15; y += 15;
spriteBatch.DrawString(GUI.SmallFont, "Received bytes: " + client.Statistics.ReceivedBytes, new Vector2(x + 10, y + 45), Color.White); spriteBatch.DrawString(GUI.SmallFont, "Received bytes: " + client.Statistics.ReceivedBytes, new Vector2(x + 10, y + 45), Color.White);
spriteBatch.DrawString(GUI.SmallFont, "Received packets: " + client.Statistics.ReceivedPackets, new Vector2(x + 10, y + 60), Color.White); spriteBatch.DrawString(GUI.SmallFont, "Received packets: " + client.Statistics.ReceivedPackets, new Vector2(x + 10, y + 60), Color.White);
spriteBatch.DrawString(GUI.SmallFont, "Sent bytes: " + client.Statistics.SentBytes, new Vector2(x + 10, y + 75), Color.White);
spriteBatch.DrawString(GUI.SmallFont, "Sent packets: " + client.Statistics.SentPackets, new Vector2(x + 10, y + 90), Color.White);
}
else
{
spriteBatch.DrawString(GUI.Font, "Disconnected", new Vector2(x + 10, y + 25), Color.White);
}
spriteBatch.DrawString(GUI.SmallFont, "Sent bytes: " + client.Statistics.SentBytes, new Vector2(x + 10, y + 75), Color.White);
spriteBatch.DrawString(GUI.SmallFont, "Sent packets: " + client.Statistics.SentPackets, new Vector2(x + 10, y + 90), Color.White);
} }
@@ -968,25 +940,6 @@ namespace Barotrauma.Networking
return true; return true;
} }
public void ReadCharacterSpawnMessage(NetIncomingMessage message)
{
string configPath = message.ReadString();
if (configPath != Character.HumanConfigFile)
{
ushort id = message.ReadUInt16();
Vector2 position = new Vector2(message.ReadFloat(), message.ReadFloat());
var character = Character.Create(configPath, position, null, true);
if (character != null) character.ID = id;
}
else
{
ReadCharacterData(message, false, true);
}
}
public void RequestFile(string file, FileTransferMessageType fileType) public void RequestFile(string file, FileTransferMessageType fileType)
{ {
if (fileStreamReceiver!=null) if (fileStreamReceiver!=null)
@@ -1171,37 +1124,77 @@ namespace Barotrauma.Networking
client.SendMessage(msg, NetDeliveryMethod.ReliableUnordered); client.SendMessage(msg, NetDeliveryMethod.ReliableUnordered);
} }
public Character ReadCharacterData(NetIncomingMessage inc, bool isMyCharacter, bool hasAi = false) public Character ReadCharacterData(NetIncomingMessage inc)
{ {
string newName = inc.ReadString(); bool noInfo = inc.ReadBoolean();
ushort ID = inc.ReadUInt16(); ushort id = inc.ReadUInt16();
bool isFemale = inc.ReadBoolean(); string configPath = inc.ReadString();
int headSpriteID = inc.ReadByte();
Vector2 position = new Vector2(inc.ReadFloat(), inc.ReadFloat()); Vector2 position = new Vector2(inc.ReadFloat(), inc.ReadFloat());
bool enabled = inc.ReadBoolean();
string jobName = inc.ReadString(); Character character = null;
JobPrefab jobPrefab = JobPrefab.List.Find(jp => jp.Name == jobName);
CharacterInfo ch = new CharacterInfo(Character.HumanConfigFile, newName, isFemale ? Gender.Female : Gender.Male, jobPrefab); if (noInfo)
ch.HeadSpriteId = headSpriteID;
Character character = Character.Create(ch, position, !isMyCharacter, hasAi);
GameMain.GameSession.CrewManager.characters.Add(character);
character.ID = ID;
Item.Spawner.ReadNetworkData(inc);
if (isMyCharacter)
{ {
myCharacter = character; var existingEntity = Entity.FindEntityByID(id);
Character.Controlled = character; if (existingEntity is AICharacter && existingEntity.ID == id)
GameMain.LightManager.LosEnabled = true; {
return (Character)existingEntity;
}
if (endVoteTickBox != null) endVoteTickBox.Visible = Voting.AllowEndVoting; character = Character.Create(configPath, position, null, true);
character.ID = id;
} }
else
{
bool hasOwner = inc.ReadBoolean();
int ownerId = -1;
if (hasOwner)
{
ownerId = inc.ReadByte();
}
string newName = inc.ReadString();
bool hasAi = inc.ReadBoolean();
bool isFemale = inc.ReadBoolean();
int headSpriteID = inc.ReadByte();
string jobName = inc.ReadString();
JobPrefab jobPrefab = JobPrefab.List.Find(jp => jp.Name == jobName);
CharacterInfo ch = new CharacterInfo(configPath, newName, isFemale ? Gender.Female : Gender.Male, jobPrefab);
ch.HeadSpriteId = headSpriteID;
character = Character.Create(configPath, position, ch, ownerId != myID, hasAi);
character.ID = id;
if (configPath == Character.HumanConfigFile)
{
GameMain.GameSession.CrewManager.characters.Add(character);
}
Item.Spawner.ReadNetworkData(inc);
if (ownerId == myID)
{
myCharacter = character;
Character.Controlled = character;
GameMain.LightManager.LosEnabled = true;
if (endVoteTickBox != null) endVoteTickBox.Visible = Voting.AllowEndVoting;
}
else
{
var characterOwner = otherClients.Find(c => c.ID == ownerId);
if (characterOwner != null) characterOwner.Character = character;
}
}
character.Enabled = enabled;
return character; return character;
} }
+39 -53
View File
@@ -995,35 +995,7 @@ namespace Barotrauma.Networking
msg.Write((byte)characters.Count); msg.Write((byte)characters.Count);
foreach (Character c in characters) foreach (Character c in characters)
{ {
msg.Write(c is AICharacter); WriteCharacterData(msg, c.Name, c);
msg.Write(c.ID);
if (c is AICharacter)
{
msg.Write(c.ConfigPath);
msg.Write(c.Position.X);
msg.Write(c.Position.Y);
}
else
{
Client client = connectedClients.Find(cl => cl.Character == c);
if (client != null)
{
msg.Write(true);
msg.Write(client.ID);
}
else if (myCharacter == c)
{
msg.Write(true);
msg.Write((byte)0);
}
else
{
msg.Write(false);
}
WriteCharacterData(msg, c.Name, c);
}
} }
return msg; return msg;
@@ -1609,41 +1581,55 @@ namespace Barotrauma.Networking
} }
} }
public void WriteCharacterData(NetOutgoingMessage message, string name, Character character) public void WriteCharacterData(NetOutgoingMessage msg, string name, Character c)
{ {
message.Write(name); msg.Write(c.Info == null);
message.Write(character.ID); msg.Write(c.ID);
message.Write(character.Info.Gender == Gender.Female); msg.Write(c.ConfigPath);
message.Write((byte)character.Info.HeadSpriteId); msg.Write(c.WorldPosition.X);
msg.Write(c.WorldPosition.Y);
message.Write(character.WorldPosition.X); msg.Write(c.Enabled);
message.Write(character.WorldPosition.Y);
if (c.Info != null)
{
Client client = connectedClients.Find(cl => cl.Character == c);
if (client != null)
{
msg.Write(true);
msg.Write(client.ID);
}
else if (myCharacter == c)
{
msg.Write(true);
msg.Write((byte)0);
}
else
{
msg.Write(false);
}
msg.Write(name);
msg.Write(c is AICharacter);
msg.Write(c.Info.Gender == Gender.Female);
msg.Write((byte)c.Info.HeadSpriteId);
msg.Write(c.Info.Job == null ? "" : c.Info.Job.Name);
message.Write(character.Info.Job.Name); Item.Spawner.FillNetworkData(msg, c.SpawnItems);
}
Item.Spawner.FillNetworkData(message, character.SpawnItems);
} }
public void SendCharacterSpawnMessage(Character character, List<NetConnection> recipients = null) public void SendCharacterSpawnMessage(Character character, List<NetConnection> recipients = null)
{ {
if (recipients == null || !recipients.Any()) return;
NetOutgoingMessage message = server.CreateMessage(); NetOutgoingMessage message = server.CreateMessage();
message.Write((byte)PacketTypes.NewCharacter); message.Write((byte)PacketTypes.NewCharacter);
message.Write(character.ConfigPath); WriteCharacterData(message, character.Name, character);
if (character.ConfigPath == Character.HumanConfigFile)
{
WriteCharacterData(message, character.Name, character);
}
else
{
message.Write(character.ID);
message.Write(character.Position.X);
message.Write(character.Position.Y);
}
SendMessage(message, NetDeliveryMethod.ReliableUnordered, recipients); SendMessage(message, NetDeliveryMethod.ReliableUnordered, recipients);
} }
@@ -532,7 +532,7 @@ namespace Barotrauma.Networking
{ {
byte clientId = inc.ReadByte(); byte clientId = inc.ReadByte();
var character = client.ReadCharacterData(inc, clientId == client.ID); var character = client.ReadCharacterData(inc);
} }
if (state != newState) if (state != newState)