Merge pull request #108 from cryptape/rc/v0.22.3

Rc/v0.22.3

Author: duanyytop

CHANGELOG.md

@@ -1,5 +1,12 @@
 All notable changes to this project will be documented in this file.
 
+# [v0.22.3](https://github.com/cryptape/cita-sdk-java/compare/v0.22.2...v0.22.3) (2019-04-10)
+
+### Feature
+
+* add peersInfo RPC request
+* add getVersion RPC request
+
 # [v0.22.2](https://github.com/cryptape/cita-sdk-java/compare/v0.22.1...v0.22.2) (2019-04-09)
 
 ### Feature

README.md

@@ -29,12 +29,12 @@ maven
 <dependency>
   <groupId>com.cryptape.cita</groupId>
   <artifactId>core</artifactId>
-  <version>0.22.2</version>
+  <version>0.22.3</version>
 </dependency>
 ```
 Gradle
 ```
-compile 'com.cryptape.cita:core:0.22.2'
+compile 'com.cryptape.cita:core:0.22.3'
 ```
 
 Install manually
@@ -166,12 +166,12 @@ Gradle 4.3
 <dependency>
   <groupId>com.cryptape.cita</groupId>
   <artifactId>core</artifactId>
-  <version>0.22.2</version>
+  <version>0.22.3</version>
 </dependency>
 ```
 Gradle
 ```
-compile 'com.cryptape.cita:core:0.22.2'
+compile 'com.cryptape.cita:core:0.22.3'
 ```
 
 手动安装  

build.gradle

