diff --git a/core/pom.xml b/core/pom.xml index cd3024b9..b4e46e1b 100644 --- a/core/pom.xml +++ b/core/pom.xml @@ -15,7 +15,7 @@ pom - 0.3.0.RELEASE + 0.4.0.RELEASE 1.2.0-SNAPSHOT 1.1.2.RELEASE diff --git a/framework/ledger-model/src/main/java/test/com/jd/blockchain/intgr/TestDbFactory.java b/framework/ledger-model/src/main/java/test/com/jd/blockchain/intgr/TestDbFactory.java deleted file mode 100644 index 0b9c7ed6..00000000 --- a/framework/ledger-model/src/main/java/test/com/jd/blockchain/intgr/TestDbFactory.java +++ /dev/null @@ -1,140 +0,0 @@ -package test.com.jd.blockchain.intgr; - -import static org.mockito.Matchers.any; -import static org.mockito.Matchers.anyLong; -import static org.mockito.Mockito.doAnswer; -import static org.mockito.Mockito.when; - -import java.util.concurrent.atomic.AtomicBoolean; - -import com.jd.blockchain.storage.service.*; -import com.jd.blockchain.storage.service.utils.MemoryKVStorage; -import org.mockito.Mockito; -import org.mockito.invocation.InvocationOnMock; -import org.mockito.stubbing.Answer; - -public class TestDbFactory implements DbConnectionFactory{ - - private DbConnectionFactory innerDbFactory; - - private AtomicBoolean errorSetTurnOn = new AtomicBoolean(false); - - public TestDbFactory(DbConnectionFactory innerDbFactory) { - this.innerDbFactory = innerDbFactory; - } - - - Answer exKVStorageMockedAnswer = new Answer() { - - @Override - public ExPolicyKVStorage answer(InvocationOnMock invocation) throws Throwable { - - ExPolicyKVStorage reallyExKVStorage = (ExPolicyKVStorage) invocation.callRealMethod(); - - ExPolicyKVStorage mockExKVStorage = Mockito.spy(reallyExKVStorage); - - //按条件开关触发异常； - doAnswer(new Answer() { - - @Override - public Boolean answer(InvocationOnMock invocation) throws Throwable { - if (isErrorSetTurnOn()) { - return false; - } - return (Boolean) invocation.callRealMethod(); - } - }).when(mockExKVStorage).set(any(), any(), any()); - - return mockExKVStorage; - } - }; - - Answer verKVStorageMockedAnswer = new Answer() { - - @Override - public VersioningKVStorage answer(InvocationOnMock invocation) throws Throwable { - - VersioningKVStorage reallyVerKVStorage = (VersioningKVStorage) invocation.callRealMethod(); - - VersioningKVStorage mockVerKVStorage = Mockito.spy(reallyVerKVStorage); - - //按条件开关触发异常； - doAnswer(new Answer() { - - @Override - public Long answer(InvocationOnMock invocation) throws Throwable { - if (isErrorSetTurnOn()) { - return (long)(-1); - } - return (Long) invocation.callRealMethod(); - } - }).when(mockVerKVStorage).set(any(), any(), anyLong()); - - return mockVerKVStorage; - } - }; - - Answer storageMockedAnswer = new Answer() { - - @Override - public KVStorageService answer(InvocationOnMock invocation) throws Throwable { - - KVStorageService reallyStorage = (KVStorageService) invocation.callRealMethod(); - - TestMemoryKVStorage testMemoryKVStorage = new TestMemoryKVStorage((MemoryKVStorage)reallyStorage); - - KVStorageService mockedStorage = Mockito.spy(testMemoryKVStorage); - - doAnswer(exKVStorageMockedAnswer).when(mockedStorage).getExPolicyKVStorage(); - - doAnswer(verKVStorageMockedAnswer).when(mockedStorage).getVersioningKVStorage(); - - return mockedStorage; - } - - }; - - - @Override - public String dbPrefix() { - return innerDbFactory.dbPrefix(); - } - - @Override - public boolean support(String scheme) { - return innerDbFactory.support(scheme); - } - - @Override - public DbConnection connect(String dbConnectionString) { - - DbConnection reallyDbConn = innerDbFactory.connect(dbConnectionString); - - DbConnection mockDbConn = Mockito.spy(reallyDbConn); - - when(mockDbConn.getStorageService()).then(storageMockedAnswer); - return mockDbConn; - } - - @Override - public DbConnection connect(String dbConnectionString, String password) { - return connect(dbConnectionString); - } - - @Override - public void close() { - innerDbFactory.close(); - - } - - public boolean isErrorSetTurnOn() { - return errorSetTurnOn.get(); - } - - public void setErrorSetTurnOn(boolean errorSetTurnOn) { - this.errorSetTurnOn.set(errorSetTurnOn);; - } - - - -} diff --git a/framework/ledger-model/src/main/java/test/com/jd/blockchain/intgr/TestMemoryKVStorage.java b/framework/ledger-model/src/main/java/test/com/jd/blockchain/intgr/TestMemoryKVStorage.java deleted file mode 100644 index 15e99f60..00000000 --- a/framework/ledger-model/src/main/java/test/com/jd/blockchain/intgr/TestMemoryKVStorage.java +++ /dev/null @@ -1,24 +0,0 @@ -package test.com.jd.blockchain.intgr; - -import com.jd.blockchain.storage.service.ExPolicyKVStorage; -import com.jd.blockchain.storage.service.VersioningKVStorage; -import com.jd.blockchain.storage.service.utils.MemoryKVStorage; - -public class TestMemoryKVStorage extends MemoryKVStorage { - - private MemoryKVStorage memoryKVStorage; - - public TestMemoryKVStorage(MemoryKVStorage memoryKVStorage) { - this.memoryKVStorage = memoryKVStorage; - } - - @Override - public ExPolicyKVStorage getExPolicyKVStorage() { - return memoryKVStorage; - } - - @Override - public VersioningKVStorage getVersioningKVStorage() { - return memoryKVStorage; - } -} diff --git a/libs/bft-smart b/libs/bft-smart index 6b5b3c24..765d6909 160000 --- a/libs/bft-smart +++ b/libs/bft-smart @@ -1 +1 @@ -Subproject commit 6b5b3c24353536ac6316ff8be1ffb186f8875a86 +Subproject commit 765d6909106afaae966c5c25137d7ad12c44e61f diff --git a/test/test-integration/src/main/java/test/com/jd/blockchain/intgr/IntegrationTest.java b/test/test-integration/src/main/java/test/com/jd/blockchain/intgr/IntegrationTest.java index 16fae5c0..73b431a8 100644 --- a/test/test-integration/src/main/java/test/com/jd/blockchain/intgr/IntegrationTest.java +++ b/test/test-integration/src/main/java/test/com/jd/blockchain/intgr/IntegrationTest.java @@ -1,704 +1,704 @@ -package test.com.jd.blockchain.intgr; - -import java.io.File; -import java.io.FileInputStream; -import java.io.IOException; -import java.io.InputStream; -import java.util.Properties; -import java.util.Random; -import java.util.concurrent.CountDownLatch; - -import org.mockito.Mockito; -import org.springframework.core.io.ClassPathResource; - -import com.jd.blockchain.consensus.ConsensusProvider; -import com.jd.blockchain.consensus.ConsensusProviders; -import com.jd.blockchain.consensus.ConsensusSettings; -import com.jd.blockchain.consensus.bftsmart.BftsmartConsensusProvider; -import com.jd.blockchain.consensus.service.NodeServerFactory; -import com.jd.blockchain.crypto.AddressEncoding; -import com.jd.blockchain.crypto.AsymmetricKeypair; -import com.jd.blockchain.crypto.Crypto; -import com.jd.blockchain.crypto.HashDigest; -import com.jd.blockchain.crypto.KeyGenUtils; -import com.jd.blockchain.crypto.PrivKey; -import com.jd.blockchain.crypto.PubKey; -import com.jd.blockchain.gateway.GatewayConfigProperties.KeyPairConfig; -import com.jd.blockchain.ledger.BlockchainIdentity; -import com.jd.blockchain.ledger.BlockchainKeyGenerator; -import com.jd.blockchain.ledger.BlockchainKeypair; -import com.jd.blockchain.ledger.BytesValue; -import com.jd.blockchain.ledger.DataAccountKVSetOperation; -import com.jd.blockchain.ledger.LedgerBlock; -import com.jd.blockchain.ledger.LedgerInfo; -import com.jd.blockchain.ledger.LedgerInitProperties; -import com.jd.blockchain.ledger.ParticipantNode; -import com.jd.blockchain.ledger.PreparedTransaction; -import com.jd.blockchain.ledger.TransactionResponse; -import com.jd.blockchain.ledger.TransactionTemplate; -import com.jd.blockchain.ledger.TypedKVEntry; -import com.jd.blockchain.ledger.UserInfo; -import com.jd.blockchain.ledger.core.DataAccountQuery; -import com.jd.blockchain.ledger.core.LedgerManage; -import com.jd.blockchain.ledger.core.LedgerManager; -import com.jd.blockchain.ledger.core.LedgerQuery; -import com.jd.blockchain.sdk.BlockchainService; -import com.jd.blockchain.sdk.client.GatewayServiceFactory; -import com.jd.blockchain.storage.service.KVStorageService; -import com.jd.blockchain.tools.initializer.DBConnectionConfig; -import com.jd.blockchain.tools.initializer.LedgerBindingConfig; -import com.jd.blockchain.tools.initializer.Prompter; -import com.jd.blockchain.utils.Bytes; -import com.jd.blockchain.utils.codec.HexUtils; -import com.jd.blockchain.utils.concurrent.ThreadInvoker.AsyncCallback; -import com.jd.blockchain.utils.net.NetworkAddress; - -import test.com.jd.blockchain.intgr.IntegratedContext.Node; -import test.com.jd.blockchain.intgr.perf.LedgerInitializeWebTest; -import test.com.jd.blockchain.intgr.perf.Utils; - -public class IntegrationTest { - // 合约测试使用的初始化数据; - BlockchainKeypair contractDataKey = BlockchainKeyGenerator.getInstance().generate(); - BlockchainKeypair contractDeployKey = BlockchainKeyGenerator.getInstance().generate(); - private String contractZipName = "AssetContract1.contract"; - private String eventName = "issue-asset"; - HashDigest txContentHash; - // String userPubKeyVal = "this is user's pubKey"; - // 保存资产总数的键； - private static final String KEY_TOTAL = "TOTAL"; - // 第二个参数; - private static final String KEY_ABC = "abc"; - - private static final String MQ_SERVER = "nats://127.0.0.1:4222"; - - private static final String MQ_TOPIC = "subject"; - - private static String memDbConnString = LedgerInitConsensusConfig.memConnectionStrings[0]; - - // private static final MQConnectionConfig mqConnConfig = new - // MQConnectionConfig(); - // static { - // mqConnConfig.setServer(MQ_SERVER); - // mqConnConfig.setTopic(MQ_TOPIC); - // } - - public static void main_(String[] args) { - // init ledgers of all nodes ; - IntegratedContext context = initLedgers(); - Node node0 = context.getNode(0); - Node node1 = context.getNode(1); - Node node2 = context.getNode(2); - Node node3 = context.getNode(3); - - BftsmartConsensusProvider csProvider0 = new BftsmartConsensusProvider(); - NodeServerFactory mockedNodeServerFactory0 = Mockito.spy(csProvider0.getServerFactory()); - - NetworkAddress peerSrvAddr0 = new NetworkAddress("127.0.0.1", 10200); - PeerTestRunner peer0 = new PeerTestRunner(peerSrvAddr0, node0.getBindingConfig(), node0.getStorageDB()); - - NetworkAddress peerSrvAddr1 = new NetworkAddress("127.0.0.1", 10210); - PeerTestRunner peer1 = new PeerTestRunner(peerSrvAddr1, node1.getBindingConfig(), node1.getStorageDB()); - - NetworkAddress peerSrvAddr2 = new NetworkAddress("127.0.0.1", 10220); - PeerTestRunner peer2 = new PeerTestRunner(peerSrvAddr2, node2.getBindingConfig(), node2.getStorageDB()); - - NetworkAddress peerSrvAddr3 = new NetworkAddress("127.0.0.1", 10230); - PeerTestRunner peer3 = new PeerTestRunner(peerSrvAddr3, node3.getBindingConfig(), node3.getStorageDB()); - - AsyncCallback peerStarting0 = peer0.start(); - AsyncCallback peerStarting1 = peer1.start(); - AsyncCallback peerStarting2 = peer2.start(); - AsyncCallback peerStarting3 = peer3.start(); - - peerStarting0.waitReturn(); - peerStarting1.waitReturn(); - peerStarting2.waitReturn(); - peerStarting3.waitReturn(); - - String encodedBase58Pwd = KeyGenUtils.encodePasswordAsBase58(LedgerInitializeWebTest.PASSWORD); - - KeyPairConfig gwkey0 = new KeyPairConfig(); - gwkey0.setPubKeyValue(LedgerInitializeWebTest.PUB_KEYS[0]); - gwkey0.setPrivKeyValue(LedgerInitializeWebTest.PRIV_KEYS[0]); - gwkey0.setPrivKeyPassword(encodedBase58Pwd); - // GatewayTestRunner gateway0 = new GatewayTestRunner("127.0.0.1", 10300, - // gwkey0, peerSrvAddr0); - GatewayTestRunner gateway0 = new GatewayTestRunner("127.0.0.1", 10300, gwkey0, peerSrvAddr0); - - // KeyPairConfig gwkey1 = new KeyPairConfig(); - // gwkey1.setPubKeyValue(LedgerInitializeWebTest.PUB_KEYS[1]); - // gwkey1.setPrivKeyValue(LedgerInitializeWebTest.PRIV_KEYS[1]); - // gwkey1.setPrivKeyPassword(encodedBase58Pwd); - // GatewayTestRunner gateway1 = new GatewayTestRunner("127.0.0.1", 10310, - // gwkey1, peerSrvAddr1); - - AsyncCallback gwStarting0 = gateway0.start(); - // AsyncCallback gwStarting1 = gateway1.start(); - - gwStarting0.waitReturn(); - // gwStarting1.waitReturn(); - - // 执行测试用例之前，校验每个节点的一致性； - // testConsistencyAmongNodes(context); - - testSDK(gateway0, context); - - // 执行测试用例之后，校验每个节点的一致性； - // testConsistencyAmongNodes(context); - } - - /** - * 检查所有节点之间的账本是否一致； - * - * @param context - */ - private void testConsistencyAmongNodes(IntegratedContext context) { - int[] ids = context.getNodeIds(); - Node[] nodes = new Node[ids.length]; - LedgerQuery[] ledgers = new LedgerQuery[ids.length]; - for (int i = 0; i < nodes.length; i++) { - nodes[i] = context.getNode(ids[i]); - HashDigest ledgerHash = nodes[i].getLedgerManager().getLedgerHashs()[0]; - ledgers[i] = nodes[i].getLedgerManager().getLedger(ledgerHash); - } - LedgerQuery ledger0 = ledgers[0]; - LedgerBlock latestBlock0 = ledger0.retrieveLatestBlock(); - for (int i = 1; i < ledgers.length; i++) { - LedgerQuery otherLedger = ledgers[i]; - LedgerBlock otherLatestBlock = otherLedger.retrieveLatestBlock(); - } - } - - private static void testSDK(GatewayTestRunner gateway, IntegratedContext context) { - // 连接网关； - GatewayServiceFactory gwsrvFact = GatewayServiceFactory.connect(gateway.getServiceAddress()); - BlockchainService bcsrv = gwsrvFact.getBlockchainService(); - - HashDigest[] ledgerHashs = bcsrv.getLedgerHashs(); - - AsymmetricKeypair adminKey = context.getNode(0).getPartiKeyPair(); - - BlockchainKeypair newUserAcount = testSDK_RegisterUser(adminKey, ledgerHashs[0], bcsrv, context); - - // BlockchainKeyPair newDataAccount = testSDK_RegisterDataAccount(adminKey, - // ledgerHashs[0], bcsrv, context); - // - // testSDK_InsertData(adminKey, ledgerHashs[0], bcsrv, - // newDataAccount.getAddress(), context); - // - // LedgerBlock latestBlock = testSDK_Contract(adminKey, ledgerHashs[0], bcsrv, - // context); - - } - - private void testSDK_InsertData(AsymmetricKeypair adminKey, HashDigest ledgerHash, BlockchainService blockchainService, - String dataAccountAddress, IntegratedContext context) { - - // 在本地定义注册账号的 TX； - TransactionTemplate txTemp = blockchainService.newTransaction(ledgerHash); - - // -------------------------------------- - // 将商品信息写入到指定的账户中； - // 对象将被序列化为 JSON 形式存储，并基于 JSON 结构建立查询索引； - String dataAccount = dataAccountAddress; - - String dataKey = "jingdong" + new Random().nextInt(100000); - String dataVal = "www.jd.com"; - - txTemp.dataAccount(dataAccount).setText(dataKey, dataVal, -1); - - // TX 准备就绪； - PreparedTransaction prepTx = txTemp.prepare(); - - // 使用私钥进行签名； - prepTx.sign(adminKey); - - // 提交交易； - TransactionResponse txResp = prepTx.commit(); - - Node node0 = context.getNode(0); - LedgerQuery ledgerOfNode0 = node0.getLedgerManager().getLedger(ledgerHash); - ledgerOfNode0.retrieveLatestBlock(); // 更新内存 - - // 先验证应答 - TypedKVEntry[] kvDataEntries = blockchainService.getDataEntries(ledgerHash, dataAccountAddress, dataKey); - for (TypedKVEntry kvDataEntry : kvDataEntries) { - String valHexText = (String) kvDataEntry.getValue(); - byte[] valBytes = HexUtils.decode(valHexText); - String valText = new String(valBytes); - System.out.println(valText); - } - } - - private static BlockchainKeypair testSDK_RegisterUser(AsymmetricKeypair adminKey, HashDigest ledgerHash, - BlockchainService blockchainService, IntegratedContext context) { - // 注册用户，并验证最终写入； - BlockchainKeypair user = BlockchainKeyGenerator.getInstance().generate(); - - // 定义交易； - TransactionTemplate txTpl = blockchainService.newTransaction(ledgerHash); - txTpl.users().register(user.getIdentity()); - - // 签名； - PreparedTransaction ptx = txTpl.prepare(); - - HashDigest transactionHash = ptx.getHash(); - - ptx.sign(adminKey); - - // 提交并等待共识返回； - TransactionResponse txResp = ptx.commit(); - - // 验证结果; - Node node0 = context.getNode(0); - LedgerManage ledgerManager = new LedgerManager(); - - KVStorageService storageService = node0.getStorageDB().connect(memDbConnString).getStorageService(); - - LedgerQuery ledgerOfNode0 = ledgerManager.register(ledgerHash, storageService); - - return user; - } - - private BlockchainKeypair testSDK_RegisterDataAccount(AsymmetricKeypair adminKey, HashDigest ledgerHash, - BlockchainService blockchainService, IntegratedContext context) { - // 注册数据账户，并验证最终写入； - BlockchainKeypair dataAccount = BlockchainKeyGenerator.getInstance().generate(); - - // 定义交易； - TransactionTemplate txTpl = blockchainService.newTransaction(ledgerHash); - txTpl.dataAccounts().register(dataAccount.getIdentity()); - - // 签名； - PreparedTransaction ptx = txTpl.prepare(); - - HashDigest transactionHash = ptx.getHash(); - - ptx.sign(adminKey); - - // 提交并等待共识返回； - TransactionResponse txResp = ptx.commit(); - - // 验证结果; - Node node0 = context.getNode(0); - // LedgerRepository ledgerOfNode0 = - // node0.getLedgerManager().getLedger(ledgerHash); - LedgerManage ledgerManager = new LedgerManager(); - - KVStorageService storageService = node0.getStorageDB().connect(memDbConnString).getStorageService(); - - LedgerQuery ledgerOfNode0 = ledgerManager.register(ledgerHash, storageService); - long latestBlockHeight = ledgerOfNode0.retrieveLatestBlockHeight(); - - return dataAccount; - } - - private void testSDK_Query(AsymmetricKeypair adminKey, HashDigest ledgerHash, BlockchainService blockchainService, - IntegratedContext context, BlockchainKeypair newUserAcount, BlockchainKeypair newDataAcount) { - - Bytes userAddress = newUserAcount.getAddress(); - Bytes dataAddress = newDataAcount.getAddress(); - - Node node0 = context.getNode(0); - // LedgerRepository ledgerOfNode0 = - // node0.getLedgerManager().getLedger(ledgerHash); - LedgerManage ledgerManager = new LedgerManager(); - - KVStorageService storageService = node0.getStorageDB().connect(memDbConnString).getStorageService(); - - LedgerQuery ledgerOfNode0 = ledgerManager.register(ledgerHash, storageService); - - // getLedgerHashs - HashDigest[] ledgerHashs = blockchainService.getLedgerHashs(); - for (HashDigest hashDigest : ledgerHashs) { - if (hashDigest.equals(ledgerHash)) { - break; - } - System.out.println("Query getLedgerHashs error! ledgerHash not exist!"); - } - - // getLedger - LedgerInfo ledgerInfo = blockchainService.getLedger(ledgerHash); - long ledgerHeight = ledgerInfo.getLatestBlockHeight(); - - // getConsensusParticipants - ParticipantNode[] consensusParticipants = blockchainService.getConsensusParticipants(ledgerHash); - for (int i = 0; i < 4; i++) { - } - - // getBlock - for (int i = 0; i < ledgerHeight + 1; i++) { - LedgerBlock expectBlock = ledgerOfNode0.getBlock(i); - } - - // getTransactionCount according to blockhash - for (int i = 0; i < ledgerHeight + 1; i++) { - LedgerBlock expectBlock = ledgerOfNode0.getBlock(i); - long expectTransactionCount = ledgerOfNode0.getTransactionSet(expectBlock).getTotalCount(); - long actualTransactionCount = blockchainService.getTransactionCount(ledgerHash, expectBlock.getHash()); - } - - // getDataAccountCount according to blockhash - for (int i = 0; i < ledgerHeight + 1; i++) { - LedgerBlock expectBlock = ledgerOfNode0.getBlock(i); - long expectDataCount = ledgerOfNode0.getDataAccountSet(expectBlock).getTotal(); - long actualDataCount = blockchainService.getDataAccountCount(ledgerHash, expectBlock.getHash()); - } - - // getUserCount according to blockhash - for (int i = 0; i < ledgerHeight + 1; i++) { - LedgerBlock expectBlock = ledgerOfNode0.getBlock(i); - long expectUserCount = ledgerOfNode0.getUserAccountSet(expectBlock).getTotal(); - long actualUserCount = blockchainService.getUserCount(ledgerHash, expectBlock.getHash()); - } - - // getContractCount according to blockhash - for (int i = 0; i < ledgerHeight + 1; i++) { - LedgerBlock expectBlock = ledgerOfNode0.getBlock(i); - long expectContractCount = ledgerOfNode0.getContractAccountSet(expectBlock).getTotal(); - long actualContractCount = blockchainService.getContractCount(ledgerHash, expectBlock.getHash()); - } - - // getTransactionCount according to height - // getDataAccountCount according to height - // getUserCount according to height - // getContractCount according to height - long expectTransactionTotal = 0; - long expectUserTotal = 0; - long expectDataTotal = 0; - long expectContractTotal = 0; - for (int i = 0; i < ledgerHeight + 1; i++) { - // actual block acount total - long transactionCount = blockchainService.getTransactionCount(ledgerHash, i); - long userCount = blockchainService.getUserCount(ledgerHash, i); - long dataCount = blockchainService.getDataAccountCount(ledgerHash, i); - long contractCount = blockchainService.getContractCount(ledgerHash, i); - - // expect block acount total - LedgerBlock ledgerBlock = ledgerOfNode0.getBlock(i); - expectTransactionTotal = ledgerOfNode0.getTransactionSet(ledgerBlock).getTotalCount(); - expectUserTotal = ledgerOfNode0.getUserAccountSet(ledgerBlock).getTotal(); - expectDataTotal = ledgerOfNode0.getDataAccountSet(ledgerBlock).getTotal(); - expectContractTotal = ledgerOfNode0.getContractAccountSet(ledgerBlock).getTotal(); - } - - // getTransactionTotalCount - long actualTransactionTotal = blockchainService.getTransactionTotalCount(ledgerHash); - - // getUserTotalCount - long actualUserTotal = blockchainService.getUserTotalCount(ledgerHash); - - // getDataAccountTotalCount - long actualDataAccountTotal = blockchainService.getDataAccountTotalCount(ledgerHash); - - // getContractTotalCount - long actualContractAccountTotal = blockchainService.getContractTotalCount(ledgerHash); - - // getTransactions - // getTransactionByContentHash - // getTransactionStateByContentHash - // ledger-core not implement - // for (int i = 0; i < ledgerHeight + 1; i++) { - // LedgerBlock ledgerBlock = ledgerOfNode0.getBlock(i); - // HashDigest blockHash = ledgerBlock.getHash(); - // long expectCount = - // ledgerOfNode0.getTransactionSet(ledgerBlock).getTotalCount(); - // long actualCount = blockchainService.getTransactionCount(ledgerHash, i); - // LedgerTransaction[] ledgerTransactions1 = - // blockchainService.getTransactions(ledgerHash, i, 0, (int)(actualCount - 1)); - // LedgerTransaction[] ledgerTransactions2 = - // blockchainService.getTransactions(ledgerHash, blockHash, 0, (int)(expectCount - // - 1)); - // assertEquals(ledgerTransactions1.length, ledgerTransactions2.length); - // assertArrayEquals(ledgerTransactions1, ledgerTransactions2); - // - // for (LedgerTransaction ledgerTransaction : ledgerTransactions1) { - // assertEquals(ledgerTransaction, - // blockchainService.getTransactionByContentHash(ledgerHash, - // ledgerTransaction.getTransactionContent().getHash())); - // assertEquals(TransactionState.SUCCESS, - // blockchainService.getTransactionStateByContentHash(ledgerHash, - // ledgerTransaction.getTransactionContent().getHash())); - // } - // } - // getUser - UserInfo userInfo = blockchainService.getUser(ledgerHash, userAddress.toString()); - - // getDataAccount - BlockchainIdentity accountHeader = blockchainService.getDataAccount(ledgerHash, dataAddress.toString()); - - // getDataEntries - - return; - } - - public static ConsensusProvider getConsensusProvider() { - return ConsensusProviders.getProvider("com.jd.blockchain.consensus.bftsmart.BftsmartConsensusProvider"); - } - - private static IntegratedContext initLedgers() { - Prompter consolePrompter = new PresetAnswerPrompter("N"); // new ConsolePrompter(); - LedgerInitProperties initSetting = loadInitSetting_integration(); - Properties props = LedgerInitializeWebTest.loadConsensusSetting(); - ConsensusProvider csProvider = getConsensusProvider(); - ConsensusSettings csProps = csProvider.getSettingsFactory() - .getConsensusSettingsBuilder() - .createSettings(props, Utils.loadParticipantNodes()); - - // 启动服务器； - NetworkAddress initAddr0 = initSetting.getConsensusParticipant(0).getInitializerAddress(); - LedgerInitializeWebTest.NodeWebContext nodeCtx0 = new LedgerInitializeWebTest.NodeWebContext(0, initAddr0); - - NetworkAddress initAddr1 = initSetting.getConsensusParticipant(1).getInitializerAddress(); - LedgerInitializeWebTest.NodeWebContext nodeCtx1 = new LedgerInitializeWebTest.NodeWebContext(1, initAddr1); - - NetworkAddress initAddr2 = initSetting.getConsensusParticipant(2).getInitializerAddress(); - LedgerInitializeWebTest.NodeWebContext nodeCtx2 = new LedgerInitializeWebTest.NodeWebContext(2, initAddr2); - - NetworkAddress initAddr3 = initSetting.getConsensusParticipant(3).getInitializerAddress(); - LedgerInitializeWebTest.NodeWebContext nodeCtx3 = new LedgerInitializeWebTest.NodeWebContext(3, initAddr3); - PrivKey privkey0 = KeyGenUtils.decodePrivKeyWithRawPassword(LedgerInitializeWebTest.PRIV_KEYS[0], - LedgerInitializeWebTest.PASSWORD); - PrivKey privkey1 = KeyGenUtils.decodePrivKeyWithRawPassword(LedgerInitializeWebTest.PRIV_KEYS[1], - LedgerInitializeWebTest.PASSWORD); - PrivKey privkey2 = KeyGenUtils.decodePrivKeyWithRawPassword(LedgerInitializeWebTest.PRIV_KEYS[2], - LedgerInitializeWebTest.PASSWORD); - PrivKey privkey3 = KeyGenUtils.decodePrivKeyWithRawPassword(LedgerInitializeWebTest.PRIV_KEYS[3], - LedgerInitializeWebTest.PASSWORD); - - String encodedPassword = KeyGenUtils.encodePasswordAsBase58(LedgerInitializeWebTest.PASSWORD); - - CountDownLatch quitLatch = new CountDownLatch(4); - - DBConnectionConfig testDb0 = new DBConnectionConfig(); - testDb0.setConnectionUri("memory://local/0"); - LedgerBindingConfig bindingConfig0 = new LedgerBindingConfig(); - AsyncCallback callback0 = nodeCtx0.startInitCommand(privkey0, encodedPassword, initSetting, csProps, - csProvider, testDb0, consolePrompter, bindingConfig0, quitLatch); - - DBConnectionConfig testDb1 = new DBConnectionConfig(); - testDb1.setConnectionUri("memory://local/1"); - LedgerBindingConfig bindingConfig1 = new LedgerBindingConfig(); - AsyncCallback callback1 = nodeCtx1.startInitCommand(privkey1, encodedPassword, initSetting, csProps, - csProvider, testDb1, consolePrompter, bindingConfig1, quitLatch); - - DBConnectionConfig testDb2 = new DBConnectionConfig(); - testDb2.setConnectionUri("memory://local/2"); - LedgerBindingConfig bindingConfig2 = new LedgerBindingConfig(); - AsyncCallback callback2 = nodeCtx2.startInitCommand(privkey2, encodedPassword, initSetting, csProps, - csProvider, testDb2, consolePrompter, bindingConfig2, quitLatch); - - DBConnectionConfig testDb3 = new DBConnectionConfig(); - testDb3.setConnectionUri("memory://local/3"); - LedgerBindingConfig bindingConfig3 = new LedgerBindingConfig(); - AsyncCallback callback3 = nodeCtx3.startInitCommand(privkey3, encodedPassword, initSetting, csProps, - csProvider, testDb3, consolePrompter, bindingConfig3, quitLatch); - - HashDigest ledgerHash0 = callback0.waitReturn(); - HashDigest ledgerHash1 = callback1.waitReturn(); - HashDigest ledgerHash2 = callback2.waitReturn(); - HashDigest ledgerHash3 = callback3.waitReturn(); - - LedgerQuery ledger0 = nodeCtx0.registLedger(ledgerHash0); - LedgerQuery ledger1 = nodeCtx1.registLedger(ledgerHash1); - LedgerQuery ledger2 = nodeCtx2.registLedger(ledgerHash2); - LedgerQuery ledger3 = nodeCtx3.registLedger(ledgerHash3); - - IntegratedContext context = new IntegratedContext(); - - Node node0 = new Node(0); - node0.setConsensusSettings(csProps); - node0.setLedgerManager(nodeCtx0.getLedgerManager()); - node0.setStorageDB(nodeCtx0.getStorageDB()); - node0.setPartiKeyPair(new AsymmetricKeypair(initSetting.getConsensusParticipant(0).getPubKey(), privkey0)); - node0.setBindingConfig(bindingConfig0); - context.addNode(node0); - - Node node1 = new Node(1); - node1.setConsensusSettings(csProps); - node1.setLedgerManager(nodeCtx1.getLedgerManager()); - node1.setStorageDB(nodeCtx1.getStorageDB()); - node1.setPartiKeyPair(new AsymmetricKeypair(initSetting.getConsensusParticipant(1).getPubKey(), privkey1)); - node1.setBindingConfig(bindingConfig1); - context.addNode(node1); - - Node node2 = new Node(2); - node2.setConsensusSettings(csProps); - node2.setLedgerManager(nodeCtx2.getLedgerManager()); - node2.setStorageDB(nodeCtx2.getStorageDB()); - node2.setPartiKeyPair(new AsymmetricKeypair(initSetting.getConsensusParticipant(2).getPubKey(), privkey2)); - node2.setBindingConfig(bindingConfig2); - context.addNode(node2); - - Node node3 = new Node(3); - node3.setConsensusSettings(csProps); - node3.setLedgerManager(nodeCtx3.getLedgerManager()); - node3.setStorageDB(nodeCtx3.getStorageDB()); - node3.setPartiKeyPair(new AsymmetricKeypair(initSetting.getConsensusParticipant(3).getPubKey(), privkey3)); - node3.setBindingConfig(bindingConfig3); - context.addNode(node3); - - nodeCtx0.closeServer(); - nodeCtx1.closeServer(); - nodeCtx2.closeServer(); - nodeCtx3.closeServer(); - - return context; - } - - public static LedgerInitProperties loadInitSetting_integration() { - ClassPathResource ledgerInitSettingResource = new ClassPathResource("ledger_init_test_integration.init"); - try (InputStream in = ledgerInitSettingResource.getInputStream()) { - LedgerInitProperties setting = LedgerInitProperties.resolve(in); - return setting; - } catch (IOException e) { - throw new IllegalStateException(e.getMessage(), e); - } - } - - private LedgerBlock testSDK_Contract(AsymmetricKeypair adminKey, HashDigest ledgerHash, - BlockchainService blockchainService, IntegratedContext context) { - // valid the basic data in contract; - prepareContractData(adminKey, ledgerHash, blockchainService, context); - - BlockchainKeypair userKey = BlockchainKeyGenerator.getInstance().generate(); - - // 定义交易； - TransactionTemplate txTpl = blockchainService.newTransaction(ledgerHash); - byte[] contractCode = getChainCodeBytes(); - - txTpl.users().register(userKey.getIdentity()); - - txTpl.contracts().deploy(contractDeployKey.getIdentity(), contractCode); - - // 签名； - PreparedTransaction ptx = txTpl.prepare(); - ptx.sign(adminKey); - - // 提交并等待共识返回； - TransactionResponse txResp = ptx.commit(); - - // 验证结果； - txResp.getContentHash(); - - Node node0 = context.getNode(0); - LedgerQuery ledgerOfNode0 = node0.getLedgerManager().getLedger(ledgerHash); - LedgerBlock block = ledgerOfNode0.getBlock(txResp.getBlockHeight()); - byte[] contractCodeInDb = ledgerOfNode0.getContractAccountSet(block).getAccount(contractDeployKey.getAddress()) - .getChainCode(); - txContentHash = ptx.getHash(); - - // execute the contract; - testContractExe(adminKey, ledgerHash, userKey, blockchainService, context); - - return block; - } - - private void testContractExe(AsymmetricKeypair adminKey, HashDigest ledgerHash, BlockchainKeypair userKey, - BlockchainService blockchainService, IntegratedContext context) { - LedgerInfo ledgerInfo = blockchainService.getLedger(ledgerHash); - LedgerBlock previousBlock = blockchainService.getBlock(ledgerHash, ledgerInfo.getLatestBlockHeight() - 1); - - // 定义交易； - TransactionTemplate txTpl = blockchainService.newTransaction(ledgerHash); - -// txTpl.contractEvents().send(contractDeployKey.getAddress(), eventName, -// ("888##abc##" + contractDataKey.getAddress() + "##" + previousBlock.getHash().toBase58() + "##" -// + userKey.getAddress() + "##" + contractDeployKey.getAddress() + "##" + txContentHash.toBase58() -// + "##SOME-VALUE").getBytes()); - - // 签名； - PreparedTransaction ptx = txTpl.prepare(); - ptx.sign(adminKey); - - // 提交并等待共识返回； - TransactionResponse txResp = ptx.commit(); - - // 验证结果； - txResp.getContentHash(); - - LedgerInfo latestLedgerInfo = blockchainService.getLedger(ledgerHash); - - Node node0 = context.getNode(0); - LedgerQuery ledgerOfNode0 = node0.getLedgerManager().getLedger(ledgerHash); - LedgerBlock backgroundLedgerBlock = ledgerOfNode0.retrieveLatestBlock(); - - // 验证合约中的赋值，外部可以获得; - DataAccountQuery dataAccountSet = ledgerOfNode0.getDataAccountSet(backgroundLedgerBlock); - AsymmetricKeypair key = Crypto.getSignatureFunction("ED25519").generateKeypair(); - PubKey pubKey = key.getPubKey(); - Bytes dataAddress = AddressEncoding.generateAddress(pubKey); - - // 验证userAccount，从合约内部赋值，然后外部验证;由于目前不允许输入重复的key，所以在内部合约中构建的key，不便于在外展示，屏蔽之; - // UserAccountSet userAccountSet = - // ledgerOfNode0.getUserAccountSet(backgroundLedgerBlock); - // PubKey userPubKey = new PubKey(CryptoAlgorithm.ED25519, - // userPubKeyVal.getBytes()); - // String userAddress = AddressEncoding.generateAddress(userPubKey); - // assertEquals(userAddress, userAccountSet.getUser(userAddress).getAddress()); - } - - private void prepareContractData(AsymmetricKeypair adminKey, HashDigest ledgerHash, BlockchainService blockchainService, - IntegratedContext context) { - - // 定义交易； - TransactionTemplate txTpl = blockchainService.newTransaction(ledgerHash); - // 注册数据账户，并验证最终写入； - txTpl.dataAccounts().register(contractDataKey.getIdentity()); - DataAccountKVSetOperation kvsetOP = txTpl.dataAccount(contractDataKey.getAddress()) - .setText("A", "Value_A_0", -1).setText("B", "Value_B_0", -1) - .setText(KEY_TOTAL, "total value,dataAccount", -1) - .setText(KEY_ABC, "abc value,dataAccount", -1) - // 所有的模拟数据都在这个dataAccount中填充; - .setBytes("ledgerHash", ledgerHash.getRawDigest(), -1).getOperation(); - - // 签名； - PreparedTransaction ptx = txTpl.prepare(); - ptx.sign(adminKey); - - // 提交并等待共识返回； - TransactionResponse txResp = ptx.commit(); - - // 验证结果； - Node node0 = context.getNode(0); - - LedgerQuery ledgerOfNode0 = node0.getLedgerManager().getLedger(ledgerHash); - LedgerBlock block = ledgerOfNode0.getBlock(txResp.getBlockHeight()); - BytesValue val1InDb = ledgerOfNode0.getDataAccountSet(block).getAccount(contractDataKey.getAddress()) - .getDataset().getValue("A"); - BytesValue val2InDb = ledgerOfNode0.getDataAccountSet(block).getAccount(contractDataKey.getAddress()) - .getDataset().getValue(KEY_TOTAL); - } - - /** - * 根据合约构建字节数组; - * - * @return - */ - private byte[] getChainCodeBytes() { - // 构建合约的字节数组; - byte[] contractCode = null; - File file = null; - InputStream input = null; - try { - ClassPathResource contractPath = new ClassPathResource(contractZipName); - file = new File(contractPath.getURI()); - input = new FileInputStream(file); - // 这种暴力的读取压缩包，在class解析时有问题，所有需要改进; - contractCode = new byte[input.available()]; - input.read(contractCode); - } catch (IOException e) { - e.printStackTrace(); - } finally { - try { - if (input != null) { - input.close(); - } - } catch (IOException e) { - e.printStackTrace(); - } - } - return contractCode; - } -} +//package test.com.jd.blockchain.intgr; +// +//import java.io.File; +//import java.io.FileInputStream; +//import java.io.IOException; +//import java.io.InputStream; +//import java.util.Properties; +//import java.util.Random; +//import java.util.concurrent.CountDownLatch; +// +//import org.mockito.Mockito; +//import org.springframework.core.io.ClassPathResource; +// +//import com.jd.blockchain.consensus.ConsensusProvider; +//import com.jd.blockchain.consensus.ConsensusProviders; +//import com.jd.blockchain.consensus.ConsensusSettings; +//import com.jd.blockchain.consensus.bftsmart.BftsmartConsensusProvider; +//import com.jd.blockchain.consensus.service.NodeServerFactory; +//import com.jd.blockchain.crypto.AddressEncoding; +//import com.jd.blockchain.crypto.AsymmetricKeypair; +//import com.jd.blockchain.crypto.Crypto; +//import com.jd.blockchain.crypto.HashDigest; +//import com.jd.blockchain.crypto.KeyGenUtils; +//import com.jd.blockchain.crypto.PrivKey; +//import com.jd.blockchain.crypto.PubKey; +//import com.jd.blockchain.gateway.GatewayConfigProperties.KeyPairConfig; +//import com.jd.blockchain.ledger.BlockchainIdentity; +//import com.jd.blockchain.ledger.BlockchainKeyGenerator; +//import com.jd.blockchain.ledger.BlockchainKeypair; +//import com.jd.blockchain.ledger.BytesValue; +//import com.jd.blockchain.ledger.DataAccountKVSetOperation; +//import com.jd.blockchain.ledger.LedgerBlock; +//import com.jd.blockchain.ledger.LedgerInfo; +//import com.jd.blockchain.ledger.LedgerInitProperties; +//import com.jd.blockchain.ledger.ParticipantNode; +//import com.jd.blockchain.ledger.PreparedTransaction; +//import com.jd.blockchain.ledger.TransactionResponse; +//import com.jd.blockchain.ledger.TransactionTemplate; +//import com.jd.blockchain.ledger.TypedKVEntry; +//import com.jd.blockchain.ledger.UserInfo; +//import com.jd.blockchain.ledger.core.DataAccountQuery; +//import com.jd.blockchain.ledger.core.LedgerManage; +//import com.jd.blockchain.ledger.core.LedgerManager; +//import com.jd.blockchain.ledger.core.LedgerQuery; +//import com.jd.blockchain.sdk.BlockchainService; +//import com.jd.blockchain.sdk.client.GatewayServiceFactory; +//import com.jd.blockchain.storage.service.KVStorageService; +//import com.jd.blockchain.tools.initializer.DBConnectionConfig; +//import com.jd.blockchain.tools.initializer.LedgerBindingConfig; +//import com.jd.blockchain.tools.initializer.Prompter; +//import com.jd.blockchain.utils.Bytes; +//import com.jd.blockchain.utils.codec.HexUtils; +//import com.jd.blockchain.utils.concurrent.ThreadInvoker.AsyncCallback; +//import com.jd.blockchain.utils.net.NetworkAddress; +// +//import test.com.jd.blockchain.intgr.IntegratedContext.Node; +//import test.com.jd.blockchain.intgr.perf.LedgerInitializeWebTest; +//import test.com.jd.blockchain.intgr.perf.Utils; +// +//public class IntegrationTest { +// // 合约测试使用的初始化数据; +// BlockchainKeypair contractDataKey = BlockchainKeyGenerator.getInstance().generate(); +// BlockchainKeypair contractDeployKey = BlockchainKeyGenerator.getInstance().generate(); +// private String contractZipName = "AssetContract1.contract"; +// private String eventName = "issue-asset"; +// HashDigest txContentHash; +// // String userPubKeyVal = "this is user's pubKey"; +// // 保存资产总数的键； +// private static final String KEY_TOTAL = "TOTAL"; +// // 第二个参数; +// private static final String KEY_ABC = "abc"; +// +// private static final String MQ_SERVER = "nats://127.0.0.1:4222"; +// +// private static final String MQ_TOPIC = "subject"; +// +// private static String memDbConnString = LedgerInitConsensusConfig.memConnectionStrings[0]; +// +// // private static final MQConnectionConfig mqConnConfig = new +// // MQConnectionConfig(); +// // static { +// // mqConnConfig.setServer(MQ_SERVER); +// // mqConnConfig.setTopic(MQ_TOPIC); +// // } +// +// public static void main_(String[] args) { +// // init ledgers of all nodes ; +// IntegratedContext context = initLedgers(); +// Node node0 = context.getNode(0); +// Node node1 = context.getNode(1); +// Node node2 = context.getNode(2); +// Node node3 = context.getNode(3); +// +// BftsmartConsensusProvider csProvider0 = new BftsmartConsensusProvider(); +// NodeServerFactory mockedNodeServerFactory0 = Mockito.spy(csProvider0.getServerFactory()); +// +// NetworkAddress peerSrvAddr0 = new NetworkAddress("127.0.0.1", 10200); +// PeerTestRunner peer0 = new PeerTestRunner(peerSrvAddr0, node0.getBindingConfig(), node0.getStorageDB()); +// +// NetworkAddress peerSrvAddr1 = new NetworkAddress("127.0.0.1", 10210); +// PeerTestRunner peer1 = new PeerTestRunner(peerSrvAddr1, node1.getBindingConfig(), node1.getStorageDB()); +// +// NetworkAddress peerSrvAddr2 = new NetworkAddress("127.0.0.1", 10220); +// PeerTestRunner peer2 = new PeerTestRunner(peerSrvAddr2, node2.getBindingConfig(), node2.getStorageDB()); +// +// NetworkAddress peerSrvAddr3 = new NetworkAddress("127.0.0.1", 10230); +// PeerTestRunner peer3 = new PeerTestRunner(peerSrvAddr3, node3.getBindingConfig(), node3.getStorageDB()); +// +// AsyncCallback peerStarting0 = peer0.start(); +// AsyncCallback peerStarting1 = peer1.start(); +// AsyncCallback peerStarting2 = peer2.start(); +// AsyncCallback peerStarting3 = peer3.start(); +// +// peerStarting0.waitReturn(); +// peerStarting1.waitReturn(); +// peerStarting2.waitReturn(); +// peerStarting3.waitReturn(); +// +// String encodedBase58Pwd = KeyGenUtils.encodePasswordAsBase58(LedgerInitializeWebTest.PASSWORD); +// +// KeyPairConfig gwkey0 = new KeyPairConfig(); +// gwkey0.setPubKeyValue(LedgerInitializeWebTest.PUB_KEYS[0]); +// gwkey0.setPrivKeyValue(LedgerInitializeWebTest.PRIV_KEYS[0]); +// gwkey0.setPrivKeyPassword(encodedBase58Pwd); +// // GatewayTestRunner gateway0 = new GatewayTestRunner("127.0.0.1", 10300, +// // gwkey0, peerSrvAddr0); +// GatewayTestRunner gateway0 = new GatewayTestRunner("127.0.0.1", 10300, gwkey0, peerSrvAddr0); +// +// // KeyPairConfig gwkey1 = new KeyPairConfig(); +// // gwkey1.setPubKeyValue(LedgerInitializeWebTest.PUB_KEYS[1]); +// // gwkey1.setPrivKeyValue(LedgerInitializeWebTest.PRIV_KEYS[1]); +// // gwkey1.setPrivKeyPassword(encodedBase58Pwd); +// // GatewayTestRunner gateway1 = new GatewayTestRunner("127.0.0.1", 10310, +// // gwkey1, peerSrvAddr1); +// +// AsyncCallback gwStarting0 = gateway0.start(); +// // AsyncCallback gwStarting1 = gateway1.start(); +// +// gwStarting0.waitReturn(); +// // gwStarting1.waitReturn(); +// +// // 执行测试用例之前，校验每个节点的一致性； +// // testConsistencyAmongNodes(context); +// +// testSDK(gateway0, context); +// +// // 执行测试用例之后，校验每个节点的一致性； +// // testConsistencyAmongNodes(context); +// } +// +// /** +// * 检查所有节点之间的账本是否一致； +// * +// * @param context +// */ +// private void testConsistencyAmongNodes(IntegratedContext context) { +// int[] ids = context.getNodeIds(); +// Node[] nodes = new Node[ids.length]; +// LedgerQuery[] ledgers = new LedgerQuery[ids.length]; +// for (int i = 0; i < nodes.length; i++) { +// nodes[i] = context.getNode(ids[i]); +// HashDigest ledgerHash = nodes[i].getLedgerManager().getLedgerHashs()[0]; +// ledgers[i] = nodes[i].getLedgerManager().getLedger(ledgerHash); +// } +// LedgerQuery ledger0 = ledgers[0]; +// LedgerBlock latestBlock0 = ledger0.retrieveLatestBlock(); +// for (int i = 1; i < ledgers.length; i++) { +// LedgerQuery otherLedger = ledgers[i]; +// LedgerBlock otherLatestBlock = otherLedger.retrieveLatestBlock(); +// } +// } +// +// private static void testSDK(GatewayTestRunner gateway, IntegratedContext context) { +// // 连接网关； +// GatewayServiceFactory gwsrvFact = GatewayServiceFactory.connect(gateway.getServiceAddress()); +// BlockchainService bcsrv = gwsrvFact.getBlockchainService(); +// +// HashDigest[] ledgerHashs = bcsrv.getLedgerHashs(); +// +// AsymmetricKeypair adminKey = context.getNode(0).getPartiKeyPair(); +// +// BlockchainKeypair newUserAcount = testSDK_RegisterUser(adminKey, ledgerHashs[0], bcsrv, context); +// +// // BlockchainKeyPair newDataAccount = testSDK_RegisterDataAccount(adminKey, +// // ledgerHashs[0], bcsrv, context); +// // +// // testSDK_InsertData(adminKey, ledgerHashs[0], bcsrv, +// // newDataAccount.getAddress(), context); +// // +// // LedgerBlock latestBlock = testSDK_Contract(adminKey, ledgerHashs[0], bcsrv, +// // context); +// +// } +// +// private void testSDK_InsertData(AsymmetricKeypair adminKey, HashDigest ledgerHash, BlockchainService blockchainService, +// String dataAccountAddress, IntegratedContext context) { +// +// // 在本地定义注册账号的 TX； +// TransactionTemplate txTemp = blockchainService.newTransaction(ledgerHash); +// +// // -------------------------------------- +// // 将商品信息写入到指定的账户中； +// // 对象将被序列化为 JSON 形式存储，并基于 JSON 结构建立查询索引； +// String dataAccount = dataAccountAddress; +// +// String dataKey = "jingdong" + new Random().nextInt(100000); +// String dataVal = "www.jd.com"; +// +// txTemp.dataAccount(dataAccount).setText(dataKey, dataVal, -1); +// +// // TX 准备就绪； +// PreparedTransaction prepTx = txTemp.prepare(); +// +// // 使用私钥进行签名； +// prepTx.sign(adminKey); +// +// // 提交交易； +// TransactionResponse txResp = prepTx.commit(); +// +// Node node0 = context.getNode(0); +// LedgerQuery ledgerOfNode0 = node0.getLedgerManager().getLedger(ledgerHash); +// ledgerOfNode0.retrieveLatestBlock(); // 更新内存 +// +// // 先验证应答 +// TypedKVEntry[] kvDataEntries = blockchainService.getDataEntries(ledgerHash, dataAccountAddress, dataKey); +// for (TypedKVEntry kvDataEntry : kvDataEntries) { +// String valHexText = (String) kvDataEntry.getValue(); +// byte[] valBytes = HexUtils.decode(valHexText); +// String valText = new String(valBytes); +// System.out.println(valText); +// } +// } +// +// private static BlockchainKeypair testSDK_RegisterUser(AsymmetricKeypair adminKey, HashDigest ledgerHash, +// BlockchainService blockchainService, IntegratedContext context) { +// // 注册用户，并验证最终写入； +// BlockchainKeypair user = BlockchainKeyGenerator.getInstance().generate(); +// +// // 定义交易； +// TransactionTemplate txTpl = blockchainService.newTransaction(ledgerHash); +// txTpl.users().register(user.getIdentity()); +// +// // 签名； +// PreparedTransaction ptx = txTpl.prepare(); +// +// HashDigest transactionHash = ptx.getHash(); +// +// ptx.sign(adminKey); +// +// // 提交并等待共识返回； +// TransactionResponse txResp = ptx.commit(); +// +// // 验证结果; +// Node node0 = context.getNode(0); +// LedgerManage ledgerManager = new LedgerManager(); +// +// KVStorageService storageService = node0.getStorageDB().connect(memDbConnString).getStorageService(); +// +// LedgerQuery ledgerOfNode0 = ledgerManager.register(ledgerHash, storageService); +// +// return user; +// } +// +// private BlockchainKeypair testSDK_RegisterDataAccount(AsymmetricKeypair adminKey, HashDigest ledgerHash, +// BlockchainService blockchainService, IntegratedContext context) { +// // 注册数据账户，并验证最终写入； +// BlockchainKeypair dataAccount = BlockchainKeyGenerator.getInstance().generate(); +// +// // 定义交易； +// TransactionTemplate txTpl = blockchainService.newTransaction(ledgerHash); +// txTpl.dataAccounts().register(dataAccount.getIdentity()); +// +// // 签名； +// PreparedTransaction ptx = txTpl.prepare(); +// +// HashDigest transactionHash = ptx.getHash(); +// +// ptx.sign(adminKey); +// +// // 提交并等待共识返回； +// TransactionResponse txResp = ptx.commit(); +// +// // 验证结果; +// Node node0 = context.getNode(0); +// // LedgerRepository ledgerOfNode0 = +// // node0.getLedgerManager().getLedger(ledgerHash); +// LedgerManage ledgerManager = new LedgerManager(); +// +// KVStorageService storageService = node0.getStorageDB().connect(memDbConnString).getStorageService(); +// +// LedgerQuery ledgerOfNode0 = ledgerManager.register(ledgerHash, storageService); +// long latestBlockHeight = ledgerOfNode0.retrieveLatestBlockHeight(); +// +// return dataAccount; +// } +// +// private void testSDK_Query(AsymmetricKeypair adminKey, HashDigest ledgerHash, BlockchainService blockchainService, +// IntegratedContext context, BlockchainKeypair newUserAcount, BlockchainKeypair newDataAcount) { +// +// Bytes userAddress = newUserAcount.getAddress(); +// Bytes dataAddress = newDataAcount.getAddress(); +// +// Node node0 = context.getNode(0); +// // LedgerRepository ledgerOfNode0 = +// // node0.getLedgerManager().getLedger(ledgerHash); +// LedgerManage ledgerManager = new LedgerManager(); +// +// KVStorageService storageService = node0.getStorageDB().connect(memDbConnString).getStorageService(); +// +// LedgerQuery ledgerOfNode0 = ledgerManager.register(ledgerHash, storageService); +// +// // getLedgerHashs +// HashDigest[] ledgerHashs = blockchainService.getLedgerHashs(); +// for (HashDigest hashDigest : ledgerHashs) { +// if (hashDigest.equals(ledgerHash)) { +// break; +// } +// System.out.println("Query getLedgerHashs error! ledgerHash not exist!"); +// } +// +// // getLedger +// LedgerInfo ledgerInfo = blockchainService.getLedger(ledgerHash); +// long ledgerHeight = ledgerInfo.getLatestBlockHeight(); +// +// // getConsensusParticipants +// ParticipantNode[] consensusParticipants = blockchainService.getConsensusParticipants(ledgerHash); +// for (int i = 0; i < 4; i++) { +// } +// +// // getBlock +// for (int i = 0; i < ledgerHeight + 1; i++) { +// LedgerBlock expectBlock = ledgerOfNode0.getBlock(i); +// } +// +// // getTransactionCount according to blockhash +// for (int i = 0; i < ledgerHeight + 1; i++) { +// LedgerBlock expectBlock = ledgerOfNode0.getBlock(i); +// long expectTransactionCount = ledgerOfNode0.getTransactionSet(expectBlock).getTotalCount(); +// long actualTransactionCount = blockchainService.getTransactionCount(ledgerHash, expectBlock.getHash()); +// } +// +// // getDataAccountCount according to blockhash +// for (int i = 0; i < ledgerHeight + 1; i++) { +// LedgerBlock expectBlock = ledgerOfNode0.getBlock(i); +// long expectDataCount = ledgerOfNode0.getDataAccountSet(expectBlock).getTotal(); +// long actualDataCount = blockchainService.getDataAccountCount(ledgerHash, expectBlock.getHash()); +// } +// +// // getUserCount according to blockhash +// for (int i = 0; i < ledgerHeight + 1; i++) { +// LedgerBlock expectBlock = ledgerOfNode0.getBlock(i); +// long expectUserCount = ledgerOfNode0.getUserAccountSet(expectBlock).getTotal(); +// long actualUserCount = blockchainService.getUserCount(ledgerHash, expectBlock.getHash()); +// } +// +// // getContractCount according to blockhash +// for (int i = 0; i < ledgerHeight + 1; i++) { +// LedgerBlock expectBlock = ledgerOfNode0.getBlock(i); +// long expectContractCount = ledgerOfNode0.getContractAccountSet(expectBlock).getTotal(); +// long actualContractCount = blockchainService.getContractCount(ledgerHash, expectBlock.getHash()); +// } +// +// // getTransactionCount according to height +// // getDataAccountCount according to height +// // getUserCount according to height +// // getContractCount according to height +// long expectTransactionTotal = 0; +// long expectUserTotal = 0; +// long expectDataTotal = 0; +// long expectContractTotal = 0; +// for (int i = 0; i < ledgerHeight + 1; i++) { +// // actual block acount total +// long transactionCount = blockchainService.getTransactionCount(ledgerHash, i); +// long userCount = blockchainService.getUserCount(ledgerHash, i); +// long dataCount = blockchainService.getDataAccountCount(ledgerHash, i); +// long contractCount = blockchainService.getContractCount(ledgerHash, i); +// +// // expect block acount total +// LedgerBlock ledgerBlock = ledgerOfNode0.getBlock(i); +// expectTransactionTotal = ledgerOfNode0.getTransactionSet(ledgerBlock).getTotalCount(); +// expectUserTotal = ledgerOfNode0.getUserAccountSet(ledgerBlock).getTotal(); +// expectDataTotal = ledgerOfNode0.getDataAccountSet(ledgerBlock).getTotal(); +// expectContractTotal = ledgerOfNode0.getContractAccountSet(ledgerBlock).getTotal(); +// } +// +// // getTransactionTotalCount +// long actualTransactionTotal = blockchainService.getTransactionTotalCount(ledgerHash); +// +// // getUserTotalCount +// long actualUserTotal = blockchainService.getUserTotalCount(ledgerHash); +// +// // getDataAccountTotalCount +// long actualDataAccountTotal = blockchainService.getDataAccountTotalCount(ledgerHash); +// +// // getContractTotalCount +// long actualContractAccountTotal = blockchainService.getContractTotalCount(ledgerHash); +// +// // getTransactions +// // getTransactionByContentHash +// // getTransactionStateByContentHash +// // ledger-core not implement +// // for (int i = 0; i < ledgerHeight + 1; i++) { +// // LedgerBlock ledgerBlock = ledgerOfNode0.getBlock(i); +// // HashDigest blockHash = ledgerBlock.getHash(); +// // long expectCount = +// // ledgerOfNode0.getTransactionSet(ledgerBlock).getTotalCount(); +// // long actualCount = blockchainService.getTransactionCount(ledgerHash, i); +// // LedgerTransaction[] ledgerTransactions1 = +// // blockchainService.getTransactions(ledgerHash, i, 0, (int)(actualCount - 1)); +// // LedgerTransaction[] ledgerTransactions2 = +// // blockchainService.getTransactions(ledgerHash, blockHash, 0, (int)(expectCount +// // - 1)); +// // assertEquals(ledgerTransactions1.length, ledgerTransactions2.length); +// // assertArrayEquals(ledgerTransactions1, ledgerTransactions2); +// // +// // for (LedgerTransaction ledgerTransaction : ledgerTransactions1) { +// // assertEquals(ledgerTransaction, +// // blockchainService.getTransactionByContentHash(ledgerHash, +// // ledgerTransaction.getTransactionContent().getHash())); +// // assertEquals(TransactionState.SUCCESS, +// // blockchainService.getTransactionStateByContentHash(ledgerHash, +// // ledgerTransaction.getTransactionContent().getHash())); +// // } +// // } +// // getUser +// UserInfo userInfo = blockchainService.getUser(ledgerHash, userAddress.toString()); +// +// // getDataAccount +// BlockchainIdentity accountHeader = blockchainService.getDataAccount(ledgerHash, dataAddress.toString()); +// +// // getDataEntries +// +// return; +// } +// +// public static ConsensusProvider getConsensusProvider() { +// return ConsensusProviders.getProvider("com.jd.blockchain.consensus.bftsmart.BftsmartConsensusProvider"); +// } +// +// private static IntegratedContext initLedgers() { +// Prompter consolePrompter = new PresetAnswerPrompter("N"); // new ConsolePrompter(); +// LedgerInitProperties initSetting = loadInitSetting_integration(); +// Properties props = LedgerInitializeWebTest.loadConsensusSetting(); +// ConsensusProvider csProvider = getConsensusProvider(); +// ConsensusSettings csProps = csProvider.getSettingsFactory() +// .getConsensusSettingsBuilder() +// .createSettings(props, Utils.loadParticipantNodes()); +// +// // 启动服务器； +// NetworkAddress initAddr0 = initSetting.getConsensusParticipant(0).getInitializerAddress(); +// LedgerInitializeWebTest.NodeWebContext nodeCtx0 = new LedgerInitializeWebTest.NodeWebContext(0, initAddr0); +// +// NetworkAddress initAddr1 = initSetting.getConsensusParticipant(1).getInitializerAddress(); +// LedgerInitializeWebTest.NodeWebContext nodeCtx1 = new LedgerInitializeWebTest.NodeWebContext(1, initAddr1); +// +// NetworkAddress initAddr2 = initSetting.getConsensusParticipant(2).getInitializerAddress(); +// LedgerInitializeWebTest.NodeWebContext nodeCtx2 = new LedgerInitializeWebTest.NodeWebContext(2, initAddr2); +// +// NetworkAddress initAddr3 = initSetting.getConsensusParticipant(3).getInitializerAddress(); +// LedgerInitializeWebTest.NodeWebContext nodeCtx3 = new LedgerInitializeWebTest.NodeWebContext(3, initAddr3); +// PrivKey privkey0 = KeyGenUtils.decodePrivKeyWithRawPassword(LedgerInitializeWebTest.PRIV_KEYS[0], +// LedgerInitializeWebTest.PASSWORD); +// PrivKey privkey1 = KeyGenUtils.decodePrivKeyWithRawPassword(LedgerInitializeWebTest.PRIV_KEYS[1], +// LedgerInitializeWebTest.PASSWORD); +// PrivKey privkey2 = KeyGenUtils.decodePrivKeyWithRawPassword(LedgerInitializeWebTest.PRIV_KEYS[2], +// LedgerInitializeWebTest.PASSWORD); +// PrivKey privkey3 = KeyGenUtils.decodePrivKeyWithRawPassword(LedgerInitializeWebTest.PRIV_KEYS[3], +// LedgerInitializeWebTest.PASSWORD); +// +// String encodedPassword = KeyGenUtils.encodePasswordAsBase58(LedgerInitializeWebTest.PASSWORD); +// +// CountDownLatch quitLatch = new CountDownLatch(4); +// +// DBConnectionConfig testDb0 = new DBConnectionConfig(); +// testDb0.setConnectionUri("memory://local/0"); +// LedgerBindingConfig bindingConfig0 = new LedgerBindingConfig(); +// AsyncCallback callback0 = nodeCtx0.startInitCommand(privkey0, encodedPassword, initSetting, csProps, +// csProvider, testDb0, consolePrompter, bindingConfig0, quitLatch); +// +// DBConnectionConfig testDb1 = new DBConnectionConfig(); +// testDb1.setConnectionUri("memory://local/1"); +// LedgerBindingConfig bindingConfig1 = new LedgerBindingConfig(); +// AsyncCallback callback1 = nodeCtx1.startInitCommand(privkey1, encodedPassword, initSetting, csProps, +// csProvider, testDb1, consolePrompter, bindingConfig1, quitLatch); +// +// DBConnectionConfig testDb2 = new DBConnectionConfig(); +// testDb2.setConnectionUri("memory://local/2"); +// LedgerBindingConfig bindingConfig2 = new LedgerBindingConfig(); +// AsyncCallback callback2 = nodeCtx2.startInitCommand(privkey2, encodedPassword, initSetting, csProps, +// csProvider, testDb2, consolePrompter, bindingConfig2, quitLatch); +// +// DBConnectionConfig testDb3 = new DBConnectionConfig(); +// testDb3.setConnectionUri("memory://local/3"); +// LedgerBindingConfig bindingConfig3 = new LedgerBindingConfig(); +// AsyncCallback callback3 = nodeCtx3.startInitCommand(privkey3, encodedPassword, initSetting, csProps, +// csProvider, testDb3, consolePrompter, bindingConfig3, quitLatch); +// +// HashDigest ledgerHash0 = callback0.waitReturn(); +// HashDigest ledgerHash1 = callback1.waitReturn(); +// HashDigest ledgerHash2 = callback2.waitReturn(); +// HashDigest ledgerHash3 = callback3.waitReturn(); +// +// LedgerQuery ledger0 = nodeCtx0.registLedger(ledgerHash0); +// LedgerQuery ledger1 = nodeCtx1.registLedger(ledgerHash1); +// LedgerQuery ledger2 = nodeCtx2.registLedger(ledgerHash2); +// LedgerQuery ledger3 = nodeCtx3.registLedger(ledgerHash3); +// +// IntegratedContext context = new IntegratedContext(); +// +// Node node0 = new Node(0); +// node0.setConsensusSettings(csProps); +// node0.setLedgerManager(nodeCtx0.getLedgerManager()); +// node0.setStorageDB(nodeCtx0.getStorageDB()); +// node0.setPartiKeyPair(new AsymmetricKeypair(initSetting.getConsensusParticipant(0).getPubKey(), privkey0)); +// node0.setBindingConfig(bindingConfig0); +// context.addNode(node0); +// +// Node node1 = new Node(1); +// node1.setConsensusSettings(csProps); +// node1.setLedgerManager(nodeCtx1.getLedgerManager()); +// node1.setStorageDB(nodeCtx1.getStorageDB()); +// node1.setPartiKeyPair(new AsymmetricKeypair(initSetting.getConsensusParticipant(1).getPubKey(), privkey1)); +// node1.setBindingConfig(bindingConfig1); +// context.addNode(node1); +// +// Node node2 = new Node(2); +// node2.setConsensusSettings(csProps); +// node2.setLedgerManager(nodeCtx2.getLedgerManager()); +// node2.setStorageDB(nodeCtx2.getStorageDB()); +// node2.setPartiKeyPair(new AsymmetricKeypair(initSetting.getConsensusParticipant(2).getPubKey(), privkey2)); +// node2.setBindingConfig(bindingConfig2); +// context.addNode(node2); +// +// Node node3 = new Node(3); +// node3.setConsensusSettings(csProps); +// node3.setLedgerManager(nodeCtx3.getLedgerManager()); +// node3.setStorageDB(nodeCtx3.getStorageDB()); +// node3.setPartiKeyPair(new AsymmetricKeypair(initSetting.getConsensusParticipant(3).getPubKey(), privkey3)); +// node3.setBindingConfig(bindingConfig3); +// context.addNode(node3); +// +// nodeCtx0.closeServer(); +// nodeCtx1.closeServer(); +// nodeCtx2.closeServer(); +// nodeCtx3.closeServer(); +// +// return context; +// } +// +// public static LedgerInitProperties loadInitSetting_integration() { +// ClassPathResource ledgerInitSettingResource = new ClassPathResource("ledger_init_test_integration.init"); +// try (InputStream in = ledgerInitSettingResource.getInputStream()) { +// LedgerInitProperties setting = LedgerInitProperties.resolve(in); +// return setting; +// } catch (IOException e) { +// throw new IllegalStateException(e.getMessage(), e); +// } +// } +// +// private LedgerBlock testSDK_Contract(AsymmetricKeypair adminKey, HashDigest ledgerHash, +// BlockchainService blockchainService, IntegratedContext context) { +// // valid the basic data in contract; +// prepareContractData(adminKey, ledgerHash, blockchainService, context); +// +// BlockchainKeypair userKey = BlockchainKeyGenerator.getInstance().generate(); +// +// // 定义交易； +// TransactionTemplate txTpl = blockchainService.newTransaction(ledgerHash); +// byte[] contractCode = getChainCodeBytes(); +// +// txTpl.users().register(userKey.getIdentity()); +// +// txTpl.contracts().deploy(contractDeployKey.getIdentity(), contractCode); +// +// // 签名； +// PreparedTransaction ptx = txTpl.prepare(); +// ptx.sign(adminKey); +// +// // 提交并等待共识返回； +// TransactionResponse txResp = ptx.commit(); +// +// // 验证结果； +// txResp.getContentHash(); +// +// Node node0 = context.getNode(0); +// LedgerQuery ledgerOfNode0 = node0.getLedgerManager().getLedger(ledgerHash); +// LedgerBlock block = ledgerOfNode0.getBlock(txResp.getBlockHeight()); +// byte[] contractCodeInDb = ledgerOfNode0.getContractAccountSet(block).getAccount(contractDeployKey.getAddress()) +// .getChainCode(); +// txContentHash = ptx.getHash(); +// +// // execute the contract; +// testContractExe(adminKey, ledgerHash, userKey, blockchainService, context); +// +// return block; +// } +// +// private void testContractExe(AsymmetricKeypair adminKey, HashDigest ledgerHash, BlockchainKeypair userKey, +// BlockchainService blockchainService, IntegratedContext context) { +// LedgerInfo ledgerInfo = blockchainService.getLedger(ledgerHash); +// LedgerBlock previousBlock = blockchainService.getBlock(ledgerHash, ledgerInfo.getLatestBlockHeight() - 1); +// +// // 定义交易； +// TransactionTemplate txTpl = blockchainService.newTransaction(ledgerHash); +// +//// txTpl.contractEvents().send(contractDeployKey.getAddress(), eventName, +//// ("888##abc##" + contractDataKey.getAddress() + "##" + previousBlock.getHash().toBase58() + "##" +//// + userKey.getAddress() + "##" + contractDeployKey.getAddress() + "##" + txContentHash.toBase58() +//// + "##SOME-VALUE").getBytes()); +// +// // 签名； +// PreparedTransaction ptx = txTpl.prepare(); +// ptx.sign(adminKey); +// +// // 提交并等待共识返回； +// TransactionResponse txResp = ptx.commit(); +// +// // 验证结果； +// txResp.getContentHash(); +// +// LedgerInfo latestLedgerInfo = blockchainService.getLedger(ledgerHash); +// +// Node node0 = context.getNode(0); +// LedgerQuery ledgerOfNode0 = node0.getLedgerManager().getLedger(ledgerHash); +// LedgerBlock backgroundLedgerBlock = ledgerOfNode0.retrieveLatestBlock(); +// +// // 验证合约中的赋值，外部可以获得; +// DataAccountQuery dataAccountSet = ledgerOfNode0.getDataAccountSet(backgroundLedgerBlock); +// AsymmetricKeypair key = Crypto.getSignatureFunction("ED25519").generateKeypair(); +// PubKey pubKey = key.getPubKey(); +// Bytes dataAddress = AddressEncoding.generateAddress(pubKey); +// +// // 验证userAccount，从合约内部赋值，然后外部验证;由于目前不允许输入重复的key，所以在内部合约中构建的key，不便于在外展示，屏蔽之; +// // UserAccountSet userAccountSet = +// // ledgerOfNode0.getUserAccountSet(backgroundLedgerBlock); +// // PubKey userPubKey = new PubKey(CryptoAlgorithm.ED25519, +// // userPubKeyVal.getBytes()); +// // String userAddress = AddressEncoding.generateAddress(userPubKey); +// // assertEquals(userAddress, userAccountSet.getUser(userAddress).getAddress()); +// } +// +// private void prepareContractData(AsymmetricKeypair adminKey, HashDigest ledgerHash, BlockchainService blockchainService, +// IntegratedContext context) { +// +// // 定义交易； +// TransactionTemplate txTpl = blockchainService.newTransaction(ledgerHash); +// // 注册数据账户，并验证最终写入； +// txTpl.dataAccounts().register(contractDataKey.getIdentity()); +// DataAccountKVSetOperation kvsetOP = txTpl.dataAccount(contractDataKey.getAddress()) +// .setText("A", "Value_A_0", -1).setText("B", "Value_B_0", -1) +// .setText(KEY_TOTAL, "total value,dataAccount", -1) +// .setText(KEY_ABC, "abc value,dataAccount", -1) +// // 所有的模拟数据都在这个dataAccount中填充; +// .setBytes("ledgerHash", ledgerHash.getRawDigest(), -1).getOperation(); +// +// // 签名； +// PreparedTransaction ptx = txTpl.prepare(); +// ptx.sign(adminKey); +// +// // 提交并等待共识返回； +// TransactionResponse txResp = ptx.commit(); +// +// // 验证结果； +// Node node0 = context.getNode(0); +// +// LedgerQuery ledgerOfNode0 = node0.getLedgerManager().getLedger(ledgerHash); +// LedgerBlock block = ledgerOfNode0.getBlock(txResp.getBlockHeight()); +// BytesValue val1InDb = ledgerOfNode0.getDataAccountSet(block).getAccount(contractDataKey.getAddress()) +// .getDataset().getValue("A"); +// BytesValue val2InDb = ledgerOfNode0.getDataAccountSet(block).getAccount(contractDataKey.getAddress()) +// .getDataset().getValue(KEY_TOTAL); +// } +// +// /** +// * 根据合约构建字节数组; +// * +// * @return +// */ +// private byte[] getChainCodeBytes() { +// // 构建合约的字节数组; +// byte[] contractCode = null; +// File file = null; +// InputStream input = null; +// try { +// ClassPathResource contractPath = new ClassPathResource(contractZipName); +// file = new File(contractPath.getURI()); +// input = new FileInputStream(file); +// // 这种暴力的读取压缩包，在class解析时有问题，所有需要改进; +// contractCode = new byte[input.available()]; +// input.read(contractCode); +// } catch (IOException e) { +// e.printStackTrace(); +// } finally { +// try { +// if (input != null) { +// input.close(); +// } +// } catch (IOException e) { +// e.printStackTrace(); +// } +// } +// return contractCode; +// } +//}