77 lines
1.5 KiB
Go
77 lines
1.5 KiB
Go
|
package bybit
|
||
|
|
|
||
|
|
import (
|
||
|
|
"fmt"
|
||
|
|
"io"
|
||
|
|
"net/http"
|
||
|
|
"net/url"
|
||
|
|
)
|
||
|
|
|
||
|
|
type secType int
|
||
|
|
|
||
|
|
const (
|
||
|
|
secTypeNone secType = iota
|
||
|
|
secTypeSigned // private request
|
||
|
|
)
|
||
|
|
|
||
|
|
type params map[string]interface{}
|
||
|
|
|
||
|
|
// request define an API request
|
||
|
|
type request struct {
|
||
|
|
method string
|
||
|
|
endpoint string
|
||
|
|
query url.Values
|
||
|
|
form url.Values
|
||
|
|
recvWindow string
|
||
|
|
secType secType
|
||
|
|
header http.Header
|
||
|
|
body io.Reader
|
||
|
|
fullURL string
|
||
|
|
}
|
||
|
|
|
||
|
|
// addParam add param with key/value to query string
|
||
|
|
func (r *request) addParam(key string, value interface{}) *request {
|
||
|
|
if r.query == nil {
|
||
|
|
r.query = url.Values{}
|
||
|
|
}
|
||
|
|
r.query.Add(key, fmt.Sprintf("%v", value))
|
||
|
|
return r
|
||
|
|
}
|
||
|
|
|
||
|
|
// setParam set param with key/value to query string
|
||
|
|
func (r *request) setParam(key string, value interface{}) *request {
|
||
|
|
if r.query == nil {
|
||
|
|
r.query = url.Values{}
|
||
|
|
}
|
||
|
|
r.query.Set(key, fmt.Sprintf("%v", value))
|
||
|
|
return r
|
||
|
|
}
|
||
|
|
|
||
|
|
// setParams set params with key/values to query string
|
||
|
|
func (r *request) setParams(m params) *request {
|
||
|
|
for k, v := range m {
|
||
|
|
r.setParam(k, v)
|
||
|
|
}
|
||
|
|
return r
|
||
|
|
}
|
||
|
|
|
||
|
|
func (r *request) validate() (err error) {
|
||
|
|
if r.query == nil {
|
||
|
|
r.query = url.Values{}
|
||
|
|
}
|
||
|
|
if r.form == nil {
|
||
|
|
r.form = url.Values{}
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
// Append `WithRecvWindow(insert_recvwindow)` to request to modify the default recvWindow value
|
||
|
|
func WithRecvWindow(recvWindow string) RequestOption {
|
||
|
|
return func(r *request) {
|
||
|
|
r.recvWindow = recvWindow
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
// RequestOption define option type for request
|
||
|
|
type RequestOption func(*request)
|