price queries

proto/ojo/oracle/v1/query.proto

@@ -4,6 +4,7 @@ package ojo.oracle.v1;
 import "gogoproto/gogo.proto";
 import "google/api/annotations.proto";
 import "ojo/oracle/v1/oracle.proto";
+import "ojo/oracle/v1/elys.proto";
 import "cosmos/base/v1beta1/coin.proto";
 
 option go_package = "github.com/ojo-network/ojo/x/oracle/types";
@@ -97,6 +98,18 @@ service Query {
     option (google.api.http).get =
         "/ojo/oracle/v1/valdiators/validator_reward_set";
   }
+
+  // Queries a Price by asset.
+  rpc Price(QueryGetPriceRequest)
+      returns (QueryGetPriceResponse) {
+    option (google.api.http).get = "/elys-network/elys/oracle/price/{asset}";
+  }
+
+  // Queries a list of Price items.
+  rpc PriceAll(QueryAllPriceRequest)
+      returns (QueryAllPriceResponse) {
+    option (google.api.http).get = "/elys-network/elys/oracle/prices";
+  }
 }
 
 // QueryExchangeRates is the request type for the Query/ExchangeRate RPC
@@ -291,3 +304,19 @@ message QueryValidatorRewardSet {}
 message QueryValidatorRewardSetResponse {
   ValidatorRewardSet validators = 1 [(gogoproto.nullable) = false];
 }
+
+message QueryGetPriceRequest {
+  string asset = 1;
+  string source = 2;
+  uint64 timestamp = 3;
+}
+
+message QueryGetPriceResponse {
+  Price price = 1 [ (gogoproto.nullable) = false ];
+}
+
+message QueryAllPriceRequest {}
+
+message QueryAllPriceResponse {
+  repeated Price price = 1 [ (gogoproto.nullable) = false ];
+}

x/oracle/client/cli/query.go

@@ -32,6 +32,8 @@ func GetQueryCmd() *cobra.Command {
 		GetCmdQueryFeederDelegation(),
 		GetCmdQueryMissCounter(),
 		GetCmdQuerySlashWindow(),
+		GetCmdListPrice(),
+		CmdShowPrice(),
 	)
 
 	return cmd
@@ -277,3 +279,57 @@ func GetCmdQuerySlashWindow() *cobra.Command {
 	flags.AddQueryFlagsToCmd(cmd)
 	return cmd
 }
+
+func GetCmdListPrice() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "list-price",
+		Short: "list all price",
+		RunE: func(cmd *cobra.Command, args []string) error {
+			clientCtx, err := client.GetClientQueryContext(cmd)
+			if err != nil {
+				return err
+			}
+			queryClient := types.NewQueryClient(clientCtx)
+
+			res, err := queryClient.PriceAll(cmd.Context(), &types.QueryAllPriceRequest{})
+			return cli.PrintOrErr(res, err, clientCtx)
+		},
+	}
+
+	flags.AddQueryFlagsToCmd(cmd)
+	return cmd
+}
+
+func CmdShowPrice() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "show-price [asset] [source] [timestamp]",
+		Short: "shows a price",
+		Args:  cobra.ExactArgs(3),
+		RunE: func(cmd *cobra.Command, args []string) (err error) {
+			clientCtx := client.GetClientContextFromCmd(cmd)
+
+			timestamp, err := cmd.Flags().GetUint64(args[2])
+			if err != nil {
+				return err
+			}
+
+			queryClient := types.NewQueryClient(clientCtx)
+			params := &types.QueryGetPriceRequest{
+				Asset:     args[0],
+				Source:    args[1],
+				Timestamp: timestamp,
+			}
+
+			res, err := queryClient.Price(cmd.Context(), params)
+			if err != nil {
+				return err
+			}
+
+			return clientCtx.PrintProto(res)
+		},
+	}
+
+	flags.AddQueryFlagsToCmd(cmd)
+
+	return cmd
+}

x/oracle/keeper/grpc_query.go

@@ -328,3 +328,47 @@ func (q querier) ValidatorRewardSet(
 		Validators: validatorRewardSet,
 	}, nil
 }
+
+func (q querier) PriceAll(goCtx context.Context, req *types.QueryAllPriceRequest) (*types.QueryAllPriceResponse, error) {
+	if req == nil {
+		return nil, status.Error(codes.InvalidArgument, "invalid request")
+	}
+
+	ctx := sdk.UnwrapSDKContext(goCtx)
+
+	prices := q.GetAllPrice(ctx)
+
+	return &types.QueryAllPriceResponse{Price: prices}, nil
+}
+
+func (q querier) Price(goCtx context.Context, req *types.QueryGetPriceRequest) (*types.QueryGetPriceResponse, error) {
+	if req == nil {
+		return nil, status.Error(codes.InvalidArgument, "invalid request")
+	}
+	ctx := sdk.UnwrapSDKContext(goCtx)
+
+	// if both source and timestamp are defined, use specific value
+	if req.Source != "" && req.Timestamp != 0 {
+		val, found := q.GetPrice(ctx, req.Asset, req.Source, req.Timestamp)
+		if !found {
+			return nil, status.Error(codes.NotFound, "not found")
+		}
+		return &types.QueryGetPriceResponse{Price: val}, nil
+	}
+
+	// if source is specified use latest price from source
+	if req.Source != "" {
+		val, found := q.GetLatestPriceFromAssetAndSource(ctx, req.Asset, req.Source)
+		if !found {
+			return nil, status.Error(codes.NotFound, "not found")
+		}
+		return &types.QueryGetPriceResponse{Price: val}, nil
+	}
+
+	// find from any source if band source does not exist
+	val, found := q.GetLatestPriceFromAnySource(ctx, req.Asset)
+	if !found {
+		return nil, status.Error(codes.NotFound, "not found")
+	}
+	return &types.QueryGetPriceResponse{Price: val}, nil
+}