Module get_missing_events 

Re-exports

use std::collections::BTreeSet; 🔒

use std::collections::VecDeque; 🔒

use axum::extract::State; 🔒

use futures::StreamExt; 🔒

use futures::TryFutureExt; 🔒

use futures::TryStreamExt; 🔒

use futures::future::try_join; 🔒

use futures::stream::FuturesOrdered; 🔒

use futures::stream::unfold; 🔒

use ruma::CanonicalJsonObject; 🔒

use ruma::CanonicalJsonValue; 🔒

use ruma::EventId; 🔒

use ruma::OwnedEventId; 🔒

use ruma::api::federation::event::get_missing_events; 🔒

use ruma::canonical_json::redact_in_place; 🔒

use tuwunel_core::Error; 🔒

use tuwunel_core::Result; 🔒

use tuwunel_core::debug; 🔒

use tuwunel_core::debug; 🔒

use tuwunel_core::err; 🔒

use tuwunel_core::utils::math::usize_from_ruma_bounded; 🔒

use tuwunel_core::utils::stream::TryWidebandExt; 🔒

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

use tuwunel_matrix::room_version::rules as room_version_rules; 🔒

use super::AccessCheck; 🔒

use crate::Ruma; 🔒

Constants

EARLIEST_MAX 🔒

LIMIT_DEFAULT 🔒

spec says default is 10

LIMIT_MAX 🔒

arbitrary number but synapse’s is 20 and we can handle lots of these anyways

WALK_MAX 🔒

Functions

get_missing_events_route 🔒

POST /_matrix/federation/v1/get_missing_events/{roomId}

next_missing_event 🔒

walk_seed 🔒

Builds the walk’s dedup set and its initial queue.

Type Aliases

Pending 🔒

Seen 🔒