SemianiakaVY/BotSharp
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

Merge pull request #1111 from iceljc/features/refine-twilio-stream-logging

Browse source 
add logging in twilio stream
This commit is contained in:
iceljc 2025-07-25 15:15:08 -05:00 committed by GitHub
parent 77ac9d22cf b15f580930
commit 0317368f46
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 24 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
src/Plugins/BotSharp.Plugin.Twilio/TwilioStreamMiddleware.cs
View file

@ -3,6 +3,7 @@ using BotSharp.Abstraction.MLTasks;
using BotSharp.Abstraction.Realtime; using BotSharp.Abstraction.Realtime;
using BotSharp.Abstraction.Realtime.Models; using BotSharp.Abstraction.Realtime.Models;
using BotSharp.Abstraction.Routing; using BotSharp.Abstraction.Routing;
using BotSharp.Abstraction.Utilities;
using BotSharp.Plugin.Twilio.Interfaces; using BotSharp.Plugin.Twilio.Interfaces;
using BotSharp.Plugin.Twilio.Models.Stream; using BotSharp.Plugin.Twilio.Models.Stream;
using Microsoft.AspNetCore.Http; using Microsoft.AspNetCore.Http;
@ -88,10 +89,15 @@ public class TwilioStreamMiddleware
continue; continue;
} }
var (eventType, data) = MapEvents(conn, receivedText); var (eventType, data) = MapEvents(conn, receivedText, conversationId);
if (eventType == "user_connected") if (eventType == "user_connected")
{ {
#if DEBUG
_logger.LogCritical($"Start twilio stream connection for conversation ({conversationId})");
#else
_logger.LogInformation($"Start twilio stream connection for conversation ({conversationId})");
#endif
// Connect to model // Connect to model
await ConnectToModel(hub, webSocket); await ConnectToModel(hub, webSocket);
} }
@ -115,6 +121,11 @@ public class TwilioStreamMiddleware
} }
else if (eventType == "user_disconnected") else if (eventType == "user_disconnected")
{ {
#if DEBUG
_logger.LogCritical($"Disconnecting twilio stream connection for conversation ({conversationId})");
#else
_logger.LogInformation($"Disconnecting twilio stream connection for conversation ({conversationId})");
#endif
await hub.Completer.Disconnect(); await hub.Completer.Disconnect();
await HandleUserDisconnected(); await HandleUserDisconnected();
} }
@ -131,9 +142,19 @@ public class TwilioStreamMiddleware
}); });
} }
private (string, string) MapEvents(RealtimeHubConnection conn, string receivedText) private (string, string) MapEvents(RealtimeHubConnection conn, string receivedText, string conversationId)
{ {
var response = JsonSerializer.Deserialize<StreamEventResponse>(receivedText); StreamEventResponse? response = new();
try
{
response = JsonSerializer.Deserialize<StreamEventResponse>(receivedText);
}
catch (Exception ex)
{
_logger.LogError(ex, $"Error when deserializing twilio stream event response for conversation ({conversationId}) (response: {receivedText?.SubstringMax(30)})");
}
conn.StreamId = response.StreamSid; conn.StreamId = response.StreamSid;
string eventType = response.Event; string eventType = response.Event;
string data = string.Empty; string data = string.Empty;