ci: setupPeer per chain in parallel

wormhole-foundation · Dec 4, 2024 · 69a2d17 · 69a2d17
1 parent a80ba8a
commit 69a2d17
Showing 1 changed file with 28 additions and 23 deletions.
diff --git a/sdk/__tests__/utils.ts b/sdk/__tests__/utils.ts
@@ -140,29 +140,34 @@ export async function link(chainInfos: Ctx[]) {
   const registrations: [string, string, VAA<"Ntt:TransceiverRegistration">][] =
     [];
 
-  for (const targetInfo of chainInfos) {
-    const toRegister = chainInfos.filter(
-      (peerInfo) => peerInfo.context.chain !== targetInfo.context.chain
-    );
-
-    console.log(
-      "Registering peers for ",
-      targetInfo.context.chain,
-      ": ",
-      toRegister.map((x) => x.context.chain)
-    );
-
-    for (const peerInfo of toRegister) {
-      const vaa = await setupPeer(targetInfo, peerInfo);
-      if (!vaa) throw new Error("No VAA found");
-      // Add to registrations by PEER chain so we can register hub first
-      registrations.push([
-        targetInfo.context.chain,
-        peerInfo.context.chain,
-        vaa,
-      ]);
-    }
-  }
+  // register each chain in parallel
+  await Promise.all(
+    chainInfos.map((targetInfo) =>
+      (async () => {
+        const toRegister = chainInfos.filter(
+          (peerInfo) => peerInfo.context.chain !== targetInfo.context.chain
+        );
+
+        console.log(
+          "Registering peers for ",
+          targetInfo.context.chain,
+          ": ",
+          toRegister.map((x) => x.context.chain)
+        );
+
+        for (const peerInfo of toRegister) {
+          const vaa = await setupPeer(targetInfo, peerInfo);
+          if (!vaa) throw new Error("No VAA found");
+          // Add to registrations by PEER chain so we can register hub first
+          registrations.push([
+            targetInfo.context.chain,
+            peerInfo.context.chain,
+            vaa,
+          ]);
+        }
+      })()
+    )
+  );
 
   // Push Hub to Spoke registrations
   const hubToSpokeRegistrations = registrations.filter(