Propagate errors

Cargo.toml

@@ -7,6 +7,7 @@ authors = ["Stephen Leitnick"]
 [dependencies]
 anyhow = "1.0.58"
 clap = { version = "3.2.14", features = ["derive"] }
+log = "0.4.17"
 reqwest = { version = "0.11.11", features = ["json"] }
 serde = { version = "1.0.140", features = ["derive"] }
 serde_json = "1.0.82"

src/cli/experience_cli.rs

@@ -1,6 +1,6 @@
 use clap::{Subcommand, ValueEnum, Args};
 
-use crate::{rbx::{RbxCloud, PublishVersionType}, util::{print_success, print_error}};
+use crate::rbx::{RbxCloud, PublishVersionType};
 
 #[derive(Debug, Subcommand)]
 pub enum ExperienceCommands {
@@ -40,7 +40,7 @@ pub enum VersionType {
 }
 
 impl Experience {
-	pub async fn run(self) -> anyhow::Result<()> {
+	pub async fn run(self) -> anyhow::Result<Option<String>> {
 		match self.command {
 			ExperienceCommands::Publish {place_id,universe_id,version_type,api_key, filename } => {
 				let rbx_cloud = RbxCloud::new(api_key, universe_id);
@@ -51,14 +51,13 @@ impl Experience {
 				let res = rbx_cloud.experience(place_id).publish(&filename, publish_version_type).await;
 				match res {
 					Ok(body) => {
-						print_success(format!("{:?} {}/{} with version number {}", version_type, universe_id, place_id, body.version_number).to_lowercase());
+						Ok(Some(format!("{:?} {}/{} with version number {}", version_type, universe_id, place_id, body.version_number).to_lowercase()))
 					}
 					Err(err) => {
-						print_error(format!("{}", err.to_string()));
+						Err(err)
 					}
 				}
 			}
 		}
-		Ok(())
 	}
 }

src/cli/messaging_cli.rs

@@ -1,6 +1,6 @@
 use clap::{Subcommand, Args};
 
-use crate::{rbx::RbxCloud, util::{print_success, print_error}};
+use crate::rbx::RbxCloud;
 
 #[derive(Debug, Subcommand)]
 pub enum MessagingCommands {
@@ -30,22 +30,21 @@ pub struct Messaging {
 }
 
 impl Messaging {
-	pub async fn run(self) -> anyhow::Result<()> {
+	pub async fn run(self) -> anyhow::Result<Option<String>> {
 		match self.command {
 			MessagingCommands::Publish { topic, message, universe_id, api_key } => {
 				let rbx_cloud = RbxCloud::new(api_key, universe_id);
 				let messaging = rbx_cloud.messaging(&topic);
 				let res = messaging.publish(message).await;
 				match res {
 					Ok(()) => {
-						print_success(format!("published message to topic {}", topic));
+						Ok(Some(format!("published message to topic {}", topic)))
 					}
 					Err(err) => {
-						print_error(format!("{}", err.to_string()));
+						Err(err)
 					}
 				}
 			}
 		}
-		Ok(())
 	}
 }

src/cli/mod.rs

@@ -13,7 +13,7 @@ pub struct Cli {
 }
 
 impl Cli {
-	pub async fn run(self) -> anyhow::Result<()> {
+	pub async fn run(self) -> anyhow::Result<Option<String>> {
 		match self.command {
 			Command::Experience(command) => command.run().await,
 			Command::Messaging(command) => command.run().await,

src/main.rs

@@ -1,12 +1,23 @@
 mod rbx;
 mod cli;
-mod util;
+
+use std::process;
 
 use clap::Parser;
 use cli::Cli;
 
 #[tokio::main]
 async fn main() {
     let args = Cli::parse();
-    args.run().await.unwrap();
+    match args.run().await {
+        Ok(str) => {
+            if let Some(s) = str {
+                log::info!("{}", s);
+            }
+        }
+        Err(err) => {
+            log::error!("{:?}", err);
+            process::exit(1);
+        }
+    }
 }