sonda 1.12.0

CLI for Sonda — synthetic telemetry generator for testing observability pipelines
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
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133

//! Integration tests for `sonda run`.

mod common;

use std::io::Write;
use std::process::Command;

use common::sonda_bin;
use tempfile::TempDir;

const RUNNABLE_YAML: &str = "version: 2
kind: runnable
scenario_name: cpu-spike
description: A CPU spike scenario
tags: [infrastructure, cpu]

defaults:
  rate: 5
  duration: 200ms
  encoder:
    type: prometheus_text
  sink:
    type: stdout

scenarios:
  - id: m
    signal_type: metrics
    name: cpu_usage
    generator:
      type: constant
      value: 1.0
";

fn write_catalog() -> TempDir {
    let dir = TempDir::new().expect("tempdir");
    let p = dir.path().join("cpu-spike.yaml");
    std::fs::File::create(&p)
        .expect("create")
        .write_all(RUNNABLE_YAML.as_bytes())
        .expect("write");
    dir
}

#[test]
fn run_file_succeeds() {
    let mut f = tempfile::NamedTempFile::new().expect("tempfile");
    f.write_all(RUNNABLE_YAML.as_bytes()).expect("write");
    f.flush().expect("flush");
    let output = Command::new(sonda_bin())
        .args(["--quiet", "run"])
        .arg(f.path())
        .output()
        .expect("spawn sonda");
    assert!(
        output.status.success(),
        "run <file> must succeed; stderr:\n{}",
        String::from_utf8_lossy(&output.stderr)
    );
    let stdout = String::from_utf8_lossy(&output.stdout);
    assert!(stdout.contains("cpu_usage"), "metric must appear in stdout");
}

#[test]
fn run_at_name_with_catalog_succeeds() {
    let cat = write_catalog();
    let output = Command::new(sonda_bin())
        .args(["--quiet", "--catalog"])
        .arg(cat.path())
        .args(["run", "@cpu-spike"])
        .output()
        .expect("spawn sonda");
    assert!(
        output.status.success(),
        "run @name must succeed; stderr:\n{}",
        String::from_utf8_lossy(&output.stderr)
    );
    let stdout = String::from_utf8_lossy(&output.stdout);
    assert!(stdout.contains("cpu_usage"));
}

#[test]
fn run_at_name_without_catalog_errors() {
    let output = Command::new(sonda_bin())
        .args(["--quiet", "run", "@cpu-spike"])
        .output()
        .expect("spawn sonda");
    assert!(
        !output.status.success(),
        "run @name without --catalog must fail"
    );
    let stderr = String::from_utf8_lossy(&output.stderr);
    assert!(
        stderr.contains("--catalog"),
        "error must mention --catalog, got: {stderr}"
    );
}

#[test]
fn run_at_unknown_name_errors_with_catalog_and_name() {
    let cat = write_catalog();
    let output = Command::new(sonda_bin())
        .args(["--quiet", "--catalog"])
        .arg(cat.path())
        .args(["run", "@no-such-thing"])
        .output()
        .expect("spawn sonda");
    assert!(!output.status.success());
    let stderr = String::from_utf8_lossy(&output.stderr);
    assert!(
        stderr.contains("no-such-thing"),
        "error must name missing entry, got: {stderr}"
    );
    assert!(
        stderr.contains(&cat.path().display().to_string()) || stderr.contains("available"),
        "error must mention catalog dir or list candidates, got: {stderr}"
    );
}

#[test]
fn run_at_name_with_overrides_applies_them() {
    let cat = write_catalog();
    let output = Command::new(sonda_bin())
        .args(["--quiet", "--catalog"])
        .arg(cat.path())
        .args(["run", "@cpu-spike", "--duration", "100ms", "--rate", "20"])
        .output()
        .expect("spawn sonda");
    assert!(
        output.status.success(),
        "overrides on @name must succeed; stderr:\n{}",
        String::from_utf8_lossy(&output.stderr)
    );
}