refactor: adding correct tags and names to errors

Author: 0xneves

indexer/src/config/migrator-wrapper.ts

@@ -73,7 +73,7 @@ async function isDatabaseAlreadyCreated() {
   try {
     await migrate();
   } catch (error) {
-    console.error('Migration failed:', error);
+    console.error('[ERROR][INFRA][INFRA_DEPLOY] Migration failed:', error);
     process.exit(1);
   } finally {
     await sequelize.close();

indexer/src/kadena-server/domain/gas/input-checker.gas.ts

@@ -101,6 +101,6 @@ export function determineInputType(input: IGasLimitEstimationInput): UserInput {
 
   // If none of the above formats match, throw error
   throw new GasLimitEstimationError(
-    'Unknown input type. Please see the README for the accepted input format.',
+    '[ERROR][GRAPHQL][GAS][INPUT_CHECKER] Unknown input type. Please see the README for the accepted input format.',
   );
 }

indexer/src/kadena-server/domain/gas/parser.gas.ts

@@ -53,7 +53,7 @@ export function parseInput(input: string): IGasLimitEstimationInput {
     return schema.parse(parsed);
   } catch (e) {
     throw new GasLimitEstimationError(
-      'Unable to parse input as JSON. Please see the README for the accepted input format.',
+      '[ERROR][GAS][PARSER] Unable to parse input as JSON. Please see the README for the accepted input format.',
     );
   }
 }

indexer/src/kadena-server/domain/gas/transaction.gas.ts

@@ -135,7 +135,9 @@ export const buildTransactionPayload = (input: UserInput, networkId: string): IU
 
     // Handle unexpected input types
     default:
-      throw new GasLimitEstimationError('Something went wrong generating the transaction.');
+      throw new GasLimitEstimationError(
+        '[ERROR][GAS][TRANSACTION] Something went wrong generating the transaction.',
+      );
   }
 
   return transaction;

indexer/src/kadena-server/repository/infra/gateway/gas-api-gateway.ts

@@ -81,7 +81,7 @@ export default class GasApiGateway implements GasGateway {
     } catch (error) {
       // Wrap and rethrow any errors in our custom error type
       throw new GasLimitEstimationError(
-        'Chainweb Node was unable to estimate the gas limit',
+        '[ERROR][GAS_API_GATEWAY][ESTIMATE_GAS] Chainweb Node was unable to estimate the gas limit',
         error,
       );
     }

indexer/src/kadena-server/repository/infra/query-builders/transaction-query-builder.ts

