120 lines
4.6 KiB
C#
120 lines
4.6 KiB
C#
#nullable enable
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using Barotrauma.Networking;
|
|
|
|
namespace Barotrauma
|
|
{
|
|
internal partial class ReadyCheck
|
|
{
|
|
private static List<Client> ActivePlayers => GameMain.Server.ConnectedClients.Where(c => c != null && !c.Spectating && c.InGame).ToList();
|
|
|
|
public void InitializeReadyCheck(string author, Client? sender = null)
|
|
{
|
|
foreach (Client client in ActivePlayers)
|
|
{
|
|
if (client != null && !client.Spectating)
|
|
{
|
|
IWriteMessage msg = new WriteOnlyMessage();
|
|
msg.WriteByte((byte)ServerPacketHeader.READY_CHECK);
|
|
msg.WriteByte((byte)ReadyCheckState.Start);
|
|
msg.WriteInt64(new DateTimeOffset(startTime).ToUnixTimeSeconds());
|
|
msg.WriteInt64(new DateTimeOffset(endTime).ToUnixTimeSeconds());
|
|
msg.WriteString(author);
|
|
|
|
if (sender != null)
|
|
{
|
|
msg.WriteBoolean(true);
|
|
msg.WriteByte(sender.SessionId);
|
|
}
|
|
else
|
|
{
|
|
msg.WriteBoolean(false);
|
|
}
|
|
|
|
msg.WriteUInt16((ushort)ActivePlayers.Count);
|
|
foreach (byte clientId in Clients.Keys)
|
|
{
|
|
msg.WriteByte(clientId);
|
|
}
|
|
|
|
GameMain.Server.ServerPeer.Send(msg, client.Connection, DeliveryMethod.Reliable);
|
|
}
|
|
}
|
|
}
|
|
|
|
private void UpdateReadyCheck(byte otherClient, ReadyStatus state)
|
|
{
|
|
if (Clients.All(pair => pair.Value != ReadyStatus.Unanswered))
|
|
{
|
|
EndReadyCheck();
|
|
return;
|
|
}
|
|
|
|
foreach (Client client in ActivePlayers)
|
|
{
|
|
IWriteMessage msg = new WriteOnlyMessage();
|
|
msg.WriteByte((byte)ServerPacketHeader.READY_CHECK);
|
|
msg.WriteByte((byte)ReadyCheckState.Update);
|
|
msg.WriteByte((byte)state);
|
|
msg.WriteByte(otherClient);
|
|
GameMain.Server.ServerPeer.Send(msg, client.Connection, DeliveryMethod.Reliable);
|
|
}
|
|
}
|
|
|
|
partial void EndReadyCheck()
|
|
{
|
|
if (IsFinished) { return; }
|
|
IsFinished = true;
|
|
foreach (Client client in ActivePlayers)
|
|
{
|
|
if (client != null && !client.Spectating)
|
|
{
|
|
IWriteMessage msg = new WriteOnlyMessage();
|
|
msg.WriteByte((byte)ServerPacketHeader.READY_CHECK);
|
|
msg.WriteByte((byte)ReadyCheckState.End);
|
|
msg.WriteUInt16((ushort)Clients.Count);
|
|
foreach (var (id, state) in Clients)
|
|
{
|
|
msg.WriteByte(id);
|
|
msg.WriteByte((byte)state);
|
|
}
|
|
|
|
GameMain.Server.ServerPeer.Send(msg, client.Connection, DeliveryMethod.Reliable);
|
|
}
|
|
}
|
|
}
|
|
|
|
public static void ServerRead(IReadMessage inc, Client client)
|
|
{
|
|
ReadyCheckState state = (ReadyCheckState)inc.ReadByte();
|
|
ReadyCheck? readyCheck = GameMain.GameSession?.CrewManager?.ActiveReadyCheck;
|
|
|
|
switch (state)
|
|
{
|
|
case ReadyCheckState.Start when readyCheck == null:
|
|
StartReadyCheck(client.Name, client);
|
|
break;
|
|
case ReadyCheckState.Update when readyCheck != null:
|
|
|
|
ReadyStatus status = (ReadyStatus)inc.ReadByte();
|
|
if (!readyCheck.Clients.ContainsKey(client.SessionId)) { return; }
|
|
|
|
readyCheck.Clients[client.SessionId] = status;
|
|
readyCheck.UpdateReadyCheck(client.SessionId, status);
|
|
break;
|
|
}
|
|
}
|
|
|
|
public static void StartReadyCheck(string author, Client? sender = null)
|
|
{
|
|
if (GameMain.GameSession?.CrewManager == null || GameMain.GameSession.CrewManager.ActiveReadyCheck != null) { return; }
|
|
|
|
var connectedClients = GameMain.Server.ConnectedClients;
|
|
ReadyCheck newReadyCheck = new ReadyCheck(connectedClients.Where(c => !c.Spectating).Select(c => c.SessionId).ToList(), 30);
|
|
GameMain.GameSession.CrewManager.ActiveReadyCheck = newReadyCheck;
|
|
newReadyCheck.InitializeReadyCheck(author, sender);
|
|
}
|
|
}
|
|
} |