rama 0.3.0

modular service framework
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

use crate::examples::example_tests::utils::ExampleRunner;

use super::utils;

use rama::{
    http::BodyExtractExt,
    net::{
        Protocol,
        address::{ProxyAddress, SocketAddress},
        user::{Basic, ProxyCredential},
    },
    telemetry::tracing,
    utils::str::non_empty_str,
};

#[tokio::test]
#[ignore]
async fn test_proxy_connectivity_check() {
    utils::init_tracing();

    let runner = utils::ExampleRunner::interactive("proxy_connectivity_check", Some("socks5,tls"));

    // test regular proxy flow
    let result = runner
        .get("http://example.com")
        .extension(ProxyAddress::try_from("http://tom:clancy@127.0.0.1:62030").unwrap())
        .send()
        .await
        .unwrap()
        .try_into_string()
        .await
        .unwrap();
    assert!(result.contains("Connectivity Example"));
    tracing::info!("http proxy: connectivity check succeeded");

    test_http_client_over_socks5_proxy_connect(runner).await;
}

async fn test_http_client_over_socks5_proxy_connect(runner: ExampleRunner) {
    let proxy_socket_addr = SocketAddress::local_ipv4(62030);

    tracing::info!(
        network.local.address = %proxy_socket_addr.ip_addr,
        network.local.port = %proxy_socket_addr.port,
        "local servers up and running",
    );

    let proxy_address = ProxyAddress {
        protocol: Some(Protocol::SOCKS5),
        address: proxy_socket_addr.into(),
        credential: Some(ProxyCredential::Basic(Basic::new(
            non_empty_str!("john"),
            non_empty_str!("secret"),
        ))),
    };

    let resp = runner
        .get("http://example.com")
        .extension(proxy_address)
        .send()
        .await
        .expect("make http request via socks5 proxy")
        .try_into_string()
        .await
        .expect("get response text");

    assert!(resp.contains("Connectivity Example"));
    tracing::info!("socks5 proxy: connectivity check succeeded");
}