diff --git a/cmd/assetCollectionService/go.mod b/cmd/assetCollectionService/go.mod index 2e8cb2025..ce6fea7df 100644 --- a/cmd/assetCollectionService/go.mod +++ b/cmd/assetCollectionService/go.mod @@ -3,7 +3,7 @@ module github.com/diadata-org/diadata/assetCollectionService go 1.22 require ( - github.com/diadata-org/diadata v1.4.557 + github.com/diadata-org/diadata v1.4.560 github.com/sirupsen/logrus v1.9.3 ) diff --git a/cmd/assetCollectionService/main.go b/cmd/assetCollectionService/main.go index fd7dcc68b..f791e8d12 100644 --- a/cmd/assetCollectionService/main.go +++ b/cmd/assetCollectionService/main.go @@ -150,6 +150,8 @@ func NewAssetScraper(exchange string, secret string, relDB *models.RelDB) source return source.NewOsmosisScraper(exchanges[dia.OsmosisExchange]) case dia.VelodromeExchange: return source.NewVelodromeAssetSource(exchanges[dia.VelodromeExchange], relDB) + case dia.VelodromeSlipstreamExchange: + return source.NewVelodromeAssetSource(exchanges[dia.VelodromeSlipstreamExchange], relDB) case dia.TraderJoeExchangeV2_1: return source.NewTraderJoeAssetSource(exchanges[dia.TraderJoeExchangeV2_1], relDB) case dia.TraderJoeExchangeV2_1Arbitrum: diff --git a/cmd/exchange-scrapers/collector/go.mod b/cmd/exchange-scrapers/collector/go.mod index ef0ddb51c..03b3620ca 100644 --- 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.22 require ( - github.com/diadata-org/diadata v1.4.559 + github.com/diadata-org/diadata v1.4.560 github.com/segmentio/kafka-go v0.4.35 github.com/sirupsen/logrus v1.9.3 ) diff --git a/cmd/liquidityScraper/go.mod b/cmd/liquidityScraper/go.mod index 67422e602..a0497d653 100644 --- a/cmd/liquidityScraper/go.mod +++ b/cmd/liquidityScraper/go.mod @@ -3,7 +3,7 @@ module github.com/diadata-org/diadata/liquidityScraper go 1.22 require ( - github.com/diadata-org/diadata v1.4.557 + github.com/diadata-org/diadata v1.4.560 github.com/sirupsen/logrus v1.9.3 ) diff --git a/pkg/dia/Config.go b/pkg/dia/Config.go index c553c7bfb..86ec1774d 100644 --- a/pkg/dia/Config.go +++ b/pkg/dia/Config.go @@ -109,6 +109,7 @@ const ( ZenlinkswapExchange = "Zenlink" ZenlinkswapExchangeBifrostPolkadot = "Zenlink-bifrost-polkadot" VelodromeExchange = "Velodrome" + VelodromeSlipstreamExchange = "VelodromeSlipstream" MaverickExchange = "Maverick" MaverickExchangeZKSync = "Maverick-zksync" MaverickExchangeBNB = "Maverick-bnb" diff --git a/pkg/dia/scraper/exchange-scrapers/APIScraper.go b/pkg/dia/scraper/exchange-scrapers/APIScraper.go index e0f1e0c03..bfce8f471 100644 --- a/pkg/dia/scraper/exchange-scrapers/APIScraper.go +++ b/pkg/dia/scraper/exchange-scrapers/APIScraper.go @@ -293,6 +293,8 @@ func NewAPIScraper(exchange string, scrape bool, key string, secret string, relD return NewBitgetScraper(Exchanges[dia.BitgetExchange], scrape, relDB) case dia.AerodromeSlipstreamExchange: return NewUniswapV3Scraper(Exchanges[dia.AerodromeSlipstreamExchange], scrape, relDB) + case dia.VelodromeSlipstreamExchange: + return NewUniswapV3Scraper(Exchanges[dia.VelodromeSlipstreamExchange], scrape, relDB) // case dia.FinageForex: // return NewFinageForexScraper(Exchanges[dia.FinageForex], scrape, relDB, key, secret) diff --git a/pkg/dia/scraper/exchange-scrapers/UniswapV3Scraper.go b/pkg/dia/scraper/exchange-scrapers/UniswapV3Scraper.go index 941bf29ee..208f82d87 100644 --- a/pkg/dia/scraper/exchange-scrapers/UniswapV3Scraper.go +++ b/pkg/dia/scraper/exchange-scrapers/UniswapV3Scraper.go @@ -105,6 +105,8 @@ func NewUniswapV3Scraper(exchange dia.Exchange, scrape bool, relDB *models.RelDB s = makeUniswapV3Scraper(exchange, listenByAddress, "", "", "2000", uint64(1768866)) case dia.AerodromeSlipstreamExchange: s = makeUniswapV3Scraper(exchange, listenByAddress, "", "", "2000", uint64(0)) + case dia.VelodromeSlipstreamExchange: + s = makeUniswapV3Scraper(exchange, listenByAddress, "", "", "2000", uint64(0)) } s.relDB = relDB diff --git a/pkg/dia/scraper/liquidity-scrapers/ScraperInterface.go b/pkg/dia/scraper/liquidity-scrapers/ScraperInterface.go index fa3e7c3cb..5c9c90f27 100644 --- a/pkg/dia/scraper/liquidity-scrapers/ScraperInterface.go +++ b/pkg/dia/scraper/liquidity-scrapers/ScraperInterface.go @@ -154,6 +154,8 @@ func NewLiquidityScraper(source string, relDB *models.RelDB, datastore *models.D return NewPlatypusScraper(exchanges[dia.PlatypusExchange], datastore) case dia.VelodromeExchange: return NewVelodromePoolScraper(exchanges[dia.VelodromeExchange], relDB, datastore) + case dia.VelodromeSlipstreamExchange: + return NewVelodromePoolScraper(exchanges[dia.VelodromeSlipstreamExchange], relDB, datastore) case dia.AerodromeV1Exchange: return NewVelodromePoolScraper(exchanges[dia.AerodromeV1Exchange], relDB, datastore) case dia.AerodromeSlipstreamExchange: diff --git a/pkg/dia/scraper/liquidity-scrapers/Velodrome.go b/pkg/dia/scraper/liquidity-scrapers/Velodrome.go index c29c4e427..628790e6f 100644 --- a/pkg/dia/scraper/liquidity-scrapers/Velodrome.go +++ b/pkg/dia/scraper/liquidity-scrapers/Velodrome.go @@ -39,6 +39,8 @@ func NewVelodromePoolScraper(exchange dia.Exchange, relDB *models.RelDB, datasto switch exchange.Name { case dia.VelodromeExchange: us = makeVelodromePoolScraper(exchange, relDB, datastore, restDialOptimism, velodromeWaitMilliseconds) + case dia.VelodromeSlipstreamExchange: + us = makeVelodromePoolScraper(exchange, relDB, datastore, restDialOptimism, velodromeWaitMilliseconds) case dia.AerodromeV1Exchange: us = makeVelodromePoolScraper(exchange, relDB, datastore, restDialBase, velodromeWaitMilliseconds) case dia.AerodromeSlipstreamExchange: @@ -170,7 +172,7 @@ func (us *VelodromePoolScraper) GetPoolByAddress(pairAddress common.Address) (po } } - if us.exchange.Name == dia.AerodromeSlipstreamExchange { + if us.exchange.Name == dia.AerodromeSlipstreamExchange || us.exchange.Name == dia.VelodromeSlipstreamExchange { us.GetLiquidityUniV3Type(token0, token1, pairAddress, &pool) } else { us.GetLiquidityUniV2Type(token0, token1, pairContract, &pool) diff --git a/pkg/dia/service/assetservice/source/velodrome.go b/pkg/dia/service/assetservice/source/velodrome.go index 4ca4df53f..f34cf2baa 100644 --- a/pkg/dia/service/assetservice/source/velodrome.go +++ b/pkg/dia/service/assetservice/source/velodrome.go @@ -44,6 +44,8 @@ func NewVelodromeAssetSource(exchange dia.Exchange, relDB *models.RelDB) (uas *V switch exchange.Name { case dia.VelodromeExchange: uas = makeVelodromeAssetSource(exchange, restDialOptimism, relDB, velodromeWaitMilliseconds) + case dia.VelodromeSlipstreamExchange: + uas = makeVelodromeAssetSource(exchange, restDialOptimism, relDB, velodromeWaitMilliseconds) case dia.AerodromeSlipstreamExchange: uas = makeVelodromeAssetSource(exchange, restDialBase, relDB, velodromeWaitMilliseconds) case dia.AerodromeV1Exchange: