grpctestify 1.6.2

gRPC testing utility written in Rust
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

// Test server binary - starts all reference gRPC servers
// Usage: cargo run --bin test-server --features test-servers -- --port 50051

use std::env;
use tokio::signal;

mod servers;

use servers::{TestServerConfig, start_all_test_servers};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let args: Vec<String> = env::args().collect();

    // Parse port from arguments
    let port = args
        .iter()
        .position(|arg| arg == "--port")
        .and_then(|i| args.get(i + 1))
        .and_then(|p| p.parse::<u16>().ok())
        .unwrap_or(50051);

    let config = TestServerConfig {
        host: "127.0.0.1".to_string(),
        port,
    };

    println!("🚀 Starting test servers...");
    println!("   Echo server:       {}:{}", config.host, config.port);
    println!("   Auth server:       {}:{}", config.host, config.port + 1);
    println!("   Validation server: {}:{}", config.host, config.port + 2);
    println!();

    // Start all servers
    let handles = start_all_test_servers(config.clone()).await?;

    println!("✅ All servers started");
    println!("   Press Ctrl+C to stop");
    println!();

    // Wait for Ctrl+C
    signal::ctrl_c().await?;

    println!();
    println!("🛑 Shutting down servers...");

    // Stop all servers
    for handle in handles {
        handle.stop();
    }

    println!("✅ All servers stopped");

    Ok(())
}