add comments

src/Infrastructure/BotSharp.Abstraction/Agents/AgentHookBase.cs

@@ -71,7 +71,14 @@ public virtual void OnAgentUtilityLoaded(Agent agent)
 
         var (functions, templates) = GetUtilityContent(agent);
 
-        agent.Functions.AddRange(functions);
+        foreach (var fn in functions)
+        {
+            if (!agent.Functions.Any(x => x.Name.Equals(fn.Name, StringComparison.OrdinalIgnoreCase)))
+            {
+                agent.Functions.Add(fn);
+            }
+        }
+
         foreach (var prompt in templates)
         {
             agent.Instruction += $"\r\n\r\n{prompt}\r\n\r\n";

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

@@ -51,4 +51,14 @@ public class BuiltInAgentId
     /// Evaluate prompt and conversation
     /// </summary>
     public const string Evaluator = "dfd9b46d-d00c-40af-8a75-3fbdc2b89869";
+
+    /// <summary>
+    /// Translates user-defined natural language rules into programmatic code
+    /// </summary>
+    public const string RuleEncoder = "6acfb93c-3412-402e-9ba5-c5d3cd8f0161";
+
+    /// <summary>
+    /// Schedule job
+    /// </summary>
+    public const string Crontab = "c2o139da-a62a-4355-8605-fdf0ffaca58e";
 }

src/Infrastructure/BotSharp.Abstraction/Browsing/Enums/BroswerActionEnum.cs

@@ -7,4 +7,5 @@ public enum BroswerActionEnum
     Typing = 3,
     Hover = 4,
     Scroll = 5,
+    DragAndDrop = 6
 }

src/Infrastructure/BotSharp.Abstraction/Browsing/Models/ElementPosition.cs

@@ -5,4 +5,9 @@ public class ElementPosition
     public float X { get; set; } = default!;
 
     public float Y { get; set; } = default!;
+
+    public override string ToString()
+    {
+        return $"[{X}, {Y}]";
+    }
 }

src/Infrastructure/BotSharp.Abstraction/Conversations/Enums/ConversationChannel.cs

@@ -7,4 +7,5 @@ public class ConversationChannel
     public const string Phone = "phone";
     public const string Messenger = "messenger";
     public const string Email = "email";
+    public const string Cron = "cron";
 }

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

@@ -0,0 +1,8 @@
+namespace BotSharp.Abstraction.Infrastructures.Enums;
+
+public enum EventPriority
+{
+    Low = 1,
+    Medium = 2,
+    High = 3
+}

src/Infrastructure/BotSharp.Abstraction/Infrastructures/Events/IEventPublisher.cs

@@ -10,7 +10,11 @@ public interface IEventPublisher
     /// <returns></returns>
     Task BroadcastAsync(string channel, string message);
 
-    Task PublishAsync(string channel, string message);
+    Task<string?> PublishAsync(string channel, string message, EventPriority? priority = null);
 
     Task ReDispatchAsync(string channel, int count = 10, string order = "asc");
+
+    Task ReDispatchPendingAsync(string channel, string group, int count = 10);
+
+    Task RemoveAsync(string channel, int count = 10);
 }

src/Infrastructure/BotSharp.Abstraction/Infrastructures/Events/IEventSubscriber.cs

@@ -1,8 +1,12 @@
+using System.Threading;
+
 namespace BotSharp.Abstraction.Infrastructures.Events;
 
 public interface IEventSubscriber
 {
     Task SubscribeAsync(string channel, Func<string, string, Task> received);
 
-    Task SubscribeAsync(string channel, string group, Func<string, string, Task> received);
+    Task SubscribeAsync(string channel, string group, int? port, bool priorityEnabled, 
+        Func<string, string, Task> received,
+        CancellationToken? stoppingToken = null);
 }

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

@@ -0,0 +1,7 @@
+namespace BotSharp.Abstraction.Infrastructures;
+
+public interface IDistributedLocker
+{
+    bool Lock(string resource, Action action, int timeout = 30);
+    Task<bool> LockAsync(string resource, Func<Task> action, int timeout = 30);
+}

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

@@ -50,7 +50,9 @@ public override void OnSuccess(MethodContext context)
         }
 
         var httpContext = Services.GetRequiredService<IHttpContextAccessor>();
-        if (httpContext.HttpContext.Response.Headers["Cache-Control"].ToString().Contains("no-store"))
+        if (httpContext != null &&
+            httpContext.HttpContext != null &&
+            httpContext.HttpContext.Response.Headers["Cache-Control"].ToString().Contains("no-store"))
         {
             return;
         }

