feat: add force ica send governance message type

docs/swagger.yml

@@ -2337,6 +2337,77 @@ paths:
                 type: string
       tags:
         - Msg
+  /quicksilver/tx/v1/interchainstaking/force_send:
+    post:
+      summary: >-
+        SignalIntent defines a method for signalling voting intent for one or
+        more
+
+        validators.
+      operationId: GovForceSend
+      responses:
+        '200':
+          description: A successful response.
+          schema:
+            type: object
+            description: MsgForceICASendResponse defines the MsgForceICASend response type.
+        default:
+          description: An unexpected error response.
+          schema:
+            type: object
+            properties:
+              error:
+                type: string
+              code:
+                type: integer
+                format: int32
+              message:
+                type: string
+              details:
+                type: array
+                items:
+                  type: object
+                  properties:
+                    type_url:
+                      type: string
+                    value:
+                      type: string
+                      format: byte
+      parameters:
+        - name: body
+          in: body
+          required: true
+          schema:
+            type: object
+            properties:
+              source_address:
+                type: string
+              destination_address:
+                type: string
+              amount:
+                type: object
+                properties:
+                  denom:
+                    type: string
+                  amount:
+                    type: string
+                description: >-
+                  Coin defines a token with a denomination and an amount.
+
+
+                  NOTE: The amount field is an Int which implements the custom
+                  method
+
+                  signatures required by gogoproto.
+              from_address:
+                type: string
+            description: >-
+              MsgForceICASend represents a governance-only message that causes a
+              transfer
+
+              of tokens from one ICA to another address.
+      tags:
+        - Msg
   /quicksilver/tx/v1/interchainstaking/intent:
     post:
       summary: >-

proto/quicksilver/interchainstaking/v1/messages.proto

@@ -53,6 +53,15 @@ service Msg {
     };
   }
 
