Merge pull request #1151 from iceljc/master

allow sending indication

Author: iceljc

src/Plugins/BotSharp.Plugin.ChartHandler/Functions/PlotChartFn.cs

@@ -82,6 +82,7 @@ public async Task<bool> Execute(RoleDialogModel message)
                         MessageId = message.MessageId,
                         CurrentAgentId = message.CurrentAgentId,
                         Content = obj.ReportSummary,
+                        Indication = "Summarizing",
                         FunctionName = message.FunctionName,
                         FunctionArgs = message.FunctionArgs,
                         CreatedAt = DateTime.UtcNow

src/Plugins/BotSharp.Plugin.ChatHub/Hooks/ChatHubConversationHook.cs

@@ -95,6 +95,14 @@ public override async Task OnResponseGenerated(RoleDialogModel message)
 
         var conv = _services.GetRequiredService<IConversationService>();
         var state = _services.GetRequiredService<IConversationStateService>();
+
+        var sender = new UserDto
+        {
+            FirstName = "AI",
+            LastName = "Assistant",
+            Role = AgentRole.Assistant
+        };
+
         var data = new ChatResponseDto()
         {
             ConversationId = conv.ConversationId,
@@ -105,12 +113,7 @@ public override async Task OnResponseGenerated(RoleDialogModel message)
             Data = message.Data,
             States = state.GetStates(),
             IsStreaming = message.IsStreaming,
-            Sender = new()
-            {
-                FirstName = "AI",
-                LastName = "Assistant",
-                Role = AgentRole.Assistant
-            }
+            Sender = sender
         };
 
         // Send type-off to client
@@ -130,6 +133,18 @@ public override async Task OnResponseGenerated(RoleDialogModel message)
 
             foreach (var item in wrapper.Messages)
             {
+                if (!string.IsNullOrWhiteSpace(item.Indication))
+                {
+                    data = new ChatResponseDto
+                    {
+                        ConversationId = conv.ConversationId,
+                        MessageId = item.MessageId,
+                        Indication = item.Indication,
+                        Sender = sender
+                    };
+                    await SendEvent(ChatEvent.OnIndicationReceived, conv.ConversationId, data);
+                }
+
                 await Task.Delay(wrapper.SendingInterval);
 
                 data = new ChatResponseDto
@@ -142,12 +157,7 @@ public override async Task OnResponseGenerated(RoleDialogModel message)
                     Data = item.Data,
                     States = state.GetStates(),
                     IsAppend = true,
-                    Sender = new()
-                    {
-                        FirstName = "AI",
-                        LastName = "Assistant",
-                        Role = AgentRole.Assistant
-                    }
+                    Sender = sender
                 };
                 await SendEvent(ChatEvent.OnMessageReceivedFromAssistant, conv.ConversationId, data);
             }