pub

type Account struct {
	Owner    string // string representation of AccAddress
	Fee      string
	Sequence int64

	Balances []*AssetBalance
}

type Accounts struct {
	Height    int64
	NumOfMsgs int
	Accounts  []Account
}

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

type AllocatedAmt struct {
	Address string
	Amount  int64
}

type AssetBalance struct {
	Asset  string
	Free   int64
	Frozen int64
	Locked int64
}

type AvroOrJsonMsg interface {
	ToNativeMap() map[string]interface{}
	String() string
}

type Block struct {
	ChainID     string
	CryptoBlock CryptoBlock
}

type BlockFee struct {
	Height     int64
	Fee        string
	Validators []string // slice of string wrappers of bytes representation of sdk.AccAddress
}

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

type Books struct {
	Height    int64
	Timestamp int64
	NumOfMsgs int
	Books     []OrderBookDelta
}

type BreatheBlockMsg struct {
	Height    int64
	Timestamp int64
}

type Coin struct {
	Denom  string `json:"denom"`
	Amount int64  `json:"amount"`
}

type CompletedReDelegation struct {
	Delegator    sdk.AccAddress
	ValidatorSrc sdk.ValAddress
	ValidatorDst sdk.ValAddress
}

type CompletedUnbondingDelegation struct {
	Validator sdk.ValAddress
	Delegator sdk.AccAddress
	Amount    Coin
}

type CrossReceiver struct {
	Addr   string
	Amount int64
}

type CrossTransfer struct {
	TxHash     string
	ChainId    string
	RelayerFee int64
	Type       string
	From       string
	Denom      string
	Contract   string
	Decimals   int
	To         []CrossReceiver
}

type CrossTransfers struct {
	Height    int64
	Num       int
	Timestamp int64
	Transfers []CrossTransfer
}

type CryptoBlock struct {
	BlockHash   string
	ParentHash  string
	BlockHeight int64
	Timestamp   string
	TxTotal     int64

	BlockMeta    NativeBlockMeta
	Transactions []Transaction
}

type DelegateEvent struct {
	Delegator sdk.AccAddress
	Validator sdk.ValAddress
	Amount    Coin
	TxHash    string
}

type Delegation stake.Delegation

type Distribution struct {
	Validator      sdk.ValAddress
	SelfDelegator  sdk.AccAddress
	DistributeAddr sdk.AccAddress
	ValTokens      int64
	TotalReward    int64
	Commission     int64
	Rewards        []*Reward
}

type DistributionMsg struct {
	NumOfMsgs     int
	Height        int64
	Timestamp     int64
	Distributions map[string][]*Distribution
}

type EssMsg interface {
	AvroOrJsonMsg

	// a string that carry essential msg used to make up downstream service on kafka issue
	// this string would be persisted into file
	EssentialMsg() string

	// an empty message of original `AvroOrJsonMsg` to make downstream logic not broken
	EmptyCopy() AvroOrJsonMsg
}

type ExecutionResults struct {
	Height       int64
	Timestamp    int64 // milli seconds since Epoch
	NumOfMsgs    int   // number of individual messages we published, consumer can verify messages they received against this field to make sure they does not miss messages
	Trades       trades
	Orders       Orders
	Proposals    Proposals
	StakeUpdates StakeUpdates
}

type Input struct {
	Address string
	Coins   []Coin
}

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

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

type MarketDataPublisher interface {
	Stop()
	// contains filtered or unexported methods
}

type Metrics struct {
	// Height of last published message
	PublicationHeight metricsPkg.Gauge

	// Size of publication queue
	PublicationQueueSize metricsPkg.Gauge

	// Time between publish this and the last block.
	// Should be (approximate) blocking + abci + publication time
	PublicationBlockIntervalMs metricsPkg.Gauge

	// Time used to collect block information
	CollectBlockTimeMs metricsPkg.Gauge

	// Time used to collect orderbook information
	CollectOrderBookTimeMs metricsPkg.Gauge

	// Time used to publish everything in a block
	// Should be (approximate) sum of folllowing Times
	PublishTotalTimeMs metricsPkg.Gauge
	// Time used to publish order & trade
	PublishTradeAndOrderTimeMs metricsPkg.Gauge
	// Time used to publish orderbook
	PublishOrderbookTimeMs metricsPkg.Gauge
	// Time used to publish accounts
	PublishAccountTimeMs metricsPkg.Gauge
	// Time used to publish blockfee
	PublishBlockfeeTimeMs metricsPkg.Gauge
	// Time	used to publish transfer
	PublishTransfersTimeMs metricsPkg.Gauge
	// Time	used to publish block
	PublishBlockTimeMs metricsPkg.Gauge
	// Time	used to publish sideProposal
	PublishSideProposalTimeMs metricsPkg.Gauge

	// num of trade
	NumTrade metricsPkg.Gauge
	// num of order
	NumOrder metricsPkg.Gauge
	// num of orderbook levels
	NumOrderBook metricsPkg.Gauge
	// num of account balance changes
	NumAccounts metricsPkg.Gauge
	// num of transfer
	NumTransfers metricsPkg.Gauge

	NumOrderInfoForPublish metricsPkg.Gauge
}

type Mirror struct {
	TxHash         string
	ChainId        string
	Type           string
	RelayerFee     int64
	Sender         string
	Contract       string
	BEP20Name      string
	BEP20Symbol    string
	BEP2Symbol     string
	OldTotalSupply int64
	TotalSupply    int64
	Decimals       int
	Fee            int64
}

type Mirrors struct {
	Height    int64
	Num       int
	Timestamp int64
	Mirrors   []Mirror
}