src/Infrastructure/BotSharp.Abstraction/Planning/IPlanningHook.cs

@@ -5,6 +5,9 @@ public interface IPlanningHook
     Task<string> GetSummaryAdditionalRequirements(string planner, RoleDialogModel message)
         => Task.FromResult(string.Empty);
 
+    Task OnSourceCodeGenerated(string planner, RoleDialogModel msg, string language)
+        => Task.CompletedTask;
+
     Task OnPlanningCompleted(string planner, RoleDialogModel msg)
         => Task.CompletedTask;
 }

src/Infrastructure/BotSharp.Abstraction/Repositories/BotSharpDatabaseSettings.cs

@@ -2,18 +2,19 @@ namespace BotSharp.Abstraction.Repositories;
 
 public class BotSharpDatabaseSettings : DatabaseBasicSettings
 {
-    public string[] Assemblies { get; set; }
-    public string FileRepository { get; set; }
-    public string BotSharpMongoDb { get; set; }
-    public string TablePrefix { get; set; }
-    public DbConnectionSetting BotSharp { get; set; }
-    public string Redis { get; set; }
+    public string[] Assemblies { get; set; } = [];
+    public string FileRepository { get; set; } = string.Empty;
+    public string BotSharpMongoDb { get; set; } = string.Empty;
+    public string TablePrefix { get; set; } = string.Empty;
+    public DbConnectionSetting BotSharp { get; set; } = new();
+    public string Redis { get; set; } = string.Empty;
+    public bool EnableReplica { get; set; } = true;
 }
 
 public class DatabaseBasicSettings
 {
-    public string Default { get; set; }
-    public DbConnectionSetting DefaultConnection { get; set; }
+    public string Default { get; set; } = string.Empty;
+    public DbConnectionSetting DefaultConnection { get; set; } = new();
     public bool EnableSqlLog { get; set; }
     public bool EnableSensitiveDataLogging { get; set; }
     public bool EnableRetryOnFailure { get; set; }
@@ -23,9 +24,11 @@ public class DbConnectionSetting
 {
     public string Master { get; set; }
     public string[] Slavers { get; set; }
+    public int ConnectionTimeout { get; set; } = 30;
+    public int ExecutionTimeout { get; set; } = 30;
 
     public DbConnectionSetting()
     {
-        Slavers = new string[0];
+        Slavers = [];
     }
 }

src/Infrastructure/BotSharp.Abstraction/Repositories/Filters/RoleFilter.cs

@@ -15,4 +15,9 @@ public static RoleFilter Empty()
     {
         return new RoleFilter();
     }
+
+    public bool IsInit()
+    {
+        return Names.IsNullOrEmpty();
+    }
 }

src/Infrastructure/BotSharp.Abstraction/Repositories/IBotSharpRepository.cs

@@ -5,6 +5,7 @@
 using BotSharp.Abstraction.Shared;
 using BotSharp.Abstraction.Tasks.Models;
 using BotSharp.Abstraction.Translation.Models;
+using BotSharp.Abstraction.Users.Enums;
 using BotSharp.Abstraction.Users.Models;
 using BotSharp.Abstraction.VectorStorage.Models;
 
@@ -26,7 +27,7 @@ public interface IBotSharpRepository : IHaveServiceProvider
 
     #region User
     User? GetUserByEmail(string email) => throw new NotImplementedException();
-    User? GetUserByPhone(string phone, string role = null, string regionCode = "CN") => throw new NotImplementedException();
+    User? GetUserByPhone(string phone, string type = UserType.Client, string regionCode = "CN") => throw new NotImplementedException();
     User? GetAffiliateUserByPhone(string phone) => throw new NotImplementedException();
     User? GetUserById(string id) => throw new NotImplementedException();
     List<User> GetUserByIds(List<string> ids) => throw new NotImplementedException();

src/Infrastructure/BotSharp.Abstraction/Users/Models/User.cs

@@ -23,6 +23,7 @@ public class User
     public bool Verified { get; set; }
     public string RegionCode { get; set; } = "CN";
     public string? AffiliateId { get; set; }
+    public string? ReferralCode { get; set; }
     public string? EmployeeId { get; set; }
     public bool IsDisabled { get; set; }
     public IEnumerable<string> Permissions { get; set; } = [];

src/Infrastructure/BotSharp.Abstraction/Utilities/MathExt.cs

