tuwunel_admin/query/presence/presence_since.rs
1use futures::StreamExt;
2use tuwunel_core::Result;
3
4use crate::admin_command;
5
6#[admin_command]
7pub(super) async fn presence_presence_since(&self, since: u64, to: Option<u64>) -> Result {
8 let query = self
9 .services
10 .presence
11 .presence_since(since, to)
12 .map(|(user_id, count, bytes)| (user_id.to_owned(), count, bytes.to_vec()))
13 .collect::<Vec<(_, _, _)>>();
14
15 self.write_timed_query(query).await
16}