Struct matrix_sdk_base::BaseClient

pub struct BaseClient { /* private fields */ }

A no IO Client implementation.

This Client is a state machine that receives responses and events and accordingly updates its state.

Implementations

impl BaseClient

pub fn new() -> Self

Create a new default client.

pub fn with_store_config(config: StoreConfig) -> Self

Create a new client.

Arguments

• config - An optional session if the user already has one from a previous login call.

pub fn clone_with_in_memory_state_store(&self) -> Self

Clones the current base client to use the same crypto store but a different, in-memory store config, and resets transient state.

pub fn session_meta(&self) -> Option<&SessionMeta>

Get the session meta information.

If the client is currently logged in, this will return a SessionMeta object which contains the user ID and device ID. Otherwise it returns None.

pub fn get_rooms(&self) -> Vec<Room>

Get all the rooms this client knows about.

pub fn get_rooms_filtered(&self, filter: RoomStateFilter) -> Vec<Room>

Get all the rooms this client knows about, filtered by room state.

pub fn get_or_create_room( &self, room_id: &RoomId, room_state: RoomState ) -> Room

Lookup the Room for the given RoomId, or create one, if it didn’t exist yet in the store

pub fn get_stripped_rooms(&self) -> Vec<Room>

👎Deprecated: Use get_rooms_filtered with RoomStateFilter::INVITED instead.

Get all the rooms this client knows about.

pub fn store(&self) -> &DynStateStore

Get a reference to the store.

pub fn logged_in(&self) -> bool

Is the client logged in.

pub async fn set_session_meta(&self, session_meta: SessionMeta) -> Result<()>

Set the meta of the session.

If encryption is enabled, this also initializes or restores the OlmMachine.

Arguments

• session_meta - The meta of a session that the user already has from a previous login call.

This method panics if it is called twice.

pub async fn regenerate_olm(&self) -> Result<()>

Available on crate feature e2e-encryption only.

Recreate an OlmMachine from scratch.

In particular, this will clear all its caches.

pub async fn sync_token(&self) -> Option<String>

Get the current, if any, sync token of the client. This will be None if the client didn’t sync at least once.

pub async fn room_joined(&self, room_id: &RoomId) -> Result<Room>

User has joined a room.

Update the internal and cached state accordingly. Return the final Room.

pub async fn room_left(&self, room_id: &RoomId) -> Result<()>

User has left a room.

Update the internal and cached state accordingly.

pub fn sync_lock(&self) -> &Mutex<()>

Get access to the store’s sync lock.

pub async fn receive_sync_response( &self, response: Response ) -> Result<SyncResponse>

Receive a response from a sync call.

Arguments

• response - The response that we received after a successful sync.

pub async fn receive_all_members( &self, room_id: &RoomId, request: &Request, response: &Response ) -> Result<()>

Receive a get member events response and convert it to a deserialized MembersResponse

This client-server request must be made without filters to make sure all members are received. Otherwise, an error is returned.

Arguments

• room_id - The room id this response belongs to.

• response - The raw response that was received from the server.

pub async fn receive_filter_upload( &self, filter_name: &str, response: &Response ) -> Result<()>

Receive a successful filter upload response, the filter id will be stored under the given name in the store.

The filter id can later be retrieved with the get_filter method.

Arguments

• filter_name - The name that should be used to persist the filter id in the store.

• response - The successful filter upload response containing the filter id.

pub async fn get_filter(&self, filter_name: &str) -> StoreResult<Option<String>>

Get the filter id of a previously uploaded filter.

Note: A filter will first need to be uploaded and persisted using receive_filter_upload.

Arguments

• filter_name - The name of the filter that was previously used to persist the filter.

pub async fn share_room_key( &self, room_id: &RoomId ) -> Result<Vec<Arc<ToDeviceRequest>>>

Available on crate feature e2e-encryption only.

Get a to-device request that will share a room key with users in a room.

pub fn get_room(&self, room_id: &RoomId) -> Option<Room>

Get the room with the given room id.

Arguments

• room_id - The id of the room that should be fetched.

pub async fn olm_machine(&self) -> RwLockReadGuard<'_, Option<OlmMachine>>

Available on crate feature e2e-encryption only.

Get the olm machine.

pub async fn get_push_rules(&self, changes: &StateChanges) -> Result<Ruleset>

Get the push rules.

Gets the push rules from changes if they have been updated, otherwise get them from the store. As a fallback, uses Ruleset::server_default if the user is logged in.

pub async fn get_push_room_context( &self, room: &Room, room_info: &RoomInfo, changes: &StateChanges ) -> Result<Option<PushConditionRoomCtx>>

Get the push context for the given room.

Tries to get the data from changes or the up to date room_info. Loads the data from the store otherwise.

Returns None if some data couldn’t be found. This should only happen in brand new rooms, while we process its state.

pub async fn update_push_room_context( &self, push_rules: &mut PushConditionRoomCtx, user_id: &UserId, room_info: &RoomInfo, changes: &StateChanges )

Update the push context for the given room.

Updates the context data from changes or room_info.

pub fn subscribe_to_ignore_user_list_changes(&self) -> Subscriber<Vec<String>>

Returns a subscriber that publishes an event every time the ignore user list changes

pub fn roominfo_update_receiver(&self) -> Receiver<RoomInfoUpdate>

Returns a new receiver that gets events for all future room info updates.

Each event contains the room and a boolean whether this event should trigger a room list update.

impl BaseClient

pub async fn process_sliding_sync_e2ee( &self, extensions: &Extensions ) -> Result<Vec<Raw<AnyToDeviceEvent>>>

Available on crate features experimental-sliding-sync and e2e-encryption only.

Processes the E2EE-related events from the Sliding Sync response.

In addition to writes to the crypto store, this may also write into the state store, in particular it may write latest-events to the state store.

pub async fn process_sliding_sync<PEP: PreviousEventsProvider>( &self, response: &Response, previous_events_provider: &PEP ) -> Result<SyncResponse>

Available on crate feature experimental-sliding-sync only.

Process a response from a sliding sync call.

Arguments

• response - The response that we received after a successful sliding sync.

Trait Implementations

impl Clone for BaseClient

fn clone(&self) -> BaseClient

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for BaseClient

Available on non-tarpaulin_include only.

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for BaseClient

fn default() -> Self

Returns the “default value” for a type.