From d1a542ad36588748c3c63e309a59b2c331699d1a Mon Sep 17 00:00:00 2001 From: jppade Date: Wed, 6 Nov 2024 10:03:19 +0100 Subject: [PATCH] make bybit ws connection string an env var. --- cmd/exchange-scrapers/collector/go.mod | 2 +- pkg/dia/scraper/exchange-scrapers/ByBitScraper.go | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/cmd/exchange-scrapers/collector/go.mod b/cmd/exchange-scrapers/collector/go.mod index ecd2d3857..b395beab0 100644 --- a/cmd/exchange-scrapers/collector/go.mod +++ b/cmd/exchange-scrapers/collector/go.mod @@ -3,7 +3,7 @@ module github.com/diadata-org/diadata/exchange-scrapers/collector go 1.22 require ( - github.com/diadata-org/diadata v1.4.557 + github.com/diadata-org/diadata v1.4.558 github.com/segmentio/kafka-go v0.4.35 github.com/sirupsen/logrus v1.9.3 ) diff --git a/pkg/dia/scraper/exchange-scrapers/ByBitScraper.go b/pkg/dia/scraper/exchange-scrapers/ByBitScraper.go index 983c859b8..c156c226c 100644 --- a/pkg/dia/scraper/exchange-scrapers/ByBitScraper.go +++ b/pkg/dia/scraper/exchange-scrapers/ByBitScraper.go @@ -17,7 +17,7 @@ import ( "github.com/diadata-org/diadata/pkg/utils" ) -var ByBitSocketURL string = "wss://stream.bybit.com/spot/public/v3" +var ByBitSocketURL string = utils.Getenv("BYBIT_WS_URL", "wss://stream.bybit.com/spot/public/v5") type ByBitMarket struct { Name string `json:"name"` @@ -135,7 +135,7 @@ func NewByBitScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) *B SwConn, _, err := wsDialer.Dial(ByBitSocketURL, nil) if err != nil { - println(err.Error()) + log.Error("Connect to websocket server: ", err.Error()) } s.wsClient = SwConn