validator

package
v0.0.0-...-84a2c7a Latest Latest
Warning

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

 Go to latest Published: Sep 7, 2020 License: GPL-3.0, GPL-3.0 Imports: 21 Imported by: 0

README

验证模块

使用场景

验证模块的使用原则是不相信任何的输入，而输入主要包括P2P网络的输入和客户端输入。 验证模块主要是在P2P收到一个广播过来的Unit或者Tx的时候进行验证。另外gptn作为一个客户端时，在生成交易，并将交易添加到交易池时也需要对Tx进行验证。

Tx的验证

P2P收到一条新交易时的验证
本地交易池添加交易时的验证

Unit的验证

P2P收到一个新单元时的验证
  1. 验证Header是否正确
  2. 验证每一条Tx是否正确（如果已经在验证缓存，就不需要重复验证）
  3. 验证每一条Tx是否存在双花（这里不能用缓存）
  4. 验证手续费的分配是否正确（Coinbase验证）
双花交易的判断
  • 一笔交易里面包含的Input中引用了同一个UTXO
  • 一个单元里面包含的多个Tx中引用了同一个UTXO
  • 一笔交易引用的UTXO与交易池中的另一个交易相同

Documentation

Index

Constants

View Source 
const ENABLE_CONTRACT_DEVELOPER_CHECK_TIME = 1577808000 //2020-1-1
View Source 
const ENABLE_CONTRACT_RWSET_CHECK_TIME = 1582992000 //2020-3-1
View Source 
const ENABLE_CONTRACT_SIGN_CHECK_TIME = 1575129600 //2019-12-1
View Source 
const ENABLE_TX_FEE_CHECK_TIME = 1570870800 //2019-10-12 17:00:00

Variables

This section is empty.

Functions

func IsOrphanError 

func IsOrphanError(err error) bool

func NewValidateError 

func NewValidateError(code ValidationCode) error

func ValidateUnitBasic 

func ValidateUnitBasic(unit *modules.Unit) error

不基于数据库，进行Unit最基本的验证

Types

type ContractTxCheckFunc 

type ContractTxCheckFunc func(tx *modules.Transaction) bool
var ContractCheckFun ContractTxCheckFunc

type IDagQuery 

type IDagQuery interface {
	GetTransactionOnly(hash common.Hash) (*modules.Transaction, error)
	IsTransactionExist(hash common.Hash) (bool, error)
	GetHeaderByHash(common.Hash) (*modules.Header, error)
	CheckReadSetValid(contractId []byte, readSet []modules.ContractReadSet) bool
	GetTxRequesterAddress(tx *modules.Transaction) (common.Address, error)
}

type IPropQuery 

type IPropQuery interface {
	GetSlotAtTime(when time.Time) uint32
	GetScheduledMediator(slotNum uint32) common.Address
	GetNewestUnitTimestamp(token modules.AssetId) (int64, error)
	GetChainParameters() *core.ChainParameters
}

type IStateQuery 

type IStateQuery interface {
	GetContractTpl(tplId []byte) (*modules.ContractTemplate, error)
	GetContractJury(contractId []byte) (*modules.ElectionNode, error)
	GetContractState(id []byte, field string) ([]byte, *modules.StateVersion, error)
	GetContractStatesByPrefix(id []byte, prefix string) (map[string]*modules.ContractStateValue, error)
	GetMediators() map[common.Address]bool
	GetMediator(add common.Address) *core.Mediator
	GetBlacklistAddress() ([]common.Address, *modules.StateVersion, error)
	GetJurorByAddrHash(addrHash common.Hash) (*modules.JurorDeposit, error)
	GetJurorReward(jurorAdd common.Address) common.Address
	IsContractDeveloper(addr common.Address) bool
}

type IUtxoQuery 

type IUtxoQuery interface {
	GetUtxoEntry(outpoint *modules.OutPoint) (*modules.Utxo, error)
	GetStxoEntry(outpoint *modules.OutPoint) (*modules.Stxo, error)
}

type Validate 

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

func NewValidate 

func NewValidate(dagdb IDagQuery, utxoRep IUtxoQuery, statedb IStateQuery, propquery IPropQuery,
	cache palletcache.ICache, light bool) *Validate

func (*Validate) CheckTxIsExist 

func (validate *Validate) CheckTxIsExist(tx *modules.Transaction) bool

func (*Validate) ContractTxCheck 

func (validate *Validate) ContractTxCheck(tx *modules.Transaction) bool

func (*Validate) SetContractTxCheckFun 

func (validate *Validate) SetContractTxCheckFun(checkFun ContractTxCheckFunc)

func (*Validate) ValidateHeader 

