sc

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 14, 2019 License: GPL-3.0 Imports: 47 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TokenEventChanSize = 10000
	BridgeAddrJournal  = "bridge_addrs.rlp"
)
View Source
const (
	KLAY uint8 = iota
	ERC20
	ERC721
)
View Source
const (
	// Protocol messages belonging to servicechain/1
	StatusMsg = 0x00

	// Below message can be deprecated.
	ServiceChainTxsMsg                     = 0x01
	ServiceChainReceiptResponseMsg         = 0x02
	ServiceChainReceiptRequestMsg          = 0x03
	ServiceChainParentChainInfoResponseMsg = 0x04
	ServiceChainParentChainInfoRequestMsg  = 0x05

	ServiceChainCall     = 0x06
	ServiceChainResponse = 0x07
	ServiceChainNotify   = 0x08
)
View Source
const (
	ErrMsgTooLarge = iota
	ErrDecode
	ErrInvalidMsgCode
	ErrProtocolVersionMismatch
	ErrNetworkIdMismatch
	ErrNoStatusMsg
	ErrUnexpectedTxType
)
View Source
const (
	DefaultBridgeTxGasLimit = 5000000
)
View Source
const ProtocolMaxMsgSize = 10 * 1024 * 1024 // Maximum cap on the size of a protocol message
View Source
const (
	SyncRequestInterval = 10
)

Variables

View Source
var (
	ErrInvalidTokenPair     = errors.New("invalid token pair")
	ErrNoBridgeInfo         = errors.New("bridge information does not exist")
	ErrDuplicatedBridgeInfo = errors.New("bridge information is duplicated")
	ErrDuplicatedToken      = errors.New("token is duplicated")
	ErrNoRecovery           = errors.New("recovery does not exist")
	ErrAlreadySubscribed    = errors.New("already subscribed")
	ErrBridgeRestore        = errors.New("restoring bridges is failed")
)
View Source
var (
	SCProtocolName    = "servicechain"
	SCProtocolVersion = []uint{1}
	SCProtocolLength  = []uint64{9}
)
View Source
var (
	ErrVtrDisabled       = errors.New("VTR is disabled")
	ErrVtrAlreadyStarted = errors.New("VTR is already started")
)
View Source
var DefaultConfig = SCConfig{
	NetworkId: 1,
	MaxPeer:   1,
}

DefaultConfig contains default settings for use on the Klaytn main net.

View Source
var (
	ErrGetServiceChainPHInCCEH = errors.New("ServiceChainPH isn't set in ChildChainEventHandler")
)
View Source
var (
	ErrGetServiceChainPHInMCEH = errors.New("ServiceChainPH isn't set in MainChainEventHandler")
)
View Source
var (
	ErrInvalidBridgePair = errors.New("invalid bridge pair")
)
View Source
var (
	ErrRPCDecode = errors.New("failed to decode mainbridge rpc call message")
)
View Source
var (
	NoParentPeerErr = errors.New("no parent peer")
)

Functions

func CreateDB

func CreateDB(ctx *node.ServiceContext, config *SCConfig, name string) database.DBManager

CreateDB creates the chain database.

func InitializeBridgeAccountKeystore added in v1.1.0

func InitializeBridgeAccountKeystore(keystorePath string) (*keystore.KeyStore, common.Address, bool, error)

InitializeBridgeAccountKeystore initializes a keystore, imports existing keys, and tries to unlock the bridge account. This returns the 1st account of the wallet, its address, the lock status and the error.

func NewRpcClientP2P added in v1.1.0

func NewRpcClientP2P(sb *SubBridge) *rpc.Client

func NewValueTransferRecovery

func NewValueTransferRecovery(config *SCConfig, scBridgeInfo, mcBridgeInfo *BridgeInfo) *valueTransferRecovery

NewValueTransferRecovery creates a new value transfer recovery structure.

Types

type Backend

type Backend interface {
	bind.ContractBackend
}

Backend wraps all methods for local and remote backend

type BridgeAccounts added in v1.1.0

type BridgeAccounts struct {
	// contains filtered or unexported fields
}

BridgeAccounts manages bridge account for main/service chain.

func NewBridgeAccounts added in v1.1.0

func NewBridgeAccounts(dataDir string) (*BridgeAccounts, error)

NewBridgeAccounts returns bridgeAccounts created by main/service bridge account keys.

func (*BridgeAccounts) GetBridgeOperators added in v1.1.0

func (ba *BridgeAccounts) GetBridgeOperators() map[string]interface{}

GetBridgeOperators returns the information of bridgeOperator.

type BridgeInfo

type BridgeInfo struct {
	// contains filtered or unexported fields
}

func NewBridgeInfo

func NewBridgeInfo(db database.DBManager, addr common.Address, bridge *bridgecontract.Bridge, cpAddr common.Address, cpBridge *bridgecontract.Bridge, account *accountInfo, local, subscribed bool) (*BridgeInfo, error)

func (*BridgeInfo) AddRequestValueTransferEvents

func (bi *BridgeInfo) AddRequestValueTransferEvents(evs []*RequestValueTransferEvent)

AddRequestValueTransferEvents adds events into the pendingRequestEvent.

func (*BridgeInfo) DeregisterToken added in v1.1.0

func (bi *BridgeInfo) DeregisterToken(token, counterpartToken common.Address) error

func (*BridgeInfo) GetCounterPartToken added in v1.1.0

func (bi *BridgeInfo) GetCounterPartToken(token common.Address) common.Address

func (*BridgeInfo) GetPendingRequestEvents added in v1.1.0

func (bi *BridgeInfo) GetPendingRequestEvents(start uint64) []*RequestValueTransferEvent

func (*BridgeInfo) GetReadyRequestValueTransferEvents

func (bi *BridgeInfo) GetReadyRequestValueTransferEvents() []*RequestValueTransferEvent

GetReadyRequestValueTransferEvents returns the processable events with the increasing nonce.

