Add implementation to runBlock

Author: acolytec3

packages/vm/src/runBlock.ts

@@ -22,6 +22,7 @@ import {
   equalsBytes,
   hexToBytes,
   intToBytes,
+  publicToAddress,
   setLengthLeft,
   short,
   unprefixedHexToBytes,
@@ -33,6 +34,7 @@ import { Bloom } from './bloom/index.ts'
 import { emitEVMProfile } from './emitEVMProfile.ts'
 import { runTx } from './index.ts'
 import { accumulateRequests } from './requests.ts'
+import { SignatureWorkerPool } from './worker/signatureWorkerPool.ts'
 
 import type { Block } from '@ethereumjs/block'
 import type { Common } from '@ethereumjs/common'
@@ -659,6 +661,37 @@ async function applyTransactions(vm: VM, block: Block, opts: RunBlockOpts) {
   const receipts: TxReceipt[] = []
   const txResults: RunTxResult[] = []
 
+  // Batch verify signatures if more than 100 transactions
+  if (block.transactions.length > 1) {
+    const workerPool = new SignatureWorkerPool()
+    const tasks = block.transactions.map((tx) => {
+      const msgHash = tx.getHashedMessageToSign()
+      if (Array.isArray(msgHash)) {
+        throw new Error('Transaction message hash cannot be an array')
+      }
+      return {
+        msgHash,
+        v: tx.v!,
+        r: bigIntToBytes(tx.r!),
+        s: bigIntToBytes(tx.s!),
+        chainId: tx.common.chainId(),
+      }
+    })
+
+    const results = await workerPool.processBatch(tasks)
+
+    // Override getSenderAddress for each transaction
+    block.transactions.forEach((tx, index) => {
+      const result = results.get(index)
+      if (result !== undefined) {
+        tx.getSenderAddress = () => new Address(publicToAddress(result.publicKey))
+      }
+    })
+
+    // Clean up worker pool
+    workerPool.terminate()
+  }
+
   /*
    * Process transactions
    */

packages/vm/src/worker/signatureWorkerPool.ts

@@ -20,8 +20,8 @@ export class SignatureWorkerPool {
 
   constructor(numWorkers: number = 4) {
     const workerCode = `
-            import { parentPort } from 'worker_threads'
-            import { ecrecover } from '@ethereumjs/util'
+            const { parentPort } = require('worker_threads')
+            const { ecrecover } = require('@ethereumjs/util')
 
             parentPort.on('message', (data) => {
                 const { tasks, taskId } = data

packages/vm/test/api/runBlock.spec.ts

@@ -683,7 +683,7 @@ describe('runBlock() -> tx types', async () => {
         to: defaultAuthAddr,
         value: BIGINT_1,
       },
-      { common },
+      { common, freeze: false },
     ).sign(defaultSenderPkey)
     const tx2 = createEOACode7702Tx(
       {
@@ -695,13 +695,13 @@ describe('runBlock() -> tx types', async () => {
         value: BIGINT_1,
         nonce: 1,
       },
-      { common },
+      { common, freeze: false },
     ).sign(defaultSenderPkey)
     const block = createBlock(
       {
         transactions: [tx1, tx2],
       },
-      { common, setHardfork: false, skipConsensusFormatValidation: true },
+      { common, setHardfork: false, skipConsensusFormatValidation: true, freeze: false },
     )
 
     await runBlock(vm, { block, skipBlockValidation: true, generate: true })