spv

package
v0.2.3 Latest Latest
Warning

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

 Go to latest Published: Sep 13, 2024 License: GPL-3.0 Imports: 53 Imported by: 9

Documentation

Index

Constants

View Source 
const (
	DefaultConfigFilename = "./spvconfig.json"
	Foundation            = "FoundationAddress"
	CRCAddress            = "CRCAddress"
	GenesisBlock          = "GenesisBlock"
	PowLimit              = "PowLimit"
)
View Source 
const (

	//Unprocessed refill transaction index prefix
	UnTransaction string = "UnT-"

	//Cross-chain recharge unprocessed transaction index
	UnTransactionIndex = "UnTI"

	//Cross-chain recharge unprocessed transaction seek
	UnTransactionSeek = "UnTS"

	// Fixed number of extra-data prefix bytes reserved for signer vanity
	ExtraVanity = 32

	// Fixed number of extra-data suffix bytes reserved for signer seal
	ExtraSeal = 65

	// Fixed height of ela chain height with LitterEnd encode
	ExtraElaHeight = 8

	GASLimtScale = 10

	IsOnlyCRConsensus = true
)
View Source 
const (
	ChainState_DPOS = iota
	ChainState_POW
	ChainState_Error
)
View Source 
const LogPath = "./logs-spv/"

Variables

View Source 
var (
	SpvService *Service

	MinedBlockSub *event.TypeMuxSubscription

	GetDefaultSingerAddr func() ethCommon.Address

	PbftEngine consensus.IPbftEngine

	ErrMainTxHashPresence = errors.New("main txhash presence")
)

Functions

func Close added in v0.2.0 

func Close()

func DumpNextDposInfo 

func DumpNextDposInfo() []peer.PID

func FindOutRechargeInput 

func FindOutRechargeInput(transactionHash string) []byte

func FindOutputFeeAndaddressByTxHash 

func FindOutputFeeAndaddressByTxHash(transactionHash string) (*big.Int, ethCommon.Address, *big.Int)

FindOutputFeeAndaddressByTxHash Finds the eth recharge address, recharge amount, and transaction fee based on the main chain hash.

func GetArbiters 

func GetArbiters() ([]string, int, error)

func GetClient added in v0.2.0 

func GetClient() *ethclient.Client

func GetCurrentConsensusMode added in v0.2.0 

func GetCurrentConsensusMode() spv.ConsensusAlgorithm

func GetFailedRechargeTxByHash added in v0.2.0 

func GetFailedRechargeTxByHash(hash string) string

func GetFailedRechargeTxs added in v0.2.0 

func GetFailedRechargeTxs(height uint64) []string

func GetNextTurnPeers added in v0.2.1 

func GetNextTurnPeers() []peer.PID

func GetProducers 

func GetProducers(elaHeight uint64) ([][]byte, int, error)

func GetSpvHeight 

func GetSpvHeight() uint64

func GetTotalProducersCount 

func GetTotalProducersCount() int

func GetUnTransactionNum 

func GetUnTransactionNum(db DatabaseReader, Prefix string) uint64

func GetWorkingHeight 

func GetWorkingHeight() uint32

func InitNextTurnDposInfo 

func InitNextTurnDposInfo()

func IsFailedElaTx added in v0.2.0 

func IsFailedElaTx(elaTx string) (bool, error)

func IsNexturnBlock 

func IsNexturnBlock(block interface{}) bool

func IsPackagedElaTx added in v0.2.0 

func IsPackagedElaTx(elaTx string) (bool, error)

func IsSmallCrossTxByData added in v0.2.0 

func IsSmallCrossTxByData(data []byte) (string, string, []string, uint64)

func IteratorUnTransaction 

func IteratorUnTransaction(from ethCommon.Address)

IteratorUnTransaction iterates before mining and processes existing spv refill transactions

func MainChainIsPowMode 

func MainChainIsPowMode() bool

func MinedBroadcastLoop 

func MinedBroadcastLoop(minedBlockSub *event.TypeMuxSubscription,
	ondutySub *event.TypeMuxSubscription,
	smallCrossTxSub *event.TypeMuxSubscription)

