blockworks-foundation
/
openbook-candles
mirror of https://github.com/blockworks-foundation/openbook-candles.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

refactor: remove slow rpc call from /tickers

This commit is contained in:
dboures 2023-05-07 16:59:00 -05:00
parent 037afe36dd
commit 5da3dd3a79
No known key found for this signature in database
GPG Key ID: AB3790129D478852
2 changed files with 10 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/server/coingecko.rs
View File

@ -54,12 +54,12 @@ pub async fn tickers(context: web::Data<WebContext>) -> Result<HttpResponse, Ser
let mut c1 = context.pool.acquire().await.unwrap();
let mut c2 = context.pool.acquire().await.unwrap();
let bba_fut = get_best_bids_and_asks(client, markets);
// let bba_fut = get_best_bids_and_asks(client, markets);
let volume_fut = fetch_coingecko_24h_volume(&mut c1);
let high_low_fut = fetch_coingecko_24h_high_low(&mut c2);
let ((best_bids, best_asks), volume_query, high_low_quey) =
join!(bba_fut, volume_fut, high_low_fut,);
let (volume_query, high_low_quey) =
join!(volume_fut, high_low_fut,);
let raw_volumes = match volume_query {
Ok(c) => c,
@ -79,7 +79,7 @@ pub async fn tickers(context: web::Data<WebContext>) -> Result<HttpResponse, Ser
let tickers = markets
.iter()
.enumerate()
.map(|(index, m)| {
.map(|(_index, m)| {
let name = m.name.clone();
let high_low = high_low
.iter()
@ -96,8 +96,6 @@ pub async fn tickers(context: web::Data<WebContext>) -> Result<HttpResponse, Ser
last_price: high_low.close.to_string(),
base_volume: volume.base_volume.to_string(),
target_volume: volume.target_volume.to_string(),
bid: best_bids[index].to_string(),
ask: best_asks[index].to_string(),
high: high_low.high.to_string(),
low: high_low.low.to_string(),
}

12
src/structs/coingecko.rs
View File

@ -27,8 +27,8 @@ pub struct CoinGeckoTicker {
pub last_price: String,
pub base_volume: String,
pub target_volume: String,
pub bid: String,
pub ask: String,
// pub bid: String,
// pub ask: String,
pub high: String,
pub low: String,
}
@ -41,8 +41,8 @@ pub struct PgCoinGecko24HourVolume {
impl PgCoinGecko24HourVolume {
pub fn convert_to_readable(&self, markets: &Vec<MarketInfo>) -> CoinGecko24HourVolume {
let market = markets.iter().find(|m| m.address == self.address).unwrap();
let base_volume = (self.raw_base_size / token_factor(market.base_decimals)).to_string();
let target_volume = (self.raw_quote_size / token_factor(market.quote_decimals)).to_string();
let base_volume = self.raw_base_size / token_factor(market.base_decimals);
let target_volume = self.raw_quote_size / token_factor(market.quote_decimals);
CoinGecko24HourVolume {
market_name: market.name.clone(),
base_volume,
@ -54,8 +54,8 @@ impl PgCoinGecko24HourVolume {
#[derive(Debug, Default)]
pub struct CoinGecko24HourVolume {
pub market_name: String,
pub base_volume: String,
pub target_volume: String,
pub base_volume: Decimal,
pub target_volume: Decimal,
}
#[derive(Debug, Default)]