add an unchanging block frequency so that validations have a more sta…

…ble environment

src/polyfills/rpc-issues.ts

@@ -13,16 +13,19 @@ RpcClient.prototype.call = async function <T = any>(
   params?: any[],
   options?: CallOptions<T>,
 ): Promise<T> {
+  const time = Date.now()
   processingStats.rpcCalls++
   const response = await (this as any)._call(method, params, options)
   if (method === 'debug_traceBlockByHash') {
     fixSelfDestructs(response)
   }
   // fs.writeFileSync(`rpcResponse${count}-in.json`, JSON.stringify({ method, params, options }, null, 2))
   // fs.writeFileSync(`rpcResponse${count++}.json`, JSON.stringify(response, null, 2))
+  processingStats.rpcCallTime += Date.now() - time
   return response
 }
 RpcClient.prototype.batchCall = async function <T = any>(batch: RpcCall[], options?: CallOptions<T>): Promise<T[]> {
+  const time = Date.now()
   processingStats.rpcCalls += batch.length
   const response = await (this as any)._batchCall(batch, options)
   for (let i = 0; i < batch.length; i++) {
@@ -32,6 +35,7 @@ RpcClient.prototype.batchCall = async function <T = any>(batch: RpcCall[], optio
   }
   // fs.writeFileSync(`rpcResponse$${count}-in.json`, JSON.stringify({ batch, options }, null, 2))
   // fs.writeFileSync(`rpcResponse$${count++}.json`, JSON.stringify(response, null, 2))
+  processingStats.rpcCallTime += Date.now() - time
   return response
 }
 

src/utils/blockFrequencyUpdater.ts

@@ -49,7 +49,7 @@ export const blockFrequencyTracker = (params: { from: number }) => {
       (ctx._chain.client as any).url.includes('tenderly') ||
       // Normal logic down below.
       block.header.height % frequency === 0 ||
-      block.header.height % 100000 || // For validation generation we need something reliable and unchanging.
+      block.header.height % 100000 === 0 || // For validation generation we need something reliable and unchanging.
       isAerodromeImportantBlock(ctx, block)
     )
   }

src/utils/processing-stats.ts

@@ -2,12 +2,14 @@ import { Context } from '@processor'
 
 export const processingStats = {
   rpcCalls: 0,
+  rpcCallTime: 0,
 }
 
 export const printStats = (ctx: Context) => {
   if (process.env.DEBUG_PERF === 'true') {
     ctx.log.info({
       ...processingStats,
+      averageRpcCallTime: processingStats.rpcCallTime / processingStats.rpcCalls,
       blockCount: ctx.blocks.length,
       blockCountWithContent: ctx.blocksWithContent.length,
       frequencyBlockCount: ctx.frequencyBlocks.length,
@@ -17,4 +19,5 @@ export const printStats = (ctx: Context) => {
     })
   }
   processingStats.rpcCalls = 0
+  processingStats.rpcCallTime = 0
 }