func (validate *Validate) ValidateHeader(h *modules.Header) ValidationCode

func (*Validate) ValidateTx 

func (validate *Validate) ValidateTx(tx *modules.Transaction, isFullTx bool) ([]*modules.Addition, ValidationCode, error)

func (*Validate) ValidateTxFeeEnough 

func (validate *Validate) ValidateTxFeeEnough(tx *modules.Transaction, extSize float64, extTime float64) bool

extSize :byte, extTime :s

func (*Validate) ValidateUnitExceptGroupSig 

func (validate *Validate) ValidateUnitExceptGroupSig(unit *modules.Unit) ValidationCode

* 验证Unit Validate unit(除群签名以外), 新生产的unit暂时还没有群签名

func (validate *Validate) ValidateUnit(unit *modules.Unit, isGenesis bool) byte {

func (*Validate) ValidateUnitGroupSign 

func (validate *Validate) ValidateUnitGroupSign(h *modules.Header) error

todo 验证群签名接口，需要验证群签的正确性和有效性

type ValidationCode 

type ValidationCode byte
const (
	TxValidationCode_VALID                        ValidationCode = 0
	TxValidationCode_INVALID_CONTRACT_TEMPLATE    ValidationCode = 1
	TxValidationCode_INVALID_FEE                  ValidationCode = 2
	TxValidationCode_BAD_COMMON_HEADER            ValidationCode = 3
	TxValidationCode_BAD_CREATOR_SIGNATURE        ValidationCode = 4
	TxValidationCode_INVALID_ENDORSER_TRANSACTION ValidationCode = 5
	TxValidationCode_INVALID_CONFIG_TRANSACTION   ValidationCode = 6
	TxValidationCode_UNSUPPORTED_TX_PAYLOAD       ValidationCode = 7
	TxValidationCode_BAD_PROPOSAL_TXID            ValidationCode = 8
	TxValidationCode_DUPLICATE_TXID               ValidationCode = 9
	TxValidationCode_ENDORSEMENT_POLICY_FAILURE   ValidationCode = 10
	TxValidationCode_MVCC_READ_CONFLICT           ValidationCode = 11
	TxValidationCode_PHANTOM_READ_CONFLICT        ValidationCode = 12
	TxValidationCode_UNKNOWN_TX_TYPE              ValidationCode = 13
	TxValidationCode_STATE_DATA_NOT_FOUND         ValidationCode = 14
	TxValidationCode_MARSHAL_TX_ERROR             ValidationCode = 15
	TxValidationCode_NIL_TXACTION                 ValidationCode = 16
	TxValidationCode_EXPIRED_CHAINCODE            ValidationCode = 17
	TxValidationCode_CHAINCODE_VERSION_CONFLICT   ValidationCode = 18
	TxValidationCode_BAD_HEADER_EXTENSION         ValidationCode = 19
	TxValidationCode_BAD_CHANNEL_HEADER           ValidationCode = 20
	TxValidationCode_BAD_RESPONSE_PAYLOAD         ValidationCode = 21
	TxValidationCode_BAD_RWSET                    ValidationCode = 22
	TxValidationCode_ILLEGAL_WRITESET             ValidationCode = 23
	TxValidationCode_INVALID_CONTRACT_SIGN        ValidationCode = 24
	TxValidationCode_INVALID_MSG                  ValidationCode = 25
	TxValidationCode_INVALID_PAYMMENTLOAD         ValidationCode = 26
	TxValidationCode_INVALID_PAYMMENT_INPUT       ValidationCode = 27
	TxValidationCode_INVALID_PAYMMENT_INPUT_COUNT ValidationCode = 28
	TxValidationCode_INVALID_COINBASE             ValidationCode = 29
	TxValidationCode_ADDRESS_IN_BLACKLIST         ValidationCode = 30
	TxValidationCode_INVALID_AMOUNT               ValidationCode = 31
	TxValidationCode_INVALID_ASSET                ValidationCode = 32
	TxValidationCode_INVALID_CONTRACT             ValidationCode = 33
	TxValidationCode_INVALID_DATAPAYLOAD          ValidationCode = 34
	TxValidationCode_INVALID_DOUBLE_SPEND         ValidationCode = 35
	TxValidationCode_INVALID_TOKEN_STATUS         ValidationCode = 36
	TxValidationCode_NOT_COMPARE_SIZE             ValidationCode = 37
	TxValidationCode_NOT_TPL_DEVELOPER            ValidationCode = 38

	TxValidationCode_ORPHAN               ValidationCode = 255
	TxValidationCode_INVALID_OTHER_REASON ValidationCode = 251
	TxValidationCode_NOT_VALIDATED        ValidationCode = 250
	UNIT_STATE_AUTHOR_SIGNATURE_PASSED    ValidationCode = 101
	UNIT_STATE_INVALID_MEDIATOR_SCHEDULE  ValidationCode = 102
	UNIT_STATE_INVALID_AUTHOR_SIGNATURE   ValidationCode = 103
	UNIT_STATE_INVALID_GROUP_SIGNATURE    ValidationCode = 104
	UNIT_STATE_HAS_INVALID_TRANSACTIONS   ValidationCode = 105
	UNIT_STATE_INVALID_AUTHOR             ValidationCode = 106
	UNIT_STATE_INVALID_EXTRA_DATA         ValidationCode = 107
	UNIT_STATE_INVALID_HEADER             ValidationCode = 108
	UNIT_STATE_INVALID_HEADER_NUMBER      ValidationCode = 109
	UNIT_STATE_INVALID_HEADER_TXROOT      ValidationCode = 110
	UNIT_STATE_INVALID_HEADER_TIME        ValidationCode = 111
	UNIT_STATE_ORPHAN                     ValidationCode = 254
)

type Validator 

type Validator interface {
	//验证一个交易是否是合法交易
	//isCoinbase
	//isFullTx这个交易是完整的可打包的交易，还是陪审团没处理或者正在处理中的交易
	ValidateTx(tx *modules.Transaction, isFullTx bool) ([]*modules.Addition, ValidationCode, error)
	//验证一个Unit中的所有交易是否是合法交易
	//ValidateTransactions(txs modules.Transactions) error
	//除了群签名外，验证Unit是否是合法Unit,包括其中的所有交易都会逐一验证
	ValidateUnitExceptGroupSig(unit *modules.Unit) ValidationCode
	//ValidateUnitExceptPayment(unit *modules.Unit) error
	//验证一个Header是否合法（Mediator签名有效）,主要用于轻节点
	ValidateHeader(h *modules.Header) ValidationCode
	ValidateUnitGroupSign(h *modules.Header) error
	ValidateTxFeeEnough(tx *modules.Transaction, extSize float64, extTime float64) bool
	CheckTxIsExist(tx *modules.Transaction) bool
}

type ValidatorAllPass 

type ValidatorAllPass struct {
}

ValidatorAllPass used for UT

func (*ValidatorAllPass) CheckTxIsExist 

func (v *ValidatorAllPass) CheckTxIsExist(tx *modules.Transaction) bool

func (*ValidatorAllPass) ValidateHeader 

func (v *ValidatorAllPass) ValidateHeader(h *modules.Header) ValidationCode

ValidateUnitExceptPayment(unit *modules.Unit) error 验证一个Header是否合法（Mediator签名有效）

func (*ValidatorAllPass) ValidateTx 

func (v *ValidatorAllPass) ValidateTx(tx *modules.Transaction, isFullTx bool) ([]*modules.Addition, ValidationCode, error)

func (*ValidatorAllPass) ValidateUnitExceptGroupSig 

func (v *ValidatorAllPass) ValidateUnitExceptGroupSig(unit *modules.Unit) ValidationCode

验证一个Unit中的所有交易是否是合法交易 ValidateTransactions(txs modules.Transactions) error 除了群签名外，验证Unit是否是合法Unit,包括其中的所有交易都会逐一验证

func (*ValidatorAllPass) ValidateUnitGroupSign 

func (v *ValidatorAllPass) ValidateUnitGroupSign(h *modules.Header) error

type ValidatorCache 

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

如果已经验证通过的对象，那么不需要重复做全部验证

func NewValidatorCache 

func NewValidatorCache(cache palletcache.ICache) *ValidatorCache

func (*ValidatorCache) AddHeaderValidateResult 

func (s *ValidatorCache) AddHeaderValidateResult(unitHash common.Hash, code ValidationCode)

func (*ValidatorCache) AddTxValidateResult 

func (s *ValidatorCache) AddTxValidateResult(txId common.Hash, validateResult []*modules.Addition)

func (*ValidatorCache) AddUnitValidateResult 

func (s *ValidatorCache) AddUnitValidateResult(unitHash common.Hash, code ValidationCode)

func (*ValidatorCache) HasHeaderValidateResult 

func (s *ValidatorCache) HasHeaderValidateResult(unitHash common.Hash) (bool, ValidationCode)

func (*ValidatorCache) HasTxValidateResult 

func (s *ValidatorCache) HasTxValidateResult(txId common.Hash) (bool, []*modules.Addition)

func (*ValidatorCache) HasUnitValidateResult 

func (s *ValidatorCache) HasUnitValidateResult(unitHash common.Hash) (bool, ValidationCode)

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.