blockfrost 1.2.3

use crate::*;
use blockfrost_openapi::models::{
    account_addresses_assets_inner::AccountAddressesAssetsInner,
    account_addresses_content_inner::AccountAddressesContentInner,
    account_addresses_total::AccountAddressesTotal, account_content::AccountContent,
    account_delegation_content_inner::AccountDelegationContentInner,
    account_history_content_inner::AccountHistoryContentInner,
    account_mir_content_inner::AccountMirContentInner,
    account_registration_content_inner::AccountRegistrationContentInner,
    account_reward_content_inner::AccountRewardContentInner,
    account_transactions_content_inner::AccountTransactionsContentInner,
    account_utxo_content_inner::AccountUtxoContentInner,
    account_withdrawal_content_inner::AccountWithdrawalContentInner,
};

impl BlockfrostAPI {
    /// Obtain information about a specific stake account.
    pub async fn accounts(&self, stake_address: &str) -> BlockfrostResult<AccountContent> {
        self.call_endpoint(format!("/accounts/{stake_address}").as_str())
            .await
    }

    /// Reward history of a specific account.
    pub async fn accounts_rewards(
        &self, stake_address: &str, pagination: Pagination,
    ) -> BlockfrostResult<Vec<AccountRewardContentInner>> {
        self.call_paged_endpoint(
            format!("/accounts/{stake_address}/rewards").as_str(),
            pagination,
        )
        .await
    }

    /// History of a specific account.
    pub async fn accounts_history(
        &self, stake_address: &str, pagination: Pagination,
    ) -> BlockfrostResult<Vec<AccountHistoryContentInner>> {
        self.call_paged_endpoint(
            format!("/accounts/{stake_address}/history").as_str(),
            pagination,
        )
        .await
    }

    /// Delegation history of a specific account.
    pub async fn accounts_delegations(
        &self, stake_address: &str, pagination: Pagination,
    ) -> BlockfrostResult<Vec<AccountDelegationContentInner>> {
        self.call_paged_endpoint(
            format!("/accounts/{stake_address}/delegations").as_str(),
            pagination,
        )
        .await
    }

    /// Registration history of a specific account.
    pub async fn accounts_registrations(
        &self, stake_address: &str, pagination: Pagination,
    ) -> BlockfrostResult<Vec<AccountRegistrationContentInner>> {
        self.call_paged_endpoint(
            format!("/accounts/{stake_address}/registrations").as_str(),
            pagination,
        )
        .await
    }

    /// Withdrawal history of a specific account.
    pub async fn accounts_withdrawals(
        &self, stake_address: &str, pagination: Pagination,
    ) -> BlockfrostResult<Vec<AccountWithdrawalContentInner>> {
        self.call_paged_endpoint(
            format!("/accounts/{stake_address}/withdrawals").as_str(),
            pagination,
        )
        .await
    }

    /// MIR history of a specific account.
    pub async fn accounts_mirs(
        &self, stake_address: &str, pagination: Pagination,
    ) -> BlockfrostResult<Vec<AccountMirContentInner>> {
        self.call_paged_endpoint(
            format!("/accounts/{stake_address}/mirs").as_str(),
            pagination,
        )
        .await
    }

    /// Addresses associated with a specific account.
    pub async fn accounts_addresses(
        &self, stake_address: &str, pagination: Pagination,
    ) -> BlockfrostResult<Vec<AccountAddressesContentInner>> {
        self.call_paged_endpoint(
            format!("/accounts/{stake_address}/addresses").as_str(),
            pagination,
        )
        .await
    }

    /// Assets associated with addresses of a specific account.
    pub async fn accounts_addresses_assets(
        &self, stake_address: &str, pagination: Pagination,
    ) -> BlockfrostResult<Vec<AccountAddressesAssetsInner>> {
        self.call_paged_endpoint(
            format!("/accounts/{stake_address}/addresses/assets").as_str(),
            pagination,
        )
        .await
    }

    /// Sum of all funds for a specific account.
    pub async fn accounts_addresses_total(
        &self, stake_address: &str,
    ) -> BlockfrostResult<AccountAddressesTotal> {
        self.call_endpoint(format!("/accounts/{stake_address}/addresses/total").as_str())
            .await
    }

    /// UTXOs of a specific account.
    pub async fn accounts_utxos(
        &self, stake_address: &str, pagination: Pagination,
    ) -> BlockfrostResult<Vec<AccountUtxoContentInner>> {
        self.call_paged_endpoint(
            format!("/accounts/{stake_address}/utxos").as_str(),
            pagination,
        )
        .await
    }

    /// UTXOs of a specific account filtered by asset.
    pub async fn accounts_utxos_asset(
        &self, stake_address: &str, asset: &str, pagination: Pagination,
    ) -> BlockfrostResult<Vec<AccountUtxoContentInner>> {
        self.call_paged_endpoint(
            format!("/accounts/{stake_address}/utxos/{asset}").as_str(),
            pagination,
        )
        .await
    }

