refactor: use console.warn instead of console.error in catch blocks of KDA-USD price update workflow and node/statistics cache

Author: mschead

indexer/package.json

@@ -21,7 +21,6 @@
     "@sentry/profiling-node": "^9.19.0",
     "@types/axios": "^0.14.4",
     "apollo-server-plugin-base": "^3.7.2",
-    "axios": "^1.9.0",
     "commander": "^12.0.0",
     "cors": "^2.8.5",
     "dataloader": "^2.2.2",

indexer/src/cache/init.ts

@@ -76,8 +76,8 @@ export default async function initCache(context: ResolverContext) {
       };
       MEMORY_CACHE.set(HASH_RATE_AND_TOTAL_DIFFICULTY_KEY, newValue);
     } catch (err) {
-      console.error(
-        '[ERROR][CACHE][CONN_TIMEOUT] Failed to get hash rate and total difficulty',
+      console.warn(
+        '[WARN][CACHE][HASH_RATE_AND_TOTAL_DIFFICULTY] Failed to get hash rate and total difficulty',
         err,
       );
     }
@@ -94,7 +94,7 @@ export default async function initCache(context: ResolverContext) {
       const networkStatistics = await networkRepository.getNetworkStatistics();
       MEMORY_CACHE.set(NETWORK_STATISTICS_KEY, networkStatistics);
     } catch (err) {
-      console.error('[ERROR][CACHE][CONN_TIMEOUT] Failed to get network statistics', err);
+      console.warn('[WARN][CACHE][NETWORK_STATISTICS] Failed to get network statistics', err);
     }
   }
 
@@ -109,23 +109,23 @@ export default async function initCache(context: ResolverContext) {
       const nodeInfo = await networkRepository.getNodeInfo();
       MEMORY_CACHE.set(NODE_INFO_KEY, nodeInfo);
     } catch (err) {
-      console.error('[ERROR][CACHE][CONN_TIMEOUT] Failed to get node info', err);
+      console.warn('[WARN][CACHE][NODE_INFO] Failed to get node info', err);
     }
   }
 
   /**
-   * Fetches and caches information about the blockchain node
-   *
-   * This includes node version, connectivity status, and other
-   * node-specific information that helps monitor the node's health.
+   * Fetches and caches information about number of blocks, transactions,
+   * and total gas used in each chain.
    */
-
   async function getCountersOfEachChain() {
     try {
       const counters = await networkRepository.getCountersOfEachChain();
       MEMORY_CACHE.set(COUNTERS_OF_EACH_CHAIN_KEY, counters);
     } catch (err) {
-      console.error('[ERROR][CACHE][CONN_TIMEOUT] Failed to get counters of each chain', err);
+      console.warn(
+        '[WARN][CACHE][COUNTERS_OF_EACH_CHAIN] Failed to get counters of each chain',
+        err,
+      );
     }
   }
 

indexer/src/kadena-server/server.ts

@@ -44,7 +44,6 @@ import {
 } from 'graphql';
 
 import initCache from '../cache/init';
-import { getArrayEnvString } from '../utils/helpers';
 import {
   directiveEstimator,
   fieldExtensionsEstimator,

indexer/src/services/price/price-updater.service.ts

@@ -1,5 +1,3 @@
-import axios from 'axios';
-
 import { PriceService } from './price.service';
 
 export class PriceUpdaterService {
@@ -23,11 +21,26 @@ export class PriceUpdaterService {
 
   private async updatePrice(): Promise<void> {
     try {
-      const response = await axios.get(this.DIA_API_URL);
-      const price = response.data.Price;
-      this.priceService.setKdaUsdPrice(price);
+      const response = await fetch(this.DIA_API_URL, {
+        headers: {
+          Accept: 'application/json',
+          'User-Agent': 'node-fetch',
+        },
+      });
+
+      if (!response.ok) {
+        throw new Error(`HTTP ${response.status} - ${response.statusText}`);
+      }
+
+      const data = await response.json();
+
+      if (data?.Price === undefined) {
+        throw new Error('Price field is missing in API response');
+      }
+
+      this.priceService.setKdaUsdPrice(data.Price);
     } catch (error) {
-      console.error('[ERROR][INT][INT_API] Failed to update KDA/USD price:', error);
+      console.warn('[WARN][API][PRICE_UPDATER] Failed to update KDA/USD price:', error);
     }
   }
 

indexer/src/utils/helpers.ts

@@ -40,18 +40,6 @@ export function getRequiredEnvString(key: string): string {
   return value;
 }
 
-/**
- * Retrieves an optional environment variable as a string array.
- * The environment variable is expected to be a comma-separated string.
- *
- * @param key - The name of the environment variable to retrieve.
- * @returns The value of the environment variable as a string array, or an empty array if the variable is not set.
- */
-export function getArrayEnvString(key: string): string[] {
-  const value = process.env[key] ?? '';
-  return value.split(',').filter(item => item.trim() !== '');
-}
-
 /**
  * Checks if a value is null or undefined.
  *

yarn.lock

@@ -3410,7 +3410,7 @@ auto-bind@~4.0.0:
   resolved "https://registry.npmjs.org/auto-bind/-/auto-bind-4.0.0.tgz"
   integrity sha512-Hdw8qdNiqdJ8LqT0iK0sVzkFbzg6fhnQqqfWhBDxcHZvU75+B+ayzTy8x+k5Ix0Y92XOhOUlx74ps+bA6BeYMQ==
 
-axios@*, axios@^1.9.0:
+axios@*:
   version "1.9.0"
   resolved "https://registry.yarnpkg.com/axios/-/axios-1.9.0.tgz#25534e3b72b54540077d33046f77e3b8d7081901"
   integrity sha512-re4CqKTJaURpzbLHtIi6XpDv20/CnpXOtjRY5/CU32L8gU8ek9UIivcfvSWvmKEngmVbrUtPpdDwWDWL7DNHvg==