feat: add crontab-based conversation cleanup jobs

Author: yileicn

src/Infrastructure/BotSharp.OpenAPI/BackgroundServices/ConversationTimeoutService.cs

@@ -1,7 +1,6 @@
 using BotSharp.Abstraction.Messaging.JsonConverters;
 using BotSharp.Core.MCP.Settings;
 using BotSharp.Core.Users.Services;
-using BotSharp.OpenAPI.BackgroundServices;
 using BotSharp.OpenAPI.Hooks;
 using BotSharp.OpenAPI.RuleTriggers;
 using Microsoft.AspNetCore.Authentication;
@@ -40,7 +39,6 @@ public static IServiceCollection AddBotSharpOpenAPI(this IServiceCollection serv
         bool enableValidation)
     {
         services.AddScoped<IUserIdentity, UserIdentity>();
-        services.AddHostedService<ConversationTimeoutService>();
 
         services.AddCrontabServices();
 
@@ -231,6 +229,8 @@ private static async Task OnTicketReceivedContext(TicketReceivedContext context)
 
     public static IServiceCollection AddCrontabServices(this IServiceCollection services)
     {
+        services.AddScoped<ICrontabHook, IdleConversationCleanupCrontabHook>();
+        services.AddScoped<ICrontabSource, IdleConversationCleanupRuleTrigger>();
         services.AddScoped<ICrontabHook, ConversationLogCleanupCrontabHook>();
         services.AddScoped<ICrontabSource, ConversationLogCleanupRuleTrigger>();
         return services;

src/Infrastructure/BotSharp.OpenAPI/BotSharpOpenApiExtensions.cs

@@ -0,0 +1,53 @@
+using BotSharp.Abstraction.Conversations;
+using BotSharp.Abstraction.Conversations.Settings;
+using BotSharp.Abstraction.Crontab;
+using BotSharp.Abstraction.Crontab.Models;
+using BotSharp.OpenAPI.RuleTriggers;
+using Microsoft.Extensions.Logging;
+
+namespace BotSharp.OpenAPI.Hooks
+{
+    public class IdleConversationCleanupCrontabHook : ICrontabHook
+    {
+        private readonly ConversationSetting _settings;
+        private readonly IConversationService _conversationService;
+        private readonly ILogger<IdleConversationCleanupCrontabHook> _logger;
+
+        public string[]? Triggers => new[] { nameof(IdleConversationCleanupRuleTrigger) };
+
+        public IdleConversationCleanupCrontabHook(
+            ConversationSetting settings,
+            IConversationService conversationService,
+            ILogger<IdleConversationCleanupCrontabHook> logger)
+        {
+            _settings = settings;
+            _conversationService = conversationService;
+            _logger = logger;
+        }
+
+        public async Task OnCronTriggered(CrontabItem item)
+        {
+            var cleanSetting = _settings.CleanSetting;
+
+            if (cleanSetting == null || !cleanSetting.Enable) return;
+
+            try
+            {
+                var batchSize = cleanSetting.BatchSize;
+                var limit = cleanSetting.MessageLimit;
+                var bufferHours = cleanSetting.BufferHours;
+                var excludeAgentIds = cleanSetting.ExcludeAgentIds ?? new List<string>();
+                var conversationIds = await _conversationService.GetIdleConversations(batchSize, limit, bufferHours, excludeAgentIds);
+
+                if (!conversationIds.IsNullOrEmpty())
+                {
+                    await _conversationService.DeleteConversations(conversationIds);
+                }
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex, "Error occurred closing conversations.");
+            }
+        }
+    }
+}

src/Infrastructure/BotSharp.OpenAPI/Hooks/IdleConversationCleanupCrontabHook.cs

@@ -0,0 +1,26 @@
+using BotSharp.Abstraction.Conversations.Enums;
+using BotSharp.Abstraction.Crontab;
+using BotSharp.Abstraction.Crontab.Models;
+using BotSharp.Abstraction.Rules;
+
+namespace BotSharp.OpenAPI.RuleTriggers
+{
+    public class IdleConversationCleanupRuleTrigger : IRuleTrigger, ICrontabSource
+    {
+        public string Channel => ConversationChannel.Crontab;
+        public string Name => nameof(IdleConversationCleanupRuleTrigger);
+        public string EntityType { get; set; } = string.Empty;
+        public string EntityId { get; set; } = string.Empty;
+
+        public CrontabItem GetCrontabItem()
+        {
+            return new CrontabItem
+            {
+                Title = nameof(IdleConversationCleanupRuleTrigger),
+                Description = "Clean up idle conversations hourly",
+                Cron = "0 * * * *",
+                TriggerType = CronTabItemTriggerType.MessageQueue
+            };
+        }
+    }
+}