vstp 0.2.1

VSTP - Vishu's Secure Transfer Protocol: A fast, secure, and extensible binary protocol for TCP and UDP
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70

//! VSTP UDP Server Example
//!
//! This example demonstrates how to use the VSTP UDP server to handle incoming frames.

use std::error::Error;
use std::net::SocketAddr;
use tracing::info;
use vstp::{types::FrameType, udp::VstpUdpServer};

#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
    // Initialize tracing
    tracing_subscriber::fmt::init();

    info!("Starting VSTP UDP Server example...");

    // Bind to UDP port 6969
    let server = VstpUdpServer::bind("127.0.0.1:6969").await?;
    let local_addr = server.local_addr()?;
    info!("Server bound to {}", local_addr);

    // Run the server with a simple frame handler
    server.run(handle_frame).await?;

    Ok(())
}

/// Handle incoming frames
async fn handle_frame(from_addr: SocketAddr, frame: vstp::types::Frame) {
    info!(
        "Received {:?} frame from {} with {} headers and {} bytes payload",
        frame.typ,
        from_addr,
        frame.headers.len(),
        frame.payload.len()
    );

    // Log frame details
    for header in &frame.headers {
        if let (Ok(key), Ok(value)) = (
            std::str::from_utf8(&header.key),
            std::str::from_utf8(&header.value),
        ) {
            info!("  Header: {} = {}", key, value);
        }
    }

    // Handle different frame types
    match frame.typ {
        FrameType::Hello => {
            info!("  -> Client said hello!");
        }
        FrameType::Data => {
            if let Ok(payload_str) = std::str::from_utf8(&frame.payload) {
                info!("  -> Data: {}", payload_str);
            } else {
                info!("  -> Data: {} bytes (binary)", frame.payload.len());
            }
        }
        FrameType::Ping => {
            info!("  -> Ping received");
        }
        FrameType::Bye => {
            info!("  -> Client said goodbye");
        }
        _ => {
            info!("  -> Other frame type: {:?}", frame.typ);
        }
    }
}