Trying to broacast pending pegouts

lib/rsk-utils.js

@@ -144,6 +144,21 @@ const printFedsLatestBlocks = async (rskTransactionHelpers) => {
   console.log('fedLatestBlockNumbers: ', fedLatestBlockNumbers);
 };
 
+const waitForPegoutWaitingForSignaturesToBeEmpty = async (rskTransactionHelpers) => {
+  const rskTxHelper = rskTransactionHelpers[rskTransactionHelpers.length - 1];
+  const method = async () => {
+    const currentBridgeState = await getBridgeState(rskTxHelper.getClient());
+    if(currentBridgeState.pegoutsWaitingForSignatures.length === 0) {
+      return true; // Returning true to stop the retryWithCheck loop early
+    }
+    await wait(1000);
+    await mineAndSync(rskTransactionHelpers);
+    return false; // Returning false to make the retryWithCheck loop continue until this check returns true or it reaches the max attempts
+  };
+  const wasPegoutBroadcasted = await retryWithCheck(method, pegoutIsBroadcasted => pegoutIsBroadcasted, MAX_ATTEMPTS, CHECK_EVERY_MILLISECONDS);
+  return wasPegoutBroadcasted;
+};
+
 /**
  * 
  * @param {Array<RskTransactionHelper>} rskTransactionHelpers RskTransactionHelper instances each belonging to one federator node to make calls to the rsk network
@@ -196,18 +211,18 @@ const triggerRelease = async (rskTransactionHelpers, btcClient, callbacks = {})
 
   await printFedsLatestBlocks(rskTransactionHelpers);
 
-  const method = async () => {
-    const currentBridgeState = await getBridgeState(rskTxHelper.getClient());
-    if(currentBridgeState.pegoutsWaitingForSignatures.length === 0) {
-      return true; // Returning true to stop the retryWithCheck loop early
-    }
-    await wait(1000);
-    await mineAndSync(rskTransactionHelpers);
-    return false; // Returning false to make the retryWithCheck loop continue until this check returns true or it reaches the max attempts
-  };
+  // const method = async () => {
+  //   const currentBridgeState = await getBridgeState(rskTxHelper.getClient());
+  //   if(currentBridgeState.pegoutsWaitingForSignatures.length === 0) {
+  //     return true; // Returning true to stop the retryWithCheck loop early
+  //   }
+  //   await wait(1000);
+  //   await mineAndSync(rskTransactionHelpers);
+  //   return false; // Returning false to make the retryWithCheck loop continue until this check returns true or it reaches the max attempts
+  // };
 
 
-  const wasPegoutBroadcasted = await retryWithCheck(method, pegoutIsBroadcasted => pegoutIsBroadcasted, MAX_ATTEMPTS, CHECK_EVERY_MILLISECONDS);
+  const wasPegoutBroadcasted = await waitForPegoutWaitingForSignaturesToBeEmpty(rskTransactionHelpers);
 
   await printFedsLatestBlocks(rskTransactionHelpers);
 
@@ -238,6 +253,10 @@ const triggerRelease = async (rskTransactionHelpers, btcClient, callbacks = {})
 
   await printFedsLatestBlocks(rskTransactionHelpers);
 
+  const anyPendingPegoutsWaitingForSignaturesBroadcasted = await waitForPegoutWaitingForSignaturesToBeEmpty(rskTransactionHelpers);
+
+  console.log('anyPendingPegoutsWaitingForSignaturesBroadcasted: ', anyPendingPegoutsWaitingForSignaturesBroadcasted);
+
 };
 
 /**