AppStd/DigitalData.Auth
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

refactor(AuthClientTests): Umbenennung der Variablennamen

Browse Source
This commit is contained in:
Developer 02 2025-02-04 20:50:34 +01:00
parent 319763040c
commit 5f9926e911
6 changed files with 23 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
DigitalData.Auth.Abstractions/IAuthClient.cs
View File

@ -1,6 +1,6 @@
namespace DigitalData.Auth.Abstractions; namespace DigitalData.Auth.Abstractions;
public interface IAuthClient : IListenHandler, IAuthSenderHandler public interface IAuthClient : IAuthListenHandler, IAuthSenderHandler
{ {
bool IsConnected { get; } bool IsConnected { get; }

6
DigitalData.Auth.Abstractions/IAuthListenHandler.cs Normal file
View File

@ -0,0 +1,6 @@
namespace DigitalData.Auth.Abstractions;
public interface IAuthListenHandler
{
Task ReceiveKeyAsync(string topic, string key);
}

6
DigitalData.Auth.Abstractions/IListenHandler.cs
View File

@ -1,6 +0,0 @@
namespace DigitalData.Auth.Abstractions;
public interface IListenHandler
{
Task ReceiveMessageAsync(string user, string message);
}

4
DigitalData.Auth.Client/AuthClient.cs
View File

@ -21,7 +21,7 @@ public class AuthClient : IAuthClient, IAsyncDisposable
.WithUrl(paramsOptions.Value.Url) .WithUrl(paramsOptions.Value.Url)
.Build(); .Build();
_connection.On<string, string>(nameof(ReceiveMessageAsync), ReceiveMessageAsync); _connection.On<string, string>(nameof(ReceiveKeyAsync), ReceiveKeyAsync);
_logger = logger; _logger = logger;
@ -61,7 +61,7 @@ public class AuthClient : IAuthClient, IAsyncDisposable
} }
} }
public Task ReceiveMessageAsync(string user, string message) => Task.Run(() => _params.Events.OnMessageReceived(user, message, _logger)); public Task ReceiveKeyAsync(string user, string message) => Task.Run(() => _params.Events.OnMessageReceived(user, message, _logger));
public Task SendKeyAsync(string user, string message) => _connection.InvokeAsync(nameof(SendKeyAsync), user, message); public Task SendKeyAsync(string user, string message) => _connection.InvokeAsync(nameof(SendKeyAsync), user, message);

20
DigitalData.Auth.Tests/Client/AuthClientTests.cs
View File

@ -86,8 +86,8 @@ public class AuthClientTests
public async Task ReceiveMessage_ShouldCallOnMessageReceived() public async Task ReceiveMessage_ShouldCallOnMessageReceived()
{ {
// Arrange // Arrange
string rcv_user = string.Empty; string rcv_topic = string.Empty;
string rcv_msg = string.Empty; string rcv_key = string.Empty;
// Sender client // Sender client
using var provider_sender = Build(opt => opt.Url = _hubUrl); using var provider_sender = Build(opt => opt.Url = _hubUrl);
@ -98,20 +98,20 @@ public class AuthClientTests
using var provider_receiver = Build(opt => using var provider_receiver = Build(opt =>
{ {
opt.Url = _hubUrl; opt.Url = _hubUrl;
opt.Events.OnMessageReceived = (user, message, logger) => opt.Events.OnMessageReceived = (topic, key, logger) =>
{ {
rcv_user = user; rcv_topic = topic;
rcv_msg = message; rcv_key = key;
}; };
}); });
var client_receiver = provider_receiver.GetRequiredService<IAuthClient>(); var client_receiver = provider_receiver.GetRequiredService<IAuthClient>();
await client_receiver.StartAsync(); await client_receiver.StartAsync();
string user = "user"; string topic = "topic";
string message = "message"; string key = "key";
// Act // Act
await sender_client.SendKeyAsync(user, message); await sender_client.SendKeyAsync(topic, key);
// delay fort getting answer // delay fort getting answer
await Task.Delay(2000); await Task.Delay(2000);
@ -119,8 +119,8 @@ public class AuthClientTests
// Assert // Assert
Assert.Multiple(() => Assert.Multiple(() =>
{ {
Assert.That(rcv_user, Is.EqualTo(user)); Assert.That(rcv_topic, Is.EqualTo(topic));
Assert.That(rcv_msg, Is.EqualTo(message)); Assert.That(rcv_key, Is.EqualTo(key));
}); });
} }
} }

8
src/DigitalData.Auth.API/Hubs/AuthHub.cs
View File

@ -3,14 +3,14 @@ using Microsoft.AspNetCore.SignalR;
namespace DigitalData.Auth.API.Hubs; namespace DigitalData.Auth.API.Hubs;
public class AuthHub : Hub<IListenHandler>, IAuthSenderHandler public class AuthHub : Hub<IAuthListenHandler>, IAuthSenderHandler
{ {
public async Task SendKeyAsync(string user, string message) public async Task SendKeyAsync(string user, string message)
=> await Clients.All.ReceiveMessageAsync(user, message); => await Clients.All.ReceiveKeyAsync(user, message);
public async Task SendMessageToCaller(string user, string message) public async Task SendMessageToCaller(string user, string message)
=> await Clients.Caller.ReceiveMessageAsync(user, message); => await Clients.Caller.ReceiveKeyAsync(user, message);
public async Task SendMessageToGroup(string user, string message) public async Task SendMessageToGroup(string user, string message)
=> await Clients.Group("Auth.API Consumers").ReceiveMessageAsync(user, message); => await Clients.Group("Auth.API Consumers").ReceiveKeyAsync(user, message);
} }