chore: make batch interactive

src/client/mod.rs

@@ -12,6 +12,8 @@ use batch::Batch;
 
 use rust_decimal::Decimal;
 
+use std::io;
+
 pub struct GaloyClient {
     graphql_client: Client,
     api: String,
@@ -179,8 +181,7 @@ impl GaloyClient {
         }
     }
 
-    // TODO: check if we can do self without &
-    pub fn batch(self, filename: String, price: Decimal) -> anyhow::Result<()> {
+    pub fn batch(self, filename: String, price: Decimal, force: bool) -> anyhow::Result<()> {
         let mut batch = Batch::new(self, price);
 
         batch.add_csv(filename).context("can't load file")?;
@@ -196,6 +197,20 @@ impl GaloyClient {
         println!("going to execute:");
         batch.show();
 
+        if !force {
+            println!("do you want to confirm? y/n");
+
+            let mut input = String::new();
+
+            io::stdin()
+                .read_line(&mut input)
+                .expect("error: unable to read user input");
+
+            if !(input.trim() == "y" || input.trim() == "yes") {
+                bail!("didn't confirm batch payment. exiting")
+            }
+        }
+
         batch.execute().context("can't make payment successfully")?;
 
         Ok(())

src/main.rs

@@ -7,7 +7,7 @@ use url::Url;
 
 use galoy_client::GaloyClient;
 
-use anyhow::Context;
+use anyhow::{bail, Context};
 
 use jsonwebtoken::decode_header;
 
@@ -61,7 +61,12 @@ enum Commands {
     /// get JWT of an account
     Login { phone: String, code: String },
     /// execute a batch payment
-    Batch { filename: String, price: Decimal },
+    Batch {
+        filename: String,
+        price: Decimal,
+        #[clap(short, long)]
+        force: bool,
+    },
 }
 
 fn main() -> anyhow::Result<()> {
@@ -83,7 +88,7 @@ fn main() -> anyhow::Result<()> {
     }
 
     info!("using api: {api} and jwt: {:?}", &jwt);
-    let galoy_client = GaloyClient::new(api, jwt);
+    let galoy_client = GaloyClient::new(api, jwt.clone());
 
     match cli.command {
         Commands::Getinfo {} => {
@@ -94,7 +99,24 @@ fn main() -> anyhow::Result<()> {
             let result = galoy_client.default_wallet(username)?;
             println!("{:#?}", result);
         }
+        Commands::RequestPhoneCode { phone } => {
+            let result = galoy_client
+                .request_auth_code(phone)
+                .context("issue getting code")?;
+            println!("{:#?}", result);
+        }
+        Commands::Login { phone, code } => {
+            let result = galoy_client
+                .user_login(phone, code)
+                .context("issue logging in")?;
+            println!("{:#?}", result);
+        }
+
         Commands::Me => {
+            if jwt.is_none() {
+                bail!("need JWT");
+            }
+
             let result = galoy_client.me().context("can't get me")?;
             println!("{:#?}", result);
         }
@@ -103,26 +125,26 @@ fn main() -> anyhow::Result<()> {
             amount,
             memo,
         } => {
+            if jwt.is_none() {
+                bail!("need JWT");
+            }
+
             let result = galoy_client
                 .intraleger_send(username, amount, memo)
                 .context("issue sending intraledger")?;
             println!("{:#?}", result);
         }
-        Commands::RequestPhoneCode { phone } => {
-            let result = galoy_client
-                .request_auth_code(phone)
-                .context("issue getting code")?;
-            println!("{:#?}", result);
-        }
-        Commands::Login { phone, code } => {
-            let result = galoy_client
-                .user_login(phone, code)
-                .context("issue logging in")?;
-            println!("{:#?}", result);
-        }
-        Commands::Batch { filename, price } => {
+        Commands::Batch {
+            filename,
+            price,
+            force,
+        } => {
+            if jwt.is_none() {
+                bail!("need JWT");
+            }
+
             let result = galoy_client
-                .batch(filename, price)
+                .batch(filename, price, force)
                 .context("issue batching payment");
             println!("{:#?}", result);
         }

tests/common/mod.rs

@@ -1,4 +1,4 @@
-use super::*;
+use galoy_client::GaloyClient;
 
 pub fn unauth_client() -> galoy_client::GaloyClient {
     let api = "http://localhost:4002/graphql".to_string();