Commit 60e29aae authored by hezhengjun's avatar hezhengjun Committed by 33cn

make notes pretty

parent 9a148465
...@@ -11,6 +11,8 @@ import ( ...@@ -11,6 +11,8 @@ import (
"strings" "strings"
"time" "time"
"github.com/33cn/plugin/plugin/dapp/cross2eth/ebrelayer/relayer/events"
erc20 "github.com/33cn/plugin/plugin/dapp/cross2eth/contracts/erc20/generated" erc20 "github.com/33cn/plugin/plugin/dapp/cross2eth/contracts/erc20/generated"
btcec_secp256k1 "github.com/btcsuite/btcd/btcec" btcec_secp256k1 "github.com/btcsuite/btcd/btcec"
...@@ -77,9 +79,8 @@ func createEvmTx(privateKey chain33Crypto.PrivKey, action proto.Message, execer, ...@@ -77,9 +79,8 @@ func createEvmTx(privateKey chain33Crypto.PrivKey, action proto.Message, execer,
} }
func relayEvmTx2Chain33(privateKey chain33Crypto.PrivKey, claim *ebrelayerTypes.EthBridgeClaim, parameter, rpcURL, oracleAddr string) (string, error) { func relayEvmTx2Chain33(privateKey chain33Crypto.PrivKey, claim *ebrelayerTypes.EthBridgeClaim, parameter, rpcURL, oracleAddr string) (string, error) {
note := fmt.Sprintf("relayEvmTx2Chain33 by validator:%s with nonce:%d", note := fmt.Sprintf("relay with type:%s, chain33-receiver:%s, ethereum-sender:%s, symbol:%s, amout:%d, ethTxHash:%s",
address.PubKeyToAddr(privateKey.PubKey().Bytes()), events.ClaimType(claim.ClaimType).String(), claim.Chain33Receiver, claim.EthereumSender, claim.Symbol, claim.Amount, claim.EthTxHash)
claim.Nonce)
_, packData, err := evmAbi.Pack(parameter, generated.OracleABI, false) _, packData, err := evmAbi.Pack(parameter, generated.OracleABI, false)
if nil != err { if nil != err {
chain33txLog.Info("relayEvmTx2Chain33", "Failed to do abi.Pack due to:", err.Error()) chain33txLog.Info("relayEvmTx2Chain33", "Failed to do abi.Pack due to:", err.Error())
......
...@@ -665,7 +665,7 @@ func (ethRelayer *Relayer4Ethereum) procBridgeBankLogs(vLog types.Log) { ...@@ -665,7 +665,7 @@ func (ethRelayer *Relayer4Ethereum) procBridgeBankLogs(vLog types.Log) {
//lock,用于捕捉 (ETH/ERC20----->chain33) 跨链转移 //lock,用于捕捉 (ETH/ERC20----->chain33) 跨链转移
if vLog.Topics[0].Hex() == ethRelayer.bridgeBankEventLockSig { if vLog.Topics[0].Hex() == ethRelayer.bridgeBankEventLockSig {
eventName := events.LogLock.String() eventName := events.LogLockFromETH.String()
relayerLog.Info("Relayer4Ethereum proc", "Going to process", eventName, relayerLog.Info("Relayer4Ethereum proc", "Going to process", eventName,
"Block number:", vLog.BlockNumber, "Tx hash:", vLog.TxHash.Hex()) "Block number:", vLog.BlockNumber, "Tx hash:", vLog.TxHash.Hex())
err := ethRelayer.handleLogLockEvent(ethRelayer.clientChainID, ethRelayer.bridgeBankAbi, eventName, vLog) err := ethRelayer.handleLogLockEvent(ethRelayer.clientChainID, ethRelayer.bridgeBankAbi, eventName, vLog)
...@@ -676,7 +676,7 @@ func (ethRelayer *Relayer4Ethereum) procBridgeBankLogs(vLog types.Log) { ...@@ -676,7 +676,7 @@ func (ethRelayer *Relayer4Ethereum) procBridgeBankLogs(vLog types.Log) {
} }
} else if vLog.Topics[0].Hex() == ethRelayer.bridgeBankEventBurnSig { } else if vLog.Topics[0].Hex() == ethRelayer.bridgeBankEventBurnSig {
//burn,用于捕捉 (chain33 token----->chain33) 实现chain33资产withdraw操作,之后在chain33上实现unlock操作 //burn,用于捕捉 (chain33 token----->chain33) 实现chain33资产withdraw操作,之后在chain33上实现unlock操作
eventName := events.LogChain33TokenBurn.String() eventName := events.LogBurnFromETH.String()
relayerLog.Info("Relayer4Ethereum proc", "Going to process", eventName, relayerLog.Info("Relayer4Ethereum proc", "Going to process", eventName,
"Block number:", vLog.BlockNumber, "Tx hash:", vLog.TxHash.Hex()) "Block number:", vLog.BlockNumber, "Tx hash:", vLog.TxHash.Hex())
err := ethRelayer.handleLogBurnEvent(ethRelayer.clientChainID, ethRelayer.bridgeBankAbi, eventName, vLog) err := ethRelayer.handleLogBurnEvent(ethRelayer.clientChainID, ethRelayer.bridgeBankAbi, eventName, vLog)
...@@ -782,9 +782,9 @@ func (ethRelayer *Relayer4Ethereum) prePareSubscribeEvent() { ...@@ -782,9 +782,9 @@ func (ethRelayer *Relayer4Ethereum) prePareSubscribeEvent() {
//bridgeBank处理 //bridgeBank处理
contactAbi := ethtxs.LoadABI(ethtxs.BridgeBankABI) contactAbi := ethtxs.LoadABI(ethtxs.BridgeBankABI)
ethRelayer.bridgeBankAbi = contactAbi ethRelayer.bridgeBankAbi = contactAbi
eventName = events.LogLock.String() eventName = events.LogLockFromETH.String()
ethRelayer.bridgeBankEventLockSig = contactAbi.Events[eventName].ID.Hex() ethRelayer.bridgeBankEventLockSig = contactAbi.Events[eventName].ID.Hex()
eventName = events.LogChain33TokenBurn.String() eventName = events.LogBurnFromETH.String()
ethRelayer.bridgeBankEventBurnSig = contactAbi.Events[eventName].ID.Hex() ethRelayer.bridgeBankEventBurnSig = contactAbi.Events[eventName].ID.Hex()
ethRelayer.bridgeBankAddr = ethRelayer.x2EthDeployInfo.BridgeBank.Address ethRelayer.bridgeBankAddr = ethRelayer.x2EthDeployInfo.BridgeBank.Address
} }
......
...@@ -57,7 +57,6 @@ type BurnEventOnChain33 struct { ...@@ -57,7 +57,6 @@ type BurnEventOnChain33 struct {
Nonce *big.Int Nonce *big.Int
} }
// UnpackChain33LogLock UnpackLogLock : Handles new LogLock events
func UnpackChain33LogLock(contractAbi abi.ABI, eventName string, eventData []byte) (lockEvent *LockEventOnChain33, err error) { func UnpackChain33LogLock(contractAbi abi.ABI, eventName string, eventData []byte) (lockEvent *LockEventOnChain33, err error) {
lockEvent = &LockEventOnChain33{} lockEvent = &LockEventOnChain33{}
// Parse the event's attributes as Ethereum network variables // Parse the event's attributes as Ethereum network variables
......
...@@ -7,7 +7,7 @@ import ( ...@@ -7,7 +7,7 @@ import (
type ClaimType int32 type ClaimType int32
type Event int type Event int
var eventsLog = log.New("module", "ethereum_relayer") var eventsLog = log.New("module", "cross2eth_relayer")
const ( const (
ClaimTypeBurn = ClaimType(1) ClaimTypeBurn = ClaimType(1)
...@@ -17,40 +17,17 @@ const ( ...@@ -17,40 +17,17 @@ const (
const ( const (
// Unsupported : unsupported Chain33 or Ethereum event // Unsupported : unsupported Chain33 or Ethereum event
Unsupported Event = iota Unsupported Event = iota
// MsgBurn : Chain33 event 'Chain33Msg' type MsgBurn // LogLockFromETH : Ethereum event 'LogLock'
MsgBurn LogLockFromETH
// MsgLock : Chain33 event 'Chain33Msg' type MsgLock // LogBurnFromETH : Ethereum event 'LogChain33TokenBurn'
MsgLock LogBurnFromETH
// LogLock : Ethereum event 'LockEvent'
LogLock
// LogChain33TokenBurn : Ethereum event 'LogChain33TokenBurn' in contract chain33Bank
LogChain33TokenBurn
// LogNewProphecyClaim : Ethereum event 'NewProphecyClaimEvent'
LogNewProphecyClaim
) )
// String : returns the event type as a string // 此处的名字命令不能随意改动,需要与合约event中的命名完全一致
func (d Event) String() string { func (d Event) String() string {
return [...]string{"unknown-x2ethereum", "Chain33ToEthBurn", "Chain33ToEthLock", "LogLock", "LogChain33TokenBurn", "LogNewProphecyClaim"}[d] return [...]string{"unknown-LOG", "LogLock", "LogChain33TokenBurn"}[d]
} }
// Chain33MsgAttributeKey : enum containing supported attribute keys func (d ClaimType) String() string {
type Chain33MsgAttributeKey int return [...]string{"unknown-LOG", "burn", "lock"}[d]
const (
// UnsupportedAttributeKey : unsupported attribute key
UnsupportedAttributeKey Chain33MsgAttributeKey = iota
// Chain33Sender : sender's address on Chain33 network
Chain33Sender
// EthereumReceiver : receiver's address on Ethereum network
EthereumReceiver
// Coin : coin type
Coin
// TokenContractAddress : coin's corresponding contract address deployed on the Ethereum network
TokenContractAddress
)
// String : returns the event type as a string
func (d Chain33MsgAttributeKey) String() string {
return [...]string{"unsupported", "chain33_sender", "ethereum_receiver", "amount", "token_contract_address"}[d]
} }
...@@ -14,7 +14,7 @@ func Test_UnpackLogLock(t *testing.T) { ...@@ -14,7 +14,7 @@ func Test_UnpackLogLock(t *testing.T) {
abiJSON := generated.BridgeBankABI abiJSON := generated.BridgeBankABI
contractABI, err := abi.JSON(strings.NewReader(abiJSON)) contractABI, err := abi.JSON(strings.NewReader(abiJSON))
require.Nil(t, err) require.Nil(t, err)
eventName := LogLock.String() eventName := LogLockFromETH.String()
eventData := []byte("nil") eventData := []byte("nil")
_, err = UnpackLogLock(contractABI, eventName, eventData) _, err = UnpackLogLock(contractABI, eventName, eventData)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment