add factories to curve assetcollector and liquidity scraper.

diadata-org · Sep 6, 2023 · dd12ec8 · dd12ec8
1 parent 9188bbe
commit dd12ec8
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 4 deletions.
diff --git a/cmd/assetCollectionService/go.mod b/cmd/assetCollectionService/go.mod
@@ -3,7 +3,7 @@ module github.com/diadata-org/diadata/assetCollectionService
 go 1.17
 
 require (
-	github.com/diadata-org/diadata v1.4.325
+	github.com/diadata-org/diadata v1.4.340
 	github.com/sirupsen/logrus v1.8.1
 )
 

diff --git a/cmd/liquidityScraper/go.mod b/cmd/liquidityScraper/go.mod
@@ -3,7 +3,7 @@ module github.com/diadata-org/diadata/liquidityScraper
 go 1.17
 
 require (
-	github.com/diadata-org/diadata v1.4.329
+	github.com/diadata-org/diadata v1.4.340
 	github.com/sirupsen/logrus v1.8.1
 )
 

diff --git a/pkg/dia/scraper/liquidity-scrapers/CurvefiScraper.go b/pkg/dia/scraper/liquidity-scrapers/CurvefiScraper.go
@@ -67,7 +67,9 @@ func NewCurveFIScraper(exchange dia.Exchange, relDB *models.RelDB, datastore *mo
 		cryptoswapPools := curveRegistry{Type: 1, Address: common.HexToAddress("0x8F942C20D02bEfc377D41445793068908E2250D0")}
 		metaPools := curveRegistry{Type: 2, Address: common.HexToAddress("0xB9fC157394Af804a3578134A6585C0dc9cc990d4")}
 		factoryPools := curveRegistry{Type: 3, Address: common.HexToAddress("0xF18056Bbd320E96A48e3Fbf8bC061322531aac99")}
-		registries = []curveRegistry{factoryPools, basePools, cryptoswapPools, metaPools}
+		factory2Pools := curveRegistry{Type: 3, Address: common.HexToAddress("0x4F8846Ae9380B90d2E71D5e3D042dff3E7ebb40d")}
+		registries = []curveRegistry{factoryPools, factory2Pools, basePools, cryptoswapPools, metaPools}
+
 	case dia.CurveFIExchangeFantom:
 		exchange.Contract = ""
 		// basePools := curveRegistry{Type: 1, Address: common.HexToAddress(exchange.Contract)}

diff --git a/pkg/dia/service/assetservice/source/curvefi.go b/pkg/dia/service/assetservice/source/curvefi.go
@@ -55,7 +55,8 @@ func NewCurvefiAssetSource(exchange dia.Exchange) *CurvefiAssetSource {
 		cryptoswapPools := curveRegistry{Type: 1, Address: common.HexToAddress("0x8F942C20D02bEfc377D41445793068908E2250D0")}
 		metaPools := curveRegistry{Type: 2, Address: common.HexToAddress("0xB9fC157394Af804a3578134A6585C0dc9cc990d4")}
 		factoryPools := curveRegistry{Type: 3, Address: common.HexToAddress("0xF18056Bbd320E96A48e3Fbf8bC061322531aac99")}
-		registries := []curveRegistry{factoryPools, basePools, cryptoswapPools, metaPools}
+		factory2Pools := curveRegistry{Type: 3, Address: common.HexToAddress("0x4F8846Ae9380B90d2E71D5e3D042dff3E7ebb40d")}
+		registries := []curveRegistry{factoryPools, factory2Pools, basePools, cryptoswapPools, metaPools}
 		cas = makeCurvefiAssetSource(exchange, registries, curveRestDialEth, uniswapWaitMilliseconds)
 	case dia.CurveFIExchangeFantom:
 		exchange.Contract = ""