added function to get a single aggregated value

x/aggregator/keeper/keeper.go

@@ -279,6 +279,14 @@ func (k Keeper) SearchAggValueBatchKeys(ctx sdk.Context, previousKey string, lim
 	return batches
 }
 
+func (k Keeper) GetAggregatedValue(ctx sdk.Context, batch string, pair string) AggregatorValue {
+	store := k.GetAggValueStore(ctx)
+	bz := store.Get(MakeAggStoreKey(batch, pair))
+	var value AggregatorValue
+	k.cdc.MustUnmarshalBinaryBare(bz, &value)
+	return value
+}
+
 func (k Keeper) SearchValues(ctx sdk.Context, prefix string, page uint, limit uint, reverse bool) []AggregatorValue {
 	if page == 0 {
 		page = 1

x/aggregator/keeper/querier.go

@@ -20,6 +20,8 @@ func NewQuerier(k Keeper) sdk.Querier {
 			return querySearchValues(ctx, req, k)
 		case types.QuerySearchBatchKeys:
 			return querySearchBatchKeys(ctx, req, k)
+		case types.QueryGetAggregatedValue:
+			return queryGetAggregatedValue(ctx, req, k)
 		default:
 			return nil, sdkerrors.Wrap(sdkerrors.ErrUnknownRequest, "unknown aggregator query endpoint")
 		}
@@ -35,6 +37,13 @@ func querySearchValues(ctx sdk.Context, req abci.RequestQuery, k Keeper) ([]byte
 	return x, nil
 }
 
+func queryGetAggregatedValue(ctx sdk.Context, req abci.RequestQuery, k Keeper) ([]byte, error) {
+	var query types.QueryReqGetAggregatorValue
+	k.cdc.MustUnmarshalJSON(req.Data, &query)
+	results := k.GetAggregatedValue(ctx, query.Batch, query.Pair)
+	return k.cdc.MustMarshalJSON(results), nil
+}
+
 func querySearchBatchKeys(ctx sdk.Context, req abci.RequestQuery, k Keeper) ([]byte, error) {
 	var query types.QueryReqSearchBatches
 	k.cdc.MustUnmarshalJSON(req.Data, &query)

x/aggregator/types/querier.go

@@ -2,9 +2,10 @@ package types
 
 // Query endpoints supported by the aggregator querier
 const (
-	QueryParams = "queryParams"
-	QuerySearchValues = "searchValues"
-	QuerySearchBatchKeys = "searchBatchKeys"
+	QueryParams             = "queryParams"
+	QuerySearchValues       = "searchValues"
+	QuerySearchBatchKeys    = "searchBatchKeys"
+	QueryGetAggregatedValue = "getAggregatedValue"
 )
 
 type QueryReqSearchValues struct {
@@ -14,6 +15,11 @@ type QueryReqSearchValues struct {
 	Limit uint
 }
 
+type QueryReqGetAggregatorValue struct {
+	Batch string
+	Pair string
+}
+
 type QueryReqSearchBatches struct {
 	PreviousBatch string
 	Reverse bool