    /// Transactions of a specific account.
    pub async fn accounts_transactions(
        &self, stake_address: &str, pagination: Pagination,
    ) -> BlockfrostResult<Vec<AccountTransactionsContentInner>> {
        self.call_paged_endpoint(
            format!("/accounts/{stake_address}/transactions").as_str(),
            pagination,
        )
        .await
    }
}
#[cfg(test)]
mod tests {
    use super::*;
    use serde_json::json;

    #[tokio::test]
    async fn test_accounts() {
        let json_value = json!({
            "stake_address": "stake1ux3g2c9dx2nhhehyrezyxpkstartcqmu9hk63qgfkccw5rqttygt7",
            "active": true,
            "active_epoch": 412,
            "controlled_amount": "619154618165",
            "rewards_sum": "319154618165",
            "withdrawals_sum": "12125369253",
            "reserves_sum": "319154618165",
            "treasury_sum": "12000000",
            "withdrawable_amount": "319154618165",
            "pool_id": "pool1pu5jlj4q9w9jlxeu370a3c9myx47md5j5m2str0naunn2q3lkdy",
            "drep_id": "drep124w9k5ml25kcshqet8r3g2pwk6kqdhj79thg2rphf5u5urve0an",
            "registered": true
        });

        serde_json::from_value::<AccountContent>(json_value).unwrap();
    }

    #[tokio::test]
    async fn test_account_reward() {
        let json_value = json!([
            {
                "epoch": 215,
                "amount": "12695385",
                "pool_id": "pool1pu5jlj4q9w9jlxeu370a3c9myx47md5j5m2str0naunn2q3lkdy",
                "type": "leader"
            },
            {
                "epoch": 216,
                "amount": "3586329",
                "pool_id": "pool1pu5jlj4q9w9jlxeu370a3c9myx47md5j5m2str0naunn2q3lkdy",
                "type": "leader"
            },
            {
                "epoch": 217,
                "amount": "0",
                "pool_id": "pool1pu5jlj4q9w9jlxeu370a3c9myx47md5j5m2str0naunn2q3lkdy",
                "type": "leader"
            },
            {
                "epoch": 218,
                "amount": "1395265",
                "pool_id": "pool1pu5jlj4q9w9jlxeu370a3c9myx47md5j5m2str0naunn2q3lkdy",
                "type": "leader"
            }
        ]);

        serde_json::from_value::<Vec<AccountRewardContentInner>>(json_value).unwrap();
    }

    #[tokio::test]
    async fn test_account_history() {
        let json_value = json!([
            {
                "active_epoch": 210,
                "amount": "12695385",
                "pool_id": "pool1pu5jlj4q9w9jlxeu370a3c9myx47md5j5m2str0naunn2q3lkdy"
            },
            {
                "active_epoch": 211,
                "amount": "22695385",
                "pool_id": "pool1pu5jlj4q9w9jlxeu370a3c9myx47md5j5m2str0naunn2q3lkdy"
            }
        ]);

        serde_json::from_value::<Vec<AccountHistoryContentInner>>(json_value).unwrap();
    }

    #[tokio::test]
    async fn test_account_delegation() {
        let json_value = json!([
            {
                "active_epoch": 210,
                "tx_hash": "2dd15e0ef6e6a17841cb9541c27724072ce4d4b79b91e58432fbaa32d9572531",
                "amount": "12695385",
                "pool_id": "pool1pu5jlj4q9w9jlxeu370a3c9myx47md5j5m2str0naunn2q3lkdy",
                "tx_slot": 42000000,
                "block_time": 1635505891,
                "block_height": 69
            },
            {
                "active_epoch": 242,
                "tx_hash": "1a0570af966fb355a7160e4f82d5a80b8681b7955f5d44bec0dde628516157f0",
                "amount": "12691385",
                "pool_id": "pool1kchver88u3kygsak8wgll7htr8uxn5v35lfrsyy842nkscrzyvj",
                "tx_slot": 43000000,
                "block_time": 1635505892,
                "block_height": 70
            }
        ]);

        serde_json::from_value::<Vec<AccountDelegationContentInner>>(json_value).unwrap();
    }

    #[tokio::test]
    async fn test_account_registration() {
        let json_value = json!([
            {
                "tx_hash": "2dd15e0ef6e6a17841cb9541c27724072ce4d4b79b91e58432fbaa32d9572531",
                "action": "registered",
                "tx_slot": 42000000,
                "block_time": 1635505891,
                "block_height": 69
            },
            {
                "tx_hash": "1a0570af966fb355a7160e4f82d5a80b8681b7955f5d44bec0dde628516157f0",
                "action": "deregistered",
                "tx_slot": 43000000,
                "block_time": 1635505892,
                "block_height": 70
            }
        ]);

        serde_json::from_value::<Vec<AccountRegistrationContentInner>>(json_value).unwrap();
    }

