fix small bug related to xdc-zero

XinFinOrg · Dec 6, 2023 · 915edda · 915edda
1 parent a9e63f1
commit 915edda
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 5 deletions.
diff --git a/src/processors/standard.ts b/src/processors/standard.ts
@@ -72,7 +72,7 @@ export class Standard implements ProcessorInterface {
         this.cache.setLastSubmittedSubnetHeader(lastestSubnetCommittedBlock);
       }
       // Keep the "jobId: NAME" and its repeat configuration here so that bull won't create a new repeated job each time we run this code.
-      (await this.queue.add({}, REPEAT_JOB_OPT)).name;
+      await this.queue.add({}, REPEAT_JOB_OPT);
     } catch (error) {
       this.logger.error(
         `Error while bootstraping, system will go into sleep mode for ${
@@ -81,7 +81,6 @@ export class Standard implements ProcessorInterface {
       );
       await sleep(config.reBootstrapWaitingTime);
       this.reset();
-      // TODO: Add back the notification
     }
   }
 

diff --git a/src/processors/zero.ts b/src/processors/zero.ts
@@ -5,6 +5,7 @@ import { ZeroService } from "../service/zero";
 import { config } from "../config";
 
 const NAME = "ZERO";
+const REPEAT_JOB_OPT = { jobId: NAME, repeat: { cron: config.cronJob.zeroJobExpression}};
 
 export class Zero implements ProcessorInterface {
   private queue: Bull.Queue;
@@ -18,6 +19,7 @@ export class Zero implements ProcessorInterface {
   }
   init() {
     this.logger.info("Initialising XDC-Zero");
+    this.zeroService.init();
     this.queue.process(async (_, done) => {
       this.logger.info("⏰ Executing xdc-zero periodically");
       try {
@@ -35,7 +37,7 @@ export class Zero implements ProcessorInterface {
   }
 
   async reset(): Promise<void> {
-    await this.queue.add({}, { jobId: NAME, repeat: { cron: config.cronJob.zeroJobExpression}});
+    await this.queue.add({}, REPEAT_JOB_OPT);
   }
 
   async processEvent() {

diff --git a/src/service/mainnet/extensions.ts b/src/service/mainnet/extensions.ts
@@ -13,7 +13,7 @@ export const mainnetExtensions = {
   property: MAINNET_EXTENSION_NAME,
   methods: [
     {
-      name: "networkInformation",
+      name: "getNetworkInformation",
       call: "XDPoS_networkInformation"
     }
   ]

diff --git a/src/service/subnet/extensions.ts b/src/service/subnet/extensions.ts
@@ -63,7 +63,7 @@ export const subnetExtensions = {
       params: 1,
       call: "XDPoS_getV2BlockByHash"
     }, {
-      name: "networkInformation",
+      name: "getNetworkInformation",
       params: 0,
       call: "XDPoS_networkInformation"
     },