diff --git a/src/Plugins/BotSharp.Plugin.ChatHub/ChatStreamMiddleware.cs b/src/Plugins/BotSharp.Plugin.ChatHub/ChatStreamMiddleware.cs index 2f89252ba..da529130c 100644 --- a/src/Plugins/BotSharp.Plugin.ChatHub/ChatStreamMiddleware.cs +++ b/src/Plugins/BotSharp.Plugin.ChatHub/ChatStreamMiddleware.cs @@ -66,8 +66,10 @@ private async Task HandleWebSocket(IServiceProvider services, string agentId, st // load conversation and state var convService = services.GetRequiredService(); var state = services.GetRequiredService(); + var routing = services.GetRequiredService(); await convService.SetConversationId(conversationId, []); await convService.GetConversationRecordOrCreateNew(agentId); + await routing.Context.Push(agentId); await foreach (ChatSessionUpdate update in session.ReceiveUpdatesAsync(CancellationToken.None)) {