fix error handling for node connection in balancerv2 type scrapers.

diadata-org · Sep 1, 2023 · d2cdbcd · d2cdbcd
1 parent 40af90d
commit d2cdbcd
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 7 deletions.
diff --git 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.17
 
 require (
-	github.com/diadata-org/diadata v1.4.329
+	github.com/diadata-org/diadata v1.4.336
 	github.com/segmentio/kafka-go v0.4.35
 	github.com/sirupsen/logrus v1.9.0
 )

diff --git a/pkg/dia/scraper/exchange-scrapers/BalancerV2Scraper.go b/pkg/dia/scraper/exchange-scrapers/BalancerV2Scraper.go
@@ -111,14 +111,12 @@ func NewBalancerV2Scraper(exchange dia.Exchange, scrape bool, relDB *models.RelD
 
 	ws, err := ethclient.Dial(utils.Getenv("ETH_URI_WS", balancerV2WSDial))
 	if err != nil {
-		log.Error(err)
-		return nil
+		log.Fatal("init ws client: ", err)
 	}
 
 	rest, err := ethclient.Dial(utils.Getenv("ETH_URI_REST", balancerV2RestDial))
 	if err != nil {
-		log.Error(err)
-		return nil
+		log.Fatal("init rest client: ", err)
 	}
 
 	scraper.relDB = relDB

diff --git a/pkg/dia/scraper/exchange-scrapers/BancorScraper.go b/pkg/dia/scraper/exchange-scrapers/BancorScraper.go
@@ -110,12 +110,12 @@ func NewBancorScraper(exchange dia.Exchange, scrape bool) *BancorScraper {
 
 	restClient, err = ethclient.Dial(utils.Getenv("ETH_URI_REST", restDialEth))
 	if err != nil {
-		log.Fatal(err)
+		log.Fatal("init rest client: ", err)
 	}
 
 	wsClient, err = ethclient.Dial(utils.Getenv("ETH_URI_WS", wsDialEth))
 	if err != nil {
-		log.Fatal(err)
+		log.Fatal("init ws client: ", err)
 	}
 
 	scraper := &BancorScraper{