Accounts addresses assets (#119)

* feat: accountsAddressesAssets endpoints

* fix: tests

CHANGELOG.MD

@@ -5,6 +5,12 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [1.2.0]
+
+### Added
+
+- `accountsAddressesAssets` and `accountsAddressesAssetsAll` endpoints
+
 ## [1.1.0]
 
 ### Added

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@blockfrost/blockfrost-js",
-  "version": "1.1.0",
+  "version": "1.2.0",
   "description": "A JavaScript/TypeScript SDK for interacting with the https://blockfrost.io API",
   "keywords": [
     "blockfrost",

src/BlockFrostAPI.ts

@@ -19,6 +19,8 @@ import {
   accountsMirsAll,
   accountsAddresses,
   accountsAddressesAll,
+  accountsAddressesAssets,
+  accountsAddressesAssetsAll,
 } from './endpoints/api/accounts';
 
 import {
@@ -279,6 +281,24 @@ class BlockFrostAPI {
    */
   accountsAddressesAll = accountsAddressesAll;
 
+  /**
+   * accountsAddressesAssets - Obtain information about assets associated with addresses of a specific account.
+   *
+   * @param stakeAddress - Bech32 stake address
+   * @returns Assets associated with the account addresses
+   *
+   */
+  accountsAddressesAssets = accountsAddressesAssets;
+
+  /**
+   * accountsAddressesAssets - Obtain information about assets associated with addresses of a specific account.
+   *
+   * @param stakeAddress - Bech32 stake address
+   * @returns Assets associated with the account addresses
+   *
+   */
+  accountsAddressesAssetsAll = accountsAddressesAssetsAll;
+
   /**
    * assets - List of assets.
    *

src/endpoints/api/accounts/index.ts

@@ -423,3 +423,63 @@ export async function accountsAddressesAll(
     }
   }
 }
+
+export async function accountsAddressesAssets(
+  this: BlockFrostAPI,
+  stakeAddress: string,
+  pagination?: PaginationOptions,
+): Promise<components['schemas']['account_addresses_assets']> {
+  const paginationOptions = getPaginationOptions(pagination);
+
+  return new Promise((resolve, reject) => {
+    this.axiosInstance(
+      `${this.apiUrl}/accounts/${stakeAddress}/addresses/assets`,
+      {
+        params: {
+          page: paginationOptions.page,
+          count: paginationOptions.count,
+          order: paginationOptions.order,
+        },
+      },
+    )
+      .then(resp => {
+        resolve(resp.data);
+      })
+      .catch(err => reject(handleError(err)));
+  });
+}
+
+export async function accountsAddressesAssetsAll(
+  this: BlockFrostAPI,
+  stakeAddress: string,
+  allMethodOptions?: AllMethodOptions,
+): Promise<components['schemas']['account_addresses_assets']> {
+  let page = 1;
+  const count = DEFAULT_PAGINATION_PAGE_ITEMS_COUNT;
+  const res: components['schemas']['account_addresses_assets'] = [];
+  const options = getAllMethodOptions(allMethodOptions);
+
+  const getPromiseBundle = () => {
+    const promises = [...Array(options.batchSize).keys()].map(i =>
+      this.accountsAddressesAssets(stakeAddress, {
+        page: page + i,
+        count,
+        order: options.order,
+      }),
+    );
+    page += options.batchSize;
+    return promises;
+  };
+
+  // eslint-disable-next-line no-constant-condition
+  while (true) {
+    const promiseBundle = getPromiseBundle();
+    const pages = await Promise.all(promiseBundle);
+    for (const page of pages) {
+      res.push(...page);
+      if (page.length < DEFAULT_PAGINATION_PAGE_ITEMS_COUNT) {
+        return res;
+      }
+    }
+  }
+}

test/fixtures/endpoints/accounts.ts

@@ -148,4 +148,28 @@ export default [
       }),
     ]),
   },
+  {
+    command: (SDK: BlockFrostAPI) =>
+      SDK.accountsAddressesAssets(
+        'stake1u9e45fvvd4ujpc0kka0pnx9zqdvh9wl96nsg6sje0f5hmfq45lrja',
+      ),
+    response: expect.arrayContaining([
+      expect.objectContaining({
+        unit: expect.any(String),
+        quantity: expect.any(String),
+      }),
+    ]),
+  },
+  {
+    command: (SDK: BlockFrostAPI) =>
+      SDK.accountsAddressesAssetsAll(
+        'stake1u9e45fvvd4ujpc0kka0pnx9zqdvh9wl96nsg6sje0f5hmfq45lrja',
+      ),
+    response: expect.arrayContaining([
+      expect.objectContaining({
+        unit: expect.any(String),
+        quantity: expect.any(String),
+      }),
+    ]),
+  },
 ] as const;