hitbox-http 0.2.1

Cacheable HTTP Request and Response
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
84
85

use bytes::Bytes;
use hitbox::predicate::{Predicate, PredicateExt, PredicateResult};
use hitbox_http::predicates::NeutralRequestPredicate;
use hitbox_http::predicates::request::header;
use hitbox_http::predicates::request::query;
use hitbox_http::predicates::request::{
    HeaderPredicate, MethodPredicate, PathPredicate, QueryPredicate,
};
use hitbox_http::{BufferedBody, CacheableHttpRequest};
use http::Request;
use http_body_util::Empty;

#[tokio::test]
async fn test_conditions_or_cacheable() {
    let request = CacheableHttpRequest::from_request(
        Request::builder()
            .method("GET")
            .body(BufferedBody::Passthrough(Empty::<Bytes>::new()))
            .unwrap(),
    );
    let correct_predicate = NeutralRequestPredicate::new().method(http::Method::GET);
    let wrong_predicate = NeutralRequestPredicate::new().method(http::Method::POST);
    let prediction = correct_predicate.or(wrong_predicate).check(request).await;
    assert!(matches!(prediction, PredicateResult::Cacheable(_)));
}

#[tokio::test]
async fn test_conditions_or_right_branch() {
    // Test that OR checks right branch when left fails
    let request = CacheableHttpRequest::from_request(
        Request::builder()
            .method("GET")
            .body(BufferedBody::Passthrough(Empty::<Bytes>::new()))
            .unwrap(),
    );
    let wrong_predicate = NeutralRequestPredicate::new().method(http::Method::POST);
    let correct_predicate = NeutralRequestPredicate::new().method(http::Method::GET);
    let prediction = wrong_predicate.or(correct_predicate).check(request).await;
    assert!(matches!(prediction, PredicateResult::Cacheable(_)));
}

#[tokio::test]
async fn test_conditions_or_noncacheable() {
    let request = CacheableHttpRequest::from_request(
        Request::builder()
            .method("GET")
            .body(BufferedBody::Passthrough(Empty::<Bytes>::new()))
            .unwrap(),
    );
    let wrong_predicate_one = NeutralRequestPredicate::new().method(http::Method::DELETE);
    let wrong_predicate_two = NeutralRequestPredicate::new().method(http::Method::POST);
    let prediction = wrong_predicate_one
        .or(wrong_predicate_two)
        .check(request)
        .await;
    assert!(matches!(prediction, PredicateResult::NonCacheable(_)));
}

#[tokio::test]
async fn test_conditions_not() {
    let path = "/path/to/resource/?one=two&name=value";
    let expression = "/path/to/resource/wrong/";
    let request = CacheableHttpRequest::from_request(
        Request::builder()
            .header("x-test", "test-value")
            .uri(path)
            .body(BufferedBody::Passthrough(Empty::<Bytes>::new()))
            .unwrap(),
    );
    let correct_query_predicate = NeutralRequestPredicate::<Empty<Bytes>>::new()
        .query(query::Operation::Eq("name".to_owned(), "value".to_owned()));
    let wrong_path_predicate =
        NeutralRequestPredicate::<Empty<Bytes>>::new().path(expression.into());
    let wrong_header_predicate = NeutralRequestPredicate::new().header(header::Operation::Eq(
        "x-test".parse().unwrap(),
        "wrong-test-value".parse().unwrap(),
    ));
    // Compose: correct_query AND (NOT wrong_path) AND (NOT wrong_header)
    let prediction = correct_query_predicate
        .and(wrong_path_predicate.not())
        .and(wrong_header_predicate.not())
        .check(request)
        .await;
    assert!(matches!(prediction, PredicateResult::Cacheable(_)));
}