DysonNetwork/Swarm
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

🐛 Fix update call participants missing profile

Browse Source
This commit is contained in:
LittleSheep 2025-05-27 02:18:39 +08:00
parent c21cdeba74
commit 093055f9ab
1 changed files with 23 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
DysonNetwork.Sphere/Chat/Realtime/LivekitService.cs
View File

@ -298,26 +298,29 @@ public class LivekitRealtimeService : IRealtimeService
Guid? accountId = null; Guid? accountId = null;
var metadata = new Dictionary<string, string>(); var metadata = new Dictionary<string, string>();
if (!string.IsNullOrEmpty(participant.Metadata)) if (string.IsNullOrEmpty(participant.Metadata))
return new ParticipantCacheItem
{ {
Identity = participant.Identity,
Name = participant.Name,
AccountId = accountId,
State = participant.State,
Metadata = metadata,
JoinedAt = DateTime.UtcNow
};
try try
{ {
metadata = JsonSerializer.Deserialize<Dictionary<string, string>>(participant.Metadata) ?? metadata = JsonSerializer.Deserialize<Dictionary<string, string>>(participant.Metadata) ??
new Dictionary<string, string>(); new Dictionary<string, string>();
if (metadata.TryGetValue("account_id", out var accountIdStr)) if (metadata.TryGetValue("account_id", out var accountIdStr))
{
if (Guid.TryParse(accountIdStr, out var parsedId)) if (Guid.TryParse(accountIdStr, out var parsedId))
{
accountId = parsedId; accountId = parsedId;
} }
}
}
catch (Exception ex) catch (Exception ex)
{ {
_logger.LogError(ex, "Failed to parse participant metadata"); _logger.LogError(ex, "Failed to parse participant metadata");
} }
}
return new ParticipantCacheItem return new ParticipantCacheItem
{ {
@ -363,10 +366,12 @@ public class LivekitRealtimeService : IRealtimeService
.ToList(); .ToList();
var memberProfiles = new Dictionary<Guid, ChatMember>(); var memberProfiles = new Dictionary<Guid, ChatMember>();
if (accountIds.Any()) if (accountIds.Count != 0)
{ {
memberProfiles = await _db.ChatMembers memberProfiles = await _db.ChatMembers
.Where(m => m.ChatRoomId == roomInfo.RoomId && accountIds.Contains(m.AccountId)) .Where(m => m.ChatRoomId == roomInfo.RoomId && accountIds.Contains(m.AccountId))
.Include(m => m.Account)
.ThenInclude(m => m.Profile)
.ToDictionaryAsync(m => m.AccountId, m => m); .ToDictionaryAsync(m => m.AccountId, m => m);
} }