Add func convert token to coin ibc

modules/apps/transfer/keeper/relay.go

@@ -7,7 +7,6 @@ import (
 	"github.com/hashicorp/go-metrics"
 
 	errorsmod "cosmossdk.io/errors"
-	sdkmath "cosmossdk.io/math"
 
 	"github.com/cosmos/cosmos-sdk/telemetry"
 	sdk "github.com/cosmos/cosmos-sdk/types"
@@ -182,10 +181,11 @@ func (k Keeper) OnRecvPacket(ctx sdk.Context, packet channeltypes.Packet, data t
 		}
 
 		// parse the transfer amount
-		transferAmount, ok := sdkmath.NewIntFromString(token.Amount)
-		if !ok {
-			return false, errorsmod.Wrapf(types.ErrInvalidAmount, "unable to parse transfer amount: %s", token.Amount)
+		coin, err := token.ToCoin()
+		if err != nil {
+			return false, err
 		}
+		transferAmount := coin.Amount
 
 		// This is the prefix that would have been prefixed to the denomination
 		// on sender chain IF and only if the token originally came from the
@@ -200,8 +200,6 @@ func (k Keeper) OnRecvPacket(ctx sdk.Context, packet channeltypes.Packet, data t
 			// remove prefix added by sender chain
 			token.Denom.Trace = token.Denom.Trace[1:]
 
-			coin := sdk.NewCoin(token.Denom.IBCDenom(), transferAmount)
-
 			if k.bankKeeper.BlockedAddr(receiver) {
 				return false, errorsmod.Wrapf(ibcerrors.ErrUnauthorized, "%s is not allowed to receive funds", receiver)
 			}
@@ -331,13 +329,11 @@ func (k Keeper) refundPacketTokens(ctx sdk.Context, packet channeltypes.Packet,
 	// NOTE: packet data type already checked in handler.go
 
 	for _, token := range data.Tokens {
-		transferAmount, ok := sdkmath.NewIntFromString(token.Amount)
-		if !ok {
-			return errorsmod.Wrapf(types.ErrInvalidAmount, "unable to parse transfer amount (%s) into math.Int", transferAmount)
+		coin, err := token.ToCoin()
+		if err != nil {
+			return err
 		}
 
-		coin := sdk.NewCoin(token.Denom.IBCDenom(), transferAmount)
-
 		sender, err := sdk.AccAddressFromBech32(data.Sender)
 		if err != nil {
 			return err

modules/apps/transfer/types/token.go

@@ -3,6 +3,7 @@ package types
 import (
 	errorsmod "cosmossdk.io/errors"
 	sdkmath "cosmossdk.io/math"
+	sdk "github.com/cosmos/cosmos-sdk/types"
 )
 
 // Tokens is a slice of Tokens
@@ -25,3 +26,19 @@ func (t Token) Validate() error {
 
 	return nil
 }
+
+// ToCoin converts a Token to an sdk.Coin.
+//
+// It takes a Token as a parameter and returns an sdk.Coin and an error. The function
+// parses the Amount field of the Token into an sdkmath.Int and creates a new
+// sdk.Coin with the IBCDenom of the Token's Denom field and the parsed Amount.
+// If the Amount cannot be parsed, an error is returned with a wrapped error message.
+func (t Token) ToCoin() (sdk.Coin, error) {
+	transferAmount, ok := sdkmath.NewIntFromString(t.Amount)
+	if !ok {
+		return sdk.Coin{}, errorsmod.Wrapf(ErrInvalidAmount, "unable to parse transfer amount (%s) into math.Int", transferAmount)
+	}
+
+	coin := sdk.NewCoin(t.Denom.IBCDenom(), transferAmount)
+	return coin, nil
+}

modules/apps/transfer/types/token_test.go

@@ -4,6 +4,8 @@ import (
 	"fmt"
 	"testing"
 
+	sdkmath "cosmossdk.io/math"
+	sdk "github.com/cosmos/cosmos-sdk/types"
 	"github.com/stretchr/testify/require"
 )
 
@@ -149,3 +151,50 @@ func TestValidate(t *testing.T) {
 		})
 	}
 }
+
+func TestToCoin(t *testing.T) {
+	testCases := []struct {
+		name     string
+		token    Token
+		coins    sdk.Coin
+		expError error
+	}{
+		{
+			"success: convert token to coin",
+			Token{
+				Denom: Denom{
+					Base:  denom,
+					Trace: []Trace{},
+				},
+				Amount: amount,
+			},
+			sdk.NewCoin(denom, sdkmath.NewInt(100)),
+			nil,
+		},
+		{
+			"failure: invalid amount string",
+			Token{
+				Denom: Denom{
+					Base:  denom,
+					Trace: []Trace{},
+				},
+				Amount: "value",
+			},
+			sdk.Coin{},
+			ErrInvalidAmount,
+		},
+	}
+
+	for _, tc := range testCases {
+		t.Run(tc.name, func(t *testing.T) {
+			coin, err := tc.token.ToCoin()
+			expPass := tc.expError == nil
+			if expPass {
+				require.NoError(t, err, tc.name)
+				require.Equal(t, tc.coins, coin, tc.name)
+			} else {
+				require.ErrorContains(t, err, tc.expError.Error(), tc.name)
+			}
+		})
+	}
+}