Fetch assets Asynchronously (#1394)

* fetch in parallel * update packages
Snowfork · Feb 26, 2025 · 8db2aec · 8db2aec
1 parent 02605ad
commit 8db2aec
Show file tree

Hide file tree

Showing 4 changed files with 54 additions and 41 deletions.
diff --git a/web/packages/api/package.json b/web/packages/api/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@snowbridge/api",
-  "version": "0.1.35",
+  "version": "0.1.36",
   "description": "Snowbridge API client",
   "license": "Apache-2.0",
   "repository": {

diff --git a/web/packages/api/src/assets_v2.ts b/web/packages/api/src/assets_v2.ts
@@ -197,60 +197,73 @@ export async function buildRegistry(options: RegistryOptions): Promise<AssetRegi
     }
 
     const providers: { [paraIdKey: string]: { parachainId: number, provider: ApiPromise, managed: boolean } } = {}
-    for (const parachain of parachains) {
-        let provider: ApiPromise;
-        let managed = false
-        if (typeof parachain === "string") {
-            provider = await ApiPromise.create({
-                provider: parachain.startsWith("http") ? new HttpProvider(parachain) : new WsProvider(parachain),
-            })
-            managed = true
-        } else {
-            provider = parachain
-        }
-        const parachainId = await getParachainId(provider)
+    for (const { parachainId, provider, managed } of await Promise.all(
+        parachains.map(async parachain => {
+            let provider: ApiPromise;
+            let managed = false
+            if (typeof parachain === "string") {
+                provider = await ApiPromise.create({
+                    provider: parachain.startsWith("http") ? new HttpProvider(parachain) : new WsProvider(parachain),
+                })
+                managed = true
+            } else {
+                provider = parachain
+            }
+            const parachainId = await getParachainId(provider)
+            return { parachainId, provider, managed }
+        })
+    )) {
         providers[parachainId.toString()] = { parachainId, provider, managed }
     }
 
     const paras: ParachainMap = {}
-    for (const parachainIdKey of Object.keys(providers)) {
-        const { parachainId, provider } = providers[parachainIdKey]
-        const para = await indexParachain(
-            provider,
-            providers[assetHubParaId.toString()].provider,
-            ethChainId,
-            parachainId,
-            assetHubParaId,
-            assetOverrides ?? {},
-            destinationFeeOverrides ?? {})
+    for (const { parachainId, para } of await Promise.all(
+        Object.keys(providers).map(async parachainIdKey => {
+            const { parachainId, provider } = providers[parachainIdKey]
+            const para = await indexParachain(
+                provider,
+                providers[assetHubParaId.toString()].provider,
+                ethChainId,
+                parachainId,
+                assetHubParaId,
+                assetOverrides ?? {},
+                destinationFeeOverrides ?? {})
+            return { parachainId, para }
+        })
+    )) {
         paras[parachainId.toString()] = para;
     }
 
-    for (const parachainIdKey of Object.keys(providers)) {
-        if (providers[parachainIdKey].managed)
-            await providers[parachainIdKey].provider.disconnect()
-    }
+    await Promise.all(
+        Object.keys(providers)
+            .filter(parachainKey => providers[parachainKey].managed)
+            .map(async parachainKey => await providers[parachainKey].provider.disconnect())
+    )
 
     if (!(assetHubParaId.toString() in paras)) {
         throw Error(`Could not resolve asset hub para id ${assetHubParaId} in the list of parachains provided.`)
     }
 
     const ethChains: { [chainId: string]: EthereumChain } = {}
-    for (const ethChain of ethchains) {
-        let provider: AbstractProvider;
-        if (typeof ethChain === "string") {
-            provider = ethers.getDefaultProvider(ethChain)
-        } else {
-            provider = ethChain
-        }
+    for (const ethChainInfo of await Promise.all(
+        ethchains.map(async ethChain => {
+            let provider: AbstractProvider;
+            if (typeof ethChain === "string") {
+                provider = ethers.getDefaultProvider(ethChain)
+            } else {
+                provider = ethChain
+            }
+            const ethChainInfo = await indexEthChain(provider, ethChainId, gatewayAddress, assetHubParaId, paras, precompiles ?? {})
 
-        const ethChainInfo = await indexEthChain(provider, ethChainId, gatewayAddress, assetHubParaId, paras, precompiles ?? {})
+            if (typeof ethChain === "string") {
+                provider.destroy()
+            }
+            return ethChainInfo
+        })
+    )) {
         ethChains[ethChainInfo.chainId.toString()] = ethChainInfo;
-
-        if (typeof ethChain === "string") {
-            provider.destroy()
-        }
     }
+
     if (!(ethChainId in ethChains)) {
         throw Error(`Cannot find ethereum chain ${ethChainId} in the list of ethereum chains.`)
     }

diff --git a/web/packages/contract-types/package.json b/web/packages/contract-types/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@snowbridge/contract-types",
-  "version": "0.1.35",
+  "version": "0.1.36",
   "description": "Snowbridge contract type bindings",
   "license": "Apache-2.0",
   "repository": {

diff --git a/web/packages/contracts/package.json b/web/packages/contracts/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@snowbridge/contracts",
-  "version": "0.1.35",
+  "version": "0.1.36",
   "description": "Snowbridge contract source and abi.",
   "license": "Apache-2.0",
   "repository": {