Struct Party

pub struct Party<T: Transport> { /* private fields */ }

The party who participates in the E2EE chat.

Example

use ratchetx2::{transport::ChannelTransport, Party, SharedKeys};
use ratchetx2::rand::SystemRandom;
use ratchetx2::agreement::{EphemeralPrivateKey, X25519};

let shared_keys = SharedKeys {
    secret_key: [0; 32],
    header_key_alice: [1; 32],
    header_key_bob: [2; 32],
};
let bob_ratchetx2 = shared_keys.bob(EphemeralPrivateKey::generate(&X25519, &SystemRandom::new()).unwrap());
let alice_ratchetx2 = shared_keys.alice(&bob_ratchetx2.public_key());
let (a, b) = ChannelTransport::new();
let mut alice = Party::new(alice_ratchetx2, a, "AliceBob");
let mut bob = Party::new(bob_ratchetx2, b, "AliceBob");
alice.push("hello world").await.unwrap();
assert_eq!(bob.fetch().await.unwrap().remove(0).unwrap(), b"hello world");
alice.push("hello Bob").await.unwrap();
assert_eq!(bob.fetch().await.unwrap().remove(0).unwrap(), b"hello Bob");
bob.push("hello Alice").await.unwrap();
assert_eq!(alice.fetch().await.unwrap().remove(0).unwrap(), b"hello Alice");

Implementations

impl<T: Transport> Party<T>

pub fn new( ratchetx2: Ratchetx2, transport: T, associated_data: impl AsRef<[u8]>, ) -> Self

New a party.

Args

• associated_data: used in enryption

pub async fn push(&mut self, content: impl AsRef<[u8]>) -> Result<(), Error>

Encrypt and push a message.

Args

• content: the bytes to push, not encrypted

pub async fn fetch(&mut self) -> Result<Vec<Result<Vec<u8>, Error>>, Error>

Fetch and decrypt messages.

Returns decrypted bytes.

Trait Implementations

impl<T: Debug + Transport> Debug for Party<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.