add current prices

Author: colmazia

proto/feeds/v1beta1/query.proto

@@ -17,6 +17,11 @@ service Query {
     option (google.api.http).get = "/feeds/v1beta1/current-feeds";
   }
 
+  // CurrentPrices is an RPC method that returns a list of current prices.
+  rpc CurrentPrices(QueryCurrentPricesRequest) returns (QueryCurrentPricesResponse) {
+    option (google.api.http).get = "/feeds/v1beta1/current-prices";
+  }
+
   // DelegatorSignals is an RPC method that returns signals of a delegator.
   rpc DelegatorSignals(QueryDelegatorSignalsRequest) returns (QueryDelegatorSignalsResponse) {
     option (google.api.http).get = "/feeds/v1beta1/delegators/{delegator_address}/signals";
@@ -73,6 +78,15 @@ message QueryCurrentFeedsResponse {
   CurrentFeedWithDeviations current_feeds = 1 [(gogoproto.nullable) = false];
 }
 
+// QueryCurrentPricesRequest is the request type for the Query/CurrentPrices RPC method.
+message QueryCurrentPricesRequest {}
+
+// QueryCurrentPricesResponse is the response type for the Query/CurrentPrices RPC method.
+message QueryCurrentPricesResponse {
+  // prices is a list of current prices.
+  repeated Price prices = 1 [(gogoproto.nullable) = false];
+}
+
 // QueryDelegatorSignalsRequest is the request type for the Query/DelegatorSignals RPC method.
 message QueryDelegatorSignalsRequest {
   // delegator_address is the delegator address to query signal for.

scripts/feeds/submit_signals.sh

@@ -4,5 +4,5 @@ bandd tx staking delegate bandvaloper1p40yh3zkmhcv0ecqp3mcazy83sa57rgjde6wec 100
 sleep 3
 
 # signal
-bandd tx feeds signal crypto_price.ethusd:30000000000 crypto_price.usdtusd:30000000000 --from validator --keyring-backend test --gas-prices 0.0025uband -y --chain-id bandchain
-bandd tx feeds signal crypto_price.ethusd:30000000000 crypto_price.usdtusd:29000000000 --from requester --keyring-backend test --gas-prices 0.0025uband -y --chain-id bandchain
+bandd tx feeds signal crypto_price.btcusd,30000000000 crypto_price.usdtusd,30000000000 --from validator --keyring-backend test --gas-prices 0.0025uband -y --chain-id bandchain
+bandd tx feeds signal crypto_price.btcusd,30000000000 crypto_price.usdtusd,29000000000 --from requester --keyring-backend test --gas-prices 0.0025uband -y --chain-id bandchain

x/feeds/client/cli/query.go

@@ -31,6 +31,7 @@ func GetQueryCmd() *cobra.Command {
 		GetQueryCmdReferenceSourceConfig(),
 		GetQueryCmdDelegatorSignals(),
 		GetQueryCmdCurrentFeeds(),
+		GetQueryCmdCurrentPrices(),
 		GetQueryCmdIsFeeder(),
 	)
 
@@ -144,6 +145,30 @@ func GetQueryCmdCurrentFeeds() *cobra.Command {
 	return cmd
 }
 
+// GetQueryCmdCurrentPrices implements the query current prices command.
+func GetQueryCmdCurrentPrices() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "current-prices",
+		Short: "Shows all current prices of all supported feeds",
+		Args:  cobra.NoArgs,
+		RunE: func(cmd *cobra.Command, args []string) error {
+			clientCtx := client.GetClientContextFromCmd(cmd)
+			queryClient := types.NewQueryClient(clientCtx)
+
+			res, err := queryClient.CurrentPrices(context.Background(), &types.QueryCurrentPricesRequest{})
+			if err != nil {
+				return err
+			}
+
+			return clientCtx.PrintProto(res)
+		},
+	}
+
+	flags.AddQueryFlagsToCmd(cmd)
+
+	return cmd
+}
+
 // GetQueryCmdValidatorPrices implements the query validator prices command.
 func GetQueryCmdValidatorPrices() *cobra.Command {
 	cmd := &cobra.Command{

x/feeds/keeper/grpc_query.go

@@ -253,6 +253,16 @@ func (q queryServer) CurrentFeeds(
 	}, nil
 }
 
+// CurrentPrices queries all current prices.
+func (q queryServer) CurrentPrices(
+	goCtx context.Context, _ *types.QueryCurrentPricesRequest,
+) (*types.QueryCurrentPricesResponse, error) {
+	ctx := sdk.UnwrapSDKContext(goCtx)
+
+	currentPrices := q.keeper.GetCurrentPrices(ctx)
+	return &types.QueryCurrentPricesResponse{Prices: currentPrices}, nil
+}
+
 // ReferenceSourceConfig queries current reference source config.
 func (q queryServer) ReferenceSourceConfig(
 	goCtx context.Context, _ *types.QueryReferenceSourceConfigRequest,

x/feeds/keeper/keeper_price.go

@@ -26,7 +26,22 @@ func (k Keeper) GetPrices(ctx sdk.Context) (prices []types.Price) {
 		prices = append(prices, price)
 	}
 
-	return prices
+	return
+}
+
+// GetCurrentPrices returns a list of all current prices.
+func (k Keeper) GetCurrentPrices(ctx sdk.Context) (prices []types.Price) {
+	currentFeeds := k.GetCurrentFeeds(ctx)
+	for _, feed := range currentFeeds.Feeds {
+		price, err := k.GetPrice(ctx, feed.SignalID)
+		if err != nil {
+			continue
+		}
+
+		prices = append(prices, price)
+	}
+
+	return
 }
 
 // GetPrice returns a price by signal id.