type MockMarketDataPublisher struct {
	AccountPublished          []*Accounts
	BooksPublished            []*Books
	ExecutionResultsPublished []*ExecutionResults
	BlockFeePublished         []BlockFee
	TransferPublished         []Transfers
	BlockPublished            []*Block

	Lock             *sync.Mutex // as mock publisher is only used in testing, its no harm to have this granularity Lock
	MessagePublished uint32      // atomic integer used to determine the published messages
}

type NativeBlockMeta struct {
	LastCommitHash     string
	DataHash           string
	ValidatorsHash     string
	NextValidatorsHash string
	ConsensusHash      string
	AppHash            string
	LastResultsHash    string
	EvidenceHash       string
	ProposerAddress    string
}

type NativeTransaction struct {
	Source     int64
	TxType     string
	TxAsset    string
	OrderId    string
	Code       uint32
	Data       string
	ProposalId int64
}

type Order struct {
	Symbol               string
	Status               orderPkg.ChangeType
	OrderId              string
	TradeId              string
	Owner                string
	Side                 int8
	OrderType            int8
	Price                int64
	Qty                  int64
	LastExecutedPrice    int64
	LastExecutedQty      int64
	CumQty               int64
	Fee                  string // DEPRECATING(Galileo): total fee for Owner in this block, should use SingleFee in future
	OrderCreationTime    int64
	TransactionTime      int64
	TimeInForce          int8
	CurrentExecutionType orderPkg.ExecutionType
	TxHash               string
	SingleFee            string // fee for this order update - ADDED Galileo
}

type OrderBookDelta struct {
	Symbol string
	Buys   []PriceLevel
	Sells  []PriceLevel
}

type OrderSymbolId struct {
	Symbol string
	Id     string
}

type Orders struct {
	NumOfMsgs int
	Orders    []*Order
}

type Output struct {
	Address string
	Coins   []Coin
}

type PriceLevel struct {
	Price   int64
	LastQty int64
}

type Proposal struct {
	Id     int64
	Status ProposalStatus
}

type ProposalStatus uint8

type Proposals struct {
	NumOfMsgs int
	Proposals []*Proposal
}

type ReDelegation stake.Redelegation

type Receiver struct {
	Addr  string
	Coins []Coin
}

type RedelegateEvent struct {
	Delegator    sdk.AccAddress
	ValidatorSrc sdk.ValAddress
	ValidatorDst sdk.ValAddress
	Amount       Coin
	TxHash       string
}

type Reward struct {
	Validator sdk.ValAddress
	Delegator sdk.AccAddress
	Tokens    int64
	Amount    int64
}

type SideProposal struct {
	Id      int64
	ChainId string
	Status  ProposalStatus
}

type SideProposals struct {
	Height    int64
	Timestamp int64
	NumOfMsgs int
	Proposals []*SideProposal
}

type Slash struct {
	Validator              sdk.ValAddress
	InfractionType         byte
	InfractionHeight       int64
	JailUtil               int64
	SlashAmount            int64
	ToFeePool              int64
	Submitter              sdk.AccAddress
	SubmitterReward        int64
	ValidatorsCompensation []*AllocatedAmt
}

type SlashMsg struct {
	NumOfMsgs int
	Height    int64
	Timestamp int64
	SlashData map[string][]*Slash
}

type StakeUpdates struct {
	NumOfMsgs                     int
	CompletedUnbondingDelegations []*CompletedUnbondingDelegation
}

type StakingMsg struct {
	NumOfMsgs int
	Height    int64
	Timestamp int64

	Validators           []*Validator
	RemovedValidators    map[string][]sdk.ValAddress
	Delegations          map[string][]*Delegation
	UnbondingDelegations map[string][]*UnbondingDelegation
	ReDelegations        map[string][]*ReDelegation
	CompletedUBDs        map[string][]*CompletedUnbondingDelegation
	CompletedREDs        map[string][]*CompletedReDelegation
	DelegateEvents       map[string][]*DelegateEvent
	UndelegateEvents     map[string][]*UndelegateEvent
	RedelegateEvents     map[string][]*RedelegateEvent
	ElectedValidators    map[string][]*Validator
}

type Trade struct {
	Id         string
	Symbol     string
	Price      int64
	Qty        int64
	Sid        string
	Bid        string
	Sfee       string // DEPRECATING(Galileo): seller's total fee in this block, in future we should use SSingleFee which is more precise
	Bfee       string // DEPRECATING(Galileo): buyer's total fee in this block, in future we should use BSingleFee which is more precise
	SAddr      string // string representation of AccAddress
	BAddr      string // string representation of AccAddress
	SSrc       int64  // sell order source - ADDED Galileo
	BSrc       int64  // buy order source - ADDED Galileo
	SSingleFee string // seller's fee for this trade - ADDED Galileo
	BSingleFee string // buyer's fee for this trade - ADDED Galileo
	TickType   int    // ADDED Galileo
}

type Transaction struct {
	TxHash    string
	Fee       string
	Timestamp string

	Inputs  []Input
	Outputs []Output

	NativeTransaction NativeTransaction
}

type Transfer struct {
	TxHash string
	Memo   string // Added for BEP39
	From   string
	To     []Receiver
}

type Transfers struct {
	Height    int64
	Num       int
	Timestamp int64
	Transfers []Transfer
}

type UnbondingDelegation stake.UnbondingDelegation

type UndelegateEvent struct {
	Delegator sdk.AccAddress
	Validator sdk.ValAddress
	Amount    Coin
	TxHash    string
}

type Validator stake.Validator