func (*BridgeInfo) RegisterToken added in v1.1.0

func (bi *BridgeInfo) RegisterToken(token, counterpartToken common.Address) error

func (*BridgeInfo) UpdateHandledNonce

func (bi *BridgeInfo) UpdateHandledNonce(nonce uint64)

UpdateHandledNonce updates the handled nonce with new nonce.

func (*BridgeInfo) UpdateInfo

func (bi *BridgeInfo) UpdateInfo() error

func (*BridgeInfo) UpdateRequestNonce

func (bi *BridgeInfo) UpdateRequestNonce(nonce uint64)

UpdateRequestNonce updates the request nonce of the bridge.

func (*BridgeInfo) UpdateRequestNonceFromCounterpart

func (bi *BridgeInfo) UpdateRequestNonceFromCounterpart(nonce uint64)

UpdateRequestNonceFromCounterpart updates the request nonce from counterpart bridge.

type BridgeJournal

type BridgeJournal struct {
	LocalAddress  common.Address `json:"localAddress"`
	RemoteAddress common.Address `json:"remoteAddress"`
	Subscribed    bool           `json:"subscribed"`
}

func (*BridgeJournal) DecodeRLP

func (b *BridgeJournal) DecodeRLP(s *rlp.Stream) error

DecodeRLP decodes the Klaytn

func (*BridgeJournal) EncodeRLP

func (b *BridgeJournal) EncodeRLP(w io.Writer) error

EncodeRLP serializes a BridgeJournal into the Klaytn RLP BridgeJournal format.

type BridgeManager

type BridgeManager struct {
	// contains filtered or unexported fields
}

BridgeManager manages Bridge SmartContracts for value transfer between service chain and parent chain

func NewBridgeManager

func NewBridgeManager(main *SubBridge) (*BridgeManager, error)

func (*BridgeManager) AddRecovery

func (bm *BridgeManager) AddRecovery(localAddress, remoteAddress common.Address) error

AddRecovery starts value transfer recovery for a given addresses pair.

func (*BridgeManager) DeleteBridgeInfo

func (bm *BridgeManager) DeleteBridgeInfo(addr common.Address) error

DeleteBridgeInfo deletes the bridge info of the specified address.

func (*BridgeManager) DeleteRecovery

func (bm *BridgeManager) DeleteRecovery(localAddress, remoteAddress common.Address) error

DeleteRecovery deletes the journal and stop the value transfer recovery for a given address pair.

func (*BridgeManager) DeployBridge

func (bm *BridgeManager) DeployBridge(backend bind.ContractBackend, local bool) (*bridgecontract.Bridge, common.Address, error)

Deploy Bridge SmartContract on same node or remote node

func (*BridgeManager) GetAllBridge

func (bm *BridgeManager) GetAllBridge() []*BridgeJournal

GetAllBridge returns a slice of journal cache.

func (*BridgeManager) GetBridgeInfo

func (bm *BridgeManager) GetBridgeInfo(addr common.Address) (*BridgeInfo, bool)

GetBridge returns bridge contract of the specified address.

func (*BridgeManager) GetCounterPartBridge added in v1.1.0

func (bm *BridgeManager) GetCounterPartBridge(bridgeAddr common.Address) *bridgecontract.Bridge

func (*BridgeManager) GetCounterPartBridgeAddr added in v1.1.0

func (bm *BridgeManager) GetCounterPartBridgeAddr(bridgeAddr common.Address) common.Address

func (*BridgeManager) GetERC20Fee added in v1.1.0

func (bm *BridgeManager) GetERC20Fee(bridgeAddr, tokenAddr common.Address) (*big.Int, error)

GetERC20Fee returns the ERC20 transfer fee on the bridge contract.

func (*BridgeManager) GetFeeReceiver added in v1.1.0

func (bm *BridgeManager) GetFeeReceiver(bridgeAddr common.Address) (common.Address, error)

GetFeeReceiver returns the receiver which can get fee of value transfer request.

func (*BridgeManager) GetKLAYFee added in v1.1.0

func (bm *BridgeManager) GetKLAYFee(bridgeAddr common.Address) (*big.Int, error)

GetKLAYFee returns the KLAY transfer fee on the bridge contract.

func (*BridgeManager) IsValidBridgePair added in v1.1.0

func (bm *BridgeManager) IsValidBridgePair(bridge1, bridge2 common.Address) bool

func (*BridgeManager) LogBridgeStatus

func (bm *BridgeManager) LogBridgeStatus()

LogBridgeStatus logs the bridge contract requested/handled nonce status as an information.

func (*BridgeManager) ResetAllSubscribedEvents

func (bm *BridgeManager) ResetAllSubscribedEvents() error

resetAllSubscribedEvents resets watch logs and recreates a goroutine loop to handle event messages.

func (*BridgeManager) RestoreBridges

func (bm *BridgeManager) RestoreBridges() error

RestoreBridges setups bridge subscription by using the journal cache.

func (*BridgeManager) SetBridgeInfo

func (bm *BridgeManager) SetBridgeInfo(addr common.Address, bridge *bridgecontract.Bridge, cpAddr common.Address, cpBridge *bridgecontract.Bridge, account *accountInfo, local bool, subscribed bool) error

SetBridgeInfo stores the address and bridge pair with local/remote and subscription status.

func (*BridgeManager) SetERC20Fee added in v1.1.0

func (bm *BridgeManager) SetERC20Fee(bridgeAddr, tokenAddr common.Address, fee *big.Int) (common.Hash, error)

SetERC20Fee set the ERC20 transfer fee on the bridge contract.

func (*BridgeManager) SetFeeReceiver added in v1.1.0

func (bm *BridgeManager) SetFeeReceiver(bridgeAddr, receiver common.Address) (common.Hash, error)

SetFeeReceiver set the fee receiver which can get the fee of value transfer request.

func (*BridgeManager) SetJournal

func (bm *BridgeManager) SetJournal(localAddress, remoteAddress common.Address) error

