hummingbird
/
jdchain
Not watched
2
0
Fork 0
Code
Releases 31 Wiki Activity
Issues 0 Pull Requests 0 Datasets Model Cloudbrain
Browse Source

Merge remote-tracking branch 'origin/develop' into feature/admin1-local

tags/1.1.0
shaozhuguang 5 years ago
parent
97201bf356 87dd1b63cb
commit
edf355d1f0
9 changed files with 307 additions and 272 deletions
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. +2
    -2
      source/ledger/ledger-model/src/main/java/com/jd/blockchain/contract/ContractJarUtils.java
  2. +6
    -0
      source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/RoleInitData.java
  3. +6
    -0
      source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/SecurityInitData.java
  4. +5
    -0
      source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/UserAuthInitData.java
  5. +5
    -0
      source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/UserRoles.java
  6. +6
    -0
      source/ledger/ledger-model/src/main/java/com/jd/blockchain/transaction/LedgerInitData.java
  7. +1
    -0
      source/ledger/ledger-model/src/main/java/com/jd/blockchain/transaction/RolesConfigureOpTemplate.java
  8. +1
    -0
      source/ledger/ledger-model/src/main/java/com/jd/blockchain/transaction/UserAuthorizeOpTemplate.java
  9. +275
    -270
      source/peer/src/main/java/com/jd/blockchain/peer/web/ManagementController.java

+ 2
- 2
source/ledger/ledger-model/src/main/java/com/jd/blockchain/contract/ContractJarUtils.java View File

@@ -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";



+ 6
- 0
source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/RoleInitData.java View File

@@ -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;


+ 6
- 0
source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/SecurityInitData.java View File

@@ -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<String, RoleInitData> roles = new LinkedHashMap<>();

private Map<Bytes, UserAuthInitData> userAuthentications = new LinkedHashMap<>();


+ 5
- 0
source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/UserAuthInitData.java View File

@@ -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;


+ 5
- 0
source/ledger/ledger-model/src/main/java/com/jd/blockchain/ledger/UserRoles.java View File

@@ -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;


+ 6
- 0
source/ledger/ledger-model/src/main/java/com/jd/blockchain/transaction/LedgerInitData.java View File

@@ -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;


+ 1
- 0
source/ledger/ledger-model/src/main/java/com/jd/blockchain/transaction/RolesConfigureOpTemplate.java View File

@@ -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<String, RolePrivilegeConfig> rolesMap = Collections


+ 1
- 0
source/ledger/ledger-model/src/main/java/com/jd/blockchain/transaction/UserAuthorizeOpTemplate.java View File

@@ -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<UserRolesAuthorization> userAuthMap = Collections


+ 275
- 270
source/peer/src/main/java/com/jd/blockchain/peer/web/ManagementController.java View File

@@ -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<HashDigest, MsgQueueMessageDispatcher> ledgerTxConverters = new ConcurrentHashMap<>();
private Map<HashDigest, NodeServer> ledgerPeers = new ConcurrentHashMap<>();
private Map<HashDigest, CryptoSetting> 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<LedgerIncomingSetting> ledgerIncomingList = new ArrayList<LedgerIncomingSetting>();
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<HashDigest, MsgQueueMessageDispatcher> ledgerTxConverters = new ConcurrentHashMap<>();

private Map<HashDigest, NodeServer> ledgerPeers = new ConcurrentHashMap<>();
private Map<HashDigest, CryptoSetting> 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<LedgerIncomingSetting> ledgerIncomingList = new ArrayList<LedgerIncomingSetting>();

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();
}
}
}

Write Preview
Loading…
Cancel
Save