minedBroadcastLoop Mining awareness, eth can initiate a recharge transaction after the block

func NotifySmallCrossTx added in v0.2.0 

func NotifySmallCrossTx(tx it.Transaction)

func OnReceivedRechargeTx added in v0.2.0 

func OnReceivedRechargeTx(tx it.Transaction) error

func OnTx2Failed added in v0.2.0 

func OnTx2Failed(elaTx string)

func ResetConfigWithReflect 

func ResetConfigWithReflect(params *config.Configuration, spvConfig *spv.Config)

func SafeAdd added in v0.2.0 

func SafeAdd(a int, b int) (int, error)

func SafeFixed64Minus added in v0.2.0 

func SafeFixed64Minus(a common.Fixed64, b common.Fixed64) (common.Fixed64, error)

func SafeMinus added in v0.2.0 

func SafeMinus(a int, b int) (int, error)

func SafeUInt64Minus added in v0.2.0 

func SafeUInt64Minus(a uint64, b uint64) (uint64, error)

func SendEvilProof 

func SendEvilProof(addr ethCommon.Address, info interface{})

func SendTransaction 

func SendTransaction(from ethCommon.Address, elaTx string, fee *big.Int) (err error, finished bool)

SendTransaction sends a reload transaction to txpool

func SpvDbInit 

func SpvDbInit(spvdataDir string, pledgeBillContract string, signer ethCommon.Address, client *rpc.Client)

Spv database initialization

func SpvIsWorkingHeight 

func SpvIsWorkingHeight() bool

func UpTransactionIndex 

func UpTransactionIndex(elaTx string)

UpTransactionIndex records spv-aware refill transaction index

func VerifySmallCrossTx added in v0.2.0 

func VerifySmallCrossTx(rawTxID, rawTx string, signatures []string,
	blockHeight uint64) (bool, error)

Types

type BlockListener 

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

func (*BlockListener) BlockHeight 

func (l *BlockListener) BlockHeight() uint32

func (*BlockListener) NotifyBlock 

func (l *BlockListener) NotifyBlock(block *util.Block)

func (*BlockListener) RegisterFunc 

func (l *BlockListener) RegisterFunc(handleFunc func(block interface{}) error)

func (*BlockListener) StoreAuxBlock 

func (l *BlockListener) StoreAuxBlock(block interface{})

type Config 

type Config struct {
	// DataDir is the data path to store db files peer addresses etc.
	DataDir string

	// ActiveNet indicates the ELA network to connect with.
	ActiveNet string

	// GenesisAddress is the address generated by the side chain genesis block.
	GenesisAddress string
}

type DatabaseReader 

type DatabaseReader interface {
	Get(key []byte) (value []byte, err error)
}

DatabaseReader wraps the Get method of a backing data store.

type NextTurnDPOSInfo added in v0.2.1 

type NextTurnDPOSInfo struct {
	*payload.NextTurnDPOSInfo
}

type PreferParams 

type PreferParams struct {
	Config config.Configuration `json:"Configuration"`
}
var PreferConfig PreferParams

type RechargeData added in v0.2.2 

type RechargeData struct {
	TargetAddress ethCommon.Address
	TargetAmount  *big.Int
	Fee           *big.Int
	TargetData    []byte
}

type RechargeDatas added in v0.2.2 

type RechargeDatas []*RechargeData

func GetRechargeDataByTxhash added in v0.2.2 

func GetRechargeDataByTxhash(elaHash string) (RechargeDatas, *big.Int, error)

type Service 

type Service struct {
	spv.SPVService
	// contains filtered or unexported fields
}

func GetSpvService added in v0.2.1 

func GetSpvService() *Service

func NewService 

func NewService(cfg *Config, tmux *event.TypeMux, dynamicArbiterHeight uint64) (*Service, error)

Spv service initialization

func (*Service) GetDatabase 

func (s *Service) GetDatabase() *leveldb.Database

func (*Service) VerifyElaHeader 

func (s *Service) VerifyElaHeader(hash *common.Uint256) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.