Struct MessageSender

pub struct MessageSender<S> { /* private fields */ }

Implementations

impl<S> MessageSender<S>

where S: ProtocolStore + SenderKeyStore + SessionStoreExt + Sync + Clone,

pub fn new( identified_ws: SignalWebSocket, unidentified_ws: SignalWebSocket, service: PushService, cipher: ServiceCipher<S>, protocol_store: S, local_aci: impl Into<Aci>, local_pni: impl Into<Pni>, aci_identity: IdentityKeyPair, pni_identity: Option<IdentityKeyPair>, device_id: DeviceId, ) -> Self

pub async fn upload_attachment<R: Rng + CryptoRng>( &mut self, spec: AttachmentSpec, contents: Vec<u8>, csprng: &mut R, ) -> Result<AttachmentPointer, AttachmentUploadError>

Encrypts and uploads an attachment

Contents are accepted as an owned, plain text Vec, because encryption happens in-place.

pub async fn send_message( &mut self, recipient: &ServiceId, unidentified_access: Option<UnidentifiedAccess>, message: impl Into<ContentBody>, timestamp: u64, include_pni_signature: bool, online: bool, ) -> SendMessageResult

Send a message content to a single recipient.

pub async fn send_message_to_group( &mut self, recipients: impl AsRef<[(ServiceId, Option<UnidentifiedAccess>, bool)]>, message: impl Into<ContentBody>, timestamp: u64, online: bool, ) -> Vec<SendMessageResult>

Send a message to the recipients in a group.

Recipients are a list of tuples, each containing:

• The recipient’s address
• The recipient’s unidentified access
• Whether the recipient requires a PNI signature

pub async fn send_contact_details<Contacts>( &mut self, recipient: &ServiceId, unidentified_access: Option<UnidentifiedAccess>, contacts: Contacts, online: bool, complete: bool, ) -> Result<(), MessageSenderError>

where Contacts: IntoIterator<Item = ContactDetails>,

Upload contact details to the CDN and send a sync message

pub async fn send_configuration( &mut self, recipient: &ServiceId, configuration: Configuration, ) -> Result<(), MessageSenderError>

Send Configuration synchronization message

pub async fn send_message_request_response( &mut self, recipient: &ServiceId, thread: &ThreadIdentifier, action: Type, ) -> Result<(), MessageSenderError>

Send MessageRequestResponse synchronization message with either a recipient ACI or a GroupV2 ID

pub async fn send_keys( &mut self, recipient: &ServiceId, keys: Keys, ) -> Result<(), MessageSenderError>

Send Keys synchronization message

pub async fn send_sync_message_request( &mut self, recipient: &ServiceId, request_type: Type, ) -> Result<(), MessageSenderError>

Send a Keys request message

Trait Implementations

impl<S: Clone> Clone for MessageSender<S>

fn clone(&self) -> MessageSender<S>

Returns a copy of the value.

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

Performs copy-assignment from source.