+  // SignalIntent defines a method for signalling voting intent for one or more
+  // validators.
+  rpc GovForceSend(MsgForceICASend) returns (MsgForceICASendResponse) {
+    option (google.api.http) = {
+      post: "/quicksilver/tx/v1/interchainstaking/force_send"
+      body: "*"
+    };
+  }
+
   // SignalIntent defines a method for signalling voting intent for one or more
   // validators.
   rpc GovCloseChannel(MsgGovCloseChannel) returns (MsgGovCloseChannelResponse) {
@@ -166,3 +175,21 @@ message MsgSignalIntent {
 
 // MsgSignalIntentResponse defines the MsgSignalIntent response type.
 message MsgSignalIntentResponse {}
+
+// MsgForceICASend represents a governance-only message that causes a transfer
+// of tokens from one ICA to another address.
+message MsgForceICASend {
+  option (gogoproto.equal) = false;
+  option (gogoproto.goproto_getters) = false;
+
+  string source_address = 1;
+  string destination_address = 2;
+  cosmos.base.v1beta1.Coin amount = 3 [
+    (gogoproto.nullable) = false,
+    (gogoproto.moretags) = "yaml:\"coin\""
+  ];
+  string from_address = 4 [(cosmos_proto.scalar) = "cosmos.AddressString"];
+}
+
+// MsgForceICASendResponse defines the MsgForceICASend response type.
+message MsgForceICASendResponse {}

x/interchainstaking/keeper/msg_server.go

@@ -11,6 +11,7 @@
 	"time"
 
 	sdk "github.com/cosmos/cosmos-sdk/types"
+	banktypes "github.com/cosmos/cosmos-sdk/x/bank/types"
 	govtypes "github.com/cosmos/cosmos-sdk/x/gov/types"
 
 	"github.com/quicksilver-zone/quicksilver/utils/addressutils"
@@ -496,3 +497,45 @@
 
 	return &types.MsgGovRemoveValidatorDenyListResponse{}, nil
 }
+
+func (k msgServer) GovForceSend(goCtx context.Context, msg *types.MsgForceICASend) (*types.MsgForceICASendResponse, error) {
+	ctx := sdk.UnwrapSDKContext(goCtx)
+
+	// checking msg authority is the gov module address
+	if k.Keeper.GetGovAuthority(ctx) != msg.FromAddress {
+		return nil,
+			govtypes.ErrInvalidSigner.Wrapf(
+				"invalid authority: expected %s, got %s",
+				k.Keeper.GetGovAuthority(ctx), msg.FromAddress,
+			)
+	}
+
+	zone, found := k.GetZoneForAccount(ctx, msg.FromAddress)
+	if !found {
+		return nil, fmt.Errorf("source address is not a valid ICA address %s", msg.FromAddress)
+	}
+
+	sourceAddress, err := addressutils.AccAddressFromBech32(msg.SourceAddress, zone.GetAccountPrefix())
+	if err != nil {
+		return nil, err
+	}
+
+	destinationAddress, err := addressutils.AccAddressFromBech32(msg.DestinationAddress, zone.GetAccountPrefix())
+	if err != nil {
+		return nil, err
+	}
+
+	sendMsg := banktypes.NewMsgSend(sourceAddress, destinationAddress, sdk.NewCoins(msg.Amount))
+
+	icaAccount, err := k.GetICAAccount(ctx, zone, msg.FromAddress)
+	if err != nil {
+		return nil, err
+	}
+
+	err = k.SubmitTx(ctx, []sdk.Msg{sendMsg}, icaAccount, "governance send", 1)
+	if err != nil {
+		return nil, err
+	}
+
+	return &types.MsgForceICASendResponse{}, nil
+}

x/interchainstaking/keeper/zones.go

@@ -1,7 +1,6 @@
 package keeper
 
 import (
-	"errors"
 	"fmt"
 	"math"
 
@@ -310,20 +309,7 @@
 	return nil
 }
 
-// SetAccountBalance triggers provable KV queries to prove an AllBalances query.
-func (k *Keeper) SetAccountBalance(ctx sdk.Context, zone types.Zone, address string, queryResult []byte) error {
-	queryRes := banktypes.QueryAllBalancesResponse{}
-	err := k.cdc.Unmarshal(queryResult, &queryRes)
-	if err != nil {
-		k.Logger(ctx).Error("unable to unmarshal balance", "zone", zone.ChainId, "err", err)
-		return err
-	}
-	_, addr, err := bech32.DecodeAndConvert(address)
-	if err != nil {
-		return err
-	}
-	data := banktypes.CreateAccountBalancesPrefix(addr)
-
+func (k *Keeper) GetICAAccount(ctx sdk.Context, zone *types.Zone, address string) (*types.ICAAccount, error) {
 	var icaAccount *types.ICAAccount
 
 	switch {
@@ -336,12 +322,27 @@
 	case zone.PerformanceAddress != nil && address == zone.PerformanceAddress.Address:
 		icaAccount = zone.PerformanceAddress
 	default:
-		return errors.New("unexpected address")
+		return nil, fmt.Errorf("unable to determine account for address %s", address)
 	}
 
-	if icaAccount == nil {
-		return fmt.Errorf("unable to determine account for address %s", address)
+	return icaAccount, nil
+}
+
+// SetAccountBalance triggers provable KV queries to prove an AllBalances query.
+func (k *Keeper) SetAccountBalance(ctx sdk.Context, zone types.Zone, address string, queryResult []byte) error {
+	queryRes := banktypes.QueryAllBalancesResponse{}
+	err := k.cdc.Unmarshal(queryResult, &queryRes)
+	if err != nil {
+		k.Logger(ctx).Error("unable to unmarshal balance", "zone", zone.ChainId, "err", err)
+		return err
 	}
+	_, addr, err := bech32.DecodeAndConvert(address)
+	if err != nil {
+		return err
+	}
+	data := banktypes.CreateAccountBalancesPrefix(addr)
+
+	icaAccount, err := k.GetICAAccount(ctx, &zone, address)
 
 	for _, coin := range icaAccount.Balance {
 		if queryRes.Balances.AmountOf(coin.Denom).Equal(sdk.ZeroInt()) {