SetJournal inserts or updates journal for a given addresses pair.

func (*BridgeManager) SetKLAYFee added in v1.1.0

func (bm *BridgeManager) SetKLAYFee(bridgeAddr common.Address, fee *big.Int) (common.Hash, error)

SetKLAYFee set the KLAY transfer fee on the bridge contract.

func (*BridgeManager) Stop

func (bm *BridgeManager) Stop()

Stop closes a subscribed event scope of the bridge manager.

func (*BridgeManager) SubscribeEvent

func (bm *BridgeManager) SubscribeEvent(addr common.Address) error

SubscribeEvent registers a subscription of BridgeERC20Received and BridgeTokenWithdrawn

func (*BridgeManager) SubscribeHandleEvent added in v1.1.0

func (bm *BridgeManager) SubscribeHandleEvent(ch chan<- *HandleValueTransferEvent) event.Subscription

SubscribeHandleEvent registers a subscription of RequestValueTransferEvent.

func (*BridgeManager) SubscribeRequestEvent added in v1.1.0

func (bm *BridgeManager) SubscribeRequestEvent(ch chan<- *RequestValueTransferEvent) event.Subscription

SubscribeRequestEvent registers a subscription of RequestValueTransferEvent.

func (*BridgeManager) UnsubscribeEvent

func (bm *BridgeManager) UnsubscribeEvent(addr common.Address)

UnsubscribeEvent cancels the contract's watch logs and initializes the status.

type BridgePeer

type BridgePeer interface {
	// Close signals the broadcast goroutine to terminate.
	Close()

	// Info gathers and returns a collection of metadata known about a peer.
	Info() *BridgePeerInfo

	Head() (hash common.Hash, td *big.Int)

	// AddToKnownTxs adds a transaction hash to knownTxsCache for the peer, ensuring that it
	// will never be propagated to this particular peer.
	AddToKnownTxs(hash common.Hash)

	// Send writes an RLP-encoded message with the given code.
	// data should have been encoded as an RLP list.
	Send(msgcode uint64, data interface{}) error

	// Handshake executes the Klaytn protocol handshake, negotiating version number,
	// network IDs, difficulties, head, genesis blocks, and onChildChain(if the node is on child chain for the peer)
	// and returning if the peer on the same chain or not and error.
	Handshake(network uint64, chainID, td *big.Int, head common.Hash) error

	// ConnType returns the conntype of the peer.
	ConnType() p2p.ConnType

	// GetID returns the id of the peer.
	GetID() string

	// GetP2PPeerID returns the id of the p2p.Peer.
	GetP2PPeerID() discover.NodeID

	// GetChainID returns the chain id of the peer.
	GetChainID() *big.Int

	// GetAddr returns the address of the peer.
	GetAddr() common.Address

	// SetAddr sets the address of the peer.
	SetAddr(addr common.Address)

	// GetVersion returns the version of the peer.
	GetVersion() int

	// KnowsTx returns if the peer is known to have the transaction, based on knownTxsCache.
	KnowsTx(hash common.Hash) bool

	// GetP2PPeer returns the p2p.
	GetP2PPeer() *p2p.Peer

	// GetRW returns the MsgReadWriter of the peer.
	GetRW() p2p.MsgReadWriter

	// Handle is the callback invoked to manage the life cycle of a Klaytn Peer. When
	// this function terminates, the Peer is disconnected.
	Handle(bn *MainBridge) error

	SendRequestRPC(data []byte) error
	SendResponseRPC(data []byte) error

	// SendServiceChainTxs sends child chain tx data to from child chain to parent chain.
	SendServiceChainTxs(txs types.Transactions) error

	// SendServiceChainInfoRequest sends a parentChainInfo request from child chain to parent chain.
	SendServiceChainInfoRequest(addr *common.Address) error

	// SendServiceChainInfoResponse sends a parentChainInfo from parent chain to child chain.
	// parentChainInfo includes nonce of an account and gasPrice in the parent chain.
	SendServiceChainInfoResponse(pcInfo *parentChainInfo) error

	// SendServiceChainReceiptRequest sends a receipt request from child chain to parent chain.
	SendServiceChainReceiptRequest(txHashes []common.Hash) error

	// SendServiceChainReceiptResponse sends a receipt as a response to request from child chain.
	SendServiceChainReceiptResponse(receipts []*types.ReceiptForStorage) error
}

type BridgePeerInfo

type BridgePeerInfo struct {
	Version int    `json:"version"` // Klaytn Bridge protocol version negotiated
	Head    string `json:"head"`    // SHA3 hash of the peer's best owned block
}

BridgePeerInfo represents a short summary of the Klaytn Bridge sub-protocol metadata known about a connected peer.

type ChildChainEventHandler

type ChildChainEventHandler struct {
	// contains filtered or unexported fields
}

func NewChildChainEventHandler

func NewChildChainEventHandler(bridge *SubBridge, handler *SubBridgeHandler) (*ChildChainEventHandler, error)

func (*ChildChainEventHandler) ConvertServiceChainBlockHashToMainChainTxHash

func (cce *ChildChainEventHandler) ConvertServiceChainBlockHashToMainChainTxHash(scBlockHash common.Hash) common.Hash

ConvertServiceChainBlockHashToMainChainTxHash returns a transaction hash of a transaction which contains ChainHashes, with the key made with given service chain block hash. Index is built when service chain indexing is enabled.

func (*ChildChainEventHandler) HandleChainHeadEvent

func (cce *ChildChainEventHandler) HandleChainHeadEvent(block *types.Block) error

func (*ChildChainEventHandler) HandleLogsEvent

func (cce *ChildChainEventHandler) HandleLogsEvent(logs []*types.Log) error

func (*ChildChainEventHandler) HandleTxEvent

func (cce *ChildChainEventHandler) HandleTxEvent(tx *types.Transaction) error

func (*ChildChainEventHandler) HandleTxsEvent

func (cce *ChildChainEventHandler) HandleTxsEvent(txs []*types.Transaction) error

