1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
use super::super::{DataResponse, ResponseOrError};
use super::types::{OrderbookRequest, OrderbookResponse};
use crate::errors::Result;
use crate::graphql::get_orderbook;
use crate::types::OrderbookOrder;
use crate::protocol::state::State;
use std::sync::Arc;
use tokio::sync::RwLock;
use bigdecimal::BigDecimal;
use std::str::FromStr;
impl OrderbookRequest {
pub async fn response_from_graphql(
&self,
response: ResponseOrError<get_orderbook::ResponseData>, _state: Arc<RwLock<State>>
) -> Result<ResponseOrError<OrderbookResponse>> {
match response {
ResponseOrError::Response(data) => {
let response = data.data;
let book = response.get_order_book;
let mut asks = Vec::new();
let mut bids = Vec::new();
let update_id = book.update_id;
let last_update_id = book.last_update_id;
for ask in book.asks {
asks.push(OrderbookOrder {
price: ask.price.amount.to_string(),
amount: BigDecimal::from_str(&ask.amount.amount)?,
});
}
for bid in book.bids {
bids.push(OrderbookOrder {
price: bid.price.amount.to_string(),
amount: BigDecimal::from_str(&bid.amount.amount)?,
});
}
Ok(ResponseOrError::Response(DataResponse {
data: OrderbookResponse {
asks,
bids,
update_id,
last_update_id
},
}))
}
ResponseOrError::Error(error) => Ok(ResponseOrError::Error(error)),
}
}
}