Merge pull request #388 from hack-a-chain-software/dataloader-fix

fix: remove unnecessary error throwing in dataloaders

Author: mschead

indexer/src/kadena-server/repository/infra/repository/block-db-repository.ts

@@ -610,12 +610,6 @@ export default class BlockDbRepository implements BlockRepository {
       [eventIds],
     );
 
-    if (blockRows.length !== eventIds.length) {
-      throw new Error(
-        `[ERROR][DB][DATA_CORRUPT] Fetched blocks count (${blockRows.length}) does not match event IDs count (${eventIds.length}).`,
-      );
-    }
-
     const blockMap = blockRows.reduce(
       (acum, row) => ({
         ...acum,
@@ -663,12 +657,6 @@ export default class BlockDbRepository implements BlockRepository {
       [transactionIds],
     );
 
-    if (blockRows.length !== transactionIds.length) {
-      throw new Error(
-        `[ERROR][DB][DATA_CORRUPT] Fetched blocks count (${blockRows.length}) does not match transaction IDs count (${transactionIds.length}).`,
-      );
-    }
-
     const blockMap = blockRows.reduce(
       (acum, row) => ({
         ...acum,
@@ -714,12 +702,6 @@ export default class BlockDbRepository implements BlockRepository {
       [hashes],
     );
 
-    if (blockRows.length !== hashes.length) {
-      throw new Error(
-        `[ERROR][DB][DATA_CORRUPT] Fetched blocks count (${blockRows.length}) does not match requested hashes count (${hashes.length}).`,
-      );
-    }
-
     const blockMap = blockRows.reduce(
       (acum, row) => ({
         ...acum,

indexer/src/kadena-server/repository/infra/repository/transaction-db-repository.ts

@@ -772,12 +772,6 @@ export default class TransactionDbRepository implements TransactionRepository {
       [eventIds],
     );
 
-    if (rows.length !== eventIds.length) {
-      throw new Error(
-        `[ERROR][DB][DATA_CORRUPT] Fetched blocks count (${rows.length}) does not match event IDs count (${eventIds.length}).`,
-      );
-    }
-
     const transactionMap = rows.reduce(
       (acum, row) => ({
         ...acum,