Merge pull request #549 from hchen2020/master

knowledge learner

Author: Oceania2018

src/Infrastructure/BotSharp.Abstraction/Agents/Enums/BuiltInAgentId.cs

@@ -2,9 +2,33 @@ namespace BotSharp.Abstraction.Agents.Enums;
 
 public class BuiltInAgentId
 {
+    /// <summary>
+    /// A routing agent can be used as a base router.
+    /// </summary>
     public const string AIAssistant = "01fcc3e5-9af7-49e6-ad7a-a760bd12dc4a";
+
+    /// <summary>
+    /// A demo agent used for open domain chatting
+    /// </summary>
     public const string Chatbot = "01e2fc5c-2c89-4ec7-8470-7688608b496c";
+
+    /// <summary>
+    /// Human customer service
+    /// </summary>
     public const string HumanSupport = "01dcc3e5-0af7-49e6-ad7a-a760bd12dc4b";
+
+    /// <summary>
+    /// Used as a container to host the shared tools/ utilities built in different plugins.
+    /// </summary>
     public const string UtilityAssistant = "6745151e-6d46-4a02-8de4-1c4f21c7da95";
+
+    /// <summary>
+    /// Used when router can't route to any existing task agent
+    /// </summary>
     public const string Fallback = "01fcc3e5-0af7-49e6-ad7a-a760bd12dc4d";
+
+    /// <summary>
+    /// Used by knowledgebase plugin to acquire domain knowledge
+    /// </summary>
+    public const string Learner = "01acc3e5-0af7-49e6-ad7a-a760bd12dc40";
 }

src/Infrastructure/BotSharp.Abstraction/Infrastructures/Enums/StateConst.cs

@@ -7,6 +7,7 @@ public class StateConst
     public const string NEXT_ACTION_AGENT = "next_action_agent";
     public const string NEXT_ACTION_REASON = "next_action_reason";
     public const string USER_GOAL_AGENT = "user_goal_agent";
+    public const string AGENT_REDIRECTION_REASON = "agent_redirection_reason";
 
     public const string LANGUAGE = "language";
 }

src/Infrastructure/BotSharp.Abstraction/Knowledges/Models/ExtractedKnowledge.cs

@@ -0,0 +1,10 @@
+namespace BotSharp.Abstraction.Knowledges.Models;
+
+public class ExtractedKnowledge
+{
+    [JsonPropertyName("question")]
+    public string Question { get; set; } = string.Empty;
+
+    [JsonPropertyName("answer")]
+    public string Answer { get; set; } = string.Empty;
+}

src/Infrastructure/BotSharp.Abstraction/VectorStorage/IVectorDb.cs

@@ -4,6 +4,6 @@ public interface IVectorDb
 {
     Task<List<string>> GetCollections();
     Task CreateCollection(string collectionName, int dim);
-    Task Upsert(string collectionName, string id, float[] vector, string text, Dictionary<string, string>? payload = null);
-    Task<List<string>> Search(string collectionName, float[] vector, int limit = 5);
+    Task<bool> Upsert(string collectionName, string id, float[] vector, string text, Dictionary<string, string>? payload = null);
+    Task<List<string>> Search(string collectionName, float[] vector, string returnFieldName, int limit = 5, float confidence = 0.5f);
 }

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

@@ -19,11 +19,7 @@ public async Task<bool> SendMessage(string agentId,
         Agent agent = await agentService.LoadAgent(agentId);
 
         var content = $"Received [{agent.Name}] {message.Role}: {message.Content}";
-#if DEBUG
-        Console.WriteLine(content);
-#else
         _logger.LogInformation(content);
-#endif
 
         message.CurrentAgentId = agent.Id;
         if (string.IsNullOrEmpty(message.SenderId))

src/Infrastructure/BotSharp.Core/Routing/Functions/RouteToAgentFn.cs

@@ -89,6 +89,7 @@ public async Task<bool> Execute(RoleDialogModel message)
                 // Stack redirection agent
                 _context.Push(agentId, reason: $"REDIRECTION {reason}");
                 message.Content = reason;
+                states.SetState(StateConst.AGENT_REDIRECTION_REASON, reason, isNeedVersion: false);
             }
         }
 

src/Infrastructure/BotSharp.Core/data/agents/01fcc3e5-0af7-49e6-ad7a-a760bd12dc4d/instruction.liquid

@@ -1 +1,4 @@
-You are a smart AI Assistant.
+You are a smart AI Assistant.
+{% if agent_redirection_reason %}
+You've been reached out because: {{ agent_redirection_reason }}
+{% endif %}

src/Infrastructure/BotSharp.Core/data/agents/01fcc3e5-9af7-49e6-ad7a-a760bd12dc4a/templates/planner_prompt.hf.liquid

@@ -1 +1 @@
-Break down the user’s most recent needs and figure out the instruction of next step.
+Break down the user’s most recent needs and figure out the instruction of next step without explanation.

src/Plugins/BotSharp.Plugin.AnthropicAI/BotSharp.Plugin.AnthropicAI.csproj

@@ -11,7 +11,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Anthropic.SDK" Version="3.2.1" />
+    <PackageReference Include="Anthropic.SDK" Version="3.2.3" />
   </ItemGroup>
 
   <ItemGroup>

src/Plugins/BotSharp.Plugin.AnthropicAI/Providers/ChatCompletionProvider.cs

@@ -1,4 +1,5 @@
 using Anthropic.SDK.Common;
+using BotSharp.Abstraction.Conversations;
 using BotSharp.Abstraction.MLTasks.Settings;
 using System.Text.Json;
 using System.Text.Json.Nodes;
@@ -160,13 +161,17 @@ public Task<bool> GetChatCompletionsStreamingAsync(Agent agent, List<RoleDialogM
             }
         }
 
+        var state = _services.GetRequiredService<IConversationStateService>();
+        var temperature = decimal.Parse(state.GetState("temperature", "0.0"));
+        var maxToken = int.Parse(state.GetState("max_tokens", "512"));
+
         var parameters = new MessageParameters()
         {
             Messages = messages,
-            MaxTokens = 256,
-            Model = settings.Version, // AnthropicModels.Claude3Haiku
+            MaxTokens = maxToken,
+            Model = settings.Name,
             Stream = false,
-            Temperature = 0m,
+            Temperature = temperature,
             SystemMessage = instruction,
             Tools = new List<Function>() { }
         };