Add tars-sdk impl

build.gradle

@@ -29,6 +29,7 @@ ext {
     slf4jApiVerison = '1.7.36'
     mockitoVersion = '4.8.0'
     gsonVersion = '2.10.1'
+    tarsSDKVersion = '3.5.0-SNAPSHOT'
 }
 
 // check.dependsOn integrationTest
@@ -60,8 +61,8 @@ allprojects {
     repositories {
         mavenCentral()
         maven { url "https://maven.aliyun.com/nexus/content/groups/public/" }
-        maven { url "https://oss.sonatype.org/service/local/staging/deploy/maven2" }
         maven { url "https://oss.sonatype.org/content/repositories/snapshots" }
+        maven { url "https://oss.sonatype.org/service/local/staging/deploy/maven2" }
     }
 
     dependencies {
@@ -126,6 +127,7 @@ googleJavaFormat {
 }
 
 dependencies {
+	api("org.fisco-bcos:fisco-bcos-tars-sdk:${tarsSDKVersion}")
     api("org.fisco-bcos:bcos-sdk-jni:${bcosSdkJniVersion}")  {
         exclude group : "org.slf4j"
         exclude group : "com.fasterxml.jackson.core"

src/main/java/org/fisco/bcos/sdk/v3/client/TarsClient.java

@@ -0,0 +1,101 @@
+package org.fisco.bcos.sdk.v3.client;
+
+import java.math.BigInteger;
+import java.util.Objects;
+import java.util.stream.Collectors;
+
+import org.fisco.bcos.sdk.v3.client.protocol.response.BcosTransactionReceipt;
+import org.fisco.bcos.sdk.v3.config.ConfigOption;
+import org.fisco.bcos.sdk.v3.model.callback.TransactionCallback;
+import org.fisco.bcos.sdk.v3.utils.Hex;
+
+import org.fisco.bcos.sdk.tars.LogEntry;
+import org.fisco.bcos.sdk.tars.TransactionReceipt;
+import org.fisco.bcos.sdk.tars.bcos;
+import org.fisco.bcos.sdk.tars.RPCClient;
+import org.fisco.bcos.sdk.tars.SWIGTYPE_p_bcos__h256;
+import org.fisco.bcos.sdk.tars.Transaction;
+import org.fisco.bcos.sdk.tars.TransactionFactoryImpl;
+import org.fisco.bcos.sdk.tars.CryptoSuite;
+
+public class TarsClient extends ClientImpl implements Client {
+  private RPCClient tarsRPCClient;
+  private TransactionFactoryImpl transactionFactory;;
+
+  protected TarsClient(String groupID, ConfigOption configOption, long nativePointer,
+      String connectionString) {
+    super(groupID, configOption, nativePointer);
+    tarsRPCClient = new RPCClient(connectionString);
+
+    CryptoSuite cryptoSuite =
+        bcos.newCryptoSuite(configOption.getCryptoMaterialConfig().getUseSmCrypto());
+    transactionFactory = new TransactionFactoryImpl(cryptoSuite);
+  }
+
+  @Override
+  public BcosTransactionReceipt sendTransaction(String node, String signedTransactionData,
+      boolean withProof) {
+    if (withProof) {
+      return super.sendTransaction(node, signedTransactionData, withProof);
+    }
+    node = Objects.isNull(node) ? "" : node;
+
+    Transaction transaction = transactionFactory
+        .createTransaction(bcos.toBytesConstRef(Hex.decode(signedTransactionData)));
+    TransactionReceipt receipt = tarsRPCClient.sendTransaction(transaction).get();
+    BcosTransactionReceipt bcosReceipt = new BcosTransactionReceipt();
+    bcosReceipt.setResult(convert(receipt, transaction));
+
+    return bcosReceipt;
+  }
+
+  @Override
+  public void sendTransactionAsync(String node, String signedTransactionData, boolean withProof,
+      TransactionCallback callback) {
+    throw new RuntimeException("Unimplemented method!");
+
+    // if (withProof) {
+    // super.sendTransactionAsync(node, signedTransactionData, withProof, callback);
+    // return;
+    // }
+    //
+    // node = Objects.isNull(node) ? "" : node;
+    // Transaction transaction = transactionFactory
+    // .createTransaction(bcos.toBytesConstRef(Hex.decode(signedTransactionData)));
+    // FutureReceipt future = tarsRPCClient.sendTransaction(transaction);
+  }
+
+  private org.fisco.bcos.sdk.v3.model.TransactionReceipt convert(TransactionReceipt receipt,
+      Transaction transaction) {
+    org.fisco.bcos.sdk.v3.model.TransactionReceipt jsonReceipt =
+        new org.fisco.bcos.sdk.v3.model.TransactionReceipt();
+    jsonReceipt.setTransactionHash("0x" + bcos.toHex(transaction.hash()));
+    jsonReceipt.setVersion(receipt.version());
+    jsonReceipt.setReceiptHash("0x" + bcos.toHex(receipt.hash()));
+    jsonReceipt.setBlockNumber(BigInteger.valueOf(receipt.blockNumber()));
+    jsonReceipt.setFrom(bcos.toString(transaction.sender()));
+    jsonReceipt.setTo(bcos.toString(transaction.to()));
+    jsonReceipt.setGasUsed(bcos.toString(receipt.gasUsed()));
+    jsonReceipt.setContractAddress(bcos.toString(receipt.contractAddress()));
+    jsonReceipt.setChecksumContractAddress(jsonReceipt.getContractAddress()); // FIXME: how to?
+    jsonReceipt.setLogEntries(
+        bcos.logEntrySpanToVector(receipt.logEntries()).stream().map((LogEntry logEntry) -> {
+          org.fisco.bcos.sdk.v3.model.TransactionReceipt.Logs rawLogEntry =
+              new org.fisco.bcos.sdk.v3.model.TransactionReceipt.Logs();
+          rawLogEntry.setAddress(bcos.toString(logEntry.address()));
+          rawLogEntry.setBlockNumber(String.valueOf(receipt.blockNumber()));
+          rawLogEntry.setData("0x" + bcos.toHex(logEntry.data()));
+          rawLogEntry.setTopics(bcos.h256SpanToVector(logEntry.topics()).stream()
+              .map((SWIGTYPE_p_bcos__h256 hash) -> {
+                return "0x" + bcos.toHex(hash);
+              }).collect(Collectors.toList()));
+          return rawLogEntry;
+        }).collect(Collectors.toList()));
+    jsonReceipt.setStatus(receipt.status());
+    jsonReceipt.setInput("0x" + bcos.toHex(transaction.input()));
+    jsonReceipt.setOutput("0x" + bcos.toHex(receipt.output()));
+    jsonReceipt.setExtraData(bcos.toString(transaction.extraData()));
+
+    return jsonReceipt;
+  }
+}