lightshuttle-manifest 0.4.0

Manifest types, parser, and JSON Schema for LightShuttle
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
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115

//! Tests for the optional `export` manifest section: parsing,
//! round-trip and resource-reference validation.

use lightshuttle_manifest::{ImagePullPolicy, Manifest, ManifestError};

const WITH_EXPORT: &str = r"
project:
  name: app
export:
  compose:
    resources:
      worker:
        enabled: false
  kubernetes:
    namespace: my-ns
    image_pull_policy: Always
    replicas: 2
    resources:
      api:
        replicas: 3
        image_pull_policy: IfNotPresent
  helm:
    chart_name: my-chart
    chart_version: 1.2.3
    resources:
      api:
        replicas: 4
resources:
  api:
    container:
      image: alpine
  worker:
    container:
      image: alpine
";

#[test]
fn parses_export_section() {
    let manifest = Manifest::parse(WITH_EXPORT).expect("manifest with export parses");
    let export = manifest.export.expect("export section present");

    let kubernetes = export.kubernetes.expect("kubernetes target present");
    assert_eq!(kubernetes.namespace.as_deref(), Some("my-ns"));
    assert_eq!(kubernetes.image_pull_policy, Some(ImagePullPolicy::Always));
    assert_eq!(kubernetes.replicas, Some(2));
    assert_eq!(kubernetes.resources["api"].replicas, Some(3));

    let helm = export.helm.expect("helm target present");
    assert_eq!(helm.chart_name.as_deref(), Some("my-chart"));
    assert_eq!(helm.chart_version.as_deref(), Some("1.2.3"));

    let compose = export.compose.expect("compose target present");
    assert_eq!(compose.resources["worker"].enabled, Some(false));
}

#[test]
fn round_trips_export_section() {
    let original = Manifest::parse(WITH_EXPORT).expect("parse");
    let yaml = original.to_yaml().expect("to_yaml");
    let reparsed = Manifest::parse(&yaml).expect("re-parse");
    assert_eq!(original, reparsed);
}

#[test]
fn absent_export_is_none() {
    let yaml = r"
project:
  name: app
resources:
  api:
    container:
      image: alpine
";
    let manifest = Manifest::parse(yaml).expect("parse");
    assert!(manifest.export.is_none(), "absent export must be None");
}

#[test]
fn rejects_override_for_unknown_resource() {
    let yaml = r"
project:
  name: app
export:
  kubernetes:
    resources:
      ghost:
        replicas: 2
resources:
  api:
    container:
      image: alpine
";
    let err = Manifest::parse(yaml).expect_err("unknown override resource is rejected");
    assert!(
        matches!(err, ManifestError::UnknownResource(ref m) if m.contains("ghost")),
        "got: {err:?}"
    );
}

#[test]
fn rejects_unknown_field_in_export() {
    let yaml = r"
project:
  name: app
export:
  kubernetes:
    bogus: true
resources:
  api:
    container:
      image: alpine
";
    let err = Manifest::parse(yaml).expect_err("unknown field is rejected");
    assert!(matches!(err, ManifestError::Yaml(_)), "got: {err:?}");
}