add balance

examples/charge.rs

@@ -1,9 +1,10 @@
-use pinpayments::{Client, Charge};
+use pinpayments::{Client, Charge, ChargeSearchParams, SortByField, SortDirection};
+//use time::macros::datetime;
 
 #[tokio::main]
 async fn main() { 
     let secret_key = std::env::var("PINPAYMENTS_SECRET_KEY").expect("Missing PINPAYMENTS_SECRET_KEY in env");
-    let client = Client::new(secret_key);
+    let client = Client::from_url(pinpayments::DEFAULT_TEST_API_BASE_URL, secret_key);
 
     let charges = match Charge::list(&client, None, None).await {
         Ok(c) => Some(c),
@@ -25,6 +26,23 @@ async fn main() {
     };
 
     println!("Result is {charge:?}");
+
+//    let search_params = ChargeSearchParams {
+//        query: Some("Kruger"),
+//        start_date: Some(datetime!(2017-02-24 3:10:49 UTC)),
+//        end_date: None,
+//        sort_by: Some(SortByField::CreatedAt),
+//        direction: Some(SortDirection::Asc),
+//        page: None,
+//        per_page: None
+//    };
+//
+    let search_params = ChargeSearchParams { ..Default::default() };
+
+    let searched_charges = Charge::search(&client, search_params).await.unwrap();
+
+    println!("Search for charges {searched_charges:?}");
+
 //    let charge = Charge::create(
 //        &client, 
 //        CreateCharge {

src/client/async_std.rs

@@ -20,7 +20,7 @@ pub(crate) fn err<T: Send + 'static>(err: PinError) -> Response<T> {
     Box::pin(future::ready(Err(err)))
 }
 
-#[derive(Clone)]
+#[derive(Clone, Debug)]
 pub struct BaseClient {
     client: surf::Client,
 }

src/client/pinpayments.rs

@@ -15,7 +15,7 @@ const USER_AGENT: &str = concat!("PinPayments/1 RustClient/", env!("CARGO_PKG_VE
 pub const DEFAULT_API_BASE_URL: &str = "https://api.pinpayments.com/1/";
 pub const DEFAULT_TEST_API_BASE_URL: &str = "https://test-api.pinpayments.com/1/";
 
-#[derive(Clone)]
+#[derive(Clone, Debug)]
 pub struct Client {
     client: crate::client::BaseClient,
     secret_key: String,

src/params.rs

@@ -10,7 +10,7 @@ use crate::{
     client::{Response},
 };
 
-#[derive(Clone, Default)]
+#[derive(Clone, Debug, Default)]
 pub struct AppInfo {
     pub name: String,
     pub url: Option<String>,
@@ -28,7 +28,7 @@ impl ToString for AppInfo {
     }
 }
 
-#[derive(Clone)]
+#[derive(Clone, Debug)]
 pub struct Headers {
     pub user_agent: String,
 }

src/resources.rs

@@ -2,8 +2,10 @@ mod currency;
 mod charge;
 mod card;
 mod refund;
+mod balance;
 
 pub use currency::*;
 pub use charge::*;
 pub use card::*;
 pub use refund::*;
+pub use balance::*;

src/resources/balance.rs

@@ -0,0 +1,23 @@
+use serde::{Deserialize};
+
+use crate::client::{Client, Response};
+use crate::params::{unpack_contained};
+use crate::resources::{Currency};
+
+#[derive(Clone, Debug, Deserialize)]
+pub struct AmountCurrency {
+    pub amount: i64,
+    pub currency: Currency
+}
+
+#[derive(Clone, Debug, Deserialize)]
+pub struct Balance {
+    pub available: Vec<AmountCurrency>,
+    pub pending: Vec<AmountCurrency>
+}
+
+impl Balance { 
+    pub fn retrieve(client: &Client) -> Response<Balance> {
+        unpack_contained(client.get("/balance"))
+    }
+}

tests/balance.rs

@@ -0,0 +1,45 @@
+use pinpayments::{Client, Currency, Balance};
+use std::fs::File;
+use httptest::{ServerPool, Expectation, matchers::*, responders::*};
+use surf::http::auth::BasicAuth;
+
+static SERVER_POOL: ServerPool = ServerPool::new(1);
+
+fn get_fixture(path: &str) -> serde_json::Value {
+    let file = File::open(path)
+        .expect("file should open read only");
+    serde_json::from_reader(file).expect("file should be JSON")
+}
+
+#[tokio::test]
+async fn get_balance_test() {
+    let json = get_fixture("tests/fixtures/get-balance.json");
+
+    println!("{json}");
+
+    let auth = BasicAuth::new("sk_test_12345", "");
+
+    let server = SERVER_POOL.get_server();
+
+    server.expect(
+        Expectation::matching(
+            all_of![
+                request::method_path("GET", "/1/balance"),
+                request::headers(
+                    contains((String::from(auth.name().as_str()), String::from(auth.value().as_str())))
+                ),
+            ]).
+            respond_with(json_encoded(json))
+    );
+
+    let client = Client::from_url(server.url_str("/1/").as_str(), "sk_test_12345");
+
+    let balance = Balance::retrieve(&client)
+        .await
+        .unwrap();
+
+    assert_eq!(balance.available[0].amount, 400);
+    assert_eq!(balance.available[0].currency, Currency::AUD);
+    assert_eq!(balance.pending[0].amount, 1200);
+    assert_eq!(balance.pending[0].currency, Currency::AUD);
+}

tests/fixtures/get-balance.json

@@ -0,0 +1,16 @@
+{
+  "response": {
+    "available": [
+      {
+        "amount": 400,
+        "currency": "AUD"
+      }
+    ],
+    "pending": [
+      {
+        "amount": 1200,
+        "currency": "AUD"
+      }
+    ]
+  }
+}