// Connect establishes a WebSocket connection.
func (client *BybitWebSocketClient) Connect() error {
    logrus.Info("Attempting to connect to WebSocket server...")
    conn, resp, err := websocket.DefaultDialer.Dial(client.url, nil)
    if err != nil {
       if resp != nil {
          logrus.WithFields(logrus.Fields{
             "status":  resp.StatusCode,
             "headers": resp.Header,
             "body":    resp.Body,
          }).Error("Failed to connect to WebSocket server")
       } else {
          logrus.WithError(err).Error("Failed to connect to WebSocket server")
       }
       return fmt.Errorf("failed to connect: %w", err)
    }
    websocket.DefaultDialer.TLSClientConfig = &tls.Config{
       InsecureSkipVerify: true,
    }
    client.conn = conn
    logrus.Info(" Successfully connected to WebSocket server")
    return nil
}

wsclient := ws.NewWebSocketClient(cfg.BYBITWSURL)
if err := wsclient.Connect(); err != nil {
    logrus.Fatalf("Failed to connect: %v", err)
}
defer func(wsclient *ws.BybitWebSocketClient) {
    err := wsclient.Close()
    if err != nil {
       logrus.Fatalf("Failed to close: %v", err)
    }
}(wsclient)