SemianiakaVY/BotSharp
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

add page limit

Browse source
This commit is contained in:
Jicheng Lu 2024-03-07 13:38:38 -06:00
parent e2a28c683a
commit 43e18a050d
2 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/Infrastructure/BotSharp.OpenAPI/BackgroundServices/ConversationTimeoutService.cs
View file

@ -21,11 +21,11 @@ namespace BotSharp.OpenAPI.BackgroundServices
while (true)
{
stoppingToken.ThrowIfCancellationRequested();
var delay = Task.Delay(TimeSpan.FromMinutes(1));
var delay = Task.Delay(TimeSpan.FromHours(1));
try
{
await CleanIdleConversationsAsync();
await CloseIdleConversationsAsync(TimeSpan.FromMinutes(10));
await CleanIdleConversationsAsync();
}
catch (Exception ex)

3
src/Plugins/BotSharp.Plugin.MongoStorage/Repository/MongoRepository.Conversation.cs
View file

@ -276,6 +276,7 @@ public partial class MongoRepository
public List<string> GetIdleConversations(int batchSize, int messageLimit, int bufferHours)
{
var page = 1;
var pageLimit = 10;
var batchLimit = 50;
var utcNow = DateTime.UtcNow;
var conversationIds = new List<string>();
@ -285,7 +286,7 @@ public partial class MongoRepository
batchSize = batchLimit;
}
while (true)
while (true && page < pageLimit)
{
var skip = (page - 1) * batchSize;
var candidates = _dc.Conversations.AsQueryable()