Try action

Signed-off-by: Jacob Kiers <code@kiers.eu>

.gitea/workflows/test.yaml

@@ -0,0 +1,20 @@
+name: Gitea Actions Demo
+run-name: ${{ gitea.actor }} is testing out Gitea Actions 🚀
+on: [push]
+
+jobs:
+  Explore-Gitea-Actions:
+    runs-on: ubuntu-latest
+    steps:
+      - run: echo "🎉 The job was automatically triggered by a ${{ gitea.event_name }} event."
+      - run: echo "🐧 This job is now running on a ${{ runner.os }} server hosted by Gitea!"
+      - run: echo "🔎 The name of your branch is ${{ gitea.ref }} and your repository is ${{ gitea.repository }}."
+      - name: Check out repository code
+        uses: actions/checkout@v3
+      - run: echo "💡 The ${{ gitea.repository }} repository has been cloned to the runner."
+      - run: echo "🖥️ The workflow is now ready to test your code on the runner."
+      - name: List files in the repository
+        run: |
+          ls ${{ gitea.workspace }}
+      - run: echo "🍏 This job's status is ${{ job.status }}. And this is the last piece of the action."
+

Cargo.toml

@@ -6,8 +6,7 @@ keywords = ["bunq", "api"]
 license = "MIT OR Apache-2.0"
 repository = "https://github.com/yuri91/bunq-rs"
 authors = ["Yuri Iozzelli <y.iozzelli@gmail.com>"]
-edition = "2018"
+edition = "2021"
-
 
 [dependencies]
 anyhow = "1.0.79"

examples/download_statement.rs

@@ -0,0 +1,35 @@
+use anyhow::Result;
+use bunq::{BunqConfig, CsvType, StatementFormat};
+use std::time::Duration;
+
+fn main() -> Result<()> {
+    let cfg = BunqConfig::load()?;
+
+    let client = cfg.install()?;
+
+    let accs = client.monetary_accounts()?;
+
+    let acc = &accs[0];
+
+    let stmt_id = client.request_statement(
+        acc,
+        StatementFormat::CSV(CsvType::Semicolon),
+        "2023-12-05",
+        "2023-12-15",
+    )?;
+
+    println!("Waiting for statement {:?}...", stmt_id);
+
+    let mut ready = client.is_statement_ready(acc, stmt_id)?;
+    while !ready {
+        println!("Statement is not ready yet. Waiting 5 seconds...");
+        std::thread::sleep(Duration::from_secs(5));
+        ready = client.is_statement_ready(acc, stmt_id)?;
+    }
+
+    let contents = client.download_statement(acc, stmt_id)?;
+
+    println!("{contents}");
+
+    Ok(())
+}

src/config.rs

