Skip to main content Module message Copy item path Source use axum::extract::State; 🔒 use futures::FutureExt; 🔒 use futures::StreamExt; 🔒 use futures::TryFutureExt; 🔒 use futures::pin_mut; 🔒 use ruma::DeviceId; 🔒 use ruma::RoomId; 🔒 use ruma::UInt; 🔒 use ruma::UserId; 🔒 use ruma::api::Direction; 🔒 use ruma::api::client::filter::RoomEventFilter; 🔒 use ruma::api::client::message::get_message_events; 🔒 use ruma::events::AnyStateEvent; 🔒 use ruma::events::StateEventType; 🔒 use ruma::events::TimelineEventType; 🔒 use ruma::events::relation::RelationType; 🔒 use ruma::serde::Raw; 🔒 use tuwunel_core::Err ; 🔒 use tuwunel_core::Result ; 🔒 use tuwunel_core::at ; 🔒 use tuwunel_core::err ; 🔒 use tuwunel_core::ref_at ; 🔒 use tuwunel_core::smallvec::SmallVec; 🔒 use tuwunel_core::utils::BoolExt ; 🔒 use tuwunel_core::utils::IterStream ; 🔒 use tuwunel_core::utils::ReadyExt ; 🔒 use tuwunel_core::utils::math::usize_from_ruma_bounded ; 🔒 use tuwunel_core::utils::result::LogErr ; 🔒 use tuwunel_core::utils::stream::BroadbandExt ; 🔒 use tuwunel_core::utils::stream::TryIgnore ; 🔒 use tuwunel_core::utils::stream::WidebandExt ; 🔒 use tuwunel_matrix::PduId ; 🔒 use tuwunel_matrix::event::Event ; 🔒 use tuwunel_matrix::event::Matches ; 🔒 use tuwunel_matrix::pdu::PduCount ; 🔒 use tuwunel_matrix::pdu::PduEvent ; 🔒 use tuwunel_service::Services ; 🔒 use tuwunel_service::rooms::lazy_loading ; 🔒 use tuwunel_service::rooms::lazy_loading::Options ; 🔒 use tuwunel_service::rooms::lazy_loading::Witness ; 🔒 use tuwunel_service::rooms::short::ShortRoomId ; 🔒 use tuwunel_service::rooms::timeline::PdusIterItem ; 🔒 use super::visibility_filter ; 🔒 use crate::Ruma ; 🔒 use ruma::events::TimelineEventType::*; 🔒 MessagesArgs Shared inputs for get_messages/messages route and the admin room-messages endpoint. IGNORED_MESSAGE_TYPES 🔒 list of safe and common non-state events to ignore if the user is ignored.
MUST be sorted by TimelineEventType::event_type_str() for binary_search. LIMIT_DEFAULT 🔒 LIMIT_MAX 🔒 _is_sorted 🔒 add_membership_unsigned 🔒 with_membership adapter for timeline-iterator items.annotate_membership 🔒 MSC4115: stamp unsigned.membership on a served PDU with the requesting
user’s membership at the time of the event. The MSC permits omitting the
property when calculating it is expensive, so the project restricts it to
encrypted rooms where membership-vs-event ordering matters for key share. event_filter 🔒 event_filters 🔒 get_member_event 🔒 get_message_events_route 🔒 GET /_matrix/client/r0/rooms/{roomId}/messagesget_messages Paginates a room’s timeline, applying the request filter and (unless
bypass_visibility) the per-user visibility and ignore filters. ignored_filter 🔒 is_ignored_pdu 🔒 lazy_loading_witness 🔒 related_by_filter 🔒 MSC3440 related_by_*: include an event only when another event relates
to it matching the filter’s reverse-relation criteria. A no-op stage when
the filter carries neither field. with_membership annotate_membership consume-and-return adapter for stream chains.RelTypes 🔒 MSC3440 related_by_rel_types entries, typed at the compare boundary.