forklaunch 1.20.1

Launch faster with forklaunch
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

use std::io::Write;

use anyhow::{Context, Result, bail};
use clap::{ArgMatches, Command};
use serde::{Deserialize, Serialize};
use termcolor::{ColorChoice, StandardStream};

use crate::{
    CliCommand,
    constants::{ERROR_FAILED_TO_SEND_REQUEST, get_platform_management_api_url},
    core::{command::command, http_client, validate::require_auth},
};

#[derive(Debug)]
pub(crate) struct StatsCommand;

impl StatsCommand {
    pub(crate) fn new() -> Self {
        Self
    }
}

impl CliCommand for StatsCommand {
    fn command(&self) -> Command {
        command("stats", "Show dead-letter queue statistics")
    }

    fn handler(&self, matches: &ArgMatches) -> Result<()> {
        let _token = require_auth()?;
        let json_output = matches.get_flag("json");

        let url = format!("{}/dlq/stats", get_platform_management_api_url());
        let response = http_client::get(&url).with_context(|| ERROR_FAILED_TO_SEND_REQUEST)?;
        if !response.status().is_success() {
            bail!(
                "Failed to get DLQ stats: {}",
                response.text().unwrap_or_default()
            );
        }
        let stats: DlqStats = response
            .json()
            .with_context(|| "Failed to parse DLQ stats response")?;

        if json_output {
            println!("{}", serde_json::to_string_pretty(&stats)?);
            return Ok(());
        }

        let mut stdout = StandardStream::stdout(ColorChoice::Always);
        writeln!(stdout)?;
        writeln!(stdout, "  total       {}", stats.total)?;
        writeln!(stdout, "  waiting     {}", stats.waiting)?;
        writeln!(stdout, "  processed   {}", stats.processed)?;
        writeln!(stdout)?;
        Ok(())
    }
}

#[derive(Debug, Deserialize, Serialize)]
struct DlqStats {
    total: u32,
    waiting: u32,
    processed: u32,
}

#[cfg(test)]
mod tests {
    use super::*;

    fn stats_cmd() -> Command {
        StatsCommand::new().command().version("0.0.0-test")
    }

    #[test]
    fn command_definition_is_valid() {
        stats_cmd().debug_assert();
    }

    #[test]
    fn dlq_stats_deserializes() {
        let json = r#"{"total": 5, "waiting": 2, "processed": 3}"#;
        let stats: DlqStats = serde_json::from_str(json).unwrap();
        assert_eq!(stats.total, 5);
    }
}