[Validator] Add functionality to switch node operation

bosagora · Mar 7, 2024 · 49db0a8 · 49db0a8
1 parent ca45c38
commit 49db0a8
Show file tree

Hide file tree

Showing 4 changed files with 10 additions and 1 deletion.
diff --git a/packages/validator/config/config.yaml b/packages/validator/config/config.yaml
@@ -55,6 +55,7 @@ setting:
     ipfs_gateway_url: "${NODE_IPFS_GATEWAY_URL}"
     nptServer: "kr.pool.ntp.org"
     nptInterval: 10
+    enabledNode: true
     SECONDS_PER_SLOT: ${SECONDS_PER_SLOT}
     SLOTS_PER_EPOCH: ${SLOTS_PER_EPOCH}
     GENESIS_TIME: ${GENESIS_TIME}

diff --git a/packages/validator/config/config_test.yaml b/packages/validator/config/config_test.yaml
@@ -55,6 +55,7 @@ setting:
     ipfs_gateway_url: "${NODE_IPFS_GATEWAY_URL}"
     nptServer: "kr.pool.ntp.org"
     nptInterval: 10
+    enabledNode: true
     SECONDS_PER_SLOT: ${SECONDS_PER_SLOT}
     SLOTS_PER_EPOCH: ${SLOTS_PER_EPOCH}
     GENESIS_TIME: ${GENESIS_TIME}

diff --git a/packages/validator/src/DefaultServer.ts b/packages/validator/src/DefaultServer.ts
@@ -35,7 +35,9 @@ export class DefaultServer extends WebService {
         this.node = new Node(this.config, this.storage);
 
         if (!schedules) schedules = [];
-        schedules.push(new NodeScheduler(this.node));
+        if (this.config.setting.enabledNode) {
+            schedules.push(new NodeScheduler(this.node));
+        }
         schedules.forEach((m) => this.schedules.push(m));
         this.schedules.forEach((m) =>
             m.setOption({

diff --git a/packages/validator/src/common/Config.ts b/packages/validator/src/common/Config.ts
@@ -454,6 +454,7 @@ export class Setting implements ISetting {
     public SECONDS_PER_SLOT: number;
     public SLOTS_PER_EPOCH: number;
     public GENESIS_TIME: bigint;
+    public enabledNode: boolean;
 
     /**
      * Constructor
@@ -466,6 +467,7 @@ export class Setting implements ISetting {
         this.SECONDS_PER_SLOT = defaults.SECONDS_PER_SLOT;
         this.SLOTS_PER_EPOCH = defaults.SLOTS_PER_EPOCH;
         this.GENESIS_TIME = BigInt(defaults.GENESIS_TIME);
+        this.enabledNode = defaults.enabledNode;
     }
 
     public readFromObject(config: ISetting) {
@@ -475,6 +477,7 @@ export class Setting implements ISetting {
         if (config.SECONDS_PER_SLOT !== undefined) this.SECONDS_PER_SLOT = config.SECONDS_PER_SLOT;
         if (config.SLOTS_PER_EPOCH !== undefined) this.SLOTS_PER_EPOCH = config.SLOTS_PER_EPOCH;
         if (config.GENESIS_TIME !== undefined) this.GENESIS_TIME = BigInt(config.GENESIS_TIME);
+        if (config.enabledNode !== undefined) this.enabledNode = config.enabledNode;
     }
 
     /**
@@ -488,6 +491,7 @@ export class Setting implements ISetting {
             GENESIS_TIME: 1704067200,
             nptServer: "kr.pool.ntp.org",
             nptInterval: 10000,
+            enabledNode: true,
         } as unknown as ISetting;
     }
 }
@@ -643,6 +647,7 @@ export interface ISetting {
     ipfs_gateway_url: string;
     nptServer: string;
     nptInterval: number;
+    enabledNode: boolean;
     SECONDS_PER_SLOT: number;
     SLOTS_PER_EPOCH: number;
     GENESIS_TIME: bigint;