blockchain

type BlockStorage interface {
	// Get a block by its digest id
	Get(bcpb.Digest) (*bcpb.Block, error)
	// Returns the genesis  block
	Genesis() (bcpb.Digest, *bcpb.Block)
	// Last block in the ledger
	Last() (bcpb.Digest, *bcpb.Block)
	// Get last executed
	LastExec() (bcpb.Digest, *bcpb.Block)
	// Sets the genesis block digest. It assumes the actual block is already in
	// in the store
	SetGenesis(bcpb.Digest) error
	// Set last block digest. It assumes the actual block is already in
	// in the store
	SetLast(bcpb.Digest) error
	// Sets the last executed block. It assumes the actual block is already in
	// in the store
	SetLastExec(bcpb.Digest) error
	// Returns true if the block by the given digest exists
	Exists(bcpb.Digest) bool
	// Adds a block to the ledger returning an error if it already exists
	Add(*bcpb.Block) (bcpb.Digest, error)
	// Iter iterates of each block in the ledger
	Iter(f stores.BlockIterator) error
}

type BlockValidator func(*bcpb.BlockHeader) error

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

type Config struct {
	// Hash function to use
	Hasher hasher.Hasher

	// Elliptic curve for verification
	Curve elliptic.Curve

	// These need to be specified by the user and are required
	BlockStorage BlockStorage
	TxStorage    TxStorage
	DataKeyIndex DataKeyIndex
}

type DataKeyIndex interface {
	Get(key bcpb.DataKey) (bcpb.Digest, int32, error)
	Set(key bcpb.DataKey, ref bcpb.Digest, idx int32) error
	Iter(prefix bcpb.DataKey, iter stores.DataKeyIterator) error
}

type TxInputOutputValidator func(ref *bcpb.TxOutput, in *bcpb.TxInput) error

type TxStorage interface {
	// Get a transaction
	Get(bcpb.Digest) (*bcpb.Tx, error)
	// Set a transaction
	Set(*bcpb.Tx) error
	// Set a batch of transactions
	SetBatch([]*bcpb.Tx) error
	// Iterate over all transactions
	Iter(func(bcpb.Tx) error)
}