await transaction stream

bitpay · May 3, 2024 · a6d51cf · a6d51cf
1 parent 32c3bb6
commit a6d51cf
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/packages/bitcore-node/src/providers/chain-state/evm/api/ecsp.ts b/packages/bitcore-node/src/providers/chain-state/evm/api/ecsp.ts
@@ -174,7 +174,7 @@ export class BaseEVMExternalStateProvider extends InternalStateProvider implemen
       const tipHeight = tip ? tip.height : 0;
       return await this._getTransaction({ chain, network, txId, tipHeight, web3 });
     } catch (err) {
-      logger.error('Error getting transations from historical node %o', err);
+      logger.error('Error getting transactions from historical node %o', err);
     }
     return undefined;
   }

diff --git a/packages/bitcore-node/src/routes/api/address.ts b/packages/bitcore-node/src/routes/api/address.ts
@@ -3,7 +3,7 @@ const router = express.Router({ mergeParams: true });
 import logger from '../../logger';
 import { ChainStateProvider } from '../../providers/chain-state';
 
-function streamCoins(req, res) {
+async function streamCoins(req, res) {
   try {
     let { address, chain, network } = req.params;
     let { unspent, limit = 10, since } = req.query;
@@ -15,7 +15,7 @@ function streamCoins(req, res) {
       res,
       args: { ...req.query, unspent, limit, since }
     };
-    ChainStateProvider.streamAddressTransactions(payload);
+    await ChainStateProvider.streamAddressTransactions(payload);
   } catch (err: any) {
     logger.error('Error streaming coins: %o', err.stack || err.message || err);
     return res.status(500).send(err.message || err);