@@ -1,138 +1,149 @@
-use anyhow::anyhow;
+use anyhow::anyhow;
-use isahc::{ReadResponseExt, RequestExt};
+use isahc::http::StatusCode;
-use isahc::http::StatusCode;
+use isahc::{ReadResponseExt, RequestExt};
-use rsa::pkcs1::{DecodeRsaPrivateKey, EncodeRsaPrivateKey, LineEnding};
+use rsa::pkcs1::{DecodeRsaPrivateKey, EncodeRsaPrivateKey, LineEnding};
-use rsa::pkcs8::EncodePublicKey;
+use rsa::pkcs8::EncodePublicKey;
-use rsa::RsaPrivateKey;
+use rsa::RsaPrivateKey;
-use serde::{Deserialize, Serialize};
+use serde::{Deserialize, Serialize};
-
+
-use crate::{BASE_URL, BunqClient, deserialize_retarded_response, sign};
+use crate::{deserialize_retarded_response, sign, BunqClient, BASE_URL};
-
+
-#[derive(Serialize, Deserialize, Default)]
+#[derive(Serialize, Deserialize, Default)]
-struct AppState {
+struct AppState {
-    token: String,
+    token: String,
-    pem_private: String,
+    pem_private: String,
-}
+}
-
+
-#[derive(Serialize, Deserialize, Default)]
+#[derive(Serialize, Deserialize, Default)]
-pub struct BunqConfig {
+pub struct BunqConfig {
-    api_key: String,
+    api_key: String,
-    state: Option<AppState>,
+    state: Option<AppState>,
-}
+}
-
+
-impl BunqConfig {
+impl BunqConfig {
-    pub fn load() -> anyhow::Result<BunqConfig> {
+    pub fn load() -> anyhow::Result<BunqConfig> {
-        println!("Loading config file from {}", confy::get_configuration_file_path("bunq-rs", "bunq-rs")?.to_string_lossy());
+        println!(
-        Ok(confy::load("bunq-rs", "bunq-rs")?)
+            "Loading config file from {}",
-    }
+            confy::get_configuration_file_path("bunq-rs", "bunq-rs")?.to_string_lossy()
-    pub fn save(&self) -> anyhow::Result<()> {
+        );
-        println!("Storing config file in {}", confy::get_configuration_file_path("bunq-rs", None)?.to_string_lossy());
+        Ok(confy::load("bunq-rs", "bunq-rs")?)
-        confy::store("bunq-rs", "bunq-rs", self)?;
+    }
-        Ok(())
+    pub fn save(&self) -> anyhow::Result<()> {
-    }
+        println!(
-    pub fn install(mut self) -> anyhow::Result<BunqClient> {
+            "Storing config file in {}",
-        let api_key = &self.api_key;
+            confy::get_configuration_file_path("bunq-rs", None)?.to_string_lossy()
-
+        );
-        let keypair = if let Some(state) = &self.state {
+        confy::store("bunq-rs", "bunq-rs", self)?;
-            RsaPrivateKey::from_pkcs1_pem(&state.pem_private)?
+        Ok(())
-        } else {
+    }
-            let mut rng = rand::thread_rng();
+    pub fn install(mut self) -> anyhow::Result<BunqClient> {
-
+        let api_key = &self.api_key;
-            let bits = 2048;
+
-            let keypair = RsaPrivateKey::new(&mut rng, bits).expect("failed to generate a key");
+        let keypair = if let Some(state) = &self.state {
-
+            RsaPrivateKey::from_pkcs1_pem(&state.pem_private)?
-            let pem_public = keypair.to_public_key().to_public_key_pem(LineEnding::CRLF)?;
+        } else {
-
+            let mut rng = rand::thread_rng();
-            let body = Installation {
+
-                client_public_key: &pem_public,
+            let bits = 2048;
-            };
+            let keypair = RsaPrivateKey::new(&mut rng, bits).expect("failed to generate a key");
-            let response = isahc::post(
+
-                format!("{}/v1/installation", BASE_URL),
+            let pem_public = keypair
-                serde_json::to_string(&body)?,
+                .to_public_key()
-            )?
+                .to_public_key_pem(LineEnding::CRLF)?;
-                .text()?;
+
-            let response: InstallationResponse = deserialize_retarded_response(&response)?.response;
+            let body = Installation {
-            let token = response.token.token;
+                client_public_key: &pem_public,
-
+            };
-            let body = DeviceServer {
+            let response = isahc::post(
-                description: "JK Test Server",
+                format!("{}/v1/installation", BASE_URL),
-                secret: api_key,
+                serde_json::to_string(&body)?,
-                permitted_ips: &["77.175.86.236", "*"],
+            )?
-            };
+            .text()?;
-            let body = serde_json::to_string(&body)?;
+            let response: InstallationResponse = deserialize_retarded_response(&response)?.response;
-            let mut response = isahc::http::Request::post(format!("{}/v1/device-server", BASE_URL))
+            let token = response.token.token;
-                .header("X-Bunq-Client-Authentication", &token)
+
-                .body(body)?
+            let body = DeviceServer {
-                .send()?;
+                description: "JK Test Server",
-
+                secret: api_key,
-            let response_text = response.text()?;
+                permitted_ips: &["77.175.86.236", "*"],
-            println!("{}", response_text);
+            };
-
+            let body = serde_json::to_string(&body)?;
-            if response.status() != StatusCode::OK {
+            let mut response = isahc::http::Request::post(format!("{}/v1/device-server", BASE_URL))
-                return Err(anyhow!(response_text));
+                .header("X-Bunq-Client-Authentication", &token)
-            }
+                .body(body)?
-
+                .send()?;
-            self.state = Some(AppState { pem_private: keypair.to_pkcs1_pem(LineEnding::CRLF)?.to_string(), token });
+
-            self.save()?;
+            let response_text = response.text()?;
-
+            println!("{}", response_text);
-            keypair
+
-        };
+            if response.status() != StatusCode::OK {
-        let token = self.state.unwrap().token;
+                return Err(anyhow!(response_text));
-        let body = SessionServer { secret: api_key };
+            }
-        let body = serde_json::to_string(&body)?;
+
-        let sig = sign(&body, &keypair)?;
+            self.state = Some(AppState {
-        let response = isahc::http::Request::post(format!("{}/v1/session-server", BASE_URL))
+                pem_private: keypair.to_pkcs1_pem(LineEnding::CRLF)?.to_string(),
-            .header("X-Bunq-Client-Authentication", &token)
+                token,
-            .header("X-Bunq-Client-Signature", &sig)
+            });
-            .body(body)?
+            self.save()?;
-            .send()?
+
-            .text()?;
+            keypair
-        let r: SessionServerResponse = deserialize_retarded_response(&response)?.response;
+        };
-
+        let token = self.state.unwrap().token;
-        Ok(BunqClient {
+        let body = SessionServer { secret: api_key };
-            keypair,
+        let body = serde_json::to_string(&body)?;
-            token: r.token.token,
+        let sig = sign(&body, &keypair)?;
-            user_id: r.user_person.id,
+        let response = isahc::http::Request::post(format!("{}/v1/session-server", BASE_URL))
-        })
+            .header("X-Bunq-Client-Authentication", &token)
-    }
+            .header("X-Bunq-Client-Signature", &sig)
-}
+            .body(body)?
-
+            .send()?
-#[derive(Serialize)]
+            .text()?;
-pub(super) struct Installation<'a> {
+        let r: SessionServerResponse = deserialize_retarded_response(&response)?.response;
-    pub(super) client_public_key: &'a str,
+
-}
+        Ok(BunqClient {
-
+            keypair,
-#[derive(Deserialize)]
+            token: r.token.token,
-pub(super) struct Token {
+            user_id: r.user_person.id,
-    pub(super) token: String,
+        })
-}
+    }
-
+}
-#[derive(Deserialize)]
+
-#[serde(rename_all = "PascalCase")]
+#[derive(Serialize)]
-pub(super) struct InstallationResponse {
+pub(super) struct Installation<'a> {
-    pub(super) token: Token,
+    pub(super) client_public_key: &'a str,
-}
+}
-
+
-#[derive(Serialize)]
+#[derive(Deserialize)]
-pub(super) struct DeviceServer<'a> {
+pub(super) struct Token {
-    pub(super) description: &'a str,
+    pub(super) token: String,
-    pub(super) secret: &'a str,
+}
-    pub(super) permitted_ips: &'a [&'a str],
+
-}
+#[derive(Deserialize)]
-
+#[serde(rename_all = "PascalCase")]
-#[derive(Serialize)]
+pub(super) struct InstallationResponse {
-pub(super) struct SessionServer<'a> {
+    pub(super) token: Token,
-    pub(super) secret: &'a str,
+}
-}
+
-
+#[derive(Serialize)]
-#[derive(Deserialize)]
+pub(super) struct DeviceServer<'a> {
-#[serde(rename_all = "PascalCase")]
+    pub(super) description: &'a str,
-pub(super) struct SessionServerResponse {
+    pub(super) secret: &'a str,
-    pub(super) token: Token,
+    pub(super) permitted_ips: &'a [&'a str],
-    pub(super) user_person: UserPerson,
+}
-}
+
-
+#[derive(Serialize)]
-#[derive(Deserialize)]
+pub(super) struct SessionServer<'a> {
-pub(super) struct UserPerson {
+    pub(super) secret: &'a str,
-    pub(super) id: i64,
+}
-}
+
+#[derive(Deserialize)]
+#[serde(rename_all = "PascalCase")]
+pub(super) struct SessionServerResponse {
+    pub(super) token: Token,
+    pub(super) user_person: UserPerson,
+}
+
+#[derive(Deserialize)]
+pub(super) struct UserPerson {
+    pub(super) id: i64,
+}

