Fetch presence avatar_url and displayname concurrently.

Signed-off-by: Jason Volk <jason@zemos.net>
This commit is contained in:
Jason Volk
2025-09-23 08:23:35 +00:00
parent 6d3b2d864f
commit 14721c90c9

View File

@@ -1,10 +1,11 @@
use futures::future::join;
use ruma::{ use ruma::{
UInt, UserId, UInt, UserId,
events::presence::{PresenceEvent, PresenceEventContent}, events::presence::{PresenceEvent, PresenceEventContent},
presence::PresenceState, presence::PresenceState,
}; };
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
use tuwunel_core::{Error, Result, utils}; use tuwunel_core::{Error, Result, utils, utils::future::TryExtExt};
use crate::users; use crate::users;
@@ -46,7 +47,11 @@ impl Presence {
users: &users::Service, users: &users::Service,
) -> PresenceEvent { ) -> PresenceEvent {
let now = utils::millis_since_unix_epoch(); let now = utils::millis_since_unix_epoch();
let last_active_ago = Some(UInt::new_saturating(now.saturating_sub(self.last_active_ts))); let last_active_ago = now.saturating_sub(self.last_active_ts);
let avatar_url = users.avatar_url(user_id).ok();
let displayname = users.displayname(user_id).ok();
let (avatar_url, displayname) = join(avatar_url, displayname).await;
PresenceEvent { PresenceEvent {
sender: user_id.to_owned(), sender: user_id.to_owned(),
@@ -54,9 +59,9 @@ impl Presence {
presence: self.state.clone(), presence: self.state.clone(),
status_msg: self.status_msg.clone(), status_msg: self.status_msg.clone(),
currently_active: Some(self.currently_active), currently_active: Some(self.currently_active),
last_active_ago, last_active_ago: Some(UInt::new_saturating(last_active_ago)),
displayname: users.displayname(user_id).await.ok(), avatar_url,
avatar_url: users.avatar_url(user_id).await.ok(), displayname,
}, },
} }
} }