crypto_ws_client/clients/bitget/
bitget_swap.rs

1use async_trait::async_trait;
2
3use crate::{
4    clients::common_traits::{
5        Candlestick, Level3OrderBook, OrderBook, OrderBookTopK, Ticker, Trade, BBO,
6    },
7    common::{command_translator::CommandTranslator, ws_client_internal::WSClientInternal},
8    WSClient,
9};
10
11use super::{
12    utils::{BitgetCommandTranslator, BitgetMessageHandler, UPLINK_LIMIT},
13    EXCHANGE_NAME,
14};
15
16const WEBSOCKET_URL: &str = "wss://ws.bitget.com/mix/v1/stream";
17
18/// The WebSocket client for Bitget swap markets.
19///
20/// * WebSocket API doc: <https://bitgetlimited.github.io/apidoc/en/mix/#websocketapi>
21/// * Trading at: <https://www.bitget.com/en/swap/>
22pub struct BitgetSwapWSClient {
23    client: WSClientInternal<BitgetMessageHandler>,
24    translator: BitgetCommandTranslator<'M'>,
25}
26
27impl BitgetSwapWSClient {
28    pub async fn new(tx: std::sync::mpsc::Sender<String>, url: Option<&str>) -> Self {
29        let real_url = match url {
30            Some(endpoint) => endpoint,
31            None => WEBSOCKET_URL,
32        };
33        BitgetSwapWSClient {
34            client: WSClientInternal::connect(
35                EXCHANGE_NAME,
36                real_url,
37                BitgetMessageHandler {},
38                Some(UPLINK_LIMIT),
39                tx,
40            )
41            .await,
42            translator: BitgetCommandTranslator::<'M'> {},
43        }
44    }
45}
46
47impl_trait!(Trade, BitgetSwapWSClient, subscribe_trade, "trade");
48#[rustfmt::skip]
49impl_trait!(OrderBookTopK, BitgetSwapWSClient, subscribe_orderbook_topk, "books15");
50impl_trait!(OrderBook, BitgetSwapWSClient, subscribe_orderbook, "books");
51impl_trait!(Ticker, BitgetSwapWSClient, subscribe_ticker, "ticker");
52impl_candlestick!(BitgetSwapWSClient);
53
54panic_bbo!(BitgetSwapWSClient);
55panic_l3_orderbook!(BitgetSwapWSClient);
56
57impl_ws_client_trait!(BitgetSwapWSClient);