Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add priority fee and dynamic slippage #34

Open
wants to merge 1 commit into
base: main
Choose a base branch
from
Open

Add priority fee and dynamic slippage #34

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
50 changes: 23 additions & 27 deletions src/jupiter_python_sdk/jupiter.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -571,8 +571,7 @@ async def quote(
only_direct_routes: bool=False,
as_legacy_transaction: bool=False,
exclude_dexes: list=None,
max_accounts: int=None,
platform_fee_bps: int=None
max_accounts: int=None
) -> dict:
"""Get the best swap route for a token trade pair sorted by largest output token amount from https://quote-api.jup.ag/v6/quote

Expand All @@ -587,8 +586,7 @@ async def quote(
``only_direct_routes (bool)``: Default is False. Direct Routes limits Jupiter routing to single hop routes only.\n
``as_legacy_transaction (bool)``: Default is False. Instead of using versioned transaction, this will use the legacy transaction.\n
``exclude_dexes (list)``: Default is that all DEXes are included. You can pass in the DEXes that you want to exclude in a list. For example, ['Aldrin','Saber'].\n
``max_accounts (int)``: Find a route given a maximum number of accounts involved, this might dangerously limit routing ending up giving a bad price. The max is an estimation and not the exact count.\n
``platform_fee_bps (int)``: If you want to charge the user a fee, you can specify the fee in BPS. Fee % is taken out of the output token.
``max_accounts (int)``: Find a route given a maximum number of accounts involved, this might dangerously limit routing ending up giving a bad price. The max is an estimation and not the exact count.

Returns:
``dict``: returns best swap route
Expand Down Expand Up @@ -622,11 +620,9 @@ async def quote(
if slippage_bps:
quote_url += "&slippageBps=" + str(slippage_bps)
if exclude_dexes:
quote_url += "&excludeDexes=" + ','.join(exclude_dexes)
quote_url += "&excludeDexes=" + ','.join(exclude_dexes).lower()
if max_accounts:
quote_url += "&maxAccounts=" + str(max_accounts)
if platform_fee_bps:
quote_url += "&plateformFeeBps=" + platform_fee_bps

quote_response = httpx.get(url=quote_url).json()
try:
Expand All @@ -640,16 +636,15 @@ async def swap(
input_mint: str,
output_mint: str,
amount: int=0,
quoteResponse: str=None,
wrap_unwrap_sol: bool=True,
slippage_bps: int=1,
swap_mode: str="ExactIn",
prioritization_fee_lamports: int=None,
only_direct_routes: bool=False,
as_legacy_transaction: bool=False,
exclude_dexes: list=None,
max_accounts: int=None,
platform_fee_bps: int=None
dynamic_slippage: dict = None,
prioritization_fee_lamports: dict = None
) -> str:
"""Perform a swap.

