-
Notifications
You must be signed in to change notification settings - Fork 2
/
funds_candles.go
295 lines (272 loc) · 11.5 KB
/
funds_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
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
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
// Package client includes types and methods to access the Funds / Candles endpoint. Retrieve historical price candles for any supported stock symbol.
//
// # Making Requests
//
// Use [FundCandlesRequest] to make requests to the endpoint using any of the three supported execution methods:
//
// | Method | Execution | Return Type | Description |
// |------------|---------------|-----------------------------|------------------------------------------------------------------------------------------------------------|
// | **Get** | Direct | `[]Candle` | Directly returns a slice of `[]Candle`, facilitating individual access to each candle. |
// | **Packed** | Intermediate | `*FundCandlesResponse` | Returns a packed `*FundCandlesResponse` object. Must be unpacked to access the `[]Candle` slice. |
// | **Raw** | Low-level | `*resty.Response` | Provides the raw `*resty.Response` for maximum flexibility. Direct access to raw JSON or `*http.Response`. |
package client
import (
"context"
"fmt"
"github.com/MarketDataApp/sdk-go/helpers/parameters"
"github.com/MarketDataApp/sdk-go/models"
"github.com/go-resty/resty/v2"
)
// FundCandlesRequest represents a request to the [/v1/funds/candles/] endpoint.
// It encapsulates parameters for resolution, symbol, date, and additional stock-specific parameters to be used in the request.
// This struct provides methods such as Resolution(), Symbol(), Date(), From(), To(), Countback(), AdjustSplits(), AdjustDividends(), Extended(), and Exchange() to set these parameters respectively.
//
// # Generated By
//
// - FundCandles() *FundCandlesRequest: FundCandles creates a new *FundCandlesRequest and returns a pointer to the request allowing for method chaining.
//
// # Setter Methods
//
// - Resolution(string) *FundCandlesRequest: Sets the resolution parameter for the request.
// - Symbol(string) *FundCandlesRequest: Sets the symbol parameter for the request.
// - Date(interface{}) *FundCandlesRequest: Sets the date parameter for the request.
// - From(interface{}) *FundCandlesRequest: Sets the 'from' date parameter for the request.
// - To(interface{}) *FundCandlesRequest: Sets the 'to' date parameter for the request.
// - Countback(int) *FundCandlesRequest: Sets the countback parameter for the request.
// - AdjustSplits(bool) *FundCandlesRequest: Sets the adjust splits parameter for the request.
// - AdjustDividends(bool) *FundCandlesRequest: Sets the adjust dividends parameter for the request.
// - Extended(bool) *FundCandlesRequest: Sets the extended hours data parameter for the request.
// - Exchange(string) *FundCandlesRequest: Sets the exchange parameter for the request.
//
// # Execution Methods
//
// These methods are used to send the request in different formats or retrieve the data.
// They handle the actual communication with the API endpoint.
//
// - Get() ([]Candle, error): Sends the request, unpacks the response, and returns the data in a user-friendly format.
// - Packed() (*FundCandlesResponse, error): Returns a struct that contains equal-length slices of primitives. This packed response mirrors Market Data's JSON response.
// - Raw() (*resty.Response, error): Sends the request as is and returns the raw HTTP response.
//
// [/v1/funds/candles/]: https://www.marketdata.app/docs/api/funds/candles
type FundCandlesRequest struct {
*baseRequest
stockCandleParams *parameters.StockCandleParams
resolutionParams *parameters.ResolutionParams
symbolParams *parameters.SymbolParams
dateParams *parameters.DateParams
}
// Resolution sets the resolution parameter for the FundCandlesRequest.
// This method is used to specify the granularity of the candle data to be retrieved.
//
// # Parameters
//
// - string: A string representing the resolution to be set.
//
// # Returns
//
// - *FundCandlesRequest: This method returns a pointer to the *FundCandlesRequest instance it was called on. This allows for method chaining.
func (cr *FundCandlesRequest) Resolution(q string) *FundCandlesRequest {
if cr == nil {
return nil
}
err := cr.resolutionParams.SetResolution(q)
if err != nil {
cr.Error = err
}
return cr
}
// Symbol sets the symbol parameter for the FundCandlesRequest.
// This method is used to specify the stock symbol for which candle data is requested.
//
// # Parameters
//
// - string: A string representing the stock symbol to be set.
//
// # Returns
//
// - *FundCandlesRequest: This method returns a pointer to the *FundCandlesRequest instance it was called on. This allows for method chaining.
func (fcr *FundCandlesRequest) Symbol(q string) *FundCandlesRequest {
if fcr == nil {
return nil
}
err := fcr.symbolParams.SetSymbol(q)
if err != nil {
fcr.Error = err
}
return fcr
}
// Date sets the date parameter for the FundCandlesRequest.
// This method is used to specify the date for which the stock candle data is requested.
//
// # Parameters
//
// - interface{}: An interface{} representing the date to be set. It can be a string, a time.Time object, a Unix timestamp as an int, or any other type that the underlying dates package method can process.
//
// # Returns
//
// - *FundCandlesRequest: This method returns a pointer to the *FundCandlesRequest instance it was called on. This allows for method chaining.
func (fcr *FundCandlesRequest) Date(q interface{}) *FundCandlesRequest {
err := fcr.dateParams.SetDate(q)
if err != nil {
fcr.baseRequest.Error = err
}
return fcr
}
// From sets the 'from' date parameter for the FundCandlesRequest.
// This method is used to specify the starting point of the date range for which the stock candle data is requested.
//
// # Parameters
//
// - interface{}: An interface{} representing the date to be set. It can be a string, a time.Time object, a Unix timestamp as an int, or any other type that the underlying dates package method can process.
//
// # Returns
//
// - *FundCandlesRequest: This method returns a pointer to the *FundCandlesRequest instance it was called on. This allows for method chaining.
func (fcr *FundCandlesRequest) From(q interface{}) *FundCandlesRequest {
err := fcr.dateParams.SetFrom(q)
if err != nil {
fcr.baseRequest.Error = err
}
return fcr
}
// To sets the 'to' date parameter for the FundCandlesRequest.
// This method is used to specify the ending point of the date range for which the stock candle data is requested.
//
// # Parameters
//
// - interface{}: An interface{} representing the date to be set. It can be a string, a time.Time object, a Unix timestamp as an int, or any other type that the underlying dates package method can process.
//
// # Returns
//
// - *FundCandlesRequest: This method returns a pointer to the *FundCandlesRequest instance it was called on
func (fcr *FundCandlesRequest) To(q interface{}) *FundCandlesRequest {
err := fcr.dateParams.SetTo(q)
if err != nil {
fcr.baseRequest.Error = err
}
return fcr
}
// Countback sets the countback parameter for the FundCandlesRequest.
// This method specifies the number of candles to return, counting backwards from the 'to' date.
//
// # Parameters
//
// - int: The number of candles to return.
//
// # Returns
//
// - *FundCandlesRequest: This method returns a pointer to the *FundCandlesRequest instance it was called on. This allows for method chaining.
func (fcr *FundCandlesRequest) Countback(q int) *FundCandlesRequest {
err := fcr.dateParams.SetCountback(q)
if err != nil {
fcr.baseRequest.Error = err
}
return fcr
}
// AdjustSplits sets the adjust splits parameter for the FundCandlesRequest.
// This method indicates whether the returned data should be adjusted for stock splits.
//
// # Parameters
//
// - bool: Whether to adjust for splits.
//
// # Returns
//
// - *FundCandlesRequest: This method returns a pointer to the *FundCandlesRequest instance it was called on. This allows for method chaining.
func (fcr *FundCandlesRequest) AdjustSplits(q bool) *FundCandlesRequest {
if fcr == nil {
return nil
}
fcr.stockCandleParams.SetAdjustSplits(q)
return fcr
}
// getParams packs the CandlesRequest struct into a slice of interface{} and returns it.
func (fcr *FundCandlesRequest) getParams() ([]parameters.MarketDataParam, error) {
if fcr == nil {
return nil, fmt.Errorf("FundCandlesRequest is nil")
}
params := []parameters.MarketDataParam{fcr.dateParams, fcr.symbolParams, fcr.resolutionParams}
return params, nil
}
// Raw executes the FundCandlesRequest with the provided context and returns the raw *resty.Response.
// This method returns the raw JSON or *http.Response for further processing without accepting an alternative MarketDataClient.
//
// # Parameters
//
// - ctx context.Context: The context to use for the request execution.
//
// # Returns
//
// - *resty.Response: The raw HTTP response from the executed request.
// - error: An error object if the request fails due to execution errors.
func (fcr *FundCandlesRequest) Raw(ctx context.Context) (*resty.Response, error) {
return fcr.baseRequest.Raw(ctx)
}
// Packed sends the FundCandlesRequest with the provided context and returns the FundCandlesResponse.
//
// # Parameters
//
// - ctx context.Context: The context to use for the request execution.
//
// # Returns
//
// - *FundCandlesResponse: A pointer to the FundCandlesResponse obtained from the request.
// - error: An error object that indicates a failure in sending the request.
func (fcr *FundCandlesRequest) Packed(ctx context.Context) (*models.FundCandlesResponse, error) {
if fcr == nil {
return nil, fmt.Errorf("FundCandlesRequest is nil")
}
var fcrResp models.FundCandlesResponse
_, err := fcr.baseRequest.client.getFromRequest(ctx, fcr.baseRequest, &fcrResp)
if err != nil {
return nil, err
}
return &fcrResp, nil
}
// Get sends the FundCandlesRequest with the provided context, unpacks the FundCandlesResponse, and returns a slice of StockCandle.
// It returns an error if the request or unpacking fails.
//
// # Parameters
//
// - ctx context.Context: The context to use for the request execution.
//
// # Returns
//
// - []Candle: A slice of []Candle containing the unpacked candle data from the response.
// - error: An error object that indicates a failure in sending the request or unpacking the response.
func (fcr *FundCandlesRequest) Get(ctx context.Context) ([]models.Candle, error) {
if fcr == nil {
return nil, fmt.Errorf("FundCandlesRequest is nil")
}
// Use the Packed method to make the request
fcrResp, err := fcr.Packed(ctx)
if err != nil {
return nil, err
}
// Unpack the data using the Unpack method in the response
data, err := fcrResp.Unpack()
if err != nil {
return nil, err
}
return data, nil
}
// FundCandles initializes a new FundCandlesRequest with default parameters.
// This function prepares a request to fetch stock candle data. It sets up all necessary parameters
// and configurations to make the request ready to be sent.
//
// # Returns
//
// - *FundCandlesRequest: A pointer to the newly created FundCandlesRequest instance. This instance contains all the necessary parameters set to their default values and is ready to have additional parameters set or to be sent.
func FundCandles() *FundCandlesRequest {
baseReq := newBaseRequest()
baseReq.path = endpoints[1]["funds"]["candles"]
fcr := &FundCandlesRequest{
baseRequest: baseReq,
dateParams: ¶meters.DateParams{},
resolutionParams: ¶meters.ResolutionParams{},
symbolParams: ¶meters.SymbolParams{},
}
// Set the date to the current time
baseReq.child = fcr
return fcr
}