1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
|
using System.Linq;
using System.Threading.Tasks;
using Impostor.Api.Innersloth;
using Impostor.Api.Net;
using Impostor.Api.Net.Messages;
using Impostor.Api.Net.Messages.S2C;
using Impostor.Hazel;
using Impostor.Server.Net.Inner;
namespace Impostor.Server.Net.State
{
internal partial class Game
{
public async ValueTask SendToAllAsync(IMessageWriter writer, LimboStates states = LimboStates.NotLimbo)
{
foreach (var connection in GetConnections(x => x.Limbo.HasFlag(states)))
{
await connection.SendAsync(writer);
}
}
public async ValueTask SendToAllExceptAsync(IMessageWriter writer, int senderId, LimboStates states = LimboStates.NotLimbo)
{
foreach (var connection in GetConnections(x =>
x.Limbo.HasFlag(states) &&
x.Client.Id != senderId))
{
await connection.SendAsync(writer);
}
}
public async ValueTask SendToAsync(IMessageWriter writer, int id)
{
if (TryGetPlayer(id, out var player))
{
await player.Client.Connection.SendAsync(writer);
}
}
internal IMessageWriter StartRpc(uint targetNetId, RpcCalls callId, int targetClientId = -1, MessageType type = MessageType.Reliable)
{
var writer = MessageWriter.Get(type);
if (targetClientId < 0)
{
writer.StartMessage(MessageFlags.GameData);
writer.Write(Code);
}
else
{
writer.StartMessage(MessageFlags.GameDataTo);
writer.Write(Code);
writer.WritePacked(targetClientId);
}
writer.StartMessage(GameDataTag.RpcFlag);
writer.WritePacked(targetNetId);
writer.Write((byte) callId);
return writer;
}
internal ValueTask FinishRpcAsync(IMessageWriter writer, int? targetClientId = null)
{
writer.EndMessage();
writer.EndMessage();
return targetClientId.HasValue
? SendToAsync(writer, targetClientId.Value)
: SendToAllAsync(writer);
}
private void WriteRemovePlayerMessage(IMessageWriter message, bool clear, int playerId, DisconnectReason reason)
{
Message04RemovePlayerS2C.Serialize(message, clear, Code, playerId, HostId, reason);
}
private void WriteJoinedGameMessage(IMessageWriter message, bool clear, IClientPlayer player)
{
var playerIds = _players
.Where(x => x.Value != player)
.Select(x => x.Key)
.ToArray();
Message07JoinedGameS2C.Serialize(message, clear, Code, player.Client.Id, HostId, playerIds);
}
private void WriteAlterGameMessage(IMessageWriter message, bool clear, bool isPublic)
{
Message10AlterGameS2C.Serialize(message, clear, Code, isPublic);
}
private void WriteKickPlayerMessage(IMessageWriter message, bool clear, int playerId, bool isBan)
{
Message11KickPlayerS2C.Serialize(message, clear, Code, playerId, isBan);
}
private void WriteWaitForHostMessage(IMessageWriter message, bool clear, IClientPlayer player)
{
Message12WaitForHostS2C.Serialize(message, clear, Code, player.Client.Id);
}
}
}
|
