model

type Acct interface {
	Apply(add bool, op *types.TxOutPoint, entry interface{}) error
	Commit() error
}

type AssertError string

type Block interface {
	GetID() uint
	GetHash() *hash.Hash
	GetState() BlockState
	GetOrder() uint
	HasParents() bool
	GetMainParent() uint
	GetHeight() uint
}

type BlockChain interface {
	GetMainOrder() uint
	FetchBlockByOrder(order uint64) (*types.SerializedBlock, Block, error)
	FetchSpendJournalPKS(targetBlock *types.SerializedBlock) ([][]byte, error)
	SetDAGDuplicateTxs(sblock *types.SerializedBlock, block Block)
	GetBlockHashByOrder(order uint) *hash.Hash
	BlockByOrder(blockOrder uint64) (*types.SerializedBlock, error)
	Rebuild() error
	GetMiningTips(expectPriority int) []*hash.Hash
	GetBlockState(order uint64) BlockState
	MeerChain() MeerChain
	Start() error
	Stop() error
	GetBlockByOrder(order uint64) Block
	GetBlockById(id uint) Block
	GetMainChainTip() Block
	FetchBlockByHash(hash *hash.Hash) (*types.SerializedBlock, error)
	GetBlockOrderByHash(hash *hash.Hash) (uint, error)
	GetBlockHeader(block Block) *types.BlockHeader
	ForeachBlueBlocks(start Block, depth uint, powType pow.PowType, fn func(block Block, header *types.BlockHeader) error) error
}

type BlockState interface {
	GetID() uint64
	SetOrder(order uint64)
	GetOrder() uint64
	IsOrdered() bool
	SetWeight(weight uint64)
	GetWeight() uint64
	GetStatus() BlockStatus
	Valid()
	Invalid()
	Root() *hash.Hash
	Bytes() ([]byte, error)
	GetEVMRoot() common.Hash
	GetEVMHash() common.Hash
	GetEVMNumber() uint64
	SetEVM(header *etypes.Header)
	GetDuplicateTxs() []int
	Update(block *types.SerializedBlock, prev BlockState, header *etypes.Header)
}

type BlockStatus byte

type Consensus interface {
	Init() error
	GenesisHash() *hash.Hash
	Config() *config.Config
	DatabaseContext() DataBase
	BlockChain() BlockChain
	IndexManager() IndexManager
	Events() *event.Feed
	MedianTimeSource() MedianTimeSource
	SigCache() *txscript.SigCache
	Interrupt() <-chan struct{}
	Params() *params.Params
	Rebuild() error
	AmanaService() service.IService
	Shutdown()
}

type DataBase interface {
	Name() string
	Init() error
	Close()
	Rebuild(mgr IndexManager) error
	GetInfo() (*common.DatabaseInfo, error)
	PutInfo(di *common.DatabaseInfo) error
	GetSpendJournal(bh *hash.Hash) ([]byte, error)
	PutSpendJournal(bh *hash.Hash, data []byte) error
	DeleteSpendJournal(bh *hash.Hash) error
	GetUtxo(key []byte) ([]byte, error)
	PutUtxo(key []byte, data []byte) error
	DeleteUtxo(key []byte) error
	ForeachUtxo(fn func(key []byte, data []byte) error) error
	UpdateUtxo(opts []*common.UtxoOpt) error
	GetTokenState(blockID uint) ([]byte, error)
	PutTokenState(blockID uint, data []byte) error
	DeleteTokenState(blockID uint) error
	GetBestChainState() ([]byte, error)
	PutBestChainState(data []byte) error
	GetBlock(hash *hash.Hash) (*types.SerializedBlock, error)
	GetBlockBytes(hash *hash.Hash) ([]byte, error)
	GetHeader(hash *hash.Hash) (*types.BlockHeader, error)
	PutBlock(block *types.SerializedBlock) error
	HasBlock(hash *hash.Hash) bool
	GetDagInfo() ([]byte, error)
	PutDagInfo(data []byte) error
	GetDAGBlock(blockID uint) ([]byte, error)
	PutDAGBlock(blockID uint, data []byte) error
	DeleteDAGBlock(blockID uint) error
	GetDAGBlockIdByHash(bh *hash.Hash) (uint, error)
	PutDAGBlockIdByHash(bh *hash.Hash, id uint) error
	DeleteDAGBlockIdByHash(bh *hash.Hash) error
	PutMainChainBlock(blockID uint) error
	HasMainChainBlock(blockID uint) bool
	DeleteMainChainBlock(blockID uint) error
	PutBlockIdByOrder(order uint, id uint) error
	GetBlockIdByOrder(order uint) (uint, error)
	PutDAGTip(id uint, isMain bool) error
	GetDAGTips() ([]uint, error)
	DeleteDAGTip(id uint) error
	PutDiffAnticone(id uint) error
	GetDiffAnticones() ([]uint, error)
	DeleteDiffAnticone(id uint) error
	Get(key []byte) ([]byte, error)
	Put(key []byte, value []byte) error
	PutTxIdxEntrys(sblock *types.SerializedBlock, block Block) error
	GetTxIdxEntry(id *hash.Hash, verbose bool) (*types.Tx, *hash.Hash, error)
	DeleteTxIdxEntrys(block *types.SerializedBlock) error
	PutTxHashs(block *types.SerializedBlock) error
	GetTxIdByHash(fullHash *hash.Hash) (*hash.Hash, error)
	DeleteTxHashs(block *types.SerializedBlock) error
	IsInvalidTxIdxEmpty() bool
	GetInvalidTxIdxTip() (uint64, *hash.Hash, error)
	PutInvalidTxIdxTip(order uint64, bh *hash.Hash) error
	PutInvalidTxs(sblock *types.SerializedBlock, block Block) error
	DeleteInvalidTxs(sblock *types.SerializedBlock, block Block) error
	GetInvalidTx(id *hash.Hash) (*types.Transaction, error)
	GetInvalidTxIdByHash(fullHash *hash.Hash) (*hash.Hash, error)
	CleanInvalidTxIdx() error
	GetAddrIdxTip() (*hash.Hash, uint, error)
	PutAddrIdxTip(bh *hash.Hash, order uint) error
	PutAddrIdx(sblock *types.SerializedBlock, block Block, stxos [][]byte) error
	GetTxForAddress(addr types.Address, numToSkip, numRequested uint32, reverse bool) ([]*common.RetrievedTx, uint32, error)
	DeleteAddrIdx(sblock *types.SerializedBlock, stxos [][]byte) error
	CleanAddrIdx(finish bool) error
	IsLegacy() bool
	TryUpgrade(di *common.DatabaseInfo, interrupt <-chan struct{}) error
	GetEstimateFee() ([]byte, error)
	PutEstimateFee(data []byte) error
	DeleteEstimateFee() error
	Snapshot() error
	SnapshotInfo() string
	DBEngine() string
	StartTrack(info string) error
	StopTrack() error
}

