types

type Block struct {
	Height    int64    `msg:"ht"`
	BlockHash [32]byte `msg:"bh"`
	BlockInfo []byte   `msg:"bi"` // the pre-serialized payload
	TxList    []Tx     `msg:"tx"`
}

type BlockIndex struct {
	Height       uint32   `msg:"ht"`
	BlockHash    [32]byte `msg:"bH"`
	BlockHash48  uint64   `msg:"bh"`
	TxHash48List []uint64 `msg:"thl"`
	BeginOffset  int64    `msg:"bo"`
	TxPosList    []int64  `msg:"tpl"`

	SrcHashes   []uint64   `msg:"sh"`
	SrcPosLists [][]uint32 `msg:"sp"`
	DstHashes   []uint64   `msg:"dh"`
	DstPosLists [][]uint32 `msg:"dp"`

	AddrHashes    []uint64   `msg:"ah"`
	AddrPosLists  [][]uint32 `msg:"ap"`
	TopicHashes   []uint64   `msg:"th"`
	TopicPosLists [][]uint32 `msg:"tp"`
}

type ConvertedOp struct {
	PrevUtxoId      [36]byte
	UtxoId          [36]byte
	OldCovenantAddr [20]byte
	NewCovenantAddr [20]byte
}

type DB interface {
	Close()
	SetExtractNotificationFn(fn ExtractNotificationFromTxFn)
	SetDisableComplexIndex(b bool)
	GetLatestHeight() int64
	AddBlock(blk *Block, pruneTillHeight int64, txid2sigMap map[[32]byte][65]byte)
	GetBlockHashByHeight(height int64) [32]byte
	GetBlockByHeight(height int64) []byte
	GetTxByHeightAndIndex(height int64, index int) []byte
	GetTxListByHeight(height int64) [][]byte
	GetTxListByHeightWithRange(height int64, start, end int) [][]byte
	GetBlockByHash(hash [32]byte, collectResult func([]byte) bool)
	GetTxByHash(hash [32]byte, collectResult func([]byte) bool)
	BasicQueryLogs(addr *[20]byte, topics [][32]byte, startHeight, endHeight uint32, fn func([]byte) bool) error
	QueryLogs(addrOrList [][20]byte, topicsOrList [][][32]byte, startHeight, endHeight uint32, fn func([]byte) bool) error
	QueryTxBySrc(addr [20]byte, startHeight, endHeight uint32, fn func([]byte) bool) error
	QueryTxByDst(addr [20]byte, startHeight, endHeight uint32, fn func([]byte) bool) error
	QueryTxBySrcOrDst(addr [20]byte, startHeight, endHeight uint32, fn func([]byte) bool) error
	QueryNotificationCounter(key []byte) int64

	SetOpListsForCcUtxo(opListsForCcUtxo OpListsForCcUtxo)
	GetUtxoInfos() (infos [][36 + 1 + 20]byte)
	GetAllUtxoIds() [][36]byte
	GetRedeemableUtxoIds() [][36]byte
	GetLostAndFoundUtxoIds() [][36]byte
	GetRedeemingUtxoIds() [][36]byte
	GetUtxoIdsByCovenantAddr(covenantAddr [20]byte) [][36]byte
	GetRedeemableUtxoIdsByCovenantAddr(covenantAddr [20]byte) [][36]byte

	// This function's parameter limits these functions' returned entry count: BasicQueryLogs, QueryLogs, QueryTxBySrc, QueryTxByDst, QueryTxBySrcOrDst
	SetMaxEntryCount(c int)
}

type DeletedOp struct {
	UtxoId       [36]byte
	CovenantAddr [20]byte
	SourceType   byte
}

type ExtendedBlock struct {
	Block
	Txid2sigMap map[string][65]byte `msg:"t2s"`
	UpdateOfADS map[string]string   `msg:"ua"`
}

type ExtractNotificationFromTxFn func(tx Tx, notiMap map[string]int64)

type IndexEntry struct {
	Hash48  uint64   `msg:"h"`
	PosList []uint32 `msg:"l"`
}

type Log struct {
	Address [20]byte   `msg:"a"`
	Topics  [][32]byte `msg:"t"`
}

type NewLostAndFoundOp struct {
	UtxoId       [36]byte
	CovenantAddr [20]byte
}

type NewRedeemableOp struct {
	UtxoId       [36]byte
	CovenantAddr [20]byte
}

type OpListsForCcUtxo struct {
	NewRedeemableOps   []NewRedeemableOp
	NewLostAndFoundOps []NewLostAndFoundOp
	RedeemOps          []RedeemOp
	ConvertedOps       []ConvertedOp
	DeletedOps         []DeletedOp
}

type RedeemOp struct {
	UtxoId       [36]byte
	CovenantAddr [20]byte
	SourceType   byte
}

type Tx struct {
	HashId  [32]byte `msg:"h"`
	SrcAddr [20]byte `msg:"s"`
	DstAddr [20]byte `msg:"d"`
	Content []byte   `msg:"c"` // the pre-serialized payload
	LogList []Log    `msg:"l"`
}