meddb

type Bigtable interface {
	Put(tableName []byte, op *PutOp) error
	Get(tableName []byte, op *GetOp) (map[string][]*Cell, error)
	CreateTable(tableName []byte) error
}

type Block struct {
	Hash         []byte
	Transactions []*Transaction
	CreatedAt    *big.Int
	Creator      []byte
	Sig          []byte
	Voters       [][]byte
	State        int
}

type BlockChangefeed interface {
	Next(*BlockChangefeedRes) bool
}

type BlockChangefeedRes struct {
	OldVal *Block
	NewVal *Block
}

type BlockchainDB interface {
	// First time setup to create required tables and indices
	SetupTables() error

	// Writes transaction to backlog table
	WriteTransaction(*Transaction) error
	// Returns transactions currently assigned to given node from backlog table
	GetAssignedTransactions([]byte) ([]*Transaction, error)
	// Returns transactions older than given time (no order) from backlog table
	GetStaleTransactions(int64) ([]*Transaction, error)
	// Deletes given transactions from backlog table
	DeleteTransactions([]*Transaction) error

	// Writes block to block table
	WriteBlock(*Block) error
	// Returns blocks from block table by block ids
	GetBlocks([][]byte) ([]*Block, error)
	// Returns k oldest blocks from block table starting at given timestamp sorted by increasing
	// CreatedAt timestamp.
	GetOldestBlocks(int64, int) ([]*Block, error)
	// Returns outputs for given output ids
	GetOutputs([][]byte) ([]*OutputRes, error)
	// Returns inputs for given output ids
	GetInputsByOutput([][]byte) ([]*InputRes, error)

	// Writes vote to vote table
	WriteVote(*Vote) error
	// Returns all votes for given public key from votes table with the given VotedAt
	GetVotes([]byte, int64) ([]*Vote, error)
	// Returns k most recent votes for given public key from votes table sorted by decreasing
	// VotedAt timestamp.
	GetRecentVotes([]byte, int) ([]*Vote, error)

	// Returns changefeed for all transactions assigned to the given public key
	GetAssignedTransactionChangefeed([]byte) (TransactionChangefeed, error)
	// Returns changefeed for all blocks
	GetBlockChangefeed() (BlockChangefeed, error)
	// Returns changefeed for all votes
	GetVoteChangefeed() (VoteChangefeed, error)
}

type Cell struct {
	VerId *big.Int
	Data  []byte
}

type ColIdAlreadyExists struct {
	ColId []byte
}

type Database interface {
	Get([]byte) ([]byte, error)
	Put([]byte, []byte) error
	Contains([]byte) (bool, error)
	Commit() error
	Delete([]byte) error
}

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

type Input struct {
	Type       int
	OutputHash []byte
	Data       []byte
}

type InputRes struct {
	Block *Block
	Input *Input
}

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

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

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

type NotFoundError struct {
	Key []byte
}

type Output struct {
	Hash []byte
	Type int
	Data []byte
}

type OutputRes struct {
	Block       *Block
	Transaction *Transaction
	Output      *Output
}

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

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

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

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

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

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

type RowNotFoundError struct {
	RowId []byte
}

type TableAlreadyExists struct {
	TableName []byte
}

type TableNotFoundError struct {
	TableName []byte
}

type Transaction struct {
	Hash       []byte
	AssignedTo []byte // Public key of node this transaction is assigned to
	AssignedAt *big.Int
	Type       int
	TableName  []byte
	RowId      []byte
	Cols       map[string]*Cell
	Outputs    []*Output
	Inputs     []*Input
}

type TransactionChangefeed interface {
	Next(*TransactionChangefeedRes) bool
}

type TransactionChangefeedRes struct {
	OldVal *Transaction
	NewVal *Transaction
}

type VerIdAlreadyExists struct {
	VerId *big.Int
}

type Vote struct {
	Hash      []byte
	Voter     []byte
	Sig       []byte
	VotedAt   *big.Int
	PrevBlock []byte
	NextBlock []byte // Block we are voting on
	Value     bool
}

type VoteChangefeed interface {
	Next(*VoteChangefeedRes) bool
}

type VoteChangefeedRes struct {
	OldVal *Vote
	NewVal *Vote
}