src/lib.rs

@@ -1,12 +1,12 @@
 use anyhow::Result;
 use rsa::pkcs1v15::SigningKey;
-use rsa::RsaPrivateKey;
 use rsa::sha2::Sha256;
 use rsa::signature::RandomizedSigner;
+use rsa::RsaPrivateKey;
 use serde::{de::DeserializeOwned, Deserialize};
 
 pub use config::BunqConfig;
-pub use monetary_account::MonetaryAccount;
+pub use monetary_account::{CsvType, MonetaryAccount, StatementFormat};
 pub use payment::Payment;
 
 mod config;
@@ -38,6 +38,23 @@ impl BunqClient {
     ) -> anyhow::Result<Vec<Payment>> {
         payment::get_from_to(self, acc, from, to)
     }
+
+    pub fn request_statement(
+        &self,
+        acc: &MonetaryAccount,
+        format: StatementFormat,
+        date_start: &str,
+        date_end: &str,
+    ) -> Result<i64> {
+        monetary_account::request_statement(self, acc, format, date_start, date_end)
+    }
+    pub fn is_statement_ready(&self, acc: &MonetaryAccount, statement_id: i64) -> Result<bool> {
+        monetary_account::is_statement_ready(self, acc, statement_id)
+    }
+
+    pub fn download_statement(&self, acc: &MonetaryAccount, statement_id: i64) -> Result<String> {
+        monetary_account::download_statement(self, acc, statement_id)
+    }
 }
 
 #[derive(Deserialize, Debug)]
