From 3028129b21b54751838784fb80f5025b5d22eba7 Mon Sep 17 00:00:00 2001 From: Gareth Kirwan Date: Mon, 13 Jan 2025 15:10:55 +0700 Subject: [PATCH] fixup! GateIO: Improve WS Header parsing --- exchanges/gateio/gateio_websocket.go | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/exchanges/gateio/gateio_websocket.go b/exchanges/gateio/gateio_websocket.go index e41026ae066..d04ab9ae4fe 100644 --- a/exchanges/gateio/gateio_websocket.go +++ b/exchanges/gateio/gateio_websocket.go @@ -223,17 +223,18 @@ func parseWSHeader(msg []byte) (r *WSResponse, errs error) { jsonparser.EachKey(msg, func(idx int, v []byte, _ jsonparser.ValueType, _ error) { switch idx { case 0: // time_ms - if ts, err := strconv.Atoi(string(v)); err != nil { + if ts, err := strconv.ParseInt(string(v), 10, 64); err != nil { errs = common.AppendError(errs, fmt.Errorf("%w parsing `time_ms`", err)) } else { - r.Time = time.UnixMilli(int64(ts)) + r.Time = time.UnixMilli(ts) } case 1: // time if r.Time.IsZero() { - if ts, err := strconv.Atoi(string(v)); err != nil { + + if ts, err := strconv.ParseInt(string(v), 10, 64); err != nil { errs = common.AppendError(errs, fmt.Errorf("%w parsing `time`", err)) } else { - r.Time = time.Unix(int64(ts), 0) + r.Time = time.Unix(ts, 0) } } case 2: @@ -243,10 +244,10 @@ func parseWSHeader(msg []byte) (r *WSResponse, errs error) { case 4: r.RequestID = string(v) case 5: - if id, err := strconv.Atoi(string(v)); err != nil { + if id, err := strconv.ParseInt(string(v), 10, 64); err != nil { errs = common.AppendError(errs, fmt.Errorf("%w parsing `id`", err)) } else { - r.ID = int64(id) + r.ID = id } case 6: r.Result = json.RawMessage(v)