ruststream 0.7.1

Async messaging framework for Rust: broker-agnostic traits, router, codecs, and a conformance harness for broker authors.
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

//! The `ruststream` command-line tool.
//!
//! A thin driver over `cargo`. A `RustStream` service is a normal binary whose `main` is generated
//! by `#[ruststream::app]`; this tool does not introspect it. Instead:
//!
//! - `ruststream run` shells out to `cargo run -- run` against the target crate.
//! - `ruststream asyncapi gen` shells out to `cargo run -- asyncapi gen`.
//!
//! Scaffolding a new project is `cargo generate` against a template: the in-memory starter lives
//! in this repo under `templates/memory`, and brokers own theirs.

#![forbid(unsafe_code)]

use std::path::PathBuf;

use anyhow::Result;
use clap::{Parser, Subcommand};

mod cargo;

/// `RustStream` command-line tool.
#[derive(Debug, Parser)]
#[command(name = "ruststream", version, about)]
struct Cli {
    #[command(subcommand)]
    command: Command,
}

#[derive(Debug, Subcommand)]
enum Command {
    /// Run a RustStream service (cargo run -- run against the target crate).
    Run {
        /// Path to the service crate or its Cargo.toml.
        #[arg(short = 'p', long, default_value = ".")]
        manifest_path: PathBuf,
        /// Build and run in release mode.
        #[arg(long)]
        release: bool,
        /// Extra arguments forwarded to the service after `run`.
        #[arg(trailing_var_arg = true)]
        args: Vec<String>,
    },
    /// AsyncAPI tooling.
    Asyncapi {
        #[command(subcommand)]
        command: AsyncApiCommand,
    },
}

#[derive(Debug, Subcommand)]
enum AsyncApiCommand {
    /// Generate the AsyncAPI document (cargo run -- asyncapi gen against the target crate).
    Gen {
        /// Path to the service crate or its Cargo.toml.
        #[arg(short = 'p', long, default_value = ".")]
        manifest_path: PathBuf,
        /// Build and run in release mode.
        #[arg(long)]
        release: bool,
        /// Write the spec to this file instead of stdout.
        #[arg(short = 'o', long)]
        out: Option<PathBuf>,
        /// Emit YAML instead of JSON.
        #[arg(long)]
        yaml: bool,
    },
}

fn main() -> Result<()> {
    match Cli::parse().command {
        Command::Run {
            manifest_path,
            release,
            args,
        } => cargo::run(&manifest_path, release, &args),
        Command::Asyncapi {
            command:
                AsyncApiCommand::Gen {
                    manifest_path,
                    release,
                    out,
                    yaml,
                },
        } => cargo::asyncapi_gen(&manifest_path, release, out.as_deref(), yaml),
    }
}