From e2ed039120958fde07297c6760022770dab710a8 Mon Sep 17 00:00:00 2001 From: Rafael Cardenas Date: Sat, 11 Nov 2023 21:05:59 -0600 Subject: [PATCH] fix: try batch iterator generator --- src/pg/pg-store.ts | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/pg/pg-store.ts b/src/pg/pg-store.ts index fc9a2821..66fc76f7 100644 --- a/src/pg/pg-store.ts +++ b/src/pg/pg-store.ts @@ -3,6 +3,7 @@ import { PgConnectionVars, PgSqlClient, PgSqlQuery, + batchIterate, connectPostgres, logger, runMigrations, @@ -255,7 +256,7 @@ export class PgStore extends BasePgStore { }); // Divide insertion array into chunks of 3000 in order to avoid the postgres limit of 65534 // query params. - for (const writeChunk of chunkArray(writes, 3000)) + for (const writeChunk of batchIterate(writes, 3000)) await this.insertInscriptions(writeChunk); updatedBlockHeightMin = Math.min(updatedBlockHeightMin, event.block_identifier.index); if (ENV.BRC20_BLOCK_SCAN_ENABLED)