paygress-cli 0.1.9

Pay-per-use compute marketplace using Cashu ecash and Nostr — no accounts, no signups
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

// Paygress CLI - Command Line Interface

use clap::{Parser, Subcommand};
use colored::Colorize;

mod api;
mod commands;
mod exec_client;

use commands::{batch, bootstrap, deploy, exec, list, mcp, provider, spawn, status, system, topup};

/// Paygress CLI - Pay-per-Use Compute with Lightning + Nostr
#[derive(Parser)]
#[command(name = "paygress-cli")]
#[command(author = "Dhananjay Purohit")]
#[command(version = env!("CARGO_PKG_VERSION"))]
#[command(about = "CLI tool for Paygress - spawn compute with Lightning + Nostr", long_about = None)]
struct Cli {
    /// Enable verbose output
    #[arg(short, long, global = true)]
    verbose: bool,

    #[command(subcommand)]
    command: Commands,
}

#[derive(Subcommand)]
enum Commands {
    // ============ Consumer Commands ============
    /// Discover providers and their offers
    List(list::ListArgs),

    /// Spawn a new workload with Cashu payment
    Spawn(spawn::SpawnArgs),

    /// Deploy an opinionated template (Unit 9)
    Deploy(deploy::DeployArgs),

    /// Top up an existing workload with additional payment
    Topup(topup::TopupArgs),

    /// Get status of a workload
    Status(status::StatusArgs),

    /// Fan-out N workloads in parallel for map-reduce shards, CI
    /// matrices, and embarrassingly-parallel batch jobs.
    Batch(batch::BatchArgs),

    /// Run a Model Context Protocol (MCP) server over stdio so AI
    /// harnesses (Claude Desktop, Claude Code, Cline, Cursor, ...)
    /// can spawn / batch / discover providers as native tools.
    Mcp(mcp::McpArgs),

    /// Run a shell command inside a spawned agent-sandbox workload
    /// via its baked-in HTTP exec server. Returns stdout/stderr/exit.
    Exec(exec::ExecArgs),

    // ============ Provider Commands ============
    /// Provider management - setup, start, stop, status
    Provider(provider::ProviderArgs),

    /// One-click bootstrap - set up a server as a Paygress provider
    Bootstrap(bootstrap::BootstrapArgs),

    /// System management - reset, clean up
    System(system::SystemArgs),
}

fn print_banner() {
    println!("{}", "PAYGRESS CLI".blue().bold());
    println!("{}", "Pay-per-Use Compute with Lightning + Nostr".blue());
    println!();
}

#[tokio::main]
async fn main() {
    tracing_subscriber::fmt()
        .with_env_filter(
            tracing_subscriber::EnvFilter::try_from_default_env()
                .unwrap_or_else(|_| tracing_subscriber::EnvFilter::new("info")),
        )
        .with_writer(std::io::stderr)
        .init();

    let cli = Cli::parse();

    if cli.verbose {
        print_banner();
    }

    let result = match cli.command {
        // Consumer
        Commands::List(args) => list::execute(args, cli.verbose).await,
        Commands::Spawn(args) => spawn::execute(args, cli.verbose).await,
        Commands::Deploy(args) => deploy::execute(args, cli.verbose).await,
        Commands::Topup(args) => topup::execute(args, cli.verbose).await,
        Commands::Status(args) => status::execute(args, cli.verbose).await,
        Commands::Batch(args) => batch::execute(args, cli.verbose).await,
        Commands::Mcp(args) => mcp::execute(args, cli.verbose).await,
        Commands::Exec(args) => exec::execute(args, cli.verbose).await,

        // Provider
        Commands::Provider(args) => provider::execute(args, cli.verbose).await,
        Commands::Bootstrap(args) => bootstrap::execute(args, cli.verbose).await,
        Commands::System(args) => system::execute(args, cli.verbose).await,
    };

    if let Err(e) = result {
        eprintln!("{} {}", "Error:".red().bold(), e);
        std::process::exit(1);
    }
}