Add setTermWeight (#862)

FISCO-BCOS · Oct 10, 2024 · dd3c678 · dd3c678
1 parent fc2a37b
commit dd3c678
Show file tree

Hide file tree

Showing 4 changed files with 34 additions and 2 deletions.
diff --git a/build.gradle b/build.gradle
@@ -42,7 +42,7 @@ dependencies {
     //implementation 'org.fisco-bcos:solcJ:0.5.2.1'
     implementation 'org.fisco-bcos:solcJ:1.0.0'
 
-    implementation ('org.fisco-bcos.java-sdk:fisco-bcos-java-sdk:3.8.0') {
+    implementation ('org.fisco-bcos.java-sdk:fisco-bcos-java-sdk:3.9.0-SNAPSHOT') {
         exclude group: "org.slf4j"
     }
 

diff --git a/src/main/java/console/command/category/ConsensusOpCommand.java b/src/main/java/console/command/category/ConsensusOpCommand.java
@@ -133,6 +133,18 @@ public Map<String, CommandInfo> getAllCommandInfo(boolean isWasm) {
                     2,
                     2);
 
+    public static final CommandInfo SET_CONSENSUS_TERM_WEIGHT =
+            new CommandInfo(
+                    "setConsensusTermWeight",
+                    "Set consensus term weight for the specified node",
+                    HelpInfo::setConsensusWeightHelp,
+                    (consoleInitializer, params, pwd) ->
+                            consoleInitializer
+                                    .getPrecompiledFace()
+                                    .setConsensusNodeTermWeight(params),
+                    2,
+                    2);
+
     static {
         Field[] fields = ConsensusOpCommand.class.getDeclaredFields();
         for (Field field : fields) {
@@ -159,5 +171,6 @@ public Map<String, CommandInfo> getAllCommandInfo(boolean isWasm) {
                             ConsensusOpCommand.ADD_OBSERVER.getCommand(),
                             ConsensusOpCommand.ADD_SEALER.getCommand(),
                             ConsensusOpCommand.REMOVE_NODE.getCommand(),
-                            ConsensusOpCommand.SET_CONSENSUS_WEIGHT.getCommand()));
+                            ConsensusOpCommand.SET_CONSENSUS_WEIGHT.getCommand(),
+                            ConsensusOpCommand.SET_CONSENSUS_TERM_WEIGHT.getCommand()));
 }
diff --git a/src/main/java/console/precompiled/PrecompiledFace.java b/src/main/java/console/precompiled/PrecompiledFace.java
@@ -29,6 +29,8 @@ void setSystemConfigByKey(ConsoleInitializer consoleInitializer, String[] params
 
     void setConsensusNodeWeight(String[] params) throws Exception;
 
+    void setConsensusNodeTermWeight(String[] params) throws Exception;
+
     void changeDir(String[] params) throws Exception;
 
     void makeDir(String[] params) throws Exception;

diff --git a/src/main/java/console/precompiled/PrecompiledImpl.java b/src/main/java/console/precompiled/PrecompiledImpl.java
@@ -134,6 +134,23 @@ public void setConsensusNodeWeight(String[] params) throws Exception {
         }
     }
 
+    @Override
+    public void setConsensusNodeTermWeight(String[] params) throws Exception {
+        String nodeId = params[1];
+        int weight = ConsoleUtils.processNonNegativeNumber("consensusWeight", params[2]);
+        if (nodeId.length() != 128) {
+            ConsoleUtils.printJson(PrecompiledRetCode.CODE_INVALID_NODEID.toString());
+        } else {
+            RetCode retCode =
+                    this.consensusService.setTermWeight(nodeId, BigInteger.valueOf(weight));
+            ConsoleUtils.printJson(retCode.toString());
+            if (retCode.getCode() == PrecompiledRetCode.CODE_NO_AUTHORIZED.getCode()) {
+                System.out.println(
+                        "Maybe you should use 'setConsensusNodeTermWeightProposal' command to change system config.");
+            }
+        }
+    }
+
     @Override
     public void setSystemConfigByKey(ConsoleInitializer consoleInitializer, String[] params)
             throws Exception {