remove influx dependency from some scrapers.

diadata-org · Jul 24, 2023 · 4350e3c · 4350e3c
1 parent 9873d08
commit 4350e3c
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 7 deletions.
diff --git 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
@@ -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 {