Merge pull request #2867 from w3f/will-update-eras

Query only past 84 eras of Era Points

Author: ironoa

packages/common/src/constants.ts

@@ -207,3 +207,5 @@ export const USE_PROVIDER = true;
 export const USE_NOMINATIONS = true;
 export const USE_RPC = true;
 export const USE_CLIENT = true;
+
+export const ERAPOINTS_JOB_MAX_ERAS = 84;

packages/common/src/scorekeeper/jobs/specificJobs/EraPointsJob.ts

@@ -1,4 +1,4 @@
-import { ChainData, logger, queries } from "../../../index";
+import { ChainData, Constants, logger, queries } from "../../../index";
 import { Job, JobConfig, JobRunnerMetadata, JobStatus } from "../JobsClass";
 import { jobStatusEmitter } from "../../../Events";
 import { withExecutionTimeLogging } from "../../../utils";
@@ -63,16 +63,15 @@ export const eraPointsJob = async (
     //    - if a record doesn't exist, create it
     const [activeEra, err] = await chaindata.getActiveEraIndex();
 
-    // Calculate total number of eras to process
-    const totalEras = activeEra;
-    let processedEras = 0;
-
-    for (let i = activeEra - 1; i >= 0; i--) {
+    for (
+      let i = activeEra - 1, processedEras = 1;
+      i >= activeEra - Constants.ERAPOINTS_JOB_MAX_ERAS;
+      i--, processedEras++
+    ) {
       await individualEraPointsJob(chaindata, i);
 
       // Calculate progress percentage
-      processedEras++;
-      const progress = (processedEras / totalEras) * 100;
+      const progress = (processedEras / Constants.ERAPOINTS_JOB_MAX_ERAS) * 100;
 
       // Emit progress update with active era as iteration
       jobStatusEmitter.emit("jobProgress", {