Struct Data 

pub(super) struct Data {
    roomuserid_privateread: Arc<Map>,
    roomuserid_lastprivatereadupdate: Arc<Map>,
    roomuserid_privatereadsync: Arc<Map>,
    services: Arc<OnceServices>,
    readreceiptid_readreceipt: Arc<Map>,
}

Fields

roomuserid_privateread: Arc<Map>

roomuserid_lastprivatereadupdate: Arc<Map>

roomuserid_privatereadsync: Arc<Map>

services: Arc<OnceServices>

readreceiptid_readreceipt: Arc<Map>

Implementations

impl Data

pub(super) fn new(args: &Args<'_>) -> Self

pub(super) async fn readreceipt_update( &self, user_id: &UserId, room_id: &RoomId, event: &ReceiptEvent, ) -> bool

Stores event as the user’s receipt for its thread context, reporting whether it advanced.

A receipt naming the stored event, or an earlier one, is rejected without allocating a stream position or writing anything. An accepted receipt replaces every superseded row in one transaction.

async fn receipt_advanced( &self, current: Option<&EventId>, incoming: &EventId, ) -> bool

Whether a receipt for incoming supersedes the stored one at current.

An identical event id never advances. A position that does not resolve to a known PDU falls through to acceptance, so a receipt this server cannot order is never silently dropped.

pub(super) fn readreceipts_since<'a>( &'a self, room_id: &'a RoomId, since: u64, to: Option<u64>, ) -> impl Stream<Item = (&'_ UserId, u64, Raw<AnySyncEphemeralRoomEvent>)> + Send + 'a

pub(super) fn readreceipts_since_fallible<'a>( &'a self, room_id: &'a RoomId, since: u64, to: Option<u64>, ) -> impl Stream<Item = Result<(&'_ UserId, u64, Raw<AnySyncEphemeralRoomEvent>)>> + Send + 'a

pub(super) async fn private_read_set(&self, __arg1: PrivateRead<'_>) -> bool

Sets the private read marker for (room, user, thread), reporting whether it advanced.

Unthreaded writes use the legacy 2-tuple (room, user) key shape and sweep any pre-existing per-thread rows so the room-wide receipt supersedes prior thread state. Threaded writes (Main, Thread, custom) use a 3-tuple (room, user, thread_kind) key disjoint from the legacy row by trailing separator. The sync gate (roomuserid_lastprivatereadupdate) stays 2-tuple and bumps only when announce is set, keeping it a single point query. Announced state is mirrored separately so notification-only writes cannot alter a sync snapshot without changing its version.

async fn private_read_position( &self, room_id: &RoomId, user_id: &UserId, thread_kind: &str, ) -> Result<(u64, Option<u64>)>

Private read position for an exact (room, user, thread) context.

An unthreaded context reads the legacy 2-tuple row; a threaded one reads its own 3-tuple row.

pub(super) async fn private_read_get_count( &self, room_id: &RoomId, user_id: &UserId, ) -> Result<(u64, Option<u64>)>

Latest unthreaded (legacy 2-tuple) private read: (pdu count, receipt ts millis). ts is None for rows written before the ts tail was added.

pub(super) async fn private_read_sync_get_count( &self, room_id: &RoomId, user_id: &UserId, ) -> Result<(u64, Option<u64>)>

pub(super) fn private_read_threaded_stream<'a>( &'a self, room_id: &'a RoomId, user_id: &'a UserId, ) -> impl Stream<Item = (SmallString<[u8; 48]>, u64, Option<u64>)> + Send + 'a

async fn sweep_thread_private_reads( &self, map: &Arc<Map>, room_id: &RoomId, user_id: &UserId, thread_kind: &str, txn: Txn, ) -> Txn

Queues deletion of the per-thread private read rows for (room, user).

Only an unthreaded write sweeps, since its room-wide receipt supersedes prior thread state; a threaded write touches only its own row.

async fn sweep_private_read_sync( &self, room_id: &RoomId, user_id: &UserId, txn: Txn, ) -> Result<Txn>

pub(super) fn private_read_sync_stream_fallible<'a>( &'a self, room_id: &'a RoomId, user_id: &'a UserId, ) -> impl Stream<Item = Result<(SmallString<[u8; 48]>, u64, Option<u64>)>> + Send + 'a

pub(super) async fn private_read_sync_update_fallible( &self, user_id: &UserId, room_id: &RoomId, ) -> Result<u64>

pub(super) async fn last_privateread_update( &self, user_id: &UserId, room_id: &RoomId, ) -> u64

pub(super) async fn last_privateread_update_fallible( &self, user_id: &UserId, room_id: &RoomId, ) -> Result<u64>

pub(super) async fn delete_all_read_receipts(&self, room_id: &RoomId) -> Result