37 lines
1 KiB
C#
37 lines
1 KiB
C#
// Copyright (c) 2023 Timothy Schenk. Subject to the GNU AGPL Version 3 License.
|
|
|
|
using System.Diagnostics;
|
|
using JetBrains.Annotations;
|
|
using NetCoreServer;
|
|
using Wonderking.Packets;
|
|
|
|
namespace Server.PacketHandlers;
|
|
|
|
[UsedImplicitly(ImplicitUseTargetFlags.WithInheritors)]
|
|
public interface IPacketHandler<in T> : IPacketHandler where T : IPacket
|
|
{
|
|
[UsedImplicitly]
|
|
public Task HandleAsync(T packet, TcpSession session);
|
|
|
|
async Task<bool> IPacketHandler.TryHandleAsync(IPacket packet, TcpSession session)
|
|
{
|
|
if (packet is not T tPacket)
|
|
{
|
|
return false;
|
|
}
|
|
|
|
using (var activity = new ActivitySource(nameof(Server)).StartActivity("HandleAsync"))
|
|
{
|
|
activity?.SetTag("Handler", this.ToString());
|
|
activity?.SetTag("PacketId", packet.ToString());
|
|
await HandleAsync(tPacket, session);
|
|
}
|
|
|
|
return true;
|
|
}
|
|
}
|
|
|
|
public interface IPacketHandler
|
|
{
|
|
Task<bool> TryHandleAsync(IPacket packet, TcpSession session);
|
|
}
|