func (*ChildChainEventHandler) ProcessHandleEvent

func (cce *ChildChainEventHandler) ProcessHandleEvent(ev *HandleValueTransferEvent) error

func (*ChildChainEventHandler) ProcessRequestEvent

func (cce *ChildChainEventHandler) ProcessRequestEvent(ev *RequestValueTransferEvent) error

type HandleValueTransferEvent

type HandleValueTransferEvent struct {
	*bridgecontract.BridgeHandleValueTransfer
}

HandleValueTransferEvent from Bridge contract

type LocalBackend

type LocalBackend struct {
	// contains filtered or unexported fields
}

TODO-Klaytn currently LocalBackend is only for ServiceChain, especially Bridge SmartContract

func NewLocalBackend

func NewLocalBackend(main *SubBridge) (*LocalBackend, error)

func (*LocalBackend) CallContract

func (lb *LocalBackend) CallContract(ctx context.Context, call klaytn.CallMsg, blockNumber *big.Int) ([]byte, error)

func (*LocalBackend) ChainID

func (lb *LocalBackend) ChainID(ctx context.Context) (*big.Int, error)

ChainID can return the chain ID of the chain.

func (*LocalBackend) CodeAt

func (lb *LocalBackend) CodeAt(ctx context.Context, contract common.Address, blockNumber *big.Int) ([]byte, error)

func (*LocalBackend) EstimateGas

func (lb *LocalBackend) EstimateGas(ctx context.Context, call klaytn.CallMsg) (gas uint64, err error)

func (*LocalBackend) FilterLogs

func (lb *LocalBackend) FilterLogs(ctx context.Context, query klaytn.FilterQuery) ([]types.Log, error)

func (*LocalBackend) PendingCodeAt

func (lb *LocalBackend) PendingCodeAt(ctx context.Context, contract common.Address) ([]byte, error)

func (*LocalBackend) PendingNonceAt

func (lb *LocalBackend) PendingNonceAt(ctx context.Context, account common.Address) (uint64, error)

func (*LocalBackend) SendTransaction

func (lb *LocalBackend) SendTransaction(ctx context.Context, tx *types.Transaction) error

func (*LocalBackend) SubscribeFilterLogs

func (lb *LocalBackend) SubscribeFilterLogs(ctx context.Context, query klaytn.FilterQuery, ch chan<- types.Log) (klaytn.Subscription, error)

func (*LocalBackend) SuggestGasPrice

func (lb *LocalBackend) SuggestGasPrice(ctx context.Context) (*big.Int, error)

func (*LocalBackend) TransactionReceipt

func (lb *LocalBackend) TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)

type MainBridge

type MainBridge struct {
	APIBackend *MainBridgeAPI
	// contains filtered or unexported fields
}

CN implements the Klaytn consensus node service.

func NewMainBridge

func NewMainBridge(ctx *node.ServiceContext, config *SCConfig) (*MainBridge, error)

New creates a new CN object (including the initialisation of the common CN object)

func (*MainBridge) APIs

func (s *MainBridge) APIs() []rpc.API

APIs returns the collection of RPC services the ethereum package offers. NOTE, some of these services probably need to be moved to somewhere else.

func (*MainBridge) AccountManager

func (s *MainBridge) AccountManager() *accounts.Manager

func (*MainBridge) BridgePeerSet

func (mb *MainBridge) BridgePeerSet() *bridgePeerSet

implement PeerSetManager

func (*MainBridge) ChainDB

func (s *MainBridge) ChainDB() database.DBManager

func (*MainBridge) Components

func (s *MainBridge) Components() []interface{}

func (*MainBridge) EventMux

func (s *MainBridge) EventMux() *event.TypeMux

func (*MainBridge) IsListening

func (s *MainBridge) IsListening() bool

func (*MainBridge) NetVersion

func (s *MainBridge) NetVersion() uint64

func (*MainBridge) NodeInfo

func (pm *MainBridge) NodeInfo() *MainBridgeInfo

NodeInfo retrieves some protocol metadata about the running host node.

func (*MainBridge) ProtocolVersion

func (s *MainBridge) ProtocolVersion() int

func (*MainBridge) Protocols

func (s *MainBridge) Protocols() []p2p.Protocol

Protocols implements node.Service, returning all the currently configured network protocols to start.

func (*MainBridge) SCProtocol

func (s *MainBridge) SCProtocol() SCProtocol

func (*MainBridge) SendRPCResponseData added in v1.1.0

func (sb *MainBridge) SendRPCResponseData(data []byte) error

func (*MainBridge) SetComponents

func (sc *MainBridge) SetComponents(components []interface{})

func (*MainBridge) Start

func (s *MainBridge) Start(srvr p2p.Server) error

Start implements node.Service, starting all internal goroutines needed by the Klaytn protocol implementation.

func (*MainBridge) Stop

func (s *MainBridge) Stop() error

Stop implements node.Service, terminating all internal goroutines used by the Klaytn protocol.

type MainBridgeAPI

type MainBridgeAPI struct {
	// contains filtered or unexported fields
}

MainBridgeAPI Implementation for main-bridge node

func (*MainBridgeAPI) ConvertServiceChainBlockHashToMainChainTxHash

func (mbapi *MainBridgeAPI) ConvertServiceChainBlockHashToMainChainTxHash(scBlockHash common.Hash) common.Hash

func (*MainBridgeAPI) GetChildChainIndexingEnabled

func (mbapi *MainBridgeAPI) GetChildChainIndexingEnabled() bool

func (*MainBridgeAPI) NodeInfo

func (mbapi *MainBridgeAPI) NodeInfo() (*p2p.NodeInfo, error)

NodeInfo retrieves all the information we know about the host node at the protocol granularity.

func (*MainBridgeAPI) Peers

func (mbapi *MainBridgeAPI) Peers() ([]*p2p.PeerInfo, error)

Peers retrieves all the information we know about each individual peer at the protocol granularity.

