Salastil/KfChatDotNet
1
0
Fork 0
mirror of https://github.com/barelyprofessional/KfChatDotNet.git synced 2026-05-02 04:22:04 -04:00
Code Issues Packages Projects Releases Wiki Activity

Remove persistently failing mesasges from the deletion scheduled task if they get forever lost for some reason.

Browse Source 
Also moved the check for null until after it has checked the deadline so it only cares if it's due to be deleted.
This commit is contained in:
barelyprofessional
2025-10-18 19:30:49 -05:00
parent 2699dcf9ca
commit d53d2f1def
1 changed files with 17 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
KfChatDotNetBot/ChatBot.cs
View File

@@ -183,6 +183,7 @@ public class ChatBot
{
var interval = (await SettingsProvider.GetValueAsync(BuiltIn.Keys.BotScheduledDeletionInterval)).ToType<int>();
using var timer = new PeriodicTimer(TimeSpan.FromMilliseconds(interval));
var failures = new Dictionary<string, int>();
while (await timer.WaitForNextTickAsync(_cancellationToken))
{
if (!KfClient.IsConnected())
@@ -195,13 +196,27 @@ public class ChatBot
var removals = new List<ScheduledAutoDeleteModel>();
foreach (var deletion in _scheduledDeletions)
{
if (deletion.DeleteAt > now) continue;
if (deletion.Message.ChatMessageId == null)
{
_logger.Error($"Can't clean up {deletion.Message.Reference} as it doesn't have a chat message ID");
if (failures.TryGetValue(deletion.Message.Reference, out var failure))
{
if (failure > 20)
{
removals.Add(deletion);
_logger.Error($"Giving up on {deletion.Message.Reference} and removing it from the deletion queue");
continue;
}
failures[deletion.Message.Reference] += 1;
}
else
{
failures[deletion.Message.Reference] = 1;
}
continue;
}
if (deletion.DeleteAt > now) continue;
await KfClient.DeleteMessageAsync(deletion.Message.ChatMessageId.Value);
removals.Add(deletion);
}