Merge pull request #128 from Permissionless-Software-Foundation/ct-unstable

fix(hydrateUtxos): Adding better error handler

package-lock.json

@@ -10,7 +10,7 @@
       "license": "MIT",
       "dependencies": {
         "@psf/bip21": "^2.0.1",
-        "@psf/bip32-utils": "^0.13.1",
+        "@psf/bip32-utils": "^1.0.0",
         "@psf/bitcoincash-ops": "^2.0.0",
         "@psf/bitcoincashjs-lib": "^4.0.2",
         "@psf/coininfo": "^4.0.0",
@@ -576,11 +576,11 @@
       }
     },
     "node_modules/@psf/bip32-utils": {
-      "version": "0.13.1",
-      "resolved": "https://registry.npmjs.org/@psf/bip32-utils/-/bip32-utils-0.13.1.tgz",
-      "integrity": "sha512-5yM2o4TXW3gWKI3zxUFj9eeYqMYbA4Q1w+ptcfb+XnGpSZLrmwGtX48q8rApIKtikRceMEFXp1Jq6ed+bS+1nA==",
+      "version": "1.0.0",
+      "resolved": "https://registry.npmjs.org/@psf/bip32-utils/-/bip32-utils-1.0.0.tgz",
+      "integrity": "sha512-cWE+uZsGyS2PsE5+bplNq7w/oE3/wGGP0pZV9TiSNMIQvJguxfu7Ruk2FuzROcaVysBclDaL70A9N3sAnworGA==",
       "dependencies": {
-        "keccak": "^1.3.0",
+        "keccak": "^3.0.1",
         "nyc": "*",
         "standard": "^11.0.1",
         "tape": "*"
@@ -5697,18 +5697,16 @@
       "dev": true
     },
     "node_modules/keccak": {
-      "version": "1.4.0",
-      "resolved": "https://registry.npmjs.org/keccak/-/keccak-1.4.0.tgz",
-      "integrity": "sha512-eZVaCpblK5formjPjeTBik7TAg+pqnDrMHIffSvi9Lh7PQgM1+hSzakUeZFCk9DVVG0dacZJuaz2ntwlzZUIBw==",
+      "version": "3.0.1",
+      "resolved": "https://registry.npmjs.org/keccak/-/keccak-3.0.1.tgz",
+      "integrity": "sha512-epq90L9jlFWCW7+pQa6JOnKn2Xgl2mtI664seYR6MHskvI9agt7AnDqmAlp9TqU4/caMYbA08Hi5DMZAl5zdkA==",
       "hasInstallScript": true,
       "dependencies": {
-        "bindings": "^1.2.1",
-        "inherits": "^2.0.3",
-        "nan": "^2.2.1",
-        "safe-buffer": "^5.1.0"
+        "node-addon-api": "^2.0.0",
+        "node-gyp-build": "^4.2.0"
       },
       "engines": {
-        "node": ">=4.0.0"
+        "node": ">=10.0.0"
       }
     },
     "node_modules/kind-of": {
@@ -6878,6 +6876,11 @@
         "@sinonjs/commons": "^1.7.0"
       }
     },
+    "node_modules/node-addon-api": {
+      "version": "2.0.2",
+      "resolved": "https://registry.npmjs.org/node-addon-api/-/node-addon-api-2.0.2.tgz",
+      "integrity": "sha512-Ntyt4AIXyaLIuMHF6IOoTakB3K+RWxwtsHNRxllEoA6vPwP9o4866g6YWDLUdnucilZhmkxiHwHr11gAENw+QA=="
+    },
     "node_modules/node-emoji": {
       "version": "1.10.0",
       "resolved": "https://registry.npmjs.org/node-emoji/-/node-emoji-1.10.0.tgz",
@@ -6915,6 +6918,16 @@
         "node": "4.x || >=6.0.0"
       }
     },
+    "node_modules/node-gyp-build": {
+      "version": "4.2.3",
+      "resolved": "https://registry.npmjs.org/node-gyp-build/-/node-gyp-build-4.2.3.tgz",
+      "integrity": "sha512-MN6ZpzmfNCRM+3t57PTJHgHyw/h4OWnZ6mR8P5j/uZtqQr46RRuDE/P+g3n0YR/AiYXeWixZZzaip77gdICfRg==",
+      "bin": {
+        "node-gyp-build": "bin.js",
+        "node-gyp-build-optional": "optional.js",
+        "node-gyp-build-test": "build-test.js"
+      }
+    },
     "node_modules/node-mocks-http": {
       "version": "1.10.1",
       "resolved": "https://registry.npmjs.org/node-mocks-http/-/node-mocks-http-1.10.1.tgz",
@@ -17611,11 +17624,11 @@
       }
     },
     "@psf/bip32-utils": {
-      "version": "0.13.1",
-      "resolved": "https://registry.npmjs.org/@psf/bip32-utils/-/bip32-utils-0.13.1.tgz",
-      "integrity": "sha512-5yM2o4TXW3gWKI3zxUFj9eeYqMYbA4Q1w+ptcfb+XnGpSZLrmwGtX48q8rApIKtikRceMEFXp1Jq6ed+bS+1nA==",
+      "version": "1.0.0",
+      "resolved": "https://registry.npmjs.org/@psf/bip32-utils/-/bip32-utils-1.0.0.tgz",
+      "integrity": "sha512-cWE+uZsGyS2PsE5+bplNq7w/oE3/wGGP0pZV9TiSNMIQvJguxfu7Ruk2FuzROcaVysBclDaL70A9N3sAnworGA==",
       "requires": {
-        "keccak": "^1.3.0",
+        "keccak": "^3.0.1",
         "nyc": "*",
         "standard": "^11.0.1",
         "tape": "*"
@@ -21827,14 +21840,12 @@
       "dev": true
     },
     "keccak": {
-      "version": "1.4.0",
-      "resolved": "https://registry.npmjs.org/keccak/-/keccak-1.4.0.tgz",
-      "integrity": "sha512-eZVaCpblK5formjPjeTBik7TAg+pqnDrMHIffSvi9Lh7PQgM1+hSzakUeZFCk9DVVG0dacZJuaz2ntwlzZUIBw==",
+      "version": "3.0.1",
+      "resolved": "https://registry.npmjs.org/keccak/-/keccak-3.0.1.tgz",
+      "integrity": "sha512-epq90L9jlFWCW7+pQa6JOnKn2Xgl2mtI664seYR6MHskvI9agt7AnDqmAlp9TqU4/caMYbA08Hi5DMZAl5zdkA==",
       "requires": {
-        "bindings": "^1.2.1",
-        "inherits": "^2.0.3",
-        "nan": "^2.2.1",
-        "safe-buffer": "^5.1.0"
+        "node-addon-api": "^2.0.0",
+        "node-gyp-build": "^4.2.0"
       }
     },
     "kind-of": {
@@ -22815,6 +22826,11 @@
         }
       }
     },
