test

Author: guibescos

apps/price_pusher/src/solana/command.ts

@@ -11,7 +11,7 @@ import {
 import { Controller } from "../controller";
 import { PythSolanaReceiver } from "@pythnetwork/pyth-solana-receiver";
 import NodeWallet from "@coral-xyz/anchor/dist/cjs/nodewallet";
-import { Keypair, Connection } from "@solana/web3.js";
+import { Keypair, Connection, LAMPORTS_PER_SOL } from "@solana/web3.js";
 import fs from "fs";
 import { PublicKey } from "@solana/web3.js";
 import {
@@ -66,6 +66,11 @@ export default {
       type: "boolean",
       default: false,
     } as Options,
+    "max-jito-tip-lamports": {
+      description: "Maximum jito tip lamports",
+      type: "number",
+      default: LAMPORTS_PER_SOL / 100,
+    } as Options,
     "jito-bundle-size": {
       description: "Number of transactions in each bundle",
       type: "number",
@@ -100,6 +105,7 @@ export default {
       jitoKeypairFile,
       jitoTipLamports,
       dynamicJitoTips,
+      maxJitoTipLamports,
       jitoBundleSize,
       updatesPerJitoBundle,
       logLevel,
@@ -155,6 +161,7 @@ export default {
         shardId,
         jitoTipLamports,
         dynamicJitoTips,
+        maxJitoTipLamports,
         jitoClient,
         jitoBundleSize,
         updatesPerJitoBundle

apps/price_pusher/src/solana/solana.ts

@@ -17,7 +17,6 @@ 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(
@@ -159,6 +158,7 @@ export class SolanaPricePusherJito implements IPricePusher {
     private shardId: number,
     private defaultJitoTipLamports: number,
     private dynamicJitoTips: boolean,
+    private maxJitoTipLamports: number,
     private searcherClient: SearcherClient,
     private jitoBundleSize: number,
     private updatesPerJitoBundle: number
@@ -195,7 +195,7 @@ export class SolanaPricePusherJito implements IPricePusher {
       ? (await this.getRecentJitoTipLamports()) ?? this.defaultJitoTipLamports
       : this.defaultJitoTipLamports;
 
-    const cappedJitoTip = Math.min(jitoTip, MAX_JITO_TIP_LAMPORTS);
+    const cappedJitoTip = Math.min(jitoTip, this.maxJitoTipLamports);
     this.logger.info({ cappedJitoTip }, "using jito tip of");
 
     let priceFeedUpdateData: string[];