check mock oracle

proto/reserve/oracle/tx.proto

@@ -22,6 +22,8 @@ service Msg {
 
   rpc UpdateBandParams(MsgUpdateBandParams) returns (MsgUpdateBandParamsResponse);
 
+  rpc SetPrice(MsgSetPrice) returns (MsgSetPriceResponse);
+
   rpc UpdateBandOracleRequest(MsgUpdateBandOracleRequestRequest) returns (MsgUpdateBandOracleRequestResponse);
 
   rpc DeleteBandOracleRequests(MsgDeleteBandOracleRequests) returns (MsgDeleteBandOracleRequestsResponse);
@@ -121,4 +123,20 @@ message MsgUpdateBandOracleRequestParamsRequest {
 }
 
 // MsgUpdateBandOracleRequestParamsResponse define the Msg/UpdateBandOracleRequestParams response type.
-message MsgUpdateBandOracleRequestParamsResponse {}
+message MsgUpdateBandOracleRequestParamsResponse {}
+
+message MsgSetPrice{
+  option (cosmos.msg.v1.signer) = "authority";
+  option (amino.name) = "reserve/x/oracle/MsgSetPrice";
+  string denom = 1;
+
+  bytes price = 2 [
+    (cosmos_proto.scalar)  = "cosmos.Dec",
+    (gogoproto.customtype) = "cosmossdk.io/math.LegacyDec",
+    (gogoproto.nullable)   = false
+  ];
+
+  string authority = 3;
+}
+
+message MsgSetPriceResponse {}

script/proposal-psm.json

@@ -6,7 +6,8 @@
       "limit_total": "100000000000000000000000000000",
       "fee_in": "0.001000000000000000",
       "fee_out": "0.001000000000000000",
-      "oracle_script": "44"
+      "oracle_script": "44",
+      "symbol": "USD"
     },
     {
       "@type": "/reserve.psm.v1.MsgAddStableCoin",
@@ -15,7 +16,8 @@
       "limit_total": "100000000000000000000000000000",
       "fee_in": "0.001000000000000000",
       "fee_out": "0.001000000000000000",
-      "oracle_script": "44"
+      "oracle_script": "44",
+      "symbol": "USD"
     }],
     "deposit": "100000000stake",
     "title": "My proposal",

x/oracle/client/cli/tx.go

@@ -4,6 +4,7 @@ import (
 	"fmt"
 	"strconv"
 
+	"cosmossdk.io/math"
 	errors "github.com/pkg/errors"
 	"github.com/spf13/cobra"
 
@@ -29,6 +30,7 @@ func GetTxCmd() *cobra.Command {
 
 	cmd.AddCommand(
 		NewRequestBandRatesTxCmd(),
+		NewSetPriceCmd(),
 	)
 
 	return cmd
@@ -73,3 +75,32 @@ func NewRequestBandRatesTxCmd() *cobra.Command {
 
 	return cmd
 }
+
+func NewSetPriceCmd() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "set-price [denom] [price]",
+		Args:  cobra.ExactArgs(2),
+		Short: "set price for denom ",
+		Long: `set price for denomn.
+
+			Example:
+			$ onomyd tx mockoracel set-price usdt 1 
+	`,
+
+		RunE: func(cmd *cobra.Command, args []string) error {
+			clientCtx, err := client.GetClientTxContext(cmd)
+			if err != nil {
+				return err
+			}
+			price := math.LegacyMustNewDecFromStr(args[1])
+			addr := clientCtx.GetFromAddress()
+			msg := types.NewSetPrice(args[0], addr.String(), price)
+
+			return tx.GenerateOrBroadcastTxCLI(clientCtx, cmd.Flags(), &msg)
+		},
+	}
+
+	flags.AddTxFlagsToCmd(cmd)
+
+	return cmd
+}

x/oracle/keeper/band_oracle.go

@@ -621,3 +621,167 @@
 
 	return allPair
 }
