Merge pull request #1034 from iceljc/test/realtime-chat

Test/realtime chat

Author: Oceania2018

Directory.Packages.props

@@ -21,6 +21,7 @@
     <PackageVersion Include="Newtonsoft.Json" Version="13.0.3" />
     <PackageVersion Include="SharpHook" Version="5.3.9" />
     <PackageVersion Include="SixLabors.ImageSharp" Version="3.1.7" />
+    <PackageVersion Include="System.ClientModel" Version="1.3.0" />
     <PackageVersion Include="System.ComponentModel.Annotations" Version="5.0.0" />
     <PackageVersion Include="System.IdentityModel.Tokens.Jwt" Version="8.0.0" />
     <PackageVersion Include="System.Memory.Data" Version="8.0.0" />

src/Infrastructure/BotSharp.Abstraction/Agents/Models/Agent.cs

@@ -82,7 +82,7 @@ public class Agent
     public PluginDef Plugin {  get; set; }
 
     [JsonIgnore]
-    public bool Installed => Plugin.Enabled;
+    public bool Installed => Plugin?.Enabled == true;
 
     /// <summary>
     /// Default is True, user will enable this by installing appropriate plugin.
@@ -168,6 +168,7 @@ public static Agent Clone(Agent agent)
             Functions = agent.Functions,
             Responses = agent.Responses,
             Samples = agent.Samples,
+            Templates = agent.Templates,
             Utilities = agent.Utilities,
             McpTools = agent.McpTools,
             Knowledges = agent.Knowledges,

src/Infrastructure/BotSharp.Abstraction/Agents/Models/AgentTemplate.cs

@@ -7,7 +7,6 @@ public class AgentTemplate
 
     public AgentTemplate()
     {
-        
     }
 
     public AgentTemplate(string name, string content)

src/Infrastructure/BotSharp.Abstraction/Knowledges/IKnowledgeService.cs

@@ -10,6 +10,7 @@ public interface IKnowledgeService
     Task<bool> CreateVectorCollection(string collectionName, string collectionType, int dimension, string provider, string model);
     Task<bool> DeleteVectorCollection(string collectionName);
     Task<IEnumerable<VectorCollectionConfig>> GetVectorCollections(string? type = null);
+    Task<VectorCollectionDetails?> GetVectorCollectionDetails(string collectionName);
     Task<IEnumerable<VectorSearchResult>> SearchVectorKnowledge(string query, string collectionName, VectorSearchOptions options);
     Task<StringIdPagedItems<VectorSearchResult>> GetPagedVectorCollectionData(string collectionName, VectorFilter filter);
     Task<bool> DeleteVectorCollectionData(string collectionName, string id);

src/Infrastructure/BotSharp.Abstraction/Loggers/IContentGeneratingHook.cs

@@ -47,5 +47,5 @@ public interface IContentGeneratingHook
     /// <param name="instruction"></param>
     /// <param name="functions"></param>
     /// <returns></returns>
-    Task OnSessionUpdated(Agent agent, string instruction, FunctionDef[] functions) => Task.CompletedTask;
+    Task OnSessionUpdated(Agent agent, string instruction, FunctionDef[] functions, bool isInit = false) => Task.CompletedTask;
 }

src/Infrastructure/BotSharp.Abstraction/MLTasks/IRealTimeCompletion.cs

@@ -8,7 +8,8 @@ public interface IRealTimeCompletion
     string Model { get; }
     void SetModelName(string model);
 
-    Task Connect(RealtimeHubConnection conn,
+    Task Connect(
+        RealtimeHubConnection conn,
         Action onModelReady,
         Action<string, string> onModelAudioDeltaReceived,
         Action onModelAudioResponseDone,
@@ -23,7 +24,7 @@ Task Connect(RealtimeHubConnection conn,
     Task SendEventToModel(object message);
     Task Disconnect();
 
-    Task<string> UpdateSession(RealtimeHubConnection conn);
+    Task<string> UpdateSession(RealtimeHubConnection conn, bool isInit = false);
     Task InsertConversationItem(RoleDialogModel message);
     Task RemoveConversationItem(string itemId);
     Task TriggerModelInference(string? instructions = null);

src/Infrastructure/BotSharp.Abstraction/Templating/Constants/TemplateRenderConstant.cs

@@ -0,0 +1,6 @@
+namespace BotSharp.Abstraction.Templating.Constants;
+
+public static class TemplateRenderConstant
+{
+    public const string RENDER_AGENT = "render_agent";
+}

src/Infrastructure/BotSharp.Abstraction/Templating/ITemplateRender.cs

@@ -3,5 +3,5 @@ namespace BotSharp.Abstraction.Templating;
 public interface ITemplateRender
 {
     string Render(string template, Dictionary<string, object> dict);
-    void Register(Type type);
+    void RegisterType(Type type);
 }

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

@@ -10,6 +10,8 @@ Task<bool> DoesCollectionExist(string collectionName)
         => throw new NotImplementedException();
     Task<IEnumerable<string>> GetCollections()
         => throw new NotImplementedException();
+    Task<VectorCollectionDetails?> GetCollectionDetails(string collectionName)
+        => throw new NotImplementedException();
     Task<StringIdPagedItems<VectorCollectionData>> GetPagedCollectionData(string collectionName, VectorFilter filter)
         => throw new NotImplementedException();
     Task<IEnumerable<VectorCollectionData>> GetCollectionData(string collectionName, IEnumerable<Guid> ids,

src/Infrastructure/BotSharp.Abstraction/VectorStorage/Models/VectorCollectionDetails.cs

@@ -0,0 +1,51 @@
+namespace BotSharp.Abstraction.VectorStorage.Models;
+
+public class VectorCollectionDetails
+{
+    [JsonPropertyName("status")]
+    public string Status { get; set; }
+
+    [JsonPropertyName("optimizer_status")]
+    public string OptimizerStatus { get; set; }
+
+    [JsonPropertyName("segments_count")]
+    public ulong SegmentsCount { get; set; }
+
+    [JsonPropertyName("vectors_count")]
+    public ulong VectorsCount { get; set; }
+
+    [JsonPropertyName("indexed_vectors_count")]
+    public ulong IndexedVectorsCount { get; set; }
+
+    [JsonPropertyName("points_count")]
+    public ulong PointsCount { get; set; }
+
+    [JsonPropertyName("inner_config")]
+    public VectorCollectionDetailConfig? InnerConfig { get; set; }
+
+    [JsonPropertyName("basic_info")]
+    public VectorCollectionConfig? BasicInfo { get; set; }
+}
+
+public class VectorCollectionDetailConfig
+{
+    public VectorCollectionDetailConfigParam? Param { get; set; }
+}
+
+public class VectorCollectionDetailConfigParam
+{
+    [JsonPropertyName("shard_number")]
+    public uint? ShardNumber { get; set; }
+
+    [JsonPropertyName("sharding_method")]
+    public string? ShardingMethod { get; set; }
+
+    [JsonPropertyName("replication_factor")]
+    public uint? ReplicationFactor { get; set; }
+
+    [JsonPropertyName("write_consistency_factor")]
+    public uint? WriteConsistencyFactor { get; set; }
+
+    [JsonPropertyName("read_fan_out_factor")]
+    public uint? ReadFanOutFactor { get; set; }
+}