feat(deployment): sign same wallet transactions in a batch

akash-network · Dec 12, 2024 · d5917c8 · d5917c8
1 parent 30f5f30
commit d5917c8
Showing 1 changed file with 19 additions and 22 deletions.
diff --git a/...t/services/stale-managed-deployments-cleaner/stale-managed-deployments-cleaner.service.ts b/...t/services/stale-managed-deployments-cleaner/stale-managed-deployments-cleaner.service.ts
@@ -54,30 +54,27 @@ export class StaleManagedDeploymentsCleanerService {
       createdHeight: currentHeight - this.MAX_LIVE_BLOCKS
     });
 
-    const closeAllWalletStaleDeployments = deployments.map(async deployment => {
-      const message = this.rpcMessageService.getCloseDeploymentMsg(wallet.address, deployment.dseq);
-      this.logger.info({ event: "DEPLOYMENT_CLEAN_UP", params: { owner: wallet.address, dseq: deployment.dseq } });
+    const messages = deployments.map(deployment => this.rpcMessageService.getCloseDeploymentMsg(wallet.address, deployment.dseq));
 
-      try {
-        await client.signAndBroadcast([message]);
-        this.logger.info({ event: "DEPLOYMENT_CLEAN_UP_SUCCESS" });
-      } catch (error) {
-        if (error.message.includes("not allowed to pay fees")) {
-          await this.managedUserWalletService.authorizeSpending({
-            address: wallet.address,
-            limits: {
-              fees: this.config.FEE_ALLOWANCE_REFILL_AMOUNT
-            }
-          });
+    this.logger.info({ event: "DEPLOYMENT_CLEAN_UP", owner: wallet.address });
 
-          await client.signAndBroadcast([message]);
-          this.logger.info({ event: "DEPLOYMENT_CLEAN_UP_SUCCESS" });
-        } else {
-          throw error;
-        }
-      }
-    });
+    try {
+      await client.signAndBroadcast(messages);
+      this.logger.info({ event: "DEPLOYMENT_CLEAN_UP_SUCCESS", owner: wallet.address });
+    } catch (error) {
+      if (error.message.includes("not allowed to pay fees")) {
+        await this.managedUserWalletService.authorizeSpending({
+          address: wallet.address,
+          limits: {
+            fees: this.config.FEE_ALLOWANCE_REFILL_AMOUNT
+          }
+        });
 
-    await Promise.all(closeAllWalletStaleDeployments);
+        await client.signAndBroadcast(messages);
+        this.logger.info({ event: "DEPLOYMENT_CLEAN_UP_SUCCESS", owner: wallet.address });
+      } else {
+        throw error;
+      }
+    }
   }
 }