tuwunel_admin/query/sending/
active_requests_for.rs1use futures::StreamExt;
2use ruma::{OwnedServerName, OwnedUserId};
3use tuwunel_core::Result;
4
5use super::parse_destination;
6use crate::admin_command;
7
8#[admin_command]
9pub(super) async fn sending_active_requests_for(
10 &self,
11 appservice_id: Option<String>,
12 server_name: Option<OwnedServerName>,
13 user_id: Option<OwnedUserId>,
14 push_key: Option<String>,
15) -> Result {
16 let destination = parse_destination(appservice_id, server_name, user_id, push_key)?;
17
18 let query = self
19 .services
20 .sending
21 .db
22 .active_requests_for(&destination)
23 .collect::<Vec<_>>();
24
25 self.write_timed_query(query).await
26}