hpx-cli 2.4.30

CLI for hpx — high-performance HTTP client and download engine
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
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131

use eyre::{Result, bail, eyre};
use futures::{SinkExt, StreamExt};
use hpx_yawc::{Frame, WebSocket, close::CloseCode, proxy::ProxyConfig};

pub(crate) async fn run(proxy_url: &str) -> Result<()> {
    println!("=== HTTP Proxy Tests (proxy={proxy_url}) ===\n");

    test_http_proxy(proxy_url).await?;
    println!("[PASS] HTTP proxy (plain HTTP)\n");

    test_https_proxy(proxy_url).await?;
    println!("[PASS] HTTPS proxy (CONNECT tunnel)\n");

    println!("=== WebSocket Proxy Tests (proxy={proxy_url}) ===\n");

    test_ws_proxy(proxy_url).await?;
    println!("[PASS] WebSocket proxy (ws://echo)\n");

    test_wss_proxy(proxy_url).await?;
    println!("[PASS] WebSocket proxy (wss://echo)\n");

    println!("=== All proxy tests passed ===");
    Ok(())
}

async fn test_http_proxy(proxy_url: &str) -> Result<()> {
    let proxy = hpx::Proxy::http(proxy_url)?;
    let client = hpx::Client::builder().proxy(proxy).build()?;

    let resp = client
        .get("http://httpbin.org/ip")
        .send()
        .await
        .map_err(|e| eyre!("HTTP proxy request failed: {e}"))?;

    let status = resp.status();
    let body = resp
        .text()
        .await
        .map_err(|e| eyre!("failed to read response body: {e}"))?;

    if !status.is_success() {
        bail!("HTTP proxy returned status {status}: {body}");
    }

    println!("  status={status}, body={}", truncate(&body, 200));
    Ok(())
}

async fn test_https_proxy(proxy_url: &str) -> Result<()> {
    let proxy = hpx::Proxy::all(proxy_url)?;
    let client = hpx::Client::builder()
        .proxy(proxy)
        .cert_verification(false)
        .build()?;

    let resp = client
        .get("https://httpbin.org/ip")
        .send()
        .await
        .map_err(|e| eyre!("HTTPS proxy request failed: {e}"))?;

    let status = resp.status();
    let body = resp
        .text()
        .await
        .map_err(|e| eyre!("failed to read response body: {e}"))?;

    if !status.is_success() {
        bail!("HTTPS proxy returned status {status}: {body}");
    }

    println!("  status={status}, body={}", truncate(&body, 200));
    Ok(())
}

async fn test_ws_proxy(proxy_url: &str) -> Result<()> {
    let proxy = ProxyConfig::Http(proxy_url.parse()?);

    let mut ws = WebSocket::connect("wss://ws.postman-echo.com/raw".parse()?)
        .with_proxy(proxy)
        .await
        .map_err(|e| eyre!("WS proxy connect failed: {e}"))?;

    let msg = "hello via proxy";
    ws.send(Frame::text(msg)).await?;

    let frame = tokio::time::timeout(std::time::Duration::from_secs(10), ws.next())
        .await
        .map_err(|_| eyre!("WS echo timeout"))?
        .ok_or_else(|| eyre!("WS stream ended before echo"))?;

    let reply = String::from_utf8_lossy(frame.payload());
    if reply != msg {
        bail!("WS echo mismatch: expected {msg:?}, got {reply:?}");
    }
    println!("  echoed: {reply}");

    ws.send(Frame::close(CloseCode::Normal, b"done")).await?;
    Ok(())
}

async fn test_wss_proxy(proxy_url: &str) -> Result<()> {
    let proxy = ProxyConfig::Http(proxy_url.parse()?);

    let mut ws = WebSocket::connect("wss://ws.postman-echo.com/raw".parse()?)
        .with_proxy(proxy)
        .await
        .map_err(|e| eyre!("WSS proxy connect failed: {e}"))?;

    let msg = "hello via wss proxy";
    ws.send(Frame::text(msg)).await?;

    let frame = tokio::time::timeout(std::time::Duration::from_secs(10), ws.next())
        .await
        .map_err(|_| eyre!("WSS echo timeout"))?
        .ok_or_else(|| eyre!("WSS stream ended before echo"))?;

    let reply = String::from_utf8_lossy(frame.payload());
    if reply != msg {
        bail!("WSS echo mismatch: expected {msg:?}, got {reply:?}");
    }
    println!("  echoed: {reply}");

    ws.send(Frame::close(CloseCode::Normal, b"done")).await?;
    Ok(())
}

fn truncate(s: &str, max: usize) -> &str {
    if s.len() > max { &s[..max] } else { s }
}