type MainBridgeHandler

type MainBridgeHandler struct {
	// contains filtered or unexported fields
}

func NewMainBridgeHandler

func NewMainBridgeHandler(scc *SCConfig, main *MainBridge) (*MainBridgeHandler, error)

func (*MainBridgeHandler) HandleSubMsg

func (mbh *MainBridgeHandler) HandleSubMsg(p BridgePeer, msg p2p.Msg) error

type MainBridgeInfo

type MainBridgeInfo struct {
	Network    uint64              `json:"network"`    // Klaytn network ID
	BlockScore *big.Int            `json:"blockscore"` // Total blockscore of the host's blockchain
	Genesis    common.Hash         `json:"genesis"`    // SHA3 hash of the host's genesis block
	Config     *params.ChainConfig `json:"config"`     // Chain configuration for the fork rules
	Head       common.Hash         `json:"head"`       // SHA3 hash of the host's best owned block
}

NodeInfo represents a short summary of the Klaytn sub-protocol metadata known about the host peer.

type MainChainEventHandler

type MainChainEventHandler struct {
	// contains filtered or unexported fields
}

func NewMainChainEventHandler

func NewMainChainEventHandler(bridge *MainBridge, handler *MainBridgeHandler) (*MainChainEventHandler, error)

func (*MainChainEventHandler) ConvertServiceChainBlockHashToMainChainTxHash

func (mce *MainChainEventHandler) ConvertServiceChainBlockHashToMainChainTxHash(scBlockHash common.Hash) common.Hash

ConvertServiceChainBlockHashToMainChainTxHash returns a transaction hash of a transaction which contains ChainHashes, with the key made with given service chain block hash. Index is built when service chain indexing is enabled.

func (*MainChainEventHandler) GetChildChainIndexingEnabled

func (mce *MainChainEventHandler) GetChildChainIndexingEnabled() bool

GetChildChainIndexingEnabled returns the current child chain indexing configuration.

func (*MainChainEventHandler) GetLastIndexedBlockNumber

func (mce *MainChainEventHandler) GetLastIndexedBlockNumber() uint64

GetLastIndexedBlockNumber returns the last child block number indexed to chain DB.

func (*MainChainEventHandler) HandleChainHeadEvent

func (mce *MainChainEventHandler) HandleChainHeadEvent(block *types.Block) error

func (*MainChainEventHandler) HandleLogsEvent

func (mce *MainChainEventHandler) HandleLogsEvent(logs []*types.Log) error

func (*MainChainEventHandler) HandleTxEvent

func (mce *MainChainEventHandler) HandleTxEvent(tx *types.Transaction) error

func (*MainChainEventHandler) HandleTxsEvent

func (mce *MainChainEventHandler) HandleTxsEvent(txs []*types.Transaction) error

func (*MainChainEventHandler) WriteChildChainTxHash

func (mce *MainChainEventHandler) WriteChildChainTxHash(ccBlockHash common.Hash, ccTxHash common.Hash)

WriteChildChainTxHash stores a transaction hash of a transaction which contains ChainHashes, with the key made with given child chain block hash. Index is built when child chain indexing is enabled.

func (*MainChainEventHandler) WriteLastIndexedBlockNumber

func (mce *MainChainEventHandler) WriteLastIndexedBlockNumber(blockNum uint64)

WriteLastIndexedBlockNumber writes the last child block number indexed to chain DB.

type PeerSetManager

type PeerSetManager interface {
	BridgePeerSet() *bridgePeerSet
}

type RemoteBackend

type RemoteBackend struct {
	// contains filtered or unexported fields
}

TODO-Klaytn currently RemoteBackend is only for ServiceChain, especially Bridge SmartContract

func NewRemoteBackend

func NewRemoteBackend(sb *SubBridge) (*RemoteBackend, error)

func (*RemoteBackend) CallContract

func (rb *RemoteBackend) CallContract(ctx context.Context, call klaytn.CallMsg, blockNumber *big.Int) ([]byte, error)

func (*RemoteBackend) ChainID

func (rb *RemoteBackend) ChainID(ctx context.Context) (*big.Int, error)

ChainID returns the chain ID of the sub-bridge configuration.

func (*RemoteBackend) CodeAt

func (rb *RemoteBackend) CodeAt(ctx context.Context, contract common.Address, blockNumber *big.Int) ([]byte, error)

func (*RemoteBackend) EstimateGas

func (rb *RemoteBackend) EstimateGas(ctx context.Context, msg klaytn.CallMsg) (uint64, error)

func (*RemoteBackend) FilterLogs

func (rb *RemoteBackend) FilterLogs(ctx context.Context, query klaytn.FilterQuery) (result []types.Log, err error)

func (*RemoteBackend) PendingCodeAt

func (rb *RemoteBackend) PendingCodeAt(ctx context.Context, contract common.Address) ([]byte, error)

func (*RemoteBackend) PendingNonceAt

func (rb *RemoteBackend) PendingNonceAt(ctx context.Context, account common.Address) (uint64, error)

func (*RemoteBackend) SendTransaction

func (rb *RemoteBackend) SendTransaction(ctx context.Context, tx *types.Transaction) error

func (*RemoteBackend) SubscribeFilterLogs

func (rb *RemoteBackend) SubscribeFilterLogs(ctx context.Context, query klaytn.FilterQuery, ch chan<- types.Log) (klaytn.Subscription, error)

func (*RemoteBackend) SuggestGasPrice

func (rb *RemoteBackend) SuggestGasPrice(ctx context.Context) (*big.Int, error)

func (*RemoteBackend) TransactionReceipt

func (rb *RemoteBackend) TransactionReceipt(ctx context.Context, txHash common.Hash) (*types.Receipt, error)

func (*RemoteBackend) TransactionReceiptRpcOutput added in v1.1.0

func (rb *RemoteBackend) TransactionReceiptRpcOutput(ctx context.Context, txHash common.Hash) (r map[string]interface{}, err error)

