forked from AwolDes/goanda
-
Notifications
You must be signed in to change notification settings - Fork 0
/
trades.go
154 lines (138 loc) · 5.11 KB
/
trades.go
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
package goanda
// Supporting OANDA docs - http://developer.oanda.com/rest-live-v20/trade-ep/
import (
"encoding/json"
"time"
)
type ReceivedTrades struct {
LastTransactionID string `json:"lastTransactionID"`
Trades []struct {
CurrentUnits string `json:"currentUnits"`
Financing string `json:"financing"`
ID string `json:"id"`
InitialUnits string `json:"initialUnits"`
Instrument string `json:"instrument"`
OpenTime time.Time `json:"openTime"`
Price string `json:"price"`
RealizedPL string `json:"realizedPL"`
State string `json:"state"`
UnrealizedPL string `json:"unrealizedPL"`
} `json:"trades"`
}
type ReceivedTrade struct {
LastTransactionID string `json:"lastTransactionID"`
Trades struct {
CurrentUnits string `json:"currentUnits"`
Financing string `json:"financing"`
ID string `json:"id"`
InitialUnits string `json:"initialUnits"`
Instrument string `json:"instrument"`
OpenTime time.Time `json:"openTime"`
Price string `json:"price"`
RealizedPL string `json:"realizedPL"`
State string `json:"state"`
UnrealizedPL string `json:"unrealizedPL"`
} `json:"trade"`
}
type CloseTradePayload struct {
Units string
}
type ModifiedTrade struct {
OrderCreateTransaction struct {
Type string `json:"type"`
Instrument string `json:"instrument"`
Units string `json:"units"`
TimeInForce string `json:"timeInForce"`
PositionFill string `json:"positionFill"`
Reason string `json:"reason"`
TradeClose struct {
Units string `json:"units"`
TradeID string `json:"tradeID"`
} `json:"tradeClose"`
ID string `json:"id"`
UserID int `json:"userID"`
AccountID string `json:"accountID"`
BatchID string `json:"batchID"`
RequestID string `json:"requestID"`
Time time.Time `json:"time"`
} `json:"orderCreateTransaction"`
OrderFillTransaction struct {
Type string `json:"type"`
Instrument string `json:"instrument"`
Units string `json:"units"`
Price string `json:"price"`
FullPrice string `json:"fullPrice"`
PL string `json:"pl"`
Financing string `json:"financing"`
Commission string `json:"commission"`
AccountBalance string `json:"accountBalance"`
TradeOpened string `json:"tradeOpened"`
TimeInForce string `json:"timeInForce"`
PositionFill string `json:"positionFill"`
Reason string `json:"reason"`
TradesClosed []struct {
TradeID string `json:"tradeID"`
Units string `json:"units"`
RealizedPL string `json:"realizedPL"`
Financing string `json:"financing"`
} `json:"tradesClosed"`
TradeReduced struct {
TradeID string `json:"tradeID"`
Units string `json:"units"`
RealizedPL string `json:"realizedPL"`
Financing string `json:"financing"`
} `json:"tradeReduced"`
ID string `json:"id"`
UserID int `json:"userID"`
AccountID string `json:"accountID"`
BatchID string `json:"batchID"`
RequestID string `json:"requestID"`
OrderID string `json:"orderId"`
ClientOrderID string `json:"clientOrderId"`
Time time.Time `json:"time"`
} `json:"orderFillTransaction"`
OrderCancelTransaction struct {
Type string `json:"type"`
OrderID string `json:"orderID"`
Reason string `json:"reason"`
ID string `json:"id"`
UserID int `json:"userID"`
AccountID string `json:"accountID"`
BatchID string `json:"batchID"`
RequestID string `json:"requestID"`
Time time.Time `json:"time"`
} `json:"orderCancelTransaction"`
RelatedTransactionIDs []string `json:"relatedTransactionIDs"`
LastTransactionID string `json:"lastTransactionID"`
}
func (c *OandaConnection) GetTradesForInstrument(instrument string) (ReceivedTrades, error, error) {
endpoint := "v3/accounts/" + c.AccountID + "/trades" + "?instrument=" + instrument
response, err1, err2 := c.Request(endpoint)
data := ReceivedTrades{}
_ = unmarshalJson(response, &data)
return data, err1, err2
}
func (c *OandaConnection) GetOpenTrades() (ReceivedTrades, error, error) {
endpoint := "v3/accounts/" + c.AccountID + "/openTrades"
response, err1, err2 := c.Request(endpoint)
data := ReceivedTrades{}
_ = unmarshalJson(response, &data)
return data, err1, err2
}
func (c *OandaConnection) GetTrade(ticket string) (ReceivedTrade, error, error) {
endpoint := "v3/accounts/" + c.AccountID + "/trades" + "/" + ticket
response, err1, err2 := c.Request(endpoint)
data := ReceivedTrade{}
_ = unmarshalJson(response, &data)
return data, err1, err2
}
// Default is close the whole position using the string "ALL" in body.units
func (c *OandaConnection) ReduceTradeSize(ticket string, body CloseTradePayload) (ModifiedTrade, error, error) {
endpoint := "v3/accounts/" + c.AccountID + "/trades/" + ticket
jsonBody, _ := json.Marshal(body)
//checkErr(err)
response, err1, err2 := c.Update(endpoint, jsonBody)
data := ModifiedTrade{}
_ = unmarshalJson(response, &data)
return data, err1, err2
}