fix: add retry logic to SolanaPricePusherJito

Author: ayazabbas

apps/price_pusher/src/solana/solana.ts

@@ -189,9 +189,12 @@ export class SolanaPricePusherJito implements IPricePusher {
     }
   }
 
+  private async sleep(ms: number): Promise<void> {
+    return new Promise(resolve => setTimeout(resolve, ms));
+  }
+
   async updatePriceFeed(
     priceIds: string[],
-    // eslint-disable-next-line @typescript-eslint/no-unused-vars
     _pubTimesToPush: number[]
   ): Promise<void> {
     const recentJitoTip = await this.getRecentJitoTipLamports();
@@ -234,11 +237,32 @@ export class SolanaPricePusherJito implements IPricePusher {
         jitoBundleSize: this.jitoBundleSize,
       });
 
-      await sendTransactionsJito(
-        transactions,
-        this.searcherClient,
-        this.pythSolanaReceiver.wallet
-      );
+      let retries = 60;
+      while (retries > 0) {
+        try {
+          await sendTransactionsJito(
+            transactions,
+            this.searcherClient,
+            this.pythSolanaReceiver.wallet
+          );
+          break;
+        } catch (err: any) {
+          if (err.code === 8 && err.details?.includes('Rate limit exceeded')) {
+            this.logger.warn('Rate limit hit, waiting before retry...');
+            await this.sleep(1100); // Wait slightly more than 1 second
+            retries--;
+            if (retries === 0) {
+              this.logger.error('Max retries reached for rate limit');
+              throw err;
+            }
+          } else {
+            throw err;
+          }
+        }
+      }
+
+      // Add a delay between bundles to avoid rate limiting
+      await this.sleep(1100);
     }
   }
 }