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

Merge pull request #1099 from iceljc/master

Browse source 
refine chat stream request
This commit is contained in:
iceljc 2025-07-11 10:17:03 -05:00 committed by GitHub
parent 21e92f46a1 2ec304b83c
commit 8e1ecc2917
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 15 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
src/Plugins/BotSharp.Plugin.ChatHub/ChatStreamMiddleware.cs
View file

@ -82,8 +82,8 @@ public class ChatStreamMiddleware
var (eventType, data) = MapEvents(conn, receivedText);
if (eventType == "start")
{
var states = InitStates(data);
await ConnectToModel(hub, webSocket, states);
var request = InitRequest(data);
await ConnectToModel(hub, webSocket, request?.States);
}
else if (eventType == "media")
{
@ -157,16 +157,15 @@ public class ChatStreamMiddleware
});
}
private List<MessageState> InitStates(string data)
private ChatStreamRequest? InitRequest(string data)
{
try
{
var states = JsonSerializer.Deserialize<List<MessageState>>(data, BotSharpOptions.defaultJsonOptions);
return states ?? [];
return JsonSerializer.Deserialize<ChatStreamRequest>(data, BotSharpOptions.defaultJsonOptions);
}
catch
{
return [];
return null;
}
}
}

10
src/Plugins/BotSharp.Plugin.ChatHub/Models/Stream/ChatStreamRequest.cs Normal file
View file

@ -0,0 +1,10 @@
using BotSharp.Abstraction.Models;
using System.Text.Json.Serialization;
namespace BotSharp.Plugin.ChatHub.Models.Stream;
public class ChatStreamRequest
{
[JsonPropertyName("states")]
public List<MessageState> States { get; set; } = [];
}