RedWizardsLab/EchoHub
1
0
Fork 0
mirror of https://github.com/RedWizardsLab/EchoHub.git synced 2026-09-04 08:36:11 +02:00
Code Issues 2 Packages Projects Releases 10 Wiki Activity

refactor: Update SignalRBroadcaster to use IServiceProvider for hub context retrieval

Browse Source
This commit is contained in:
HueByte
2026-02-19 13:54:42 +01:00
parent cf5ef80c08
commit 0422066851
1 changed files with 23 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/EchoHub.Server/Services/SignalRBroadcaster.cs
+23 -12
View File
@@ -5,42 +5,53 @@ using Microsoft.AspNetCore.SignalR;
namespace EchoHub.Server.Services; namespace EchoHub.Server.Services;
public class SignalRBroadcaster( public class SignalRBroadcaster : IChatBroadcaster
IHubContext<ChatHub, IEchoHubClient> hubContext,
PresenceTracker presenceTracker) : IChatBroadcaster
{ {
private readonly IServiceProvider _serviceProvider;
private readonly PresenceTracker _presenceTracker;
private IHubContext<ChatHub, IEchoHubClient>? _hubContext;
private IHubContext<ChatHub, IEchoHubClient> HubContext
=> _hubContext ??= _serviceProvider.GetRequiredService<IHubContext<ChatHub, IEchoHubClient>>();
public SignalRBroadcaster(IServiceProvider serviceProvider, PresenceTracker presenceTracker)
{
_serviceProvider = serviceProvider;
_presenceTracker = presenceTracker;
}
public Task SendMessageToChannelAsync(string channelName, MessageDto message) public Task SendMessageToChannelAsync(string channelName, MessageDto message)
=> hubContext.Clients.Group(channelName).ReceiveMessage(message); => HubContext.Clients.Group(channelName).ReceiveMessage(message);
public Task SendUserJoinedAsync(string channelName, string username, string? excludeConnectionId = null) public Task SendUserJoinedAsync(string channelName, string username, string? excludeConnectionId = null)
{ {
if (excludeConnectionId is not null && !excludeConnectionId.StartsWith("irc-")) if (excludeConnectionId is not null && !excludeConnectionId.StartsWith("irc-"))
return hubContext.Clients.GroupExcept(channelName, [excludeConnectionId]).UserJoined(channelName, username); return HubContext.Clients.GroupExcept(channelName, [excludeConnectionId]).UserJoined(channelName, username);
return hubContext.Clients.Group(channelName).UserJoined(channelName, username); return HubContext.Clients.Group(channelName).UserJoined(channelName, username);
} }
public Task SendUserLeftAsync(string channelName, string username) public Task SendUserLeftAsync(string channelName, string username)
=> hubContext.Clients.Group(channelName).UserLeft(channelName, username); => HubContext.Clients.Group(channelName).UserLeft(channelName, username);
public Task SendChannelUpdatedAsync(ChannelDto channel, string? channelName = null) public Task SendChannelUpdatedAsync(ChannelDto channel, string? channelName = null)
{ {
if (channelName is not null) if (channelName is not null)
return hubContext.Clients.Group(channelName).ChannelUpdated(channel); return HubContext.Clients.Group(channelName).ChannelUpdated(channel);
return hubContext.Clients.All.ChannelUpdated(channel); return HubContext.Clients.All.ChannelUpdated(channel);
} }
public Task SendUserStatusChangedAsync(List<string> channelNames, UserPresenceDto presence) public Task SendUserStatusChangedAsync(List<string> channelNames, UserPresenceDto presence)
{ {
var connections = presenceTracker.GetConnectionsInChannels(channelNames) var connections = _presenceTracker.GetConnectionsInChannels(channelNames)
.Where(c => !c.StartsWith("irc-")) .Where(c => !c.StartsWith("irc-"))
.ToList(); .ToList();
if (connections.Count == 0) if (connections.Count == 0)
return Task.CompletedTask; return Task.CompletedTask;
return hubContext.Clients.Clients(connections).UserStatusChanged(presence); return HubContext.Clients.Clients(connections).UserStatusChanged(presence);
} }
public Task SendErrorAsync(string connectionId, string message) public Task SendErrorAsync(string connectionId, string message)
@@ -48,6 +59,6 @@ public class SignalRBroadcaster(
if (connectionId.StartsWith("irc-")) if (connectionId.StartsWith("irc-"))
return Task.CompletedTask; return Task.CompletedTask;
return hubContext.Clients.Client(connectionId).Error(message); return HubContext.Clients.Client(connectionId).Error(message);
} }
} }