@@ -94,7 +111,7 @@ fn deserialize_normal_response<T: DeserializeOwned>(r: &str) -> Result<Response<
 }
 
 fn sign(body: &str, key: &RsaPrivateKey) -> Result<String> {
-    use base64::prelude::{BASE64_STANDARD, Engine};
+    use base64::prelude::{Engine, BASE64_STANDARD};
 
     let signing_key = SigningKey::<Sha256>::new(key.clone());
     let mut rng = rand::thread_rng();

src/monetary_account.rs

@@ -1,38 +1,235 @@
-use isahc::{ReadResponseExt, RequestExt};
+use std::fmt::Display;
-use serde::Deserialize;
+use std::str::FromStr;
-
+
-use crate::{BASE_URL, BunqClient};
+use anyhow::{anyhow, Result};
-
+use isahc::http::StatusCode;
-pub(super) fn get(client: &BunqClient) -> anyhow::Result<Vec<MonetaryAccount>> {
+use isahc::{ReadResponseExt, RequestExt};
-    let response = isahc::http::Request::get(format!(
+use serde::{Deserialize, Serialize};
-        "{}/v1/user/{}/monetary-account",
+
-        BASE_URL, client.user_id
+use crate::{deserialize_normal_response, sign, BunqClient, BASE_URL};
-    ))
+
-        .header("X-Bunq-Client-Authentication", &client.token)
+pub(super) fn get(client: &BunqClient) -> anyhow::Result<Vec<MonetaryAccount>> {
-        .body(())?
+    let response = isahc::http::Request::get(format!(
-        .send()?
+        "{}/v1/user/{}/monetary-account",
-        .text()?;
+        BASE_URL, client.user_id
-
+    ))
-    let accounts = crate::deserialize_normal_response::<Vec<MonetaryAccount>>(&response)?;
+    .header("X-Bunq-Client-Authentication", &client.token)
-
+    .body(())?
-    Ok(accounts.response)
+    .send()?
-}
+    .text()?;
-
+
-#[derive(Deserialize, Debug)]
+    let accounts = crate::deserialize_normal_response::<Vec<MonetaryAccount>>(&response)?;
-#[serde(rename_all = "PascalCase")]
+
-pub enum MonetaryAccount {
+    Ok(accounts.response)
-    MonetaryAccountBank(MonetaryAccountBank),
+}
-    MonetaryAccountSavings(MonetaryAccountSavings),
+
-}
+pub(super) fn request_statement(
-
+    client: &BunqClient,
-#[derive(Deserialize, Debug)]
+    account: &MonetaryAccount,
-pub struct MonetaryAccountBank {
+    format: StatementFormat,
-    pub id: i64,
+    start: &str,
-    pub description: String,
+    end: &str,
-}
+) -> Result<i64> {
-
+    let statement_request = CreateStatementRequest {
-#[derive(Deserialize, Debug)]
+        statement_format: &format.to_string(),
-pub struct MonetaryAccountSavings {
+        regional_format: match format {
-    pub id: i64,
+            StatementFormat::CSV(CsvType::Comma) => "UK_US",
-    pub description: String,
+            StatementFormat::CSV(CsvType::Semicolon) => "EUROPEAN",
-}
+            _ => "",
+        },
+        date_start: start,
+        date_end: end,
+        include_attachment: match format {
+            StatementFormat::PDF(v) => v,
+            _ => false,
+        },
+    };
+
+    let body = serde_json::to_string(&statement_request)?;
+    let sig = sign(&body, &client.keypair)?;
+
+    let request_url = format!(
+        "{}/v1/user/{}/monetary-account/{}/customer-statement",
+        BASE_URL,
+        client.user_id,
+        account.id()
+    );
+
+    let mut response = isahc::http::Request::post(request_url)
+        .header("X-Bunq-Client-Authentication", &client.token)
+        .header("X-Bunq-Client-Signature", &sig)
+        .body(body)?
+        .send()?;
+
+    if response.status() != StatusCode::OK {
+        return Err(anyhow!(response.text()?));
+    }
+
+    let response_body = response.text()?;
+
+    //let response_body = r#"{"Response":[{"Id":{"id":4203007}}]}"#;
+    //println!("{response_body}");
+
+    let r = deserialize_normal_response::<CreateStatementResponse>(&response_body)?.response;
+
+    let statement_id = r.id.id.id;
+
+    Ok(statement_id)
+}
+
+pub(super) fn is_statement_ready(
+    client: &BunqClient,
+    account: &MonetaryAccount,
+    statement_id: i64,
+) -> Result<bool> {
+    let url = format!(
+        "{}/v1/user/{}/monetary-account/{}/customer-statement/{}",
+        BASE_URL,
+        client.user_id,
+        account.id(),
+        statement_id
+    );
+
+    let mut response = isahc::http::Request::get(url)
+        .header("X-Bunq-Client-Authentication", &client.token)
+        .body(())?
+        .send()?;
+
+    let body = response.text()?;
+
+    let statement = deserialize_normal_response::<Vec<CustomerStatementWrapper>>(&body)?
+        .response
+        .iter()
+        .map(|v| v.customer_statement.clone())
+        .take(1)
+        .collect::<Vec<CustomerStatement>>()
+        .pop()
+        .unwrap();
+
+    //let statement = statements.first().unwrap();
+
+    Ok(statement.status == "COMPLETED")
+}
+
+pub(super) fn download_statement(
+    client: &BunqClient,
+    account: &MonetaryAccount,
+    id: i64,
+) -> Result<String> {
+    let content_url = format!(
+        "{}/v1/user/{}/monetary-account/{}/customer-statement/{}/content",
+        BASE_URL,
+        client.user_id,
+        account.id(),
+        id
+    );
+
+    let mut response = isahc::http::Request::get(content_url)
+        .header("X-Bunq-Client-Authentication", &client.token)
+        .body(())?
+        .send()?;
+
+    Ok(response.text()?)
+}
+
+#[derive(Deserialize, Debug)]
+#[serde(rename_all = "PascalCase")]
+pub enum MonetaryAccount {
+    MonetaryAccountBank(MonetaryAccountBank),
+    MonetaryAccountSavings(MonetaryAccountSavings),
+}
+
+impl MonetaryAccount {
+    pub fn id(&self) -> i64 {
+        match &self {
+            MonetaryAccount::MonetaryAccountBank(b) => b.id,
+            MonetaryAccount::MonetaryAccountSavings(s) => s.id,
+        }
+    }
+}
+
+#[derive(Deserialize, Debug)]
+pub struct MonetaryAccountBank {
+    pub id: i64,
+    pub description: String,
+}
+
+#[derive(Deserialize, Debug)]
+pub struct MonetaryAccountSavings {
+    pub id: i64,
+    pub description: String,
+}
+
+pub enum CsvType {
+    Comma,
+    Semicolon,
+}
+
+pub enum StatementFormat {
+    CSV(CsvType),
+    MT940,
+    PDF(bool),
+}
+
+impl Display for StatementFormat {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        let str = match self {
+            StatementFormat::CSV(_) => "CSV",
+            StatementFormat::MT940 => "MT940",
+            StatementFormat::PDF(_) => "PDF",
+        };
+        write!(f, "{}", str)
+    }
+}
+
+impl FromStr for StatementFormat {
+    type Err = ();
+
+    fn from_str(s: &str) -> Result<Self, Self::Err> {
+        match s.to_ascii_uppercase().as_str() {
+            "CSV" => Ok(StatementFormat::CSV(CsvType::Semicolon)),
+            "MT940" => Ok(StatementFormat::MT940),
+            "PDF" => Ok(StatementFormat::PDF(false)),
+            _ => Err(()),
+        }
+    }
+}
+
+#[derive(Deserialize, Debug)]
+#[serde(rename_all = "PascalCase")]
+struct CustomerStatementWrapper {
+    customer_statement: CustomerStatement,
+}
+
+#[derive(Deserialize, Debug, Clone)]
+pub struct CustomerStatement {
+    pub id: i64,
+    status: String,
+}
+
+#[derive(Serialize)]
+struct CreateStatementRequest<'a> {
+    statement_format: &'a str,
+    date_start: &'a str,
+    date_end: &'a str,
+    regional_format: &'a str,
+    include_attachment: bool,
+}
+
+#[derive(Deserialize, Debug)]
+#[serde(rename_all = "PascalCase")]
+struct CreateStatementResponse {
+    id: Id,
+}
+
+//#[derive(Deserialize, Debug)]
+#[derive(Deserialize, Debug)]
+#[serde(rename_all = "PascalCase")]
+struct Id {
+    id: Id2,
+}
+
+#[derive(Deserialize, Debug)]
+struct Id2 {
+    id: i64,
+}

