Merge pull request #144 from Permissionless-Software-Foundation/dh-v5-fulcrum-block

feat(block): Created v5 Fulcrum /block endpoints in bch-api

src/routes/v5/electrumx.js

@@ -52,11 +52,11 @@ class Electrum {
     this.router.post('/balance', this.balanceBulk)
     this.router.get('/utxos/:address', this.getUtxos)
     this.router.post('/utxos', this.utxosBulk)
-    // this.router.get('/tx/data/:txid', this.getTransactionDetails)
+    this.router.get('/tx/data/:txid', this.getTransactionDetails)
-    // this.router.post('/tx/data', this.transactionDetailsBulk)
+    this.router.post('/tx/data', this.transactionDetailsBulk)
-    // this.router.post('/tx/broadcast', this.broadcastTransaction)
+    this.router.post('/tx/broadcast', this.broadcastTransaction)
-    // this.router.get('/block/headers/:height', this.getBlockHeaders)
+    this.router.get('/block/headers/:height', this.getBlockHeaders)
-    // this.router.post('/block/headers', this.blockHeadersBulk)
+    this.router.post('/block/headers', this.blockHeadersBulk)
     // this.router.get('/transactions/:address', this.getTransactions)
     // this.router.post('/transactions', this.transactionsBulk)
     // this.router.get('/unconfirmed/:address', this.getMempool)
@@ -423,53 +423,40 @@ class Electrum {
    *
    */
   // GET handler for single transaction
-  // async getTransactionDetails (req, res, next) {
+  async getTransactionDetails (req, res, next) {
-  //   try {
+    try {
-  //     const txid = req.params.txid
+      const txid = req.params.txid
-  //     const verbose = req.query.verbose
+      // const verbose = req.query.verbose
-  //
+
-  //     // Reject if txid is anything other than a string
+      // Reject if txid is anything other than a string
-  //     if (typeof txid !== 'string') {
+      if (typeof txid !== 'string') {
-  //       res.status(400)
+        res.status(400)
-  //       return res.json({
+        return res.json({
-  //         success: false,
+          success: false,
-  //         error: 'txid must be a string'
+          error: 'txid must be a string'
-  //       })
+        })
-  //     }
+      }
-  //
+
-  //     wlogger.debug(
+      wlogger.debug(
-  //       'Executing electrumx/getTransactionDetails with this txid: ',
+        'Executing electrumx/getTransactionDetails with this txid: ',
-  //       txid
+        txid
-  //     )
+      )
-  //
+
-  //     // Get data from ElectrumX server.
+      // Get data from ElectrumX server.
-  //     const electrumResponse = await _this._transactionDetailsFromElectrum(
+      const response = await _this.axios.get(
-  //       txid,
+        `${_this.fulcrumApi}electrumx/tx/data/${txid}`
-  //       verbose
+      )
-  //     )
+      // console.log(`_transactionDetailsFromElectrum(): ${JSON.stringify(electrumResponse, null, 2)}`)
-  //     // console.log(`_transactionDetailsFromElectrum(): ${JSON.stringify(electrumResponse, null, 2)}`)
+
-  //
+      res.status(200)
-  //     // Pass the error message if ElectrumX reports an error.
+      return res.json(response.data)
-  //     if (electrumResponse instanceof Error) {
+    } catch (err) {
-  //       res.status(400)
+      // Write out error to error log.
-  //       return res.json({
+      wlogger.error('Error in elecrumx.js/getTransactionDetails().', err)
-  //         success: false,
+
-  //         error: electrumResponse.message
+      return _this.errorHandler(err, res)
-  //       })
+    }
-  //     }
+  }
-  //
-  //     res.status(200)
-  //     return res.json({
-  //       success: true,
-  //       details: electrumResponse
-  //     })
-  //   } catch (err) {
-  //     // Write out error to error log.
-  //     wlogger.error('Error in elecrumx.js/getTransactionDetails().', err)
-  //
-  //     return _this.errorHandler(err, res)
-  //   }
-  // }
 
   /**
    * @api {post} /electrumx/tx/data Get transaction details for an array of TXIDs
@@ -484,61 +471,47 @@ class Electrum {
    *
    */
   // POST handler for bulk queries on transaction details
-  // async transactionDetailsBulk (req, res, next) {
+  async transactionDetailsBulk (req, res, next) {
-  //   try {
+    try {
-  //     const txids = req.body.txids
+      const txids = req.body.txids
-  //     const verbose = req.body.verbose || true
+      const verbose = req.body.verbose || true
-  //
+      // Reject if txids is not an array.
-  //     // Reject if txids is not an array.
+      if (!Array.isArray(txids)) {
-  //     if (!Array.isArray(txids)) {
+        res.status(400)
-  //       res.status(400)
+        return res.json({
-  //       return res.json({
+          success: false,
-  //         success: false,
+          error: 'txids needs to be an array. Use GET for single txid.'
-  //         error: 'txids needs to be an array. Use GET for single txid.'
+        })
-  //       })
+      }
-  //     }
+
-  //
+      // Enforce array size rate limits
-  //     // Enforce array size rate limits
+      if (!_this.routeUtils.validateArraySize(req, txids)) {
-  //     if (!_this.routeUtils.validateArraySize(req, txids)) {
+        res.status(400) // https://github.com/Bitcoin-com/rest.bitcoin.com/issues/330
-  //       res.status(400) // https://github.com/Bitcoin-com/rest.bitcoin.com/issues/330
+        return res.json({
-  //       return res.json({
+          success: false,
-  //         success: false,
+          error: 'Array too large.'
-  //         error: 'Array too large.'
+        })
-  //       })
+      }
-  //     }
+
-  //
+      wlogger.debug(
-  //     wlogger.debug(
+        'Executing electrumx.js/transactionDetailsBulk with these txids: ',
-  //       'Executing electrumx.js/transactionDetailsBulk with these txids: ',
+        txids
-  //       txids
+      )
-  //     )
+
-  //
+      const response = await _this.axios.post(
-  //     // Loops through each address and creates an array of Promises, querying
+        `${_this.fulcrumApi}electrumx/tx/data`,
-  //     // the Electrum server in parallel.
+        { txids, verbose }
-  //     const transactions = txids.map(async (txid, index) => {
+      )
-  //       // console.log(`address: ${address}`)
+
-  //       const details = await _this._transactionDetailsFromElectrum(
+      // Return the array of retrieved transaction details.
-  //         txid,
+      res.status(200)
-  //         verbose
+      return res.json(response.data)
-  //       )
+    } catch (err) {
-  //
+      wlogger.error('Error in electrumx.js/transactionDetailsBulk().', err)
-  //       return { details, txid }
+
-  //     })
+      return _this.errorHandler(err, res)
-  //
+    }
-  //     // Wait for all parallel Electrum requests to return.
+  }
-  //     const result = await Promise.all(transactions)
-  //
-  //     // Return the array of retrieved transaction details.
-  //     res.status(200)
-  //     return res.json({
-  //       success: true,
-  //       transactions: result
-  //     })
-  //   } catch (err) {
-  //     wlogger.error('Error in electrumx.js/transactionDetailsBulk().', err)
-  //
-  //     return _this.errorHandler(err, res)
-  //   }
-  // }
 
   // Returns a promise that resolves to transaction ID of the broadcasted transaction or an error.
   // Expects input to be a txHex string, and input validation to have already
@@ -584,47 +557,36 @@ class Electrum {
    *
    */
   // POST handler for broadcasting a single transaction
-  // async broadcastTransaction (req, res, next) {
+  async broadcastTransaction (req, res, next) {
-  //   try {
+    try {
-  //     const txHex = req.body.txHex
+      const txHex = req.body.txHex
-  //
+      if (typeof txHex !== 'string') {
-  //     if (typeof txHex !== 'string') {
+        res.status(400)
-  //       res.status(400)
+        return res.json({
-  //       return res.json({
+          success: false,
-  //         success: false,
+          error: 'request body must be a string.'
-  //         error: 'request body must be a string.'
+        })
-  //       })
+      }
-  //     }
+
-  //
+      wlogger.debug(
-  //     wlogger.debug(
+        'Executing electrumx/broadcastTransaction with this tx hex: ',
-  //       'Executing electrumx/broadcastTransaction with this tx hex: ',
+        txHex
-  //       txHex
+      )
-  //     )
+
-  //
+      // Get data from ElectrumX server.
-  //     // Get data from ElectrumX server.
+      const response = await _this.axios.post(
-  //     const electrumResponse = await _this._broadcastTransactionWithElectrum(txHex)
+        `${_this.fulcrumApi}electrumx/tx/broadcast`,
-  //     // console.log(`_utxosFromElectrumx(): ${JSON.stringify(electrumResponse, null, 2)}`)
+        { txHex }
-  //
+      )
-  //     // Pass the error message if ElectrumX reports an error.
+
-  //     if (electrumResponse instanceof Error) {
+      res.status(200)
-  //       res.status(400)
+      return res.json(response.data)
-  //       return res.json({
+    } catch (err) {
-  //         success: false,
+      wlogger.error('Error in electrumx.js/broadcastTransaction().', err)
-  //         error: electrumResponse.message
+
-  //       })
+      return _this.errorHandler(err, res)
-  //     }
+    }
-  //
+  }
-  //     res.status(200)
-  //     return res.json({
-  //       success: true,
-  //       txid: electrumResponse
-  //     })
-  //   } catch (err) {
-  //     wlogger.error('Error in electrumx.js/broadcastTransaction().', err)
-  //
-  //     return _this.errorHandler(err, res)
-  //   }
-  // }
 
   // Returns a promise that resolves to block header data for a block height.
   // Expects input to be a height number, and input validation to have already
@@ -671,63 +633,51 @@ class Electrum {
    *
    *
    * @apiExample Example usage:
-   * curl -X GET "https://api.fullstack.cash/v5/electrumx/block/header/42?count=2" -H "accept: application/json"
+   * curl -X GET "https://api.fullstack.cash/v5/electrumx/block/headers/42?count=2" -H "accept: application/json"
    *
    */
   // GET handler for single block headers
-  // async getBlockHeaders (req, res, next) {
+  async getBlockHeaders (req, res, next) {
-  //   try {
+    try {
-  //     const height = Number(req.params.height)
+      const height = Number(req.params.height)
-  //     const count = req.query.count === undefined ? 1 : Number(req.query.count)
+      const count = req.query.count === undefined ? 1 : Number(req.query.count)
-  //
+
-  //     // Reject if height is not a number
+      // Reject if height is not a number
-  //     if (Number.isNaN(height) || height < 0) {
+      if (Number.isNaN(height) || height < 0) {
-  //       res.status(400)
+        res.status(400)
-  //       return res.json({
+        return res.json({
-  //         success: false,
+          success: false,
-  //         error: 'height must be a positive number'
+          error: 'height must be a positive number'
-  //       })
+        })
-  //     }
+      }
-  //
+
-  //     // Reject if height is not a number
+      // Reject if height is not a number
-  //     if (Number.isNaN(count) || count < 0) {
+      if (Number.isNaN(count) || count < 0) {
-  //       res.status(400)
+        res.status(400)
-  //       return res.json({
+        return res.json({
-  //         success: false,
+          success: false,
-  //         error: 'count must be a positive number'
+          error: 'count must be a positive number'
-  //       })
+        })
-  //     }
+      }
-  //
+
-  //     wlogger.debug(
+      wlogger.debug(
-  //       'Executing electrumx/getBlockHeaders with this height: ',
+        'Executing electrumx/getBlockHeaders with this height: ',
-  //       height
+        height
-  //     )
+      )
-  //
+
-  //     // Get data from ElectrumX server.
+      const response = await _this.axios.get(
-  //     const electrumResponse = await _this._blockHeadersFromElectrum(height, count)
+        `${_this.fulcrumApi}electrumx/block/headers/${height}?count=${count}`
-  //     // console.log(`_transactionDetailsFromElectrum(): ${JSON.stringify(electrumResponse, null, 2)}`)
+      )
-  //
+
-  //     // Pass the error message if ElectrumX reports an error.
+      res.status(200)
-  //     if (electrumResponse instanceof Error) {
+      return res.json(response.data)
-  //       res.status(400)
+    } catch (err) {
-  //       return res.json({
+      // Write out error to error log.
-  //         success: false,
+      wlogger.error('Error in elecrumx.js/getBlockHeader().', err)
-  //         error: electrumResponse.message
+
-  //       })
+      return _this.errorHandler(err, res)
-  //     }
+    }
-  //
+  }
-  //     res.status(200)
-  //     return res.json({
-  //       success: true,
-  //       headers: electrumResponse
-  //     })
-  //   } catch (err) {
-  //     // Write out error to error log.
-  //     wlogger.error('Error in elecrumx.js/getBlockHeader().', err)
-  //
-  //     return _this.errorHandler(err, res)
-  //   }
-  // }
 
   /**
    * @api {post} /electrumx/block/headers Get block headers for an array of height + count pairs
@@ -737,63 +687,50 @@ class Electrum {
    * Limited to 20 items per request.
    *
    * @apiExample Example usage:
-   * curl -X POST "https://api.fullstack.cash/v5/electrumx/block/headers" -H "accept: application/json" -H "Content-Type: application/json" -d '{"heights":[{ "height": 42, count: 2 }, { "height": 100, count: 5 }]}'
+   * curl -X POST "https://api.fullstack.cash/v5/electrumx/block/headers" -H "accept: application/json" -H "Content-Type: application/json" -d '{"heights":[{ "height": 42, "count": 2 }, { "height": 100, "count": 5 }]}'
    *
    */
   // POST handler for bulk queries on block headers
-  // async blockHeadersBulk (req, res, next) {
+  async blockHeadersBulk (req, res, next) {
-  //   try {
+    try {
-  //     const heights = req.body.heights
+      const heights = req.body.heights
-  //
+
-  //     // Reject if heights is not an array.
+      // Reject if heights is not an array.
-  //     if (!Array.isArray(heights)) {
+      if (!Array.isArray(heights)) {
-  //       res.status(400)
+        res.status(400)
-  //       return res.json({
+        return res.json({
-  //         success: false,
+          success: false,
-  //         error: 'heights needs to be an array. Use GET for single height.'
+          error: 'heights needs to be an array. Use GET for single height.'
-  //       })
+        })
-  //     }
+      }
-  //
+
-  //     // Enforce array size rate limits
+      // Enforce array size rate limits
-  //     if (!_this.routeUtils.validateArraySize(req, heights)) {
+      if (!_this.routeUtils.validateArraySize(req, heights)) {
-  //       res.status(400) // https://github.com/Bitcoin-com/rest.bitcoin.com/issues/330
+        res.status(400) // https://github.com/Bitcoin-com/rest.bitcoin.com/issues/330
-  //       return res.json({
+        return res.json({
-  //         success: false,
+          success: false,
-  //         error: 'Array too large.'
+          error: 'Array too large.'
-  //       })
+        })
-  //     }
+      }
-  //
+
-  //     wlogger.debug(
+      wlogger.debug(
-  //       'Executing electrumx.js/blockHeadersBulk with these txids: ',
+        'Executing electrumx.js/blockHeadersBulk with these txids: ',
-  //       heights
+        heights
-  //     )
+      )
-  //
+
-  //     // Loops through each address and creates an array of Promises, querying
+      const response = await _this.axios.post(
-  //     // the Electrum server in parallel.
+        `${_this.fulcrumApi}electrumx/block/headers`,
-  //     const transactions = heights.map(async (obj) => {
+        { heights }
-  //       const headers = await _this._blockHeadersFromElectrum(
+      )
-  //         obj.height,
+
-  //         obj.count
+      res.status(200)
-  //       )
+      return res.json(response.data)
-  //
+    } catch (err) {
-  //       return { headers }
+      wlogger.error('Error in electrumx.js/blockHeadersBulk().', err)
-  //     })
+
-  //
+      return _this.errorHandler(err, res)
-  //     // Wait for all parallel Electrum requests to return.
+    }
-  //     const result = await Promise.all(transactions)
+  }
-  //
-  //     // Return the array of retrieved transaction details.
-  //     res.status(200)
-  //     return res.json({
-  //       success: true,
-  //       headers: result
-  //     })
-  //   } catch (err) {
-  //     wlogger.error('Error in electrumx.js/blockHeadersBulk().', err)
-  //
-  //     return _this.errorHandler(err, res)
-  //   }
-  // }
 
   // Returns a promise that resolves an array of transaction history for an
   // address. Expects input to be a cash address, and input validation to have

test/v5/a01-electrumx.js

@@ -609,6 +609,500 @@ describe('#Electrumx', () => {
     })
   })
 
+  describe('#getTransactionDetails', () => {
+    it('should throw 400 if tx is empty', async () => {
+      const result = await electrumxRoute.getTransactionDetails(req, res)
+      // console.log(`result: ${util.inspect(result)}`)
+
+      assert.equal(res.statusCode, 400, 'Expect 400 status code')
+
+      assert.property(result, 'error')
+      assert.include(result.error, 'txid must be a string')
+
+      assert.property(result, 'success')
+      assert.equal(result.success, false)
+    })
+
+    it('should throw 400 on array input', async () => {
+      req.params.txid = [
+        'a1075db55d416d3ca199f55b6084e2115b9345e16c5cf302fc80e9d5fbf5d48d'
+      ]
+
+      const result = await electrumxRoute.getTransactionDetails(req, res)
+      // console.log(`result: ${util.inspect(result)}`)
+
+      assert.equal(res.statusCode, 400, 'Expect 400 status code')
+
+      assert.property(result, 'error')
+      assert.include(result.error, 'txid must be a string')
+
+      assert.property(result, 'success')
+      assert.equal(result.success, false)
+    })
+
+    it('should pass errors from electrum-cash to user', async () => {
+      req.params.txid = '02v05l7qs5s24srqju498qu55dwuj0cx5ehjm2c'
+
+      const result = await electrumxRoute.getTransactionDetails(req, res)
+
+      assert.property(result, 'error')
+      assert.include(result.error.error, 'Invalid tx hash')
+
+      assert.property(result, 'success')
+      assert.equal(result.success, false)
+    })
+
+    it('should get details for a single tx', async () => {
+      req.params.txid =
+        'a1075db55d416d3ca199f55b6084e2115b9345e16c5cf302fc80e9d5fbf5d48d'
+
+      // Mock unit tests to prevent live network calls.
+      if (process.env.TEST === 'unit') {
+        electrumxRoute.isReady = true // Force flag.
+
+        sandbox
+          .stub(electrumxRoute.axios, 'get')
+          .resolves({ data: { success: true, details: mockData.txDetails } })
+      }
+
+      // Call the details API.
+      const result = await electrumxRoute.getTransactionDetails(req, res)
+      // console.log(`result: ${JSON.stringify(result, null, 2)}`)
+
+      assert.property(result, 'success')
+      assert.equal(result.success, true)
+
+      assert.property(result, 'details')
+      assert.property(result.details, 'blockhash')
+      assert.property(result.details, 'blocktime')
+      assert.property(result.details, 'confirmations')
+      assert.property(result.details, 'hash')
+      assert.property(result.details, 'hex')
+      assert.property(result.details, 'locktime')
+      assert.property(result.details, 'size')
+      assert.property(result.details, 'time')
+      assert.property(result.details, 'txid')
+      assert.property(result.details, 'version')
+      assert.property(result.details, 'vin')
+      assert.property(result.details, 'vout')
+    })
+  })
+
+  describe('#transactionDetailsBulk', () => {
+    it('should throw 400 if txids is empty', async () => {
+      const result = await electrumxRoute.transactionDetailsBulk(req, res)
+      // console.log(`result: ${util.inspect(result)}`)
+
+      assert.equal(res.statusCode, 400, 'Expect 400 status code')
+
+      assert.property(result, 'error')
+      assert.include(result.error, 'txids needs to be an array')
+
+      assert.property(result, 'success')
+      assert.equal(result.success, false)
+    })
+
+    it('should throw 400 if input provided is not array', async () => {
+      req.body.txids =
+        'a1075db55d416d3ca199f55b6084e2115b9345e16c5cf302fc80e9d5fbf5d48d'
+
+      const result = await electrumxRoute.transactionDetailsBulk(req, res)
+      // console.log(`result: ${util.inspect(result)}`)
+
+      assert.equal(res.statusCode, 400, 'Expect 400 status code')
+
+      assert.property(result, 'error')
+      assert.include(result.error, 'txids needs to be an array')
+
+      assert.property(result, 'success')
+      assert.equal(result.success, false)
+    })
+
+    it('should throw 400 error if addresses array is too large', async () => {
+      const testArray = []
+      for (var i = 0; i < 25; i++) testArray.push('')
+
+      req.body.txids = testArray
+
+      const result = await electrumxRoute.transactionDetailsBulk(req, res)
+      // console.log(`result: ${util.inspect(result)}`)
+
+      assert.property(result, 'error')
+      assert.include(result.error, 'Array too large')
+
+      assert.property(result, 'success')
+      assert.equal(result.success, false)
+    })
+
+    it('should handle error', async () => {
+      req.body.txids = [
+        'a1075db55d416d3ca199f55b6084e2115b9345e16c5cf302fc80e9d5fbf5d48d',
+        'a1075db55d416d3ca199f55b6084e2115b9345e16c5cf302fc80e9d5fbf5d48d'
+      ]
+      // Force error
+      sandbox.stub(electrumxRoute.axios, 'post').throws(new Error('Test error'))
+
+      // Call the details API.
+      const result = await electrumxRoute.transactionDetailsBulk(req, res)
+      // console.log(`result: ${JSON.stringify(result, null, 2)}`)
+
+      assert.property(result, 'success')
+      assert.equal(result.success, false)
+
+      assert.property(result, 'error')
+      assert.include(result.error, 'Test error')
+    })
+
+    it('should get details for an array of tx', async () => {
+      req.body.txids = [
+        'a1075db55d416d3ca199f55b6084e2115b9345e16c5cf302fc80e9d5fbf5d48d'
+      ]
+
+      // Mock unit tests to prevent live network calls.
+      if (process.env.TEST === 'unit') {
+        electrumxRoute.isReady = true // Force flag.
+
+        sandbox
+          .stub(electrumxRoute.axios, 'post')
+          .resolves({ data: mockData.txDetailsBulk })
+      }
+
+      // Call the details API.
+      const result = await electrumxRoute.transactionDetailsBulk(req, res)
+      // console.log(`result: ${JSON.stringify(result, null, 2)}`)
+
+      assert.property(result, 'success')
+      assert.equal(result.success, true)
+
+      assert.property(result, 'transactions')
+      const tx = result.transactions[0]
+
+      assert.property(tx, 'details')
+      assert.property(tx.details, 'blockhash')
+      assert.property(tx.details, 'blocktime')
+      assert.property(tx.details, 'confirmations')
+      assert.property(tx.details, 'hash')
+      assert.property(tx.details, 'hex')
+      assert.property(tx.details, 'locktime')
+      assert.property(tx.details, 'size')
+      assert.property(tx.details, 'time')
+      assert.property(tx.details, 'txid')
+      assert.property(tx.details, 'version')
+      assert.property(tx.details, 'vin')
+      assert.property(tx.details, 'vout')
+    })
+  })
+
+  describe('#broadcastTransaction', () => {
+    it('should throw 400 if txHex is empty', async () => {
+      const result = await electrumxRoute.broadcastTransaction(req, res)
+      // console.log(`result: ${util.inspect(result)}`)
+
+      assert.equal(res.statusCode, 400, 'Expect 400 status code')
+
+      assert.property(result, 'error')
+      assert.include(result.error, 'request body must be a string')
+
+      assert.property(result, 'success')
+      assert.equal(result.success, false)
+    })
+
+    it('should throw 400 on invalid input type', async () => {
+      req.body.txHex = [mockData.txDetails.hex]
+
+      const result = await electrumxRoute.broadcastTransaction(req, res)
+      // console.log(`result: ${util.inspect(result)}`)
+
+      assert.equal(res.statusCode, 400, 'Expect 400 status code')
+
+      assert.property(result, 'error')
+      assert.include(result.error, 'request body must be a string')
+
+      assert.property(result, 'success')
+      assert.equal(result.success, false)
+    })
+
+    it('should pass errors from electrum-cash to user', async () => {
+      req.body.txHex = mockData.txDetails.hex.substring(10)
+      const result = await electrumxRoute.broadcastTransaction(req, res)
+      // console.log(`result: ${util.inspect(result)}`)
+
+      assert.equal(res.statusCode, 400, 'Expect 400 status code')
+
+      assert.property(result, 'error')
+      assert.include(result.error.error, 'the transaction was rejected')
+
+      assert.property(result, 'success')
+      assert.equal(result.success, false)
+    })
+
+    it('should broadcast transaction', async function () {
+      req.body.txHex = mockData.txDetails.hex
+
+      // Mock unit tests to prevent live network calls.
+      if (process.env.TEST === 'unit') {
+        electrumxRoute.isReady = true // Force flag.
+
+        sandbox
+          .stub(electrumxRoute.axios, 'post')
+          .resolves({ data: { success: true, txid: mockData.txDetails.hash } })
+      } else {
+        return this.skip()
+      }
+
+      // Call the details API.
+      const result = await electrumxRoute.broadcastTransaction(req, res)
+      // console.log(`result: ${JSON.stringify(result, null, 2)}`)
+
+      assert.property(result, 'success')
+      assert.equal(result.success, true)
+
+      assert.property(result, 'txid')
+      assert.isString(result.txid)
+    })
+  })
+
+  describe('#getBlockHeaders', () => {
+    it('should throw 400 if height is empty', async () => {
+      const result = await electrumxRoute.getBlockHeaders(req, res)
+      // console.log(`result: ${util.inspect(result)}`)
+
+      assert.equal(res.statusCode, 400, 'Expect 400 status code')
+
+      assert.property(result, 'error')
+      assert.include(result.error, 'height must be a positive number')
+
+      assert.property(result, 'success')
+      assert.equal(result.success, false)
+    })
+    it('should throw 400 if height is not a number', async () => {
+      req.params.height = 'wrong type'
+
+      const result = await electrumxRoute.getBlockHeaders(req, res)
+      // console.log(`result: ${util.inspect(result)}`)
+
+      assert.equal(res.statusCode, 400, 'Expect 400 status code')
+
+      assert.property(result, 'error')
+      assert.include(result.error, 'height must be a positive number')
+
+      assert.property(result, 'success')
+      assert.equal(result.success, false)
+    })
+    it('should throw 400 if height is negative', async () => {
+      req.params.height = -1
+
+      const result = await electrumxRoute.getBlockHeaders(req, res)
+      // console.log(`result: ${util.inspect(result)}`)
+
+      assert.equal(res.statusCode, 400, 'Expect 400 status code')
+
+      assert.property(result, 'error')
+      assert.include(result.error, 'height must be a positive number')
+
+      assert.property(result, 'success')
+      assert.equal(result.success, false)
+    })
+
+    it('should throw 400 if count is not a number', async () => {
+      req.params.height = 2
+      req.query.count = 'wrong type'
+
+      const result = await electrumxRoute.getBlockHeaders(req, res)
+      // console.log(`result: ${util.inspect(result)}`)
+
+      assert.equal(res.statusCode, 400, 'Expect 400 status code')
+
+      assert.property(result, 'error')
+      assert.include(result.error, 'count must be a positive number')
+
+      assert.property(result, 'success')
+      assert.equal(result.success, false)
+    })
+
+    it('should throw 400 if count is negative', async () => {
+      req.params.height = 2
+      req.query.count = -1
+
+      const result = await electrumxRoute.getBlockHeaders(req, res)
+      // console.log(`result: ${util.inspect(result)}`)
+
+      assert.equal(res.statusCode, 400, 'Expect 400 status code')
+
+      assert.property(result, 'error')
+      assert.include(result.error, 'count must be a positive number')
+
+      assert.property(result, 'success')
+      assert.equal(result.success, false)
+    })
+
+    it('should pass errors from electrum-cash to user', async () => {
+      req.params.height = 99999999999999
+      req.query.count = 99999999999999
+
+      // Mock unit tests to prevent live network calls.
+      if (process.env.TEST === 'unit') {
+        electrumxRoute.isReady = true // Force flag.
+
+        sandbox.stub(electrumxRoute.axios, 'get').resolves({
+          data: { success: false, error: { error: 'Invalid height' } }
+        })
+      }
+      // Call the details API.
+      const result = await electrumxRoute.getBlockHeaders(req, res)
+      // console.log(`result: ${JSON.stringify(result, null, 2)}`)
+
+      assert.property(result, 'success')
+      assert.equal(result.success, false)
+
+      assert.property(result, 'error')
+      assert.include(result.error.error, 'Invalid height')
+    })
+    it('should handle error', async () => {
+      req.params.height = 42
+      req.query.count = 2
+      // Force error
+      sandbox.stub(electrumxRoute.axios, 'get').throws(new Error('Test error'))
+
+      // Call the details API.
+      const result = await electrumxRoute.getBlockHeaders(req, res)
+      // console.log(`result: ${JSON.stringify(result, null, 2)}`)
+
+      assert.property(result, 'success')
+      assert.equal(result.success, false)
+
+      assert.property(result, 'error')
+      assert.include(result.error, 'Test error')
+    })
+
+    it('should get headers for a single block height with count 2', async () => {
+      req.params.height = 42
+      req.query.count = 2
+      // Mock unit tests to prevent live network calls.
+      if (process.env.TEST === 'unit') {
+        electrumxRoute.isReady = true // Force flag.
+
+        sandbox.stub(electrumxRoute.axios, 'get').resolves({
+          data: { success: true, headers: mockData.blockHeaders }
+        })
+      }
+
+      // Call the details API.
+      const result = await electrumxRoute.getBlockHeaders(req, res)
+      // console.log(`result: ${JSON.stringify(result, null, 2)}`)
+
+      assert.property(result, 'success')
+      assert.equal(result.success, true)
+
+      assert.property(result, 'headers')
+      assert.isArray(result.headers)
+      assert.deepEqual(result.headers, mockData.blockHeaders)
+    })
+  })
+  describe('#blockHeadersBulk', () => {
+    it('should throw 400 for an empty body', async () => {
+      const result = await electrumxRoute.blockHeadersBulk(req, res)
+      // console.log(`result: ${util.inspect(result)}`)
+
+      assert.equal(res.statusCode, 400, 'Expect 400 status code')
+
+      assert.property(result, 'error')
+      assert.include(result.error, 'heights needs to be an array')
+
+      assert.property(result, 'success')
+      assert.equal(result.success, false)
+    })
+
+    it('should NOT throw 400 error for an invalid height', async () => {
+      req.body = {
+        heights: [{ height: -10, count: 2 }]
+      }
+      if (process.env.TEST === 'unit') {
+        electrumxRoute.isReady = true // Force flag.
+
+        sandbox.stub(electrumxRoute.axios, 'post').resolves({
+          data: { success: true, headers: [{ headers: {} }] }
+        })
+      }
+      const result = await electrumxRoute.blockHeadersBulk(req, res)
+      console.log(`result: ${util.inspect(result)}`)
+
+      assert.equal(res.statusCode, 200, 'Expect 200 status code')
+
+      assert.property(result, 'success')
+      assert.equal(result.success, true)
+
+      assert.property(result, 'headers')
+      assert.isArray(result.headers)
+      assert.property(result.headers[0], 'headers')
+    })
+
+    it('should throw 400 error if heights array is too large', async () => {
+      const testArray = []
+      for (var i = 0; i < 25; i++) testArray.push('')
+
+      req.body.heights = testArray
+
+      const result = await electrumxRoute.blockHeadersBulk(req, res)
+      // console.log(`result: ${util.inspect(result)}`)
+
+      assert.property(result, 'error')
+      assert.include(result.error, 'Array too large')
+
+      assert.property(result, 'success')
+      assert.equal(result.success, false)
+    })
+
+    it('should handle error', async () => {
+      req.body = {
+        heights: [
+          { height: 42, count: 2 },
+          { height: 42, count: 2 }
+        ]
+      }
+
+      // Force error
+      sandbox.stub(electrumxRoute.axios, 'post').throws(new Error('Test error'))
+
+      // Call the details API.
+      const result = await electrumxRoute.blockHeadersBulk(req, res)
+      // console.log(`result: ${JSON.stringify(result, null, 2)}`)
+
+      assert.property(result, 'success')
+      assert.equal(result.success, false)
+
+      assert.property(result, 'error')
+      assert.include(result.error, 'Test error')
+    })
+    it('should get block heights', async () => {
+      req.body = {
+        heights: [
+          { height: 42, count: 2 },
+          { height: 42, count: 2 }
+        ]
+      }
+
+      // Mock unit tests to prevent live network calls.
+      if (process.env.TEST === 'unit') {
+        electrumxRoute.isReady = true // Force flag.
+        sandbox
+          .stub(electrumxRoute.axios, 'post')
+          .resolves({ data: mockData.blockHeadersBulk })
+      }
+
+      // Call the details API.
+      const result = await electrumxRoute.blockHeadersBulk(req, res)
+      // console.log(`result: ${JSON.stringify(result, null, 2)}`)
+
+      assert.property(result, 'success')
+      assert.equal(result.success, true)
+
+      assert.property(result, 'headers')
+      assert.isArray(result.headers)
+      assert.property(result.headers[0], 'headers')
+    })
+  })
+
   // describe('#_utxosFromElectrumx', () => {
   //   it('should throw error for invalid address', async () => {
   //     try {

test/v5/mocks/electrumx-mock.js

@@ -166,11 +166,20 @@ const txDetails = {
   ]
 }
 
+const txDetailsBulk = {
+  success: true,
+  transactions: [{ details: txDetails }]
+}
+
 const blockHeaders = [
   '010000008b52bbd72c2f49569059f559c1b1794de5192e4f7d6d2b03c7482bad0000000083e4f8a9d502ed0c419075c1abb5d56f878a2e9079e5612bfb76a2dc37d9c42741dd6849ffff001d2b909dd6',
   '01000000f528fac1bcb685d0cd6c792320af0300a5ce15d687c7149548904e31000000004e8985a786d864f21e9cbb7cbdf4bc9265fe681b7a0893ac55a8e919ce035c2f85de6849ffff001d385ccb7c'
 ]
 
+const blockHeadersBulk = {
+  success: true,
+  headers: [{ headers: blockHeaders }, { headers: blockHeaders }]
+}
 module.exports = {
   utxos,
   utxosArray,
@@ -178,6 +187,8 @@ module.exports = {
   txHistory,
   mempool,
   txDetails,
+  txDetailsBulk,
   blockHeaders,
+  blockHeadersBulk,
   balances
 }