Skip to content

Use new Jup endpoints. JUP_API_KEY is now required #23

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

Merged
mvines merged 1 commit into from
Jan 12, 2026
Merged

Use new Jup endpoints. JUP_API_KEY is now required #23

Show file tree
Hide file tree
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
4 changes: 2 additions & 2 deletions Cargo.lock
View file
Open in desktop

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

2 changes: 1 addition & 1 deletion Cargo.toml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ ftx = { git = "https://github.com/fabianboesiger/ftx", rev = "bb98235d356dd1a2be
futures = "0.3.25"
influxdb-client = "0.1.4"
itertools = "0.10.0"
jup-ag = "0.9.2"
jup-ag = "0.10.0"
#jup-ag = { path = "../jup_ag" }
#kraken_sdk_rest = { path = "../kraken_sdk_rust/kraken_sdk_rest" }
kraken_sdk_rest = { git = "https://github.com/mvines/kraken_sdk_rust", rev = "80c634b3a8527f653db989689b298496dad30d4e" }
Expand Down
121 changes: 69 additions & 52 deletions src/bin/sys.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -998,6 +998,7 @@ async fn process_jup_quote(
to_token: MaybeToken,
ui_amount: f64,
slippage_bps: u64,
jup_api_key: String,
) -> Result<(), Box<dyn std::error::Error>> {
let quote = jup_ag::quote(
from_token.mint(),
Expand All @@ -1007,6 +1008,7 @@ async fn process_jup_quote(
slippage_bps: Some(slippage_bps),
..jup_ag::QuoteConfig::default()
},
jup_api_key,
)
.await?;

Expand All @@ -1032,6 +1034,7 @@ async fn process_jup_swap<T: Signers>(
max_coingecko_value_percentage_loss: f64,
priority_fee: PriorityFee,
notifier: &Notifier,
jup_api_key: String,
) -> Result<(), Box<dyn std::error::Error>> {
let rpc_client = rpc_clients.default();

Expand Down Expand Up @@ -1106,6 +1109,7 @@ async fn process_jup_swap<T: Signers>(
slippage_bps: Some(slippage_bps),
..jup_ag::QuoteConfig::default()
},
jup_api_key.clone(),
)
.await?;

Expand Down Expand Up @@ -1150,7 +1154,9 @@ async fn process_jup_swap<T: Signers>(
jup_ag::PrioritizationFeeLamports::Exact { lamports };
}

let mut transaction = jup_ag::swap(swap_request).await?.swap_transaction;
let mut transaction = jup_ag::swap(swap_request, jup_api_key.clone())
.await?
.swap_transaction;

{
let mut transaction_compute_budget = sys::priority_fee::ComputeBudget::default();
Expand Down Expand Up @@ -6453,60 +6459,71 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
}
_ => unreachable!(),
},
("jup", Some(jup_matches)) => match jup_matches.subcommand() {
("quote", Some(arg_matches)) => {
let from_token = MaybeToken::from(value_t!(arg_matches, "from_token", Token).ok());
let to_token = MaybeToken::from(value_t!(arg_matches, "to_token", Token).ok());
let ui_amount = value_t_or_exit!(arg_matches, "amount", f64);
let slippage_bps = value_t_or_exit!(arg_matches, "slippage_bps", u64);
("jup", Some(jup_matches)) => {
let jup_api_key = std::env::var("JUP_API_KEY").map_err(|_| {
"JUP_API_KEY env var not set. Get one from https://portal.jup.ag".to_string()
});

process_jup_quote(from_token, to_token, ui_amount, slippage_bps).await?;
}
("swap", Some(arg_matches)) => {
let (signer, address) = signer_of(arg_matches, "address", &mut wallet_manager)?;
let from_token = MaybeToken::from(value_t!(arg_matches, "from_token", Token).ok());
let to_token = MaybeToken::from(value_t!(arg_matches, "to_token", Token).ok());
let ui_amount = match arg_matches.value_of("amount").unwrap() {
"ALL" => None,
ui_amount => Some(ui_amount.parse::<f64>().unwrap()),
};
let slippage_bps = value_t_or_exit!(arg_matches, "slippage_bps", u64);
let signer = signer.expect("signer");
let address = address.expect("address");
let lot_selection_method =
value_t_or_exit!(arg_matches, "lot_selection", LotSelectionMethod);
let lot_numbers = lot_numbers_of(arg_matches, "lot_numbers");
let signature = value_t!(arg_matches, "transaction", Signature).ok();
let if_from_balance_exceeds = value_t!(arg_matches, "if_from_balance_exceeds", f64)
.ok()
.map(|x| from_token.amount(x));
let for_no_less_than = value_t!(arg_matches, "for_no_less_than", f64).ok();
let max_coingecko_value_percentage_loss =
value_t_or_exit!(arg_matches, "max_coingecko_value_percentage_loss", f64);
match jup_matches.subcommand() {
("quote", Some(arg_matches)) => {
let from_token =
MaybeToken::from(value_t!(arg_matches, "from_token", Token).ok());
let to_token = MaybeToken::from(value_t!(arg_matches, "to_token", Token).ok());
let ui_amount = value_t_or_exit!(arg_matches, "amount", f64);
let slippage_bps = value_t_or_exit!(arg_matches, "slippage_bps", u64);

process_jup_swap(
&mut db,
&rpc_clients,
address,
from_token,
to_token,
ui_amount,
slippage_bps,
lot_selection_method,
lot_numbers,
vec![signer],
signature,
if_from_balance_exceeds,
for_no_less_than,
max_coingecko_value_percentage_loss,
priority_fee,
&notifier,
)
.await?;
process_sync_swaps(&mut db, rpc_client, &notifier).await?;
process_jup_quote(from_token, to_token, ui_amount, slippage_bps, jup_api_key?)
.await?;
}
("swap", Some(arg_matches)) => {
let (signer, address) = signer_of(arg_matches, "address", &mut wallet_manager)?;
let from_token =
MaybeToken::from(value_t!(arg_matches, "from_token", Token).ok());
let to_token = MaybeToken::from(value_t!(arg_matches, "to_token", Token).ok());
let ui_amount = match arg_matches.value_of("amount").unwrap() {
"ALL" => None,
ui_amount => Some(ui_amount.parse::<f64>().unwrap()),
};
let slippage_bps = value_t_or_exit!(arg_matches, "slippage_bps", u64);
let signer = signer.expect("signer");
let address = address.expect("address");
let lot_selection_method =
value_t_or_exit!(arg_matches, "lot_selection", LotSelectionMethod);
let lot_numbers = lot_numbers_of(arg_matches, "lot_numbers");
let signature = value_t!(arg_matches, "transaction", Signature).ok();
let if_from_balance_exceeds =
value_t!(arg_matches, "if_from_balance_exceeds", f64)
.ok()
.map(|x| from_token.amount(x));
let for_no_less_than = value_t!(arg_matches, "for_no_less_than", f64).ok();
let max_coingecko_value_percentage_loss =
value_t_or_exit!(arg_matches, "max_coingecko_value_percentage_loss", f64);

process_jup_swap(
&mut db,
&rpc_clients,
address,
from_token,
to_token,
ui_amount,
slippage_bps,
lot_selection_method,
lot_numbers,
vec![signer],
signature,
if_from_balance_exceeds,
for_no_less_than,
max_coingecko_value_percentage_loss,
priority_fee,
&notifier,
jup_api_key?,
)
.await?;
process_sync_swaps(&mut db, rpc_client, &notifier).await?;
}
_ => unreachable!(),
}
_ => unreachable!(),
},
}
(exchange, Some(exchange_matches)) => {
assert!(exchanges.contains(&exchange), "Bug!");
let exchange = Exchange::from_str(exchange)?;
Expand Down
Loading