Struct Messenger 

pub struct Messenger { /* private fields */ }

Implementations

impl Messenger

pub fn open(data_dir: &Path) -> Result<Self, ServerError>

pub fn sync(&mut self) -> Result<(), MessengerError>

Re-read the ledger when it changed and bring participants and rooms in line.

pub fn send( &mut self, from: &str, to: &str, subject: &str, body: &str, idempotency_key: Option<String>, ) -> Result<String, MessengerError>

to is a node id (or hatchery.operator) or room:NAME.

pub fn inbox( &mut self, who: &str, since_ms: u64, limit: u16, ) -> Result<Vec<MailView>, MessengerError>

pub fn thread( &mut self, node: &str, limit: u16, ) -> Result<Vec<MailView>, MessengerError>

Conversation between the operator and one node, both directions, oldest first. Empty for a node that is not a mailbox (neutral, suspended, revoked).

pub fn ack(&mut self, who: &str, message_id: &str) -> Result<(), MessengerError>

pub fn is_registered(&mut self, who: &str) -> bool