pdk-test 1.6.0

PDK Test
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

// Copyright (c) 2025, Salesforce, Inc.,
// All rights reserved.
// For full license text, see the LICENSE.txt file

use anyhow::Result;
use pdk_test::port::PortVisibility;
use serde_json::{json, Value};

use pdk_test::services::httpbin::{HttpBin, HttpBinConfig};
use pdk_test::{pdk_test, TestComposite, TestError};

#[pdk_test]
async fn httpbin() -> Result<()> {
    let composite = TestComposite::builder()
        .with_service(
            HttpBinConfig::builder()
                .visibility(PortVisibility::Published)
                .build(),
        )
        .build()
        .await?;

    let httpbin: HttpBin = composite.service()?;

    let response = reqwest::get(format!("{}/get", httpbin.address().unwrap())).await?;

    assert_eq!(response.status(), 200);

    let mut actual = response.json::<Value>().await?;
    actual.as_object_mut().unwrap().remove("origin");

    let expected_host = httpbin.socket().map(|s| s.trim_end_matches(":80")).unwrap();

    let expected_url = httpbin
        .address()
        .map(|s| format!("{}/get", s.trim_end_matches(":80")))
        .unwrap();

    assert_eq!(
        actual,
        json! ({
            "args": {},
            "headers": {
                "Accept": "*/*",
                "Host": expected_host,
            },
            "url": expected_url,
        })
    );

    Ok(())
}

#[pdk_test]
async fn invalid_explicit_repository() {
    let httpbin_config = HttpBinConfig::builder()
        .image_name("unknown/httpmock")
        .build();

    let result = TestComposite::builder()
        .with_service(httpbin_config)
        .build()
        .await;

    assert!(result.is_err());

    let Err(error) = result else {
        unreachable!();
    };

    assert!(matches!(error, TestError::Docker(_)));
}

#[pdk_test]
async fn valid_explicit_image_name() {
    let httpbin_config = HttpBinConfig::builder()
        .image_name("kennethreitz/httpbin")
        .build();

    let result = TestComposite::builder()
        .with_service(httpbin_config)
        .build()
        .await;

    assert!(result.is_ok());
}