Function execWebsocket

cmd/cli/cli.go:369–412

(ep Endpoint, reqURL string)

}

func execWebsocket(ep Endpoint, reqURL string) error {
	wsURL := strings.Replace(reqURL, "http://", "ws://", 1)
	wsURL = strings.Replace(wsURL, "https://", "wss://", 1)
	if strings.ToUpper(ep.Method) != http.MethodGet {
		return fmt.Errorf("--ws requires GET endpoint, got %s", ep.Method)
	}
	c, _, err := websocket.DefaultDialer.Dial(wsURL, nil)
	if err != nil {
		return err
	}
	defer c.Close()

	stopPing := make(chan struct{})
	defer close(stopPing)
	go func() {
		ticker := time.NewTicker(3 * time.Second)
		defer ticker.Stop()
		for {
			select {
			case <-stopPing:
				return
			case <-ticker.C:
				_ = c.SetWriteDeadline(time.Now().Add(2 * time.Second))
				if err := c.WriteMessage(websocket.TextMessage, []byte("ping")); err != nil {
					return
				}
			}
		}
	}()

	for {
		_, msg, err := c.ReadMessage()
		if err != nil {
			if websocket.IsCloseError(err, websocket.CloseNormalClosure, websocket.CloseGoingAway) || strings.Contains(err.Error(), "close") {
				return nil
			}
			return err
		}
		if string(msg) == "pong" {
			continue
		}
		fmt.Println(string(msg))
	}
}

func printJSON(payload []byte) {
	if len(payload) == 0 {