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

Merge pull request #1008 from iceljc/features/debug-local-realtime

Browse source 
add default func
This commit is contained in:
iceljc 2025-04-11 19:15:13 -05:00 committed by GitHub
parent 568c98fab0 145df077a1
commit d88e762fdb
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/Infrastructure/BotSharp.Abstraction/Realtime/IRealtimeHub.cs
View file

@ -13,5 +13,5 @@ public interface IRealtimeHub
IRealTimeCompletion Completer { get; }
Task ConnectToModel(Func<string, Task> responseToUser);
Task ConnectToModel(Func<string, Task>? responseToUser = null, Func<string, Task>? init = null);
}

10
src/Infrastructure/BotSharp.Core.Realtime/Services/RealtimeHub.cs
View file

@ -21,7 +21,7 @@ public class RealtimeHub : IRealtimeHub
_logger = logger;
}
public async Task ConnectToModel(Func<string, Task> responseToUser)
public async Task ConnectToModel(Func<string, Task>? responseToUser = null, Func<string, Task>? init = null)
{
var hookProvider = _services.GetService<ConversationHookProvider>();
var convService = _services.GetRequiredService<IConversationService>();
@ -57,13 +57,13 @@ public class RealtimeHub : IRealtimeHub
// Not TriggerModelInference, waiting for user utter.
var instruction = await _completer.UpdateSession(_conn);
var data = _conn.OnModelReady();
await responseToUser(data);
await (init?.Invoke(data) ?? Task.CompletedTask);
await HookEmitter.Emit<IRealtimeHook>(_services, async hook => await hook.OnModelReady(agent, _completer));
},
onModelAudioDeltaReceived: async (audioDeltaData, itemId) =>
{
var data = _conn.OnModelMessageReceived(audioDeltaData);
await responseToUser(data);
await (responseToUser?.Invoke(data) ?? Task.CompletedTask);
// If this is the first delta of a new response, set the start timestamp
if (!_conn.ResponseStartTimestamp.HasValue)
@ -83,7 +83,7 @@ public class RealtimeHub : IRealtimeHub
onModelAudioResponseDone: async () =>
{
var data = _conn.OnModelAudioResponseDone();
await responseToUser(data);
await (responseToUser?.Invoke(data) ?? Task.CompletedTask);
},
onAudioTranscriptDone: async transcript =>
{
@ -148,7 +148,7 @@ public class RealtimeHub : IRealtimeHub
_conn.ResetResponseState();
var data = _conn.OnModelUserInterrupted();
await responseToUser(data);
await (responseToUser?.Invoke(data) ?? Task.CompletedTask);
}
});
}