Skip to content

Commit 72f2334

Browse files
committed
feat: message router class name
1 parent 0f7dcf1 commit 72f2334

4 files changed

Lines changed: 15 additions & 15 deletions

File tree

SimpleNetworkManager.NET.Tests/Network/TcpTransport/TcpTransportTests.cs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -109,10 +109,10 @@ public async Task TestMessageFromClientHandling()
109109
{
110110
var server = new TcpNetworkServer(_loggerFactoryMock.Object);
111111
var serverTestMsgHandler = new TestMessageHandler();
112-
server.MessageRouter.RegisterHandler(serverTestMsgHandler);
112+
server.MessageRouterService.RegisterHandler(serverTestMsgHandler);
113113
var client = new TcpNetworkClient(_loggerFactoryMock.Object);
114114
var clientTestMsgHandler = new TestMessageHandler();
115-
client.MessageRouter.RegisterHandler(clientTestMsgHandler);
115+
client.MessageRouterService.RegisterHandler(clientTestMsgHandler);
116116

117117
var serverCancelSrc = new CancellationTokenSource();
118118
await server.StartAsync(7893, serverCancelSrc.Token);
@@ -145,10 +145,10 @@ public async Task TestMessageFromServerHandling()
145145
{
146146
var server = new TcpNetworkServer(_loggerFactoryMock.Object);
147147
var serverTestMsgHandler = new TestMessageHandler();
148-
server.MessageRouter.RegisterHandler(serverTestMsgHandler);
148+
server.MessageRouterService.RegisterHandler(serverTestMsgHandler);
149149
var client = new TcpNetworkClient(_loggerFactoryMock.Object);
150150
var clientTestMsgHandler = new TestMessageHandler();
151-
client.MessageRouter.RegisterHandler(clientTestMsgHandler);
151+
client.MessageRouterService.RegisterHandler(clientTestMsgHandler);
152152

153153
var serverCancelSrc = new CancellationTokenSource();
154154
await server.StartAsync(7894, serverCancelSrc.Token);

SimpleNetworkManager.NET/Network/BaseNetworkClient.cs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -11,17 +11,17 @@ public abstract class BaseNetworkClient
1111
{
1212
protected readonly ILoggerFactory _loggerFactory;
1313
protected readonly ILogger<BaseNetworkClient> _logger;
14-
protected readonly MessageRouterService _messageRouter;
14+
protected readonly MessageRouterService _messageRouterService;
1515

16-
public MessageRouterService MessageRouter => _messageRouter;
16+
public MessageRouterService MessageRouterService => _messageRouterService;
1717
public abstract BaseClientConnection? ClientConnection { get; }
1818
public bool IsConnected => ClientConnection?.IsConnected ?? false;
1919

2020
public BaseNetworkClient(ILoggerFactory loggerFactory)
2121
{
2222
_loggerFactory = loggerFactory;
2323
_logger = _loggerFactory.CreateLogger<BaseNetworkClient>();
24-
_messageRouter = new MessageRouterService(_loggerFactory.CreateLogger<MessageRouterService>());
24+
_messageRouterService = new MessageRouterService(_loggerFactory.CreateLogger<MessageRouterService>());
2525
}
2626

2727
public async UniTask SendMessageAsync<T>(T message)
@@ -84,7 +84,7 @@ protected virtual async void OnClientMessageReceived(BaseClientConnection client
8484
_logger.LogDebug("Received message from server");
8585

8686
// Route the message to the appropriate handler
87-
await _messageRouter.RouteMessageAsync(clientConnection, message);
87+
await _messageRouterService.RouteMessageAsync(clientConnection, message);
8888
}
8989
catch (Exception ex)
9090
{

SimpleNetworkManager.NET/Network/BaseNetworkServer.cs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -12,11 +12,11 @@ public abstract class BaseNetworkServer
1212
protected readonly ILoggerFactory _loggerFactory;
1313
protected readonly ILogger<BaseNetworkServer> _logger;
1414
protected readonly ConnectionManager _connectionManager;
15-
protected readonly MessageRouterService _messageRouter;
15+
protected readonly MessageRouterService _messageRouterService;
1616
public int MaxConnections = 1;
1717

1818
public ConnectionManager ConnectionManager => _connectionManager;
19-
public MessageRouterService MessageRouter => _messageRouter;
19+
public MessageRouterService MessageRouterService => _messageRouterService;
2020

2121
/// <summary>
2222
/// Indicates whether the server is currently running
@@ -28,7 +28,7 @@ public BaseNetworkServer(ILoggerFactory loggerFactory)
2828
_loggerFactory = loggerFactory;
2929
_logger = _loggerFactory.CreateLogger<BaseNetworkServer>();
3030
_connectionManager = new ConnectionManager(_loggerFactory.CreateLogger<ConnectionManager>());
31-
_messageRouter = new MessageRouterService(_loggerFactory.CreateLogger<MessageRouterService>());
31+
_messageRouterService = new MessageRouterService(_loggerFactory.CreateLogger<MessageRouterService>());
3232
}
3333

3434
public async UniTask SendMessageAsync<T>(uint connectionId, T message)
@@ -98,7 +98,7 @@ protected virtual async void OnClientMessageReceived(BaseClientConnection client
9898
_logger.LogDebug("Received message from client {ConnectionId}", clientConnection.ConnectionId);
9999

100100
// Route the message to the appropriate handler
101-
await _messageRouter.RouteMessageAsync(clientConnection, message);
101+
await _messageRouterService.RouteMessageAsync(clientConnection, message);
102102
}
103103
catch (Exception ex)
104104
{

SimpleNetworkManager.NET/Services/MessageRouter.cs renamed to SimpleNetworkManager.NET/Services/MessageRouterService.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -12,14 +12,14 @@ namespace Insthync.SimpleNetworkManager.NET.Services
1212
/// Routes incoming messages to appropriate message handlers based on message type.
1313
/// Provides thread-safe handler registration and async message routing.
1414
/// </summary>
15-
public class MessageRouter
15+
public class MessageRouterService
1616
{
17-
private readonly ILogger<MessageRouter> _logger;
17+
private readonly ILogger<MessageRouterService> _logger;
1818
private readonly ConcurrentDictionary<uint, IMessageHandler> _handlers;
1919
private readonly ConcurrentDictionary<uint, IMessageHandler> _requestHandlers;
2020
private readonly ConcurrentDictionary<uint, IResponseMessageHandler> _responseHandlers;
2121

22-
public MessageRouter(ILogger<MessageRouter> logger)
22+
public MessageRouterService(ILogger<MessageRouterService> logger)
2323
{
2424
_logger = logger ?? throw new ArgumentNullException(nameof(logger));
2525
_handlers = new ConcurrentDictionary<uint, IMessageHandler>();

0 commit comments

Comments
 (0)