adapter

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

type RDbBlockActivityDataRepo interface {
	InsertGenesisActivity(tx RDbTx, activity *chainindex.Activity) error
	InsertTransferTransaction(tx RDbTx, activity *chainindex.Activity) error
	InsertDepositTransaction(tx RDbTx, activity *chainindex.Activity) error
	InsertUnbondTransaction(tx RDbTx, activity *chainindex.Activity) error
	InsertWithdrawTransaction(tx RDbTx, activity *chainindex.Activity) error
	InsertNodeJoinTransaction(tx RDbTx, activity *chainindex.Activity) error
	InsertUnjailTransaction(tx RDbTx, activity *chainindex.Activity) error
	InsertRewardEvent(tx RDbTx, activity *chainindex.Activity) error
	InsertSlashEvent(tx RDbTx, activity *chainindex.Activity) error
	InsertJailEvent(tx RDbTx, activity *chainindex.Activity) error
}

type RDbBlockCommittedCouncilNodeRow struct {
	BlockHeight        uint64 `json:"-"`
	ID                 uint64 `json:"id"`
	Name               string `json:"name"`
	CouncilNodeAddress string `json:"address"`
	Signature          string `json:"signature"`
	IsProposer         bool   `json:"is_proposer"`
}

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

type RDbConn interface {
	Begin() (RDbTx, error)
	Exec(sql string, args ...interface{}) (RDbExecResult, error)
	Query(sql string, args ...interface{}) (RDbRowsResult, error)
	QueryRow(sql string, args ...interface{}) RDbRowResult
}

type RDbCouncilNodeRow struct {
	ID                         *uint64 `json:"id"`
	Name                       string  `json:"name"`
	MaybeSecurityContact       *string `json:"security_contact"`
	PubKeyType                 string  `json:"pubkey_type"`
	PubKey                     string  `json:"pubkey"`
	Address                    string  `json:"address"`
	CreatedAtBlockHeight       uint64  `json:"created_at_block_height"`
	MaybeLastLeftAtBlockHeight *uint64 `json:"last_left_at_block_height"`
}

type RDbExecResult interface {
	RowsAffected() int64
	IsInsert() bool
	IsUpdate() bool
	IsDelete() bool
	IsSelect() bool
	String() string
}

type RDbNtobReader interface {
	// returns reference to a scannable type
	ScannableArg() interface{}
	// parse the scannable argument reference to big.Int
	Parse() (*big.Int, error)
	ParseW() (*bignum.WBigInt, error)
}

type RDbNtotReader interface {
	// returns reference to a scannable type
	ScannableArg() interface{}
	// parse the scannable argument reference to time.Time
	Parse() (*time.Time, error)
}

type RDbPaginationBuilder struct {
	*viewrepo.Pagination
	// contains filtered or unexported fields
}

type RDbPaginationSQLBuilder struct {
	*viewrepo.Pagination
	// contains filtered or unexported fields
}

type RDbPaginationStmtBuilder struct {
	*viewrepo.Pagination
	// contains filtered or unexported fields
}

type RDbRowResult interface {
	Scan(dest ...interface{}) error
}

type RDbRowsResult interface {
	Close()
	Err() error
	ExecResult() RDbExecResult
	Next() bool
	Scan(dest ...interface{}) error
}

type RDbRunner interface {
	Exec(sql string, args ...interface{}) (RDbExecResult, error)
	Query(sql string, args ...interface{}) (RDbRowsResult, error)
	QueryRow(sql string, args ...interface{}) RDbRowResult
}

type RDbStakingAccountRow struct {
	Address              string
	Nonce                uint64
	Bonded               *big.Int
	Unbonded             *big.Int
	UnbondedFrom         *time.Time
	PunishmentKind       *string
	JailedUntil          *time.Time
	CurrentCouncilNodeId *uint64
}

type RDbTransferInputRow struct {
	TxID  string `json:"prev_txid"`
	Index int32  `json:"prev_output_index"`
}

type RDbTx interface {
	Exec(sql string, args ...interface{}) (RDbExecResult, error)
	Query(sql string, args ...interface{}) (RDbRowsResult, error)
	QueryRow(sql string, args ...interface{}) RDbRowResult
	Commit() error
	Rollback() error
}

type RDbTypeConv interface {
	// convert big.Int to native number pointer. Return nil if big.Int is nil
	Bton(*big.Int) interface{}
	Iton(int) interface{}
	// native number reader and parser to big.Int
	NtobReader() RDbNtobReader

	// convert time.Time to native time format pointer. Return nil if time
	// is nil
	Tton(*time.Time) interface{}
	NtotReader() RDbNtotReader
}

type StakingDiffConfidentialInit struct {
	Cert string `json:"cert"`
}

type StakingDiffConsensusPubKey struct {
	Type  string `json:"type"`
	Value string `json:"value"`
}

type StakingDiffCouncilNode struct {
	Name             string                      `json:"name"`
	SecurityContact  string                      `json:"security_contact"`
	ConsensusPubKey  StakingDiffConsensusPubKey  `json:"consensus_pubkey"`
	ConfidentialInit StakingDiffConfidentialInit `json:"confidential_init"`
}

type StakingDiffKVPair struct {
	Key   string      `json:"key"`
	Value interface{} `json:"value"`
}

type StakingDiffs = []StakingDiffKVPair

type TendermintBlockData struct {
	Block        *tenderminttypes.Block
	BlockResults *tenderminttypes.BlockResults
}

type TendermintGenesisBlockData struct {
	Genesis *tenderminttypes.Genesis
	Block   *tenderminttypes.Block
}