fix OOM by limiting concurrency

Author: juliangruber

index.js

@@ -1,5 +1,6 @@
 import assert from 'node:assert'
 import ms from 'ms'
+import pSettle from 'p-settle'
 
 export const cancelTx = ({
   tx,
@@ -123,11 +124,14 @@ export class StuckTransactionsCanceller {
       ')'
     )
 
-    return Promise.allSettled(txsToCancel.map(tx => this.#cancelTx({
-      tx,
-      recentGasLimit: recentSendMessage.gasLimit,
-      recentGasFeeCap: Number(recentSendMessage.gasFeeCap)
-    })))
+    return pSettle(
+      txsToCancel.map(tx => this.#cancelTx({
+        tx,
+        recentGasLimit: recentSendMessage.gasLimit,
+        recentGasFeeCap: Number(recentSendMessage.gasFeeCap)
+      })),
+      { concurrency: 50 }
+    )
   }
 
   async #cancelTx ({ tx, recentGasLimit, recentGasFeeCap }) {

package-lock.json

@@ -20,6 +20,7 @@
     "standard": "^17.1.2"
   },
   "dependencies": {
-    "ms": "^2.1.3"
+    "ms": "^2.1.3",
+    "p-settle": "^5.1.1"
   }
 }

package.json

@@ -163,7 +163,9 @@ test('StuckTransactionsCanceller', async t => {
       const status = await stuckTransactionsCanceller.cancelOlderThan(0)
       assert.deepStrictEqual(status, [{
         status: 'fulfilled',
-        value: undefined
+        value: undefined,
+        isFulfilled: true,
+        isRejected: false
       }])
       assert.strictEqual(sentTransactions.length, 1)
       const sentTransactionClone = { ...sentTransactions[0] }