type RemoteBackendInterface added in v1.1.0

type RemoteBackendInterface interface {
	bind.ContractBackend
	TransactionReceiptRpcOutput(ctx context.Context, txHash common.Hash) (map[string]interface{}, error)
}

RemoteBackendInterface wraps methods for remote backend

type RequestValueTransferEvent

type RequestValueTransferEvent struct {
	*bridgecontract.BridgeRequestValueTransfer
}

RequestValueTransferEvent from Bridge contract

func (RequestValueTransferEvent) Nonce added in v1.1.0

func (rEv RequestValueTransferEvent) Nonce() uint64

type SCConfig

type SCConfig struct {
	// Name sets the instance name of the node. It must not contain the / character and is
	// used in the devp2p node identifier. The instance name is "kscn". If no
	// value is specified, the basename of the current executable is used.
	Name string `toml:"-"`

	// BridgeService
	EnabledMainBridge bool
	EnabledSubBridge  bool
	DataDir           string

	// Protocol options
	NetworkId uint64 // Network ID to use for selecting peers to connect to

	// Database options
	SkipBcVersionCheck bool `toml:"-"`
	DatabaseHandles    int  `toml:"-"`
	LevelDBCacheSize   int
	TrieCacheSize      int
	TrieTimeout        time.Duration
	TrieBlockInterval  uint
	ChildChainIndexing bool

	// Network
	MainBridgePort string
	SubBridgePort  string
	MaxPeer        int

	// ServiceChain
	ServiceChainConsensus string
	AnchoringPeriod       uint64
	SentChainTxsLimit     uint64

	ParentChainID      uint64
	VTRecovery         bool
	VTRecoveryInterval uint64
}

func (*SCConfig) MainBridges

func (c *SCConfig) MainBridges() []*discover.Node

StaticNodes returns a list of node enode URLs configured as static nodes.

func (SCConfig) MarshalTOML

func (s SCConfig) MarshalTOML() (interface{}, error)

MarshalTOML marshals as TOML.

func (*SCConfig) NodeName

func (c *SCConfig) NodeName() string

NodeName returns the devp2p node identifier.

func (*SCConfig) ResolvePath

func (c *SCConfig) ResolvePath(path string) string

ResolvePath resolves path in the instance directory.

func (*SCConfig) UnmarshalTOML

func (s *SCConfig) UnmarshalTOML(unmarshal func(interface{}) error) error

UnmarshalTOML unmarshals from TOML.

type SCProtocol

type SCProtocol struct {
	// Official short name of the protocol used during capability negotiation.
	Name string
	// Supported versions of the Klaytn protocol (first is primary).
	Versions []uint
	// Number of implemented message corresponding to different protocol versions.
	Lengths []uint64
}

Protocol defines the protocol of the consensus

type SubBridge

type SubBridge struct {
	APIBackend *SubBridgeAPI
	// contains filtered or unexported fields
}

SubBridge implements the Klaytn consensus node service.

func NewSubBridge

func NewSubBridge(ctx *node.ServiceContext, config *SCConfig) (*SubBridge, error)

New creates a new CN object (including the initialisation of the common CN object)

func (*SubBridge) APIs

func (s *SubBridge) APIs() []rpc.API

APIs returns the collection of RPC services the ethereum package offers. NOTE, some of these services probably need to be moved to somewhere else.

func (*SubBridge) AccountManager

func (s *SubBridge) AccountManager() *accounts.Manager

func (*SubBridge) BridgePeerSet

func (sb *SubBridge) BridgePeerSet() *bridgePeerSet

implement PeerSetManager

func (*SubBridge) ChainDB

func (s *SubBridge) ChainDB() database.DBManager

func (*SubBridge) Components

func (s *SubBridge) Components() []interface{}

func (*SubBridge) EventMux

func (s *SubBridge) EventMux() *event.TypeMux

func (*SubBridge) GetAnchoringTx

func (sb *SubBridge) GetAnchoringTx() bool

func (*SubBridge) GetBridgeTxPool

func (sb *SubBridge) GetBridgeTxPool() *bridgepool.BridgeTxPool

func (*SubBridge) IsListening

func (s *SubBridge) IsListening() bool

func (*SubBridge) NetVersion

func (s *SubBridge) NetVersion() uint64

func (*SubBridge) NodeInfo

func (pm *SubBridge) NodeInfo() *SubBridgeInfo

NodeInfo retrieves some protocol metadata about the running host node.

func (*SubBridge) ProtocolVersion

func (s *SubBridge) ProtocolVersion() int

func (*SubBridge) Protocols

func (s *SubBridge) Protocols() []p2p.Protocol

Protocols implements node.Service, returning all the currently configured network protocols to start.

func (*SubBridge) SCProtocol

func (s *SubBridge) SCProtocol() SCProtocol

func (*SubBridge) SendRPCData added in v1.1.0

func (sb *SubBridge) SendRPCData(data []byte) error

func (*SubBridge) SetAnchoringTx

func (sb *SubBridge) SetAnchoringTx(flag bool) bool

func (*SubBridge) SetComponents

func (sc *SubBridge) SetComponents(components []interface{})

func (*SubBridge) SetRPCConn added in v1.1.0

func (sb *SubBridge) SetRPCConn(conn net.Conn)

func (*SubBridge) Start

func (s *SubBridge) Start(srvr p2p.Server) error

Start implements node.Service, starting all internal goroutines needed by the Klaytn protocol implementation.

func (*SubBridge) Stop

func (s *SubBridge) Stop() error

Stop implements node.Service, terminating all internal goroutines used by the Klaytn protocol.

type SubBridgeAPI

type SubBridgeAPI struct {
	// contains filtered or unexported fields
}

SubBridgeAPI Implementation for sub-bridge node

func (*SubBridgeAPI) AddPeer

func (sbapi *SubBridgeAPI) AddPeer(url string) (bool, error)

AddPeer requests connecting to a remote node, and also maintaining the new connection at all times, even reconnecting if it is lost.

