From d433c7f5b13379432332be0f52b0269923ff4d90 Mon Sep 17 00:00:00 2001
From: c9s <yoan@maicoin.com>
Date: Thu, 23 Dec 2021 21:09:40 +0800
Subject: [PATCH] kucoin: replace UnixMilli

---
 examples/kucoin/websocket.go   | 4 ++--
 pkg/exchange/kucoin/convert.go | 2 +-
 pkg/exchange/kucoin/stream.go  | 4 ++--
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/examples/kucoin/websocket.go b/examples/kucoin/websocket.go
index af67b4feb..287d0e2e7 100644
--- a/examples/kucoin/websocket.go
+++ b/examples/kucoin/websocket.go
@@ -74,7 +74,7 @@ var websocketCmd = &cobra.Command{
 
 		defer c.Close()
 
-		id := time.Now().UnixMilli()
+		id := time.Now().UnixNano() / int64(time.Millisecond)
 		wsCmds := []kucoin.WebSocketCommand{
 			/*
 			{
@@ -125,7 +125,7 @@ var websocketCmd = &cobra.Command{
 
 			case <-pingTicker.C:
 				if err := c.WriteJSON(kucoin.WebSocketCommand{
-					Id:   time.Now().UnixMilli(),
+					Id:   time.Now().UnixNano() / int64(time.Millisecond),
 					Type: "ping",
 				}); err != nil {
 					logrus.WithError(err).Error("websocket ping error", err)
diff --git a/pkg/exchange/kucoin/convert.go b/pkg/exchange/kucoin/convert.go
index 6786c75a8..2acbeb5b8 100644
--- a/pkg/exchange/kucoin/convert.go
+++ b/pkg/exchange/kucoin/convert.go
@@ -94,7 +94,7 @@ func toLocalInterval(i types.Interval) string {
 
 // convertSubscriptions global subscription to local websocket command
 func convertSubscriptions(ss []types.Subscription) ([]WebSocketCommand, error) {
-	var id = time.Now().UnixMilli()
+	var id = time.Now().UnixNano() / int64(time.Millisecond)
 	var cmds []WebSocketCommand
 	for _, s := range ss {
 		id++
diff --git a/pkg/exchange/kucoin/stream.go b/pkg/exchange/kucoin/stream.go
index a40fe058d..5908ce5c2 100644
--- a/pkg/exchange/kucoin/stream.go
+++ b/pkg/exchange/kucoin/stream.go
@@ -137,7 +137,7 @@ func (s *Stream) handleConnect() {
 			return
 		}
 	} else {
-		id := time.Now().UnixMilli()
+		id := time.Now().UnixNano() / int64(time.Millisecond)
 		cmds := []WebSocketCommand{
 			{
 				Id:             id,
@@ -406,7 +406,7 @@ func ping(ctx context.Context, w WebSocketConnector, interval time.Duration) {
 			conn := w.Conn()
 
 			if err := conn.WriteJSON(WebSocketCommand{
-				Id:   time.Now().UnixMilli(),
+				Id:   time.Now().UnixNano() / int64(time.Millisecond),
 				Type: "ping",
 			}); err != nil {
 				log.WithError(err).Error("websocket ping error", err)