Merge pull request #742 from hchen2020/master

ITwilioHook

Author: Oceania2018

src/Infrastructure/BotSharp.Abstraction/Conversations/IConversationHook.cs

@@ -10,6 +10,13 @@ public interface IConversationHook
     Conversation Conversation { get; }
     IConversationHook SetConversation(Conversation conversation);
 
+    /// <summary>
+    /// Get the predifined intent for the conversation.
+    /// It will send to the conversation context to help LLM to understand the user's intent.
+    /// </summary>
+    /// <returns></returns>
+    Task<string> GetConversationIntent() => Task.FromResult(string.Empty);
+
     /// <summary>
     /// Triggered when user connects with agent first time.
     /// This hook is the good timing to show welcome infomation.

src/Infrastructure/BotSharp.Abstraction/Infrastructures/HookEmitOption.cs

@@ -0,0 +1,6 @@
+namespace BotSharp.Abstraction.Infrastructures;
+
+public class HookEmitOption
+{
+    public bool OnlyOnce { get; set; }
+}

src/Infrastructure/BotSharp.Core/Infrastructures/HookEmitter.cs

@@ -4,18 +4,24 @@ namespace BotSharp.Core.Infrastructures;
 
 public static class HookEmitter
 {
-    public static HookEmittedResult Emit<T>(IServiceProvider services, Action<T> action)
+    public static HookEmittedResult Emit<T>(IServiceProvider services, Action<T> action, HookEmitOption? option = null)
     {
         var logger = services.GetRequiredService<ILogger<T>>();
         var result = new HookEmittedResult();
         var hooks = services.GetServices<T>();
+        option = option ?? new();
 
         foreach (var hook in hooks)
         {
             try
             {
                 logger.LogInformation($"Emit hook action on {action.Method.Name}({hook.GetType().Name})");
                 action(hook);
+
+                if (option.OnlyOnce)
+                {
+                    break;
+                }
             }
             catch (Exception ex)
             {
@@ -26,18 +32,24 @@ public static HookEmittedResult Emit<T>(IServiceProvider services, Action<T> act
         return result;
     }
 
-    public static async Task<HookEmittedResult> Emit<T>(IServiceProvider services, Func<T, Task> action)
+    public static async Task<HookEmittedResult> Emit<T>(IServiceProvider services, Func<T, Task> action, HookEmitOption? option = null)
     {
         var logger = services.GetRequiredService<ILogger<T>>();
         var result = new HookEmittedResult();
         var hooks = services.GetServices<T>();
+        option = option ?? new();
 
         foreach (var hook in hooks)
         {
             try
             {
                 logger.LogInformation($"Emit hook action on {action.Method.Name}({hook.GetType().Name})");
                 await action(hook);
+
+                if (option.OnlyOnce)
+                {
+                    break;
+                }
             }
             catch (Exception ex)
             {