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

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

@@ -0,0 +1,94 @@
+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 pools = new PoolsSubgraphRepository({
+  // url: 'https://api.thegraph.com/subgraphs/name/balancer-labs/balancer-v2',
+  // chainId: 1,
+  // url: 'https://api.thegraph.com/subgraphs/name/balancer-labs/balancer-polygon-v2',
+  // chainId: 137,
+  // url: 'https://api.thegraph.com/subgraphs/name/balancer-labs/balancer-arbitrum-v2',
+  // chainId: 42161,
+  // url: 'https://api.thegraph.com/subgraphs/name/balancer-labs/balancer-optimism-v2',
+  // chainId: 10,
+  // url: 'https://api.thegraph.com/subgraphs/name/balancer-labs/balancer-gnosis-chain-v2',
+  // chainId: 100,
+  // url: 'https://api.thegraph.com/subgraphs/name/balancer-labs/balancer-avalanche-v2',
+  // chainId: 43114,
+  url: 'https://api.studio.thegraph.com/query/24660/balancer-base-v2/version/latest',
+  chainId: 8453,
+  // url: 'https://api.thegraph.com/subgraphs/name/beethovenxfi/beethovenx-v2-fantom',
+  // chainId: 250,
+  // url: 'https://api.studio.thegraph.com/query/24660/balancer-polygon-zk-v2/version/latest',
+  // chainId: 1101,
+  query: {
+    args: {
+      first: 1000,
+      skip: 0,
+      orderBy: 'totalLiquidity',
+      orderDirection: 'desc',
+      // where: {
+      //   poolType: {
+      //     eq: "MetaStable"
+      //   },
+      // },
+    },
+    attrs: {},
+  },
+})
+
+// const provider = new JsonRpcProvider('https://rpc.ankr.com/eth')
+// const provider = new JsonRpcProvider('https://rpc.ankr.com/polygon')
+// const provider = new JsonRpcProvider('https://rpc.ankr.com/arbitrum')
+// const provider = new JsonRpcProvider('https://rpc.ankr.com/optimism')
+const provider = new JsonRpcProvider('https://rpc.ankr.com/base')
+// const provider = new JsonRpcProvider('https://rpc.ankr.com/fantom')
+// const provider = new JsonRpcProvider('http://127.0.0.1:8545')
+// const provider = new JsonRpcProvider('https://rpc.ankr.com/polygon_zkevm')
+
+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