Expand All @@ -659,15 +654,13 @@ async def swap(
``output_mint (str)``: Output token mint str\n
``amount (int)``: The API takes in amount in integer and you have to factor in the decimals for each token by looking up the decimals for that token. For example, USDC has 6 decimals and 1 USDC is 1000000 in integer when passing it in into the API.\n
Optionals:
``prioritizationFeeLamports (int)``: If transactions are expiring without confirmation on-chain, this might mean that you have to pay additional fees to prioritize your transaction. To do so, you can set the prioritizationFeeLamports parameter.\n
``wrap_unwrap_sol (bool)``: Auto wrap and unwrap SOL. Default is True.\n
``slippage_bps (int)``: The slippage % in BPS. If the output token amount exceeds the slippage then the swap transaction will fail.\n
``swap_mode (str)``: (ExactIn or ExactOut) Defaults to ExactIn. ExactOut is for supporting use cases where you need an exact token amount, like payments. In this case the slippage is on the input token.\n
``only_direct_routes (bool)``: Default is False. Direct Routes limits Jupiter routing to single hop routes only.\n
``as_legacy_transaction (bool)``: Default is False. Instead of using versioned transaction, this will use the legacy transaction.\n
``exclude_dexes (list)``: Default is that all DEXes are included. You can pass in the DEXes that you want to exclude in a list. For example, ['Aldrin','Saber'].\n
``max_accounts (int)``: Find a route given a maximum number of accounts involved, this might dangerously limit routing ending up giving a bad price. The max is an estimation and not the exact count.\n
``platform_fee_bps (int)``: If you want to charge the user a fee, you can specify the fee in BPS. Fee % is taken out of the output token.
``max_accounts (int)``: Find a route given a maximum number of accounts involved, this might dangerously limit routing ending up giving a bad price. The max is an estimation and not the exact count.

Returns:
``str``: returns serialized transactions to perform the swap from https://quote-api.jup.ag/v6/swap
Expand All @@ -685,26 +678,29 @@ async def swap(
AQAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAACAAQAJDpQzg6Gwmq0Gtgp4+LWUVz0yQOAuHGNJAGTs0dcqEMVCoh2aSWdVMvcatcojrWtwXATiOw7/o5hE7NFuy3p8vgLfsLhf7Ff9NofcPgIyAbMytm5ggTyKwmR+JqgXUXARVfefILshj4ZhFSjUfRpiSI47mVNFUq9v5NOOCWSEZJZM/GHGfBesEb9blQsf7DnKodziY279S/OPkZf0/OalnPEAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAMGRm/lIRcy/+ytunLDm+e8jOW7xfcSayxDmzpAAAAABHnVW/IxwG7udMVuzmgVB/2xst6j9I5RArHNola8E48Gm4hX/quBhPtof2NGGMA12sQ53BrrO1WYoPAAAAAAAQbd9uHXZaGT2cvhRs7reawctIXtX1s3kTqM9YV+/wCpT0tsDkEI/SpqJHjq4KzFnbIbtO31EcFiz2AtHgwJAfuMlyWPTiSJ8bs9ECkUjg2DC1oTmdr/EIQEjnvY2+n4WbQ/+if11/ZKdMCbHylYed5LCas238ndUUsyGqezjOXoxvp6877brTo9ZfNqq8l0MbG75MLS9uDkfKYCA0UvXWHmraeknnR8/memFAZWZHeDMQG7C5ZFLxolWUniPl6SYgcGAAUCwFwVAAYACQNIDQAAAAAAAAsGAAMACAUJAQEFAgADDAIAAAAgTgAAAAAAAAkBAwERBx8JCgADAQIECA0HBwwHGREBAhUOFxMWDxIQFAoYCQcHJMEgmzNB1pyBBwEAAAATZAABIE4AAAAAAACHBQAAAAAAADIAAAkDAwAAAQkB1rO1s+JVEuIRoGsE8f2MlAkFWssCkimIonlHpLV2w4gKBwKRTE0SjIeLSwIICg==
"""

if quoteResponse is None:
quoteResponse = await self.quote(
input_mint=input_mint,
output_mint=output_mint,
amount=amount,
slippage_bps=slippage_bps,
swap_mode=swap_mode,
only_direct_routes=only_direct_routes,
as_legacy_transaction=as_legacy_transaction,
exclude_dexes=exclude_dexes,
max_accounts=max_accounts,
platform_fee_bps=platform_fee_bps
)
quoteResponse = await self.quote(
input_mint=input_mint,
output_mint=output_mint,
amount=amount,
slippage_bps=slippage_bps,
swap_mode=swap_mode,
only_direct_routes=only_direct_routes,
as_legacy_transaction=as_legacy_transaction,
exclude_dexes=exclude_dexes,
max_accounts=max_accounts
)
transaction_parameters = {
"quoteResponse": quoteResponse,
"userPublicKey": self.keypair.pubkey().__str__(),
"wrapAndUnwrapSol": wrap_unwrap_sol
}

# Add dynamic slippage and prioritization fee dictionaries if they are provided
if dynamic_slippage:
transaction_parameters["dynamicSlippage"] = dynamic_slippage
if prioritization_fee_lamports:
transaction_parameters.update({"prioritizationFeeLamports": prioritization_fee_lamports})
transaction_parameters["prioritizationFeeLamports"] = prioritization_fee_lamports

transaction_data = httpx.post(url=self.ENDPOINT_APIS_URL['SWAP'], json=transaction_parameters).json()
return transaction_data['swapTransaction']

Expand Down