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

use std::error::Error;
use tracing::info;
use vstp::{
    tcp::VstpTcpServer,
    types::{Frame, FrameType, SessionId},
};

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

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

    // Bind to default port
    let server = VstpTcpServer::bind("127.0.0.1:6969").await?;

    // Run the server with our handler
    server.run(handle_frame).await?;

    Ok(())
}

/// Handle incoming frames from clients
async fn handle_frame(session_id: SessionId, frame: Frame) {
    info!("Session {}: Received {:?} frame", session_id, frame.typ);

    match frame.typ {
        FrameType::Hello => {
            info!("Session {}: Client said HELLO, sending WELCOME", session_id);
            // In a real implementation, you'd send a WELCOME frame back
        }
        FrameType::Data => {
            if let Ok(payload_str) = String::from_utf8(frame.payload.clone()) {
                info!("Session {}: Received data: {}", session_id, payload_str);
            } else {
                info!(
                    "Session {}: Received binary data ({} bytes)",
                    session_id,
                    frame.payload.len()
                );
            }
        }
        FrameType::Bye => {
            info!("Session {}: Client said BYE", session_id);
        }
        FrameType::Ping => {
            info!("Session {}: Received PING", session_id);
            // In a real implementation, you'd send PONG back
        }
        _ => {
            info!(
                "Session {}: Received frame type: {:?}",
                session_id, frame.typ
            );
        }
    }
}