src/payment.rs

@@ -1,100 +1,101 @@
-use anyhow::Result;
+use anyhow::Result;
-use isahc::{ReadResponseExt, RequestExt};
+use isahc::{ReadResponseExt, RequestExt};
-use serde::Deserialize;
+use serde::Deserialize;
-
+
-use crate::{BASE_URL, BunqClient, MonetaryAccount, Pagination, Response};
+use crate::{BunqClient, MonetaryAccount, Pagination, Response, BASE_URL};
-
+
-pub(super) fn get_from_to(client: &BunqClient,
+pub(super) fn get_from_to(
-                          acc: &MonetaryAccount,
+    client: &BunqClient,
-                          from: Option<i64>,
+    acc: &MonetaryAccount,
-                          to: Option<i64>) -> Result<Vec<Payment>>
+    from: Option<i64>,
-{
+    to: Option<i64>,
-    let next_page = |url: &str| -> Result<(_, _)> {
+) -> Result<Vec<Payment>> {
-        let response = isahc::http::Request::get(url)
+    let next_page = |url: &str| -> Result<(_, _)> {
-            .header("X-Bunq-Client-Authentication", &client.token)
+        let response = isahc::http::Request::get(url)
-            .body(())?
+            .header("X-Bunq-Client-Authentication", &client.token)
-            .send()?
+            .body(())?
-            .text()?;
+            .send()?
-        let Response {
+            .text()?;
-            response,
+        let Response {
-            pagination,
+            response,
-        } = crate::deserialize_normal_response::<Vec<PaymentPayment>>(&response)?;
+            pagination,
-        Ok((
+        } = crate::deserialize_normal_response::<Vec<PaymentPayment>>(&response)?;
-            response.into_iter().map(|p| p.payment).collect(),
+        Ok((
-            pagination,
+            response.into_iter().map(|p| p.payment).collect(),
-        ))
+            pagination,
-    };
+        ))
-
+    };
-    let account_id = match acc {
+
-        MonetaryAccount::MonetaryAccountBank(bank) => bank.id,
+    let account_id = match acc {
-        MonetaryAccount::MonetaryAccountSavings(savings) => savings.id,
+        MonetaryAccount::MonetaryAccountBank(bank) => bank.id,
-    };
+        MonetaryAccount::MonetaryAccountSavings(savings) => savings.id,
-
+    };
-    let mut url = format!(
+
-        "/v1/user/{}/monetary-account/{}/payment",
+    let mut url = format!(
-        client.user_id, account_id
+        "/v1/user/{}/monetary-account/{}/payment",
-    );
+        client.user_id, account_id
-
+    );
-    if let Some(to) = to {
+
-        url = format!("{}?newer_id={}", url, to);
+    if let Some(to) = to {
-    }
+        url = format!("{}?newer_id={}", url, to);
-
+    }
-    let mut all = Vec::new();
+
-    loop {
+    let mut all = Vec::new();
-        let (mut payments, pag) = next_page(&format!("{}{}", BASE_URL, url))?;
+    loop {
-        dbg!(&payments);
+        let (mut payments, pag) = next_page(&format!("{}{}", BASE_URL, url))?;
-        all.append(&mut payments);
+        dbg!(&payments);
-        dbg!(&pag);
+        all.append(&mut payments);
-        if let Some(Pagination {
+        dbg!(&pag);
-                        older_url: Some(older_url),
+        if let Some(Pagination {
-                        ..
+            older_url: Some(older_url),
-                    }) = pag
+            ..
-        {
+        }) = pag
-            if let (Some(latest), Some(from)) = (all.last(), from) {
+        {
-                if latest.id <= from {
+            if let (Some(latest), Some(from)) = (all.last(), from) {
-                    all.retain(|p| p.id >= from);
+                if latest.id <= from {
-                    break;
+                    all.retain(|p| p.id >= from);
-                }
+                    break;
-            }
+                }
-            url = older_url;
+            }
-        } else {
+            url = older_url;
-            break;
+        } else {
-        }
+            break;
-    }
+        }
-    Ok(all)
+    }
-}
+    Ok(all)
-
+}
-#[derive(Deserialize, Debug)]
+
-pub struct LabelMonetaryAccount {
+#[derive(Deserialize, Debug)]
-    pub iban: Option<String>,
+pub struct LabelMonetaryAccount {
-    pub display_name: String,
+    pub iban: Option<String>,
-    pub merchant_category_code: Option<String>,
+    pub display_name: String,
-}
+    pub merchant_category_code: Option<String>,
-
+}
-#[derive(Deserialize, Debug)]
+
-pub struct Amount {
+#[derive(Deserialize, Debug)]
-    pub value: String,
+pub struct Amount {
-    pub currency: String,
+    pub value: String,
-}
+    pub currency: String,
-
+}
-#[derive(Deserialize, Debug)]
+
-#[serde(rename_all = "PascalCase")]
+#[derive(Deserialize, Debug)]
-struct PaymentPayment {
+#[serde(rename_all = "PascalCase")]
-    payment: Payment,
+struct PaymentPayment {
-}
+    payment: Payment,
-
+}
-#[derive(Deserialize, Debug)]
+
-pub struct Payment {
+#[derive(Deserialize, Debug)]
-    pub alias: LabelMonetaryAccount,
+pub struct Payment {
-    pub counterparty_alias: LabelMonetaryAccount,
+    pub alias: LabelMonetaryAccount,
-    pub amount: Amount,
+    pub counterparty_alias: LabelMonetaryAccount,
-    pub balance_after_mutation: Amount,
+    pub amount: Amount,
-    pub created: String,
+    pub balance_after_mutation: Amount,
-    pub updated: String,
+    pub created: String,
-    pub description: String,
+    pub updated: String,
-    pub id: i64,
+    pub description: String,
-    pub monetary_account_id: i64,
+    pub id: i64,
-    #[serde(rename = "type")]
+    pub monetary_account_id: i64,
-    pub type_: String,
+    #[serde(rename = "type")]
-    pub sub_type: String,
+    pub type_: String,
-}
+    pub sub_type: String,
+}