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
|
using System.Collections.ObjectModel;
using LiteNetLib;
using LiteNetLib.Utils;
namespace OnekoOnline.Net;
class Client
{
public readonly string UserName = OnekoOnline.Config.GetValue("UserName", "Oneko");
public int Id {get; private set;} = -1;
public bool Connected => NetClient?.ConnectedPeersCount > 0 && Id != -1;
readonly EventBasedNetListener Listener;
readonly NetManager NetClient;
public NetPeer ConnectedServer => NetClient.FirstPeer;
readonly Dictionary<int, User> users = [];
public ReadOnlyDictionary<int, User> Users => users.AsReadOnly();
public Client(string ServerAddress, int port, string ServerPassword)
{
if (ServerAddress == "") throw new Exception("Server Address invalid!");
Listener = new();
NetClient = new(Listener);
NetClient.Start();
NetClient.Connect(ServerAddress, port, ServerPassword);
Listener.PeerConnectedEvent += peer => {
Console.WriteLine("Connected to the Server!");
NetDataWriter writer = new();
writer.Put(new PacketInfo(PacketType.OnekoSpritesheet, Id));
writer.Put(Oneko.LocalOneko!.SpriteSheet.Serialize());
peer.Send(writer, DeliveryMethod.ReliableUnordered);
writer.ResetWithInfo(new PacketInfo(PacketType.Username, Id));
writer.Put(UserName);
peer.Send(writer, DeliveryMethod.ReliableUnordered);
};
Listener.NetworkReceiveEvent += (fromPeer, reader, channel, DeliveryMethod) => {
if (reader.AvailableBytes < PacketInfo.SizeOf) return;
PacketInfo info = reader.GetPacketInfo();
if (info.Type == PacketType.UserId) {
Id = reader.GetInt();
return;
}
User? from;
if (!users.TryGetValue(info.FromId, out from)) {
from = new(info.FromId);
users.Add(from.Id, from);
}
if (info.Type == PacketType.Disconnect) {
if (from.Username != null) Console.WriteLine($"User {from.Username} left.");
users.Remove(info.FromId);
}
if (info.Type == PacketType.OnekoSpritesheet) from.SpriteSheet = reader.GetRemainingBytes();
if (info.Type == PacketType.Username) {
from.Username = reader.GetString();
Console.WriteLine($"User {from.Username} joined!");
}
};
}
public void Poll()
{
NetClient.PollEvents();
}
public void Disconnect()
{
NetClient.DisconnectAll();
}
}
|
