tuwunel_admin/query/account_data/
changes_since.rs1use futures::StreamExt;
2use ruma::{OwnedRoomId, OwnedUserId};
3use tuwunel_core::Result;
4
5use crate::admin_command;
6
7#[admin_command]
8pub(super) async fn changes_since(
9 &self,
10 user_id: OwnedUserId,
11 since: u64,
12 room_id: Option<OwnedRoomId>,
13) -> Result {
14 let query = self
15 .services
16 .account_data
17 .changes_since(room_id.as_deref(), &user_id, since, None)
18 .collect::<Vec<_>>();
19
20 self.write_timed_query(query).await
21}