getting on-chain data via multicall3 with soft fails and batching

balancer-js/examples/data/onchain-multicall3.ts

@@ -0,0 +1,104 @@
+import { PoolsSubgraphRepository } from '@/modules/data/pool/subgraph'
+import { getOnChainBalances as getOnChainBalances3 } from '@/modules/sor/pool-data/onChainData3'
+import { SubgraphPoolBase } from '@/.'
+import { getOnChainBalances } from '@/modules/sor/pool-data/onChainData'
+import { JsonRpcProvider } from '@ethersproject/providers'
+import _ from 'lodash'
+
+const network = Network.MAINNET;
+
+const urls: Record<number, string> = {
+  [Network.MAINNET]:
+    'https://api.thegraph.com/subgraphs/name/balancer-labs/balancer-v2',
+  [Network.POLYGON]:
+    'https://api.thegraph.com/subgraphs/name/balancer-labs/balancer-polygon-v2',
+  [Network.ARBITRUM]:
+    'https://api.thegraph.com/subgraphs/name/balancer-labs/balancer-arbitrum-v2',
+  [Network.OPTIMISM]:
+    'https://api.thegraph.com/subgraphs/name/balancer-labs/balancer-optimism-v2',
+  [Network.GNOSIS]:
+    'https://api.thegraph.com/subgraphs/name/balancer-labs/balancer-gnosis-chain-v2',
+  [Network.AVALANCHE]:
+    'https://api.thegraph.com/subgraphs/name/balancer-labs/balancer-avalanche-v2',
+  [Network.BASE]:
+    'https://api.studio.thegraph.com/query/24660/balancer-base-v2/version/latest',
+  [Network.FANTOM]:
+    'https://api.thegraph.com/subgraphs/name/beethovenxfi/beethovenx-v2-fantom',
+  [Network.ZKEVM]:
+    'https://api.studio.thegraph.com/query/24660/balancer-polygon-zk-v2/version/latest',
+};
+
+const pools = new PoolsSubgraphRepository({
+  url: urls[network],
+  chainId: network,
+  query: {
+    args: {
+      first: 10,
+      skip: 0,
+      orderBy: 'totalLiquidity',
+      orderDirection: 'desc',
+      // where: {
+      //   poolType: {
+      //     eq: "MetaStable"
+      //   },
+      // },
+    },
+    attrs: {},
+  },
+});
+
+const providers: Record<number, JsonRpcProvider> = {
+  [Network.MAINNET]: new JsonRpcProvider('https://rpc.ankr.com/eth'),
+  [Network.POLYGON]: new JsonRpcProvider('https://rpc.ankr.com/polygon'),
+  [Network.ARBITRUM]: new JsonRpcProvider('https://rpc.ankr.com/arbitrum'),
+  [Network.OPTIMISM]: new JsonRpcProvider('https://rpc.ankr.com/optimism'),
+  [Network.BASE]: new JsonRpcProvider('https://rpc.ankr.com/base'),
+  [Network.FANTOM]: new JsonRpcProvider('https://rpc.ankr.com/fantom'),
+  [Network.ZKEVM]: new JsonRpcProvider('https://rpc.ankr.com/polygon_zkevm'),
+};
+
+const provider = providers[network];
+
+function findNestedValueDifferences(object1: any, object2: any, path = ''): any {
+  const allKeys = _.union(Object.keys(object1), Object.keys(object2))
+
+  const differences = []
+
+  for (const key of allKeys) {
+    const newPath = path ? `${path}.${key}` : key
+
+    if (_.isObject(object1[key]) && _.isObject(object2[key])) {
+      differences.push(...findNestedValueDifferences(object1[key], object2[key], newPath))
+    } else if (!_.isEqual(object1[key], object2[key])) {
+      differences.push({
+        path: newPath,
+        value1: object1[key],
+        value2: object2[key]
+      })
+    }
+  }
+
+  return differences
+}
+
+async function main() {
+  const subgraph = await pools.fetch() as SubgraphPoolBase[];
+  const onchain3 = await getOnChainBalances3(subgraph, '', '0xBA12222222228d8Ba445958a75a0704d566BF2C8', provider);
+  console.log(onchain3.length)
+  // const onchain = await getOnChainBalances(subgraph, '0xeefba1e63905ef1d7acba5a8513c70307c1ce441', '0xBA12222222228d8Ba445958a75a0704d566BF2C8', provider);
+  // console.log(onchain.length)
+  // for(const i in subgraph) {
+  //   const one = onchain3.find((x) => x.id === subgraph[i].id)
+  //   const two = onchain.find((x) => x.id === subgraph[i].id)
+  //   console.log('Pool', subgraph[i].id)
+  //   if (!two) {
+  //     console.log('two missing')
+  //     continue
+  //   }
+  //   console.log(JSON.stringify(findNestedValueDifferences(one, two), null, 2));
+  // }
+}
+
+main()
+
+// yarn example ./examples/data/onchain-multicall3.ts