feat: htx usdm ws apis

linstohu · Dec 20, 2023 · a71660f · a71660f
1 parent 19fd19c
commit a71660f
Show file tree

Hide file tree

Showing 20 changed files with 1,705 additions and 3 deletions.
diff --git a/htx/spot/marketws/client.go b/htx/spot/marketws/client.go
@@ -231,7 +231,9 @@ func (m *MarketWsClient) readMessages() {
 
 				switch {
 				case msg.Ping != nil:
-					err := m.pong(msg.Ping)
+					err := m.pong(&PongMessage{
+						Pong: msg.Ping.Ping,
+					})
 					if err != nil {
 						m.logger.Error(fmt.Sprintf("handle ping error: %s", err.Error()))
 					}
@@ -327,7 +329,7 @@ func (m *MarketWsClient) send(req *Request) error {
 	return m.conn.WriteJSON(req)
 }
 
-func (m *MarketWsClient) pong(ping *PingMessage) error {
+func (m *MarketWsClient) pong(ping *PongMessage) error {
 	m.sending.Lock()
 
 	// Rate Limit: https://www.htx.com/en-us/opend/newApiPages/?id=662

diff --git a/htx/spot/marketws/response.go b/htx/spot/marketws/response.go
@@ -41,6 +41,10 @@ type PingMessage struct {
 	Ping int64 `json:"ping,omitempty"`
 }
 
+type PongMessage struct {
+	Pong int64 `json:"pong,omitempty"`
+}
+
 type Response struct {
 	ID     string `json:"id,omitempty"`
 	Status string `json:"status,omitempty"`