add chainbridge.json.sample

Author: zhangbin

chainbridge-core/chainbridge.go

@@ -26,6 +26,7 @@ import (
 	"github.com/elastos/Elastos.ELA.SideChain.ESC/crypto"
 	"github.com/elastos/Elastos.ELA.SideChain.ESC/dpos"
 	"github.com/elastos/Elastos.ELA.SideChain.ESC/log"
+	"github.com/elastos/Elastos.ELA.SideChain.ESC/node"
 	"github.com/elastos/Elastos.ELA.SideChain.ESC/rpc"
 	"github.com/elastos/Elastos.ELA.SideChain.ESC/spv"
 
@@ -85,13 +86,13 @@ func APIs(engine *pbft.Pbft) []rpc.API {
 	}}
 }
 
-func Init(engine *pbft.Pbft, accountPath, accountPassword string) {
+func Init(engine *pbft.Pbft, stack *node.Node, accountPath, accountPassword string) {
 	pbftEngine = engine
 	if MsgReleayer != nil {
 		log.Warn("chain bridge is started")
 		return
 	}
-	err := initRelayer(engine, accountPath, accountPassword)
+	err := initRelayer(engine, stack, accountPath, accountPassword)
 	if err != nil {
 		bridgelog.Error("chain bridge started error", "error", err)
 		return
@@ -645,13 +646,14 @@ func onProducersChanged(e *events.Event) {
 	bridgelog.Info("SetManualArbiters", "total", total, "error", err, "arbiterCount", len(addresses))
 }
 
-func initRelayer(engine *pbft.Pbft, accountPath, accountPassword string) error {
+func initRelayer(engine *pbft.Pbft, stack *node.Node, accountPath, accountPassword string) error {
 	if MsgReleayer != nil {
 		return nil
 	}
 	cfg, err := config.GetConfig(config.DefaultConfigDir)
 	if err != nil {
 		log.Info("engine.GetBlockChain().Config().BridgeContractAddr", "address", engine.GetBlockChain().Config().BridgeContractAddr)
+		err = createSelfChain(engine, stack)
 		return err
 	}
 	db, err := lvldb.NewLvlDB(config.BlockstoreFlagName)
@@ -675,6 +677,24 @@ func initRelayer(engine *pbft.Pbft, accountPath, accountPassword string) error {
 	return nil
 }
 
+func createSelfChain(engine *pbft.Pbft, stack *node.Node) error {
+	escChainID = engine.GetBlockChain().Config().ChainID.Uint64()
+	rpc := fmt.Sprintf("http://localhost:%d", stack.Config().HTTPPort)
+	generalConfig := config.GeneralChainConfig{
+		Name:     "ESC",
+		Id:       escChainID,
+		Endpoint: rpc,
+	}
+	layer, errMsg := createChain(&generalConfig, nil, engine, "", "")
+	if errMsg != nil {
+		return errors.New(fmt.Sprintf("evm createSelfChain is error:%s, chainid:%d", errMsg.Error(), escChainID))
+	}
+	chains := make([]relayer.RelayedChain, 1)
+	chains[0] = layer
+	MsgReleayer = relayer.NewRelayer(chains, escChainID)
+	return nil
+}
+
 func Stop(msg string) {
 	if isRequireArbiter {
 		errChn <- fmt.Errorf(msg)

cmd/geth/main.go

@@ -653,7 +653,7 @@ func initChainBridge(ctx *cli.Context, stack *node.Node, blockChain *core.BlockC
 		log.Info("is common sync node, no password")
 	}
 	engine := blockChain.GetDposEngine().(*pbft.Pbft)
-	chainbridge_core.Init(engine, accPath, password)
+	chainbridge_core.Init(engine, stack, accPath, password)
 }
 
 func startLayer2(blockChain *core.BlockChain) {

docs/chainbridge/config/chain_bridge.json.smaple

@@ -0,0 +1,34 @@
+{
+	"chains":[
+		{
+		    "name": "layer1",
+		    "type": "ethereum",
+		    "id": 80,
+		    "endpoint": "http://127.0.0.1:1111",
+		    "freshstart": true,
+		    "opts": {
+		        "bridge": "0xd68251F74a6C1E502653A505cd0cF7072e66981D",
+		        "gasLimit": 8000000,
+		        "maxGasPrice": 10000000000,
+		        "blockConfirmations": 1,
+		        "gasMultiplier": 1.2,
+		        "startBlock": 5
+		    }    
+		},
+		{
+		    "name": "layer2",
+		    "type": "ethereum",
+		    "id": 83,
+		    "endpoint": "http://127.0.0.1:6111",
+		    "freshstart": false,
+		    "opts": {
+		        "bridge": "0xd68251F74a6C1E502653A505cd0cF7072e66981D",
+		        "gasLimit": 8000000,
+		        "maxGasPrice": 10000000000,
+		        "blockConfirmations": 1,
+		        "gasMultiplier": 1.2,
+		        "startBlock": 5
+		    }
+	   }
+	]
+}