ignore zero registry/factory for curve pools (#37)

* ignore zero registry/factory for curve pools

* ignore zero for platypus

---------

Co-authored-by: le.cao <[email protected]>

Author: it4rb

pkg/source/curve/pools_list_updater.go

@@ -5,6 +5,7 @@ import (
 	"encoding/json"
 	"errors"
 	"math/big"
+	"strings"
 
 	"github.com/KyberNetwork/ethrpc"
 	"github.com/KyberNetwork/logger"
@@ -65,6 +66,10 @@ func (d *PoolsListUpdater) GetNewPools(ctx context.Context, metadataBytes []byte
 
 	var newPoolLimitLeft = d.config.NewPoolLimit
 	for i := 0; i < len(registryOrFactoryList); i++ {
+		if strings.EqualFold(registryOrFactoryList[i].Address, addressZero) {
+			logger.Debugf("skip zero factory %v", i)
+			continue
+		}
 		poolAddresses, poolTypes, nextOffset, err := d.getNewPoolAddressesFromRegistryOrFactory(
 			ctx,
 			registryOrFactoryList[i].ABI,

pkg/source/platypus/pools_list_updater.go

@@ -12,6 +12,7 @@ import (
 	"github.com/KyberNetwork/logger"
 	"github.com/ethereum/go-ethereum/common"
 	"github.com/machinebox/graphql"
+	"github.com/samber/lo"
 
 	"github.com/KyberNetwork/kyberswap-dex-lib/pkg/entity"
 	graphqlpkg "github.com/KyberNetwork/kyberswap-dex-lib/pkg/util/graphql"
@@ -118,7 +119,8 @@ func (p *PoolsListUpdater) getPoolAddresses(
 		return nil, err
 	}
 
-	return response.Pools, nil
+	validPools := lo.Filter(response.Pools, func(p SubgraphPool, _ int) bool { return !strings.EqualFold(p.ID, addressZero) })
+	return validPools, nil
 }
 
 func (p *PoolsListUpdater) getPools(