310 lines
9.3 KiB
C#
310 lines
9.3 KiB
C#
using Barotrauma.Items.Components;
|
|
using Microsoft.Xna.Framework;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
|
|
namespace Barotrauma.Networking
|
|
{
|
|
public enum ClientPacketHeader
|
|
{
|
|
UPDATE_LOBBY, //update state in lobby
|
|
UPDATE_INGAME, //update state ingame
|
|
|
|
SERVER_SETTINGS, //change server settings
|
|
|
|
CAMPAIGN_SETUP_INFO,
|
|
|
|
FILE_REQUEST, //request a (submarine) file from the server
|
|
|
|
VOICE,
|
|
|
|
PING_RESPONSE,
|
|
|
|
RESPONSE_STARTGAME, //tell the server whether you're ready to start
|
|
SERVER_COMMAND, //tell the server to end a round or kick/ban someone (special permissions required)
|
|
|
|
EVENTMANAGER_RESPONSE,
|
|
|
|
REQUEST_STARTGAMEFINALIZE, //tell the server you're ready to finalize round initialization
|
|
|
|
ERROR, //tell the server that an error occurred
|
|
CREW, //hiring UI
|
|
MEDICAL, //medical clinic
|
|
MONEY, //wallet updates
|
|
REWARD_DISTRIBUTION, // wallet reward distribution
|
|
READY_CHECK,
|
|
READY_TO_SPAWN
|
|
}
|
|
enum ClientNetObject
|
|
{
|
|
END_OF_MESSAGE, //self-explanatory
|
|
SYNC_IDS, //ids of the last changes the client knows about
|
|
CHAT_MESSAGE, //also self-explanatory
|
|
VOTE, //you get the idea
|
|
CHARACTER_INPUT,
|
|
ENTITY_STATE,
|
|
SPECTATING_POS
|
|
}
|
|
|
|
enum ClientNetError
|
|
{
|
|
MISSING_EVENT, //client was expecting a previous event
|
|
MISSING_ENTITY //client can't find an entity of a certain ID
|
|
}
|
|
|
|
public enum ServerPacketHeader
|
|
{
|
|
AUTH_RESPONSE, //tell the player if they require a password to log in
|
|
AUTH_FAILURE, //the server won't authorize player yet, however connection is still alive
|
|
UPDATE_LOBBY, //update state in lobby (votes and chat messages)
|
|
UPDATE_INGAME, //update state ingame (character input and chat messages)
|
|
|
|
PERMISSIONS, //tell the client which special permissions they have (if any)
|
|
ACHIEVEMENT, //give the client a steam achievement
|
|
CHEATS_ENABLED, //tell the clients whether cheats are on or off
|
|
|
|
CAMPAIGN_SETUP_INFO,
|
|
|
|
FILE_TRANSFER,
|
|
|
|
VOICE,
|
|
|
|
PING_REQUEST, //ping the client
|
|
CLIENT_PINGS, //tell the client the pings of all other clients
|
|
|
|
QUERY_STARTGAME, //ask the clients whether they're ready to start
|
|
STARTGAME, //start a new round
|
|
STARTGAMEFINALIZE, //finalize round initialization
|
|
ENDGAME,
|
|
|
|
TRAITOR_MESSAGE,
|
|
MISSION,
|
|
EVENTACTION,
|
|
CREW, //anything related to managing bots in multiplayer
|
|
MEDICAL, //medical clinic
|
|
MONEY,
|
|
READY_CHECK //start, end and update a ready check
|
|
}
|
|
enum ServerNetObject
|
|
{
|
|
END_OF_MESSAGE,
|
|
SYNC_IDS,
|
|
CHAT_MESSAGE,
|
|
VOTE,
|
|
CLIENT_LIST,
|
|
ENTITY_POSITION,
|
|
ENTITY_EVENT,
|
|
ENTITY_EVENT_INITIAL
|
|
}
|
|
|
|
enum TraitorMessageType
|
|
{
|
|
Server,
|
|
ServerMessageBox,
|
|
Objective,
|
|
Console
|
|
}
|
|
|
|
enum VoteType
|
|
{
|
|
Unknown,
|
|
Sub,
|
|
Mode,
|
|
EndRound,
|
|
Kick,
|
|
StartRound,
|
|
PurchaseAndSwitchSub,
|
|
PurchaseSub,
|
|
SwitchSub
|
|
}
|
|
|
|
public enum ReadyCheckState
|
|
{
|
|
Start,
|
|
Update,
|
|
End
|
|
}
|
|
|
|
enum DisconnectReason
|
|
{
|
|
Unknown,
|
|
Banned,
|
|
Kicked,
|
|
ServerShutdown,
|
|
ServerCrashed,
|
|
ServerFull,
|
|
AuthenticationRequired,
|
|
SteamAuthenticationRequired,
|
|
SteamAuthenticationFailed,
|
|
SessionTaken,
|
|
TooManyFailedLogins,
|
|
NoName,
|
|
InvalidName,
|
|
NameTaken,
|
|
InvalidVersion,
|
|
MissingContentPackage,
|
|
IncompatibleContentPackage,
|
|
NotOnWhitelist,
|
|
ExcessiveDesyncOldEvent,
|
|
ExcessiveDesyncRemovedEvent,
|
|
SyncTimeout,
|
|
SteamP2PError,
|
|
SteamP2PTimeOut,
|
|
}
|
|
|
|
abstract partial class NetworkMember
|
|
{
|
|
public UInt16 LastClientListUpdateID
|
|
{
|
|
get;
|
|
set;
|
|
}
|
|
|
|
public virtual bool IsServer
|
|
{
|
|
get { return false; }
|
|
}
|
|
|
|
public virtual bool IsClient
|
|
{
|
|
get { return false; }
|
|
}
|
|
|
|
public abstract void CreateEntityEvent(INetSerializable entity, NetEntityEvent.IData extraData = null);
|
|
|
|
#if DEBUG
|
|
public Dictionary<string, long> messageCount = new Dictionary<string, long>();
|
|
#endif
|
|
|
|
protected ServerSettings serverSettings;
|
|
|
|
protected TimeSpan updateInterval;
|
|
protected DateTime updateTimer;
|
|
|
|
public int EndVoteCount, EndVoteMax, SubmarineVoteYesCount, SubmarineVoteNoCount, SubmarineVoteMax;
|
|
|
|
protected bool gameStarted;
|
|
|
|
protected RespawnManager respawnManager;
|
|
|
|
public bool ShowNetStats;
|
|
|
|
public float SimulatedRandomLatency, SimulatedMinimumLatency;
|
|
public float SimulatedLoss;
|
|
public float SimulatedDuplicatesChance;
|
|
|
|
public int TickRate
|
|
{
|
|
get { return serverSettings.TickRate; }
|
|
set
|
|
{
|
|
serverSettings.TickRate = MathHelper.Clamp(value, 1, 60);
|
|
updateInterval = new TimeSpan(0, 0, 0, 0, MathHelper.Clamp(1000 / serverSettings.TickRate, 1, 500));
|
|
}
|
|
}
|
|
|
|
public KarmaManager KarmaManager
|
|
{
|
|
get;
|
|
private set;
|
|
} = new KarmaManager();
|
|
|
|
public bool GameStarted
|
|
{
|
|
get { return gameStarted; }
|
|
}
|
|
|
|
public virtual List<Client> ConnectedClients
|
|
{
|
|
get { return null; }
|
|
}
|
|
|
|
public RespawnManager RespawnManager
|
|
{
|
|
get { return respawnManager; }
|
|
}
|
|
|
|
public ServerSettings ServerSettings
|
|
{
|
|
get { return serverSettings; }
|
|
}
|
|
|
|
public bool CanUseRadio(Character sender)
|
|
{
|
|
if (sender == null) { return false; }
|
|
|
|
var radio = sender.Inventory.AllItems.FirstOrDefault(i => i.GetComponent<WifiComponent>() != null);
|
|
if (radio == null || !sender.HasEquippedItem(radio)) { return false; }
|
|
|
|
var radioComponent = radio.GetComponent<WifiComponent>();
|
|
if (radioComponent == null) { return false; }
|
|
return radioComponent.HasRequiredContainedItems(sender, addMessage: false);
|
|
}
|
|
|
|
public void AddChatMessage(string message, ChatMessageType type, string senderName = "", Client senderClient = null, Character senderCharacter = null, PlayerConnectionChangeType changeType = PlayerConnectionChangeType.None, Color? textColor = null)
|
|
{
|
|
AddChatMessage(ChatMessage.Create(senderName, message, type, senderCharacter, senderClient, changeType: changeType, textColor: textColor));
|
|
}
|
|
|
|
public virtual void AddChatMessage(ChatMessage message)
|
|
{
|
|
if (string.IsNullOrEmpty(message.Text)) { return; }
|
|
|
|
if (message.Sender != null && !message.Sender.IsDead)
|
|
{
|
|
message.Sender.ShowSpeechBubble(2.0f, message.Color);
|
|
}
|
|
}
|
|
|
|
public static string ClientLogName(Client client, string name = null)
|
|
{
|
|
if (client == null) { return name; }
|
|
string retVal = "‖";
|
|
if (client.Karma < 40.0f)
|
|
{
|
|
retVal += "color:#ff9900;";
|
|
}
|
|
retVal += "metadata:" + (client.SteamID != 0 ? client.SteamID.ToString() : client.ID.ToString()) + "‖" + (name ?? client.Name).Replace("‖", "") + "‖end‖";
|
|
return retVal;
|
|
}
|
|
|
|
public virtual void KickPlayer(string kickedName, string reason) { }
|
|
|
|
public virtual void BanPlayer(string kickedName, string reason, bool range = false, TimeSpan? duration = null) { }
|
|
|
|
public virtual void UnbanPlayer(string playerName, string playerIP) { }
|
|
|
|
public virtual void Update(float deltaTime) { }
|
|
|
|
public virtual void Disconnect() { }
|
|
|
|
/// <summary>
|
|
/// Check if the two version are compatible (= if they can play together in multiplayer).
|
|
/// Returns null if compatibility could not be determined (invalid/unknown version number).
|
|
/// </summary>
|
|
public static bool? IsCompatible(string myVersion, string remoteVersion)
|
|
{
|
|
if (string.IsNullOrEmpty(myVersion) || string.IsNullOrEmpty(remoteVersion)) { return null; }
|
|
|
|
if (!Version.TryParse(myVersion, out Version myVersionNumber)) { return null; }
|
|
if (!Version.TryParse(remoteVersion, out Version remoteVersionNumber)) { return null; }
|
|
|
|
return IsCompatible(myVersionNumber, remoteVersionNumber);
|
|
}
|
|
|
|
/// <summary>
|
|
/// Check if the two version are compatible (= if they can play together in multiplayer).
|
|
/// </summary>
|
|
public static bool IsCompatible(Version myVersion, Version remoteVersion)
|
|
{
|
|
//major.minor.build.revision
|
|
//revision number is ignored, other values have to match
|
|
return
|
|
myVersion.Major == remoteVersion.Major &&
|
|
myVersion.Minor == remoteVersion.Minor &&
|
|
myVersion.Build == remoteVersion.Build;
|
|
}
|
|
}
|
|
}
|