Struct OwningServerFilter

pub struct OwningServerFilter<S, FilterFn, AsyncBool>(/* private fields */);

A future that accepts a secret-handshake based on a filter function and then yields a channel that encrypts/decrypts all data via box-stream.

This copies the handshake keys so that it is not constrained by the key’s lifetime.

Implementations

impl<S, FilterFn, AsyncBool> OwningServerFilter<S, FilterFn, AsyncBool>

where S: AsyncRead + AsyncWrite, FilterFn: FnOnce(&PublicKey) -> AsyncBool, AsyncBool: Future<Item = bool>,

pub fn new( stream: S, filter_fn: FilterFn, network_identifier: [u8; 32], server_longterm_pk: PublicKey, server_longterm_sk: SecretKey, server_ephemeral_pk: PublicKey, server_ephemeral_sk: SecretKey, ) -> OwningServerFilter<S, FilterFn, AsyncBool>

Create a new OwningServerFilter to accept a connection from a client which knows the server’s public key, uses the right app key over the given stream and whose longterm public key is accepted by the filter function.

This copies the handshake keys so that it is not constrained by the key’s lifetime.

Ephemeral keypairs can be generated via sodiumoxide::crypto::box_::gen_keypair.

Trait Implementations

impl<S, FilterFn, AsyncBool> Future for OwningServerFilter<S, FilterFn, AsyncBool>

where S: AsyncRead + AsyncWrite, FilterFn: FnOnce(&PublicKey) -> AsyncBool, AsyncBool: Future<Item = bool>,

type Item = (BoxDuplex<S>, PublicKey)

On success, the result contains the encrypted connection and the longterm public key of the client.

type Error = (FilteringHandshakeError<<AsyncBool as Future>::Error>, S)

An error

fn poll(&mut self, cx: &mut Context<'_>) -> Poll<Self::Item, Self::Error>

Attempt to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.