func (*SubBridgeAPI) Anchoring

func (sbapi *SubBridgeAPI) Anchoring(flag bool) bool

func (*SubBridgeAPI) ConvertRequestTxHashToHandleTxHash

func (sbapi *SubBridgeAPI) ConvertRequestTxHashToHandleTxHash(hash common.Hash) common.Hash

func (*SubBridgeAPI) ConvertServiceChainBlockHashToMainChainTxHash

func (sbapi *SubBridgeAPI) ConvertServiceChainBlockHashToMainChainTxHash(scBlockHash common.Hash) common.Hash

func (*SubBridgeAPI) DeployBridge

func (sbapi *SubBridgeAPI) DeployBridge() ([]common.Address, error)

func (*SubBridgeAPI) DeregisterBridge

func (sbapi *SubBridgeAPI) DeregisterBridge(cBridgeAddr common.Address, pBridgeAddr common.Address) error

func (*SubBridgeAPI) DeregisterToken

func (sbapi *SubBridgeAPI) DeregisterToken(cBridgeAddr, pBridgeAddr, cTokenAddr, pTokenAddr common.Address) error

func (*SubBridgeAPI) GetAnchoring

func (sbapi *SubBridgeAPI) GetAnchoring() bool

func (*SubBridgeAPI) GetAnchoringPeriod

func (sbapi *SubBridgeAPI) GetAnchoringPeriod() uint64

func (*SubBridgeAPI) GetBridgeInformation

func (sbapi *SubBridgeAPI) GetBridgeInformation(bridgeAddr common.Address) (map[string]interface{}, error)

func (*SubBridgeAPI) GetERC20Fee added in v1.1.0

func (sbapi *SubBridgeAPI) GetERC20Fee(bridgeAddr, tokenAddr common.Address) (*big.Int, error)

func (*SubBridgeAPI) GetFeeReceiver added in v1.1.0

func (sbapi *SubBridgeAPI) GetFeeReceiver(bridgeAddr common.Address) (common.Address, error)

func (*SubBridgeAPI) GetKLAYFee added in v1.1.0

func (sbapi *SubBridgeAPI) GetKLAYFee(bridgeAddr common.Address) (*big.Int, error)

func (*SubBridgeAPI) GetLatestAnchoredBlockNumber

func (sbapi *SubBridgeAPI) GetLatestAnchoredBlockNumber() uint64

func (*SubBridgeAPI) GetMainChainAccountAddr

func (sbapi *SubBridgeAPI) GetMainChainAccountAddr() string

func (*SubBridgeAPI) GetMainChainAccountNonce

func (sbapi *SubBridgeAPI) GetMainChainAccountNonce() uint64

func (*SubBridgeAPI) GetOperators added in v1.1.0

func (sbapi *SubBridgeAPI) GetOperators() map[string]interface{}

GetOperators returns the information of bridge operators.

func (*SubBridgeAPI) GetParentTransactionReceipt added in v1.1.0

func (sbapi *SubBridgeAPI) GetParentTransactionReceipt(txHash common.Hash) (map[string]interface{}, error)

func (*SubBridgeAPI) GetReceiptFromParentChain

func (sbapi *SubBridgeAPI) GetReceiptFromParentChain(blockHash common.Hash) *types.Receipt

func (*SubBridgeAPI) GetSentChainTxsLimit

func (sbapi *SubBridgeAPI) GetSentChainTxsLimit() uint64

func (*SubBridgeAPI) GetServiceChainAccountAddr

func (sbapi *SubBridgeAPI) GetServiceChainAccountAddr() string

func (*SubBridgeAPI) GetServiceChainAccountNonce

func (sbapi *SubBridgeAPI) GetServiceChainAccountNonce() uint64

func (*SubBridgeAPI) ListBridge

func (sbapi *SubBridgeAPI) ListBridge() []*BridgeJournal

func (*SubBridgeAPI) LockChildOperator added in v1.1.0

func (sbapi *SubBridgeAPI) LockChildOperator() error

LockChildOperator can lock the child bridge operator.

func (*SubBridgeAPI) LockParentOperator added in v1.1.0

func (sbapi *SubBridgeAPI) LockParentOperator() error

LockParentOperator can lock the parent bridge operator.

func (*SubBridgeAPI) NodeInfo

func (sbapi *SubBridgeAPI) NodeInfo() (*p2p.NodeInfo, error)

NodeInfo retrieves all the information we know about the host node at the protocol granularity.

func (*SubBridgeAPI) Peers

func (sbapi *SubBridgeAPI) Peers() ([]*p2p.PeerInfo, error)

Peers retrieves all the information we know about each individual peer at the protocol granularity.

func (*SubBridgeAPI) RegisterBridge

func (sbapi *SubBridgeAPI) RegisterBridge(cBridgeAddr common.Address, pBridgeAddr common.Address) error

func (*SubBridgeAPI) RegisterToken

func (sbapi *SubBridgeAPI) RegisterToken(cBridgeAddr, pBridgeAddr, cTokenAddr, pTokenAddr common.Address) error

func (*SubBridgeAPI) RemovePeer

func (sbapi *SubBridgeAPI) RemovePeer(url string) (bool, error)

RemovePeer disconnects from a a remote node if the connection exists

func (*SubBridgeAPI) SetERC20Fee added in v1.1.0

func (sbapi *SubBridgeAPI) SetERC20Fee(bridgeAddr, tokenAddr common.Address, fee *big.Int) (common.Hash, error)

func (*SubBridgeAPI) SetFeeReceiver added in v1.1.0

func (sbapi *SubBridgeAPI) SetFeeReceiver(bridgeAddr, receiver common.Address) (common.Hash, error)

func (*SubBridgeAPI) SetKLAYFee added in v1.1.0

func (sbapi *SubBridgeAPI) SetKLAYFee(bridgeAddr common.Address, fee *big.Int) (common.Hash, error)