@@ -46,7 +46,7 @@ allprojects {
     targetCompatibility = 1.8
 
     group 'com.cryptape.cita'
-    version '0.22.1'
+    version '0.22.3'
 
     apply plugin: 'java'
     apply plugin: 'jacoco'
@@ -142,7 +142,7 @@ configure(subprojects.findAll {it.name != 'integration-tests'}) {
         publications {
             mavenJava(MavenPublication) {
                 groupId 'com.cryptape.cita'
-                version '0.22.1'
+                version '0.22.3'
                 from components.java
 
                 artifact sourcesJar {

core/src/main/java/com/cryptape/cita/protocol/core/CITA.java

@@ -3,23 +3,7 @@
 import java.math.BigInteger;
 
 import com.cryptape.cita.protocol.core.methods.request.Call;
-import com.cryptape.cita.protocol.core.methods.response.AppAccounts;
-import com.cryptape.cita.protocol.core.methods.response.AppBlock;
-import com.cryptape.cita.protocol.core.methods.response.AppBlockNumber;
-import com.cryptape.cita.protocol.core.methods.response.AppCall;
-import com.cryptape.cita.protocol.core.methods.response.AppFilter;
-import com.cryptape.cita.protocol.core.methods.response.AppGetAbi;
-import com.cryptape.cita.protocol.core.methods.response.AppGetBalance;
-import com.cryptape.cita.protocol.core.methods.response.AppGetCode;
-import com.cryptape.cita.protocol.core.methods.response.AppGetTransactionCount;
-import com.cryptape.cita.protocol.core.methods.response.AppGetTransactionReceipt;
-import com.cryptape.cita.protocol.core.methods.response.AppLog;
-import com.cryptape.cita.protocol.core.methods.response.AppMetaData;
-import com.cryptape.cita.protocol.core.methods.response.AppSendTransaction;
-import com.cryptape.cita.protocol.core.methods.response.AppSign;
-import com.cryptape.cita.protocol.core.methods.response.AppTransaction;
-import com.cryptape.cita.protocol.core.methods.response.AppUninstallFilter;
-import com.cryptape.cita.protocol.core.methods.response.NetPeerCount;
+import com.cryptape.cita.protocol.core.methods.response.*;
 
 
 /**
@@ -29,6 +13,10 @@ public interface CITA {
 
     Request<?, NetPeerCount> netPeerCount();
 
+    Request<?, NetPeersInfo> netPeersInfo();
+
+    Request<?, AppVersion> getVersion();
+
     Request<?, AppAccounts> appAccounts();
 
     Request<?, AppSign> appSign(String address, String sha3HashOfDataToSign);

core/src/main/java/com/cryptape/cita/protocol/core/JsonRpc2_0CITAj.java

@@ -6,28 +6,10 @@
 import java.util.concurrent.ScheduledExecutorService;
 
 import com.cryptape.cita.protocol.core.methods.request.Call;
+import com.cryptape.cita.protocol.core.methods.response.*;
 import io.reactivex.Flowable;
 import com.cryptape.cita.protocol.CITAj;
 import com.cryptape.cita.protocol.CITAjService;
-import com.cryptape.cita.protocol.core.methods.response.AppAccounts;
-import com.cryptape.cita.protocol.core.methods.response.AppBlock;
-import com.cryptape.cita.protocol.core.methods.response.AppBlockNumber;
-import com.cryptape.cita.protocol.core.methods.response.AppCall;
-import com.cryptape.cita.protocol.core.methods.response.AppFilter;
-import com.cryptape.cita.protocol.core.methods.response.AppGetAbi;
-import com.cryptape.cita.protocol.core.methods.response.AppGetBalance;
-import com.cryptape.cita.protocol.core.methods.response.AppGetCode;
-import com.cryptape.cita.protocol.core.methods.response.AppGetTransactionCount;
-import com.cryptape.cita.protocol.core.methods.response.AppGetTransactionReceipt;
-import com.cryptape.cita.protocol.core.methods.response.AppLog;
-import com.cryptape.cita.protocol.core.methods.response.AppMetaData;
-import com.cryptape.cita.protocol.core.methods.response.AppSendTransaction;
-import com.cryptape.cita.protocol.core.methods.response.AppSign;
-import com.cryptape.cita.protocol.core.methods.response.AppTransaction;
-import com.cryptape.cita.protocol.core.methods.response.AppUninstallFilter;
-import com.cryptape.cita.protocol.core.methods.response.Log;
-import com.cryptape.cita.protocol.core.methods.response.NetPeerCount;
-import com.cryptape.cita.protocol.core.methods.response.Transaction;
 import com.cryptape.cita.protocol.rx.JsonRpc2_0Rx;
 import com.cryptape.cita.utils.Async;
 import com.cryptape.cita.utils.Numeric;
@@ -68,6 +50,24 @@ public Request<?, NetPeerCount> netPeerCount() {
                 NetPeerCount.class);
     }
 
+    @Override
+    public Request<?, NetPeersInfo> netPeersInfo() {
+        return new Request<>(
+                "peersInfo",
+                Collections.<String>emptyList(),
+                CITAjService,
+                NetPeersInfo.class);
+    }
+
+    @Override
+    public Request<?, AppVersion> getVersion() {
+        return new Request<>(
+                "getVersion",
+                Collections.<String>emptyList(),
+                CITAjService,
+                AppVersion.class);
+    }
+
 
     //2 methods: appAccount, appSign are not used
     //keep them for wallet use in future.

core/src/main/java/com/cryptape/cita/protocol/core/methods/response/AppVersion.java

@@ -0,0 +1,19 @@
+package com.cryptape.cita.protocol.core.methods.response;
+
+import com.cryptape.cita.protocol.core.Response;
+
+/**
+ * Created by duanyytop on 2019-04-09.
+ * Copyright © 2018 Cryptape. All rights reserved.
+ */
+public class AppVersion extends Response<AppVersion.Version> {
+
+    public Version getVersion() {
+        return getResult();
+    }
+
+    public static class Version {
+        public String softwareVersion;
+    }
+
+}

core/src/main/java/com/cryptape/cita/protocol/core/methods/response/NetPeersInfo.java

@@ -0,0 +1,22 @@
+package com.cryptape.cita.protocol.core.methods.response;
+
+import com.cryptape.cita.protocol.core.Response;
+
+import java.util.Map;
+
+/**
+ * Created by duanyytop on 2019-04-09.
+ * Copyright © 2018 Cryptape. All rights reserved.
+ */
+public class NetPeersInfo extends Response<NetPeersInfo.PeersInfo> {
+
+    public PeersInfo getPeersInfo() {
+        return getResult();
+    }
+
+    public static class PeersInfo {
+        public long amount;
+        public Map<String, String> peers;
+    }
+
+}

…m/cryptape/cita/tests/InterfaceTest.java …ava/com/cryptape/cita/tests/RpcTest.javatests/src/main/java/com/cryptape/cita/tests/InterfaceTest.java renamed to tests/src/main/java/com/cryptape/cita/tests/RpcTest.java tests/src/main/java/com/cryptape/cita/tests/InterfaceTest.java renamed to tests/src/main/java/com/cryptape/cita/tests/RpcTest.java

@@ -3,6 +3,8 @@
 import java.io.IOException;
 import java.math.BigInteger;
 import java.util.Arrays;
+import java.util.Map;
+import java.util.Set;
 
 import com.cryptape.cita.abi.FunctionEncoder;
 import com.cryptape.cita.abi.TypeReference;
@@ -15,23 +17,12 @@
 import com.cryptape.cita.protocol.core.DefaultBlockParameterName;
 import com.cryptape.cita.protocol.core.methods.request.Call;
 import com.cryptape.cita.protocol.core.methods.request.Transaction;
+import com.cryptape.cita.protocol.core.methods.response.*;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
-import com.cryptape.cita.protocol.core.methods.response.AppBlock;
-import com.cryptape.cita.protocol.core.methods.response.AppBlockNumber;
-import com.cryptape.cita.protocol.core.methods.response.AppCall;
-import com.cryptape.cita.protocol.core.methods.response.AppGetBalance;
-import com.cryptape.cita.protocol.core.methods.response.AppGetCode;
-import com.cryptape.cita.protocol.core.methods.response.AppGetTransactionCount;
-import com.cryptape.cita.protocol.core.methods.response.AppGetTransactionReceipt;
-import com.cryptape.cita.protocol.core.methods.response.AppMetaData;
-import com.cryptape.cita.protocol.core.methods.response.AppSendTransaction;
-import com.cryptape.cita.protocol.core.methods.response.AppTransaction;
-import com.cryptape.cita.protocol.core.methods.response.NetPeerCount;
-import com.cryptape.cita.protocol.core.methods.response.TransactionReceipt;
 import com.google.gson.Gson;
 
-public class InterfaceTest {
+public class RpcTest {
 
     private static int version;
     private static BigInteger chainId;
@@ -56,14 +47,18 @@ public class InterfaceTest {
 
     public static void main(String[] args) throws Exception {
 
+        testNetPeerCount();
+
+        testNetPeersInfo();
+
+        testGetVersion();
+
         testGetBlockByNumber(BigInteger.valueOf(47));
 
         testGetBalance();
 
         testMetaData();
 
-        testNetPeerCount();
-
         BigInteger validBlockNumber = testBlockNumber();
 
         System.out.println(validBlockNumber.toString(10));
@@ -167,6 +162,20 @@ private static void testNetPeerCount() throws Exception {
         System.out.println("net_peerCount:" + netPeerCount.getQuantity());
     }
 
+    private static void testNetPeersInfo() throws Exception {
+        NetPeersInfo netPeersInfo = service.netPeersInfo().send();
+        Map<String, String> peers = netPeersInfo.getPeersInfo().peers;
+        System.out.println("net_peersInfo amount:" + netPeersInfo.getPeersInfo().amount);
+        for (Map.Entry<String, String> entry : peers.entrySet()) {
+            System.out.println("Address : " + entry.getKey() + " Node : " + entry.getValue());
+        }
+    }
+
+    private static void testGetVersion() throws Exception {
+        AppVersion appVersion = service.getVersion().send();
+        System.out.println("version:" + appVersion.getVersion().softwareVersion);
+    }
+
     private static BigInteger testBlockNumber() throws Exception {
 
         AppBlockNumber appBlockNumber = service.appBlockNumber().send();