Struct ProxyServer 

pub struct ProxyServer { /* private fields */ }

The proxy server that accepts client connections and relays messages.

This server handles:

• Client authentication using MlDsa65 challenge-response
• Rendezvous code generation and lookup
• Message routing between authenticated clients
• Automatic cleanup of expired rendezvous codes

Examples

Run a standalone server:

use ap_proxy::server::ProxyServer;
use std::net::SocketAddr;

let addr: SocketAddr = "127.0.0.1:8080".parse()?;
let server = ProxyServer::new(addr);

println!("Starting proxy server on {}", addr);
server.run().await?;

Embed in an application with cancellation:

use ap_proxy::server::ProxyServer;
use std::net::SocketAddr;
use tokio::signal;

let addr: SocketAddr = "127.0.0.1:8080".parse()?;
let server = ProxyServer::new(addr);

tokio::select! {
    result = server.run() => {
        result?;
    }
    _ = signal::ctrl_c() => {
        println!("Shutting down...");
    }
}

Implementations

impl ProxyServer

pub fn new(bind_addr: SocketAddr) -> Self

Create a new proxy server that will listen on the given address.

This does not start the server - call run() to begin accepting connections.

Examples

use ap_proxy::server::ProxyServer;
use std::net::SocketAddr;

let addr: SocketAddr = "127.0.0.1:8080".parse().unwrap();
let server = ProxyServer::new(addr);

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

Run the proxy server, accepting and handling connections.

This method:

1. Binds to the configured address
2. Spawns a background task to clean up expired rendezvous codes
3. Accepts incoming WebSocket connections
4. Spawns a handler task for each connection
5. Runs indefinitely until an error occurs or cancelled

Cancellation

Use tokio::select! or similar to cancel the server:

use ap_proxy::server::ProxyServer;
use std::net::SocketAddr;
use tokio::signal;

let addr: SocketAddr = "127.0.0.1:8080".parse()?;
let server = ProxyServer::new(addr);

tokio::select! {
    result = server.run() => result?,
    _ = signal::ctrl_c() => {
        println!("Shutting down gracefully");
    }
}

Errors

Returns an error if:

• The bind address is already in use
• The address is invalid or cannot be bound
• A network error occurs

Examples

use ap_proxy::server::ProxyServer;
use std::net::SocketAddr;

let addr: SocketAddr = "127.0.0.1:8080".parse()?;
let server = ProxyServer::new(addr);
server.run().await?;

pub async fn run_with_listener( &self, listener: TcpListener, ) -> Result<(), ProxyError>

Run the proxy server using an already-bound TcpListener.

This is useful in tests to avoid the race condition of binding a port, dropping the listener, and re-binding.