okx-sdk 0.1.0

library for okx
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

use super::models::{
    AccountBalance, AccountPositions, AccountPositionsHistory, AccountSetLeverage, RestApi,
};
use crate::client::OkxClient;
use anyhow::Result;
use std::collections::BTreeMap;

impl OkxClient {
    // 查看余额
    // GET /api/v5/account/balance
    pub async fn account_balance(&self, ccy: Option<String>) -> Result<RestApi<AccountBalance>> {
        let mut params: BTreeMap<String, String> = BTreeMap::new();
        if let Some(ccy) = ccy {
            params.insert("ccy".into(), ccy.into());
        }
        Ok(self
            .get::<RestApi<AccountBalance>>("/api/v5/account/balance", &params)
            .await?)
    }

    // 检查仓位
    // GET /api/v5/account/positions
    // 查看持仓信息
    // 获取该账户下拥有实际持仓的信息。账户为单向持仓模式会显示净持仓（net），账户为双向持仓模式下会分别返回多头（long）或空头（short）的仓位。按照仓位创建时间倒序排列。
    // GET /api/v5/account/positions
    pub async fn account_positions<T>(
        &self,
        inst_type: Option<T>,
        inst_id: Option<T>,
        pos_id: Option<T>,
        // impl Into<String>
        // pos_side: impl Into<String>,
    ) -> Result<RestApi<AccountPositions>>
    where
        T: Into<String>,
    {
        let mut params: BTreeMap<String, String> = BTreeMap::new();
        if let Some(inst_type) = inst_type {
            params.insert("instType".into(), inst_type.into());
        }
        if let Some(inst_id) = inst_id {
            params.insert("instId".into(), inst_id.into());
        }
        if let Some(pos_id) = pos_id {
            params.insert("posId".into(), pos_id.into());
        }
        Ok(self
            .get::<RestApi<AccountPositions>>("/api/v5/account/positions", &params)
            .await?)
    }

    // 获取未成交订单列表
    // 获取当前账户下所有未成交订单信息
    // 设置杠杆倍数
    // POST  /api/v5/account/set-leverage
    pub async fn account_set_leverage<T>(
        &self,
        inst_id: Option<T>,
        ccy: Option<T>,
        lever: T,
        mgn_mode: T,
        pos_side: Option<T>,
    ) -> Result<RestApi<AccountSetLeverage>>
    where
        T: Into<String>,
    {
        let mut params: BTreeMap<String, String> = BTreeMap::new();
        if let Some(inst_id) = inst_id {
            params.insert("instId".into(), inst_id.into());
        }
        if let Some(ccy) = ccy {
            params.insert("ccy".into(), ccy.into());
        }
        if let Some(pos_side) = pos_side {
            params.insert("posSide".into(), pos_side.into());
        }
        params.insert("lever".into(), lever.into());
        params.insert("mgnMode".into(), mgn_mode.into());
        Ok(self
            .post::<RestApi<AccountSetLeverage>>("/api/v5/account/set-leverage", &params)
            .await?)
    }

    // 查看历史持仓信息
    // 获取最近3个月有更新的仓位信息，按照仓位更新时间倒序排列。
    // GET /api/v5/account/positions-history
    pub async fn account_positions_history<T>(
        &self,
        inst_type: Option<T>,
        inst_id: Option<T>,
        mgn_mode: Option<T>,
        ptype: Option<T>,
        pos_id: Option<T>,
        after: Option<T>,
        before: Option<T>,
        limit: Option<T>,
        // impl Into<String>
        // pos_side: impl Into<String>,
    ) -> Result<RestApi<AccountPositionsHistory>>
    where
        T: Into<String>,
    {
        let mut params: BTreeMap<String, String> = BTreeMap::new();
        if let Some(inst_type) = inst_type {
            params.insert("instType".into(), inst_type.into());
        }
        if let Some(inst_id) = inst_id {
            params.insert("instId".into(), inst_id.into());
        }
        if let Some(mgn_mode) = mgn_mode {
            params.insert("mgnMode".into(), mgn_mode.into());
        }
        if let Some(ptype) = ptype {
            params.insert("type".into(), ptype.into());
        }
        if let Some(pos_id) = pos_id {
            params.insert("posId".into(), pos_id.into());
        }
        if let Some(after) = after {
            params.insert("after".into(), after.into());
        }
        if let Some(before) = before {
            params.insert("before".into(), before.into());
        }
        if let Some(limit) = limit {
            params.insert("limit".into(), limit.into());
        }
        Ok(self
            .get::<RestApi<AccountPositionsHistory>>("/api/v5/account/positions-history", &params)
            .await?)
    }
}