Spin off consensus apis from block apis in json_rpc/block.js

ainblockchain · Feb 5, 2024 · af9e336 · af9e336
1 parent 5ba09ad
commit af9e336
Show file tree

Hide file tree

Showing 3 changed files with 63 additions and 53 deletions.
diff --git a/json_rpc/account.js b/json_rpc/account.js
@@ -40,20 +40,5 @@ module.exports = function getAccountApis(node) {
  trafficStatsManager.addEvent(TrafficEventTypes.JSON_RPC_GET, latency);
  done(null, JsonRpcUtil.addProtocolVersion({ result }));
  },
-
- [JSON_RPC_METHODS.AIN_GET_VALIDATOR_INFO]: function(args, done) {
- const beginTime = Date.now();
- const addr = args.address;
- const isWhitelisted = node.db.getValue(PathUtil.getConsensusProposerWhitelistAddrPath(addr)) || false;
- const stake = node.db.getValue(PathUtil.getServiceAccountBalancePath(addr)) || 0;
- const latency = Date.now() - beginTime;
- trafficStatsManager.addEvent(TrafficEventTypes.JSON_RPC_GET, latency);
- done(null, JsonRpcUtil.addProtocolVersion({
- result: {
- isWhitelisted,
- stake,
- }
- }));
- },
  };
 };
diff --git a/json_rpc/block.js b/json_rpc/block.js
@@ -66,37 +66,10 @@ module.exports = function getBlockApis(node) {
  done(null, JsonRpcUtil.addProtocolVersion({ result: blockHeaders }));
  },
 
- [JSON_RPC_METHODS.AIN_GET_PROPOSER_BY_HASH]: function(args, done) {
- const beginTime = Date.now();
- const block = node.bc.getBlockByHash(args.hash);
- const result = block ? block.proposer : null;
- const latency = Date.now() - beginTime;
- trafficStatsManager.addEvent(TrafficEventTypes.JSON_RPC_GET, latency);
- done(null, JsonRpcUtil.addProtocolVersion({ result }));
- },
-
- [JSON_RPC_METHODS.AIN_GET_PROPOSER_BY_NUMBER]: function(args, done) {
- const beginTime = Date.now();
- const block = node.bc.getBlockByNumber(args.number);
- const result = block ? block.proposer : null;
- const latency = Date.now() - beginTime;
- trafficStatsManager.addEvent(TrafficEventTypes.JSON_RPC_GET, latency);
- done(null, JsonRpcUtil.addProtocolVersion({ result }));
- },
-
- [JSON_RPC_METHODS.AIN_GET_VALIDATORS_BY_NUMBER]: function(args, done) {
+ [JSON_RPC_METHODS.AIN_GET_BLOCK_TRANSACTION_COUNT_BY_NUMBER]: function(args, done) {
  const beginTime = Date.now();
  const block = node.bc.getBlockByNumber(args.number);
- const result = block ? block.validators : null;
- const latency = Date.now() - beginTime;
- trafficStatsManager.addEvent(TrafficEventTypes.JSON_RPC_GET, latency);
- done(null, JsonRpcUtil.addProtocolVersion({ result }));
- },
-
- [JSON_RPC_METHODS.AIN_GET_VALIDATORS_BY_HASH]: function(args, done) {
- const beginTime = Date.now();
- const block = node.bc.getBlockByHash(args.hash);
- const result = block ? block.validators : null;
+ const result = block ? block.transactions.length : null;
  const latency = Date.now() - beginTime;
  trafficStatsManager.addEvent(TrafficEventTypes.JSON_RPC_GET, latency);
  done(null, JsonRpcUtil.addProtocolVersion({ result }));
@@ -110,14 +83,5 @@ module.exports = function getBlockApis(node) {
  trafficStatsManager.addEvent(TrafficEventTypes.JSON_RPC_GET, latency);
  done(null, JsonRpcUtil.addProtocolVersion({ result }));
  },
-
- [JSON_RPC_METHODS.AIN_GET_BLOCK_TRANSACTION_COUNT_BY_NUMBER]: function(args, done) {
- const beginTime = Date.now();
- const block = node.bc.getBlockByNumber(args.number);
- const result = block ? block.transactions.length : null;
- const latency = Date.now() - beginTime;
- trafficStatsManager.addEvent(TrafficEventTypes.JSON_RPC_GET, latency);
- done(null, JsonRpcUtil.addProtocolVersion({ result }));
- },
  };
 };
diff --git a/json_rpc/consensus.js b/json_rpc/consensus.js
@@ -0,0 +1,61 @@
+const {
+ TrafficEventTypes,
+ trafficStatsManager,
+} = require('../common/constants');
+const JsonRpcUtil = require('./json-rpc-util');
+const { JSON_RPC_METHODS } = require('./constants');
+
+module.exports = function getBlockApis(node) {
+ return {
+ [JSON_RPC_METHODS.AIN_GET_VALIDATOR_INFO]: function(args, done) {
+ const beginTime = Date.now();
+ const addr = args.address;
+ const isWhitelisted = node.db.getValue(PathUtil.getConsensusProposerWhitelistAddrPath(addr)) || false;
+ const stake = node.db.getValue(PathUtil.getServiceAccountBalancePath(addr)) || 0;
+ const latency = Date.now() - beginTime;
+ trafficStatsManager.addEvent(TrafficEventTypes.JSON_RPC_GET, latency);
+ done(null, JsonRpcUtil.addProtocolVersion({
+ result: {
+ isWhitelisted,
+ stake,
+ }
+ }));
+ },
+
+ [JSON_RPC_METHODS.AIN_GET_VALIDATORS_BY_NUMBER]: function(args, done) {
+ const beginTime = Date.now();
+ const block = node.bc.getBlockByNumber(args.number);
+ const result = block ? block.validators : null;
+ const latency = Date.now() - beginTime;
+ trafficStatsManager.addEvent(TrafficEventTypes.JSON_RPC_GET, latency);
+ done(null, JsonRpcUtil.addProtocolVersion({ result }));
+ },
+
+ [JSON_RPC_METHODS.AIN_GET_VALIDATORS_BY_HASH]: function(args, done) {
+ const beginTime = Date.now();
+ const block = node.bc.getBlockByHash(args.hash);
+ const result = block ? block.validators : null;
+ const latency = Date.now() - beginTime;
+ trafficStatsManager.addEvent(TrafficEventTypes.JSON_RPC_GET, latency);
+ done(null, JsonRpcUtil.addProtocolVersion({ result }));
+ },
+
+ [JSON_RPC_METHODS.AIN_GET_PROPOSER_BY_NUMBER]: function(args, done) {
+ const beginTime = Date.now();
+ const block = node.bc.getBlockByNumber(args.number);
+ const result = block ? block.proposer : null;
+ const latency = Date.now() - beginTime;
+ trafficStatsManager.addEvent(TrafficEventTypes.JSON_RPC_GET, latency);
+ done(null, JsonRpcUtil.addProtocolVersion({ result }));
+ },
+
+ [JSON_RPC_METHODS.AIN_GET_PROPOSER_BY_HASH]: function(args, done) {
+ const beginTime = Date.now();
+ const block = node.bc.getBlockByHash(args.hash);
+ const result = block ? block.proposer : null;
+ const latency = Date.now() - beginTime;
+ trafficStatsManager.addEvent(TrafficEventTypes.JSON_RPC_GET, latency);
+ done(null, JsonRpcUtil.addProtocolVersion({ result }));
+ },
+ };
+};