@@ -0,0 +1,14 @@
+namespace BotSharp.Abstraction.Utilities;
+
+public static class MathExt
+{
+    public static int Max(int a, int b, int c)
+    {
+        return Math.Max(Math.Max(a, b), c);
+    }
+
+    public static long Max(long a, long b, long c)
+    {
+        return Math.Max(Math.Max(a, b), c);
+    }
+}

src/Infrastructure/BotSharp.Abstraction/Utilities/Pagination.cs

@@ -1,7 +1,9 @@
 using BotSharp.Abstraction.Infrastructures;
+using System.Diagnostics;
 
 namespace BotSharp.Abstraction.Utilities;
 
+[DebuggerStepThrough]
 public class Pagination : ICacheKey
 {
     private int _page;

src/Infrastructure/BotSharp.Core.Crontab/Abstraction/ICrontabHook.cs

@@ -0,0 +1,8 @@
+using BotSharp.Core.Crontab.Models;
+
+namespace BotSharp.Core.Crontab.Abstraction;
+
+public interface ICrontabHook
+{
+    Task OnCronTriggered(CrontabItem item);
+}

src/Infrastructure/BotSharp.Core.Crontab/Abstraction/ICrontabService.cs

@@ -0,0 +1,9 @@
+using BotSharp.Core.Crontab.Models;
+
+namespace BotSharp.Core.Crontab.Abstraction;
+
+public interface ICrontabService
+{
+    Task<List<CrontabItem>> GetCrontable();
+    Task ScheduledTimeArrived(CrontabItem item);
+}

src/Infrastructure/BotSharp.Core.Crontab/BotSharp.Core.Crontab.csproj

@@ -0,0 +1,28 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <None Remove="data\agents\c2o139da-a62a-4355-8605-fdf0ffaca58e\agent.json" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <Content Include="data\agents\c2o139da-a62a-4355-8605-fdf0ffaca58e\agent.json">
+      <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
+    </Content>
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\BotSharp.Abstraction\BotSharp.Abstraction.csproj" />
+    <ProjectReference Include="..\BotSharp.Core\BotSharp.Core.csproj" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <PackageReference Include="NCrontab" Version="3.3.3" />
+  </ItemGroup>
+
+</Project>

src/Infrastructure/BotSharp.Core.Crontab/CrontabPlugin.cs

@@ -0,0 +1,40 @@
+/*****************************************************************************
+  Copyright 2024 Written by Haiping Chen. All Rights Reserved.
+
+  Licensed under the Apache License, Version 2.0 (the "License");
+  you may not use this file except in compliance with the License.
+  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+  Unless required by applicable law or agreed to in writing, software
+  distributed under the License is distributed on an "AS IS" BASIS,
+  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  See the License for the specific language governing permissions and
+  limitations under the License.
+******************************************************************************/
+
+namespace BotSharp.Core.Crontab;
+
+/// <summary>
+///  Crontab plugin is a time-based job scheduler in agent framework. 
+///  The cron system is used for automating repetitive tasks, such as trigger AI Agent to do specific task periodically.
+/// </summary>
+public class CrontabPlugin : IBotSharpPlugin
+{
+    public string Id => "3155c15e-28d3-43f7-8ead-fc43324ec21a";
+    public string Name => "BotSharp Crontab";
+    public string Description => "Crontab plugin is a time-based job scheduler in agent framework. The cron system is used to trigger AI Agent to do specific task periodically.";
+    public string IconUrl => "https://icon-library.com/images/stop-watch-icon/stop-watch-icon-10.jpg";
+
+    public string[] AgentIds =
+    [
+        BuiltInAgentId.Crontab
+    ];
+
+    public void RegisterDI(IServiceCollection services, IConfiguration config)
+    {
+        services.AddScoped<ICrontabService, CrontabService>();
+        services.AddHostedService<CrontabWatcher>();
+    }
+}

src/Infrastructure/BotSharp.Core.Crontab/Models/CrontabItem.cs

@@ -0,0 +1,14 @@
+namespace BotSharp.Core.Crontab.Models;
+
+public class CrontabItem
+{
+    public string UserId { get; set; } = null!;
+    public string AgentId { get; set; } = null!;
+    public string Topic { get; set; } = null!;
+    public string Cron { get; set; } = null!;
+
+    public override string ToString()
+    {
+        return $"AgentId: {AgentId}, UserId: {UserId}, Topic: {Topic}";
+    }
+}