Struct OnionClient

pub struct OnionClient { /* private fields */ }

Onion client that is responsible for announcing our DHT PublicKey to our friends and looking for their DHT PublicKeys.

Implementations

impl OnionClient

pub fn new( dht: DhtServer, tcp_connections: TcpConnections, real_sk: SecretKey, real_pk: PublicKey, ) -> Self

Create new OnionClient.

pub async fn set_dht_pk_sink( &self, dht_pk_tx: UnboundedSender<(PublicKey, PublicKey)>, )

Set sink to send DHT PublicKey when it gets known.

pub async fn set_friend_request_sink( &self, friend_request_sink: UnboundedSender<(PublicKey, FriendRequest)>, )

Set sink to receive FriendRequests.

pub async fn handle_announce_response( &self, packet: &OnionAnnounceResponse, is_global: bool, ) -> Result<(), HandleAnnounceResponseError>

Handle OnionAnnounceResponse packet.

pub async fn handle_dht_pk_announce( &self, friend_pk: PublicKey, dht_pk_announce: DhtPkAnnouncePayload, ) -> Result<(), HandleDhtPkAnnounceError>

Handle DHT PublicKey announce from both onion and DHT.

pub async fn handle_data_response( &self, packet: &OnionDataResponse, ) -> Result<(), HandleDataResponseError>

Handle OnionDataResponse packet.

pub async fn add_path_node(&self, node: PackedNode)

Add new node to random nodes pool to use them to build random paths.

pub async fn add_friend(&self, real_pk: PublicKey)

Add a friend to start looking for its DHT PublicKey.

pub async fn remove_friend(&self, real_pk: PublicKey)

Remove a friend and stop looking for him.

pub async fn set_friend_connected(&self, real_pk: PublicKey, connected: bool)

Set connection status of a friend. If he’s connected we can stop looking for his DHT PublicKey.

pub async fn set_friend_dht_pk(&self, real_pk: PublicKey, dht_pk: PublicKey)

Set friend’s DHT PublicKey when it gets known somewhere else.

pub async fn run(&self) -> Result<(), RunError>

Run periodical announcements and friends searching.

Trait Implementations

impl Clone for OnionClient

fn clone(&self) -> OnionClient

Returns a copy of the value.

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

Performs copy-assignment from source.