relay-knowledge 1.1.17

Graph-database-based knowledge graph project.
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

use crate::ports::release_metadata::{
    ReleaseMetadataError, ReleaseMetadataErrorKind, ReleaseMetadataFuture,
};

use super::*;

struct StubSession {
    result: Result<Vec<u8>, ReleaseMetadataError>,
}

impl ReleaseMetadataSession for StubSession {
    fn fetch(&self, _request: ReleaseMetadataRequest) -> ReleaseMetadataFuture<'_> {
        Box::pin(std::future::ready(self.result.clone()))
    }
}

#[tokio::test]
async fn fetch_json_maps_payloads_and_port_failures() {
    let payload: serde_json::Value = fetch_json(
        &StubSession {
            result: Ok(br#"{"version":"1.2.3"}"#.to_vec()),
        },
        "https://release.example/latest".to_owned(),
        UpdateSource::Github,
    )
    .await
    .expect("valid metadata should decode");
    let diagnostic = fetch_json::<serde_json::Value>(
        &StubSession {
            result: Err(ReleaseMetadataError {
                kind: ReleaseMetadataErrorKind::NetworkTimeout,
                message: "request timed out".to_owned(),
                retryable: true,
            }),
        },
        "https://release.example/latest".to_owned(),
        UpdateSource::Github,
    )
    .await
    .expect_err("port failure should become a source diagnostic");

    assert_eq!(payload["version"], "1.2.3");
    assert_eq!(diagnostic.code, "network_timeout");
    assert!(diagnostic.retryable);
}