Merge to master

app/Cli.ts

@@ -17,11 +17,10 @@ let app: App;
   const version = await getVersion(__dirname);
   console.log(`PowerPool Agent Node version: ${version}`);
 
-  let config: Config;
-  let configPath;
+  let config: Config, configPath: string;
 
   try {
-    const configPath = process.env.CONFIG_PATH || path.resolve(__dirname, '../config/main.yaml');
+    configPath = process.env.CONFIG_PATH || path.resolve(__dirname, '../config/main.yaml');
     logger.info(`CLI: Reading configuration from ${configPath} ...`);
     config = YAML.parse(fs.readFileSync(configPath).toString()) as Config;
   } catch (error) {

app/ConfigGetters.ts

@@ -98,6 +98,10 @@ export function getMaxBlocksSubgraphDelay(_ /*networkName*/) {
   return 10000;
 }
 
+export function getMaxBlockEventsQuery(_ /*networkName*/) {
+  return 4900;
+}
+
 export function setConfigDefaultValues(config, defaultValues) {
   Object.keys(defaultValues).forEach(name => {
     if (typeof config[name] === 'undefined') {

app/Constants.ts

@@ -41,6 +41,16 @@ export const AGENT_HARDCODED_CONFIGS: { [network: string]: { [agent: string]: Ag
       version: '2.5.0',
       strategy: 'randao',
     },
+    '0xD6d094a2a2dB8ceB9c00ae719E37011f22B7a8Ac': {
+      deployedAt: 37155151,
+      version: '2.5.0',
+      strategy: 'randao',
+    },
+    '0xa7Dabab40BAe7a920C437483549f42762815DBA2': {
+      deployedAt: 37312227,
+      version: '2.5.0',
+      strategy: 'randao',
+    },
   },
   arbitrumOne: {
     '0xad1e507f8A0cB1B91421F3bb86BBE29f001CbcC6': {
@@ -63,20 +73,45 @@ export const AGENT_HARDCODED_CONFIGS: { [network: string]: { [agent: string]: Ag
       version: '2.5.0',
       strategy: 'randao',
     },
+    '0x0eBcc7B676E2b29971173CECA72De79853124879': {
+      deployedAt: 280364988,
+      version: '2.5.0',
+      strategy: 'randao',
+    },
   },
   polygon: {
     '0x20D4029c783D5c9f47569940c656Af4189e53799': {
       deployedAt: 52818115,
       version: '2.3.0',
       strategy: 'randao',
     },
+    '0xCDF80C73640a756D0810babA52F3d01280e5be32': {
+      deployedAt: 64973530,
+      version: '2.5.0',
+      strategy: 'randao',
+    },
+    '0xCB2A4200a0B42018FeAb87815B1AACB0eB2Ce638': {
+      deployedAt: 64973715,
+      version: '2.5.0',
+      strategy: 'randao',
+    },
   },
   base: {
     '0x12e49CeDc34C4F455e0dfff7ec38cC535Cbd07C2': {
       deployedAt: 14835289,
       version: '2.3.0',
       strategy: 'randao',
     },
+    '0xcD7D8e8Fe442253Fa65A3BFcdF12cdCD0013631a': {
+      deployedAt: 22752546,
+      version: '2.5.0',
+      strategy: 'randao',
+    },
+    '0x59ad18f31Ad6AC183d136AF4d7aDAc01b6cC4421': {
+      deployedAt: 23155296,
+      version: '2.5.0',
+      strategy: 'randao',
+    },
   },
   linea: {
     '0x20D4029c783D5c9f47569940c656Af4189e53799': {
@@ -89,6 +124,11 @@ export const AGENT_HARDCODED_CONFIGS: { [network: string]: { [agent: string]: Ag
       version: '2.3.0',
       strategy: 'randao',
     },
+    '0x98D73653D64Ea1779C616A823064CA4da05dAD86': {
+      deployedAt: 12787200,
+      version: '2.5.0',
+      strategy: 'randao',
+    },
   },
   goerli: {
     '0x96cb9B293eB7695904B4Ea0FA73eB3650e07e8E4': {
@@ -203,6 +243,16 @@ export const AGENT_HARDCODED_CONFIGS: { [network: string]: { [agent: string]: Ag
       version: '2.3.0',
       strategy: 'randao',
     },
+    '0xd78521F50D252b6075B3c05C6A3043ea4bE0E52B': {
+      deployedAt: 7190875,
+      version: '2.5.0',
+      strategy: 'randao',
+    },
+    '0x518D1741F4B1bf1f859E64dd4B52047e9Dd2d499': {
+      deployedAt: 7190881,
+      version: '2.5.0',
+      strategy: 'randao',
+    },
   },
 };
 

app/Network.ts

@@ -15,6 +15,7 @@ import {
   getAverageBlockTime,
   getDefaultNetworkConfig,
   getExternalLensAddress,
+  getMaxBlockEventsQuery,
   getMulticall2Address,
   getResolverCallSkipBlocksNumber,
   setConfigDefaultValues,
@@ -402,8 +403,8 @@ export class Network {
 
         if (this.contractEventsEmitter.blockLogsMode) {
           this.contractEventsEmitter.emitByBlockQuery({
-            fromBlock: Number(this.agentsStartBlockNumber) + 1,
-            toBlock: Number(this.agentsStartBlockNumber) + count,
+            fromBlock: startBlockNumber + 1,
+            toBlock: startBlockNumber + count,
           });
         }
 
@@ -484,7 +485,7 @@ export class Network {
     blockNumber = BigInt(blockNumber.toString());
     const before = this.nowMs();
 
-    const oldLatestBlockNumber = this.latestBlockNumber ? BigInt(this.latestBlockNumber) : null;
+    let oldLatestBlockNumber = this.latestBlockNumber ? BigInt(this.latestBlockNumber) : null;
     if (this.latestBlockNumber && blockNumber <= this.latestBlockNumber) {
       return null;
     }
@@ -505,6 +506,9 @@ export class Network {
 
     if (this.contractEventsEmitter.blockLogsMode) {
       const blocksDiff = oldLatestBlockNumber ? blockNumber - oldLatestBlockNumber : 0n;
+      if (blocksDiff > getMaxBlockEventsQuery(this.name)) {
+        oldLatestBlockNumber = blockNumber - BigInt(getMaxBlockEventsQuery(this.name));
+      }
       const fromBlock = bigintToHex(blocksDiff > 1n ? oldLatestBlockNumber + 1n : blockNumber);
       const toBlock = bigintToHex(blockNumber);
       this.contractEventsEmitter.emitByBlockQuery({ fromBlock, toBlock });
@@ -594,6 +598,7 @@ export class Network {
     // TODO: protect from handlers queueing on the networks with < 3s block time
     const resolversToCall = [];
     const callbacks = [];
+
     for (const [jobKey, jobData] of Object.entries(this.resolverJobData)) {
       callbacks.push(jobData.callback);
       resolversToCall.push({
@@ -622,6 +627,13 @@ export class Network {
     for (let i = 0; i < results.length; i++) {
       const { jobKey } = resolversToCall[i];
       const agent = this.getAgent(jobKey.split('/')[0]);
+
+      // Watch job in case of blockchain node lag
+      if (!this.resolverJobData[jobKey]) {
+        const jobEntity = await agent.getJob(jobKey.split('/')[1]);
+        jobEntity.watch();
+      }
+
       let decoded;
       try {
         decoded = results[i].success

app/jobs/AbstractJob.ts

@@ -319,6 +319,7 @@ export abstract class AbstractJob {
         e.message.includes('Tx not mined, max attempts') ||
         e.message.includes('Too many requests') ||
         e.message.includes('InsufficientFunds') ||
+        e.message.includes('exceeds the configured cap') ||
         e.message.toLowerCase().includes('insufficient funds') ||
         e.message.includes('could not replace existing tx') ||
         e.message.includes('replacement fee too low') ||