El Protocolo Orzatty (PO) se distribuye como un paquete llamado 'Crate' en el ecosistema Rust. Para usarlo, simplemente debes agregarlo a la mochila de herramientas de tu proyecto, que se llama `Cargo.toml`.

# Cargo.toml
[dependencies]
po-node = { git = "https://github.com/orzattyholding/po.git" }
tokio = { version = "1.0", features = ["full"] }

Para que dos computadoras se hablen, una tiene que estar escuchando (como un oyente de radio esperando una llamada). En PO, crear un servidor toma exactamente 1 línea de código.

use po_node::Po;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 1. Abrimos el puerto 4433. ¡Ya estamos escuchando!
    let mut server = Po::bind(4433).await?;
    println!("Servidor Orzatty escuchando en modo E2EE...");

    // 2. Nos quedamos en un ciclo eterno esperando que lleguen paquetes
    while let Some((canal, datos)) = server.recv().await? {
        let mensaje_texto = String::from_utf8_lossy(&datos);
        println!("¡Recibimos un paquete!: {}", mensaje_texto);
    }
    
    Ok(())
}

Ahora que el servidor está escuchando en la puerta 4433, necesitamos que otra computadora (o un programa distinto) llame a esa puerta para establecer el túnel secreto cifrado. ¡Felicidades! A diferencia de los sistemas tradicionales como WebSockets, con Orzatty Protocol tú NO creas candados manuales. La matemática ED25519 crea el candado y la llave automáticamente.

use po_node::Po;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 1. Conectarnos a la computadora que está en nuestro mismo cuarto (127.0.0.1)
    let mut client = Po::connect("127.0.0.1:4433").await?;
    
    // 2. ¡Lanzar la data cifrada!
    let contenido = b"Este es un secreto corporativo de Orzatty";
    client.send(contenido).await?;
    
    println!("¡Paquete enviado a hiper-velocidad!");
    Ok(())
}

Si eres un Arquitecto de Sistemas intentando escalar, `send` normal cifrará 1 por 1 los mensajes. Si vas a inundar la red con miles de paquetes pequeños (Telemetría de juegos, IA), tienes que usar `send_batch()`.

use po_node::Po;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let mut client = Po::connect("127.0.0.1:4433").await?;
    
    // Creamos 5,000 mensajitos pequeños
    let mut batch_de_mensajes = Vec::new();
    for _ in 0..5000 {
        batch_de_mensajes.push(b"telemetria_diminuta".as_slice());
    }

    // Usamos el optimizador! (Aumento de velocidad de 4.8x)
    client.send_batch(&batch_de_mensajes).await?;
    
    Ok(())
}