From 4350e3c199195811310ecee8116699e3a6149bbe Mon Sep 17 00:00:00 2001 From: jppade Date: Mon, 24 Jul 2023 11:12:13 +0200 Subject: [PATCH] remove influx dependency from some scrapers. --- pkg/dia/scraper/exchange-scrapers/CurvefiScraper.go | 1 - pkg/dia/scraper/exchange-scrapers/UniswapV2Scraper.go | 6 ------ 2 files changed, 7 deletions(-) diff --git a/pkg/dia/scraper/exchange-scrapers/CurvefiScraper.go b/pkg/dia/scraper/exchange-scrapers/CurvefiScraper.go index 86adb84fb..5ca79d0c7 100644 --- a/pkg/dia/scraper/exchange-scrapers/CurvefiScraper.go +++ b/pkg/dia/scraper/exchange-scrapers/CurvefiScraper.go @@ -114,7 +114,6 @@ type CurveFIScraper struct { WsClient *ethclient.Client RestClient *ethclient.Client relDB *models.RelDB - datastore *models.DB curveCoins map[string]*CurveCoin resubscribe chan string pools *Pools diff --git a/pkg/dia/scraper/exchange-scrapers/UniswapV2Scraper.go b/pkg/dia/scraper/exchange-scrapers/UniswapV2Scraper.go index 73feb3f40..1bc05267b 100644 --- a/pkg/dia/scraper/exchange-scrapers/UniswapV2Scraper.go +++ b/pkg/dia/scraper/exchange-scrapers/UniswapV2Scraper.go @@ -127,7 +127,6 @@ type UniswapScraper struct { WsClient *ethclient.Client RestClient *ethclient.Client relDB *models.RelDB - datastore *models.DB // signaling channels for session initialization and finishing //initDone chan nothing run bool @@ -228,11 +227,6 @@ func NewUniswapScraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB) s.relDB = relDB - s.datastore, err = models.NewDataStore() - if err != nil { - log.Fatal("new datastore: ", err) - } - // Only include pools with (minimum) liquidity bigger than given env var. liquidityThreshold, err := strconv.ParseFloat(utils.Getenv("LIQUIDITY_THRESHOLD", "0"), 64) if err != nil {