test: end point to get intents across all zones for a delegator address #466

proto/quicksilver/interchainquery/v1/query.proto

@@ -16,7 +16,8 @@ option go_package = "github.com/ingenuity-build/quicksilver/x/interchainquery/ty
 service QuerySrvr {
   // Params returns the total set of minting parameters.
   rpc Queries(QueryRequestsRequest) returns (QueryRequestsResponse) {
-    option (google.api.http).get = "/quicksilver/interchainquery/v1/queries/{chain_id}";
+    option (google.api.http).get =
+        "/quicksilver/interchainquery/v1/queries/{chain_id}";
   }
 }
 
@@ -29,7 +30,8 @@ message QueryRequestsRequest {
 // QueryParamsResponse is the response type for the Query/Params RPC method.
 message QueryRequestsResponse {
   // params defines the parameters of the module.
-  repeated quicksilver.interchainquery.v1.Query queries = 1 [(gogoproto.nullable) = false];
+  repeated quicksilver.interchainquery.v1.Query queries = 1
+      [ (gogoproto.nullable) = false ];
   cosmos.base.query.v1beta1.PageResponse pagination = 2;
 }
 

proto/quicksilver/interchainstaking/v1/query.proto

@@ -29,12 +29,20 @@ service Query {
   rpc DepositAccount(QueryDepositAccountForChainRequest) returns (QueryDepositAccountForChainResponse) {
     option (google.api.http).get = "/quicksilver/interchainstaking/v1/zones/{chain_id}/deposit_address";
   }
+
   // DelegatorIntent provides data on the intent of the delegator for the given
   // zone.
   rpc DelegatorIntent(QueryDelegatorIntentRequest) returns (QueryDelegatorIntentResponse) {
     option (google.api.http).get =
-      "/quicksilver/interchainstaking/v1/zones/{chain_id}/delegator_intent/"
-      "{delegator_address}";
+    "/quicksilver/interchainstaking/v1/zones/{chain_id}/delegator_intent/"
+        "{delegator_address}";
+  }
+
+  // DelegatorIntents provides data on the intent of the delegator for all zones
+  rpc DelegatorIntents(QueryDelegatorIntentsRequest) returns (QueryDelegatorIntentsResponse) {
+    option (google.api.http).get =
+    "/quicksilver/interchainstaking/v1/delegator_intents/"
+        "{delegator_address}";
   }
 
   // Delegations provides data on the delegations for the given zone.
@@ -50,15 +58,20 @@ service Query {
   // WithdrawalRecords provides data on the active withdrawals.
   rpc ZoneWithdrawalRecords(QueryWithdrawalRecordsRequest) returns (QueryWithdrawalRecordsResponse) {
     option (google.api.http).get =
-      "/quicksilver/interchainstaking/v1/zones/{chain_id}/withdrawal_records/"
-      "{delegator_address}";
+    "/quicksilver/interchainstaking/v1/zones/{chain_id}/withdrawal_records/"
+        "{delegator_address}";
   }
 
   // WithdrawalRecords provides data on the active withdrawals.
   rpc WithdrawalRecords(QueryWithdrawalRecordsRequest) returns (QueryWithdrawalRecordsResponse) {
     option (google.api.http).get = "/quicksilver/interchainstaking/v1/zones/{chain_id}/withdrawal_records";
   }
 
+  // WithdrawalRecords provides data on the active withdrawals.
+  rpc UserWithdrawalRecords(QueryUserWithdrawalRecordsRequest) returns (QueryWithdrawalRecordsResponse) {
+    option (google.api.http).get = "/quicksilver/interchainstaking/v1/users/{user_address}/withdrawal_records";
+  }
+
   // UnbondingRecords provides data on the active unbondings.
   rpc UnbondingRecords(QueryUnbondingRecordsRequest) returns (QueryUnbondingRecordsResponse) {
     option (google.api.http).get = "/quicksilver/interchainstaking/v1/zones/{chain_id}/unbonding_records";
@@ -67,8 +80,8 @@ service Query {
   // RedelegationRecords provides data on the active unbondings.
   rpc RedelegationRecords(QueryRedelegationRecordsRequest) returns (QueryRedelegationRecordsResponse) {
     option (google.api.http).get =
-      "/quicksilver/interchainstaking/v1/zones/"
-      "{chain_id}/redelegation_records";
+    "/quicksilver/interchainstaking/v1/zones/"
+        "{chain_id}/redelegation_records";
   }
 
   // MappedAccounts provides data on the mapped accounts for a given user over different host chains.
@@ -138,6 +151,19 @@ message QueryDelegatorIntentResponse {
   DelegatorIntent intent = 1;
 }
 
+message QueryDelegatorIntentsRequest {
+  string delegator_address = 1 [(cosmos_proto.scalar) = "cosmos.AddressString"];
+}
+
+message DelegatorIntentsResponse {
+  string chain_id = 1;
+  DelegatorIntent intent = 2;
+}
+
+message QueryDelegatorIntentsResponse {
+  repeated DelegatorIntentsResponse intents = 1;
+}
+
 message QueryDelegationsRequest {
   string chain_id = 1 [(gogoproto.moretags) = "yaml:\"chain_id\""];
   cosmos.base.query.v1beta1.PageRequest pagination = 2;
@@ -170,9 +196,14 @@ message QueryWithdrawalRecordsResponse {
   cosmos.base.query.v1beta1.PageResponse pagination = 2;
 }
 
+message QueryUserWithdrawalRecordsRequest {
+  string user_address = 1 [(gogoproto.moretags) = "cosmos.AddressString"];
+  cosmos.base.query.v1beta1.PageRequest pagination = 2;
+}
+
 message QueryUnbondingRecordsRequest {
   string chain_id = 1 [(gogoproto.moretags) = "yaml:\"chain_id\""];
-  cosmos.base.query.v1beta1.PageRequest pagination = 3;
+  cosmos.base.query.v1beta1.PageRequest pagination = 2;
 }
 
 message QueryUnbondingRecordsResponse {
@@ -198,4 +229,4 @@ message QueryMappedAccountsRequest {
 message QueryMappedAccountsResponse {
   map<string, bytes> RemoteAddressMap = 1 [(gogoproto.nullable) = false];
   cosmos.base.query.v1beta1.PageResponse pagination = 2;
-}
+}

proto/quicksilver/participationrewards/v1/participationrewards.proto

@@ -35,7 +35,8 @@ message Params {
 
   // distribution_proportions defines the proportions of the minted
   // participation rewards;
-  DistributionProportions distribution_proportions = 1 [(gogoproto.nullable) = false];
+  DistributionProportions distribution_proportions = 1
+      [ (gogoproto.nullable) = false ];
   bool claims_enabled = 2;
 }
 
@@ -48,7 +49,7 @@ message KeyedProtocolData {
 // determination of rewards.
 message ProtocolData {
   string type = 1;
-  bytes data = 2 [(gogoproto.casttype) = "encoding/json.RawMessage"];
+  bytes data = 2 [ (gogoproto.casttype) = "encoding/json.RawMessage" ];
 }
 
 enum ProtocolDataType {

x/interchainstaking/keeper/grpc_query.go

@@ -146,6 +146,26 @@ func (k *Keeper) DelegatorIntent(c context.Context, req *types.QueryDelegatorInt
 	return &types.QueryDelegatorIntentResponse{Intent: &intent}, nil
 }
 
+// DelegatorIntents returns information about the delegation intent of the caller for all zones.
+func (k *Keeper) DelegatorIntents(c context.Context, req *types.QueryDelegatorIntentsRequest) (*types.QueryDelegatorIntentsResponse, error) {
+	if req == nil {
+		return nil, status.Error(codes.InvalidArgument, "empty request")
+	}
+
+	ctx := sdk.UnwrapSDKContext(c)
+
+	intents := []*types.DelegatorIntentsResponse{}
+
+	k.IterateZones(ctx, func(_ int64, zone *types.Zone) bool {
+		intent, _ := k.GetDelegatorIntent(ctx, zone, req.DelegatorAddress, false)
+
+		intents = append(intents, &types.DelegatorIntentsResponse{ChainId: zone.ChainId, Intent: &intent})
+		return false
+	})
+
+	return &types.QueryDelegatorIntentsResponse{Intents: intents}, nil
+}
+
 func (k *Keeper) Delegations(c context.Context, req *types.QueryDelegationsRequest) (*types.QueryDelegationsResponse, error) {
 	if req == nil {
 		return nil, status.Error(codes.InvalidArgument, "empty request")
@@ -230,6 +250,23 @@ func (k *Keeper) WithdrawalRecords(c context.Context, req *types.QueryWithdrawal
 	return &types.QueryWithdrawalRecordsResponse{Withdrawals: withdrawalrecords}, nil
 }
 
+func (k *Keeper) UserWithdrawalRecords(c context.Context, req *types.QueryUserWithdrawalRecordsRequest) (*types.QueryWithdrawalRecordsResponse, error) {
+	// TODO: implement pagination
+	if req == nil {
+		return nil, status.Error(codes.InvalidArgument, "empty request")
+	}
+
+	if _, err := addressutils.AddressFromBech32(req.UserAddress, ""); err != nil {
+		return nil, err
+	}
+
+	ctx := sdk.UnwrapSDKContext(c)
+
+	withdrawalrecords := k.AllUserWithdrawalRecords(ctx, req.UserAddress)
+
+	return &types.QueryWithdrawalRecordsResponse{Withdrawals: withdrawalrecords}, nil
+}
+
 func (k *Keeper) UnbondingRecords(c context.Context, req *types.QueryUnbondingRecordsRequest) (*types.QueryUnbondingRecordsResponse, error) {
 	// TODO: implement pagination
 	if req == nil {