db

type CrossTransactionIndexed struct {
	PK       uint64         `storm:"id,increment"`
	CtxId    common.Hash    `storm:"unique"`
	From     common.Address `storm:"index"`
	TxHash   common.Hash    `storm:"index"`
	Price    *big.Float     `storm:"index"`
	BlockNum uint64         `storm:"index"`

	// normal field
	Status cc.CtxStatus

	Value            *big.Int
	BlockHash        common.Hash
	DestinationId    *big.Int
	DestinationValue *big.Int `storm:"index"`
	Input            []byte

	V []*big.Int
	R []*big.Int
	S []*big.Int
}

type CtxDB interface {
	io.Closer
	ChainID() *big.Int
	//Size() int
	Count(filter ...q.Matcher) int
	Height() uint64
	Load() error
	Repair() error
	Write(ctx *cc.CrossTransactionWithSignatures) error
	Read(ctxId common.Hash) (*cc.CrossTransactionWithSignatures, error)
	One(field FieldName, key interface{}) *cc.CrossTransactionWithSignatures
	//ReadAll(ctxId common.Hash) (common.Hash, error)
	//Delete(ctxId common.Hash, atNumber uint64) error
	Update(id common.Hash, updater func(ctx *CrossTransactionIndexed)) error
	Has(id common.Hash) bool
	Query(pageSize int, startPage int, orderBy FieldName, filter ...q.Matcher) []*cc.CrossTransactionWithSignatures
	RangeByNumber(begin, end uint64, pageSize int) []*cc.CrossTransactionWithSignatures
}

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

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

type CtxToBlockHash lru.ARCCache

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

type FieldName = string

type Filter func(ctx *cc.CrossTransactionWithSignatures) bool

type IndexDbCache lru.ARCCache

type ServiceContext interface {
	ResolvePath(string) string
	OpenDatabase(string, int, int, string) (ethdb.Database, error)
}