geist_bootloader 0.1.10

bootloader & cli for controlling Geist
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

use clap::{Args, Parser, Subcommand};

#[derive(Parser)]
#[clap(version = "1.0", about = "Geist Command Line Interface")]
struct Cli {
    #[clap(subcommand)]
    pub command: Commands,
}

#[derive(Subcommand)]
enum Commands {
    /// Tails the logs from the geist
    Logs,
    Service(ServiceCommand),
    /// Checks the status of the Geist service
    Status,
    Start(StartOpts),
    /// Stops geist
    Stop,
    Topic(TopicCommand),
    /// Prints the version of geist
    Version,
    Update(UpdateOpts),
    /// Opens an interactive shell in the Geist container
    Exec,
}

#[derive(Args)]
/// Starts geist
struct StartOpts {
    #[clap(short, long)]
    version: Option<String>,
    /// Optional path to the .env file
    #[clap(short, long)]
    env_file: Option<String>,
}

#[derive(Args)]
/// Updates the geist to a specific version
struct UpdateOpts {
    #[clap(short, long)]
    version: Option<String>,
}

// Wrapper structs
#[derive(Args)]
struct ServiceCommand {
    #[clap(subcommand)]
    pub opt: ServiceOpts,
}

#[derive(Subcommand)]
/// Commands for interacting with Geist services
enum ServiceOpts {
    /// List all services
    List,
}

#[derive(Args)]
struct TopicCommand {
    #[clap(subcommand)]
    pub opt: TopicOpts,
}

#[derive(Subcommand)]
/// Commands for interacting with Geist topics
enum TopicOpts {
    /// List all topics
    List,
    /// Get the type of a topic
    Type { name: String },
    /// Echo a topic
    Echo { name: String },
}

#[derive(Args)]
struct VersionOpts {}

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let cli = Cli::parse();

    match &cli.command {
        Commands::Logs => geist_bootloader::logs().await?,
        Commands::Service(service_command) => match &service_command.opt {
            ServiceOpts::List => geist_bootloader::list_services().await?,
        },
        Commands::Start(start_opts) => {
            geist_bootloader::start(start_opts.version.clone(), start_opts.env_file.clone()).await?
        }
        Commands::Stop => geist_bootloader::stop().await?,
        Commands::Topic(topic_command) => match &topic_command.opt {
            TopicOpts::List => geist_bootloader::list_topics().await?,
            TopicOpts::Type { name } => geist_bootloader::get_topic_type(name.clone()).await?,
            TopicOpts::Echo { name } => geist_bootloader::echo_topic(name.clone()).await?,
        },
        Commands::Version => geist_bootloader::version().await?,
        Commands::Update(update_opts) => {
            geist_bootloader::update(update_opts.version.clone()).await?
        }
        Commands::Status => {
            geist_bootloader::status().await?;
        }
        Commands::Exec => {
            geist_bootloader::exec().await?;
        }
    }
    Ok(())
}