bybit_rs 0.1.7

Fork of the Official Python3 API connector for Bybit's HTTP (bybit) and WebSockets APIs to rust
Documentation 
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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158

#![allow(unused)]
use async_trait::async_trait;
use std::sync::Arc;
use std::{
    collections::{BTreeMap, HashMap},
    pin::Pin,
};

use futures::Future;
use reqwest::Method;
use serde_json::Value;

use crate::endpoints::v5spot_leverage_token;

use super::http_manager::{HttpManager, Manager};
#[async_trait]
pub trait SpotLeverageTokenTrade {
    fn new(http_manager: Arc<HttpManager>) -> Self;
    async fn get_leveraged_token_info(
        &self,
        query: HashMap<String, String>,
    ) -> Result<Value, Box<dyn std::error::Error + Send + Sync + 'static>>;

    async fn get_leveraged_token_market(
        &self,
        query: HashMap<String, String>,
    ) -> Result<Value, Box<dyn std::error::Error + Send + Sync + 'static>>;

    async fn purchase_leveraged_token(
        &self,
        query: HashMap<String, String>,
    ) -> Result<Value, Box<dyn std::error::Error + Send + Sync + 'static>>;

    async fn redeem_leveraged_token(
        &self,
        query: HashMap<String, String>,
    ) -> Result<Value, Box<dyn std::error::Error + Send + Sync + 'static>>;

    async fn get_purchase_redemption_records(
        &self,
        query: HashMap<String, String>,
    ) -> Result<Value, Box<dyn std::error::Error + Send + Sync + 'static>>;
}

pub struct SpotLeverageTokenTradeHTTP {
    http_manager: Arc<HttpManager>,
}
#[async_trait]
impl SpotLeverageTokenTrade for SpotLeverageTokenTradeHTTP {
    ///
    ///
    ///// Initialize the SpotLeverageTokenHTTP by passing the Arc<HttpManager>
    ///
    ///
    fn new(http_manager: Arc<HttpManager>) -> Self {
        SpotLeverageTokenTradeHTTP { http_manager }
    }

    /// Query leverage token information

    ///     Returns:
    ///         Request results as HashMap.

    ///     Additional information:
    ///         https://bybit-exchange.github.io/docs/v5/lt/leverage-token-info
    async fn get_leveraged_token_info(
        &self,
        query: HashMap<String, String>,
    ) -> Result<Value, Box<dyn std::error::Error + Send + Sync + 'static>> {
        let endpoint = v5spot_leverage_token::SpotLeverageToken::GetLeveragedTokenInfo.to_string();
        self.http_manager
            .submit_request(Method::GET, &endpoint, query, true)
            .await
    }

    /// Get leverage token market information

    ///     Required args:
    ///         ltCoin (string): Abbreviation of the LT, such as BTC3L

    ///     Returns:
    ///         Request results as HashMap.

    ///     Additional information:
    ///         https://bybit-exchange.github.io/docs/v5/lt/leverage-token-reference
    async fn get_leveraged_token_market(
        &self,
        query: HashMap<String, String>,
    ) -> Result<Value, Box<dyn std::error::Error + Send + Sync + 'static>> {
        let endpoint =
            v5spot_leverage_token::SpotLeverageToken::GetLeveragedTokenMarket.to_string();
        self.http_manager
            .submit_request(Method::GET, &endpoint, query, true)
            .await
    }

    /// Purchase levearge token

    ///     Required args:
    ///         ltCoin (string): Abbreviation of the LT, such as BTC3L
    ///         ltAmount (string): Purchase amount

    ///     Returns:
    ///         Request results as HashMap.

    ///     Additional information:
    ///         https://bybit-exchange.github.io/docs/v5/lt/purchase
    async fn purchase_leveraged_token(
        &self,
        query: HashMap<String, String>,
    ) -> Result<Value, Box<dyn std::error::Error + Send + Sync + 'static>> {
        let endpoint = v5spot_leverage_token::SpotLeverageToken::Purchase.to_string();
        self.http_manager
            .submit_post_request(Method::POST, &endpoint, true, query)
            .await
    }

    /// Redeem leverage token

    ///     Required args:
    ///         ltCoin (string): Abbreviation of the LT, such as BTC3L
    ///         quantity (string): Redeem quantity of LT

    ///     Returns:
    ///         Request results as HashMap.

    ///     Additional information:
    ///         https://bybit-exchange.github.io/docs/v5/lt/redeem
    async fn redeem_leveraged_token(
        &self,
        query: HashMap<String, String>,
    ) -> Result<Value, Box<dyn std::error::Error + Send + Sync + 'static>> {
        let endpoint = v5spot_leverage_token::SpotLeverageToken::Redeem.to_string();
        self.http_manager
            .submit_post_request(Method::POST, &endpoint, true, query)
            .await
    }

    /// Get purchase or redeem history

    ///     Required args:

    ///     Returns:
    ///         Request results as HashMap.

    ///     Additional information:
    ///         https://bybit-exchange.github.io/docs/v5/lt/order-record
    async fn get_purchase_redemption_records(
        &self,
        query: HashMap<String, String>,
    ) -> Result<Value, Box<dyn std::error::Error + Send + Sync + 'static>> {
        let endpoint =
            v5spot_leverage_token::SpotLeverageToken::GetPurchaseRedemptionRecords.to_string();
        self.http_manager
            .submit_request(Method::GET, &endpoint, query, true)
            .await
    }
}