@@ -57,7 +57,7 @@ export default class TransactionQueryBuilder {
 
     if (isNullOrUndefined(accountName) && minHeight && !maxHeight) {
       if (minHeight < 0) {
-        throw new Error('minHeight cannot be less than 0');
+        throw new Error('[ERROR][VALID][VALID_RANGE] minHeight cannot be less than 0');
       }
       blockParams.push(minHeight);
       const op = this.operator(blockParams.length);
@@ -66,7 +66,7 @@ export default class TransactionQueryBuilder {
 
     if (isNullOrUndefined(accountName) && minHeight && maxHeight) {
       if (minHeight > maxHeight) {
-        throw new Error('minHeight cannot be greater than maxHeight');
+        throw new Error('[ERROR][VALID][VALID_RANGE] minHeight cannot be greater than maxHeight');
       }
 
       blockParams.push(minHeight);

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

@@ -118,7 +118,7 @@ export default class BlockDbRepository implements BlockRepository {
       lastHeight = parseInt(heightStr, 10);
       lastId = parseInt(idStr, 10);
       if (isNaN(lastHeight) || isNaN(lastId)) {
-        throw new Error(`[INFO][PAGINATION][INVALID_AFTER_CURSOR] Invalid 'after' cursor:', ${after}`);
+        throw new Error(`[ERROR][VALID][VALID_FORMAT] Invalid 'after' cursor:', ${after}`);
       }
     }
 
@@ -127,7 +127,7 @@ export default class BlockDbRepository implements BlockRepository {
       lastHeight = parseInt(heightStr, 10);
       lastId = parseInt(idStr, 10);
       if (isNaN(lastHeight) || isNaN(lastId)) {
-        throw new Error(`[INFO][PAGINATION][INVALID_BEFORE_CURSOR] Invalid 'before' cursor:', ${before}`);
+        throw new Error(`[ERROR][VALID][VALID_FORMAT] Invalid 'before' cursor:', ${before}`);
       }
     }
 
@@ -240,7 +240,7 @@ export default class BlockDbRepository implements BlockRepository {
       const beforeId = parseInt(id, 10);
 
       if (isNaN(beforeHeight) || isNaN(beforeId)) {
-        throw new Error(`[ERROR][PAGINATION][INVALID_BEFORE_CURSOR] Invalid 'before' cursor:', ${before}`);
+        throw new Error(`[ERROR][VALID][VALID_FORMAT] Invalid 'before' cursor:', ${before}`);
       }
 
       queryParams.push(beforeHeight, beforeId);
@@ -254,7 +254,7 @@ export default class BlockDbRepository implements BlockRepository {
       const afterId = parseInt(id, 10);
 
       if (isNaN(afterHeight) || isNaN(afterId)) {
-        throw new Error(`[ERROR][PAGINATION][INVALID_BEFORE_CURSOR] Invalid 'before' cursor:', ${before}`);
+        throw new Error(`[ERROR][VALID][VALID_FORMAT] Invalid 'after' cursor:', ${after}`);
       }
       queryParams.push(afterHeight, afterId);
       conditions += `\nAND (b.height, b.id) < ($${queryParams.length - 1}, $${queryParams.length})`;
@@ -339,7 +339,9 @@ export default class BlockDbRepository implements BlockRepository {
     const [balanceRow] = balanceRows;
 
     if (!balanceRow) {
-      throw new Error(`[ERROR][MINER][NOT_FOUND] Miner account not found for block ${hash} on chain ${chainId}.`);
+      throw new Error(
+        `[ERROR][DB][DATA_MISSING] Miner account not found for block ${hash} on chain ${chainId}.`,
+      );
     }
 
     const res = await handleSingleQuery({
@@ -539,7 +541,9 @@ export default class BlockDbRepository implements BlockRepository {
     );
 
     if (blockRows.length !== eventIds.length) {
-      throw new Error(`[ERROR][EVENTS][FETCH_BLOCKS_MISMATCH] Fetched blocks count (${blockRows.length}) does not match event IDs count (${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(
@@ -589,7 +593,9 @@ export default class BlockDbRepository implements BlockRepository {
     );
 
     if (blockRows.length !== transactionIds.length) {
-      throw new Error(`[ERROR][TRANSACTIONS][FETCH_BLOCKS_MISMATCH] Fetched blocks count (${blockRows.length}) does not match transaction IDs count (${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(
@@ -637,7 +643,9 @@ export default class BlockDbRepository implements BlockRepository {
     );
 
     if (blockRows.length !== hashes.length) {
-      throw new Error(`[ERROR][BLOCKS][FETCH_BY_HASHES_MISMATCH] Fetched blocks count (${blockRows.length}) does not match requested hashes count (${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(

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

@@ -169,7 +169,7 @@ export default class PoolDbRepository {
     });
 
     if (!pairResult) {
-      throw new Error(`Token pair not found for pool ${id}`);
+      throw new Error(`[ERROR][GRAPHQL][DB][DATA_MISSING] Token pair not found for pool ${id}`);
     }
     const pair = pairResult as Pair;
 
@@ -188,7 +188,7 @@ export default class PoolDbRepository {
     const token0 = tokens.find((t: any) => t.id === pair.token0Id) as TokenModel;
     const token1 = tokens.find((t: any) => t.id === pair.token1Id) as TokenModel;
     if (!token0 || !token1) {
-      throw new Error(`Tokens not found for pool ${id}`);
+      throw new Error(`[ERROR][GRAPHQL][DB][DATA_MISSING] Tokens not found for pool ${id}`);
     }
 
     // Get the latest pool stats

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

@@ -719,7 +719,9 @@ export default class TransactionDbRepository implements TransactionRepository {
     );
 
     if (rows.length !== eventIds.length) {
-      throw new Error(`[ERROR][EVENTS][FETCH_BLOCKS_MISMATCH] Fetched blocks count (${rows.length}) does not match event IDs count (${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(

indexer/src/kadena-server/resolvers/node-utils.ts

@@ -61,7 +61,7 @@ export const getNode = async (context: ResolverContext, id: string) => {
     // TODO: [ERROR-OPTIMIZATION] missing try catch block
     const output = await context.blockRepository.getBlockByHash(params);
     if (!output) {
-      throw new Error('[ERROR][DB][DATA_MISSING] Block not found.');
+      throw new Error('[ERROR][GRAPHQL][DB][DATA_MISSING] Block not found.');
     }
     return buildBlockOutput(output);
   }