fix: get UTXO ordinal data in batches

api/ordinals.ts

@@ -1,5 +1,6 @@
 import axios from 'axios';
 import BitcoinEsploraApiProvider from '../api/esplora/esploraAPiProvider';
+import XordApiProvider from '../api/ordinals/provider';
 import { INSCRIPTION_REQUESTS_SERVICE_URL, ORDINALS_URL, XVERSE_API_BASE_URL, XVERSE_INSCRIBE_URL } from '../constant';
 import {
   Account,
@@ -47,28 +48,31 @@
   const btcClient = new BitcoinEsploraApiProvider({
     network,
   });
-  const addressUTXOs = await btcClient.getUnspentUtxos(btcAddress);
-  const ordinals: BtcOrdinal[] = [];
+  const xordClient = new XordApiProvider({
+    network,
+  });
 
-  await Promise.all(
-    addressUTXOs
-      .filter((utxo) => utxo.status.confirmed) // we can only detect ordinals from confirmed utxos
-      .map(async (utxo: UTXO) => {
-        const ordinalContentUrl = `${XVERSE_INSCRIBE_URL(network)}/v1/inscriptions/utxo/${utxo.txid}/${utxo.vout}`;
+  const [addressUTXOs, inscriptions] = await Promise.all([
+    btcClient.getUnspentUtxos(btcAddress),
+    xordClient.getAllInscriptions(btcAddress),
+  ]);
+  const ordinals: BtcOrdinal[] = [];
 
-        const ordinalIds = await axios.get<string[]>(ordinalContentUrl);
+  const utxoMap = addressUTXOs.reduce((acc, utxo) => {
+    acc[`${utxo.txid}:${utxo.vout}`] = utxo;
+    return acc;
+  }, {} as Record<string, UTXO>);
 
-        if (ordinalIds.data.length > 0) {
-          ordinalIds.data.forEach((ordinalId) => {
-            ordinals.push({
-              id: ordinalId,
-              confirmationTime: utxo.status.block_time || 0,
-              utxo,
-            });
-          });
-        }
-      }),
-  );
+  inscriptions.forEach((inscription) => {
+    const utxo = utxoMap[inscription.output];
+    if (utxo) {
+      ordinals.push({
+        id: inscription.id,
+        confirmationTime: utxo.status.block_time || 0,
+        utxo,
+      });
+    }
+  });
 
   return ordinals.sort(sortOrdinalsByConfirmationTime);
 }
@@ -97,8 +101,8 @@
       timeout: 30000,
       transformResponse: [(data) => parseOrdinalTextContentData(data)],
     })
     .then((response) => response!.data)
     .catch((error) => {
       return '';
     });
 }
@@ -128,9 +132,9 @@
     })
     .then((response) => {
       if (response.data) {
         const responseTokensList = response!.data;
         const tokensList: Array<FungibleToken> = [];
         responseTokensList.forEach((responseToken: any) => {
           const token: FungibleToken = {
             name: responseToken.ticker,
             balance: responseToken.overallBalance,
@@ -153,7 +157,7 @@
         return [];
       }
     })
     .catch((error) => {
       return [];
     });
 }

api/ordinals/provider.ts

@@ -111,6 +111,19 @@ export default class OrdinalsApi implements OrdinalsApiProvider {
     }
   }
 
+  async getAllInscriptions(address: string): Promise<ordinalsType.Inscription[]> {
+    const firstPage = await this.getInscriptions(address, 0, 100);
+    const results = [...firstPage.results];
+
+    // we do this sequentially to avoid rate limiting
+    while (results.length < firstPage.total) {
+      const nextPage = await this.getInscriptions(address, results.length, firstPage.limit);
+      results.push(...nextPage.results);
+    }
+
+    return results;
+  }
+
   async getInscriptions(address: string, offset: number, limit: number): Promise<ordinalsType.InscriptionsList> {
     const url = 'inscriptions';
     const params = {