Add hooks of OnConversationsListing, OnConversationCreating

Author: Oceania2018

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

@@ -1,3 +1,5 @@
+using BotSharp.Abstraction.Repositories.Filters;
+
 namespace BotSharp.Abstraction.Conversations;
 
 public abstract class ConversationHookBase : IConversationHook
@@ -37,6 +39,12 @@ public virtual Task OnDialogsLoaded(List<RoleDialogModel> dialogs)
         return Task.CompletedTask;
     }
 
+    public virtual Task<string> OnConversationsListing(ConversationFilter filter)
+        => Task.FromResult(string.Empty);
+
+    public virtual Task OnConversationCreating(Conversation conversation)
+        => Task.CompletedTask;
+
     public virtual Task OnConversationEnding(RoleDialogModel message)
         => Task.CompletedTask;
 

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

@@ -1,4 +1,5 @@
 using BotSharp.Abstraction.Hooks;
+using BotSharp.Abstraction.Repositories.Filters;
 
 namespace BotSharp.Abstraction.Conversations;
 
@@ -19,6 +20,20 @@ public interface IConversationHook : IHookBase
     /// <returns></returns>
     Task<string> GetConversationIntent() => Task.FromResult(string.Empty);
 
+    /// <summary>
+    /// Triggered when listing conversations.
+    /// </summary>
+    /// <param name="filter"></param>
+    /// <returns></returns>
+    Task<string> OnConversationsListing(ConversationFilter filter);
+
+    /// <summary>
+    /// Triggered when a new conversation is creating.
+    /// </summary>
+    /// <param name="conversation"></param>
+    /// <returns></returns>
+    Task OnConversationCreating(Conversation conversation);
+
     /// <summary>
     /// Triggered when user connects with agent first time.
     /// This hook is the good timing to show welcome infomation.

src/Infrastructure/BotSharp.Core/Conversations/Services/ConversationService.cs

@@ -84,6 +84,13 @@ public async Task<PagedItems<Conversation>> GetConversations(ConversationFilter
         }
 
         var db = _services.GetRequiredService<IBotSharpRepository>();
+
+        var hooks = _services.GetHooks<IConversationHook>(filter.AgentId);
+        foreach (var hook in hooks)
+        {
+            await hook.OnConversationsListing(filter);
+        }
+
         var conversations = await db.GetConversations(filter);
         return conversations;
     }
@@ -112,9 +119,14 @@ public async Task<Conversation> NewConversation(Conversation sess)
         record.Tags = sess.Tags;
         record.Title = string.IsNullOrEmpty(record.Title) ? "New Conversation" : record.Title;
 
-        await db.CreateNewConversation(record);
+        var hooks = _services.GetHooks<IConversationHook>(sess.AgentId);
+        foreach (var hook in hooks)
+        {
+            // If user connect agent first time
+            await hook.OnConversationCreating(record);
+        }
 
-        var hooks = _services.GetHooks<IConversationHook>(record.AgentId);
+        await db.CreateNewConversation(record);
 
         foreach (var hook in hooks)
         {