flexprice-cli 0.1.1

A beautiful terminal CLI for the FlexPrice billing platform
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

use anyhow::Result;
use clap::Subcommand;
use tabled::Tabled;

use crate::api::client::ApiClient;
use crate::api::models::{Wallet, WalletBalance, ListResponse};
use crate::cli::auth::require_auth;
use crate::utils::{output, spinner};

#[derive(Subcommand)]
pub enum WalletCommands {
    /// List all wallets
    List {
        #[arg(long)]
        json: bool,
    },
    /// Get a wallet by ID
    Get {
        id: String,
        #[arg(long)]
        json: bool,
    },
    /// Create a new wallet from a JSON file
    Create {
        #[arg(long)]
        json: String,
    },
    /// Top up a wallet
    TopUp {
        /// Wallet ID
        id: String,
        /// JSON body with top-up details
        #[arg(long)]
        json: String,
    },
    /// Get real-time wallet balance
    Balance {
        id: String,
        #[arg(long)]
        json: bool,
    },
}

#[derive(Tabled, serde::Serialize)]
struct WalletRow {
    #[tabled(rename = "ID")]
    id: String,
    #[tabled(rename = "Customer")]
    customer_id: String,
    #[tabled(rename = "Balance")]
    balance: String,
    #[tabled(rename = "Currency")]
    currency: String,
    #[tabled(rename = "Status")]
    status: String,
}

impl From<Wallet> for WalletRow {
    fn from(w: Wallet) -> Self {
        Self {
            id: w.id,
            customer_id: w.customer_id.unwrap_or_default(),
            balance: w.balance.map(|b| format!("{:.2}", b)).unwrap_or_default(),
            currency: w.currency.unwrap_or_default(),
            status: w.wallet_status.map(|s| output::status_badge(&s)).unwrap_or_default(),
        }
    }
}

pub async fn handle(cmd: WalletCommands) -> Result<()> {
    let creds = require_auth()?;
    let client = ApiClient::new(creds)?;

    match cmd {
        WalletCommands::List { json } => {
            let sp = spinner::create_spinner("Fetching wallets...");
            let resp: ListResponse<Wallet> = client.get("/v1/wallets").await?;
            sp.finish_and_clear();
            let rows: Vec<WalletRow> = resp.items.into_iter().map(Into::into).collect();
            println!("{}", output::print_table(&rows, json));
        }
        WalletCommands::Get { id, json } => {
            let sp = spinner::create_spinner("Fetching wallet...");
            let wallet: Wallet = client.get(&format!("/v1/wallets/{}", id)).await?;
            sp.finish_and_clear();
            println!("{}", output::print_detail(&wallet, json));
        }
        WalletCommands::Create { json: file } => {
            let data = std::fs::read_to_string(&file)?;
            let body: serde_json::Value = serde_json::from_str(&data)?;
            let sp = spinner::create_spinner("Creating wallet...");
            let wallet: Wallet = client.post("/v1/wallets", &body).await?;
            sp.finish_and_clear();
            output::success(&format!("Wallet created: {}", wallet.id));
            println!("{}", output::print_detail(&wallet, false));
        }
        WalletCommands::TopUp { id, json: file } => {
            let data = std::fs::read_to_string(&file)?;
            let body: serde_json::Value = serde_json::from_str(&data)?;
            let sp = spinner::create_spinner("Topping up wallet...");
            let resp: serde_json::Value = client.post(&format!("/v1/wallets/{}/top-up", id), &body).await?;
            sp.finish_and_clear();
            output::success(&format!("Wallet {} topped up.", id));
            println!("{}", output::print_detail(&resp, false));
        }
        WalletCommands::Balance { id, json } => {
            let sp = spinner::create_spinner("Fetching balance...");
            let balance: WalletBalance = client.get(&format!("/v1/wallets/{}/balance/real-time", id)).await?;
            sp.finish_and_clear();
            println!("{}", output::print_detail(&balance, json));
        }
    }
    Ok(())
}