Module send 

Re-exports

use std::collections::BTreeMap; 🔒

use std::iter::once; 🔒

use std::net::IpAddr; 🔒

use std::sync::atomic::AtomicBool; 🔒

use std::sync::atomic::Ordering; 🔒

use std::time::Duration; 🔒

use std::time::Instant; 🔒

use axum::extract::State; 🔒

use futures::FutureExt; 🔒

use futures::Stream; 🔒

use futures::StreamExt; 🔒

use futures::TryFutureExt; 🔒

use futures::TryStreamExt; 🔒

use ruma::CanonicalJsonObject; 🔒

use ruma::CanonicalJsonValue; 🔒

use ruma::MilliSecondsSinceUnixEpoch; 🔒

use ruma::OwnedDeviceId; 🔒

use ruma::OwnedEventId; 🔒

use ruma::OwnedRoomId; 🔒

use ruma::OwnedUserId; 🔒

use ruma::RoomId; 🔒

use ruma::ServerName; 🔒

use ruma::TransactionId; 🔒

use ruma::UserId; 🔒

use ruma::api::error::ErrorKind; 🔒

use ruma::api::federation::transactions::edu::DeviceListUpdateContent; 🔒

use ruma::api::federation::transactions::edu::DirectDeviceContent; 🔒

use ruma::api::federation::transactions::edu::Edu; 🔒

use ruma::api::federation::transactions::edu::PresenceContent; 🔒

use ruma::api::federation::transactions::edu::PresenceUpdate; 🔒

use ruma::api::federation::transactions::edu::ReceiptContent; 🔒

use ruma::api::federation::transactions::edu::ReceiptData; 🔒

use ruma::api::federation::transactions::edu::ReceiptMap; 🔒

use ruma::api::federation::transactions::edu::SigningKeyUpdateContent; 🔒

use ruma::api::federation::transactions::edu::TypingContent; 🔒

use ruma::api::federation::transactions::send_transaction_message; 🔒

use ruma::events::receipt::ReceiptEvent; 🔒

use ruma::events::receipt::ReceiptEventContent; 🔒

use ruma::events::receipt::ReceiptType; 🔒

use ruma::int; 🔒

use ruma::serde::Raw; 🔒

use ruma::to_device::DeviceIdOrAllDevices; 🔒

use ruma::uint; 🔒

use tuwunel_core::Err; 🔒

use tuwunel_core::Error; 🔒

use tuwunel_core::Result; 🔒

use tuwunel_core::debug; 🔒

use tuwunel_core::debug; 🔒

use tuwunel_core::debug::INFO_SPAN_LEVEL; 🔒

use tuwunel_core::debug_warn; 🔒

use tuwunel_core::defer; 🔒

use tuwunel_core::err; 🔒

use tuwunel_core::error; 🔒

use tuwunel_core::error; 🔒

use tuwunel_core::itertools::Itertools; 🔒

use tuwunel_core::result::LogErr; 🔒

use tuwunel_core::smallvec::SmallVec; 🔒

use tuwunel_core::trace; 🔒

use tuwunel_core::utils::debug::str_truncated; 🔒

use tuwunel_core::utils::future::TryExtExt; 🔒

use tuwunel_core::utils::millis_since_unix_epoch; 🔒

use tuwunel_core::utils::stream::BroadbandExt; 🔒

use tuwunel_core::utils::stream::IterStream; 🔒

use tuwunel_core::utils::stream::ReadyExt; 🔒

use tuwunel_core::utils::stream::TryBroadbandExt; 🔒

use tuwunel_core::utils::stream::automatic_width; 🔒

use tuwunel_core::warn; 🔒

use tuwunel_matrix::room::state::resolution::is_topologically_sorted_in_place; 🔒

use tuwunel_matrix::room::state::resolution::topological_sort; 🔒

use tuwunel_matrix::room::state::resolution::topological_sort; 🔒

use tuwunel_service::Services; 🔒

use tuwunel_service::sending::EDU_LIMIT; 🔒

use tuwunel_service::sending::PDU_LIMIT; 🔒

use tuwunel_service::users::DeviceListChange; 🔒

use crate::ClientIp; 🔒

use crate::Ruma; 🔒

Functions

already_sorted 🔒

Whether the batch is already in causal order, in which case the sort can be skipped.

handle 🔒

handle_edu 🔒

handle_edu_device_list_update 🔒

handle_edu_direct_to_device 🔒

handle_edu_direct_to_device_event 🔒

handle_edu_direct_to_device_user 🔒

handle_edu_presence 🔒

handle_edu_presence_update 🔒

handle_edu_receipt 🔒

handle_edu_receipt_room 🔒

handle_edu_receipt_room_user 🔒

handle_edu_signing_key_update 🔒

handle_edu_typing 🔒

handle_edus 🔒

handle_pdu 🔒

handle_pdus 🔒

handle_room 🔒

prev_event_ids 🔒

The prev_events of a PDU held as canonical JSON.

send_transaction_message_route 🔒

PUT /_matrix/federation/v1/send/{txnId}

sort_pdus 🔒

Reorder a room’s transaction PDUs so each event follows the in-batch events it references. An already-ordered batch is returned unchanged; references to events outside the batch are non-edges. The sort is an optimization, so a failure falls back to the arrival order.

to_device_deliverable 🔒

A local account we store or forward to-device events for.

Type Aliases

Deliveries 🔒

Recipient devices of one AllDevices to-device send paired with their inbox counts.

Pdu 🔒

ResolvedMap 🔒

RoomPdus 🔒

RoomsPdus 🔒

TxnPdus 🔒