rust/forkmessager
1
0
Fork 0
Code Issues 2 Pull Requests Actions Packages Projects 3 Releases Wiki Activity

безопасная обертка IsUserInvisibleAsync

Browse Source
This commit is contained in:
max
2026-04-17 23:03:15 +03:00
parent bccbf12a11
commit e8c9a55fe9
2 changed files with 31 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/src/Modules/Conversations/Infrastructure/SignalR/ChatHub.cs
+26 -9
View File
@@ -102,7 +102,11 @@ public sealed class ChatHub : Hub
var isInvisible = await IsUserInvisibleAsync(_userContext.UserId, Context.ConnectionAborted);
if (!isInvisible)
{
await BroadcastPresenceToVisibleUsersAsync("user_online", new { userId }, _userContext.UserId);
await BroadcastPresenceToVisibleUsersAsync(
"user_online",
new { userId },
_userContext.UserId,
Context.ConnectionAborted);
}
}
await base.OnConnectedAsync();
@@ -119,13 +123,22 @@ public sealed class ChatHub : Hub
if (set.Count == 0)
{
_userConnections.TryRemove(userId, out _);
var isInvisible = await IsUserInvisibleAsync(_userContext.UserId, Context.ConnectionAborted);
if (!isInvisible)
try
{
await BroadcastPresenceToVisibleUsersAsync(
"user_offline",
new { userId, lastSeen = DateTime.UtcNow },
_userContext.UserId);
// Connection is tearing down: ConnectionAborted is already signaled and will cancel I/O.
var isInvisible = await IsUserInvisibleAsync(_userContext.UserId, CancellationToken.None);
if (!isInvisible)
{
await BroadcastPresenceToVisibleUsersAsync(
"user_offline",
new { userId, lastSeen = DateTime.UtcNow },
_userContext.UserId,
CancellationToken.None);
}
}
catch (Exception ex)
{
_logger.LogWarning(ex, "Presence broadcast on disconnect failed for {UserId}", userId);
}
}
}
@@ -141,7 +154,11 @@ public sealed class ChatHub : Hub
return profile?.IsInvisible ?? false;
}
private async Task BroadcastPresenceToVisibleUsersAsync(string eventName, object payload, Guid sourceUserId)
private async Task BroadcastPresenceToVisibleUsersAsync(
string eventName,
object payload,
Guid sourceUserId,
CancellationToken cancellationToken)
{
var recipients = _userConnections.Keys
.Where(id => id != sourceUserId.ToString())
@@ -153,7 +170,7 @@ public sealed class ChatHub : Hub
if (recipients.Count == 0)
return;
var recipientProfiles = await _profileRepository.GetAsync(recipients, Context.ConnectionAborted);
var recipientProfiles = await _profileRepository.GetAsync(recipients, cancellationToken);
var invisibleRecipientIds = recipientProfiles
.Where(p => p.IsInvisible)
.Select(p => p.UserId)