lychiyu/bbgo_origin
1
0
Fork 0
mirror of https://github.com/c9s/bbgo.git synced 2024-11-22 14:55:16 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

parse ResultEvent

Browse Source
This commit is contained in:
c9s 2020-06-29 10:55:00 +08:00
parent 4cd96360b3
commit 1ca46435c3
2 changed files with 14 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
bbgo/binance_exchange.go
View File

@ -113,7 +113,7 @@ func (s *PrivateStream) Read(ctx context.Context, eventC chan interface{}) {
log.Debugf("[binance] recv: %s", message)
e, err := ParseBinanceEvent(string(message))
e, err := parseEvent(string(message))
if err != nil {
log.WithError(err).Errorf("[binance] event parse error")
continue

16
bbgo/parser.go
View File

@ -112,7 +112,7 @@ balanceUpdate
"T": 1573200697068 //Clear Time
}
*/
type BinanceBalanceUpdateEvent struct {
type BalanceUpdateEvent struct {
EventBase
Asset string `json:"a"`
@ -192,7 +192,12 @@ type OutboundAccountInfoEvent struct {
Permissions []string `json:"P,omitempty"`
}
func ParseBinanceEvent(message string) (interface{}, error) {
type ResultEvent struct {
Result interface{} `json:"result,omitempty"`
ID int `json:"id"`
}
func parseEvent(message string) (interface{}, error) {
val, err := fastjson.Parse(message)
if err != nil {
return nil, err
@ -212,7 +217,7 @@ func ParseBinanceEvent(message string) (interface{}, error) {
return &event, err
case "balanceUpdate":
var event BinanceBalanceUpdateEvent
var event BalanceUpdateEvent
err := json.Unmarshal([]byte(message), &event)
return &event, err
@ -221,6 +226,11 @@ func ParseBinanceEvent(message string) (interface{}, error) {
err := json.Unmarshal([]byte(message), &event)
return &event, err
default:
id := val.GetInt("id")
if id > 0 {
return &ResultEvent{ID: id}, nil
}
}
return nil, fmt.Errorf("unsupported message: %s", message)