Struct tox_core::net_crypto::NetCrypto

pub struct NetCrypto { /* fields omitted */ }

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<(TcpDataPayload, PublicKey)>)

Set sink for sending TCP packets via relays.

Trait Implementations

impl Clone for NetCrypto

pub fn clone(&self) -> NetCrypto

Returns a copy of the value.

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

Performs copy-assignment from source.