Merge pull request #1 from adamped/main

Initial SDK implementation

Cargo.toml

@@ -1,8 +1,10 @@
 [package]
-name = "rust-sdk"
-version = "0.1.0"
+name = "maestro"
+version = "1.0.0"
 edition = "2021"
-
-# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+license = "Apache-2.0"
 
 [dependencies]
+reqwest = "0.11"
+serde = { version = "1.0", features = ["derive"] }
+serde_json = "1.0"

README.md

@@ -31,9 +31,10 @@
 # Getting Started
 
 ## Prerequisites
-* [Rust](https://www.rust-lang.org/tools/install)
-* [Clippy](https://github.com/rust-lang/rust-clippy)
-* [Audit](https://docs.rs/cargo-audit/latest/cargo_audit/)
+
+- [Rust](https://www.rust-lang.org/tools/install)
+- [Clippy](https://github.com/rust-lang/rust-clippy)
+- [Audit](https://docs.rs/cargo-audit/latest/cargo_audit/)
 
 ## Installation
 
@@ -45,22 +46,43 @@
 
 ## Usage
 
+```toml
+[dependencies]
+maestro = { git = "https://github.com/maestro-org/rust-sdk.git" }
+```
+
 ```rust
-// TODO
+use maestro::Maestro;
+
+let maestro_client = Maestro::new("<PROJECT_API_KEY>", "<NETWORK>")
 ```
 
-* To generate an API key, create a free account [here](https://dashboard.gomaestro.org/)!
-* Network options: `mainnet`, `preprod`, `preview`
+- To generate an API key, create a free account [here](https://dashboard.gomaestro.org/)!
+- Network options: `mainnet`, `preprod`, `preview`
 
 ## Example
 
 ```rust
-// TODO
+use maestro::Maestro;
+
+#[tokio::main]
+async fn main() {
+    let maestro_client = Maestro::new(
+        String::from("<PROJECT_API_KEY>"),
+        String::from("<NETWORK>"),
+    );
+
+    match maestro_client.block_info(9005859).await {
+        Ok(block_info) => println!("{}", block_info.data.absolute_slot),
+        Err(e) => eprint!("Failed to retrieve block info {}", e),
+    }
+}
 ```
 
 # Documentation
 
-* [Maestro public docs](https://docs.gomaestro.org/)
+- [Maestro public docs](https://docs.gomaestro.org/)
 
 # Contributing
+
 Meastro welcomes all contributors! Please see our [contributing guidelines](CONTRIBUTING.md) and [code of conduct](CODE_OF_CONDUCT.md).

src/client/accounts.rs

@@ -0,0 +1,87 @@
+use super::maestro::Maestro;
+use crate::{
+    models::accounts::{
+        AccountAddresses, AccountAssets, StakeAccountHistory, StakeAccountInformation,
+        StakeAccountRewards, StakeAccountUpdates,
+    },
+    utils::Parameters,
+};
+use std::error::Error;
+
+impl Maestro {
+    pub async fn account_addresses(
+        &self,
+        stake_addr: &str,
+        params: Option<Parameters>,
+    ) -> Result<AccountAddresses, Box<dyn Error>> {
+        let formatted_params = params.map(|p| p.format()).unwrap_or_default();
+        let url = format!("/accounts/{}/addresses{}", stake_addr, formatted_params);
+        let resp = self.get(&url).await?;
+        let account_addresses =
+            serde_json::from_str(&resp).map_err(|e| Box::new(e) as Box<dyn Error>)?;
+        Ok(account_addresses)
+    }
+
+    pub async fn account_assets(
+        &self,
+        stake_addr: &str,
+        params: Option<Parameters>,
+    ) -> Result<AccountAssets, Box<dyn Error>> {
+        let formatted_params = params.map(|p| p.format()).unwrap_or_default();
+        let url = format!("/accounts/{}/assets{}", stake_addr, formatted_params);
+        let resp = self.get(&url).await?;
+        let account_assets =
+            serde_json::from_str(&resp).map_err(|e| Box::new(e) as Box<dyn Error>)?;
+        Ok(account_assets)
+    }
+
+    pub async fn stake_account_history(
+        &self,
+        stake_addr: &str,
+        params: Option<Parameters>,
+    ) -> Result<StakeAccountHistory, Box<dyn Error>> {
+        let formatted_params = params.map(|p| p.format()).unwrap_or_default();
+        let url = format!("/accounts/{}/history{}", stake_addr, formatted_params);
+        let resp = self.get(&url).await?;
+        let stake_account_history =
+            serde_json::from_str(&resp).map_err(|e| Box::new(e) as Box<dyn Error>)?;
+        Ok(stake_account_history)
+    }
+
+    pub async fn stake_account_information(
+        &self,
+        stake_addr: &str,
+    ) -> Result<StakeAccountInformation, Box<dyn Error>> {
+        let url = format!("/accounts/{}", stake_addr);
+        let resp = self.get(&url).await?;
+        let stake_account_information =
+            serde_json::from_str(&resp).map_err(|e| Box::new(e) as Box<dyn Error>)?;
+        Ok(stake_account_information)
+    }
+
+    pub async fn stake_account_rewards(
+        &self,
+        stake_addr: &str,
+        params: Option<Parameters>,
+    ) -> Result<StakeAccountRewards, Box<dyn Error>> {
+        let formatted_params = params.map(|p| p.format()).unwrap_or_default();
+        let url = format!("/accounts/{}/rewards{}", stake_addr, formatted_params);
+        let resp = self.get(&url).await?;
+        let stake_account_rewards =
+            serde_json::from_str(&resp).map_err(|e| Box::new(e) as Box<dyn Error>)?;
+        Ok(stake_account_rewards)
+    }
+
+    pub async fn stake_account_updates(
+        &self,
+        stake_addr: &str,
+        params: Option<Parameters>,
+    ) -> Result<StakeAccountUpdates, Box<dyn Error>> {
+        let formatted_params = params.map(|p| p.format()).unwrap_or_default();
+        let url = format!("/accounts/{}/updates{}", stake_addr, formatted_params);
+        let resp = self.get(&url).await?;
+        let stake_account_updates =
+            serde_json::from_str(&resp).map_err(|e| Box::new(e) as Box<dyn Error>)?;
+        Ok(stake_account_updates)
+    }
+}