feat: add dynamic jito tips

apps/price_pusher/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pythnetwork/price-pusher",
-  "version": "8.1.0",
+  "version": "8.2.0",
   "description": "Pyth Price Pusher",
   "homepage": "https://pyth.network",
   "main": "lib/index.js",

apps/price_pusher/src/solana/command.ts

@@ -61,6 +61,11 @@ export default {
       type: "number",
       optional: true,
     } as Options,
+    "dynamic-jito-tips": {
+      description: "Use dynamic jito tips",
+      type: "boolean",
+      default: false,
+    } as Options,
     "jito-bundle-size": {
       description: "Number of transactions in each bundle",
       type: "number",
@@ -94,6 +99,7 @@ export default {
       jitoEndpoint,
       jitoKeypairFile,
       jitoTipLamports,
+      dynamicJitoTips,
       jitoBundleSize,
       updatesPerJitoBundle,
       logLevel,
@@ -148,6 +154,7 @@ export default {
         logger.child({ module: "SolanaPricePusherJito" }),
         shardId,
         jitoTipLamports,
+        dynamicJitoTips,
         jitoClient,
         jitoBundleSize,
         updatesPerJitoBundle

apps/price_pusher/src/solana/solana.ts

@@ -14,8 +14,10 @@ import {
 import { SearcherClient } from "jito-ts/dist/sdk/block-engine/searcher";
 import { sliceAccumulatorUpdateData } from "@pythnetwork/price-service-sdk";
 import { Logger } from "pino";
+import { LAMPORTS_PER_SOL } from "@solana/web3.js";
 
 const HEALTH_CHECK_TIMEOUT_SECONDS = 60;
+const MAX_JITO_TIP_LAMPORTS = LAMPORTS_PER_SOL / 100;
 
 export class SolanaPriceListener extends ChainPriceListener {
   constructor(
@@ -155,17 +157,47 @@ export class SolanaPricePusherJito implements IPricePusher {
     private priceServiceConnection: PriceServiceConnection,
     private logger: Logger,
     private shardId: number,
-    private jitoTipLamports: number,
+    private defaultJitoTipLamports: number,
+    private dynamicJitoTips: boolean,
     private searcherClient: SearcherClient,
     private jitoBundleSize: number,
     private updatesPerJitoBundle: number
   ) {}
 
+  async getRecentJitoTipLamports(): Promise<number | undefined> {
+    try {
+      const response = await fetch(
+        "http://bundles-api-rest.jito.wtf/api/v1/bundles/tip_floor"
+      );
+      if (!response.ok) {
+        this.logger.error(
+          { status: response.status, statusText: response.statusText },
+          "getRecentJitoTips http request failed"
+        );
+        return undefined;
+      }
+      const data = await response.json();
+      return Math.floor(
+        Number(data[0].landed_tips_25th_percentile) * LAMPORTS_PER_SOL
+      );
+    } catch (err: any) {
+      this.logger.error({ err }, "getRecentJitoTips failed");
+      return undefined;
+    }
+  }
+
   async updatePriceFeed(
     priceIds: string[],
     // eslint-disable-next-line @typescript-eslint/no-unused-vars
     _pubTimesToPush: number[]
   ): Promise<void> {
+    const jitoTip = this.dynamicJitoTips
+      ? (await this.getRecentJitoTipLamports()) ?? this.defaultJitoTipLamports
+      : this.defaultJitoTipLamports;
+
+    const cappedJitoTip = Math.min(jitoTip, MAX_JITO_TIP_LAMPORTS);
+    this.logger.info({ cappedJitoTip }, "using jito tip of");
+
     let priceFeedUpdateData: string[];
     try {
       priceFeedUpdateData = await this.priceServiceConnection.getLatestVaas(
@@ -192,7 +224,7 @@ export class SolanaPricePusherJito implements IPricePusher {
       );
 
       const transactions = await transactionBuilder.buildVersionedTransactions({
-        jitoTipLamports: this.jitoTipLamports,
+        jitoTipLamports: cappedJitoTip,
         tightComputeBudget: true,
         jitoBundleSize: this.jitoBundleSize,
       });