additional processing stats

OriginProtocol · Mar 4, 2025 · 61d78b4 · 61d78b4
1 parent ca0f67f
commit 61d78b4
Show file tree

Hide file tree

Showing 10 changed files with 14 additions and 5 deletions.
diff --git a/lib/calculateBlockRate.js b/lib/calculateBlockRate.js
diff --git a/lib/calculateBlockRate.js.map b/lib/calculateBlockRate.js.map
diff --git a/lib/polyfills/rpc-issues.js b/lib/polyfills/rpc-issues.js
diff --git a/lib/polyfills/rpc-issues.js.map b/lib/polyfills/rpc-issues.js.map
diff --git a/lib/processing-stats.d.ts b/lib/processing-stats.d.ts
@@ -2,5 +2,6 @@ import { Context } from './types';
 export declare const processingStats: {
     rpcCalls: number;
     rpcCallTime: number;
+    rpcCallTypes: Map<string, number>;
 };
 export declare const printStats: (ctx: Context) => void;
diff --git a/lib/processing-stats.js b/lib/processing-stats.js
diff --git a/lib/processing-stats.js.map b/lib/processing-stats.js.map
diff --git a/src/calculateBlockRate.ts b/src/calculateBlockRate.ts
@@ -33,5 +33,5 @@ export const calculateBlockRate = async (ctx: Context) => {
     lastContextBlock = latestBlock.header
   }
 
-  return blockRateResult
+  return blockRateResult || 1
 }
diff --git a/src/polyfills/rpc-issues.ts b/src/polyfills/rpc-issues.ts
@@ -21,6 +21,7 @@ RpcClient.prototype.call = async function <T = any>(
   // 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
+  processingStats.rpcCallTypes.set(method, (processingStats.rpcCallTypes.get(method) ?? 0) + 1)
   return response
 }
 RpcClient.prototype.batchCall = async function <T = any>(batch: RpcCall[], options?: CallOptions<T>): Promise<T[]> {
@@ -35,6 +36,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
+  processingStats.rpcCallTypes.set(batch[0].method, (processingStats.rpcCallTypes.get(batch[0].method) ?? 0) + batch.length)
   return response
 }
 

diff --git a/src/processing-stats.ts b/src/processing-stats.ts
@@ -3,6 +3,7 @@ import { Context } from './types'
 export const processingStats = {
   rpcCalls: 0,
   rpcCallTime: 0,
+  rpcCallTypes: new Map<string, number>(),
 }
 
 export const printStats = (ctx: Context) => {
@@ -20,4 +21,5 @@ export const printStats = (ctx: Context) => {
   }
   processingStats.rpcCalls = 0
   processingStats.rpcCallTime = 0
+  processingStats.rpcCallTypes.clear()
 }