barter_data/exchange/bitmex/
market.rs

1use crate::{
2    Identifier, exchange::bitmex::Bitmex, instrument::MarketInstrumentData,
3    subscription::Subscription,
4};
5use barter_instrument::{
6    Keyed, asset::name::AssetNameInternal, instrument::market_data::MarketDataInstrument,
7};
8use serde::{Deserialize, Serialize};
9use smol_str::{SmolStr, StrExt, format_smolstr};
10
11/// Type that defines how to translate a Barter [`Subscription`] into a [`Bitmex`]
12/// market that can be subscribed to.
13///
14/// See docs: <https://www.bitmex.com/app/wsAPI>
15#[derive(Clone, Eq, PartialEq, Ord, PartialOrd, Hash, Debug, Deserialize, Serialize)]
16pub struct BitmexMarket(pub SmolStr);
17
18impl<Kind> Identifier<BitmexMarket> for Subscription<Bitmex, MarketDataInstrument, Kind> {
19    fn id(&self) -> BitmexMarket {
20        bitmex_market(&self.instrument.base, &self.instrument.quote)
21    }
22}
23
24impl<InstrumentKey, Kind> Identifier<BitmexMarket>
25    for Subscription<Bitmex, Keyed<InstrumentKey, MarketDataInstrument>, Kind>
26{
27    fn id(&self) -> BitmexMarket {
28        bitmex_market(&self.instrument.value.base, &self.instrument.value.quote)
29    }
30}
31
32impl<InstrumentKey, Kind> Identifier<BitmexMarket>
33    for Subscription<Bitmex, MarketInstrumentData<InstrumentKey>, Kind>
34{
35    fn id(&self) -> BitmexMarket {
36        BitmexMarket(self.instrument.name_exchange.name().clone())
37    }
38}
39
40impl AsRef<str> for BitmexMarket {
41    fn as_ref(&self) -> &str {
42        &self.0
43    }
44}
45
46fn bitmex_market(base: &AssetNameInternal, quote: &AssetNameInternal) -> BitmexMarket {
47    // Notes:
48    // - Must be uppercase since Bitmex sends message with uppercase MARKET (eg/ XBTUSD).
49    BitmexMarket(format_smolstr!("{base}{quote}").to_uppercase_smolstr())
50}
barter_data/exchange/bitmex/market.rs

barter_data/exchange/bitmex/
market.rs
