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

⏪ Revert create message when call ended by webhook to prevent circular deps

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

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

@ -15,7 +15,6 @@ public class LivekitRealtimeService : IRealtimeService
private readonly AppDatabase _db; private readonly AppDatabase _db;
private readonly ICacheService _cache; private readonly ICacheService _cache;
private readonly WebSocketService _ws; private readonly WebSocketService _ws;
private readonly ChatService _cs;
private readonly ILogger<LivekitRealtimeService> _logger; private readonly ILogger<LivekitRealtimeService> _logger;
private readonly RoomServiceClient _roomService; private readonly RoomServiceClient _roomService;
@ -27,8 +26,7 @@ public class LivekitRealtimeService : IRealtimeService
ILogger<LivekitRealtimeService> logger, ILogger<LivekitRealtimeService> logger,
AppDatabase db, AppDatabase db,
ICacheService cache, ICacheService cache,
WebSocketService ws, WebSocketService ws
ChatService cs
) )
{ {
_logger = logger; _logger = logger;
@ -48,7 +46,6 @@ public class LivekitRealtimeService : IRealtimeService
_db = db; _db = db;
_cache = cache; _cache = cache;
_ws = ws; _ws = ws;
_cs = cs;
} }
/// <inheritdoc /> /// <inheritdoc />
@ -143,29 +140,10 @@ public class LivekitRealtimeService : IRealtimeService
{ {
case "room_finished": case "room_finished":
var now = SystemClock.Instance.GetCurrentInstant(); var now = SystemClock.Instance.GetCurrentInstant();
var call = await _db.ChatRealtimeCall await _db.ChatRealtimeCall
.Where(c => c.SessionId == evt.Room.Name) .Where(c => c.SessionId == evt.Room.Name)
.Include(c => c.Room) .ExecuteUpdateAsync(s => s.SetProperty(p => p.EndedAt, now)
.Include(c => c.Sender) );
.FirstOrDefaultAsync();
if (call is not null)
{
await _cs.SendMessageAsync(new Message
{
Type = "call.ended",
ChatRoomId = call.RoomId,
SenderId = call.SenderId,
Meta = new Dictionary<string, object>
{
{ "call_id", call.Id },
{ "duration", (call.EndedAt!.Value - call.CreatedAt).TotalSeconds }
}
}, call.Sender, call.Room);
await _db.ChatRealtimeCall
.Where(c => c.SessionId == evt.Room.Name)
.ExecuteUpdateAsync(s => s.SetProperty(p => p.EndedAt, now)
);
}
// Also clean up participants list when the room is finished // Also clean up participants list when the room is finished
await _cache.RemoveAsync(_GetParticipantsKey(evt.Room.Name)); await _cache.RemoveAsync(_GetParticipantsKey(evt.Room.Name));