Noi/RegexBot
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Move member cache updating off main thread

Browse source
This commit is contained in:
Noi 2022-12-03 17:21:20 -08:00
parent a707792fe4
commit 12f8359b90
1 changed files with 16 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
Services/EntityCache/UserCachingSubservice.cs
View file

@ -18,15 +18,22 @@ class UserCachingSubservice {
bot.DiscordClient.GuildMemberUpdated += DiscordClient_GuildMemberUpdated; bot.DiscordClient.GuildMemberUpdated += DiscordClient_GuildMemberUpdated;
bot.DiscordClient.UserUpdated += DiscordClient_UserUpdated; bot.DiscordClient.UserUpdated += DiscordClient_UserUpdated;
} }
private async Task DiscordClient_GuildMembersDownloaded(SocketGuild arg) { private Task DiscordClient_GuildMembersDownloaded(SocketGuild arg) {
_log($"{arg.Name}: Full member list obtained. Cache update in progress."); var userlist = arg.Users.ToList();
_ = Task.Run(async () => {
try {
using var db = new BotDatabaseContext(); using var db = new BotDatabaseContext();
foreach (var user in arg.Users) { foreach (var user in userlist) {
UpdateUser(user, db); UpdateUser(user, db);
UpdateGuildUser(user, db); UpdateGuildUser(user, db);
} }
var changes = await db.SaveChangesAsync(); var changes = await db.SaveChangesAsync();
_log($"{arg.Name}: Member caches updated ({changes} database writes)."); _log($"{arg.Name}: Member caches updated ({changes} database writes).");
} catch (Exception ex) {
_log($"{arg.Name}: {ex}");
}
});
return Task.CompletedTask;
} }
private async Task DiscordClient_GuildMemberUpdated(Discord.Cacheable<SocketGuildUser, ulong> old, SocketGuildUser current) { private async Task DiscordClient_GuildMemberUpdated(Discord.Cacheable<SocketGuildUser, ulong> old, SocketGuildUser current) {