add rr logs (#2143)

core/src/listener/listener.ts

@@ -1,5 +1,6 @@
 import { Job, Queue, Worker } from 'bullmq'
 import { ethers } from 'ethers'
+import { performance } from 'perf_hooks'
 import { Logger } from 'pino'
 import type { RedisClientType } from 'redis'
 import { BULLMQ_CONNECTION, LISTENER_JOB_SETTINGS } from '../settings'
@@ -358,6 +359,7 @@ function processEventJob({
   const _logger = logger.child({ name: 'processEventJob', file: FILE_NAME })
 
   async function wrapper(job: Job) {
+    const start = performance.now()
     const inData: IProcessEventListenerJob = job.data
     const { events, blockNumber } = inData
 
@@ -383,6 +385,11 @@ function processEventJob({
         blockNumber,
         service,
       })
+
+      if (events.length > 0) {
+        const endTime = performance.now()
+        _logger.info(`Passed ${events.length} events in ${endTime - start} ms`)
+      }
     } catch (e) {
       _logger.error(e, 'Error in user defined listener processing function')
       throw e

core/src/reporter/reporter.ts

@@ -83,6 +83,8 @@ export function reporter(state: State, logger: Logger) {
 
       txParams.nonce = localNonce
     }
+
+    logger.info(`Transaction sent to ${to} with nonce ${localNonce}`)
   }
 
   logger.debug('Reporter job built')

core/src/reporter/state.ts

@@ -284,6 +284,7 @@ export class State {
   async getAndIncrementNonce(oracleAddress: string): Promise<number> {
     return await this.mutex.runExclusive(async () => {
       const nonce = this.nonces[oracleAddress]
+      this.logger.info(`nonce for ${oracleAddress} is ${nonce}`)
       this.nonces[oracleAddress] = nonce + 1
 
       return nonce