lychiyu/bbgo_origin
1
0
Fork 0
mirror of https://github.com/c9s/bbgo.git synced 2024-11-26 00:35:15 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

pkg/exchange: rename v2Client -> v2client

Browse Source
This commit is contained in:
Edwin 2023-11-14 20:42:11 +08:00
parent 53bce6d5c1
commit 562f85af75
1 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
pkg/exchange/bitget/exchange.go
View File

@ -58,7 +58,7 @@ type Exchange struct {
key, secret, passphrase string key, secret, passphrase string
client *bitgetapi.RestClient client *bitgetapi.RestClient
v2Client *v2.Client v2client *v2.Client
} }
func New(key, secret, passphrase string) *Exchange { func New(key, secret, passphrase string) *Exchange {
@ -73,7 +73,7 @@ func New(key, secret, passphrase string) *Exchange {
secret: secret, secret: secret,
passphrase: passphrase, passphrase: passphrase,
client: client, client: client,
v2Client: v2.NewClient(client), v2client: v2.NewClient(client),
} }
} }
@ -94,7 +94,7 @@ func (e *Exchange) QueryMarkets(ctx context.Context) (types.MarketMap, error) {
return nil, fmt.Errorf("markets rate limiter wait error: %w", err) return nil, fmt.Errorf("markets rate limiter wait error: %w", err)
} }
req := e.v2Client.NewGetSymbolsRequest() req := e.v2client.NewGetSymbolsRequest()
symbols, err := req.Do(ctx) symbols, err := req.Do(ctx)
if err != nil { if err != nil {
return nil, err return nil, err
@ -113,7 +113,7 @@ func (e *Exchange) QueryTicker(ctx context.Context, symbol string) (*types.Ticke
return nil, fmt.Errorf("ticker rate limiter wait error: %w", err) return nil, fmt.Errorf("ticker rate limiter wait error: %w", err)
} }
req := e.v2Client.NewGetTickersRequest() req := e.v2client.NewGetTickersRequest()
req.Symbol(symbol) req.Symbol(symbol)
resp, err := req.Do(ctx) resp, err := req.Do(ctx)
if err != nil { if err != nil {
@ -146,7 +146,7 @@ func (e *Exchange) QueryTickers(ctx context.Context, symbols ...string) (map[str
return nil, fmt.Errorf("tickers rate limiter wait error: %w", err) return nil, fmt.Errorf("tickers rate limiter wait error: %w", err)
} }
resp, err := e.v2Client.NewGetTickersRequest().Do(ctx) resp, err := e.v2client.NewGetTickersRequest().Do(ctx)
if err != nil { if err != nil {
return nil, fmt.Errorf("failed to query tickers: %w", err) return nil, fmt.Errorf("failed to query tickers: %w", err)
} }
@ -167,7 +167,7 @@ func (e *Exchange) QueryTickers(ctx context.Context, symbols ...string) (map[str
// The end time has different limits. 1m, 5m can query for one month,15m can query for 52 days,30m can query for 62 days, // The end time has different limits. 1m, 5m can query for one month,15m can query for 52 days,30m can query for 62 days,
// 1H can query for 83 days,4H can query for 240 days,6H can query for 360 days. // 1H can query for 83 days,4H can query for 240 days,6H can query for 360 days.
func (e *Exchange) QueryKLines(ctx context.Context, symbol string, interval types.Interval, options types.KLineQueryOptions) ([]types.KLine, error) { func (e *Exchange) QueryKLines(ctx context.Context, symbol string, interval types.Interval, options types.KLineQueryOptions) ([]types.KLine, error) {
req := e.v2Client.NewGetKLineRequest().Symbol(symbol) req := e.v2client.NewGetKLineRequest().Symbol(symbol)
intervalStr, found := toLocalGranularity[interval] intervalStr, found := toLocalGranularity[interval]
if !found { if !found {
return nil, fmt.Errorf("%s not supported, supported granlarity: %+v", intervalStr, toLocalGranularity) return nil, fmt.Errorf("%s not supported, supported granlarity: %+v", intervalStr, toLocalGranularity)
@ -255,7 +255,7 @@ func (e *Exchange) SubmitOrder(ctx context.Context, order types.SubmitOrder) (cr
return nil, fmt.Errorf("order.Market.Symbol is required: %+v", order) return nil, fmt.Errorf("order.Market.Symbol is required: %+v", order)
} }
req := e.v2Client.NewPlaceOrderRequest() req := e.v2client.NewPlaceOrderRequest()
req.Symbol(order.Market.Symbol) req.Symbol(order.Market.Symbol)
// set order type // set order type
@ -323,7 +323,7 @@ func (e *Exchange) SubmitOrder(ctx context.Context, order types.SubmitOrder) (cr
} }
orderId := res.OrderId orderId := res.OrderId
ordersResp, err := e.v2Client.NewGetUnfilledOrdersRequest().OrderId(orderId).Do(ctx) ordersResp, err := e.v2client.NewGetUnfilledOrdersRequest().OrderId(orderId).Do(ctx)
if err != nil { if err != nil {
return nil, fmt.Errorf("failed to query open order by order id: %s, err: %w", orderId, err) return nil, fmt.Errorf("failed to query open order by order id: %s, err: %w", orderId, err)
} }
@ -332,7 +332,7 @@ func (e *Exchange) SubmitOrder(ctx context.Context, order types.SubmitOrder) (cr
case 0: case 0:
// The market order will be executed immediately, so we cannot retrieve it through the NewGetUnfilledOrdersRequest API. // The market order will be executed immediately, so we cannot retrieve it through the NewGetUnfilledOrdersRequest API.
// Try to get the order from the NewGetHistoryOrdersRequest API. // Try to get the order from the NewGetHistoryOrdersRequest API.
ordersResp, err := e.v2Client.NewGetHistoryOrdersRequest().OrderId(orderId).Do(ctx) ordersResp, err := e.v2client.NewGetHistoryOrdersRequest().OrderId(orderId).Do(ctx)
if err != nil { if err != nil {
return nil, fmt.Errorf("failed to query history order by order id: %s, err: %w", orderId, err) return nil, fmt.Errorf("failed to query history order by order id: %s, err: %w", orderId, err)
} }
@ -358,7 +358,7 @@ func (e *Exchange) QueryOpenOrders(ctx context.Context, symbol string) (orders [
return nil, fmt.Errorf("open order rate limiter wait error: %w", err) return nil, fmt.Errorf("open order rate limiter wait error: %w", err)
} }
req := e.v2Client.NewGetUnfilledOrdersRequest(). req := e.v2client.NewGetUnfilledOrdersRequest().
Symbol(symbol). Symbol(symbol).
Limit(strconv.FormatInt(queryLimit, 10)) Limit(strconv.FormatInt(queryLimit, 10))
if nextCursor != 0 { if nextCursor != 0 {
@ -417,7 +417,7 @@ func (e *Exchange) QueryClosedOrders(ctx context.Context, symbol string, since,
if err := closedQueryOrdersRateLimiter.Wait(ctx); err != nil { if err := closedQueryOrdersRateLimiter.Wait(ctx); err != nil {
return nil, fmt.Errorf("query closed order rate limiter wait error: %w", err) return nil, fmt.Errorf("query closed order rate limiter wait error: %w", err)
} }
res, err := e.v2Client.NewGetHistoryOrdersRequest(). res, err := e.v2client.NewGetHistoryOrdersRequest().
Symbol(symbol). Symbol(symbol).
Limit(strconv.Itoa(queryLimit)). Limit(strconv.Itoa(queryLimit)).
StartTime(since.UnixMilli()). StartTime(since.UnixMilli()).
@ -505,7 +505,7 @@ func (e *Exchange) QueryTrades(ctx context.Context, symbol string, options *type
log.Warn("!!!BITGET EXCHANGE API NOTICE!!! The trade of response is in descending order, so the last trade id not supported.") log.Warn("!!!BITGET EXCHANGE API NOTICE!!! The trade of response is in descending order, so the last trade id not supported.")
} }
req := e.v2Client.NewGetTradeFillsRequest() req := e.v2client.NewGetTradeFillsRequest()
req.Symbol(symbol) req.Symbol(symbol)
if options.StartTime != nil { if options.StartTime != nil {