rsgmo 0.2.2

GMOコインのRust用APIライブラリ.
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

use crate::{
    v1::ws::{GmoWs, Channel, CommandType},
    connect::Connect,
    utils,
};

use anyhow::Result;
use serde::{Deserialize, Serialize};

impl GmoWs {
    pub async fn connect_execution_events(&self, parameters: ConnectExecutionEventsParameters) -> Result<()> {
        self.execute(parameters).await
    }
}


#[derive(Debug, Clone, Serialize)]
pub struct ConnectExecutionEventsParameters {
    command: CommandType,
    channel: Channel,
}

impl ConnectExecutionEventsParameters {
    pub fn new(command: CommandType) -> Self {
        Self {
            command,
            channel: Channel::ExecutionEvents,
        }
    }
}

#[derive(Debug, Clone, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct ConnectExecutionEventsResponse {
    channel: String,
    order_id: i64,
    execution_id: i64,
    symbol: String,
    settle_type: String,
    execution_type: String,
    side: String,
    #[serde(deserialize_with = "utils::deserialize_f64")]
    execution_price: f64,
    #[serde(deserialize_with = "utils::deserialize_f64")]
    execution_size: f64,
    position_id: Option<i64>,
    order_timestamp: String,
    execution_timestamp: String,
    #[serde(deserialize_with = "utils::deserialize_f64")]
    loss_gain: f64,
    #[serde(deserialize_with = "utils::deserialize_f64")]
    fee: f64,
    #[serde(deserialize_with = "utils::deserialize_f64")]
    order_price: f64,
    #[serde(deserialize_with = "utils::deserialize_f64")]
    order_size: f64,
    #[serde(deserialize_with = "utils::deserialize_f64")]
    order_executed_size: f64,
    time_in_force: String,
    msg_type: String,
}

impl ConnectExecutionEventsResponse {
    pub fn channel(&self) -> &str {
        &self.channel
    }
    pub fn order_id(&self) -> i64 {
        self.order_id
    }
    pub fn execution_id(&self) -> i64 {
        self.execution_id
    }
    pub fn symbol(&self) -> &str {
        &self.symbol
    }
    pub fn settle_type(&self) -> &str {
        &self.settle_type
    }
    pub fn execution_type(&self) -> &str {
        &self.execution_type
    }
    pub fn side(&self) -> &str {
        &self.side
    }
    pub fn execution_price(&self) -> f64 {
        self.execution_price
    }
    pub fn execution_size(&self) -> f64 {
        self.execution_size
    }
    pub fn position_id(&self) -> Option<i64> {
        self.position_id
    }
    pub fn order_timestamp(&self) -> &str {
        &self.order_timestamp
    }
    pub fn execution_timestamp(&self) -> &str {
        &self.execution_timestamp
    }
    pub fn loss_gain(&self) -> f64 {
        self.loss_gain
    }
    pub fn fee(&self) -> f64 {
        self.fee
    }
    pub fn order_price(&self) -> f64 {
        self.order_price
    }
    pub fn order_size(&self) -> f64 {
        self.order_size
    }
    pub fn order_executed_size(&self) -> f64 {
        self.order_executed_size
    }
    pub fn time_in_force(&self) -> &str {
        &self.time_in_force
    }
    pub fn msg_type(&self) -> &str {
        &self.msg_type
    }
}