datastore

type AssetInfo struct {
	Token *struct {
		ContractAddr string `json:"contract_addr"`
	} `json:"token,omitempty"`

	NativeToken *struct {
		Denom string `json:"denom"`
	} `json:"native_token,omitempty"`
}

type AssetInfoWithType struct {
	Type           string `json:"type"`
	DenomOrAddress string `json:"denom_or_address"`
}

type BlockTxsDTO struct {
	BlockId int64   `json:"block_id"`
	Txs     []TxDTO `json:"txs"`
}

type BlockTxsRaw struct {
	BlockId int64   `json:"block_id"`
	Txs     []TxRaw `json:"txs"`
}

type DataStore interface {
	// testing purpose
	SetNewServiceClientFunc(func(cc grpc1.ClientConn) txtypes.ServiceClient)
	SetNewS3ClientFunc(func() (s3client.S3ClientInterface, error))
	SetNewQueryClientFunc(func(cc grpc1.ClientConn) wasm.QueryClient)

	// additional wrapper for Collector module usage
	GetNodeSyncedHeight() (int64, error)
	GetChainId() string
	GetLatestProcessedBlockNumber(...string) (int64, error)
	ChangeLatestBlock(int64, ...string) error
	UploadBlockBinary(int64, []byte, ...string) error

	// exposed to public usage in actual
	AddCustomInterfaceRegistry(...func(codectypes.InterfaceRegistry))
	GetBlockByHeight(int64) (*tendermintType.Block, error)
	GetBlockTxsFromHeight(int64) (*BlockTxsRaw, error)
	GetBlockTxsFromBlockData(*tendermintType.Block) (*BlockTxsRaw, error)
	GetCurrentPairsList(int64) (*PairListDTO, error)
	GetCurrentPoolStatusOfUnitPair(int64, string) (*PoolInfoDTO, error)
	GetCurrentPoolStatusOfAllPairs(int64) (*PoolInfoList, error)
	GetPoolStatusOfUnitPairByHeight(int64, string, ...string) (*PoolInfoDTO, error)
	GetPoolStatusOfAllPairsByHeight(int64, ...string) (*PoolInfoList, error)
	UploadPoolInfoBinary(int64, []byte, ...string) error
}

type PairListDTO struct {
	Pairs map[string]UnitPairDTO `json:"pairs"`
}

type PairListResponse struct {
	Pairs []UnitPair `json:"pairs"`
}

type PoolAssetInfo struct {
	Info   AssetInfo      `json:"info"`
	Amount *cosmossdk.Int `json:"amount"`
}

type PoolAssetInfoWithType struct {
	Info   *AssetInfoWithType `json:"info"`
	Amount *cosmossdk.Int     `json:"amount"`
}

type PoolInfo struct {
	Assets     [2]PoolAssetInfo `json:"assets"`
	TotalShare *cosmossdk.Int   `json:"total_share"`
}

type PoolInfoDTO struct {
	Assets     [2]PoolAssetInfoWithType `json:"assets"`
	TotalShare *cosmossdk.Int           `json:"total_share"`
}

type PoolInfoList struct {
	Pairs map[string]PoolInfoDTO `json:"pairs"`
}

type ReadStore interface {
	GetLatestHeight() (uint64, error)
	GetBlockByHeight(height uint64) (*BlockTxsDTO, error)
	GetPoolStatusOfAllPairsByHeight(uint64) (*PoolInfoList, error)
}

type ReadStoreMock struct {
	mock.Mock
}

type TxDTO struct {
	Height    string                    `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	TxHash    string                    `protobuf:"bytes,2,opt,name=txhash,proto3" json:"txhash,omitempty"`
	Codespace string                    `protobuf:"bytes,3,opt,name=codespace,proto3" json:"codespace,omitempty"`
	Code      uint32                    `protobuf:"varint,4,opt,name=code,proto3" json:"code,omitempty"`
	Data      string                    `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	RawLog    string                    `protobuf:"bytes,6,opt,name=raw_log,json=rawLog,proto3" json:"raw_log,omitempty"`
	Logs      cosmossdk.ABCIMessageLogs `protobuf:"bytes,7,rep,name=logs,proto3,castrepeated=ABCIMessageLogs" json:"logs"`
	Info      string                    `protobuf:"bytes,8,opt,name=info,proto3" json:"info,omitempty"`
	GasWanted string                    `protobuf:"varint,9,opt,name=gas_wanted,json=gasWanted,proto3" json:"gas_wanted,omitempty"`
	GasUsed   string                    `protobuf:"varint,10,opt,name=gas_used,json=gasUsed,proto3" json:"gas_used,omitempty"`

	// the type of Tx will be replace when we can find the appropriate type
	Tx        *codectypes.Any   `protobuf:"bytes,11,opt,name=tx,proto3" json:"tx,omitempty"`
	Timestamp string            `protobuf:"bytes,12,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Events    []abcitypes.Event `protobuf:"bytes,13,rep,name=events,proto3" json:"events"`
}

type TxRaw struct {
	TxHash    string
	TxContent *txtypes.GetTxResponse
}

type UnitPair struct {
	AssetInfo      [2]AssetInfo `json:"asset_infos"`
	ContractAddr   string       `json:"contract_addr"`
	LiquidityToken string       `json:"liquidity_token"`
	AssetDecimals  [2]uint      `json:"asset_decimals"`
}

type UnitPairDTO struct {
	AssetInfo      [2]AssetInfoWithType `json:"asset_infos"`
	ContractAddr   string               `json:"contract_addr"`
	LiquidityToken string               `json:"liquidity_token"`
	AssetDecimals  [2]uint              `json:"asset_decimals"`
}