vantage-api-client 2.2.2

Vantage extension for REST and GraphQL HTTP API backends
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
86
87
88
89
90
91

//! `GraphqlApi` on the resilient transport.

mod support;

use std::sync::Arc;
use std::time::Duration;

use serde_json::Map;
use support::{Recorder, mount, mount_n, recorder, requests, test_client};
use vantage_api_client::{GraphqlApi, Priority};
use wiremock::MockServer;

fn api(server: &MockServer, rec: &Arc<Recorder>) -> GraphqlApi {
    GraphqlApi::builder(server.uri())
        .observer("gql", rec.clone())
        .http_client(test_client())
        .build()
}

#[tokio::test]
async fn background_post_makes_one_attempt_and_keeps_the_body() {
    let server = MockServer::start().await;
    mount(
        &server,
        "POST",
        400,
        r#"{"errors":[{"message":"Unknown argument find"}]}"#,
    )
    .await;
    let rec = recorder();
    let api = api(&server, &rec);
    let err = api
        .post_graphql("{ missions { id } }", &Map::new())
        .await
        .unwrap_err();
    let text = err.to_string();
    assert!(text.contains("400"), "{text}");
    assert!(
        text.contains("Unknown argument"),
        "server message kept: {text}"
    );
    assert_eq!(requests(&server).await, 1);
    assert_eq!(rec.tags(), ["started", "failed:status"]);
    assert!(rec.keys().iter().all(|k| k == "gql"));
}

#[tokio::test]
async fn essential_post_retries_5xx() {
    let server = MockServer::start().await;
    mount_n(&server, "POST", 502, "", 2).await;
    mount(
        &server,
        "POST",
        200,
        r#"{"data":{"missions":[{"id":"m1"}]}}"#,
    )
    .await;
    let rec = recorder();
    let api = api(&server, &rec);
    let data = tokio::time::timeout(
        Duration::from_secs(5),
        Priority::Essential.scope(api.post_graphql("{ missions { id } }", &Map::new())),
    )
    .await
    .expect("finishes")
    .expect("succeeds");
    assert_eq!(data["missions"][0]["id"], "m1");
    assert_eq!(requests(&server).await, 3);
}

#[tokio::test]
async fn graphql_errors_in_a_200_are_joined_and_not_retried() {
    let server = MockServer::start().await;
    mount(
        &server,
        "POST",
        200,
        r#"{"data":null,"errors":[{"message":"first"},{"message":"second"}]}"#,
    )
    .await;
    let rec = recorder();
    let api = api(&server, &rec);
    let err = Priority::Essential
        .scope(api.post_graphql("{ x }", &Map::new()))
        .await
        .unwrap_err()
        .to_string();
    assert!(err.contains("first; second"), "{err}");
    assert_eq!(requests(&server).await, 1);
    assert_eq!(rec.tags(), ["started", "ok:200"]);
}