publish to prod

apps/worker/job-handlers.ts

@@ -31,6 +31,8 @@ import { LoopsService } from '../../modules/loops/service';
 import { ContentController } from '../../modules/content/content-controller';
 import { StakedSonicController } from '../../modules/sts/sts-controller';
 import { UserBalancesController } from '../../modules/user/user-balances-controller';
+import { ca } from '@bgd-labs/aave-address-book/dist/ChainlinkEthereum-CbJoeh6P';
+import { error } from 'console';
 
 const runningJobs: Set<string> = new Set();
 
@@ -128,8 +130,17 @@ const setupJobHandlers = async (name: string, chainId: string, res: any, next: N
                 async () => {
                     const chains = Object.keys(config) as Chain[];
                     const service = new PricingService(chains);
+                    const errors: Error[] = [];
                     for (const chain of chains) {
-                        await service.updatePrices(chain);
+                        try {
+                            await service.updatePrices(chain);
+                        } catch (error) {
+                            console.log(`Error updating prices for chain ${chain}:`, error);
+                            errors.push(error instanceof Error ? error : new Error(`Unknown error: ${error}`));
+                        }
+                    }
+                    if (errors.length > 0) {
+                        throw new Error(errors.map((e) => e.message).join(', '));
                     }
                     return 'OK';
                 },

modules/pricing/pricing-manager.ts

@@ -11,7 +11,7 @@ export class PricingManager {
         // Build initial price map from tokens' currentPrice
         const allPrices = new Map<string, { price: number; updatedBy: string }>();
         tokens.forEach((token) => {
-            if (token.currentPrice) {
+            if (typeof token.currentPrice === 'number' && Number.isFinite(token.currentPrice)) {
                 allPrices.set(token.address, {
                     price: token.currentPrice,
                     updatedBy: token.pricedBy || '',

modules/pricing/pricing-repository.ts

@@ -98,14 +98,29 @@ export class PricingRepository {
             return [];
         }
 
+        const validPriceItems = priceItems.filter(
+            (item) => typeof item.price === 'number' && Number.isFinite(item.price),
+        );
+
+        if (validPriceItems.length === 0) {
+            return [];
+        }
+
         // Create latest price map
-        const latestPrices = Object.fromEntries(tokensForPricing.map((token) => [token.address, token.currentPrice]));
+        const latestPrices = Object.fromEntries(
+            tokensForPricing.map((token) => [
+                token.address,
+                typeof token.currentPrice === 'number' && Number.isFinite(token.currentPrice)
+                    ? token.currentPrice
+                    : undefined,
+            ]),
+        );
 
         const hourlyTimestamp = timestampRoundedUpToNearestHour();
 
         const operations: any[] = [];
 
-        for (const item of priceItems) {
+        for (const item of validPriceItems) {
             // Update or create hourly price in TokenPrice table
             operations.push(
                 prisma.prismaTokenPrice.upsert({
@@ -170,7 +185,7 @@ export class PricingRepository {
 
         await prismaBulkExecuteOperations(operations);
 
-        return priceItems.map((item) => item.address);
+        return validPriceItems.map((item) => item.address);
     }
 
     private collectAllTokenAddresses(tokens: { address: string; underlyingTokenAddress?: string | null }[]): string[] {