forked from bitfinexcom/bitfinex-api-go
/
candles.go
108 lines (90 loc) · 2.87 KB
/
candles.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
package rest
import (
"fmt"
"net/url"
"path"
"strconv"
"strings"
"github.com/laikasinjason/bitfinex-api-go/pkg/convert"
"github.com/laikasinjason/bitfinex-api-go/pkg/models/candle"
"github.com/laikasinjason/bitfinex-api-go/pkg/models/common"
)
// CandleService manages the Candles endpoint.
type CandleService struct {
Synchronous
}
func getPathSegments(symbol string, resolution common.CandleResolution) (s string, err error) {
if len(symbol) == 0 {
err = fmt.Errorf("symbol cannot be empty")
return
}
segments := []string{"trade", string(resolution), symbol}
s = strings.Join(segments, ":")
return
}
// Last - retrieve the last candle for the given symbol with the given resolution
// See https://docs.bitfinex.com/reference#rest-public-candles for more info
func (c *CandleService) Last(symbol string, resolution common.CandleResolution) (*candle.Candle, error) {
segments, err := getPathSegments(symbol, resolution)
if err != nil {
return nil, err
}
req := NewRequestWithMethod(path.Join("candles", segments, "LAST"), "GET")
raw, err := c.Request(req)
if err != nil {
return nil, err
}
cs, err := candle.FromRaw(symbol, resolution, raw)
if err != nil {
return nil, err
}
return cs, nil
}
// History - retrieves all candles (Max=1000) with the given symbol and the given candle resolution
// See https://docs.bitfinex.com/reference#rest-public-candles for more info
func (c *CandleService) History(symbol string, resolution common.CandleResolution) (*candle.Snapshot, error) {
segments, err := getPathSegments(symbol, resolution)
if err != nil {
return nil, err
}
req := NewRequestWithMethod(path.Join("candles", segments, "HIST"), "GET")
raw, err := c.Request(req)
if err != nil {
return nil, err
}
cs, err := candle.SnapshotFromRaw(symbol, resolution, convert.ToInterfaceArray(raw))
if err != nil {
return nil, err
}
return cs, nil
}
// HistoryWithQuery - retrieves all candles (Max=1000) that fit the given query criteria
// See https://docs.bitfinex.com/reference#rest-public-candles for more info
func (c *CandleService) HistoryWithQuery(
symbol string,
resolution common.CandleResolution,
start common.Mts,
end common.Mts,
limit common.QueryLimit,
sort common.SortOrder,
) (*candle.Snapshot, error) {
segments, err := getPathSegments(symbol, resolution)
if err != nil {
return nil, err
}
req := NewRequestWithMethod(path.Join("candles", segments, "HIST"), "GET")
req.Params = make(url.Values)
req.Params.Add("end", strconv.FormatInt(int64(end), 10))
req.Params.Add("start", strconv.FormatInt(int64(start), 10))
req.Params.Add("limit", strconv.FormatInt(int64(limit), 10))
req.Params.Add("sort", strconv.FormatInt(int64(sort), 10))
raw, err := c.Request(req)
if err != nil {
return nil, err
}
cs, err := candle.SnapshotFromRaw(symbol, resolution, convert.ToInterfaceArray(raw))
if err != nil {
return nil, err
}
return cs, nil
}