33using Administrator . Database ;
44using Disqord . Bot . Hosting ;
55using LinqToDB ;
6+ using LinqToDB . EntityFrameworkCore ;
67using Microsoft . Extensions . Logging ;
78using Qommon ;
89using Quartz ;
@@ -20,13 +21,13 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
2021
2122 await using var scope = Bot . Services . CreateAsyncScopeWithDatabase ( out var db ) ;
2223
23- var reminders = await db . Reminders . Where ( x => x . CreatedAt != x . ExpiresAt ) . ToListAsync ( stoppingToken ) ;
24+ var reminders = await db . Reminders . Where ( x => x . CreatedAt != x . ExpiresAt ) . ToListAsyncEF ( stoppingToken ) ;
2425 await scheduler . ScheduleAdminJobs < ReminderExpiryJob , Reminder > ( reminders ) ;
2526 Logger . LogDebug ( "Scheduled {Count} reminder expiry jobs." , reminders . Count ) ;
2627
27- var membersWithDecay = await db . Members . Where ( x => x . NextDemeritPointDecay != null ) . ToListAsync ( stoppingToken ) ;
28- var warningsWithDemeritPoints = await db . Punishments . OfType < Warning > ( ) . Where ( x => x . DemeritPointsRemaining > 0 && x . RevokedAt == null ) . ToListAsync ( stoppingToken ) ;
29- var guilds = await db . Guilds . ToListAsync ( stoppingToken ) ;
28+ var membersWithDecay = await db . Members . Where ( x => x . NextDemeritPointDecay != null ) . ToListAsyncEF ( stoppingToken ) ;
29+ var warningsWithDemeritPoints = await db . Punishments . OfType < Warning > ( ) . Where ( x => x . DemeritPointsRemaining > 0 && x . RevokedAt == null ) . ToListAsyncEF ( stoppingToken ) ;
30+ var guilds = await db . Guilds . ToListAsyncEF ( stoppingToken ) ;
3031 var warningsWithDecay = membersWithDecay . Select ( member => new
3132 {
3233 Member = member ,
@@ -45,7 +46,7 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
4546
4647 var punishments = await db . Punishments . OfType < RevocablePunishment > ( )
4748 . Where ( x => x . RevokedAt == null )
48- . ToListAsync ( stoppingToken ) ;
49+ . ToListAsyncEF ( stoppingToken ) ;
4950
5051 var expiringPunishments = punishments . Where ( x => x is IExpiringEntity { ExpiresAt : not null } ) . ToList ( ) ;
5152 await SchedulePunishmentExpiryJobsAsync ( scheduler , expiringPunishments ) ;
@@ -121,7 +122,7 @@ public async ValueTask UnscheduleDemeritPointDecayJobAsync(Warning warning)
121122 x . RevokedAt == null &&
122123 x . DemeritPointsRemaining > 0 )
123124 . OrderByDescending ( x => x . Id )
124- . FirstOrDefaultAsync ( ) ;
125+ . FirstOrDefaultAsyncEF ( ) ;
125126
126127 if ( otherWarning is not null )
127128 {
0 commit comments