104 lines
2.8 KiB
C#
104 lines
2.8 KiB
C#
using System.Text;
|
|
using Mine2d.engine.system.annotations;
|
|
using Mine2d.game;
|
|
using Mine2d.game.backend.network;
|
|
using Mine2d.game.backend.network.packets;
|
|
using Newtonsoft.Json;
|
|
using WatsonTcp;
|
|
|
|
namespace Mine2d.engine.networking;
|
|
|
|
public class Backend : IBackend
|
|
{
|
|
private WatsonTcpServer server;
|
|
private Publisher publisher;
|
|
private readonly Queue<Packet> pendingPackets = new();
|
|
private uint tick;
|
|
|
|
public void Process(double dt)
|
|
{
|
|
this.ProcessPacket(new TickPacket
|
|
{
|
|
Tick = ++this.tick
|
|
});
|
|
|
|
var context = Context.Get();
|
|
context.GameState.Tick = this.tick;
|
|
context.GameState.DeltaTime = dt;
|
|
while (this.pendingPackets.Count > 0)
|
|
{
|
|
this.publisher.Publish(this.pendingPackets.Dequeue());
|
|
}
|
|
this.SendGameState();
|
|
}
|
|
|
|
public void ProcessPacket(Packet packet)
|
|
{
|
|
this.pendingPackets.Enqueue(packet);
|
|
}
|
|
|
|
public void Init()
|
|
{
|
|
Task.Run(this.Run);
|
|
this.publisher = new Publisher(InteractorKind.Hybrid);
|
|
this.publisher.Dump();
|
|
}
|
|
|
|
public void Run()
|
|
{
|
|
this.server = new WatsonTcpServer("127.0.0.1", 42069);
|
|
this.server.Events.ClientConnected += this.ClientConnected;
|
|
this.server.Events.ClientDisconnected += this.ClientDisconnected;
|
|
this.server.Events.MessageReceived += this.MessageReceived;
|
|
this.server.Start();
|
|
}
|
|
|
|
private void ClientConnected(object sender, ConnectionEventArgs args)
|
|
{
|
|
Console.WriteLine("Client connected: " + args.IpPort);
|
|
var gameState = Context.Get().GameState;
|
|
var json = JsonConvert.SerializeObject(gameState);
|
|
if (sender is WatsonTcpServer server)
|
|
{
|
|
server.Send(args.IpPort, Encoding.UTF8.GetBytes(json));
|
|
}
|
|
}
|
|
|
|
private void ClientDisconnected(object sender, DisconnectionEventArgs args)
|
|
{
|
|
Console.WriteLine("Client disconnected: " + args.IpPort);
|
|
}
|
|
|
|
private void MessageReceived(object sender, MessageReceivedEventArgs args)
|
|
{
|
|
Console.WriteLine("Message Received: " + args.IpPort);
|
|
|
|
var packet = Converter.ParsePacket(args.Data);
|
|
Console.WriteLine($"Received packet: {packet.Type}");
|
|
|
|
this.pendingPackets.Enqueue(packet);
|
|
}
|
|
|
|
private void SendGameState()
|
|
{
|
|
if (this.server == null)
|
|
{
|
|
return;
|
|
}
|
|
|
|
var clients = this.server.ListClients().ToArray();
|
|
if (!clients.Any())
|
|
{
|
|
return;
|
|
}
|
|
|
|
var gameState = Context.Get().GameState;
|
|
var json = JsonConvert.SerializeObject(gameState);
|
|
var bytes = Encoding.UTF8.GetBytes(json);
|
|
foreach (var client in clients)
|
|
{
|
|
this.server.Send(client, bytes);
|
|
}
|
|
}
|
|
}
|