nki/youmubot
1
0
Fork 0
mirror of https://github.com/natsukagami/youmubot.git synced 2025-04-19 00:38:54 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Properly implement member cache

Browse source
This commit is contained in:
Natsu Kagami 2024-08-05 13:41:08 +02:00
parent 26b72d90ef
commit e77930c8db
Signed by: nki
GPG key ID: 55A032EB38B49ADB
1 changed files with 10 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
youmubot-prelude/src/member_cache.rs
View file

@ -88,11 +88,11 @@ impl MemberCache {
) -> crate::Result<Arc<[Member]>> {
let now = Utc::now();
let mut map = self.per_guild.lock().await;
let entry = map.entry(guild_id);
let entry = map.get(&guild_id);
// Check cache
if let Entry::Occupied(oe) = &entry {
if oe.get().timeout > now {
return match &oe.get().value {
if let Some(oe) = &entry {
if oe.timeout > now {
return match &oe.value {
Some(v) => Ok(v.clone()),
None => bail!("guild members for {} unavailable", guild_id),
};
@ -105,17 +105,18 @@ impl MemberCache {
.await
.ok()
.map(|v| v.into());
match &entry
.or_insert(Expiring::new(
map.insert(
guild_id,
Expiring::new(
members.clone(),
now + chrono::Duration::seconds(if members.is_some() {
VALID_CACHE_SECONDS
} else {
INVALID_CACHE_SECONDS
}),
))
.value
{
),
);
match members {
Some(v) => Ok(v.clone()),
None => bail!("guild members for {} unavailable", guild_id),
}