fix: still high cpu usage

Author: chedieck

constants/index.ts

@@ -276,7 +276,7 @@ export const MEMPOOL_PROCESS_DELAY = 100
 // When fetching some address transactions, number of transactions to fetch at a time.
 // On chronik, the max allowed is 200
 export const CHRONIK_FETCH_N_TXS_PER_PAGE = 200
-export const INITIAL_ADDRESS_SYNC_FETCH_CONCURRENTLY = 10
+export const INITIAL_ADDRESS_SYNC_FETCH_CONCURRENTLY = 5
 export const TX_EMIT_BATCH_SIZE = 500
 export const TRANSFORM_TX_FROM_CHRONIK_BATCH_SIZE = 10
 export const DB_COMMIT_BATCH_SIZE = 500

services/chronikService.ts

@@ -33,6 +33,7 @@ import { PHASE_PRODUCTION_BUILD } from 'next/dist/shared/lib/constants'
 import { AddressType } from 'ecashaddrjs/dist/types'
 import { DecimalJsLike } from '@prisma/client/runtime/library'
 
+const yieldEventLoop = async (): Promise<void> => await new Promise(resolve => setImmediate(resolve))
 const decoder = new TextDecoder()
 
 export function getNullDataScriptData (outputScript: string): OpReturnData | null {
@@ -434,6 +435,9 @@ export class ChronikBlockchainClient {
 
       syncedAlready += addressBatchSlice.length
 
+      // Yield event loop to prevent CPU starvation between address batches
+      await yieldEventLoop()
+
       // Yield full TX batches when buffer reaches TX_EMIT_BATCH_SIZE — use splice to drain in-place
       while (chronikTxs.length >= TX_EMIT_BATCH_SIZE) {
         const drained = chronikTxs.splice(0, TX_EMIT_BATCH_SIZE)
@@ -865,6 +869,8 @@ export class ChronikBlockchainClient {
               })
             )
             pairsFromBatch.push(...chunkResults)
+            // Yield event loop between transform chunks to prevent CPU starvation
+            await yieldEventLoop()
           }
 
           for (const { row } of pairsFromBatch) {