feat(AllbridgeCoreSdkOptions): add optional jupiterMaxAccounts parameter

allbridge-io · Jan 27, 2025 · f1cc941 · f1cc941
1 parent 7e8ae33
commit f1cc941
Show file tree

Hide file tree

Showing 4 changed files with 18 additions and 8 deletions.
diff --git a/src/index.ts b/src/index.ts
@@ -44,6 +44,12 @@ export interface AllbridgeCoreSdkOptions {
    * Jupiter v6 Swap Api
    */
   jupiterUrl: string;
+  /**
+   * Jupiter v6 'maxAccounts' parameter</br>
+   * Rough estimate of the max accounts to be used for the quote, so that you can compose with your own accounts</br>
+   * {@link https://station.jup.ag/docs/apis/swap-api#using-maxaccounts}
+   */
+  jupiterMaxAccounts?: number;
   wormholeMessengerProgramId: string;
   solanaLookUpTable: string;
   sorobanNetworkPassphrase: string;

diff --git a/src/services/bridge/index.ts b/src/services/bridge/index.ts
@@ -177,6 +177,7 @@ export function getChainBridgeService(
           solanaLookUpTable: params.solanaLookUpTable,
           cctpParams: params.cctpParams,
           jupiterUrl: params.jupiterUrl,
+          jupiterMaxAccounts: params.jupiterMaxAccounts,
         },
         api,
       );

diff --git a/src/services/bridge/sol/index.ts b/src/services/bridge/sol/index.ts
@@ -59,6 +59,7 @@ export interface SolanaBridgeParams {
   solanaLookUpTable: string;
   cctpParams: CctpParams;
   jupiterUrl: string;
+  jupiterMaxAccounts?: number;
 }
 
 export interface CctpParams {
@@ -90,7 +91,7 @@ export class SolanaBridgeService extends ChainBridgeService {
     public api: AllbridgeCoreClient,
   ) {
     super();
-    this.jupiterService = new JupiterService(solanaRpcUrl, params.jupiterUrl);
+    this.jupiterService = new JupiterService(solanaRpcUrl, params.jupiterUrl, params.jupiterMaxAccounts);
   }
 
   async buildRawTransactionSwap(params: SwapParams): Promise<RawTransaction> {

diff --git a/src/services/bridge/sol/jupiter.ts b/src/services/bridge/sol/jupiter.ts
@@ -7,10 +7,12 @@ import { fetchAddressLookupTableAccountsFromTx } from "../../../utils/sol/utils"
 export class JupiterService {
   connection: Connection;
   jupiterUrl: string;
+  maxAccounts?: number;
 
-  constructor(solanaRpcUrl: string, jupiterUrl: string) {
+  constructor(solanaRpcUrl: string, jupiterUrl: string, jupiterMaxAccounts?: number) {
     this.connection = new Connection(solanaRpcUrl);
     this.jupiterUrl = jupiterUrl.replace(/\/$/, ""); // trim last "/" if exist
+    this.maxAccounts = jupiterMaxAccounts;
   }
 
   async getJupiterSwapTx(
@@ -22,12 +24,12 @@ export class JupiterService {
     let quoteResponse: any;
     try {
       const swapMode = exactOut ? "ExactOut" : "ExactIn";
-      quoteResponse = await axios.get(`${this.jupiterUrl}/quote?inputMint=${stableTokenAddress}
-&outputMint=${NATIVE_MINT.toString()}
-&amount=${amount}
-&swapMode=${swapMode}
-&slippageBps=100
-&onlyDirectRoutes=true`);
+      let url = `${this.jupiterUrl}/quote?inputMint=${stableTokenAddress}&outputMint=${NATIVE_MINT.toString()}&amount=${amount}&swapMode=${swapMode}&slippageBps=100&onlyDirectRoutes=true`;
+
+      if (this.maxAccounts) {
+        url += `&maxAccounts=${this.maxAccounts}`;
+      }
+      quoteResponse = await axios.get(url);
     } catch (err) {
       if (err instanceof AxiosError && err.response && err.response.data && err.response.data.error) {
         throw new JupiterError(err.response.data.error);