enhance error handling and logging in HCaptcha and stats services

Author: flopez7

packages/apps/dashboard/server/src/modules/stats/stats.service.ts

@@ -392,47 +392,66 @@ export class StatsService implements OnModuleInit {
       return cachedHmtPrice;
     }
 
-    const headers = this.envConfigService.hmtPriceSourceApiKey
-      ? { 'x-cg-demo-api-key': this.envConfigService.hmtPriceSourceApiKey }
-      : {};
+    try {
+      const headers = this.envConfigService.hmtPriceSourceApiKey
+        ? { 'x-cg-demo-api-key': this.envConfigService.hmtPriceSourceApiKey }
+        : {};
 
-    const { data } = await lastValueFrom(
-      this.httpService.get(this.envConfigService.hmtPriceSource, { headers }),
-    );
+      const { data } = await lastValueFrom(
+        this.httpService.get(this.envConfigService.hmtPriceSource, { headers }),
+      );
 
-    let hmtPrice: number;
-
-    if (this.envConfigService.hmtPriceSource.includes('coingecko')) {
-      if (
-        !data ||
-        !data[this.envConfigService.hmtPriceFromKey] ||
-        !data[this.envConfigService.hmtPriceFromKey][
-          this.envConfigService.hmtPriceToKey
-        ]
-      ) {
-        throw new Error('Failed to fetch HMT price from CoinGecko API');
+      let hmtPrice: number;
+
+      if (this.envConfigService.hmtPriceSource.includes('coingecko')) {
+        if (
+          !data ||
+          !data[this.envConfigService.hmtPriceFromKey] ||
+          !data[this.envConfigService.hmtPriceFromKey][
+            this.envConfigService.hmtPriceToKey
+          ]
+        ) {
+          throw new Error('Failed to fetch HMT price from CoinGecko API');
+        }
+        hmtPrice = parseFloat(
+          data[this.envConfigService.hmtPriceFromKey][
+            this.envConfigService.hmtPriceToKey
+          ],
+        );
+      } else if (this.envConfigService.hmtPriceSource.includes('coinlore')) {
+        if (
+          !data ||
+          !data[0] ||
+          !data[0].price_usd ||
+          data[0].symbol !== 'HMT'
+        ) {
+          throw new Error('Failed to fetch HMT price from Coinlore API');
+        }
+        hmtPrice = parseFloat(data[0].price_usd);
+      } else {
+        throw new Error('Unsupported HMT price source');
       }
-      hmtPrice = parseFloat(
-        data[this.envConfigService.hmtPriceFromKey][
-          this.envConfigService.hmtPriceToKey
-        ],
+
+      await this.cacheManager.set(
+        this.redisConfigService.hmtPriceCacheKey,
+        hmtPrice,
+        this.redisConfigService.cacheHmtPriceTTL,
       );
-    } else if (this.envConfigService.hmtPriceSource.includes('coinlore')) {
-      if (!data || !data[0] || !data[0].price_usd || data[0].symbol !== 'HMT') {
-        throw new Error('Failed to fetch HMT price from Coinlore API');
+
+      return hmtPrice;
+    } catch (error) {
+      let formattedError = error;
+      if (error instanceof AxiosError) {
+        formattedError = httpUtils.formatAxiosError(error);
       }
-      hmtPrice = parseFloat(data[0].price_usd);
-    } else {
-      throw new Error('Unsupported HMT price source');
-    }
 
-    await this.cacheManager.set(
-      this.redisConfigService.hmtPriceCacheKey,
-      hmtPrice,
-      this.redisConfigService.cacheHmtPriceTTL,
-    );
+      this.logger.error('Failed to fetch HMT price', {
+        source: this.envConfigService.hmtPriceSource,
+        error: formattedError,
+      });
 
-    return hmtPrice;
+      throw error;
+    }
   }
 
   async hCaptchaStats(from: string, to: string): Promise<HcaptchaDailyStats[]> {

packages/apps/job-launcher/server/src/common/utils/storage.ts

@@ -1,5 +1,5 @@
 import { HttpStatus } from '@nestjs/common';
-import axios from 'axios';
+import axios, { AxiosError } from 'axios';
 import { parseString } from 'xml2js';
 import { StorageDataDto } from '../../modules/job/job.dto';
 import { ErrorBucket } from '../constants/errors';
@@ -10,6 +10,7 @@ import {
   GCS_HTTP_REGEX_PATH_BASED,
   GCS_HTTP_REGEX_SUBDOMAIN,
 } from './gcstorage';
+import { formatAxiosError } from './http';
 
 export function generateBucketUrl(
   storageData: StorageDataDto,
@@ -140,7 +141,11 @@ export async function listObjectsInBucket(url: URL): Promise<string[]> {
       } while (nextContinuationToken);
       resolve(objects);
     } catch (err) {
-      reject(err);
+      let formatted = err;
+      if (err instanceof AxiosError) {
+        formatted = formatAxiosError(err);
+      }
+      reject(formatted);
     }
   });
 }

packages/apps/reputation-oracle/server/src/integrations/hcaptcha/hcaptcha.service.ts

@@ -1,10 +1,12 @@
 import { HttpService } from '@nestjs/axios';
 import { Injectable } from '@nestjs/common';
+import { AxiosError } from 'axios';
 import { ethers } from 'ethers';
 import { firstValueFrom } from 'rxjs';
 
 import { HCaptchaConfigService } from '@/config';
 import logger from '@/logger';
+import { formatAxiosError } from '@/utils/http';
 
 import {
   GetLabelerQueryParams,
@@ -59,7 +61,13 @@ export class HCaptchaService {
         });
       }
     } catch (error) {
-      this.logger.error('Error occurred during token verification', error);
+      let formattedError = error;
+      if (error instanceof AxiosError) {
+        formattedError = formatAxiosError(error);
+      }
+      this.logger.error('Error occurred during token verification', {
+        error: formattedError,
+      });
     }
 
     return false;
@@ -105,8 +113,12 @@ export class HCaptchaService {
         });
       }
     } catch (error) {
+      let formattedError = error;
+      if (error instanceof AxiosError) {
+        formattedError = formatAxiosError(error);
+      }
       this.logger.error('Error occurred during labeling registration', {
-        error,
+        error: formattedError,
         ...data,
       });
     }
@@ -134,8 +146,12 @@ export class HCaptchaService {
         return response.data;
       }
     } catch (error) {
+      let formattedError = error;
+      if (error instanceof AxiosError) {
+        formattedError = formatAxiosError(error);
+      }
       this.logger.error(`Error occurred while retrieving labeler data`, {
-        error,
+        error: formattedError,
         email,
       });
     }