+
+func (k Keeper) SetInitPrice(ctx context.Context) error {
+	sdkCtx := sdk.UnwrapSDKContext(ctx)
+	initPrice := []*types.BandPriceState{
+		// multiplier = 1000
+		{
+			Symbol:      "fxUSD",
+			Rate:        math.NewInt(10000), //1
+			ResolveTime: sdkCtx.BlockTime().Unix(),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("1"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "USD",
+			Rate:        math.NewInt(10000), //1
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("1"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "EUR",
+			Rate:        math.NewInt(10910), //1
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("1"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "JPY",
+			Rate:        math.NewInt(66), //1
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("1"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "fxEUR",
+			Rate:        math.NewInt(10910), //1.091
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("1.091"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "fxJPY",
+			Rate:        math.NewInt(66), //0.0066
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("0.0066"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "anom",
+			Rate:        math.NewInt(330), //0.03
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("0.03"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "NOM",
+			Rate:        math.NewInt(330), //0.03
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("0.03"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "usdt",
+			Rate:        math.NewInt(10000), //1
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("1"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "USDT",
+			Rate:        math.NewInt(10000), //1
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("1"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "usdc",
+			Rate:        math.NewInt(10000), //1
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("1"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "eurt",
+			Rate:        math.NewInt(10910), //1.091
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("1.091"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "jpyt",
+			Rate:        math.NewInt(66), //0.0066
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("0.0066"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "uatom",
+			Rate:        math.NewInt(80000), //8
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("8"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "ATOM",
+			Rate:        math.NewInt(80000), //8
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("8"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "uosmo",
+			Rate:        math.NewInt(4500), //0.45
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("0.45"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "uusdt",
+			Rate:        math.NewInt(10000), //0.45
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("1"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "atom",
+			Rate:        math.NewInt(80000), //0.45
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("8"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "ibc/E50A183716AB596378047D9688FE648CD3470C4D196FB4C2C8E61989DB48562E", //transfer/channel-10/transfer/channel-7/transfer/channel-143/erc20/tether/usdt
+			Rate:        math.NewInt(10000),
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("1"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "ibc/BE4C72028781730B9DF0542466EB26DEA6DDD42C32316D774F943151F6010320", // transfer/channel-5/usdt
+			Rate:        math.NewInt(10000),
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("1"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "ibc/ED07A3391A112B175915CD8FAF43A2DA8E4790EDE12566649D0C2F97716B8518", //transfer/channel-0/uosmo
+			Rate:        math.NewInt(4500),                                                      //0.45
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("0.45"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "ibc/27394FB092D2ECCD56123C74F36E4C1F926001CEADA9CA97EA622B25F41E5EB2", //ibc-atom
+			Rate:        math.NewInt(80000),                                                     //0.45
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("8"), sdkCtx.BlockTime().Unix()),
+		},
+		{
+			Symbol:      "ibc/BC599B88586F8C22E408569D7F6FAD40AEBF808A67D2051B86958CBB5F0A16B0", //usdt
+			Rate:        math.NewInt(10000),
+			ResolveTime: (sdkCtx.BlockTime().Unix()),
+			PriceState:  *types.NewPriceState(math.LegacyMustNewDecFromStr("1"), sdkCtx.BlockTime().Unix()),
+		},
+	}
+
+	for _, i := range initPrice {
+		err := k.SetBandPriceState(ctx, i.Symbol, i)
+		if err != nil {
+			return err
+		}
+	}
+	return nil
+}
+
+func (k Keeper) SetPrice(goCtx context.Context, msg *types.MsgSetPrice) (*types.MsgSetPriceResponse, error) {
+	sdkCtx := sdk.UnwrapSDKContext(goCtx)
+	k.SetBandPriceState(goCtx, msg.Denom, &types.BandPriceState{
+		Symbol:      msg.Denom,
+		Rate:        math.NewInt(10000).ToLegacyDec().Mul(msg.Price).TruncateInt(),
+		ResolveTime: (sdkCtx.BlockTime().Unix()),
+		PriceState:  *types.NewPriceState(msg.Price, sdkCtx.BlockTime().Unix()),
+	})
+	return &types.MsgSetPriceResponse{}, nil
+}

x/oracle/module/genesis.go

@@ -23,6 +23,7 @@
 			sdkCtx.Logger().Info("can not set band price state for symbol %s", bandPriceState.Symbol)
 		}
 	}
+	k.SetInitPrice(ctx)
 
 	for _, bandOracleRequest := range genState.BandOracleRequests {
 		err := k.SetBandOracleRequest(ctx, *bandOracleRequest)

x/oracle/types/msgs.go

@@ -2,6 +2,7 @@ package types
 
 import (
 	errorsmod "cosmossdk.io/errors"
+	math "cosmossdk.io/math"
 	sdk "github.com/cosmos/cosmos-sdk/types"
 )
 
@@ -90,3 +91,11 @@ func (msg MsgRequestBandRates) GetSignBytes() []byte {
 	bz := ModuleCdc.MustMarshalJSON(&msg)
 	return sdk.MustSortJSON(bz)
 }
+
+func NewSetPrice(denom, authority string, price math.LegacyDec) MsgSetPrice {
+	return MsgSetPrice{
+		Denom:     denom,
+		Price:     price,
+		Authority: authority,
+	}
+}