Publish

- @0x/contracts-integrations@2.7.55
 - @0x/asset-swapper@16.19.0

contracts/integrations/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@0x/contracts-integrations",
-    "version": "2.7.53",
+    "version": "2.7.55",
     "private": true,
     "engines": {
         "node": ">=6.12"
@@ -93,7 +93,7 @@
         "typescript": "4.2.2"
     },
     "dependencies": {
-        "@0x/asset-swapper": "^6.18.2",
+        "@0x/asset-swapper": "^16.19.0",
         "@0x/base-contract": "^6.4.0",
         "@0x/contracts-asset-proxy": "^3.7.16",
         "@0x/contracts-erc1155": "^2.1.34",

packages/asset-swapper/CHANGELOG.json

@@ -1,4 +1,23 @@
 [
+    {
+        "version": "16.19.0",
+        "changes": [
+            {
+                "note": "Add LiquidityProvider to Polygon sources",
+                "pr": 270
+            }
+        ],
+        "timestamp": 1625190486
+    },
+    {
+        "version": "6.18.3",
+        "changes": [
+            {
+                "note": "Polygon Balance V2"
+            }
+        ],
+        "timestamp": 1624987208
+    },
     {
         "timestamp": 1624562704,
         "version": "6.18.2",

packages/asset-swapper/CHANGELOG.md

@@ -5,6 +5,14 @@ Edit the package's CHANGELOG.json file only.
 
 CHANGELOG
 
+## v16.19.0 - _July 2, 2021_
+
+    * Add LiquidityProvider to Polygon sources (#270)
+
+## v6.18.3 - _June 29, 2021_
+
+    * Polygon Balance V2
+
 ## v6.18.2 - _June 24, 2021_
 
     * Dependencies updated

packages/asset-swapper/contracts/src/KyberDmmSampler.sol

@@ -20,12 +20,20 @@
 pragma solidity ^0.6;
 pragma experimental ABIEncoderV2;
 
-interface IKyberDmmFactory {
+interface IKyberDmmPool {
 
-    function getPoolAtIndex(address token0, address token1, uint256 index)
+    function totalSupply()
         external
         view
-        returns (address);
+        returns (uint256);
+}
+
+interface IKyberDmmFactory {
+
+    function getPools(address token0, address token1)
+        external
+        view
+        returns (address[] memory _tokenPools);
 }
 
 interface IKyberDmmRouter {
@@ -140,17 +148,26 @@ contract KyberDmmSampler
         view
         returns (address[] memory pools)
     {
-        pools = new address[](path.length - 1);
         IKyberDmmFactory factory = IKyberDmmFactory(IKyberDmmRouter(router).factory());
+        pools = new address[](path.length - 1);
         for (uint256 i = 0; i < pools.length; i++) {
-            // Currently only supporting the first pool found at the index
+            // find the best pool
+            address[] memory allPools;
             try
-                factory.getPoolAtIndex
+                factory.getPools
                     {gas: KYBER_DMM_CALL_GAS}
-                    (path[i], path[i + 1], 0)
-                returns (address pool)
+                    (path[i], path[i + 1])
+                returns (address[] memory allPools)
             {
-                pools[i] = pool;
+                uint256 maxSupply = 0;
+                require(allPools.length >= 1, "KyberDMMSampler/NO_POOLS_FOUND");
+                for (uint256 j = 0; j < allPools.length; j++) {
+                    uint256 totalSupply = IKyberDmmPool(allPools[j]).totalSupply();
+                    if (totalSupply > maxSupply) {
+                        maxSupply = totalSupply;
+                        pools[i] = allPools[j];
+                    }
+                }
             } catch (bytes memory) {
                 return new address[](0);
             }

packages/asset-swapper/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@0x/asset-swapper",
-    "version": "6.18.2",
+    "version": "16.19.0",
     "engines": {
         "node": ">=6.12"
     },

packages/asset-swapper/src/utils/market_operation_utils/constants.ts

@@ -146,6 +146,9 @@ export const SELL_SOURCE_FILTER_BY_CHAIN_ID = valueByChainId<SourceFilters>(
             ERC20BridgeSource.Polydex,
             ERC20BridgeSource.ApeSwap,
             ERC20BridgeSource.FirebirdOneSwap,
+            ERC20BridgeSource.BalancerV2,
+            ERC20BridgeSource.KyberDmm,
+            ERC20BridgeSource.LiquidityProvider,
         ]),
     },
     new SourceFilters([]),
@@ -237,6 +240,9 @@ export const BUY_SOURCE_FILTER_BY_CHAIN_ID = valueByChainId<SourceFilters>(
             ERC20BridgeSource.Polydex,
             ERC20BridgeSource.ApeSwap,
             ERC20BridgeSource.FirebirdOneSwap,
+            ERC20BridgeSource.BalancerV2,
+            ERC20BridgeSource.KyberDmm,
+            ERC20BridgeSource.LiquidityProvider,
         ]),
     },
     new SourceFilters([]),
@@ -1135,6 +1141,7 @@ export const OASIS_ROUTER_BY_CHAIN_ID = valueByChainId<string>(
 export const KYBER_DMM_ROUTER_BY_CHAIN_ID = valueByChainId<string>(
     {
         [ChainId.Mainnet]: '0x1c87257f5e8609940bc751a07bb085bb7f8cdbe6',
+        [ChainId.Polygon]: '0x546c79662e028b661dfb4767664d0273184e4dd1',
     },
     NULL_ADDRESS,
 );
@@ -1283,6 +1290,7 @@ export const COMPONENT_POOLS_BY_CHAIN_ID = valueByChainId(
 export const BALANCER_V2_VAULT_ADDRESS_BY_CHAIN = valueByChainId<string>(
     {
         [ChainId.Mainnet]: '0xba12222222228d8ba445958a75a0704d566bf2c8',
+        [ChainId.Polygon]: '0xba12222222228d8ba445958a75a0704d566bf2c8',
     },
     NULL_ADDRESS,
 );
@@ -1303,7 +1311,13 @@ export const LIDO_INFO_BY_CHAIN = valueByChainId<LidoInfo>(
 export const BALANCER_SUBGRAPH_URL = 'https://api.thegraph.com/subgraphs/name/balancer-labs/balancer';
 export const BALANCER_TOP_POOLS_FETCHED = 250;
 export const BALANCER_MAX_POOLS_FETCHED = 3;
-export const BALANCER_V2_SUBGRAPH_URL = 'https://api.thegraph.com/subgraphs/name/balancer-labs/balancer-v2';
+
+export const BALANCER_V2_SUBGRAPH_URL_BY_CHAIN = valueByChainId<string>(
+    {
+        [ChainId.Polygon]: 'https://api.thegraph.com/subgraphs/name/balancer-labs/balancer-polygon-v2',
+    },
+    'https://api.thegraph.com/subgraphs/name/balancer-labs/balancer-v2',
+);
 
 export const UNISWAPV3_CONFIG_BY_CHAIN_ID = valueByChainId(
     {

packages/asset-swapper/src/utils/market_operation_utils/pools_cache/balancer_v2_utils.ts

@@ -1,3 +1,4 @@
+import { ChainId } from '@0x/contract-addresses';
 import { BigNumber } from '@0x/utils';
 // import { parsePoolData } from '@balancer-labs'; // TODO - upgrade to v2
 import { Pool } from '@balancer-labs/sor/dist/types';
@@ -5,7 +6,11 @@ import { gql, request } from 'graphql-request';
 
 import { DEFAULT_WARNING_LOGGER } from '../../../constants';
 import { LogFunction } from '../../../types';
-import { BALANCER_MAX_POOLS_FETCHED, BALANCER_TOP_POOLS_FETCHED, BALANCER_V2_SUBGRAPH_URL } from '../constants';
+import {
+    BALANCER_MAX_POOLS_FETCHED,
+    BALANCER_TOP_POOLS_FETCHED,
+    BALANCER_V2_SUBGRAPH_URL_BY_CHAIN,
+} from '../constants';
 
 import { parsePoolData } from './balancer_sor_v2';
 import { CacheValue, PoolsCache } from './pools_cache';
@@ -45,7 +50,8 @@ export class BalancerV2PoolsCache extends PoolsCache {
     }
 
     constructor(
-        private readonly subgraphUrl: string = BALANCER_V2_SUBGRAPH_URL,
+        chainId: ChainId,
+        private readonly subgraphUrl: string = BALANCER_V2_SUBGRAPH_URL_BY_CHAIN[chainId],
         private readonly maxPoolsFetched: number = BALANCER_MAX_POOLS_FETCHED,
         private readonly _topPoolsFetched: number = BALANCER_TOP_POOLS_FETCHED,
         private readonly _warningLogger: LogFunction = DEFAULT_WARNING_LOGGER,

packages/asset-swapper/src/utils/market_operation_utils/sampler_operations.ts

@@ -122,7 +122,7 @@ export class SamplerOperations {
         this.poolsCaches = poolsCaches
             ? poolsCaches
             : {
-                  [ERC20BridgeSource.BalancerV2]: new BalancerV2PoolsCache(),
+                  [ERC20BridgeSource.BalancerV2]: new BalancerV2PoolsCache(chainId),
                   [ERC20BridgeSource.Balancer]: new BalancerPoolsCache(),
                   [ERC20BridgeSource.Cream]: new CreamPoolsCache(),
               };

packages/asset-swapper/test/pools_cache_test.ts

@@ -1,3 +1,4 @@
+import { ChainId } from '@0x/contract-addresses';
 import * as chai from 'chai';
 import 'mocha';
 
@@ -49,7 +50,7 @@ describe('Pools Caches for Balancer-based sampling', () => {
     });
 
     describe('BalancerV2PoolsCache', () => {
-        const cache = new BalancerV2PoolsCache();
+        const cache = new BalancerV2PoolsCache(ChainId.Mainnet);
         it('fetches pools', async () => {
             const pairs = [
                 [wethAddress, wbtcAddress],