From ae0fcaf50524652c34424828106e26ec1ee86314 Mon Sep 17 00:00:00 2001
From: Nex <nexzhu@gmail.com>
Date: Thu, 11 Oct 2018 16:38:44 +0800
Subject: [PATCH] Update clients according to API updates

---
 .../bdchain/api/AccountingChainClient.java    | 39 ++++++++++++++++++-
 .../bdchain/api/TransactionLedgerClient.java  | 34 ++++++++++++++++
 2 files changed, 71 insertions(+), 2 deletions(-)

diff --git a/src/main/java/bdchain/api/AccountingChainClient.java b/src/main/java/bdchain/api/AccountingChainClient.java
index b146b4c..c8844f4 100644
--- a/src/main/java/bdchain/api/AccountingChainClient.java
+++ b/src/main/java/bdchain/api/AccountingChainClient.java
@@ -5,6 +5,7 @@ import bdchain.api.grpc.AccountingChainGrpc.AccountingChainBlockingStub;
 import bdchain.api.grpc.AccountingChainGrpc.AccountingChainFutureStub;
 import com.google.common.util.concurrent.ListenableFuture;
 import com.google.protobuf.ByteString;
+import com.google.protobuf.Empty;
 import io.grpc.ManagedChannel;
 import io.grpc.ManagedChannelBuilder;
 import io.grpc.StatusRuntimeException;
@@ -30,7 +31,7 @@ public class AccountingChainClient {
   private final ManagedChannel channel;
   private final AccountingChainFutureStub futureStub;
   private final AccountingChainBlockingStub blockingStub;
-//  private final AccountingChainStub asyncStub;
+  //  private final AccountingChainStub asyncStub;
 
   /** 构造客户端来访问{@code host:port}的记账链服务。 */
   public AccountingChainClient(String host, int port) {
@@ -43,7 +44,7 @@ public class AccountingChainClient {
     AccountingChainGrpc.newFutureStub(channel);
     futureStub = AccountingChainGrpc.newFutureStub(channel);
     blockingStub = AccountingChainGrpc.newBlockingStub(channel);
-//    asyncStub = AccountingChainGrpc.newStub(channel);
+    //    asyncStub = AccountingChainGrpc.newStub(channel);
   }
 
   /** 关闭客户端的网络连接。 */
@@ -51,6 +52,40 @@ public class AccountingChainClient {
     channel.shutdown().awaitTermination(5, TimeUnit.SECONDS);
   }
 
+  /**
+   * <a
+   * href="https://phabricator.internetapi.cn/w/public/bdchain/grpc-api/#clientversion-1">查询节点客户端版本</a>
+   * （非阻塞）
+   */
+  public ListenableFuture<ClientVersionResponse> clientVersion() {
+
+    info("*** clientVersion");
+
+    try {
+      return futureStub.clientVersion(Empty.getDefaultInstance());
+    } catch (StatusRuntimeException e) {
+      warning("RPC failed: {0}", e.getStatus());
+      return null;
+    }
+  }
+
+  /**
+   * <a
+   * href="https://phabricator.internetapi.cn/w/public/bdchain/grpc-api/#clientversion-1">查询节点客户端版本</a>
+   * （阻塞）
+   */
+  public ClientVersionResponse clientVersionSync() {
+
+    info("*** clientVersionSync");
+
+    try {
+      return blockingStub.clientVersion(Empty.getDefaultInstance());
+    } catch (StatusRuntimeException e) {
+      warning("RPC failed: {0}", e.getStatus());
+      return null;
+    }
+  }
+
   /**
    * <a
    * href="https://phabricator.internetapi.cn/w/public/bdchain/grpc-api/#blocknumber">返回最新区块的区块号</a>
diff --git a/src/main/java/bdchain/api/TransactionLedgerClient.java b/src/main/java/bdchain/api/TransactionLedgerClient.java
index 421baa2..1432ae9 100644
--- a/src/main/java/bdchain/api/TransactionLedgerClient.java
+++ b/src/main/java/bdchain/api/TransactionLedgerClient.java
@@ -51,6 +51,40 @@ public class TransactionLedgerClient {
     channel.shutdown().awaitTermination(5, TimeUnit.SECONDS);
   }
 
+  /**
+   * <a
+   * href="https://phabricator.internetapi.cn/w/public/bdchain/grpc-api/#clientversion">查询节点客户端版本</a>
+   * （非阻塞）
+   */
+  public ListenableFuture<ClientVersionResponse> clientVersion() {
+
+    info("*** clientVersion");
+
+    try {
+      return futureStub.clientVersion(Empty.getDefaultInstance());
+    } catch (StatusRuntimeException e) {
+      warning("RPC failed: {0}", e.getStatus());
+      return null;
+    }
+  }
+
+  /**
+   * <a
+   * href="https://phabricator.internetapi.cn/w/public/bdchain/grpc-api/#clientversion">查询节点客户端版本</a>
+   * （阻塞）
+   */
+  public ClientVersionResponse clientVersionSync() {
+
+    info("*** clientVersionSync");
+
+    try {
+      return blockingStub.clientVersion(Empty.getDefaultInstance());
+    } catch (StatusRuntimeException e) {
+      warning("RPC failed: {0}", e.getStatus());
+      return null;
+    }
+  }
+
   /**
    * <a href="https://phabricator.internetapi.cn/w/public/bdchain/grpc-api/#createledger">创建账本</a>
    * （非阻塞）