Struct Communication 

pub struct Communication {
    pub events: Arc<KnownEvents>,
    pub transport: Box<dyn Transport + Send + Sync>,
    pub tel_transport: Box<dyn IdentifierTelTransport + Send + Sync>,
}

Fields

events: Arc<KnownEvents>

transport: Box<dyn Transport + Send + Sync>

tel_transport: Box<dyn IdentifierTelTransport + Send + Sync>

Implementations

impl Communication

pub fn new( known_events: Arc<KnownEvents>, transport: Box<dyn Transport<ActorError> + Send + Sync>, tel_transport: Box<dyn IdentifierTelTransport + Send + Sync>, ) -> Self

pub async fn resolve_loc_schema( &self, lc: &LocationScheme, ) -> Result<(), MechanicsError>

Make http request to get identifier’s endpoints information.

pub async fn resolve_end_role(&self, er: &EndRole) -> Result<(), MechanicsError>

Make http request to get identifier’s endpoints information.

pub async fn resolve_oobi(&self, oobi: &Oobi) -> Result<(), MechanicsError>

Make http request to get identifier’s endpoints information.

pub async fn send_message_to( &self, id: IdentifierPrefix, scheme: Scheme, msg: Message, ) -> Result<(), SendingError>

pub async fn send_query_to( &self, id: &IdentifierPrefix, scheme: Scheme, query: SignedKelQuery, ) -> Result<PossibleResponse, SendingError>

pub async fn send_management_query_to( &self, id: &IdentifierPrefix, scheme: Scheme, query: SignedMailboxQuery, ) -> Result<PossibleResponse, SendingError>

pub async fn publish( &self, witness_prefixes: Vec<BasicPrefix>, message: &SignedEventMessage, ) -> Result<(), MechanicsError>

Publish key event to witnesses

1. send it to all witnesses
2. collect witness receipts and process them
3. get processed receipts from db and send it to all witnesses

pub async fn send_oobi_to_watcher( &self, id: &IdentifierPrefix, oobi: &Oobi, ) -> Result<(), ControllerError>

Sends identifier’s endpoint information to identifiers’s watchers.

pub async fn send_tel_query( &self, qry: SignedTelQuery, location: LocationScheme, ) -> Result<String, SendingError>

pub async fn send_tel_event( &self, event: VerifiableEvent, location: LocationScheme, ) -> Result<(), SendingError>