Make getAsyncAddress for limit CPU usage

src/helpers/btc.js

@@ -98,6 +98,9 @@ export async function getAccount({
     }),
   })
 
+  const getAsyncAddress = params =>
+    new Promise(resolve => setTimeout(() => resolve(getAddress(params)), 100))
+
   const getLastAddress = (addresses, txs) => {
     const txsAddresses = [...txs.inputs.map(tx => tx.prev_out.addr), ...txs.out.map(tx => tx.addr)]
     const lastAddress = addresses.reverse().find(a => txsAddresses.includes(a.address)) || {
@@ -110,14 +113,19 @@ export async function getAccount({
   }
 
   const nextPath = (index = 0) =>
-    Promise.all(
-      Array.from(new Array(gapLimit).keys()).map(v =>
-        Promise.all([
-          getAddress({ type: 'external', index: v + index }),
-          getAddress({ type: 'internal', index: v + index }),
-        ]),
-      ),
-    ).then(async results => {
+    Array.from(new Array(gapLimit).keys())
+      .reduce(
+        (promise, v) =>
+          promise.then(async results => {
+            const result = await Promise.all([
+              getAsyncAddress({ type: 'external', index: v + index }),
+              getAsyncAddress({ type: 'internal', index: v + index }),
+            ])
+            return [...results, result]
+          }),
+        Promise.resolve([]),
+      )
+      .then(async results => {
         const addresses = results.reduce((result, v) => [...result, ...v], [])
         const listAddresses = addresses.map(a => a.address)
 

src/internals/accounts/sync.js

@@ -2,22 +2,30 @@
 
 import { getAccount, getHDNode, networks } from 'helpers/btc'
 
-export default (send: Function) => ({
-  all: async ({ accounts }: { accounts: Array<Object> }) => {
-    const network = networks[1]
+const network = networks[1]
 
-    send('accounts.sync.progress', null, { kill: false })
-
-    const syncAccount = ({ id, currentIndex }) => {
+function syncAccount({ id, ...currentAccount }) {
   const hdnode = getHDNode({ xpub58: id, network })
-      return getAccount({ currentIndex, hdnode, network, segwit: true }).then(account => ({
+  return getAccount({ hdnode, network, segwit: true, ...currentAccount }).then(account => ({
     id,
     ...account,
   }))
-    }
+}
+
+export default (send: Function) => ({
+  all: async ({ accounts }: { accounts: Array<Object> }) => {
+    send('accounts.sync.progress', null, { kill: false })
 
     try {
-      const result = await Promise.all(accounts.map(syncAccount))
+      const result = await accounts.reduce(
+        (promise, account) =>
+          promise.then(async results => {
+            const result = await syncAccount(account)
+            return [...results, result]
+          }),
+        Promise.resolve([]),
+      )
+
       send('accounts.sync.success', result)
     } catch (err) {
       send('accounts.sync.fail', err.stack || err)