Struct MlsStore 

pub struct MlsStore<Context> { /* private fields */ }

Implementations

impl<Context> MlsStore<Context>

pub fn new(context: Context) -> Self

impl<Context> MlsStore<Context>

where Context: XmtpSharedContext,

pub fn received_cursors( &self, topics: &[Topic], ) -> Result<TopicCursor, MlsStoreError>

Read durable receipt F. Transport delivery alone does not advance it.

pub fn admit_incoming_batch( &self, batch: &OrderedEnvelopeBatch, limits: IncomingLimits, ) -> Result<AdmissionResult, MlsStoreError>

Store a validated raw batch and its receipt position in one transaction. New Welcome rows queue key rotation in that same writer, before decoding.

pub async fn receive_topics_once( &self, topics: &[Topic], limits: IncomingLimits, ) -> Result<ReceivedPage, MlsStoreError>

Query from durable receipt positions and commit one bounded page.

pub async fn get_key_packages_for_installation_ids( &self, installation_ids: Vec<Vec<u8>>, ) -> Result<HashMap<Vec<u8>, Result<VerifiedKeyPackageV2, KeyPackageVerificationError>>, MlsStoreError>

Fetches the current key package from the network for each of the installation_ids specified

pub fn find_groups( &self, args: GroupQueryArgs, ) -> Result<Vec<MlsGroup<Context>>, MlsStoreError>

Query for groups with optional filters

Filters:

• allowed_states: only return groups with the given membership states
• created_after_ns: only return groups created after the given timestamp (in nanoseconds)
• created_before_ns: only return groups created before the given timestamp (in nanoseconds)
• limit: only return the first limit groups

pub fn group( &self, group_id: &GroupId, ) -> Result<MlsGroup<Context>, MlsStoreError>

Look up a group by its ID

Returns a MlsGroup if the group exists, or an error if it does not

Trait Implementations

impl<Context: Clone> Clone for MlsStore<Context>

fn clone(&self) -> MlsStore<Context>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.