refactor!: rename BaseClientNode to ClientNode
This commit is contained in:
parent
e7dfe97c6d
commit
259fdddd6e
|
@ -4,7 +4,7 @@ namespace TcpDotNet.ClientIntegrationTest.PacketHandlers;
|
||||||
|
|
||||||
internal sealed class GoodbyePacketHandler : PacketHandler<GoodbyePacket>
|
internal sealed class GoodbyePacketHandler : PacketHandler<GoodbyePacket>
|
||||||
{
|
{
|
||||||
public override Task HandleAsync(BaseClientNode recipient, GoodbyePacket packet, CancellationToken cancellationToken = default)
|
public override Task HandleAsync(ClientNode recipient, GoodbyePacket packet, CancellationToken cancellationToken = default)
|
||||||
{
|
{
|
||||||
Console.WriteLine($"Server sent {packet.Message}");
|
Console.WriteLine($"Server sent {packet.Message}");
|
||||||
return Task.CompletedTask;
|
return Task.CompletedTask;
|
||||||
|
|
|
@ -4,7 +4,7 @@ namespace TcpDotNet.ListenerIntegrationTest.PacketHandlers;
|
||||||
|
|
||||||
internal sealed class HelloPacketHandler : PacketHandler<HelloPacket>
|
internal sealed class HelloPacketHandler : PacketHandler<HelloPacket>
|
||||||
{
|
{
|
||||||
public override Task HandleAsync(BaseClientNode recipient, HelloPacket packet, CancellationToken cancellationToken = default)
|
public override Task HandleAsync(ClientNode recipient, HelloPacket packet, CancellationToken cancellationToken = default)
|
||||||
{
|
{
|
||||||
Console.WriteLine($"Client sent {packet.Message}");
|
Console.WriteLine($"Client sent {packet.Message}");
|
||||||
return recipient.SendPacketAsync(new GoodbyePacket {Message = "Goodbye!"}, cancellationToken);
|
return recipient.SendPacketAsync(new GoodbyePacket {Message = "Goodbye!"}, cancellationToken);
|
||||||
|
|
|
@ -16,7 +16,7 @@ await Task.Delay(-1);
|
||||||
|
|
||||||
internal sealed class PingPacketHandler : PacketHandler<PingPacket>
|
internal sealed class PingPacketHandler : PacketHandler<PingPacket>
|
||||||
{
|
{
|
||||||
public override async Task HandleAsync(BaseClientNode recipient, PingPacket packet, CancellationToken cancellationToken = default)
|
public override async Task HandleAsync(ClientNode recipient, PingPacket packet, CancellationToken cancellationToken = default)
|
||||||
{
|
{
|
||||||
Console.WriteLine($"Client {recipient.SessionId} sent ping with payload {BitConverter.ToString(packet.Payload)}");
|
Console.WriteLine($"Client {recipient.SessionId} sent ping with payload {BitConverter.ToString(packet.Payload)}");
|
||||||
var pong = new PongPacket(packet.CallbackId, packet.Payload);
|
var pong = new PongPacket(packet.CallbackId, packet.Payload);
|
||||||
|
|
|
@ -13,16 +13,16 @@ namespace TcpDotNet;
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// Represents a client node.
|
/// Represents a client node.
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public abstract class BaseClientNode : Node
|
public abstract class ClientNode : Node
|
||||||
{
|
{
|
||||||
private readonly ObjectIDGenerator _callbackIdGenerator = new();
|
private readonly ObjectIDGenerator _callbackIdGenerator = new();
|
||||||
private readonly ConcurrentDictionary<int, List<TaskCompletionSource<Packet>>> _packetCompletionSources = new();
|
private readonly ConcurrentDictionary<int, List<TaskCompletionSource<Packet>>> _packetCompletionSources = new();
|
||||||
private EndPoint? _remoteEP;
|
private EndPoint? _remoteEP;
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// Initializes a new instance of the <see cref="BaseClientNode" /> class.
|
/// Initializes a new instance of the <see cref="ClientNode" /> class.
|
||||||
/// </summary>
|
/// </summary>
|
||||||
protected BaseClientNode()
|
protected ClientNode()
|
||||||
{
|
{
|
||||||
}
|
}
|
||||||
|
|
|
@ -1,7 +1,7 @@
|
||||||
namespace TcpDotNet;
|
namespace TcpDotNet;
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// An enumeration of states for a <see cref="BaseClientNode" /> to be in.
|
/// An enumeration of states for a <see cref="ClientNode" /> to be in.
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public enum ClientState
|
public enum ClientState
|
||||||
{
|
{
|
||||||
|
|
|
@ -12,7 +12,7 @@ public abstract class PacketHandler
|
||||||
/// <param name="recipient">The recipient of the packet.</param>
|
/// <param name="recipient">The recipient of the packet.</param>
|
||||||
/// <param name="packet">The packet to handle.</param>
|
/// <param name="packet">The packet to handle.</param>
|
||||||
/// <param name="cancellationToken">A cancellation token that can be used to cancel the asynchronous operation.</param>
|
/// <param name="cancellationToken">A cancellation token that can be used to cancel the asynchronous operation.</param>
|
||||||
public abstract Task HandleAsync(BaseClientNode recipient, Packet packet, CancellationToken cancellationToken = default);
|
public abstract Task HandleAsync(ClientNode recipient, Packet packet, CancellationToken cancellationToken = default);
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
|
@ -27,7 +27,7 @@ public abstract class PacketHandler<T> : PacketHandler
|
||||||
public static readonly PacketHandler<T> Empty = new NullPacketHandler<T>();
|
public static readonly PacketHandler<T> Empty = new NullPacketHandler<T>();
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
public override Task HandleAsync(BaseClientNode recipient, Packet packet, CancellationToken cancellationToken = default)
|
public override Task HandleAsync(ClientNode recipient, Packet packet, CancellationToken cancellationToken = default)
|
||||||
{
|
{
|
||||||
if (packet is T actual) return HandleAsync(recipient, actual, cancellationToken);
|
if (packet is T actual) return HandleAsync(recipient, actual, cancellationToken);
|
||||||
return Task.CompletedTask;
|
return Task.CompletedTask;
|
||||||
|
@ -39,7 +39,7 @@ public abstract class PacketHandler<T> : PacketHandler
|
||||||
/// <param name="recipient">The recipient of the packet.</param>
|
/// <param name="recipient">The recipient of the packet.</param>
|
||||||
/// <param name="packet">The packet to handle.</param>
|
/// <param name="packet">The packet to handle.</param>
|
||||||
/// <param name="cancellationToken">A cancellation token that can be used to cancel the asynchronous operation.</param>
|
/// <param name="cancellationToken">A cancellation token that can be used to cancel the asynchronous operation.</param>
|
||||||
public abstract Task HandleAsync(BaseClientNode recipient, T packet, CancellationToken cancellationToken = default);
|
public abstract Task HandleAsync(ClientNode recipient, T packet, CancellationToken cancellationToken = default);
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
|
@ -50,7 +50,7 @@ internal sealed class NullPacketHandler<T> : PacketHandler<T>
|
||||||
where T : Packet
|
where T : Packet
|
||||||
{
|
{
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
public override Task HandleAsync(BaseClientNode recipient, T packet, CancellationToken cancellationToken = default)
|
public override Task HandleAsync(ClientNode recipient, T packet, CancellationToken cancellationToken = default)
|
||||||
{
|
{
|
||||||
return Task.CompletedTask;
|
return Task.CompletedTask;
|
||||||
}
|
}
|
||||||
|
|
|
@ -6,7 +6,7 @@ internal sealed class DisconnectPacketHandler : PacketHandler<DisconnectPacket>
|
||||||
{
|
{
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
public override Task HandleAsync(
|
public override Task HandleAsync(
|
||||||
BaseClientNode recipient,
|
ClientNode recipient,
|
||||||
DisconnectPacket packet,
|
DisconnectPacket packet,
|
||||||
CancellationToken cancellationToken = default
|
CancellationToken cancellationToken = default
|
||||||
)
|
)
|
||||||
|
|
|
@ -11,7 +11,7 @@ internal sealed class EncryptionResponsePacketHandler : PacketHandler<Encryption
|
||||||
{
|
{
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
public override async Task HandleAsync(
|
public override async Task HandleAsync(
|
||||||
BaseClientNode recipient,
|
ClientNode recipient,
|
||||||
EncryptionResponsePacket packet,
|
EncryptionResponsePacket packet,
|
||||||
CancellationToken cancellationToken = default
|
CancellationToken cancellationToken = default
|
||||||
)
|
)
|
||||||
|
|
|
@ -10,7 +10,7 @@ internal sealed class HandshakeRequestPacketHandler : PacketHandler<HandshakeReq
|
||||||
{
|
{
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
public override async Task HandleAsync(
|
public override async Task HandleAsync(
|
||||||
BaseClientNode recipient,
|
ClientNode recipient,
|
||||||
HandshakeRequestPacket packet,
|
HandshakeRequestPacket packet,
|
||||||
CancellationToken cancellationToken = default
|
CancellationToken cancellationToken = default
|
||||||
)
|
)
|
||||||
|
|
|
@ -14,7 +14,7 @@ namespace TcpDotNet;
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// Represents a client on the TcpDotNet protocol.
|
/// Represents a client on the TcpDotNet protocol.
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public sealed class ProtocolClient : BaseClientNode
|
public sealed class ProtocolClient : ClientNode
|
||||||
{
|
{
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// Initializes a new instance of the <see cref="ProtocolClient" /> class.
|
/// Initializes a new instance of the <see cref="ProtocolClient" /> class.
|
||||||
|
|
|
@ -8,7 +8,7 @@ public sealed partial class ProtocolListener
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// Represents a client that is connected to a <see cref="ProtocolListener" />.
|
/// Represents a client that is connected to a <see cref="ProtocolListener" />.
|
||||||
/// </summary>
|
/// </summary>
|
||||||
public sealed class Client : BaseClientNode
|
public sealed class Client : ClientNode
|
||||||
{
|
{
|
||||||
internal Client(ProtocolListener listener, Socket socket)
|
internal Client(ProtocolListener listener, Socket socket)
|
||||||
{
|
{
|
||||||
|
|
Loading…
Reference in New Issue