add asset collector for univ2 on base.

diadata-org · Sep 20, 2024 · 271f19c · 271f19c
1 parent 1fefb92
commit 271f19c
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 1 deletion.
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.20
 
 require (
-	github.com/diadata-org/diadata v1.4.528
+	github.com/diadata-org/diadata v1.4.532
 	github.com/sirupsen/logrus v1.9.3
 )
 

diff --git a/cmd/assetCollectionService/main.go b/cmd/assetCollectionService/main.go
@@ -162,6 +162,8 @@ func NewAssetScraper(exchange string, secret string, relDB *models.RelDB) source
 		return source.NewUniswapAssetSource(exchanges[dia.PearlfiExchange], relDB)
 	case dia.ThenaExchange:
 		return source.NewUniswapAssetSource(exchanges[dia.ThenaExchange], relDB)
+	case dia.UniswapExchangeBase:
+		return source.NewUniswapAssetSource(exchanges[dia.UniswapExchangeBase], relDB)
 	case "assetlists":
 		return source.NewJSONReader(exchange, secret)
 	case dia.AyinExchange:

diff --git a/pkg/dia/Config.go b/pkg/dia/Config.go
@@ -57,6 +57,7 @@ const (
 	FilterKing                         = "MAIR120"
 	BancorExchange                     = "Bancor"
 	UniswapExchange                    = "Uniswap"
+	UniswapExchangeBase                = "Uniswap-Base"
 	UniswapExchangeV3                  = "UniswapV3"
 	UniswapExchangeV3Polygon           = "UniswapV3-polygon"
 	UniswapExchangeV3Arbitrum          = "UniswapV3-Arbitrum"

diff --git a/pkg/dia/service/assetservice/source/uniswap.go b/pkg/dia/service/assetservice/source/uniswap.go
@@ -25,6 +25,7 @@ type UniswapPair struct {
 
 const (
 	restDial              = ""
+	restDialBase          = ""
 	restDialBSC           = ""
 	restDialPolygon       = ""
 	restDialCelo          = ""
@@ -44,6 +45,7 @@ const (
 	restDialLinea         = ""
 
 	uniswapWaitMilliseconds     = "25"
+	baseWaitMilliseconds        = "200"
 	sushiswapWaitMilliseconds   = "100"
 	pancakeswapWaitMilliseconds = "100"
 	dfynWaitMilliseconds        = "100"
@@ -138,6 +140,8 @@ func NewUniswapAssetSource(exchange dia.Exchange, relDB *models.RelDB) (uas *Uni
 		uas = makeUniswapAssetSource(exchange, restDialLinea, relDB, wanchainWaitMilliseconds)
 	case dia.ThenaExchange:
 		uas = makeUniswapAssetSource(exchange, restDialBSC, relDB, sushiswapWaitMilliseconds)
+	case dia.UniswapExchangeBase:
+		uas = makeUniswapAssetSource(exchange, restDialBase, relDB, baseWaitMilliseconds)
 	}
 
 	exchangeFactoryContractAddress = exchange.Contract