base-http-client 0.3.0

Supervised pooled HTTP clients for Base scheduler capabilities
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
70
71
72
73
74
75
76
77
78
79
80
81
82
83

// Released under the MIT License.
// Copyright, 2026, by Samuel Williams.

use super::{chain, unconnected};
use base_http_client::{Client, Endpoint, Error, Options};
use base_scheduler_native::NativeScheduler;

#[test]
fn invalid_limits_are_reported_by_the_layer_that_owns_them() {
    assert!(Options::default().validate().is_ok());
    let pool = Options {
        pool: base_pool::Options {
            max_resources: 0,
            ..Default::default()
        },
        ..Default::default()
    };
    let error = pool.validate().unwrap_err();
    assert!(matches!(
        error,
        Error::Pool(base_pool::Error::InvalidOptions)
    ));
    assert_eq!(
        chain(&error),
        ["resource and construction limits must be positive"]
    );
    let http1 = Options {
        http1: base_http1::Options {
            read_size: 0,
            ..Default::default()
        },
        ..Default::default()
    };
    let error = http1.validate().unwrap_err();
    assert!(matches!(error, Error::Protocol(_)));
    assert_eq!(
        chain(&error),
        ["invalid HTTP/1 message: invalid HTTP/1 limits"]
    );
    let defaults = Options::default();
    let client = [
        Options {
            max_requests: 0,
            ..defaults.clone()
        },
        Options {
            response_buffer_frames: 0,
            ..defaults.clone()
        },
        // The response buffer must hold a complete head.
        Options {
            response_buffer_bytes: defaults.http1.max_head_bytes - 1,
            ..defaults.clone()
        },
    ];
    for options in client {
        assert!(matches!(options.validate(), Err(Error::InvalidOptions)));
    }
}

#[test]
fn clients_reject_invalid_options_before_construction() {
    let scheduler = NativeScheduler::new().unwrap();
    let endpoint = Endpoint::new("127.0.0.1:1".parse().unwrap());
    let options = Options {
        max_requests: 0,
        ..Default::default()
    };
    assert!(matches!(
        Client::new(&scheduler, endpoint, options),
        Err(Error::InvalidOptions)
    ));
}

#[test]
fn clients_report_their_endpoint() {
    unconnected(async |client| {
        let endpoint = client.endpoint();
        assert_eq!(endpoint.address, "127.0.0.1:1".parse().unwrap());
        assert_eq!(endpoint.authority.as_str(), "127.0.0.1:1");
        assert_eq!(endpoint.scheme(), "http");
    });
}