TeamInklings/Octobot
TeamInklings/Octobot
1
0
Fork 1
mirror of https://github.com/TeamOctolings/Octobot.git synced 2025-04-20 00:43:36 +03:00
Code Issues Wiki Activity

fix(scheduled events update): run update synchronously to avoid rate limit race conditions

Browse source
This commit is contained in:
Octol1ttle 2023-09-30 19:49:46 +05:00
parent 804bcd6e68
commit f4387deef7
Signed by: Octol1ttle
GPG key ID: B77C34313AEE1FFF
1 changed files with 2 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/Services/Update/ScheduledEventUpdateService.cs
View file

@ -34,20 +34,15 @@ public sealed class ScheduledEventUpdateService : BackgroundService
protected override async Task ExecuteAsync(CancellationToken ct) protected override async Task ExecuteAsync(CancellationToken ct)
{ {
using var timer = new PeriodicTimer(TimeSpan.FromSeconds(1)); using var timer = new PeriodicTimer(TimeSpan.FromSeconds(1));
var tasks = new List<Task>();
while (await timer.WaitForNextTickAsync(ct)) while (await timer.WaitForNextTickAsync(ct))
{ {
var guildIds = _guildData.GetGuildIds(); var guildIds = _guildData.GetGuildIds();
foreach (var id in guildIds)
tasks.AddRange(guildIds.Select(async id =>
{ {
var tickResult = await TickScheduledEventsAsync(id, ct); var tickResult = await TickScheduledEventsAsync(id, ct);
_logger.LogResult(tickResult, $"Error in scheduled events update for guild {id}."); _logger.LogResult(tickResult, $"Error in scheduled events update for guild {id}.");
})); }
await Task.WhenAll(tasks);
tasks.Clear();
} }
} }