type DifficultyManager interface {
	RequiredDifficulty(block Block, newBlockTime time.Time, powInstance pow.IPow) (uint32, error)
	CalcEasiestDifficulty(bits uint32, duration time.Duration, powInstance pow.IPow) uint32
	GetCurrentPowDiff(ib Block, powType pow.PowType) *big.Int
}

type ErrDeserialize string

type FeeEstimator interface {
	RegisterBlock(block *types.SerializedBlock, mainheight uint) error
	Rollback(hash *hash.Hash) error
}

type IndexManager interface {
	// Init is invoked during chain initialize in order to allow the index
	// manager to initialize itself and any indexes it is managing.  The
	// channel parameter specifies a channel the caller can close to signal
	// that the process should be interrupted.  It can be nil if that
	// behavior is not desired.
	Init() error

	// ConnectBlock is invoked when a new block has been connected to the
	// main chain.
	ConnectBlock(sblock *types.SerializedBlock, block Block, stxos [][]byte) error

	// DisconnectBlock is invoked when a block has been disconnected from
	// the main chain.
	DisconnectBlock(sblock *types.SerializedBlock, block Block, stxos [][]byte) error

	UpdateMainTip(bh *hash.Hash, order uint64) error

	// IsDuplicateTx
	IsDuplicateTx(txid *hash.Hash, blockHash *hash.Hash) bool

	HasTx(txid *hash.Hash) bool
}

type InvalidTxIndexStore interface {
	Store
	Stage(stagingArea *StagingArea, bid uint64, block *types.SerializedBlock)
	StageTip(stagingArea *StagingArea, bhash *hash.Hash, order uint64)
	IsStaged(stagingArea *StagingArea) bool
	Get(stagingArea *StagingArea, txid *hash.Hash) (*types.Transaction, error)
	GetIdByHash(stagingArea *StagingArea, h *hash.Hash) (*hash.Hash, error)
	Delete(stagingArea *StagingArea, bid uint64, block *types.SerializedBlock)
	Tip(stagingArea *StagingArea) (uint64, *hash.Hash, error)
	IsEmpty() bool
	Clean() error
}

type MedianTimeSource interface {
	// AdjustedTime returns the current time adjusted by the median time
	// offset as calculated from the time samples added by AddTimeSample.
	AdjustedTime() time.Time

	// AddTimeSample adds a time sample that is used when determining the
	// median time of the added samples.
	AddTimeSample(id string, timeVal time.Time)

	// Offset returns the number of seconds to adjust the local clock based
	// upon the median of the time samples added by AddTimeData.
	Offset() time.Duration
}

type MeerChain interface {
	RegisterAPIs(apis []api.API)
	GetBlockIDByTxHash(txhash *hash.Hash) uint64
}

type Notify interface {
	AnnounceNewTransactions(newTxs []*types.TxDesc, filters []peer.ID)
	RelayInventory(block *types.SerializedBlock, flags uint32, source *peer.ID)
	BroadcastMessage(data interface{})
	TransactionConfirmed(tx *types.Tx)
	TransactionsConfirmed(txs []*types.Tx)
	AddRebroadcastInventory(newTxs []*types.TxDesc)
}

type P2PService interface {
	IsCurrent() bool
	IsNearlySynced() bool
}

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

type StagingShard interface {
	Commit(dbTx legacydb.Tx) error
}

type StagingShardID uint64

type Store interface {
}

type Tx interface {
	GetTxType() types.TxType
	GetFrom() []byte
	GetTo() []byte
	GetValue() uint64
	GetData() []byte
}

type TxManager interface {
	MemPool() TxPool
	FeeEstimator() FeeEstimator
	InitDefaultFeeEstimator()
}

type TxPool interface {
	RemoveTransaction(tx *types.Tx, removeRedeemers bool)

	RemoveDoubleSpends(tx *types.Tx)

	RemoveOrphan(tx *types.Tx)

	ProcessOrphans(tx *types.Tx) []*types.TxDesc

	MaybeAcceptTransaction(tx *types.Tx, isNew, rateLimit bool) ([]*hash.Hash, error)

	HaveTransaction(hash *hash.Hash) bool

	PruneExpiredTx()

	ProcessTransaction(tx *types.Tx, allowOrphan, rateLimit, allowHighFees bool) ([]*types.TxDesc, error)

	GetMainHeight() int64

	AddTransaction(tx *types.Tx, height uint64, fee int64)

	IsSupportVMTx() bool
}

type TxStatus byte