+    "node-addon-api": {
+      "version": "2.0.2",
+      "resolved": "https://registry.npmjs.org/node-addon-api/-/node-addon-api-2.0.2.tgz",
+      "integrity": "sha512-Ntyt4AIXyaLIuMHF6IOoTakB3K+RWxwtsHNRxllEoA6vPwP9o4866g6YWDLUdnucilZhmkxiHwHr11gAENw+QA=="
+    },
     "node-emoji": {
       "version": "1.10.0",
       "resolved": "https://registry.npmjs.org/node-emoji/-/node-emoji-1.10.0.tgz",
@@ -22848,6 +22864,11 @@
       "integrity": "sha512-V4aYg89jEoVRxRb2fJdAg8FHvI7cEyYdVAh94HH0UIK8oJxUfkjlDQN9RbMx+bEjP7+ggMiFRprSti032Oipxw==",
       "dev": true
     },
+    "node-gyp-build": {
+      "version": "4.2.3",
+      "resolved": "https://registry.npmjs.org/node-gyp-build/-/node-gyp-build-4.2.3.tgz",
+      "integrity": "sha512-MN6ZpzmfNCRM+3t57PTJHgHyw/h4OWnZ6mR8P5j/uZtqQr46RRuDE/P+g3n0YR/AiYXeWixZZzaip77gdICfRg=="
+    },
     "node-mocks-http": {
       "version": "1.10.1",
       "resolved": "https://registry.npmjs.org/node-mocks-http/-/node-mocks-http-1.10.1.tgz",

package.json

@@ -16,8 +16,9 @@
     "test:integration:local:abc": "export RESTURL=http://localhost:3000/v4/ && mocha --timeout 30000 test/integration && mocha --timeout 30000 test/integration/chains/abc/",
     "test:integration:local:bchn": "export RESTURL=http://localhost:3000/v4/ && mocha --timeout 30000 test/integration/ && mocha --timeout 30000 test/integration/chains/bchn/",
     "test:integration:local:testnet": "RESTURL=http://localhost:4000/v4/ mocha --timeout 30000 test/integration/chains/testnet",
+    "test:integration:decatur:bchn": "export RESTURL=http://192.168.0.36:3000/v4/ && mocha --timeout 30000 test/integration/",
     "test:temp": "export RESTURL=http://localhost:3000/v4/ && mocha --timeout 30000 -g '#hydrateUtxos' test/integration/",
-    "test:temp2": "mocha --timeout=30000 -g '#Util' test/unit/",
+    "test:temp2": "mocha --timeout=30000 -g '#_hydrateUtxo' test/unit/",
     "test:temp3": "export RESTURL=https://bchn.fullstack.cash/v4/ && mocha --timeout 30000 -g '#hydrateUtxos' test/integration/",
     "test:temp4": "export RESTURL=http://localhost:3000/v4/ && mocha --timeout 30000 -g '#decodeOpReturn' test/integration/",
     "coverage": "nyc report --reporter=text-lcov | coveralls",
@@ -33,7 +34,7 @@
   },
   "dependencies": {
     "@psf/bip21": "^2.0.1",
-    "@psf/bip32-utils": "^0.13.1",
+    "@psf/bip32-utils": "^1.0.0",
     "@psf/bitcoincash-ops": "^2.0.0",
     "@psf/bitcoincashjs-lib": "^4.0.2",
     "@psf/coininfo": "^4.0.0",

src/electrumx.js

@@ -284,7 +284,7 @@ class ElectrumX {
    *   }
    *
    */
-  async transactions (address) {
+  async transactions (address, usrObj = null) {
     try {
       // Handle single address.
       if (typeof address === 'string') {
@@ -299,7 +299,8 @@ class ElectrumX {
         const response = await axios.post(
           `${this.restURL}electrumx/transactions`,
           {
-            addresses: address
+            addresses: address,
+            usrObj // pass user data when making an internal call.
           },
           _this.axiosOptions
         )

src/raw-transactions.js

@@ -263,7 +263,7 @@ class RawTransactions {
    * //   time: 1547752564,
    * //   blocktime: 1547752564 } ]
    */
-  async getRawTransaction (txid, verbose = false) {
+  async getRawTransaction (txid, verbose = false, usrObj = null) {
     try {
       if (typeof txid === 'string') {
         const response = await axios.get(
@@ -278,7 +278,8 @@ class RawTransactions {
           url: `${this.restURL}rawtransactions/getRawTransaction`,
           data: {
             txids: txid,
-            verbose: verbose
+            verbose: verbose,
+            usrObj // pass user data when making an internal call.
           },
           headers: _this.axiosOptions.headers
         }

src/slp/utils.js

@@ -1,12 +1,12 @@
+/* eslint-disable no-useless-catch */
+
 // Public npm libraries
 const axios = require('axios')
 const slpParser = require('slp-parser')
 const BigNumber = require('bignumber.js')
 
-// const Script = require("../script")
-// const scriptLib = new Script()
-
-// const BigNumber = require("bignumber.js")
+// Local libraries
+const Util = require('../util')
 
 let _this
 
@@ -37,6 +37,8 @@ class Utils {
     _this = this
 
     this.whitelist = []
+
+    this.util = new Util(config)
   }
 
   /**
@@ -440,7 +442,7 @@ class Utils {
     const path = `${this.restURL}slp/validateTxid`
 
     // console.log(`txid: ${JSON.stringify(txid, null, 2)}`)
-    console.log(`validateTxid usrObj: ${JSON.stringify(usrObj, null, 2)}`)
+    // console.log(`validateTxid usrObj: ${JSON.stringify(usrObj, null, 2)}`)
 
     // Handle a single TXID or an array of TXIDs.
     let txids
@@ -452,7 +454,7 @@ class Utils {
         path,
         {
           txids: txids,
-          usrObj
+          usrObj // pass user data when making an internal call.
         },
         _this.axiosOptions
       )
@@ -651,12 +653,12 @@ class Utils {
    *     '00ea27261196a411776f81029c0ebe34362936b4a9847deb1f7a40a02b3a1476',
    *    valid: true } ]
    */
-  async validateTxid3 (txid, usbObj = null) {
+  async validateTxid3 (txid, usrObj = null) {
     const path = `${this.restURL}slp/validateTxid3`
 
     // console.log(`txid: ${JSON.stringify(txid, null, 2)}`)
     // console.log(`path: ${JSON.stringify(path, null, 2)}`)
-    console.log('validateTxid3 usbObj: ', usbObj)
+    // console.log('validateTxid3 usrObj: ', usrObj)
 
     // Handle a single TXID or an array of TXIDs.
     let txids
@@ -668,7 +670,7 @@ class Utils {
         path,
         {
           txids: txids,
-          usbObj
+          usrObj // pass user data when making an internal call.
         },
         _this.axiosOptions
       )
@@ -897,6 +899,9 @@ class Utils {
    * If optional associative array parameter cache is used, will cache and
    * reuse responses for the same input.
    *
+   * A third optional input, `usrObj`, is used by bch-api for managing rate limits.
+   * It can be safely ignored when writing apps using this call.
+   *
    *
    * @apiExample Example usage:
    *
@@ -926,7 +931,7 @@ class Utils {
    *
    */
   // Reimplementation of decodeOpReturn() using slp-parser.
-  async decodeOpReturn (txid, cache = null, ip = null) {
+  async decodeOpReturn (txid, cache = null, usrObj = null) {
     // The cache object is an in-memory cache (JS Object) that can be passed
     // into this function. It helps if multiple vouts from the same TXID are
     // being evaluated. In that case, it can significantly reduce the number
@@ -943,7 +948,7 @@ class Utils {
       if (cachedVal) return cachedVal
     }
 
-    console.log(`decodeOpReturn ip: ${ip}`)
+    // console.log(`decodeOpReturn usrObj: ${JSON.stringify(usrObj, null, 2)}`)
 
     try {
       // Validate the txid input.
@@ -953,22 +958,17 @@ class Utils {
 
       // CT: 2/24/21 Deprected GET in favor of POST, to pass IP address.
       // Retrieve the transaction object from the full node.
-      // const path = `${this.restURL}rawtransactions/getRawTransaction/${txid}?verbose=true`
-      // const response = await _this.axios.get(path, _this.axiosOptions)
-      // const txDetails = response.data
-
       const path = `${this.restURL}rawtransactions/getRawTransaction`
       const response = await _this.axios.post(
         path,
         {
           verbose: true,
           txids: [txid],
-          ip
+          usrObj // pass user data when making an internal call.
         },
         _this.axiosOptions
       )
       const txDetails = response.data[0]
-
       // console.log(`txDetails: ${JSON.stringify(txDetails, null, 2)}`)
 
       // SLP spec expects OP_RETURN to be the first output of the transaction.
@@ -1015,8 +1015,16 @@ class Utils {
 
       return tokenData
     } catch (error) {
+      // Used for debugging
       // console.log('decodeOpReturn error: ', error)
-      if (error.response && error.response.data) throw error.response.data
+      // console.log(`decodeOpReturn error.message: ${error.message}`)
+      // if (error.response && error.response.data) {
+      //   console.log(
+      //     `decodeOpReturn error.response.data: ${JSON.stringify(
+      //       error.response.data
+      //     )}`
+      //   )
+      // }
       throw error
     }
   }
@@ -1029,18 +1037,30 @@ class Utils {
    *
    * Expects an array of UTXO objects as input. Returns an array of equal size.
    * Returns UTXO data hydrated with token information.
-   * If the
-   * UTXO does not belong to a SLP transaction, it will return an `isValid` property
-   * set to false.
-   * If the UTXO is part of an SLP transaction, it will return the UTXO object
-   * with additional SLP information attached. An `isValid` property will be included.
-   * If its value is true, the UTXO is a valid SLP UTXO.
-   * If the isValid value is null,
-   * then SLPDB has not yet processed that txid and validity has not been confirmed,
-   * or a 429 rate-limit error was enountered during the processing of the request.
    *
-   * This is an API-heavy call. If you get a lot of null values, then slow down
-   * the calls or request info on fewer UTXOs at a time.
+   * - If the UTXO does not belong to a SLP transaction, it will return an
+   * `isValid` property set to `false`.
+   *
+   * - If the UTXO is part of an SLP transaction, it will return the UTXO object
+   * with additional SLP information attached. An `isValid` property will be
+   * included.
+   *   - If the `isValid` property is `true`, the UTXO is a valid SLP UTXO.
+   *   - If the `isValid` property is `null`, then SLPDB has not yet processed
+   *     that txid and validity has not been confirmed, or a 429 rate-limit error
+   *     was enountered during the processing of the request.
+   *
+   * An optional second input object, `usrObj`, allows the user to inject an
+   * artifical delay while processing UTXOs. If `usrObj.utxoDelay` is set to
+   * a number, the call will delay by that number of milliseconds between
+   * processing UTXOs.
+   *
+   * This is an API-heavy call. If you get a lot of `null` values, then slow down
+   * the calls by using the usrObj.utxoDelay property, or request info on fewer
+   * UTXOs at a
+   * time. `null` indicates that the UTXO can *not* be safely spent, because
+   * a judgement as to weather it is a token UTXO has not been made. Spending it
+   * could burn tokens. It's safest to ignore UTXOs with a value of `null`.
+   *
    *
    * @apiExample Example usage:
    *
@@ -1048,7 +1068,8 @@ class Utils {
    * try {
    *  const utxos = await bchjs.Electrumx.utxo(`bitcoincash:qpcqs0n5xap26un2828n55gan2ylj7wavvzeuwdx05`)
    *
-   *  const utxoInfo = await bchjs.SLP.Utils.tokenUtxoDetails(utxos)
+   *  // Delay 100mS between processing UTXOs, to prevent rate-limit errors.
+   *  const utxoInfo = await bchjs.SLP.Utils.tokenUtxoDetails(utxos, { utxoDelay: 100 })
    *
    *  console.log(`utxoInfo: ${JSON.stringify(utxoInfo, null, 2)}`)
    * } catch (error) {
@@ -1081,12 +1102,12 @@ class Utils {
   // https://github.com/Bitcoin-com/slp-sdk/issues/84
 
   // CT 5/31/20: Refactored to use slp-parse library.
-  async tokenUtxoDetails (utxos, usbObj = null) {
+  async tokenUtxoDetails (utxos, usrObj = null) {
     try {
       // Throw error if input is not an array.
       if (!Array.isArray(utxos)) throw new Error('Input must be an array.')
 
-      console.log(`tokenUtxoDetails usbObj: ${JSON.stringify(usbObj, null, 2)}`)
+      // console.log(`tokenUtxoDetails usrObj: ${JSON.stringify(usrObj, null, 2)}`)
 
       // Loop through each element in the array and validate the input before
       // further processing.
@@ -1119,7 +1140,7 @@ class Utils {
       }
 
       // Hydrate each UTXO with data from SLP OP_REUTRNs.
-      const outAry = await this._hydrateUtxo(utxos, usbObj)
+      const outAry = await this._hydrateUtxo(utxos, usrObj)
       // console.log(`outAry: ${JSON.stringify(outAry, null, 2)}`)
 
       // *After* each UTXO has been hydrated with SLP data,
@@ -1130,12 +1151,12 @@ class Utils {
         // *After* the UTXO has been hydrated with SLP data,
         // validate the TXID with SLPDB.
         if (utxo.tokenType) {
-          // Only execute this block if the current UTXO has a 'tokenType'
+          // Only execute this code-path if the current UTXO has a 'tokenType'
           // property. i.e. it has been successfully hydrated with SLP
           // information.
 
           // Validate using a 'waterfall' of validators.
-          utxo.isValid = await this.waterfallValidateTxid(utxo.txid, usbObj)
+          utxo.isValid = await this.waterfallValidateTxid(utxo.txid, usrObj)
           // console.log(`isValid: ${JSON.stringify(utxo.isValid, null, 2)}`)
         }
       }
@@ -1239,11 +1260,25 @@ class Utils {
   // This is a private function that is called by tokenUtxoDetails().
   // It loops through an array of UTXOs and tries to hydrate them with SLP
   // token information from the OP_RETURN data.
-  async _hydrateUtxo (utxos, usbObj = null) {
+  //
+  // This function makes several calls to decodeOpReturn() to retrieve SLP
+  // token data. If that call throws an error due to hitting rate limits, this
+  // function will not throw an error. Instead, it will mark the `isValid`
+  // property as `null`
+  //
+  // Exception to the above: It *will* throw an error if decodeOpReturn() throws
+  // an error while trying to get the Genesis transaction for a Send or Mint
+  // transaction. However, that is a rare occurence since the cache of
+  // decodeOpReturn() will minimize API calls for this case. This behavior
+  // could be changed, but right now it's a corner case of a corner case.
+  //
+  // If the usrObj has a utxoDelay property, then it will delay the loop for
+  // each UTXO by that many milliseconds.
+  async _hydrateUtxo (utxos, usrObj = null) {
     try {
       const decodeOpReturnCache = {}
 
-      console.log(`_hydrateUtxo usbObj: ${JSON.stringify(usbObj, null, 2)}`)
+      // console.log(`_hydrateUtxo usrObj: ${JSON.stringify(usrObj, null, 2)}`)
 
       // Output Array
       const outAry = []
@@ -1252,6 +1287,12 @@ class Utils {
       for (let i = 0; i < utxos.length; i++) {
         const utxo = utxos[i]
 
+        // If the user passes in a delay, then wait.
+        if (usrObj && usrObj.utxoDelay && !isNaN(Number(usrObj.utxoDelay))) {
+          const delayMs = Number(usrObj.utxoDelay)
+          await this.util.sleep(delayMs)
+        }
+
         // Get raw transaction data from the full node and attempt to decode
         // the OP_RETURN data.
         // If there is no OP_RETURN, mark the UTXO as false.
@@ -1260,11 +1301,14 @@ class Utils {
           slpData = await this.decodeOpReturn(
             utxo.txid,
             decodeOpReturnCache,
-            usbObj
+            usrObj // pass user data when making an internal call.
           )
           // console.log(`slpData: ${JSON.stringify(slpData, null, 2)}`)
         } catch (err) {
-          // console.log(`error from decodeOpReturn(${utxo.txid}): `, err)
+          // console.log(
+          //   `error in _hydrateUtxo() from decodeOpReturn(${utxo.txid}): `,
+          //   err
+          // )
 
           // An error will be thrown if the txid is not SLP.
           // If error is for some other reason, like a 429 error, mark utxo as 'null'
@@ -1276,7 +1320,7 @@ class Utils {
               err.message.indexOf('trailing data') === -1)
           ) {
             // console.log(
-            //   'unknown error from decodeOpReturn(). Marking as \'null\'',
+            //   "unknown error from decodeOpReturn(). Marking as 'null'",
             //   err
             // )
 
@@ -1295,6 +1339,7 @@ class Utils {
           // Halt the execution of the loop and increase to the next index.
           continue
         }
+        // console.log(`slpData: ${JSON.stringify(slpData, null, 2)}`)
 
         const txType = slpData.txType.toLowerCase()
 
@@ -1332,6 +1377,10 @@ class Utils {
             utxo.decimals = slpData.decimals
             utxo.tokenType = slpData.tokenType
 
+            // Initial value is null until UTXO can be validated and confirmed
+            // to be valid (true) or not (false).
+            utxo.isValid = null
+
             outAry[i] = utxo
           }
         }
@@ -1352,7 +1401,7 @@ class Utils {
             const genesisData = await this.decodeOpReturn(
               slpData.tokenId,
               decodeOpReturnCache,
-              usbObj
+              usrObj // pass user data when making an internal call.
             )
             // console.log(`genesisData: ${JSON.stringify(genesisData, null, 2)}`)
 
@@ -1381,6 +1430,10 @@ class Utils {
 
             utxo.mintBatonVout = slpData.mintBatonVout
 
+            // Initial value is null until UTXO can be validated and confirmed
+            // to be valid (true) or not (false).
+            utxo.isValid = null
+
             outAry[i] = utxo
           }
         }
@@ -1405,7 +1458,7 @@ class Utils {
             const genesisData = await this.decodeOpReturn(
               slpData.tokenId,
               decodeOpReturnCache,
-              usbObj
+              usrObj // pass user data when making an internal call.
             )
             // console.log(`genesisData: ${JSON.stringify(genesisData, null, 2)}`)
 
@@ -1422,6 +1475,10 @@ class Utils {
             utxo.decimals = genesisData.decimals
             utxo.tokenType = slpData.tokenType
 
+            // Initial value is null until UTXO can be validated and confirmed
+            // to be valid (true) or not (false).
+            utxo.isValid = null
+
             // Calculate the real token quantity.
 
             const tokenQtyBig = new BigNumber(tokenQty).div(
@@ -1439,7 +1496,7 @@ class Utils {
 
       return outAry
     } catch (error) {
-      if (error.response && error.response.data) throw error.response.data
+      // console.log('_hydrateUtxo error: ', error)
       throw error
     }
   }
@@ -1480,7 +1537,7 @@ class Utils {
    * // returns
    * true
    */
-  async waterfallValidateTxid (txid, usbObj = null) {
+  async waterfallValidateTxid (txid, usrObj = null) {
     try {
       // console.log('txid: ', txid)
 
@@ -1512,7 +1569,7 @@ class Utils {
       // validateTxid2() uses slp-validate, which has a different output format.
 
       // Validate against the whitelist SLPDB first.
-      const whitelistResult = await this.validateTxid3(txid, usbObj)
+      const whitelistResult = await this.validateTxid3(txid, usrObj)
       // console.log(
       //   `whitelist-SLPDB for ${txid}: ${JSON.stringify(
       //     whitelistResult,
@@ -1533,7 +1590,7 @@ class Utils {
       }
 
       // Try the general SLPDB, if the whitelist returned null.
-      const generalResult = await this.validateTxid(txid, usbObj)
+      const generalResult = await this.validateTxid(txid, usrObj)
       // console.log(
       //   `validateTxid() isValid: ${JSON.stringify(generalResult, null, 2)}`
       // )
@@ -1586,22 +1643,33 @@ class Utils {
    * @apiDescription Hydrate a UTXO with SLP token metadata.
    *
    * The same as tokenUtxoDetails(), but uses bch-api to do the heavy lifting,
-   * which greatly reduces the number of API calls.
+   * which greatly increases the speed, since fewer API calls need to be made.
+   * However, internal API calls are still counted against your rate limits.
    *
-   * Expects an array of UTXO objects as input. Returns an array of equal size.
-   * Returns UTXO data hydrated with token information.
-   * If the
-   * UTXO does not belong to a SLP transaction, it will return an `isValid` property
-   * set to false.
-   * If the UTXO is part of an SLP transaction, it will return the UTXO object
-   * with additional SLP information attached. An `isValid` property will be included.
-   * If its value is true, the UTXO is a valid SLP UTXO.
-   * If the isValid value is null,
-   * then SLPDB has not yet processed that txid and validity has not been confirmed,
-   * or a 429 rate-limit error was enountered during the processing of the request.
+   * This function expects an array of UTXO objects as input. It returns an
+   * array of equal size. The UTXO data hydrated with token information.
+   * - If the UTXO does not belong to a SLP transaction, it will return an
+   *   `isValid` property set to `false`.
+   * - If the UTXO is part of an SLP transaction, it will return the UTXO object
+   *   with additional SLP information attached. An `isValid` property will be
+   *   included.
+   *     - If `isValid` is `true`, the UTXO is a valid SLP UTXO.
+   *     - If `isValid` is `null`, then SLPDB has not yet processed that txid
+   *       and validity has not been confirmed,
+   *       or a 429 rate-limit error was enountered during the processing of the
+   *       request.
    *
-   * This is an API-heavy call. If you get a lot of null values, then slow down
-   * the calls or request info on fewer UTXOs at a time.
+   * An optional second input object, `usrObj`, allows the user to inject an
+   * artifical delay while processing UTXOs. If `usrObj.utxoDelay` is set to
+   * a number, the call will delay by that number of milliseconds between
+   * processing UTXOs.
+   *
+   * This is an API-heavy call. If you get a lot of `null` values, then slow down
+   * the calls by using the usrObj.utxoDelay property, or request info on fewer
+   * UTXOs at a
+   * time. `null` indicates that the UTXO can *not* be safely spent, because
+   * a judgement as to weather it is a token UTXO has not been made. Spending it
+   * could burn tokens. It's safest to ignore UTXOs with a value of `null`.
    *
    * @apiExample Example usage:
    *
@@ -1613,7 +1681,8 @@ class Utils {
    *   "bitcoincash:qzygn28zpgeemnptkn26xzyuzzfu9l8f9vfvq7kptk"
    *  ])
    *
-   *  const utxoInfo = await bchjs.SLP.Utils.hydrateUtxos(utxos.utxos)
+   *  // Wait 100mS between processing UTXOs, to prevent rate limit errors.
+   *  const utxoInfo = await bchjs.SLP.Utils.hydrateUtxos(utxos.utxos, { utxoDelay: 100 })
    *
    *  console.log(`${JSON.stringify(utxoInfo, null, 2)}`)
    * } catch (error) {
@@ -1747,7 +1816,7 @@ class Utils {
    */
   // Same as tokenUtxoDetails(), but reduces API calls by having bch-api server
   // do the heavy lifting.
-  async hydrateUtxos (utxos) {
+  async hydrateUtxos (utxos, usrObj) {
     try {
       // Throw error if input is not an array.
       if (!Array.isArray(utxos)) throw new Error('Input must be an array.')
@@ -1755,15 +1824,18 @@ class Utils {
       const response = await _this.axios.post(
         `${this.restURL}slp/hydrateUtxos`,
         {
-          utxos: utxos
+          utxos: utxos,
+          usrObj
         },
         _this.axiosOptions
       )
 
       return response.data
     } catch (error) {
-      if (error.response && error.response.data) throw error.response.data
-      else throw error
+      if (error.response && error.response.data) {
+        throw new Error(error.response.data)
+      }
+      throw error
     }
   }
 

test/integration/chains/bchn/slp.js

@@ -31,6 +31,31 @@ describe('#SLP', () => {
   })
 
   describe('#util', () => {
+    describe('#decodeOpReturn', () => {
+      it('should decode a NFT Child transaction', async () => {
+        const txid =
+          'eeddccc4d716f04157ea132ac93a48040fea34a6b57f3d8f0cccb7d1a731ab2b'
+
+        const data = await bchjs.SLP.Utils.decodeOpReturn(txid)
+        // console.log(`data: ${JSON.stringify(data, null, 2)}`)
+
+        assert.property(data, 'tokenType')
+        assert.property(data, 'txType')
+        assert.property(data, 'ticker')
+        assert.property(data, 'name')
+        assert.property(data, 'tokenId')
+        assert.property(data, 'documentUri')
+        assert.property(data, 'documentHash')
+        assert.property(data, 'decimals')
+        assert.property(data, 'mintBatonVout')
+        assert.property(data, 'qty')
+
+        assert.equal(data.tokenType, 65)
+        assert.equal(data.mintBatonVout, 0)
+        assert.equal(data.qty, '1')
+      })
+    })
+
     describe('#tokenUtxoDetails', () => {
       it('should handle a range of UTXO types', async () => {
         const utxos = [

test/unit/fixtures/slp/mock-utils.js

@@ -1290,6 +1290,100 @@ const slpdbStatus = {
   }
 }
 
+const txDetailsSLPNftChild = {
+  txid: 'eeddccc4d716f04157ea132ac93a48040fea34a6b57f3d8f0cccb7d1a731ab2b',
+  hash: 'eeddccc4d716f04157ea132ac93a48040fea34a6b57f3d8f0cccb7d1a731ab2b',
+  version: 2,
+  size: 453,
+  locktime: 0,
+  vin: [
+    {
+      txid: 'a9a2458a0f9f0761d5b8725c256f2e7fa35b9de4dec6f47b46e9f20d92d0e395',
+      vout: 1,
+      scriptSig: {
+        asm:
+          '3045022100890ff2f80f3c184419ba03a575b9d159c0a5edfa817e4548cfdb6c74d16ce8d202205a8237d2139196716c273fe80506896d369a0022bb54401e2eadb364286a9f07[ALL|FORKID] 03136d9ec06adef1c9154105950e82d470d290aa019ed34a5e3bbd0b679805623b',
+        hex:
+          '483045022100890ff2f80f3c184419ba03a575b9d159c0a5edfa817e4548cfdb6c74d16ce8d202205a8237d2139196716c273fe80506896d369a0022bb54401e2eadb364286a9f07412103136d9ec06adef1c9154105950e82d470d290aa019ed34a5e3bbd0b679805623b'
+      },
+      sequence: 4294967295
+    },
+    {
+      txid: 'a9a2458a0f9f0761d5b8725c256f2e7fa35b9de4dec6f47b46e9f20d92d0e395',
+      vout: 3,
+      scriptSig: {
+        asm:
+          '304402203905a61ec4e3567f7cad7eb514132e5b32d8a1d77c8838baac1b34b735282a5f022044da6130b5cc41b65615b17df6610087fe1baedd1a3a9f37552b56ea8d36d026[ALL|FORKID] 03136d9ec06adef1c9154105950e82d470d290aa019ed34a5e3bbd0b679805623b',
+        hex:
+          '47304402203905a61ec4e3567f7cad7eb514132e5b32d8a1d77c8838baac1b34b735282a5f022044da6130b5cc41b65615b17df6610087fe1baedd1a3a9f37552b56ea8d36d026412103136d9ec06adef1c9154105950e82d470d290aa019ed34a5e3bbd0b679805623b'
+      },
+      sequence: 4294967295
+    }
+  ],
+  vout: [
+    {
+      value: 0,
+      n: 0,
+      scriptPubKey: {
+        asm:
+          'OP_RETURN 5262419 65 47454e45534953 4e4654303034 4e4654204368696c64 68747470733a2f2f46756c6c537461636b2e63617368 0 0 0 0000000000000001',
+        hex:
+          '6a04534c500001410747454e45534953064e4654303034094e4654204368696c641668747470733a2f2f46756c6c537461636b2e636173684c0001004c00080000000000000001',
+        type: 'nulldata'
+      }
+    },
+    {
+      value: 0.00000546,
+      n: 1,
+      scriptPubKey: {
+        asm:
+          'OP_DUP OP_HASH160 f6fc6bce702ef779d2373aa4356a32113d95e674 OP_EQUALVERIFY OP_CHECKSIG',
+        hex: '76a914f6fc6bce702ef779d2373aa4356a32113d95e67488ac',
+        reqSigs: 1,
+        type: 'pubkeyhash',
+        addresses: ['bitcoincash:qrm0c67wwqh0w7wjxua2gdt2xggnm90xws00a3lezv']
+      }
+    },
+    {
+      value: 0.0003923,
+      n: 2,
+      scriptPubKey: {
+        asm:
+          'OP_DUP OP_HASH160 f6fc6bce702ef779d2373aa4356a32113d95e674 OP_EQUALVERIFY OP_CHECKSIG',
+        hex: '76a914f6fc6bce702ef779d2373aa4356a32113d95e67488ac',
+        reqSigs: 1,
+        type: 'pubkeyhash',
+        addresses: ['bitcoincash:qrm0c67wwqh0w7wjxua2gdt2xggnm90xws00a3lezv']
+      }
+    }
+  ],
+  hex:
+    '020000000295e3d0920df2e9467bf4c6dee49d5ba37f2e6f255c72b8d561079f0f8a45a2a9010000006b483045022100890ff2f80f3c184419ba03a575b9d159c0a5edfa817e4548cfdb6c74d16ce8d202205a8237d2139196716c273fe80506896d369a0022bb54401e2eadb364286a9f07412103136d9ec06adef1c9154105950e82d470d290aa019ed34a5e3bbd0b679805623bffffffff95e3d0920df2e9467bf4c6dee49d5ba37f2e6f255c72b8d561079f0f8a45a2a9030000006a47304402203905a61ec4e3567f7cad7eb514132e5b32d8a1d77c8838baac1b34b735282a5f022044da6130b5cc41b65615b17df6610087fe1baedd1a3a9f37552b56ea8d36d026412103136d9ec06adef1c9154105950e82d470d290aa019ed34a5e3bbd0b679805623bffffffff030000000000000000476a04534c500001410747454e45534953064e4654303034094e4654204368696c641668747470733a2f2f46756c6c537461636b2e636173684c0001004c0008000000000000000122020000000000001976a914f6fc6bce702ef779d2373aa4356a32113d95e67488ac3e990000000000001976a914f6fc6bce702ef779d2373aa4356a32113d95e67488ac00000000',
+  blockhash: '000000000000000001360fe42629f4136e9adec53546b278de0e7ef788eed328',
+  confirmations: 2113,
+  time: 1613181364,
+  blocktime: 1613181364
+}
+
+const mock429Error = new Error('Request failed with status code 429')
+mock429Error.response = {
+  status: 429,
+  statusText: 'Too Many Requests',
+  data: {
+    error:
+      'Too many requests. Your limits are currently 100 requests per minute. Increase rate limits at https://fullstack.cash'
+  }
+}
+
+const mock503Error = new Error('Request failed with status code 503')
+mock503Error.response = {
+  status: 503,
+  statusText: 'Service Unavailable',
+  data: {
+    error: 'Some error message'
+  }
+}
+
 module.exports = {
   mockList,
   mockToken,
@@ -1311,6 +1405,7 @@ module.exports = {
   txDetailsSLPGenesisNoBaton,
   txDetailsSLPSendAlt,
   txDetailsSLPNftGenesis,
+  txDetailsSLPNftChild,
   mockTxDetails,
   mockDualValidation,
   mockDualOpData,
@@ -1320,5 +1415,7 @@ module.exports = {
   mockValidateTxid3Invalid,
   whitelist,
   slpdbStatus,
-  mockValidateTxidArray
+  mockValidateTxidArray,
+  mock429Error,
+  mock503Error
 }

test/unit/slp-utils.js

@@ -453,33 +453,383 @@ describe('#SLP Utils', () => {
       assert.equal(data.qty, 1)
     })
 
-    // it("should decode a NFT Child transaction", async () => {
-    //   // Mock the call to the REST API.
-    //   // sandbox
-    //   //   .stub(uut.Utils.axios, "get")
-    //   //   .resolves({ data: mockData.txDetailsSLPNftGenesis })
-    //
-    //   const txid =
-    //     "3de3766b10506c9156533f1639979e49d1884521543c13e4af73647df1ed3f76"
-    //
-    //   const data = await uut.Utils.decodeOpReturn(txid)
-    //   console.log(`data: ${JSON.stringify(data, null, 2)}`)
-    //
-    //   // assert.property(data, "tokenType")
-    //   // assert.property(data, "txType")
-    //   // assert.property(data, "ticker")
-    //   // assert.property(data, "name")
-    //   // assert.property(data, "tokenId")
-    //   // assert.property(data, "documentUri")
-    //   // assert.property(data, "documentHash")
-    //   // assert.property(data, "decimals")
-    //   // assert.property(data, "mintBatonVout")
-    //   // assert.property(data, "qty")
-    //   //
-    //   // assert.equal(data.tokenType, 129)
-    //   // assert.equal(data.mintBatonVout, 2)
-    //   // assert.equal(data.qty, 1)
-    // })
+    it('should decode a NFT Child transaction', async () => {
+      // Mock the call to the REST API.
+      sandbox
+        .stub(uut.Utils.axios, 'post')
+        .resolves({ data: [mockData.txDetailsSLPNftChild] })
+
+      const txid =
+        'eeddccc4d716f04157ea132ac93a48040fea34a6b57f3d8f0cccb7d1a731ab2b'
+
+      const data = await uut.Utils.decodeOpReturn(txid)
+      // console.log(`data: ${JSON.stringify(data, null, 2)}`)
+
+      assert.property(data, 'tokenType')
+      assert.property(data, 'txType')
+      assert.property(data, 'ticker')
+      assert.property(data, 'name')
+      assert.property(data, 'tokenId')
+      assert.property(data, 'documentUri')
+      assert.property(data, 'documentHash')
+      assert.property(data, 'decimals')
+      assert.property(data, 'mintBatonVout')
+      assert.property(data, 'qty')
+
+      assert.equal(data.tokenType, 65)
+      assert.equal(data.mintBatonVout, 0)
+      assert.equal(data.qty, '1')
+    })
+
+    // 429 means the user is exceeding the rate limits.
+    it('should throw error when axios returns 429 status', async () => {
+      try {
+        // Mock the call to the REST API
+        sandbox.stub(uut.Utils.axios, 'post').rejects(mockData.mock429Error)
+
+        const txid =
+          'a60a522cc11ad7011b74e57fbabbd99296e4b9346bcb175dcf84efb737030415'
+
+        await uut.Utils.decodeOpReturn(txid)
+        // console.log(`result: ${JSON.stringify(result, null, 2)}`)
+
+        assert.fail('Unexpect result')
+      } catch (err) {
+        // console.log('err: ', err)
+
+        assert.property(err, 'message')
+        assert.property(err, 'response')
+        assert.equal(err.response.status, 429)
+        assert.equal(err.response.statusText, 'Too Many Requests')
+        assert.include(err.response.data.error, 'Too many requests')
+      }
+    })
+
+    // 503 means the service is down.
+    it('should throw error when axios returns 503 status', async () => {
+      try {
+        // Mock the call to the REST API
+        sandbox.stub(uut.Utils.axios, 'post').rejects(mockData.mock503Error)
+
+        const txid =
+          'a60a522cc11ad7011b74e57fbabbd99296e4b9346bcb175dcf84efb737030415'
+
+        await uut.Utils.decodeOpReturn(txid)
+        // console.log(`result: ${JSON.stringify(result, null, 2)}`)
+
+        assert.fail('Unexpect result')
+      } catch (err) {
+        // console.log('err: ', err)
+
+        assert.property(err, 'message')
+        assert.property(err, 'response')
+        assert.equal(err.response.status, 503)
+        assert.equal(err.response.statusText, 'Service Unavailable')
+        assert.property(err.response, 'data')
+      }
+    })
+  })
+
+  describe('#_hydrateUtxo', () => {
+    // // This captures an important corner-case. When an SLP token is created, the
+    // // change UTXO will contain the same SLP txid, but it is not an SLP UTXO.
+    it('should return details on minting baton from genesis transaction', async () => {
+      // Mock the call to REST API
+      // sandbox.stub(uut.Utils, 'waterfallValidateTxid').resolves(true)
+
+      // Stub the calls to decodeOpReturn.
+      sandbox.stub(uut.Utils, 'decodeOpReturn').resolves({
+        tokenType: 1,
+        txType: 'GENESIS',
+        ticker: 'SLPSDK',
+        name: 'SLP SDK example using BITBOX',
+        tokenId:
+          'bd158c564dd4ef54305b14f44f8e94c44b649f246dab14bcb42fb0d0078b8a90',
+        documentUri: 'developer.bitcoin.com',
+        documentHash: '',
+        decimals: 8,
+        mintBatonVout: 2,
+        qty: '50700000000'
+      })
+
+      const utxos = [
+        {
+          txid:
+            'bd158c564dd4ef54305b14f44f8e94c44b649f246dab14bcb42fb0d0078b8a90',
+          vout: 3,
+          amount: 0.00002015,
+          satoshis: 2015,
+          height: 594892,
+          confirmations: 5
+        },
+        {
+          txid:
+            'bd158c564dd4ef54305b14f44f8e94c44b649f246dab14bcb42fb0d0078b8a90',
+          vout: 2,
+          amount: 0.00000546,
+          satoshis: 546,
+          height: 594892,
+          confirmations: 5
+        }
+      ]
+
+      const data = await uut.Utils._hydrateUtxo(utxos)
+      // console.log(`data: ${JSON.stringify(data, null, 2)}`)
+
+      // assert.equal(data[0], false, "Change UTXO marked as false.")
+      assert.property(data[0], 'txid')
+      assert.property(data[0], 'vout')
+      assert.property(data[0], 'amount')
+      assert.property(data[0], 'satoshis')
+      assert.property(data[0], 'height')
+      assert.property(data[0], 'confirmations')
+      assert.property(data[0], 'isValid')
+      assert.equal(data[0].isValid, false)
+
+      assert.property(data[1], 'txid')
+      assert.property(data[1], 'vout')
+      assert.property(data[1], 'amount')
+      assert.property(data[1], 'satoshis')
+      assert.property(data[1], 'height')
+      assert.property(data[1], 'confirmations')
+      assert.property(data[1], 'utxoType')
+      assert.property(data[1], 'tokenId')
+      assert.property(data[1], 'tokenTicker')
+      assert.property(data[1], 'tokenName')
+      assert.property(data[1], 'tokenDocumentUrl')
+      assert.property(data[1], 'tokenDocumentHash')
+      assert.property(data[1], 'decimals')
+    })
+
+    // 429 means the user is exceeding the rate limits.
+    it('should return isValid=null for 429 rate limit error', async () => {
+      // Force decodeOpReturn() to throw a 429 error.
+      sandbox.stub(uut.Utils, 'decodeOpReturn').rejects(mockData.mock429Error)
+
+      const utxos = [
+        {
+          txid:
+            'bd158c564dd4ef54305b14f44f8e94c44b649f246dab14bcb42fb0d0078b8a90',
+          vout: 3,
+          amount: 0.00002015,
+          satoshis: 2015,
+          height: 594892,
+          confirmations: 5
+        },
+        {
+          txid:
+            'bd158c564dd4ef54305b14f44f8e94c44b649f246dab14bcb42fb0d0078b8a90',
+          vout: 2,
+          amount: 0.00000546,
+          satoshis: 546,
+          height: 594892,
+          confirmations: 5
+        }
+      ]
+
+      const result = await uut.Utils._hydrateUtxo(utxos)
+      // console.log(`result: ${JSON.stringify(result, null, 2)}`)
+
+      assert.equal(result[0].isValid, null)
+      assert.equal(result[1].isValid, null)
+    })
+
+    // 503 means the server is down or is not responding.
+    it('should return isValid=null for 503 rate limit error', async () => {
+      // Force decodeOpReturn() to throw a 429 error.
+      sandbox.stub(uut.Utils, 'decodeOpReturn').rejects(mockData.mock503Error)
+
+      const utxos = [
+        {
+          txid:
+            'bd158c564dd4ef54305b14f44f8e94c44b649f246dab14bcb42fb0d0078b8a90',
+          vout: 3,
+          amount: 0.00002015,
+          satoshis: 2015,
+          height: 594892,
+          confirmations: 5
+        },
+        {
+          txid:
+            'bd158c564dd4ef54305b14f44f8e94c44b649f246dab14bcb42fb0d0078b8a90',
+          vout: 2,
+          amount: 0.00000546,
+          satoshis: 546,
+          height: 594892,
+          confirmations: 5
+        }
+      ]
+
+      const result = await uut.Utils._hydrateUtxo(utxos)
+      // console.log(`result: ${JSON.stringify(result, null, 2)}`)
+
+      assert.equal(result[0].isValid, null)
+      assert.equal(result[1].isValid, null)
+    })
+
+    it('should return details for a simple SEND SLP token utxo', async () => {
+      // Mock the call to REST API
+      // Stub the calls to decodeOpReturn.
+      sandbox
+        .stub(uut.Utils, 'decodeOpReturn')
+        .onCall(0)
+        .resolves({
+          tokenType: 1,
+          txType: 'SEND',
+          tokenId:
+            '497291b8a1dfe69c8daea50677a3d31a5ef0e9484d8bebb610dac64bbc202fb7',
+          amounts: ['200000000', '99887500000000']
+        })
+        .onCall(1)
+        .resolves({
+          tokenType: 1,
+          txType: 'GENESIS',
+          ticker: 'TOK-CH',
+          name: 'TokyoCash',
+          tokenId:
+            '497291b8a1dfe69c8daea50677a3d31a5ef0e9484d8bebb610dac64bbc202fb7',
+          documentUri: '',
+          documentHash: '',
+          decimals: 8,
+          mintBatonVout: 0,
+          qty: '2100000000000000'
+        })
+
+      // sandbox.stub(uut.Utils, 'waterfallValidateTxid').resolves(true)
+
+      const utxos = [
+        {
+          txid:
+            'fde117b1f176b231e2fa9a6cb022e0f7c31c288221df6bcb05f8b7d040ca87cb',
+          vout: 1,
+          amount: 0.00000546,
+          satoshis: 546,
+          height: 596089,
+          confirmations: 748
+        }
+      ]
+
+      const data = await uut.Utils._hydrateUtxo(utxos)
+      // console.log(`data: ${JSON.stringify(data, null, 2)}`)
+
+      assert.property(data[0], 'txid')
+      assert.property(data[0], 'vout')
+      assert.property(data[0], 'amount')
+      assert.property(data[0], 'satoshis')
+      assert.property(data[0], 'height')
+      assert.property(data[0], 'confirmations')
+      assert.property(data[0], 'utxoType')
+      assert.property(data[0], 'tokenId')
+      assert.property(data[0], 'tokenTicker')
+      assert.property(data[0], 'tokenName')
+      assert.property(data[0], 'tokenDocumentUrl')
+      assert.property(data[0], 'tokenDocumentHash')
+      assert.property(data[0], 'decimals')
+      assert.property(data[0], 'tokenQty')
+      assert.property(data[0], 'isValid')
+      assert.equal(data[0].isValid, null)
+    })
+
+    // I don't know if this is the ideal behavior, but this is the behavior
+    // that is in production, so I wanted to capture it in a test case. This
+    // behavior can always be changed in the future.
+    it('should throw error if 429 when querying Genesis transaction', async () => {
+      try {
+        // Mock the call to REST API
+        // Stub the calls to decodeOpReturn.
+        sandbox
+          .stub(uut.Utils, 'decodeOpReturn')
+          .onCall(0)
+          .resolves({
+            tokenType: 1,
+            txType: 'SEND',
+            tokenId:
+              '497291b8a1dfe69c8daea50677a3d31a5ef0e9484d8bebb610dac64bbc202fb7',
+            amounts: ['200000000', '99887500000000']
+          })
+          .onCall(1)
+          .rejects(mockData.mock429Error)
+
+        const utxos = [
+          {
+            txid:
+              'fde117b1f176b231e2fa9a6cb022e0f7c31c288221df6bcb05f8b7d040ca87cb',
+            vout: 1,
+            amount: 0.00000546,
+            satoshis: 546,
+            height: 596089,
+            confirmations: 748
+          }
+        ]
+
+        await uut.Utils._hydrateUtxo(utxos)
+
+        assert.fail('Unexpected result')
+      } catch (err) {
+        // console.log('error: ', err)
+
+        assert.property(err, 'message')
+        assert.property(err, 'response')
+        assert.equal(err.response.status, 429)
+        assert.equal(err.response.statusText, 'Too Many Requests')
+        assert.include(err.response.data.error, 'Too many requests')
+      }
+    })
+
+    it('should add delay if delay is specified', async () => {
+      // Mock the call to REST API
+      // Stub the calls to decodeOpReturn.
+      sandbox
+        .stub(uut.Utils, 'decodeOpReturn')
+        .onCall(0)
+        .resolves({
+          tokenType: 1,
+          txType: 'SEND',
+          tokenId:
+            '497291b8a1dfe69c8daea50677a3d31a5ef0e9484d8bebb610dac64bbc202fb7',
+          amounts: ['200000000', '99887500000000']
+        })
+        .onCall(1)
+        .resolves({
+          tokenType: 1,
+          txType: 'GENESIS',
+          ticker: 'TOK-CH',
+          name: 'TokyoCash',
+          tokenId:
+            '497291b8a1dfe69c8daea50677a3d31a5ef0e9484d8bebb610dac64bbc202fb7',
+          documentUri: '',
+          documentHash: '',
+          decimals: 8,
+          mintBatonVout: 0,
+          qty: '2100000000000000'
+        })
+
+      // sandbox.stub(uut.Utils, 'waterfallValidateTxid').resolves(true)
+
+      const utxos = [
+        {
+          txid:
+            'fde117b1f176b231e2fa9a6cb022e0f7c31c288221df6bcb05f8b7d040ca87cb',
+          vout: 1,
+          amount: 0.00000546,
+          satoshis: 546,
+          height: 596089,
+          confirmations: 748
+        }
+      ]
+
+      const usrObj = {
+        utxoDelay: 100
+      }
+
+      await uut.Utils._hydrateUtxo(utxos, usrObj)
+      // console.log(`data: ${JSON.stringify(data, null, 2)}`)
+
+      // TODO: This test should realy assert that the test took at least 100mS
+      // to complete. However, as-is, it exercises the code path, so not
+      // throwing an error can be considered a pass.
+      assert.equal(true, true)
+    })
   })
 
   describe('#tokenUtxoDetails', () => {