115 lines
4.1 KiB
C#
115 lines
4.1 KiB
C#
using System.Buffers;
|
|
using System.Net.Sockets;
|
|
using System.Numerics;
|
|
using System.Runtime.InteropServices;
|
|
using Shared;
|
|
using Shared.Packet;
|
|
using Shared.Packet.Packets;
|
|
|
|
// Guid startId = new Guid(1, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0);
|
|
|
|
Guid baseOtherId = Guid.Parse("8ca3fcdd-2940-1000-b5f8-579301fcbfbb");
|
|
// Guid baseOtherId = Guid.Parse("d5feae62-2e71-1000-88fd-597ea147ae88");
|
|
|
|
PacketType[] reboundPackets = {
|
|
PacketType.Player,
|
|
PacketType.Cap,
|
|
PacketType.Capture,
|
|
PacketType.Costume,
|
|
PacketType.Tag,
|
|
PacketType.Game,
|
|
// PacketType.Shine
|
|
};
|
|
|
|
//string lastCapture = ""; //not referenced
|
|
List<TcpClient> clients = new List<TcpClient>();
|
|
|
|
async Task S(string n, Guid otherId, Guid ownId) {
|
|
Logger logger = new Logger($"Client ({n})");
|
|
TcpClient client = new TcpClient(args[0], 1027);
|
|
clients.Add(client);
|
|
NetworkStream stream = client.GetStream();
|
|
logger.Info("Connected!");
|
|
async Task<bool> Read(Memory<byte> readMem, int readSize, int readOffset) {
|
|
readSize += readOffset;
|
|
while (readOffset < readSize) {
|
|
int size = await stream.ReadAsync(readMem[readOffset..readSize]);
|
|
if (size == 0) {
|
|
// treat it as a disconnect and exit
|
|
logger.Info($"Socket {client.Client.RemoteEndPoint} disconnected.");
|
|
return false;
|
|
}
|
|
|
|
readOffset += size;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
{
|
|
ConnectPacket connect = new ConnectPacket {
|
|
ConnectionType = ConnectPacket.ConnectionTypes.Reconnecting,
|
|
ClientName = n
|
|
};
|
|
PacketHeader coolHeader = new PacketHeader {
|
|
Type = PacketType.Connect,
|
|
Id = ownId,
|
|
PacketSize = connect.Size,
|
|
};
|
|
IMemoryOwner<byte> connectOwner = MemoryPool<byte>.Shared.RentZero(Constants.HeaderSize + connect.Size);
|
|
// coolHeader.Serialize(connectOwner.Memory.Span[..Constants.HeaderSize]);
|
|
MemoryMarshal.Write(connectOwner.Memory.Span[..Constants.HeaderSize], ref coolHeader);
|
|
connect.Serialize(connectOwner.Memory.Span[Constants.HeaderSize..(Constants.HeaderSize + connect.Size)]);
|
|
await stream.WriteAsync(connectOwner.Memory[..(Constants.HeaderSize + connect.Size)]);
|
|
connectOwner.Dispose();
|
|
}
|
|
|
|
while (true) {
|
|
IMemoryOwner<byte> owner = MemoryPool<byte>.Shared.RentZero(0xFF);
|
|
if (!await Read(owner.Memory, Constants.HeaderSize, 0)) return;
|
|
PacketHeader header = MemoryMarshal.Read<PacketHeader>(owner.Memory.Span);
|
|
if (header.Size > 0) {
|
|
if (!await Read(owner.Memory, header.PacketSize, Constants.HeaderSize)) return;
|
|
}
|
|
PacketType type = header.Type;
|
|
if (header.Id != otherId || reboundPackets.All(x => x != type)) {
|
|
owner.Dispose();
|
|
continue;
|
|
}
|
|
if (type == PacketType.Player) {
|
|
#pragma warning disable CS4014
|
|
Task.Run(async () => {
|
|
await Task.Delay(1000);
|
|
header.Id = ownId;
|
|
MemoryMarshal.Write(owner.Memory.Span[..Constants.HeaderSize], ref header);
|
|
await stream.WriteAsync(owner.Memory[..(Constants.HeaderSize + header.PacketSize)]);
|
|
owner.Dispose();
|
|
}).ContinueWith(x => { if (x.Exception != null) { logger.Error(x.Exception.ToString()); } });
|
|
#pragma warning restore CS4014
|
|
continue;
|
|
}
|
|
header.Id = ownId;
|
|
MemoryMarshal.Write(owner.Memory.Span[..Constants.HeaderSize], ref header);
|
|
await stream.WriteAsync(owner.Memory[..(Constants.HeaderSize + header.PacketSize)]);
|
|
owner.Dispose();
|
|
}
|
|
}
|
|
|
|
Guid temp = baseOtherId;
|
|
IEnumerable<Task> stuff = Enumerable.Range(0, 7).Select(i => {
|
|
byte[] tmp = temp.ToByteArray();
|
|
tmp[0]++;
|
|
Guid newOwnId = new Guid(tmp);
|
|
Task task = S($"Sussy {i}", temp, newOwnId);
|
|
temp = newOwnId;
|
|
return task;
|
|
});
|
|
Console.CancelKeyPress += (_, e) => {
|
|
e.Cancel = true;
|
|
foreach (TcpClient tcpClient in clients) {
|
|
tcpClient.Close();
|
|
}
|
|
Environment.Exit(0);
|
|
};
|
|
await Task.WhenAll(stuff.ToArray());
|