Module delayed_events 

Delayed events (MSC4140): scheduling, management and lookup.

Scheduling applies the policy an ordinary send would at the time of the request, then checks the event against room auth without storing it. The service sends it once due through the ordinary append path.

Re-exports

use std::time::Duration; 🔒

use axum::extract::MatchedPath; 🔒

use futures::future::OptionFuture; 🔒

use ruma::DeviceId; 🔒

use ruma::MilliSecondsSinceUnixEpoch; 🔒

use ruma::RoomId; 🔒

use ruma::TransactionId; 🔒

use ruma::UserId; 🔒

use ruma::events::AnyMessageLikeEventContent; 🔒

use ruma::events::AnyStateEventContent; 🔒

use ruma::events::MessageLikeEventType; 🔒

use ruma::events::StateEventType; 🔒

use ruma::events::TimelineEventType; 🔒

use ruma::serde::Raw; 🔒

use serde_json::from_str; 🔒

use serde_json::value::RawValue as RawJsonValue; 🔒

use tuwunel_core::Err; 🔒

use tuwunel_core::Result; 🔒

use tuwunel_core::err; 🔒

use tuwunel_core::implement; 🔒

use tuwunel_core::utils::time::millis; 🔒

use tuwunel_core::utils::time::now_millis; 🔒

use tuwunel_matrix::pdu::PduBuilder; 🔒

use tuwunel_service::Services; 🔒

use tuwunel_service::delayed_events::DelayId; 🔒

use tuwunel_service::delayed_events::Event; 🔒

use tuwunel_service::delayed_events::Limits; 🔒

use tuwunel_service::rooms::timeline::RoomMutexGuard; 🔒

use tuwunel_service::transaction_ids::RoomTxn; 🔒

pub(crate) use self::delay_query::send_message_event_or_delayed_route; 🔒

pub(crate) use self::delay_query::send_state_event_or_delayed_route; 🔒

pub(crate) use self::get_delayed_event::get_delayed_event_route; 🔒

pub(crate) use self::get_delayed_events::get_delayed_events_route; 🔒

pub(crate) use self::send_delayed_event::send_delayed_event_route; 🔒

pub(crate) use self::update_delayed_event::update_delayed_event_by_body_route; 🔒

pub(crate) use self::update_delayed_event::update_delayed_event_route; 🔒

use crate::send::check_send_content; 🔒

use crate::send::check_send_policy; 🔒

use crate::state::allowed_to_send_state_event; 🔒

use crate::state::check_member_content_size; 🔒

Modules

delay_query 🔒

get_delayed_event 🔒

get_delayed_events 🔒

send_delayed_event 🔒

update_delayed_event 🔒

Structs

Schedule 🔒

Enums

Kind 🔒

Functions

check_delay 🔒

Returns the delay in milliseconds once it is positive and within limits.

check_room_auth 🔒

Builds and signs the event against the room’s current state without storing it, refusing one room auth would reject now.

is_stable 🔒

schedule 🔒

Schedules an event and returns its delay_id.