Merge pull request bitpay#1863 from micahriggan/feature/no-limit-addresses

micahriggan · web-flow · commit 3fb71ea03af5 · 2019-01-04T17:03:04.000-05:00
fix(node): removing limits on wallet address endpoint
diff --git a/packages/bitcore-node/src/providers/chain-state/internal/internal.ts b/packages/bitcore-node/src/providers/chain-state/internal/internal.ts
@@ -55,10 +55,9 @@ export class InternalStateProvider implements CSP.IChainStateService {
   }
 
   async streamAddressTransactions(params: CSP.StreamAddressUtxosParams) {
-    const { args, req, res } = params;
-    const { limit = 10 } = args;
+    const { req, res } = params;
     const query = this.getAddressQuery(params);
-    Storage.apiStreamingFind(CoinStorage, query, { limit }, req, res);
+    Storage.apiStreamingFind(CoinStorage, query, {}, req, res);
   }
 
   async getBalanceForAddress(params: CSP.GetBalanceForAddressParams) {
@@ -253,9 +252,9 @@ export class InternalStateProvider implements CSP.IChainStateService {
   }
 
   streamWalletAddresses(params: CSP.StreamWalletAddressesParams) {
-    let { walletId, limit = 1000, req, res } = params;
+    let { walletId, req, res } = params;
     let query = { wallet: walletId };
-    Storage.apiStreamingFind(WalletAddressStorage, query, { limit }, req, res);
+    Storage.apiStreamingFind(WalletAddressStorage, query, {}, req, res);
   }
 
   async walletCheck(params: CSP.WalletCheckParams) {

Original file line number	Diff line number	Diff line change
`@@ -55,10 +55,9 @@ export class InternalStateProvider implements CSP.IChainStateService {`
`55`	`55`	`}`
`56`	`56`
`57`	`57`	`async streamAddressTransactions(params: CSP.StreamAddressUtxosParams) {`
`58`		`- const { args, req, res } = params;`
`59`		`- const { limit = 10 } = args;`
	`58`	`+ const { req, res } = params;`
`60`	`59`	`const query = this.getAddressQuery(params);`
`61`		`- Storage.apiStreamingFind(CoinStorage, query, { limit }, req, res);`
	`60`	`+ Storage.apiStreamingFind(CoinStorage, query, {}, req, res);`
`62`	`61`	`}`
`63`	`62`
`64`	`63`	`async getBalanceForAddress(params: CSP.GetBalanceForAddressParams) {`
`@@ -253,9 +252,9 @@ export class InternalStateProvider implements CSP.IChainStateService {`
`253`	`252`	`}`
`254`	`253`
`255`	`254`	`streamWalletAddresses(params: CSP.StreamWalletAddressesParams) {`
`256`		`- let { walletId, limit = 1000, req, res } = params;`
	`255`	`+ let { walletId, req, res } = params;`
`257`	`256`	`let query = { wallet: walletId };`
`258`		`- Storage.apiStreamingFind(WalletAddressStorage, query, { limit }, req, res);`
	`257`	`+ Storage.apiStreamingFind(WalletAddressStorage, query, {}, req, res);`
`259`	`258`	`}`
`260`	`259`
`261`	`260`	`async walletCheck(params: CSP.WalletCheckParams) {`