    #[tokio::test]
    async fn test_account_withdrawal() {
        let json_value = json!([
            {
                "tx_hash": "48a9625c841eea0dd2bb6cf551eabe6523b7290c9ce34be74eedef2dd8f7ecc5",
                "amount": "454541212442",
                "tx_slot": 42000000,
                "block_time": 1635505891,
                "block_height": 69
            },
            {
                "tx_hash": "4230b0cbccf6f449f0847d8ad1d634a7a49df60d8c142bb8cc2dbc8ca03d9e34",
                "amount": "97846969",
                "tx_slot": 43000000,
                "block_time": 1635505892,
                "block_height": 70
            }
        ]);

        serde_json::from_value::<Vec<AccountWithdrawalContentInner>>(json_value).unwrap();
    }

    #[tokio::test]
    async fn test_account_mir() {
        let json_value = json!([
            {
                "tx_hash": "48a9625c841eea0dd2bb6cf551eabe6523b7290c9ce34be74eedef2dd8f7ecc5",
                "amount": "454541212442",
                "tx_slot": 42000000,
                "block_time": 1635505891,
                "block_height": 69
            },
            {
                "tx_hash": "4230b0cbccf6f449f0847d8ad1d634a7a49df60d8c142bb8cc2dbc8ca03d9e34",
                "amount": "97846969",
                "tx_slot": 43000000,
                "block_time": 1635505892,
                "block_height": 70
            }
        ]);

        serde_json::from_value::<Vec<AccountMirContentInner>>(json_value).unwrap();
    }

    #[tokio::test]
    async fn test_account_address() {
        let json_value = json!([
            {
                "address": "addr1qx2kd28nq8ac5prwg32hhvudlwggpgfp8utlyqxu6wqgz62f79qsdmm5dsknt9ecr5w468r9ey0fxwkdrwh08ly3tu9sy0f4qd"
            },
            {
                "address": "addr1qys3czp8s9thc6u2fqed9yq3h24nyw28uk0m6mkgn9dkckjf79qsdmm5dsknt9ecr5w468r9ey0fxwkdrwh08ly3tu9suth4w4"
            },
            {
                "address": "addr1q8j55h253zcvl326sk5qdt2n8z7eghzspe0ekxgncr796s2f79qsdmm5dsknt9ecr5w468r9ey0fxwkdrwh08ly3tu9sjmd35m"
            },
            {
                "address": "addr1q8f7gxrprank3drhx8k5grlux7ene0nlwun8y9thu8mc3yjf79qsdmm5dsknt9ecr5w468r9ey0fxwkdrwh08ly3tu9sls6vnt"
            }
        ]);

        serde_json::from_value::<Vec<AccountAddressesContentInner>>(json_value).unwrap();
    }

    #[tokio::test]
    async fn test_account_address_asset() {
        let json_value = json!([
            {
                "unit": "d5e6bf0500378d4f0da4e8dde6becec7621cd8cbf5cbb9b87013d4cc537061636542756433343132",
                "quantity": "1"
            },
            {
                "unit": "b0d07d45fe9514f80213f4020e5a61241458be626841cde717cb38a76e7574636f696e",
                "quantity": "125"
            }
        ]);

        serde_json::from_value::<Vec<AccountAddressesAssetsInner>>(json_value).unwrap();
    }

    #[tokio::test]
    async fn test_account_utxos() {
        let json_value = json!([
            {
                "address": "addr1qxqs59lphg8g6qndelq8xwqn60ag3aeyfcp33c2kdp46a09re5df3pzwwmyq946axfcejy5n4x0y99wqpgtp2gd0k09qsgy6pz",
                "tx_hash": "39a7a284c2a0948189dc45dec670211cd4d72f7b66c5726c08d9b3df11e44d58",
                "tx_index": 0,
                "output_index": 0,
                "amount": [
                    {
                        "unit": "lovelace",
                        "quantity": "42000000"
                    }
                ],
                "block": "7eb8e27d18686c7db9a18f8bbcfe34e3fed6e047afaa2d969904d15e934847e6",
                "data_hash": null,
                "inline_datum": null,
                "reference_script_hash": null
            }
        ]);

        serde_json::from_value::<Vec<AccountUtxoContentInner>>(json_value).unwrap();
    }

    #[tokio::test]
    async fn test_account_transactions() {
        let json_value = json!([
            {
                "address": "addr1qxqs59lphg8g6qndelq8xwqn60ag3aeyfcp33c2kdp46a09re5df3pzwwmyq946axfcejy5n4x0y99wqpgtp2gd0k09qsgy6pz",
                "tx_hash": "8788591983aa73981fc92d6cddbbe643959f5a784e84b8bee0db15823f575a5b",
                "tx_index": 6,
                "block_height": 69,
                "block_time": 1635505891
            },
            {
                "address": "addr1qxqs59lphg8g6qndelq8xwqn60ag3aeyfcp33c2kdp46a09re5df3pzwwmyq946axfcejy5n4x0y99wqpgtp2gd0k09qsgy6pz",
                "tx_hash": "52e748c4dec58b687b90b0b40d383b9fe1f24c1a833b7395cdf07dd67859f46f",
                "tx_index": 9,
                "block_height": 4547,
                "block_time": 1635505891
            }
        ]);

        serde_json::from_value::<Vec<AccountTransactionsContentInner>>(json_value).unwrap();
    }
}