common

type APIError struct {
	Status  int    `json:"status"`
	Code    int64  `json:"code"`
	Message string `json:"msg"`
}

type Client interface {
	GetTimeOffset() int64
	UpdateTimeOffset(offset int64)
	UpdateDoFunc(f DoFunc)
	UpdateHTTPClient(hc *http.Client)
	CallAPIBytes(ctx context.Context, r *Request, opts ...RequestOption) (data []byte, err error)
	CallAPI(ctx context.Context, r *Request, result interface{}, opts ...RequestOption) (err error)
}

type DefaultLogger struct {
	// contains filtered or unexported fields
}

type DoFunc func(req *http.Request) (*http.Response, error)

type LogLevel int

type Logger interface {
	Debugw(msg string, keyAndValues ...interface{})
	Infow(msg string, keyAndValues ...interface{})
	Warningw(msg string, keyAndValues ...interface{})
}

type MockWebsocketSession interface {
	WebsocketSession
	MockProcessMessage(data []byte) error
}

type Params map[string]interface{}

type PriceLevel struct {
	Price    string
	Quantity string
}

type PriceLevelArray []string

type Printf interface {
	Printf(format string, v ...interface{})
}

type Request struct {
	ID         uint64
	Method     string
	Endpoint   string
	SecType    SecType
	Query      url.Values
	Form       url.Values
	RecvWindow int64
	Header     http.Header
}

type RequestOption func(*Request)

type SecType int

type WebsocketClient interface {
	Loop(f WebsocketMessageCallback) error
	Delay() time.Duration
	Ping()
	Write(data []byte)
}

type WebsocketMessageCallback func(messageType websocket.MessageType, data []byte) error

type WebsocketReply struct {
	ID      uint64 `json:"id"`
	Code    int64  `json:"code"`
	Message string `json:"msg"`
	Result  interface{}
}

type WebsocketRequest struct {
	ID     uint64      `json:"id"`
	Method string      `json:"method"`
	Params interface{} `json:"params"`
}

type WebsocketSession interface {
	// Loop hold this websocket connection until the connection disconnected or got error
	// from message processor. return error same as SessionHandler.OnClose function.
	Loop() (err error)
	// RunLoop create new go routine and call IOLoop function.
	RunLoop() chan error
	Subscribe(ctx context.Context, streams ...string) (reply *WebsocketReply, err error)
	SubscribeNoReply(ctx context.Context, streams ...string) (err error)
	RegisterMessageHandler(factory WebsocketSessionMessageFactory, callback WebsocketSessionMessageCallback,
		checker ...WebsocketSessionMessageChecker)
	RequireMapHasAllKeys(keys ...string) WebsocketSessionMessageChecker
	RequireMapKeyValue(key, value string) WebsocketSessionMessageChecker
}

type WebsocketSessionHandler interface {
	OnUnknownMessage([]byte, interface{}) error
	OnClose(err error)
}

type WebsocketSessionMessageCallback func(m interface{})

type WebsocketSessionMessageChecker func(m interface{}) bool

type WebsocketSessionMessageFactory func() interface{}

type WebsocketSubscribe interface {
	Run(ctx context.Context)
	Subscribe(topics ...string) bool
}