From 90f704bab0569df7a177cdca3ce3e1a3209fd0ed Mon Sep 17 00:00:00 2001 From: c9s Date: Thu, 18 May 2023 15:22:50 +0800 Subject: [PATCH] bitgetapi: add get order detail request --- .../bitgetapi/get_order_detail_request.go | 41 ++++ .../get_order_detail_request_requestgen.go | 177 ++++++++++++++++++ 2 files changed, 218 insertions(+) create mode 100644 pkg/exchange/bitget/bitgetapi/get_order_detail_request.go create mode 100644 pkg/exchange/bitget/bitgetapi/get_order_detail_request_requestgen.go diff --git a/pkg/exchange/bitget/bitgetapi/get_order_detail_request.go b/pkg/exchange/bitget/bitgetapi/get_order_detail_request.go new file mode 100644 index 000000000..717bed4a6 --- /dev/null +++ b/pkg/exchange/bitget/bitgetapi/get_order_detail_request.go @@ -0,0 +1,41 @@ +package bitgetapi + +//go:generate -command GetRequest requestgen -method GET -responseType .APIResponse -responseDataField Data +//go:generate -command PostRequest requestgen -method POST -responseType .APIResponse -responseDataField Data + +import ( + "github.com/c9s/requestgen" + + "github.com/c9s/bbgo/pkg/fixedpoint" + "github.com/c9s/bbgo/pkg/types" +) + +type OrderDetail struct { + AccountId string `json:"accountId"` + Symbol string `json:"symbol"` + OrderId string `json:"orderId"` + ClientOrderId string `json:"clientOrderId"` + Price fixedpoint.Value `json:"price"` + Quantity fixedpoint.Value `json:"quantity"` + OrderType OrderType `json:"orderType"` + Side OrderSide `json:"side"` + Status string `json:"status"` + FillPrice fixedpoint.Value `json:"fillPrice"` + FillQuantity fixedpoint.Value `json:"fillQuantity"` + FillTotalAmount fixedpoint.Value `json:"fillTotalAmount"` + EnterPointSource string `json:"enterPointSource"` + CTime types.MillisecondTimestamp `json:"cTime"` +} + +//go:generate PostRequest -url "/api/spot/v1/trade/orderInfo" -type GetOrderDetailRequest -responseDataType .OrderDetail +type GetOrderDetailRequest struct { + client requestgen.AuthenticatedAPIClient + + symbol string `param:"symbol"` + orderId *string `param:"orderId"` + clientOrderId *string `param:"clientOid"` +} + +func (c *RestClient) NewGetOrderDetailRequest() *GetOrderDetailRequest { + return &GetOrderDetailRequest{client: c} +} diff --git a/pkg/exchange/bitget/bitgetapi/get_order_detail_request_requestgen.go b/pkg/exchange/bitget/bitgetapi/get_order_detail_request_requestgen.go new file mode 100644 index 000000000..70055fe7c --- /dev/null +++ b/pkg/exchange/bitget/bitgetapi/get_order_detail_request_requestgen.go @@ -0,0 +1,177 @@ +// Code generated by "requestgen -method POST -responseType .APIResponse -responseDataField Data -url /api/spot/v1/trade/orderInfo -type GetOrderDetailRequest -responseDataType .OrderDetail"; DO NOT EDIT. + +package bitgetapi + +import ( + "context" + "encoding/json" + "fmt" + "net/url" + "reflect" + "regexp" +) + +func (g *GetOrderDetailRequest) Symbol(symbol string) *GetOrderDetailRequest { + g.symbol = symbol + return g +} + +func (g *GetOrderDetailRequest) OrderId(orderId string) *GetOrderDetailRequest { + g.orderId = &orderId + return g +} + +func (g *GetOrderDetailRequest) ClientOrderId(clientOrderId string) *GetOrderDetailRequest { + g.clientOrderId = &clientOrderId + return g +} + +// GetQueryParameters builds and checks the query parameters and returns url.Values +func (g *GetOrderDetailRequest) GetQueryParameters() (url.Values, error) { + var params = map[string]interface{}{} + + query := url.Values{} + for _k, _v := range params { + query.Add(_k, fmt.Sprintf("%v", _v)) + } + + return query, nil +} + +// GetParameters builds and checks the parameters and return the result in a map object +func (g *GetOrderDetailRequest) GetParameters() (map[string]interface{}, error) { + var params = map[string]interface{}{} + // check symbol field -> json key symbol + symbol := g.symbol + + // assign parameter of symbol + params["symbol"] = symbol + // check orderId field -> json key orderId + if g.orderId != nil { + orderId := *g.orderId + + // assign parameter of orderId + params["orderId"] = orderId + } else { + } + // check clientOrderId field -> json key clientOid + if g.clientOrderId != nil { + clientOrderId := *g.clientOrderId + + // assign parameter of clientOrderId + params["clientOid"] = clientOrderId + } else { + } + + return params, nil +} + +// GetParametersQuery converts the parameters from GetParameters into the url.Values format +func (g *GetOrderDetailRequest) GetParametersQuery() (url.Values, error) { + query := url.Values{} + + params, err := g.GetParameters() + if err != nil { + return query, err + } + + for _k, _v := range params { + if g.isVarSlice(_v) { + g.iterateSlice(_v, func(it interface{}) { + query.Add(_k+"[]", fmt.Sprintf("%v", it)) + }) + } else { + query.Add(_k, fmt.Sprintf("%v", _v)) + } + } + + return query, nil +} + +// GetParametersJSON converts the parameters from GetParameters into the JSON format +func (g *GetOrderDetailRequest) GetParametersJSON() ([]byte, error) { + params, err := g.GetParameters() + if err != nil { + return nil, err + } + + return json.Marshal(params) +} + +// GetSlugParameters builds and checks the slug parameters and return the result in a map object +func (g *GetOrderDetailRequest) GetSlugParameters() (map[string]interface{}, error) { + var params = map[string]interface{}{} + + return params, nil +} + +func (g *GetOrderDetailRequest) applySlugsToUrl(url string, slugs map[string]string) string { + for _k, _v := range slugs { + needleRE := regexp.MustCompile(":" + _k + "\\b") + url = needleRE.ReplaceAllString(url, _v) + } + + return url +} + +func (g *GetOrderDetailRequest) iterateSlice(slice interface{}, _f func(it interface{})) { + sliceValue := reflect.ValueOf(slice) + for _i := 0; _i < sliceValue.Len(); _i++ { + it := sliceValue.Index(_i).Interface() + _f(it) + } +} + +func (g *GetOrderDetailRequest) isVarSlice(_v interface{}) bool { + rt := reflect.TypeOf(_v) + switch rt.Kind() { + case reflect.Slice: + return true + } + return false +} + +func (g *GetOrderDetailRequest) GetSlugsMap() (map[string]string, error) { + slugs := map[string]string{} + params, err := g.GetSlugParameters() + if err != nil { + return slugs, nil + } + + for _k, _v := range params { + slugs[_k] = fmt.Sprintf("%v", _v) + } + + return slugs, nil +} + +func (g *GetOrderDetailRequest) Do(ctx context.Context) (*OrderDetail, error) { + + params, err := g.GetParameters() + if err != nil { + return nil, err + } + query := url.Values{} + + apiURL := "/api/spot/v1/trade/orderInfo" + + req, err := g.client.NewAuthenticatedRequest(ctx, "POST", apiURL, query, params) + if err != nil { + return nil, err + } + + response, err := g.client.SendRequest(req) + if err != nil { + return nil, err + } + + var apiResponse APIResponse + if err := response.DecodeJSON(&apiResponse); err != nil { + return nil, err + } + var data OrderDetail + if err := json.Unmarshal(apiResponse.Data, &data); err != nil { + return nil, err + } + return &data, nil +}