Добавил класс для представления сообщения

This commit is contained in:
2026-08-29 00:27:48 +03:00
parent a40fcca7be
commit 4d36c5242f
5 changed files with 32 additions and 17 deletions
+6 -5
View File
@@ -1,6 +1,7 @@
using System;
using System.Threading;
using System.Threading.Tasks;
using AMessanger.Models;
using Microsoft.AspNetCore.SignalR.Client;
namespace AMessanger.Services;
@@ -9,7 +10,7 @@ public class ChatService
{
private readonly HubConnection _connection;
public event Action<string, string>? OnMessageRecieved;
public event Action<Message>? OnMessageRecieved;
public bool IsConnected { get; private set; } = false;
@@ -20,8 +21,8 @@ public class ChatService
.WithAutomaticReconnect()
.Build();
_connection.On<string, string>("ReceiveMessage", (user, message) =>
OnMessageRecieved?.Invoke(user, message));
_connection.On<Message>("ReceiveMessage", m =>
OnMessageRecieved?.Invoke(m));
}
public Task ConnectAsync(CancellationToken cancellationToken = default)
@@ -42,8 +43,8 @@ public class ChatService
return _connection.StopAsync(cancellationToken);
}
public Task SendMessageAsync(string user, string message, CancellationToken cancellationToken = default)
public Task SendMessageAsync(Message message, CancellationToken cancellationToken = default)
{
return _connection.InvokeAsync("SendMessage", user, message, cancellationToken);
return _connection.InvokeAsync("SendMessage", message, cancellationToken);
}
}