diff --git a/backend/src/api/rbf-cache.ts b/backend/src/api/rbf-cache.ts index d2b7ddf6c..708393083 100644 --- a/backend/src/api/rbf-cache.ts +++ b/backend/src/api/rbf-cache.ts @@ -480,7 +480,7 @@ class RbfCache { }; if (config.MEMPOOL.BACKEND === 'esplora') { - const sliceLength = Math.floor(config.ESPLORA.BATCH_QUERY_BASE_SIZE / 40); + const sliceLength = Math.ceil(config.ESPLORA.BATCH_QUERY_BASE_SIZE / 40); for (let i = 0; i < Math.ceil(txids.length / sliceLength); i++) { const slice = txids.slice(i * sliceLength, (i + 1) * sliceLength); try { diff --git a/backend/src/tasks/lightning/forensics.service.ts b/backend/src/tasks/lightning/forensics.service.ts index a21c4c280..aa88f5bb4 100644 --- a/backend/src/tasks/lightning/forensics.service.ts +++ b/backend/src/tasks/lightning/forensics.service.ts @@ -79,7 +79,7 @@ class ForensicsService { } let progress = 0; - const sliceLength = Math.floor(config.ESPLORA.BATCH_QUERY_BASE_SIZE / 10); + const sliceLength = Math.ceil(config.ESPLORA.BATCH_QUERY_BASE_SIZE / 10); // process batches of 1000 channels for (let i = 0; i < Math.ceil(allChannels.length / sliceLength); i++) { const channels = allChannels.slice(i * sliceLength, (i + 1) * sliceLength); diff --git a/backend/src/tasks/lightning/network-sync.service.ts b/backend/src/tasks/lightning/network-sync.service.ts index 09c8b912e..7d6a40571 100644 --- a/backend/src/tasks/lightning/network-sync.service.ts +++ b/backend/src/tasks/lightning/network-sync.service.ts @@ -290,7 +290,7 @@ class NetworkSyncService { const allChannels = await channelsApi.$getChannelsByStatus([0, 1]); - const sliceLength = Math.floor(config.ESPLORA.BATCH_QUERY_BASE_SIZE / 2); + const sliceLength = Math.ceil(config.ESPLORA.BATCH_QUERY_BASE_SIZE / 2); // process batches of 5000 channels for (let i = 0; i < Math.ceil(allChannels.length / sliceLength); i++) { const channels = allChannels.slice(i * sliceLength, (i + 1) * sliceLength);