diff --git a/src/GmRelay.Bot/Features/Sessions/RescheduleSession/RescheduleVotingDeadlineService.cs b/src/GmRelay.Bot/Features/Sessions/RescheduleSession/RescheduleVotingDeadlineService.cs index ffd21e8..e35c9e0 100644 --- a/src/GmRelay.Bot/Features/Sessions/RescheduleSession/RescheduleVotingDeadlineService.cs +++ b/src/GmRelay.Bot/Features/Sessions/RescheduleSession/RescheduleVotingDeadlineService.cs @@ -46,7 +46,7 @@ public sealed class RescheduleVotingDeadlineService( { try { - var proposalIds = await finalizer.GetDueProposalIdsAsync(ct); + var proposalIds = await finalizer.GetDueProposalIdsAsync("Telegram", ct); foreach (var proposalId in proposalIds) { diff --git a/src/GmRelay.DiscordBot/Features/Sessions/DiscordRescheduleVotingDeadlineService.cs b/src/GmRelay.DiscordBot/Features/Sessions/DiscordRescheduleVotingDeadlineService.cs index 2f1b4be..bb88411 100644 --- a/src/GmRelay.DiscordBot/Features/Sessions/DiscordRescheduleVotingDeadlineService.cs +++ b/src/GmRelay.DiscordBot/Features/Sessions/DiscordRescheduleVotingDeadlineService.cs @@ -34,7 +34,7 @@ public sealed class DiscordRescheduleVotingDeadlineService( { try { - var proposalIds = await finalizer.GetDueProposalIdsAsync(ct); + var proposalIds = await finalizer.GetDueProposalIdsAsync("Discord", ct); foreach (var id in proposalIds) { await TryFinalizeAsync(id, ct); diff --git a/src/GmRelay.Shared/Features/Sessions/RescheduleSession/RescheduleVotingFinalizer.cs b/src/GmRelay.Shared/Features/Sessions/RescheduleSession/RescheduleVotingFinalizer.cs index 8942b4b..bb00f4a 100644 --- a/src/GmRelay.Shared/Features/Sessions/RescheduleSession/RescheduleVotingFinalizer.cs +++ b/src/GmRelay.Shared/Features/Sessions/RescheduleSession/RescheduleVotingFinalizer.cs @@ -26,7 +26,7 @@ public sealed class RescheduleVotingFinalizer( ISystemClock clock, ILogger logger) { - public async Task> GetDueProposalIdsAsync(CancellationToken ct) + public async Task> GetDueProposalIdsAsync(string sourcePlatform, CancellationToken ct) { await using var connection = await dataSource.OpenConnectionAsync(ct); var proposalIds = (await connection.QueryAsync( @@ -36,10 +36,11 @@ public sealed class RescheduleVotingFinalizer( WHERE status = 'Voting' AND voting_deadline_at IS NOT NULL AND voting_deadline_at <= @Now + AND source_platform = @SourcePlatform ORDER BY voting_deadline_at LIMIT 25 """, - new { Now = clock.UtcNow.UtcDateTime })).ToList(); + new { Now = clock.UtcNow.UtcDateTime, SourcePlatform = sourcePlatform })).ToList(); return proposalIds; }