From 5280cdba6ca72d42c89ad56e33a43b8d7d3af059 Mon Sep 17 00:00:00 2001
From: Aditya Arora <arora.aditya520@gmail.com>
Date: Mon, 2 Jun 2025 14:34:22 +0200
Subject: [PATCH] fix(price-pusher) Ignore Invlide PF

---
 apps/price_pusher/src/aptos/aptos.ts         | 1 +
 apps/price_pusher/src/fuel/fuel.ts           | 1 +
 apps/price_pusher/src/injective/injective.ts | 1 +
 apps/price_pusher/src/near/near.ts           | 1 +
 apps/price_pusher/src/solana/solana.ts       | 2 ++
 apps/price_pusher/src/sui/sui.ts             | 1 +
 apps/price_pusher/src/ton/ton.ts             | 1 +
 7 files changed, 8 insertions(+)

diff --git a/apps/price_pusher/src/aptos/aptos.ts b/apps/price_pusher/src/aptos/aptos.ts
index fe95a5f73d..ad3d738c75 100644
--- a/apps/price_pusher/src/aptos/aptos.ts
+++ b/apps/price_pusher/src/aptos/aptos.ts
@@ -109,6 +109,7 @@ export class AptosPricePusher implements IPricePusher {
   async getPriceFeedsUpdateData(priceIds: string[]): Promise<number[][]> {
     const response = await this.hermesClient.getLatestPriceUpdates(priceIds, {
       encoding: "base64",
+      ignoreInvalidPriceIds: true,
     });
     return response.binary.data.map((data) =>
       Array.from(Buffer.from(data, "base64")),
diff --git a/apps/price_pusher/src/fuel/fuel.ts b/apps/price_pusher/src/fuel/fuel.ts
index 0d6edb9f1a..3efe3aeea4 100644
--- a/apps/price_pusher/src/fuel/fuel.ts
+++ b/apps/price_pusher/src/fuel/fuel.ts
@@ -101,6 +101,7 @@ export class FuelPricePusher implements IPricePusher {
     try {
       const response = await this.hermesClient.getLatestPriceUpdates(priceIds, {
         encoding: "base64",
+        ignoreInvalidPriceIds: true,
       });
       priceFeedUpdateData = response.binary.data;
     } catch (err: any) {
diff --git a/apps/price_pusher/src/injective/injective.ts b/apps/price_pusher/src/injective/injective.ts
index 23ebb0b820..8ef45375ad 100644
--- a/apps/price_pusher/src/injective/injective.ts
+++ b/apps/price_pusher/src/injective/injective.ts
@@ -301,6 +301,7 @@ export class InjectivePricePusher implements IPricePusher {
     try {
       const response = await this.hermesClient.getLatestPriceUpdates(priceIds, {
         encoding: "base64",
+        ignoreInvalidPriceIds: true,
       });
       const vaas = response.binary.data;
 
diff --git a/apps/price_pusher/src/near/near.ts b/apps/price_pusher/src/near/near.ts
index 41a3000557..3bc39c173d 100644
--- a/apps/price_pusher/src/near/near.ts
+++ b/apps/price_pusher/src/near/near.ts
@@ -131,6 +131,7 @@ export class NearPricePusher implements IPricePusher {
   ): Promise<string[]> {
     const response = await this.hermesClient.getLatestPriceUpdates(priceIds, {
       encoding: "base64",
+      ignoreInvalidPriceIds: true,
     });
     return response.binary.data;
   }
diff --git a/apps/price_pusher/src/solana/solana.ts b/apps/price_pusher/src/solana/solana.ts
index e907283496..8993f619d5 100644
--- a/apps/price_pusher/src/solana/solana.ts
+++ b/apps/price_pusher/src/solana/solana.ts
@@ -118,6 +118,7 @@ export class SolanaPricePusher implements IPricePusher {
         shuffledPriceIds,
         {
           encoding: "base64",
+          ignoreInvalidPriceIds: true,
         },
       );
       priceFeedUpdateData = response.binary.data;
@@ -211,6 +212,7 @@ export class SolanaPricePusherJito implements IPricePusher {
     try {
       const response = await this.hermesClient.getLatestPriceUpdates(priceIds, {
         encoding: "base64",
+        ignoreInvalidPriceIds: true,
       });
       priceFeedUpdateData = response.binary.data;
     } catch (err: any) {
diff --git a/apps/price_pusher/src/sui/sui.ts b/apps/price_pusher/src/sui/sui.ts
index 96c6541d37..2ba1644806 100644
--- a/apps/price_pusher/src/sui/sui.ts
+++ b/apps/price_pusher/src/sui/sui.ts
@@ -225,6 +225,7 @@ export class SuiPricePusher implements IPricePusher {
           priceIdChunk,
           {
             encoding: "base64",
+            ignoreInvalidPriceIds: true,
           },
         );
         if (response.binary.data.length !== 1) {
diff --git a/apps/price_pusher/src/ton/ton.ts b/apps/price_pusher/src/ton/ton.ts
index d527ba3c66..4ecb681de8 100644
--- a/apps/price_pusher/src/ton/ton.ts
+++ b/apps/price_pusher/src/ton/ton.ts
@@ -98,6 +98,7 @@ export class TonPricePusher implements IPricePusher {
     try {
       const response = await this.hermesClient.getLatestPriceUpdates(priceIds, {
         encoding: "base64",
+        ignoreInvalidPriceIds: true,
       });
       priceFeedUpdateData = response.binary.data;
     } catch (err: any) {