Re-exports§
use std::collections::BTreeMap;🔒use futures::FutureExt;🔒use futures::StreamExt;🔒use futures::TryFutureExt;🔒use futures::future::join3;🔒use futures::future::join4;🔒use ruma::OwnedEventId;🔒use ruma::OwnedRoomId;🔒use ruma::RoomId;🔒use ruma::UserId;🔒use ruma::api::client::filter::FilterDefinition;🔒use ruma::api::client::sync::sync_events::v3::LeftRoom;🔒use ruma::api::client::sync::sync_events::v3::RoomAccountData;🔒use ruma::api::client::sync::sync_events::v3::StateEvents;🔒use ruma::api::client::sync::sync_events::v3::Timeline;🔒use ruma::events::AnyRawAccountDataEvent;🔒use ruma::events::room::member::MembershipState;🔒use tuwunel_core::Error;🔒use tuwunel_core::Result;🔒use tuwunel_core::at;🔒use tuwunel_core::debug;🔒use tuwunel_core::debug;🔒use tuwunel_core::error::inspect_debug_log;🔒use tuwunel_core::extract_variant;🔒use tuwunel_core::is_equal_to;🔒use tuwunel_core::ref_at;🔒use tuwunel_core::result::FlatOk;🔒use tuwunel_core::smallvec::SmallVec;🔒use tuwunel_core::utils::BoolExt;🔒use tuwunel_core::utils::FutureBoolExt;🔒use tuwunel_core::utils::IterStream;🔒use tuwunel_core::utils::ReadyExt;🔒use tuwunel_core::utils::TryFutureExtExt;🔒use tuwunel_core::utils::future::ReadyBoolExt;🔒use tuwunel_core::utils::option::OptionExt;🔒use tuwunel_core::utils::result::MapExpect;🔒use tuwunel_core::utils::stream::BroadbandExt;🔒use tuwunel_core::utils::stream::WidebandExt;🔒use tuwunel_core::warn;🔒use tuwunel_matrix::Event;🔒use tuwunel_matrix::event::Matches;🔒use tuwunel_matrix::event::trim_event_fields;🔒use tuwunel_matrix::pdu::PduCount;🔒use tuwunel_matrix::pdu::PduEvent;🔒use tuwunel_service::Services;🔒use super::super::load_timeline;🔒use super::super::own_departure;🔒use super::super::stand_in_leave;🔒use super::super::strip_state_unsigned;🔒use super::super::timeline_prev_batch;🔒use super::StateAfter;🔒use super::StateChangeParams;🔒use super::StateChanges;🔒use super::missing_room_state;🔒use super::state::calculate_state_changes;🔒use crate::ignored_filter;🔒use crate::is_empty_account_data_event;🔒use crate::with_membership;🔒use ruma::events::TimelineEventType::*;🔒
Functions§
- collect_
rooms 🔒 - departed_
out_ 🔒of_ band - Whether the room holds no departure event this sync can send.
- handle_
left_ 🔒room - in_
timeline 🔒 - late_
departure 🔒 - load_
left_ 🔒room - log_
horizon_ 🔒error - Records a failed horizon read, quietly when the row is simply absent.