func (*SubBridgeAPI) SubscribeBridge

func (sbapi *SubBridgeAPI) SubscribeBridge(cBridgeAddr, pBridgeAddr common.Address) error

SubscribeBridge enables the given service/main chain bridges to subscribe the events.

func (*SubBridgeAPI) TxPending

func (sbapi *SubBridgeAPI) TxPending() map[common.Address]types.Transactions

func (*SubBridgeAPI) TxPendingCount

func (sbapi *SubBridgeAPI) TxPendingCount() int

func (*SubBridgeAPI) UnlockChildOperator added in v1.1.0

func (sbapi *SubBridgeAPI) UnlockChildOperator(passphrase string) error

UnlockChildOperator can unlock the child bridge operator.

func (*SubBridgeAPI) UnlockParentOperator added in v1.1.0

func (sbapi *SubBridgeAPI) UnlockParentOperator(passphrase string) error

UnlockParentOperator can unlock the parent bridge operator.

func (*SubBridgeAPI) UnsubscribeBridge

func (sbapi *SubBridgeAPI) UnsubscribeBridge(cBridgeAddr, pBridgeAddr common.Address) error

UnsubscribeBridge disables the event subscription of the given service/main chain bridges.

type SubBridgeHandler

type SubBridgeHandler struct {
	// contains filtered or unexported fields
}

func NewSubBridgeHandler

func NewSubBridgeHandler(scc *SCConfig, main *SubBridge) (*SubBridgeHandler, error)

func (*SubBridgeHandler) GetAnchoringPeriod

func (sbh *SubBridgeHandler) GetAnchoringPeriod() uint64

GetAnchoringPeriod returns the period to make and send a chain transaction to parent chain.

func (*SubBridgeHandler) GetLatestAnchoredBlockNumber

func (sbh *SubBridgeHandler) GetLatestAnchoredBlockNumber() uint64

GetLatestAnchoredBlockNumber returns the latest block number whose data has been anchored to the parent chain.

func (*SubBridgeHandler) GetMainChainAccountAddr

func (sbh *SubBridgeHandler) GetMainChainAccountAddr() *common.Address

GetMainChainAccountAddr returns a pointer of a hex address of an account used for parent chain. If given as a parameter, it will use it. If not given, it will use the address of the public key derived from chainKey.

func (*SubBridgeHandler) GetNextAnchoringBlockNumber

func (sbh *SubBridgeHandler) GetNextAnchoringBlockNumber() uint64

GetNextAnchoringBlockNumber returns the next block number which is needed to be anchored.

func (*SubBridgeHandler) GetReceiptFromParentChain

func (sbh *SubBridgeHandler) GetReceiptFromParentChain(blockHash common.Hash) *types.Receipt

GetReceiptFromParentChain returns a receipt received from parent chain to child chain with corresponding block hash. It assumes that a child chain has only one parent chain.

func (*SubBridgeHandler) GetSentChainTxsLimit

func (sbh *SubBridgeHandler) GetSentChainTxsLimit() uint64

GetSentChainTxsLimit returns the maximum number of stored chain transactions for resending.

func (*SubBridgeHandler) GetServiceChainAccountAddr

func (sbh *SubBridgeHandler) GetServiceChainAccountAddr() *common.Address

GetServiceChainAccountAddr returns a pointer of a hex address of an account used for service chain. If given as a parameter, it will use it. If not given, it will use the address of the public key derived from chainKey.

func (*SubBridgeHandler) HandleMainMsg

func (sbh *SubBridgeHandler) HandleMainMsg(p BridgePeer, msg p2p.Msg) error

func (*SubBridgeHandler) LocalChainHeadEvent

func (sbh *SubBridgeHandler) LocalChainHeadEvent(block *types.Block)

LocalChainHeadEvent deals with servicechain feature to generate/broadcast service chain transactions and request receipts.

func (*SubBridgeHandler) LockMainChainAccount

func (sbh *SubBridgeHandler) LockMainChainAccount()

func (*SubBridgeHandler) RegisterNewPeer

func (sbh *SubBridgeHandler) RegisterNewPeer(p BridgePeer) error

func (*SubBridgeHandler) SyncNonceAndGasPrice

func (scpm *SubBridgeHandler) SyncNonceAndGasPrice()

SyncNonceAndGasPrice requests the nonce of address used for service chain tx to parent chain peers.

func (*SubBridgeHandler) UnLockMainChainAccount

func (sbh *SubBridgeHandler) UnLockMainChainAccount()

func (*SubBridgeHandler) UpdateLastestAnchoredBlockNumber

func (sbh *SubBridgeHandler) UpdateLastestAnchoredBlockNumber(newLastestAnchoredBN uint64)

UpdateLastestAnchoredBlockNumber set the latestAnchoredBlockNumber to the block number of the last anchoring tx which was added into bridge txPool.

func (*SubBridgeHandler) WriteAnchoredBlockNumber

func (sbh *SubBridgeHandler) WriteAnchoredBlockNumber(blockNum uint64)

WriteAnchoredBlockNumber writes the block number whose data has been anchored to the parent chain.

func (*SubBridgeHandler) WriteReceiptFromParentChain

func (sbh *SubBridgeHandler) WriteReceiptFromParentChain(blockHash common.Hash, receipt *types.Receipt)

WriteReceiptFromParentChain writes a receipt received from parent chain to child chain with corresponding block hash. It assumes that a child chain has only one parent chain.

type SubBridgeInfo

type SubBridgeInfo struct {
	Network uint64              `json:"network"` // Klaytn network ID
	Genesis common.Hash         `json:"genesis"` // SHA3 hash of the host's genesis block
	Config  *params.ChainConfig `json:"config"`  // Chain configuration for the fork rules
	Head    common.Hash         `json:"head"`    // SHA3 hash of the host's best owned block
	ChainID *big.Int            `json:"chainid"` // ChainID
}

NodeInfo represents a short summary of the ServiceChain sub-protocol metadata known about the host peer.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL