Merge pull request #785 from kerryjiang/master

Oceania2018 · web-flow · commit f8ce505a1b02 · 2024-12-14T19:48:59.000Z
Introduce ConversationHookProvider to avoid ordering conversation hooks in runtime
diff --git a/src/Infrastructure/BotSharp.Abstraction/Conversations/ConversationHookBase.cs b/src/Infrastructure/BotSharp.Abstraction/Conversations/ConversationHookBase.cs
@@ -2,27 +2,23 @@ namespace BotSharp.Abstraction.Conversations;
 
 public abstract class ConversationHookBase : IConversationHook
 {
-    protected Agent _agent;
-    public Agent Agent => _agent;
+    public Agent Agent { get; private set; }
 
-    protected Conversation _conversation;
-    public Conversation Conversation => _conversation;
+    public Conversation Conversation { get; private set; }
 
-    protected List<RoleDialogModel> _dialogs;
-    public List<RoleDialogModel> Dialogs => _dialogs;
+    public List<RoleDialogModel> Dialogs { get; private set; }
 
-    protected int _priority = 0;
-    public int Priority => _priority;
+    public int Priority { get; protected set; } = 0;
 
     public IConversationHook SetAgent(Agent agent)
     {
-        _agent = agent;
+        Agent = agent;
         return this;
     }
 
     public IConversationHook SetConversation(Conversation conversation)
     {
-        _conversation = conversation;
+        Conversation = conversation;
         return this;
     }
 
@@ -37,7 +33,7 @@ public virtual Task OnDialogRecordLoaded(RoleDialogModel dialog)
 
     public virtual Task OnDialogsLoaded(List<RoleDialogModel> dialogs)
     {
-        _dialogs = dialogs;
+        Dialogs = dialogs;
         return Task.CompletedTask;
     }
 
diff --git a/src/Infrastructure/BotSharp.Abstraction/Conversations/ConversationHookProvider.cs b/src/Infrastructure/BotSharp.Abstraction/Conversations/ConversationHookProvider.cs
@@ -0,0 +1,20 @@
+namespace BotSharp.Abstraction.Conversations;
+
+public class ConversationHookProvider
+{
+    public IEnumerable<IConversationHook> Hooks { get; }
+
+    private readonly Lazy<IEnumerable<IConversationHook>> _hooksOrderByPriority;
+
+    public IEnumerable<IConversationHook> HooksOrderByPriority
+        => _hooksOrderByPriority.Value;
+
+    public ConversationHookProvider(IEnumerable<IConversationHook> conversationHooks)
+    {
+        Hooks = conversationHooks;
+        _hooksOrderByPriority = new Lazy<IEnumerable<IConversationHook>>(() =>
+        {
+            return conversationHooks.OrderBy(hook => hook.Priority).ToArray();
+        });
+    }
+}
diff --git a/src/Infrastructure/BotSharp.Core/Conversations/Services/ConversationService.SendMessage.cs b/src/Infrastructure/BotSharp.Core/Conversations/Services/ConversationService.SendMessage.cs
@@ -28,7 +28,7 @@ public async Task<bool> SendMessage(string agentId,
         var dialogs = conv.GetDialogHistory();
 
         var statistics = _services.GetRequiredService<ITokenStatistics>();
-        var hooks = _services.GetServices<IConversationHook>().ToList();
+        var hookProvider = _services.GetRequiredService<ConversationHookProvider>();
 
         RoleDialogModel response = message;
         bool stopCompletion = false;
@@ -44,9 +44,7 @@ public async Task<bool> SendMessage(string agentId,
             message.Payload = replyMessage.Payload;
         }
 
-        // Before chat completion hook
-        hooks = ReOrderConversationHooks(hooks);
-        foreach (var hook in hooks)
+        foreach (var hook in hookProvider.HooksOrderByPriority)
         {
             hook.SetAgent(agent)
                 .SetConversation(conversation);
@@ -173,18 +171,4 @@ await hook.OnResponseGenerated(response)
         // Add to dialog history
         _storage.Append(_conversationId, response);
     }
-
-    private List<IConversationHook> ReOrderConversationHooks(List<IConversationHook> hooks)
-    {
-        var target = "ChatHubConversationHook";
-        var chathub = hooks.FirstOrDefault(x => x.GetType().Name == target);
-        var otherHooks = hooks.Where(x => x.GetType().Name != target).ToList();
-
-        if (chathub != null)
-        {
-            var newHooks = new List<IConversationHook> { chathub }.Concat(otherHooks);
-            return newHooks.ToList();
-        }
-        return hooks;
-    }
 }
diff --git a/src/Infrastructure/BotSharp.Core/Conversations/Services/ConversationService.TruncateMessage.cs b/src/Infrastructure/BotSharp.Core/Conversations/Services/ConversationService.TruncateMessage.cs
@@ -9,7 +9,7 @@ public async Task<bool> TruncateConversation(string conversationId, string messa
         var deleteMessageIds = db.TruncateConversation(conversationId, messageId, cleanLog: true);
         fileStorage.DeleteMessageFiles(conversationId, deleteMessageIds, messageId, newMessageId);
 
-        var hooks = _services.GetServices<IConversationHook>().ToList();
+        var hooks = _services.GetServices<IConversationHook>();
         foreach (var hook in hooks)
         {
             await hook.OnMessageDeleted(conversationId, messageId);
diff --git a/src/Infrastructure/BotSharp.Core/Conversations/Services/ConversationService.UpdateBreakpoint.cs b/src/Infrastructure/BotSharp.Core/Conversations/Services/ConversationService.UpdateBreakpoint.cs
@@ -31,9 +31,9 @@ public async Task UpdateBreakpoint(bool resetStates = false, string? reason = nu
             states.CleanStates(excludedStates);
         }
 
-        var hooks = _services.GetServices<IConversationHook>()
-            .OrderBy(x => x.Priority)
-            .ToList();
+        var hooks = _services
+            .GetRequiredService<ConversationHookProvider>()
+            .HooksOrderByPriority;
 
         // Before executing functions
         foreach (var hook in hooks)
diff --git a/src/Infrastructure/BotSharp.Core/Conversations/Services/ConversationService.cs b/src/Infrastructure/BotSharp.Core/Conversations/Services/ConversationService.cs
@@ -103,7 +103,8 @@ public async Task<Conversation> NewConversation(Conversation sess)
 
         db.CreateNewConversation(record);
 
-        var hooks = _services.GetServices<IConversationHook>().ToList();
+        var hooks = _services.GetServices<IConversationHook>();
+
         foreach (var hook in hooks)
         {
             // If user connect agent first time
diff --git a/src/Infrastructure/BotSharp.Core/Evaluations/EvaluationConversationHook.cs b/src/Infrastructure/BotSharp.Core/Evaluations/EvaluationConversationHook.cs
@@ -15,45 +15,45 @@ public EvaluationConversationHook(IExecutionLogger logger, ConversationSetting c
 
     public override Task OnMessageReceived(RoleDialogModel message)
     {
-        if (_conversation != null && _convSettings.EnableExecutionLog)
+        if (Conversation != null && _convSettings.EnableExecutionLog)
         {
-            _logger.Append(_conversation.Id, $"[{DateTime.Now}] {message.Role}: {message.Content}");
+            _logger.Append(Conversation.Id, $"[{DateTime.Now}] {message.Role}: {message.Content}");
         }
         return base.OnMessageReceived(message);
     }
 
     public override Task OnFunctionExecuted(RoleDialogModel message)
     {
-        if (_conversation != null && _convSettings.EnableExecutionLog)
+        if (Conversation != null && _convSettings.EnableExecutionLog)
         {
-            _logger.Append(_conversation.Id, $"[{DateTime.Now}] {message.Role}: {message.FunctionName}({message.FunctionArgs}) => {message.Content}");
+            _logger.Append(Conversation.Id, $"[{DateTime.Now}] {message.Role}: {message.FunctionName}({message.FunctionArgs}) => {message.Content}");
         } 
         return base.OnFunctionExecuted(message);
     }
 
     public override Task OnResponseGenerated(RoleDialogModel message)
     {
-        if (_conversation != null && _convSettings.EnableExecutionLog)
+        if (Conversation != null && _convSettings.EnableExecutionLog)
         {
-            _logger.Append(_conversation.Id, $"[{DateTime.Now}] {message.Role}: {message.Content}");
-        } 
+            _logger.Append(Conversation.Id, $"[{DateTime.Now}] {message.Role}: {message.Content}");
+        }
         return base.OnResponseGenerated(message);
     }
 
     public override Task OnHumanInterventionNeeded(RoleDialogModel message)
     {
-        if (_conversation != null && _convSettings.EnableExecutionLog)
+        if (Conversation != null && _convSettings.EnableExecutionLog)
         {
-            _logger.Append(_conversation.Id, $"[{DateTime.Now}] {AgentRole.Function}: trigger_event({{\"event\": \"{message.FunctionName}\"}})");
+            _logger.Append(Conversation.Id, $"[{DateTime.Now}] {AgentRole.Function}: trigger_event({{\"event\": \"{message.FunctionName}\"}})");
         }
         return base.OnHumanInterventionNeeded(message);
     }
 
     public override Task OnConversationEnding(RoleDialogModel message)
     {
-        if (_conversation != null && _convSettings.EnableExecutionLog)
+        if (Conversation != null && _convSettings.EnableExecutionLog)
         {
-            _logger.Append(_conversation.Id, $"[{DateTime.Now}] {AgentRole.Function}: trigger_event({{\"event\": \"{message.FunctionName}\"}})");
+            _logger.Append(Conversation.Id, $"[{DateTime.Now}] {AgentRole.Function}: trigger_event({{\"event\": \"{message.FunctionName}\"}})");
         }
         return base.OnConversationEnding(message);
     }
diff --git a/src/Infrastructure/BotSharp.Core/Routing/Functions/HumanInterventionNeededFn.cs b/src/Infrastructure/BotSharp.Core/Routing/Functions/HumanInterventionNeededFn.cs
@@ -15,9 +15,9 @@ public HumanInterventionNeededFn(IServiceProvider services)
 
     public async Task<bool> Execute(RoleDialogModel message)
     {
-        var hooks = _services.GetServices<IConversationHook>()
-            .OrderBy(x => x.Priority)
-            .ToList();
+        var hooks = _services
+            .GetRequiredService<ConversationHookProvider>()
+            .HooksOrderByPriority;
 
         foreach (var hook in hooks)
         {
diff --git a/src/Infrastructure/BotSharp.Core/Routing/RoutingService.InvokeFunction.cs b/src/Infrastructure/BotSharp.Core/Routing/RoutingService.InvokeFunction.cs
@@ -18,9 +18,9 @@ public async Task<bool> InvokeFunction(string name, RoleDialogModel message)
         var clonedMessage = RoleDialogModel.From(message);
         clonedMessage.FunctionName = name;
 
-        var hooks = _services.GetServices<IConversationHook>()
-            .OrderBy(x => x.Priority)
-            .ToList();
+        var hooks = _services
+            .GetRequiredService<ConversationHookProvider>()
+            .HooksOrderByPriority;
 
         var progressService = _services.GetService<IConversationProgressService>();
 
diff --git a/src/Infrastructure/BotSharp.Logger/Hooks/RateLimitConversationHook.cs b/src/Infrastructure/BotSharp.Logger/Hooks/RateLimitConversationHook.cs
@@ -34,7 +34,7 @@ public override async Task OnMessageReceived(RoleDialogModel message)
         }
 
         // Check message sending frequency
-        var userSents = _dialogs.Where(x => x.Role == AgentRole.User)
+        var userSents = Dialogs.Where(x => x.Role == AgentRole.User)
             .TakeLast(2).ToList();
 
         if (userSents.Count > 1)
diff --git a/src/Plugins/BotSharp.Plugin.ChatHub/ChatHubPlugin.cs b/src/Plugins/BotSharp.Plugin.ChatHub/ChatHubPlugin.cs
@@ -22,6 +22,7 @@ public void RegisterDI(IServiceCollection services, IConfiguration config)
         services.AddScoped<IConversationHook, ChatHubConversationHook>();
         services.AddScoped<IConversationHook, StreamingLogHook>();
         services.AddScoped<IConversationHook, WelcomeHook>();
+        services.AddScoped<ConversationHookProvider>();
         services.AddScoped<IRoutingHook, StreamingLogHook>();
         services.AddScoped<IContentGeneratingHook, StreamingLogHook>();
         services.AddScoped<ICrontabHook, ChatHubCrontabHook>();
diff --git a/src/Plugins/BotSharp.Plugin.ChatHub/Hooks/ChatHubConversationHook.cs b/src/Plugins/BotSharp.Plugin.ChatHub/Hooks/ChatHubConversationHook.cs
@@ -29,6 +29,7 @@ public ChatHubConversationHook(
         _chatHub = chatHub;
         _user = user;
         _options = options;
+        Priority = -1; // Make sure this hook is the top one.
     }
 
     public override async Task OnConversationInitialized(Conversation conversation)
diff --git a/src/Plugins/BotSharp.Plugin.RoutingSpeeder/RoutingConversationHook.cs b/src/Plugins/BotSharp.Plugin.RoutingSpeeder/RoutingConversationHook.cs
@@ -42,7 +42,7 @@ public override async Task OnMessageReceived(RoleDialogModel message)
 
         // Render by template
         var templateService = _services.GetRequiredService<IResponseTemplateService>();
-        var response = await templateService.RenderIntentResponse(_agent.Id, message);
+        var response = await templateService.RenderIntentResponse(Agent.Id, message);
 
         if (!string.IsNullOrEmpty(response))
         {
@@ -54,7 +54,7 @@ public override async Task OnMessageReceived(RoleDialogModel message)
     public override async Task OnResponseGenerated(RoleDialogModel message)
     {
         var routerSettings = _services.GetRequiredService<RoutingSettings>();
-        bool saveFlag = _agent.Type != AgentType.Routing;
+        bool saveFlag = Agent.Type != AgentType.Routing;
 
         if (saveFlag)
         {
@@ -63,7 +63,7 @@ public override async Task OnResponseGenerated(RoleDialogModel message)
             var rootDataPath = agentService.GetDataDir();
 
             string rawDataDir = Path.Combine(rootDataPath, "raw_data", $"agent.{message.CurrentAgentId}.txt");
-            var lastThreeDialogs = _dialogs.Where(x => x.Role == AgentRole.User || x.Role == AgentRole.Assistant)
+            var lastThreeDialogs = Dialogs.Where(x => x.Role == AgentRole.User || x.Role == AgentRole.Assistant)
                 .Select(x => x.Content.Replace('\r', ' ').Replace('\n', ' '))
                 .TakeLast(3)
                 .ToArray();
diff --git a/tests/UnitTest/MainTest.cs b/tests/UnitTest/MainTest.cs
@@ -0,0 +1,63 @@
+using Microsoft.Extensions.DependencyInjection;
+using BotSharp.Abstraction.Conversations;
+
+namespace UnitTest
+{    
+    [TestClass]
+    public class MainTest
+    {
+        [TestMethod]
+        public void TestConversationHookProvider()
+        {
+            var services = new ServiceCollection();
+
+            services.AddSingleton<IConversationHook, TestHookC>();
+            services.AddSingleton<IConversationHook, TestHookA>();
+            services.AddSingleton<IConversationHook, TestHookB>();
+            
+            services.AddSingleton<ConversationHookProvider>();
+
+            var serviceProvider = services.BuildServiceProvider();
+            var conversationHookProvider = serviceProvider.GetService<ConversationHookProvider>();
+
+            Assert.AreEqual(3, conversationHookProvider.Hooks.Count());
+
+            var prevHook = default(IConversationHook);
+
+            // Assert priority
+            foreach (var hook in conversationHookProvider.HooksOrderByPriority)
+            {
+                if (prevHook != null)
+                {
+                    Assert.IsTrue(prevHook.Priority < hook.Priority);
+                }
+
+                prevHook = hook;
+            }
+        }
+
+        class TestHookA : ConversationHookBase
+        {
+            public TestHookA()
+            {
+                Priority = 1;
+            }
+        }
+
+        class TestHookB : ConversationHookBase
+        {
+            public TestHookB()
+            {
+                Priority = 2;
+            }
+        }
+
+        class TestHookC : ConversationHookBase
+        {
+            public TestHookC()
+            {
+                Priority = 3;
+            }
+        }
+    }
+}
diff --git a/tests/UnitTest/UnitTest.csproj b/tests/UnitTest/UnitTest.csproj
@@ -13,10 +13,14 @@
     <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.8.0" />
     <PackageReference Include="MSTest.TestAdapter" Version="3.1.1" />
     <PackageReference Include="MSTest.TestFramework" Version="3.1.1" />
+    <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="8.0.2" />
+    <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="8.0.1" />
     <PackageReference Include="coverlet.collector" Version="6.0.0">
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
     </PackageReference>
   </ItemGroup>
-
+  <ItemGroup>
+    <ProjectReference Include="..\..\src\Infrastructure\BotSharp.Abstraction\BotSharp.Abstraction.csproj" />
+  </ItemGroup>
 </Project>
diff --git a/tests/UnitTest/UnitTest1.cs b/tests/UnitTest/UnitTest1.cs

Original file line number	Diff line number	Diff line change
`@@ -2,27 +2,23 @@ namespace BotSharp.Abstraction.Conversations;`
`2`	`2`
`3`	`3`	`public abstract class ConversationHookBase : IConversationHook`
`4`	`4`	`{`
`5`		`- protected Agent _agent;`
`6`		`- public Agent Agent => _agent;`
	`5`	`+ public Agent Agent { get; private set; }`
`7`	`6`
`8`		`- protected Conversation _conversation;`
`9`		`- public Conversation Conversation => _conversation;`
	`7`	`+ public Conversation Conversation { get; private set; }`
`10`	`8`
`11`		`- protected List<RoleDialogModel> _dialogs;`
`12`		`- public List<RoleDialogModel> Dialogs => _dialogs;`
	`9`	`+ public List<RoleDialogModel> Dialogs { get; private set; }`
`13`	`10`
`14`		`- protected int _priority = 0;`
`15`		`- public int Priority => _priority;`
	`11`	`+ public int Priority { get; protected set; } = 0;`
`16`	`12`
`17`	`13`	`public IConversationHook SetAgent(Agent agent)`
`18`	`14`	`{`
`19`		`- _agent = agent;`
	`15`	`+ Agent = agent;`
`20`	`16`	`return this;`
`21`	`17`	`}`
`22`	`18`
`23`	`19`	`public IConversationHook SetConversation(Conversation conversation)`
`24`	`20`	`{`
`25`		`- _conversation = conversation;`
	`21`	`+ Conversation = conversation;`
`26`	`22`	`return this;`
`27`	`23`	`}`
`28`	`24`
`@@ -37,7 +33,7 @@ public virtual Task OnDialogRecordLoaded(RoleDialogModel dialog)`
`37`	`33`
`38`	`34`	`public virtual Task OnDialogsLoaded(List<RoleDialogModel> dialogs)`
`39`	`35`	`{`
`40`		`- _dialogs = dialogs;`
	`36`	`+ Dialogs = dialogs;`
`41`	`37`	`return Task.CompletedTask;`
`42`	`38`	`}`
`43`	`39`
Original file line number	Diff line number	Diff line change
`@@ -9,7 +9,7 @@ public async Task<bool> TruncateConversation(string conversationId, string messa`
`9`	`9`	`var deleteMessageIds = db.TruncateConversation(conversationId, messageId, cleanLog: true);`
`10`	`10`	`fileStorage.DeleteMessageFiles(conversationId, deleteMessageIds, messageId, newMessageId);`
`11`	`11`
`12`		`- var hooks = _services.GetServices<IConversationHook>().ToList();`
	`12`	`+ var hooks = _services.GetServices<IConversationHook>();`
`13`	`13`	`foreach (var hook in hooks)`
`14`	`14`	`{`
`15`	`15`	`await hook.OnMessageDeleted(conversationId, messageId);`
Original file line number	Diff line number	Diff line change
`@@ -103,7 +103,8 @@ public async Task<Conversation> NewConversation(Conversation sess)`
`103`	`103`
`104`	`104`	`db.CreateNewConversation(record);`
`105`	`105`
`106`		`- var hooks = _services.GetServices<IConversationHook>().ToList();`
	`106`	`+ var hooks = _services.GetServices<IConversationHook>();`
	`107`	`+`
`107`	`108`	`foreach (var hook in hooks)`
`108`	`109`	`{`
`109`	`110`	`// If user connect agent first time`
Original file line number	Diff line number	Diff line change
`@@ -15,45 +15,45 @@ public EvaluationConversationHook(IExecutionLogger logger, ConversationSetting c`
`15`	`15`
`16`	`16`	`public override Task OnMessageReceived(RoleDialogModel message)`
`17`	`17`	`{`
`18`		`- if (_conversation != null && _convSettings.EnableExecutionLog)`
	`18`	`+ if (Conversation != null && _convSettings.EnableExecutionLog)`
`19`	`19`	`{`
`20`		`- _logger.Append(_conversation.Id, $"[{DateTime.Now}] {message.Role}: {message.Content}");`
	`20`	`+ _logger.Append(Conversation.Id, $"[{DateTime.Now}] {message.Role}: {message.Content}");`
`21`	`21`	`}`
`22`	`22`	`return base.OnMessageReceived(message);`
`23`	`23`	`}`
`24`	`24`
`25`	`25`	`public override Task OnFunctionExecuted(RoleDialogModel message)`
`26`	`26`	`{`
`27`		`- if (_conversation != null && _convSettings.EnableExecutionLog)`
	`27`	`+ if (Conversation != null && _convSettings.EnableExecutionLog)`
`28`	`28`	`{`
`29`		`- _logger.Append(_conversation.Id, $"[{DateTime.Now}] {message.Role}: {message.FunctionName}({message.FunctionArgs}) => {message.Content}");`
	`29`	`+ _logger.Append(Conversation.Id, $"[{DateTime.Now}] {message.Role}: {message.FunctionName}({message.FunctionArgs}) => {message.Content}");`
`30`	`30`	`}`
`31`	`31`	`return base.OnFunctionExecuted(message);`
`32`	`32`	`}`
`33`	`33`
`34`	`34`	`public override Task OnResponseGenerated(RoleDialogModel message)`
`35`	`35`	`{`
`36`		`- if (_conversation != null && _convSettings.EnableExecutionLog)`
	`36`	`+ if (Conversation != null && _convSettings.EnableExecutionLog)`
`37`	`37`	`{`
`38`		`- _logger.Append(_conversation.Id, $"[{DateTime.Now}] {message.Role}: {message.Content}");`
`39`		`- }`
	`38`	`+ _logger.Append(Conversation.Id, $"[{DateTime.Now}] {message.Role}: {message.Content}");`
	`39`	`+ }`
`40`	`40`	`return base.OnResponseGenerated(message);`
`41`	`41`	`}`
`42`	`42`
`43`	`43`	`public override Task OnHumanInterventionNeeded(RoleDialogModel message)`
`44`	`44`	`{`
`45`		`- if (_conversation != null && _convSettings.EnableExecutionLog)`
	`45`	`+ if (Conversation != null && _convSettings.EnableExecutionLog)`
`46`	`46`	`{`
`47`		`- _logger.Append(_conversation.Id, $"[{DateTime.Now}] {AgentRole.Function}: trigger_event({{\"event\": \"{message.FunctionName}\"}})");`
	`47`	`+ _logger.Append(Conversation.Id, $"[{DateTime.Now}] {AgentRole.Function}: trigger_event({{\"event\": \"{message.FunctionName}\"}})");`
`48`	`48`	`}`
`49`	`49`	`return base.OnHumanInterventionNeeded(message);`
`50`	`50`	`}`
`51`	`51`
`52`	`52`	`public override Task OnConversationEnding(RoleDialogModel message)`
`53`	`53`	`{`
`54`		`- if (_conversation != null && _convSettings.EnableExecutionLog)`
	`54`	`+ if (Conversation != null && _convSettings.EnableExecutionLog)`
`55`	`55`	`{`
`56`		`- _logger.Append(_conversation.Id, $"[{DateTime.Now}] {AgentRole.Function}: trigger_event({{\"event\": \"{message.FunctionName}\"}})");`
	`56`	`+ _logger.Append(Conversation.Id, $"[{DateTime.Now}] {AgentRole.Function}: trigger_event({{\"event\": \"{message.FunctionName}\"}})");`
`57`	`57`	`}`
`58`	`58`	`return base.OnConversationEnding(message);`
`59`	`59`	`}`
Original file line number	Diff line number	Diff line change
`@@ -15,9 +15,9 @@ public HumanInterventionNeededFn(IServiceProvider services)`
`15`	`15`
`16`	`16`	`public async Task<bool> Execute(RoleDialogModel message)`
`17`	`17`	`{`
`18`		`- var hooks = _services.GetServices<IConversationHook>()`
`19`		`- .OrderBy(x => x.Priority)`
`20`		`- .ToList();`
	`18`	`+ var hooks = _services`
	`19`	`+ .GetRequiredService<ConversationHookProvider>()`
	`20`	`+ .HooksOrderByPriority;`
`21`	`21`
`22`	`22`	`foreach (var hook in hooks)`
`23`	`23`	`{`
Original file line number	Diff line number	Diff line change
`@@ -34,7 +34,7 @@ public override async Task OnMessageReceived(RoleDialogModel message)`
`34`	`34`	`}`
`35`	`35`
`36`	`36`	`// Check message sending frequency`
`37`		`- var userSents = _dialogs.Where(x => x.Role == AgentRole.User)`
	`37`	`+ var userSents = Dialogs.Where(x => x.Role == AgentRole.User)`
`38`	`38`	`.TakeLast(2).ToList();`
`39`	`39`
`40`	`40`	`if (userSents.Count > 1)`