re-gen

Author: albertchon

chain/client/context.go

@@ -157,7 +157,7 @@ func newContext(
 ) client.Context {
 	clientCtx := client.Context{
 		ChainID:           chainId,
-		JSONCodec:     encodingConfig.Marshaler,
+		JSONCodec:         encodingConfig.Marshaler,
 		InterfaceRegistry: encodingConfig.InterfaceRegistry,
 		Output:            os.Stderr,
 		OutputFormat:      "json",

chain/oracle/types/expected_keepers.go

@@ -2,7 +2,6 @@ package types
 
 import (
 	sdk "github.com/cosmos/cosmos-sdk/types"
-	banktypes "github.com/cosmos/cosmos-sdk/x/bank/types"
 )
 
 // BankKeeper defines the expected bank keeper methods
@@ -12,5 +11,4 @@ type BankKeeper interface {
 	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
 	SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
 	BurnCoins(ctx sdk.Context, moduleName string, amt sdk.Coins) error
-	GetDenomMetaData(ctx sdk.Context, denom string) banktypes.Metadata
 }

chain/oracle/types/genesis.go

@@ -6,6 +6,9 @@ func NewGenesisState() GenesisState {
 
 func (gs GenesisState) Validate() error {
 	// TODO: validate stuff in genesis
+	if err := gs.Params.Validate(); err != nil {
+		return err
+	}
 	return nil
 }
 

chain/oracle/types/key.go

@@ -52,6 +52,11 @@ func GetPricefeedRelayerStorePrefix(baseQuoteHash common.Hash) []byte {
 	return append(PricefeedRelayerKey, baseQuoteHash.Bytes()...)
 }
 
-func GetCoinbasePriceStoreKey(key string) []byte {
-	return append(CoinbasePriceKey, []byte(key)...)
+func GetCoinbasePriceStoreKey(key string, timestamp uint64) []byte {
+	timeKey := sdk.Uint64ToBigEndian(timestamp)
+	return append(append(CoinbasePriceKey, []byte(key)...), timeKey...)
+}
+
+func GetCoinbasePriceStoreIterationKey(key string) []byte {
+	return append(append(CoinbasePriceKey, []byte(key)...))
 }

chain/oracle/types/msgs.go

@@ -7,6 +7,13 @@ import (
 
 const RouterKey = ModuleName
 
+// oracle message types
+const (
+	TypeMsgRelayPriceFeedPrice   = "relayPriceFeedPrice"
+	TypeMsgRelayBandRates        = "relayBandRates"
+	TypeMsgRelayCoinbaseMessages = "relayCoinbaseMessages"
+)
+
 var (
 	_ sdk.Msg = &MsgRelayPriceFeedPrice{}
 	_ sdk.Msg = &MsgRelayBandRates{}
@@ -17,7 +24,7 @@ var (
 func (msg MsgRelayPriceFeedPrice) Route() string { return RouterKey }
 
 // Type implements the sdk.Msg interface. It should return the action.
-func (msg MsgRelayPriceFeedPrice) Type() string { return "msgRelayPriceFeedPrice" }
+func (msg MsgRelayPriceFeedPrice) Type() string { return TypeMsgRelayPriceFeedPrice }
 
 // ValidateBasic implements the sdk.Msg interface. It runs stateless checks on the message
 func (msg MsgRelayPriceFeedPrice) ValidateBasic() error {
@@ -55,7 +62,7 @@ func (msg MsgRelayPriceFeedPrice) GetSigners() []sdk.AccAddress {
 func (msg MsgRelayBandRates) Route() string { return RouterKey }
 
 // Type implements the sdk.Msg interface. It should return the action.
-func (msg MsgRelayBandRates) Type() string { return "msgRelayBandRates" }
+func (msg MsgRelayBandRates) Type() string { return TypeMsgRelayBandRates }
 
 // ValidateBasic implements the sdk.Msg interface for MsgRelay.
 func (msg MsgRelayBandRates) ValidateBasic() error {
@@ -96,7 +103,7 @@ func (msg MsgRelayBandRates) GetSigners() []sdk.AccAddress {
 func (msg MsgRelayCoinbaseMessages) Route() string { return RouterKey }
 
 // Type implements the sdk.Msg interface. It should return the action.
-func (msg MsgRelayCoinbaseMessages) Type() string { return "msgRelayCoinbaseMessages" }
+func (msg MsgRelayCoinbaseMessages) Type() string { return TypeMsgRelayCoinbaseMessages }
 
 // ValidateBasic implements the sdk.Msg interface for MsgRelay.
 func (msg MsgRelayCoinbaseMessages) ValidateBasic() error {

chain/oracle/types/oracle.go

@@ -1,13 +1,15 @@
 package types
 
 import (
+	"strings"
+
 	sdk "github.com/cosmos/cosmos-sdk/types"
 	sdkerrors "github.com/cosmos/cosmos-sdk/types/errors"
 	"github.com/gogo/protobuf/proto"
-	"strings"
 )
 
 const QuoteUSD = "USD"
+const TwapWindow = int64(5 * 60) // 5 minute TWAP window
 
 func GetOracleType(oracleTypeStr string) (OracleType, error) {
 	oracleTypeStr = strings.ToLower(oracleTypeStr)