diff --git a/source/ledger/ledger-model/src/main/java/com/jd/blockchain/contract/ContractJarUtils.java b/source/ledger/ledger-model/src/main/java/com/jd/blockchain/contract/ContractJarUtils.java index d27323f2..775d0ec5 100644 --- a/source/ledger/ledger-model/src/main/java/com/jd/blockchain/contract/ContractJarUtils.java +++ b/source/ledger/ledger-model/src/main/java/com/jd/blockchain/contract/ContractJarUtils.java @@ -17,9 +17,9 @@ import java.util.jar.JarOutputStream; public class ContractJarUtils { - public static final String BLACK_CONF = "black.conf"; + public static final String BLACK_CONF = "blacks.conf"; - public static final String WHITE_CONF = "white.conf"; + public static final String WHITE_CONF = "whites.conf"; private static final String CONTRACT_MF = "META-INF/CONTRACT.MF"; diff --git a/source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/RoleInitData.java b/source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/RoleInitData.java index ea1822e2..090b19f8 100644 --- a/source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/RoleInitData.java +++ b/source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/RoleInitData.java @@ -1,7 +1,13 @@ package com.jd.blockchain.ledger; +import com.jd.blockchain.binaryproto.DataContractRegistry; + public class RoleInitData implements RoleInitSettings { + static { + DataContractRegistry.register(RoleInitSettings.class); + } + private String roleName; private LedgerPermission[] ledgerPermissions; diff --git a/source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/SecurityInitData.java b/source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/SecurityInitData.java index 626adef1..90f51869 100644 --- a/source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/SecurityInitData.java +++ b/source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/SecurityInitData.java @@ -3,10 +3,16 @@ package com.jd.blockchain.ledger; import java.util.LinkedHashMap; import java.util.Map; +import com.jd.blockchain.binaryproto.DataContractRegistry; import com.jd.blockchain.utils.Bytes; public class SecurityInitData implements SecurityInitSettings { + static { + DataContractRegistry.register(SecurityInitSettings.class); + } + + private Map roles = new LinkedHashMap<>(); private Map userAuthentications = new LinkedHashMap<>(); diff --git a/source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/UserAuthInitData.java b/source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/UserAuthInitData.java index 6866c991..81dd5587 100644 --- a/source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/UserAuthInitData.java +++ b/source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/UserAuthInitData.java @@ -1,9 +1,14 @@ package com.jd.blockchain.ledger; +import com.jd.blockchain.binaryproto.DataContractRegistry; import com.jd.blockchain.utils.Bytes; public class UserAuthInitData implements UserAuthInitSettings { + static { + DataContractRegistry.register(UserAuthInitSettings.class); + } + private Bytes userAddress; private String[] roles; diff --git a/source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/UserRoles.java b/source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/UserRoles.java index 2cae56d1..19f86ed8 100644 --- a/source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/UserRoles.java +++ b/source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/UserRoles.java @@ -5,10 +5,15 @@ import java.util.Collections; import java.util.Set; import java.util.TreeSet; +import com.jd.blockchain.binaryproto.DataContractRegistry; import com.jd.blockchain.utils.Bytes; public class UserRoles implements RoleSet { + static { + DataContractRegistry.register(RoleSet.class); + } + private Bytes userAddress; private RolesPolicy policy; diff --git a/source/ledger/ledger-model/src/main/java/com/jd/blockchain/transaction/LedgerInitData.java b/source/ledger/ledger-model/src/main/java/com/jd/blockchain/transaction/LedgerInitData.java index 6de96680..656b4aa3 100644 --- a/source/ledger/ledger-model/src/main/java/com/jd/blockchain/transaction/LedgerInitData.java +++ b/source/ledger/ledger-model/src/main/java/com/jd/blockchain/transaction/LedgerInitData.java @@ -1,12 +1,18 @@ package com.jd.blockchain.transaction; +import com.jd.blockchain.binaryproto.DataContractRegistry; import com.jd.blockchain.ledger.CryptoSetting; import com.jd.blockchain.ledger.LedgerInitSetting; import com.jd.blockchain.ledger.ParticipantNode; +import com.jd.blockchain.ledger.UserAuthInitSettings; import com.jd.blockchain.utils.Bytes; public class LedgerInitData implements LedgerInitSetting { + static { + DataContractRegistry.register(LedgerInitSetting.class); + } + private byte[] ledgerSeed; private ParticipantNode[] consensusParticipants; diff --git a/source/ledger/ledger-model/src/main/java/com/jd/blockchain/transaction/RolesConfigureOpTemplate.java b/source/ledger/ledger-model/src/main/java/com/jd/blockchain/transaction/RolesConfigureOpTemplate.java index ab8d19dc..ba5fc4e5 100644 --- a/source/ledger/ledger-model/src/main/java/com/jd/blockchain/transaction/RolesConfigureOpTemplate.java +++ b/source/ledger/ledger-model/src/main/java/com/jd/blockchain/transaction/RolesConfigureOpTemplate.java @@ -20,6 +20,7 @@ public class RolesConfigureOpTemplate implements RolesConfigurer, RolesConfigure static { DataContractRegistry.register(UserRegisterOperation.class); DataContractRegistry.register(RolesConfigureOperation.class); + DataContractRegistry.register(RolePrivilegeEntry.class); } private Map rolesMap = Collections diff --git a/source/ledger/ledger-model/src/main/java/com/jd/blockchain/transaction/UserAuthorizeOpTemplate.java b/source/ledger/ledger-model/src/main/java/com/jd/blockchain/transaction/UserAuthorizeOpTemplate.java index ed851763..2575fdd5 100644 --- a/source/ledger/ledger-model/src/main/java/com/jd/blockchain/transaction/UserAuthorizeOpTemplate.java +++ b/source/ledger/ledger-model/src/main/java/com/jd/blockchain/transaction/UserAuthorizeOpTemplate.java @@ -19,6 +19,7 @@ public class UserAuthorizeOpTemplate implements UserAuthorizer, UserAuthorizeOpe static { DataContractRegistry.register(UserRegisterOperation.class); DataContractRegistry.register(UserAuthorizeOperation.class); + DataContractRegistry.register(UserRolesEntry.class); } private Set userAuthMap = Collections diff --git a/source/peer/src/main/java/com/jd/blockchain/peer/web/ManagementController.java b/source/peer/src/main/java/com/jd/blockchain/peer/web/ManagementController.java index 9e771a33..ced6284c 100644 --- a/source/peer/src/main/java/com/jd/blockchain/peer/web/ManagementController.java +++ b/source/peer/src/main/java/com/jd/blockchain/peer/web/ManagementController.java @@ -1,270 +1,275 @@ -package com.jd.blockchain.peer.web; - -import java.util.ArrayList; -import java.util.List; -import java.util.Map; -import java.util.concurrent.ConcurrentHashMap; - -import com.jd.blockchain.ledger.*; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.security.authentication.AuthenticationServiceException; -import org.springframework.web.bind.annotation.RequestBody; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RequestMethod; -import org.springframework.web.bind.annotation.RestController; - -import com.jd.blockchain.binaryproto.DataContractRegistry; -import com.jd.blockchain.consensus.ClientIdentification; -import com.jd.blockchain.consensus.ClientIdentifications; -import com.jd.blockchain.consensus.ClientIncomingSettings; -import com.jd.blockchain.consensus.ConsensusProvider; -import com.jd.blockchain.consensus.ConsensusProviders; -import com.jd.blockchain.consensus.ConsensusSettings; -import com.jd.blockchain.consensus.NodeSettings; -import com.jd.blockchain.consensus.action.ActionResponse; -import com.jd.blockchain.consensus.bftsmart.BftsmartConsensusSettings; -import com.jd.blockchain.consensus.bftsmart.BftsmartNodeSettings; -import com.jd.blockchain.consensus.mq.server.MsgQueueMessageDispatcher; -import com.jd.blockchain.consensus.service.MessageHandle; -import com.jd.blockchain.consensus.service.NodeServer; -import com.jd.blockchain.consensus.service.ServerSettings; -import com.jd.blockchain.consensus.service.StateMachineReplicate; -import com.jd.blockchain.crypto.HashDigest; -import com.jd.blockchain.ledger.LedgerAdminInfo; -import com.jd.blockchain.ledger.core.LedgerAdminDataQuery; -import com.jd.blockchain.ledger.core.LedgerManage; -import com.jd.blockchain.ledger.core.LedgerQuery; -import com.jd.blockchain.peer.ConsensusRealm; -import com.jd.blockchain.peer.LedgerBindingConfigAware; -import com.jd.blockchain.peer.PeerManage; -import com.jd.blockchain.setting.GatewayIncomingSetting; -import com.jd.blockchain.setting.LedgerIncomingSetting; -import com.jd.blockchain.storage.service.DbConnection; -import com.jd.blockchain.storage.service.DbConnectionFactory; -import com.jd.blockchain.tools.initializer.LedgerBindingConfig; -import com.jd.blockchain.utils.Bytes; -import com.jd.blockchain.utils.io.ByteArray; -import com.jd.blockchain.web.converters.BinaryMessageConverter; - -/** - * 网关管理服务； - * - * 提供 - * - * @author huanghaiquan - * - */ -@RestController -@RequestMapping(path = "/management") -public class ManagementController implements LedgerBindingConfigAware, PeerManage { - - private static Logger LOGGER = LoggerFactory.getLogger(ManagementController.class); - - public static final String GATEWAY_PUB_EXT_NAME = ".gw.pub"; - - public static final int MIN_GATEWAY_ID = 10000; - - @Autowired - private LedgerManage ledgerManager; - - @Autowired - private DbConnectionFactory connFactory; - - private Map ledgerTxConverters = new ConcurrentHashMap<>(); - - private Map ledgerPeers = new ConcurrentHashMap<>(); - private Map ledgerCryptoSettings = new ConcurrentHashMap<>(); - - - private LedgerBindingConfig config; - - @Autowired - private MessageHandle consensusMessageHandler; - - @Autowired - private StateMachineReplicate consensusStateManager; - - static { - DataContractRegistry.register(LedgerInitOperation.class); - DataContractRegistry.register(LedgerBlock.class); - DataContractRegistry.register(TransactionContent.class); - DataContractRegistry.register(TransactionContentBody.class); - DataContractRegistry.register(TransactionRequest.class); - DataContractRegistry.register(NodeRequest.class); - DataContractRegistry.register(EndpointRequest.class); - DataContractRegistry.register(TransactionResponse.class); - DataContractRegistry.register(DataAccountKVSetOperation.class); - DataContractRegistry.register(DataAccountKVSetOperation.KVWriteEntry.class); - - DataContractRegistry.register(Operation.class); - DataContractRegistry.register(ContractCodeDeployOperation.class); - DataContractRegistry.register(ContractEventSendOperation.class); - DataContractRegistry.register(DataAccountRegisterOperation.class); - DataContractRegistry.register(UserRegisterOperation.class); - DataContractRegistry.register(ParticipantRegisterOperation.class); - DataContractRegistry.register(ParticipantStateUpdateOperation.class); - - DataContractRegistry.register(ActionResponse.class); - - DataContractRegistry.register(BftsmartConsensusSettings.class); - DataContractRegistry.register(BftsmartNodeSettings.class); - - DataContractRegistry.register(LedgerAdminInfo.class); - DataContractRegistry.register(LedgerSettings.class); - - } - - /** - * 接入认证； - * - * @param clientIdentifications - * @return - */ - @RequestMapping(path = "/gateway/auth", method = RequestMethod.POST, consumes = BinaryMessageConverter.CONTENT_TYPE_VALUE) - public GatewayIncomingSetting authenticateGateway(@RequestBody ClientIdentifications clientIdentifications) { - // 去掉不严谨的网关注册和认证逻辑；暂时先放开，不做认证，后续应该在链上注册网关信息，并基于链上的网关信息进行认证； - // by: huanghaiquan; at 2018-09-11 18:34; - // TODO: 实现网关的链上注册与认证机制； - // TODO: 暂时先返回全部账本对应的共识网络配置信息；以账本哈希为 key 标识每一个账本对应的共识域、以及共识配置参数； - if (ledgerPeers.size() == 0 || clientIdentifications == null) { - return null; - } - - ClientIdentification[] identificationArray = clientIdentifications.getClientIdentifications(); - if (identificationArray == null || identificationArray.length <= 0) { - return null; - } - - GatewayIncomingSetting setting = new GatewayIncomingSetting(); - List ledgerIncomingList = new ArrayList(); - - for (HashDigest ledgerHash : ledgerPeers.keySet()) { - - NodeServer peer = ledgerPeers.get(ledgerHash); - - String peerProviderName = peer.getProviderName(); - - ConsensusProvider provider = ConsensusProviders.getProvider(peer.getProviderName()); - - ClientIncomingSettings clientIncomingSettings = null; - for (ClientIdentification authId : identificationArray) { - if (authId.getProviderName() == null || - authId.getProviderName().length() <= 0 || - !authId.getProviderName().equalsIgnoreCase(peerProviderName)) { - continue; - } - try { - clientIncomingSettings = peer.getManageService().authClientIncoming(authId); - break; - } catch (Exception e) { - throw new AuthenticationServiceException(e.getMessage(), e); - } - } - if (clientIncomingSettings == null) { - continue; - } - - byte[] clientIncomingBytes = provider.getSettingsFactory().getIncomingSettingsEncoder() - .encode(clientIncomingSettings); - String base64ClientIncomingSettings = ByteArray.toBase64(clientIncomingBytes); - - LedgerIncomingSetting ledgerIncomingSetting = new LedgerIncomingSetting(); - ledgerIncomingSetting.setLedgerHash(ledgerHash); - ledgerIncomingSetting.setCryptoSetting(ledgerCryptoSettings.get(ledgerHash)); - ledgerIncomingSetting.setClientSetting(base64ClientIncomingSettings); - ledgerIncomingSetting.setProviderName(peerProviderName); - - ledgerIncomingList.add(ledgerIncomingSetting); - - } - setting.setLedgers(ledgerIncomingList.toArray(new LedgerIncomingSetting[ledgerIncomingList.size()])); - return setting; - } - - @Override - public void setConfig(LedgerBindingConfig config) { - // TODO 更新配置；暂时不考虑变化过程的平滑切换问题,后续完善该流程； - // 1、检查账本的数据库配置；a、配置发生变化的账本，建立新的账本库(LedgerRepository)替换旧的实例；b、加入新增加的账本库实例；c、移除已经废弃的账本库； - // 2、完成账本库更改后，读取最新的共识配置信息，更新共识域； - // 3、基于当前共识地址检查共识域；a、启动新增加的共识地址，以及更新相应的共识域关系；c、已经废弃的共识域直接停止； - try { - // remove all existing ledger repositories; - HashDigest[] existingLedgerHashs = ledgerManager.getLedgerHashs(); - for (HashDigest lh : existingLedgerHashs) { - ledgerManager.unregister(lh); - } - HashDigest[] ledgerHashs = config.getLedgerHashs(); - for (HashDigest ledgerHash : ledgerHashs) { - setConfig(config,ledgerHash); - } - - this.config = config; - - } catch (Exception e) { - LOGGER.error("Error occurred on configing LedgerBindingConfig! --" + e.getMessage(), e); - throw new IllegalStateException(e); - } - } - - @Override - public NodeServer setConfig(LedgerBindingConfig config, HashDigest ledgerHash) { - LedgerBindingConfig.BindingConfig bindingConfig = config.getLedger(ledgerHash); - DbConnection dbConnNew = connFactory.connect(bindingConfig.getDbConnection().getUri(), - bindingConfig.getDbConnection().getPassword()); - LedgerQuery ledgerRepository = ledgerManager.register(ledgerHash, dbConnNew.getStorageService()); - - // load provider; - LedgerAdminInfo ledgerAdminAccount = ledgerRepository.getAdminInfo(); - String consensusProvider = ledgerAdminAccount.getSettings().getConsensusProvider(); - ConsensusProvider provider = ConsensusProviders.getProvider(consensusProvider); - // find current node; - Bytes csSettingBytes = ledgerAdminAccount.getSettings().getConsensusSetting(); - ConsensusSettings csSettings = provider.getSettingsFactory().getConsensusSettingsEncoder() - .decode(csSettingBytes.toBytes()); - NodeSettings currentNode = null; - for (NodeSettings nodeSettings : csSettings.getNodes()) { - if (nodeSettings.getAddress().equals(bindingConfig.getParticipant().getAddress())) { - currentNode = nodeSettings; - } - } - if (currentNode == null) { - throw new IllegalArgumentException( - "Current node is not found from the consensus settings of ledger[" + ledgerHash.toBase58() - + "]!"); - } - ServerSettings serverSettings = provider.getServerFactory().buildServerSettings(ledgerHash.toBase58(), csSettings, currentNode.getAddress()); - - NodeServer server = provider.getServerFactory().setupServer(serverSettings, consensusMessageHandler, - consensusStateManager); - ledgerPeers.put(ledgerHash, server); - ledgerCryptoSettings.put(ledgerHash, ledgerAdminAccount.getSettings().getCryptoSetting()); - - return server; - } - - @Override - public ConsensusRealm[] getRealms() { - throw new IllegalStateException("Not implemented!"); - } - - @Override - public void runAllRealms() { - for (NodeServer peer : ledgerPeers.values()) { - runRealm(peer); - } - } - - @Override - public void runRealm(NodeServer nodeServer) { - nodeServer.start(); - } - - @Override - public void closeAllRealms() { - for (NodeServer peer : ledgerPeers.values()) { - peer.stop(); - } - } -} +package com.jd.blockchain.peer.web; + +import java.util.ArrayList; +import java.util.List; +import java.util.Map; +import java.util.concurrent.ConcurrentHashMap; + +import com.jd.blockchain.ledger.*; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.security.authentication.AuthenticationServiceException; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestMethod; +import org.springframework.web.bind.annotation.RestController; + +import com.jd.blockchain.binaryproto.DataContractRegistry; +import com.jd.blockchain.consensus.ClientIdentification; +import com.jd.blockchain.consensus.ClientIdentifications; +import com.jd.blockchain.consensus.ClientIncomingSettings; +import com.jd.blockchain.consensus.ConsensusProvider; +import com.jd.blockchain.consensus.ConsensusProviders; +import com.jd.blockchain.consensus.ConsensusSettings; +import com.jd.blockchain.consensus.NodeSettings; +import com.jd.blockchain.consensus.action.ActionResponse; +import com.jd.blockchain.consensus.bftsmart.BftsmartConsensusSettings; +import com.jd.blockchain.consensus.bftsmart.BftsmartNodeSettings; +import com.jd.blockchain.consensus.mq.server.MsgQueueMessageDispatcher; +import com.jd.blockchain.consensus.service.MessageHandle; +import com.jd.blockchain.consensus.service.NodeServer; +import com.jd.blockchain.consensus.service.ServerSettings; +import com.jd.blockchain.consensus.service.StateMachineReplicate; +import com.jd.blockchain.crypto.HashDigest; +import com.jd.blockchain.ledger.LedgerAdminInfo; +import com.jd.blockchain.ledger.core.LedgerAdminDataQuery; +import com.jd.blockchain.ledger.core.LedgerManage; +import com.jd.blockchain.ledger.core.LedgerQuery; +import com.jd.blockchain.peer.ConsensusRealm; +import com.jd.blockchain.peer.LedgerBindingConfigAware; +import com.jd.blockchain.peer.PeerManage; +import com.jd.blockchain.setting.GatewayIncomingSetting; +import com.jd.blockchain.setting.LedgerIncomingSetting; +import com.jd.blockchain.storage.service.DbConnection; +import com.jd.blockchain.storage.service.DbConnectionFactory; +import com.jd.blockchain.tools.initializer.LedgerBindingConfig; +import com.jd.blockchain.utils.Bytes; +import com.jd.blockchain.utils.io.ByteArray; +import com.jd.blockchain.web.converters.BinaryMessageConverter; + +/** + * 网关管理服务； + * + * 提供 + * + * @author huanghaiquan + * + */ +@RestController +@RequestMapping(path = "/management") +public class ManagementController implements LedgerBindingConfigAware, PeerManage { + + private static Logger LOGGER = LoggerFactory.getLogger(ManagementController.class); + + public static final String GATEWAY_PUB_EXT_NAME = ".gw.pub"; + + public static final int MIN_GATEWAY_ID = 10000; + + @Autowired + private LedgerManage ledgerManager; + + @Autowired + private DbConnectionFactory connFactory; + + private Map ledgerTxConverters = new ConcurrentHashMap<>(); + + private Map ledgerPeers = new ConcurrentHashMap<>(); + private Map ledgerCryptoSettings = new ConcurrentHashMap<>(); + + + private LedgerBindingConfig config; + + @Autowired + private MessageHandle consensusMessageHandler; + + @Autowired + private StateMachineReplicate consensusStateManager; + + static { + DataContractRegistry.register(LedgerInitOperation.class); + DataContractRegistry.register(LedgerBlock.class); + DataContractRegistry.register(TransactionContent.class); + DataContractRegistry.register(TransactionContentBody.class); + DataContractRegistry.register(TransactionRequest.class); + DataContractRegistry.register(NodeRequest.class); + DataContractRegistry.register(EndpointRequest.class); + DataContractRegistry.register(TransactionResponse.class); + DataContractRegistry.register(DataAccountKVSetOperation.class); + DataContractRegistry.register(DataAccountKVSetOperation.KVWriteEntry.class); + + DataContractRegistry.register(Operation.class); + DataContractRegistry.register(ContractCodeDeployOperation.class); + DataContractRegistry.register(ContractEventSendOperation.class); + DataContractRegistry.register(DataAccountRegisterOperation.class); + DataContractRegistry.register(UserRegisterOperation.class); + DataContractRegistry.register(ParticipantRegisterOperation.class); + DataContractRegistry.register(ParticipantStateUpdateOperation.class); + + DataContractRegistry.register(ActionResponse.class); + + DataContractRegistry.register(BftsmartConsensusSettings.class); + DataContractRegistry.register(BftsmartNodeSettings.class); + + DataContractRegistry.register(LedgerAdminInfo.class); + DataContractRegistry.register(LedgerSettings.class); + DataContractRegistry.register(RoleSet.class); + DataContractRegistry.register(SecurityInitSettings.class); + DataContractRegistry.register(RoleInitSettings.class); + DataContractRegistry.register(UserAuthInitSettings.class); + DataContractRegistry.register(PrivilegeSet.class); + + } + + /** + * 接入认证； + * + * @param clientIdentifications + * @return + */ + @RequestMapping(path = "/gateway/auth", method = RequestMethod.POST, consumes = BinaryMessageConverter.CONTENT_TYPE_VALUE) + public GatewayIncomingSetting authenticateGateway(@RequestBody ClientIdentifications clientIdentifications) { + // 去掉不严谨的网关注册和认证逻辑；暂时先放开，不做认证，后续应该在链上注册网关信息，并基于链上的网关信息进行认证； + // by: huanghaiquan; at 2018-09-11 18:34; + // TODO: 实现网关的链上注册与认证机制； + // TODO: 暂时先返回全部账本对应的共识网络配置信息；以账本哈希为 key 标识每一个账本对应的共识域、以及共识配置参数； + if (ledgerPeers.size() == 0 || clientIdentifications == null) { + return null; + } + + ClientIdentification[] identificationArray = clientIdentifications.getClientIdentifications(); + if (identificationArray == null || identificationArray.length <= 0) { + return null; + } + + GatewayIncomingSetting setting = new GatewayIncomingSetting(); + List ledgerIncomingList = new ArrayList(); + + for (HashDigest ledgerHash : ledgerPeers.keySet()) { + + NodeServer peer = ledgerPeers.get(ledgerHash); + + String peerProviderName = peer.getProviderName(); + + ConsensusProvider provider = ConsensusProviders.getProvider(peer.getProviderName()); + + ClientIncomingSettings clientIncomingSettings = null; + for (ClientIdentification authId : identificationArray) { + if (authId.getProviderName() == null || + authId.getProviderName().length() <= 0 || + !authId.getProviderName().equalsIgnoreCase(peerProviderName)) { + continue; + } + try { + clientIncomingSettings = peer.getManageService().authClientIncoming(authId); + break; + } catch (Exception e) { + throw new AuthenticationServiceException(e.getMessage(), e); + } + } + if (clientIncomingSettings == null) { + continue; + } + + byte[] clientIncomingBytes = provider.getSettingsFactory().getIncomingSettingsEncoder() + .encode(clientIncomingSettings); + String base64ClientIncomingSettings = ByteArray.toBase64(clientIncomingBytes); + + LedgerIncomingSetting ledgerIncomingSetting = new LedgerIncomingSetting(); + ledgerIncomingSetting.setLedgerHash(ledgerHash); + ledgerIncomingSetting.setCryptoSetting(ledgerCryptoSettings.get(ledgerHash)); + ledgerIncomingSetting.setClientSetting(base64ClientIncomingSettings); + ledgerIncomingSetting.setProviderName(peerProviderName); + + ledgerIncomingList.add(ledgerIncomingSetting); + + } + setting.setLedgers(ledgerIncomingList.toArray(new LedgerIncomingSetting[ledgerIncomingList.size()])); + return setting; + } + + @Override + public void setConfig(LedgerBindingConfig config) { + // TODO 更新配置；暂时不考虑变化过程的平滑切换问题,后续完善该流程； + // 1、检查账本的数据库配置；a、配置发生变化的账本，建立新的账本库(LedgerRepository)替换旧的实例；b、加入新增加的账本库实例；c、移除已经废弃的账本库； + // 2、完成账本库更改后，读取最新的共识配置信息，更新共识域； + // 3、基于当前共识地址检查共识域；a、启动新增加的共识地址，以及更新相应的共识域关系；c、已经废弃的共识域直接停止； + try { + // remove all existing ledger repositories; + HashDigest[] existingLedgerHashs = ledgerManager.getLedgerHashs(); + for (HashDigest lh : existingLedgerHashs) { + ledgerManager.unregister(lh); + } + HashDigest[] ledgerHashs = config.getLedgerHashs(); + for (HashDigest ledgerHash : ledgerHashs) { + setConfig(config,ledgerHash); + } + + this.config = config; + + } catch (Exception e) { + LOGGER.error("Error occurred on configing LedgerBindingConfig! --" + e.getMessage(), e); + throw new IllegalStateException(e); + } + } + + @Override + public NodeServer setConfig(LedgerBindingConfig config, HashDigest ledgerHash) { + LedgerBindingConfig.BindingConfig bindingConfig = config.getLedger(ledgerHash); + DbConnection dbConnNew = connFactory.connect(bindingConfig.getDbConnection().getUri(), + bindingConfig.getDbConnection().getPassword()); + LedgerQuery ledgerRepository = ledgerManager.register(ledgerHash, dbConnNew.getStorageService()); + + // load provider; + LedgerAdminInfo ledgerAdminAccount = ledgerRepository.getAdminInfo(); + String consensusProvider = ledgerAdminAccount.getSettings().getConsensusProvider(); + ConsensusProvider provider = ConsensusProviders.getProvider(consensusProvider); + // find current node; + Bytes csSettingBytes = ledgerAdminAccount.getSettings().getConsensusSetting(); + ConsensusSettings csSettings = provider.getSettingsFactory().getConsensusSettingsEncoder() + .decode(csSettingBytes.toBytes()); + NodeSettings currentNode = null; + for (NodeSettings nodeSettings : csSettings.getNodes()) { + if (nodeSettings.getAddress().equals(bindingConfig.getParticipant().getAddress())) { + currentNode = nodeSettings; + } + } + if (currentNode == null) { + throw new IllegalArgumentException( + "Current node is not found from the consensus settings of ledger[" + ledgerHash.toBase58() + + "]!"); + } + ServerSettings serverSettings = provider.getServerFactory().buildServerSettings(ledgerHash.toBase58(), csSettings, currentNode.getAddress()); + + NodeServer server = provider.getServerFactory().setupServer(serverSettings, consensusMessageHandler, + consensusStateManager); + ledgerPeers.put(ledgerHash, server); + ledgerCryptoSettings.put(ledgerHash, ledgerAdminAccount.getSettings().getCryptoSetting()); + + return server; + } + + @Override + public ConsensusRealm[] getRealms() { + throw new IllegalStateException("Not implemented!"); + } + + @Override + public void runAllRealms() { + for (NodeServer peer : ledgerPeers.values()) { + runRealm(peer); + } + } + + @Override + public void runRealm(NodeServer nodeServer) { + nodeServer.start(); + } + + @Override + public void closeAllRealms() { + for (NodeServer peer : ledgerPeers.values()) { + peer.stop(); + } + } +}