Merge pull request #472 from begd/feat-monitoring

Monitoring: unified error reporting with severity, enriched context, and GraphQL/streaming coverageFeat monitoring

Author: mschead

indexer/config/config.js

@@ -37,6 +37,7 @@ module.exports = {
     password: process.env.DB_PASSWORD,
     database: process.env.DB_NAME,
     host: process.env.DB_HOST || 'localhost',
+    port: Number(process.env.DB_PORT) || 5432,
 
     // Database dialect to use (PostgreSQL)
     dialect: 'postgres',

indexer/src/config/database.ts

@@ -17,7 +17,9 @@ const DB_PASSWORD = getRequiredEnvString('DB_PASSWORD');
 const DB_NAME = getRequiredEnvString('DB_NAME');
 const DB_HOST = getRequiredEnvString('DB_HOST');
 const DB_SSL_ENABLED = getRequiredEnvString('DB_SSL_ENABLED');
-const DB_CONNECTION = `postgres://${DB_USERNAME}:${encodeURIComponent(DB_PASSWORD)}@${DB_HOST}/${DB_NAME}`;
+// Optional DB port (defaults to 5432)
+const DB_PORT = process.env.DB_PORT ? Number(process.env.DB_PORT) : 5432;
+const DB_CONNECTION = `postgres://${DB_USERNAME}:${encodeURIComponent(DB_PASSWORD)}@${DB_HOST}:${DB_PORT}/${DB_NAME}`;
 
 // Determine if SSL is enabled for database connections
 const isSslEnabled = DB_SSL_ENABLED === 'true';
@@ -78,6 +80,7 @@ export const sequelize = new Sequelize(
   process.env.DB_PASSWORD as string,
   {
     host: process.env.DB_HOST || 'localhost',
+    port: DB_PORT,
     dialect: 'postgres',
     pool: {
       max: 20,

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/index.ts

@@ -12,6 +12,8 @@ import dotenv from 'dotenv';
 console.info('[INFO][INFRA][INFRA_CONFIG] Loading environment variables...');
 dotenv.config();
 
+import { initializeErrorMonitoring } from './services/monitoring';
+
 import { program } from 'commander';
 import { startGraphqlServer } from './kadena-server/server';
 import { startStreaming } from './services/streaming';
@@ -48,6 +50,7 @@ const options = program.opts();
 async function main() {
   try {
     console.info('Starting v1.0.2.2 with pair creation');
+    initializeErrorMonitoring();
     setupAssociations();
     PriceUpdaterService.getInstance();
 

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

@@ -117,7 +117,7 @@ export default class BlockDbRepository implements BlockRepository {
       lastHeight = parseInt(heightStr, 10);
       lastId = parseInt(idStr, 10);
       if (isNaN(lastHeight) || isNaN(lastId)) {
-        throw new Error('Invalid after cursor');
+        throw new Error(`[ERROR][VALID][VALID_FORMAT] Invalid 'after' cursor:', ${after}`);
       }
     }
 
@@ -126,7 +126,7 @@ export default class BlockDbRepository implements BlockRepository {
       lastHeight = parseInt(heightStr, 10);
       lastId = parseInt(idStr, 10);
       if (isNaN(lastHeight) || isNaN(lastId)) {
-        throw new Error('Invalid before cursor');
+        throw new Error(`[ERROR][VALID][VALID_FORMAT] Invalid 'before' cursor:', ${before}`);
       }
     }
 
@@ -308,7 +308,7 @@ export default class BlockDbRepository implements BlockRepository {
       const beforeId = parseInt(id, 10);
 
       if (isNaN(beforeHeight) || isNaN(beforeId)) {
-        throw new Error('Invalid before cursor');
+        throw new Error(`[ERROR][VALID][VALID_FORMAT] Invalid 'before' cursor:', ${before}`);
       }
 
       queryParams.push(beforeHeight, beforeId);
@@ -322,7 +322,7 @@ export default class BlockDbRepository implements BlockRepository {
       const afterId = parseInt(id, 10);
 
       if (isNaN(afterHeight) || isNaN(afterId)) {
-        throw new Error('Invalid after cursor');
+        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})`;
@@ -407,7 +407,9 @@ export default class BlockDbRepository implements BlockRepository {
     const [balanceRow] = balanceRows;
 
     if (!balanceRow) {
-      throw new Error("Miner didn't exist.");
+      throw new Error(
+        `[ERROR][DB][DATA_MISSING] Miner account not found for block ${hash} on chain ${chainId}.`,
+      );
     }
 
     const res = await handleSingleQuery({
@@ -609,7 +611,9 @@ export default class BlockDbRepository implements BlockRepository {
     );
 
     if (blockRows.length !== eventIds.length) {
-      throw new Error('There was an issue fetching blocks for event IDs.');
+      throw new Error(
+        `[ERROR][DB][DATA_CORRUPT] Fetched blocks count (${blockRows.length}) does not match event IDs count (${eventIds.length}).`,
+      );
     }
 
     const blockMap = blockRows.reduce(
@@ -660,7 +664,9 @@ export default class BlockDbRepository implements BlockRepository {
     );
 
     if (blockRows.length !== transactionIds.length) {
-      throw new Error('There was an issue fetching blocks for transaction IDs.');
+      throw new Error(
+        `[ERROR][DB][DATA_CORRUPT] Fetched blocks count (${blockRows.length}) does not match transaction IDs count (${transactionIds.length}).`,
+      );
     }
 
     const blockMap = blockRows.reduce(
@@ -709,7 +715,9 @@ export default class BlockDbRepository implements BlockRepository {
     );
 
     if (blockRows.length !== hashes.length) {
-      throw new Error('There was an issue fetching blocks for transaction IDs.');
+      throw new Error(
+        `[ERROR][DB][DATA_CORRUPT] Fetched blocks count (${blockRows.length}) does not match requested hashes count (${hashes.length}).`,
+      );
     }
 
     const blockMap = blockRows.reduce(