tuwunel_admin/query/room_state_cache/rooms_invited.rs
1use futures::StreamExt;
2use ruma::OwnedUserId;
3use tuwunel_core::Result;
4
5use crate::admin_command;
6
7#[admin_command]
8pub(super) async fn rooms_invited(&self, user_id: OwnedUserId) -> Result {
9 let query = self
10 .services
11 .state_cache
12 .rooms_invited_state(&user_id)
13 .collect::<Vec<_>>();
14
15 self.write_timed_query(query).await
16}