hayate 5.1.1

High-performance completion-based QUIC transfer engine.
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

//! Standalone example demonstrating how to receive files programmatically using `HayateReceiver`.
//!
//! Run this example with:
//! ```bash
//! cargo run --example receive [port]
//! ```

use hayate::runner::HayateReceiver;
use std::net::SocketAddr;

#[compio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let args: Vec<String> = std::env::args().collect();
    let port = if args.len() > 1 {
        args[1].parse::<u16>()?
    } else {
        50001
    };

    let bind_addr = SocketAddr::from(([0, 0, 0, 0], port));
    println!("Listening for incoming Hayate connections on {bind_addr}...");

    let receiver = HayateReceiver::new().bind(bind_addr).auto_accept(false); // Ask for consent

    let (checksum, dest) = receiver
        .receive(
            ".",
            |meta| {
                println!("\nIncoming Transfer Request:");
                println!("  Name: {}", meta.filename);
                println!("  Size: {} bytes", meta.total_size);
                println!("Accepting transfer request automatically...");
                true // Accept
            },
            |bytes| {
                println!("Progress: {bytes} bytes received");
            },
        )
        .await?;

    println!("\nTransfer complete!");
    println!("Saved to: {}", dest.display());
    println!("SHA-256 Checksum: {checksum}");

    Ok(())
}