Struct NetCrypto

pub struct NetCrypto { /* private fields */ }

Struct that manages crypto connections to friends and handles net crypto packets from both UDP and TCP connections.

Implementations

impl NetCrypto

pub fn new(args: NetCryptoNewArgs) -> NetCrypto

Create new NetCrypto object

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

Add a friend to accept incoming connections from him.

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

Remove a friend to stop accepting incoming connections from him.

pub async fn add_connection( &self, peer_real_pk: PublicKey, peer_dht_pk: PublicKey, )

Add connection to a friend when its DHT PublicKey is known.

pub async fn kill_connection( &self, real_pk: PublicKey, ) -> Result<(), KillConnectionError>

Kill a connection sending PACKET_ID_KILL packet and removing it from the connections list.

pub async fn set_friend_udp_addr(&self, real_pk: PublicKey, saddr: SocketAddr)

Set friend’s UDP IP address when it gets known.

pub async fn send_lossless( &self, real_pk: PublicKey, packet: Vec<u8>, ) -> Result<(), SendLosslessPacketError>

Send lossless packet to a friend via established connection.

pub async fn handle_udp_cookie_request( &self, packet: &CookieRequest, addr: SocketAddr, ) -> Result<(), HandlePacketError>

Handle CookieRequest packet received from UDP socket

pub async fn handle_tcp_cookie_request( &self, packet: &CookieRequest, sender_pk: PublicKey, ) -> Result<(), HandlePacketError>

Handle CookieRequest packet received from TCP socket

pub async fn handle_cookie_response( &self, connection: &mut CryptoConnection, packet: &CookieResponse, ) -> Result<(), HandlePacketError>

Handle CookieResponse and if it’s correct change connection status to HandshakeSending.

pub async fn handle_udp_cookie_response( &self, packet: &CookieResponse, addr: SocketAddr, ) -> Result<(), HandlePacketError>

Handle CookieResponse packet received from UDP socket

pub async fn handle_tcp_cookie_response( &self, packet: &CookieResponse, sender_pk: PublicKey, ) -> Result<(), HandlePacketError>

Handle CookieResponse packet received from TCP socket

pub async fn handle_crypto_handshake( &self, connection: &mut CryptoConnection, packet: &CryptoHandshake, ) -> Result<(), HandlePacketError>

Handle CryptoHandshake and if it’s correct change connection status to NotConfirmed.

pub async fn handle_udp_crypto_handshake( &self, packet: &CryptoHandshake, addr: SocketAddr, ) -> Result<(), HandlePacketError>

Handle CryptoHandshake packet received from UDP socket

pub async fn handle_tcp_crypto_handshake( &self, packet: &CryptoHandshake, sender_pk: PublicKey, ) -> Result<(), HandlePacketError>

Handle CryptoHandshake packet received from TCP socket

pub async fn handle_udp_crypto_data( &self, packet: &CryptoData, addr: SocketAddr, ) -> Result<(), HandlePacketError>

Handle CryptoData packet received from UDP socket

pub async fn handle_tcp_crypto_data( &self, packet: &CryptoData, sender_pk: PublicKey, ) -> Result<(), HandlePacketError>

Handle CryptoData packet received from TCP socket

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

Run net_crypto periodical tasks. Result future will never be completed successfully.

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_connection_status_sink( &self, connection_status_tx: UnboundedSender<(PublicKey, bool)>, )

Set sink to send a connection status when it becomes connected or disconnected.

pub async fn set_tcp_sink(&self, tcp_tx: Sender<(DataPayload, PublicKey)>)

Set sink for sending TCP packets via relays.

Trait Implementations

impl Clone for NetCrypto

fn clone(&self) -> NetCrypto

Returns a copy of the value.

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

Performs copy-assignment from source.