✨ Listen stream messages

internal/protocols/stream/response.go

@@ -0,0 +1,5 @@
+package stream
+
+type Response struct {
+	Command string `json:"response"`
+}

xapi.go

@@ -1,6 +1,7 @@
 package xapi
 
 import (
+	"encoding/json"
 	"fmt"
 	"time"
 
@@ -56,10 +57,28 @@ func NewClient(userId string, password string, connectionType string) (*client,
 	}
 	go c.pingSocket()
 	go c.pingStream()
+	go c.listenStream()
 
 	return c, nil
 }
 
+func (c *client) listenStream() {
+	for {
+		_, msg, err := c.streamConn.ReadMessage()
+		if err != nil {
+			fmt.Println(err.Error())
+		}
+		fmt.Println("Stream message:", msg)
+		response := stream.Response{}
+		err = json.Unmarshal(msg, &response)
+		if err != nil {
+			fmt.Println(err.Error())
+		}
+		switch response.Command {
+		}
+	}
+}
+
 func (c *client) pingSocket() {
 	for {
 		request := socket.Request{