Merge pull request #5 from renegade-fi/joey/funds-manager-backend

funds-manager: Refactor into HTTP server setup

Cargo.toml

@@ -4,7 +4,7 @@ members = [
     "compliance/compliance-api",
     "dealer/renegade-dealer",
     "dealer/renegade-dealer-api",
-    "fee-sweeper",
+    "funds-manager",
     "price-reporter",
 ]
 

fee-sweeper/Cargo.toml → funds-manager/Cargo.toml

@@ -1,12 +1,15 @@
 [package]
 name = "fee-sweeper"
+description = "Manages custody of funds for protocol operator"
 version = "0.1.0"
 edition = "2021"
 
 [dependencies]
-# === CLI + Runtime === #
+# === CLI + Server === #
 clap = { version = "4.5.3", features = ["derive", "env"] }
+http-body-util = "0.1.0"
 tokio = { version = "1.10", features = ["full"] }
+warp = "0.3"
 
 # === Infra === #
 aws-sdk-secretsmanager = "1.37"

funds-manager/src/error.rs

@@ -0,0 +1,69 @@
+//! Error types for the funds manager
+
+use std::{error::Error, fmt::Display};
+
+use warp::reject::Reject;
+
+/// The error type emitted by the funds manager
+#[derive(Debug, Clone)]
+pub enum FundsManagerError {
+    /// An error with the arbitrum client
+    Arbitrum(String),
+    /// An error with a database query
+    Db(String),
+    /// An error executing an HTTP request
+    Http(String),
+    /// An error parsing a value
+    Parse(String),
+    /// An error with AWS secrets manager
+    SecretsManager(String),
+    /// A miscellaneous error
+    Custom(String),
+}
+
+impl FundsManagerError {
+    /// Create an arbitrum error
+    pub fn arbitrum<T: ToString>(msg: T) -> FundsManagerError {
+        FundsManagerError::Arbitrum(msg.to_string())
+    }
+
+    /// Create a database error
+    pub fn db<T: ToString>(msg: T) -> FundsManagerError {
+        FundsManagerError::Db(msg.to_string())
+    }
+
+    /// Create an HTTP error
+    pub fn http<T: ToString>(msg: T) -> FundsManagerError {
+        FundsManagerError::Http(msg.to_string())
+    }
+
+    /// Create a parse error
+    pub fn parse<T: ToString>(msg: T) -> FundsManagerError {
+        FundsManagerError::Parse(msg.to_string())
+    }
+
+    /// Create a secrets manager error
+    pub fn secrets_manager<T: ToString>(msg: T) -> FundsManagerError {
+        FundsManagerError::SecretsManager(msg.to_string())
+    }
+
+    /// Create a custom error
+    pub fn custom<T: ToString>(msg: T) -> FundsManagerError {
+        FundsManagerError::Custom(msg.to_string())
+    }
+}
+
+impl Display for FundsManagerError {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        match self {
+            FundsManagerError::Arbitrum(e) => write!(f, "Arbitrum error: {}", e),
+            FundsManagerError::Db(e) => write!(f, "Database error: {}", e),
+            FundsManagerError::Http(e) => write!(f, "HTTP error: {}", e),
+            FundsManagerError::Parse(e) => write!(f, "Parse error: {}", e),
+            FundsManagerError::SecretsManager(e) => write!(f, "Secrets manager error: {}", e),
+            FundsManagerError::Custom(e) => write!(f, "Custom error: {}", e),
+        }
+    }
+}
+impl Error for FundsManagerError {}
+impl Reject for FundsManagerError {}