d0zingcat/ore
1
0
Fork 0
mirror of https://github.com/d0zingcat/ore.git synced 2026-05-13 23:16:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

swap event

Browse Source
This commit is contained in:
Hardhat Chad
2025-06-30 14:57:55 -10:00
parent c42656460c
commit 6955c33aba
6 changed files with 39 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
api/src/event.rs
View File

@@ -49,6 +49,12 @@ pub struct SwapEvent {
/// Amount of quote tokens taken in fees.
pub quote_fee: u64,
/// Amount of base tokens in the market.
pub base_liquidity: u64,
/// Amount of quote tokens in the market.
pub quote_liquidity: u64,
/// The timestamp of the event.
pub ts: i64,
}

2
api/src/state/market/buy_exact_in.rs
View File

@@ -65,6 +65,8 @@ impl Market {
base_via_curve: base_via_curve as u64,
quote_via_curve: quote_via_curve as u64,
quote_fee: quote_fee as u64,
base_liquidity: self.base.liquidity() as u64,
quote_liquidity: self.quote.liquidity() as u64,
ts: 0,
};

2
api/src/state/market/buy_exact_out.rs
View File

@@ -70,6 +70,8 @@ impl Market {
base_via_curve: base_via_curve as u64,
quote_via_curve: quote_via_curve as u64,
quote_fee: quote_fee as u64,
base_liquidity: self.base.liquidity() as u64,
quote_liquidity: self.quote.liquidity() as u64,
ts: 0,
};

2
api/src/state/market/sell_exact_in.rs
View File

@@ -74,6 +74,8 @@ impl Market {
base_via_curve: base_via_curve as u64,
quote_via_curve: quote_via_curve as u64,
quote_fee: quote_fee as u64,
base_liquidity: self.base.liquidity() as u64,
quote_liquidity: self.quote.liquidity() as u64,
ts: 0,
};

2
api/src/state/market/sell_exact_out.rs
View File

@@ -72,6 +72,8 @@ impl Market {
base_via_curve: base_via_curve as u64,
quote_via_curve: quote_via_curve as u64,
quote_fee: quote_fee as u64,
base_liquidity: self.base.liquidity() as u64,
quote_liquidity: self.quote.liquidity() as u64,
ts: 0,
};

25
cli/src/main.rs
View File

@@ -33,6 +33,9 @@ async fn main() {
"close" => {
close(&rpc, &payer).await.unwrap();
}
"close_all" => {
close_all(&rpc, &payer).await.unwrap();
}
"clock" => {
log_clock(&rpc).await.unwrap();
}
@@ -94,6 +97,28 @@ async fn close(
Ok(())
}
async fn close_all(
rpc: &RpcClient,
payer: &solana_sdk::signer::keypair::Keypair,
) -> Result<(), anyhow::Error> {
let config = get_config(rpc).await?;
let clock = get_clock(rpc).await?;
let blocks = get_blocks(rpc).await?;
for (_, block) in blocks {
if clock.slot > block.start_slot + 1500 {
let ix = ore_api::sdk::close(
payer.pubkey(),
config.fee_collector,
block.opener,
payer.pubkey(),
block.id,
);
submit_transaction(rpc, payer, &[ix]).await?;
}
}
Ok(())
}
async fn commit(
rpc: &RpcClient,
payer: &solana_sdk::signer::keypair::Keypair,