fix: arch updates (#221)

* fee grant support * feegranter config to unsigned tx --------- Co-authored-by: Aniket Dixit <dixitaniket199@gmail.com>
ojo-network · Mar 29, 2024 · d0a1b49 · d0a1b49
1 parent 71fa322
commit d0a1b49
Show file tree

Hide file tree

Showing 4 changed files with 30 additions and 8 deletions.
diff --git a/cw-relayer/cmd/cw-relayer.go b/cw-relayer/cmd/cw-relayer.go
@@ -143,6 +143,7 @@ func cwRelayerCmdHandler(cmd *cobra.Command, args []string) error {
 		cfg.Account.AccPrefix,
 		cfg.GasAdjustment,
 		cfg.GasPrices,
+		cfg.FeeGrant.Granter,
 	)
 	if err != nil {
 		return err

diff --git a/cw-relayer/config/config.go b/cw-relayer/config/config.go
@@ -29,10 +29,11 @@ var (
 type (
 	// Config defines all necessary cw-relayer configuration parameters.
 	Config struct {
-		Account Account       `mapstructure:"account" validate:"required,gt=0,dive,required"`
-		Keyring Keyring       `mapstructure:"keyring" validate:"required,gt=0,dive,required"`
-		RPC     RPC           `mapstructure:"rpc" validate:"required,gt=0,dive,required"`
-		Restart RestartConfig `mapstructure:"restart" validate:"required"`
+		Account  Account        `mapstructure:"account" validate:"required,gt=0,dive,required"`
+		Keyring  Keyring        `mapstructure:"keyring" validate:"required,gt=0,dive,required"`
+		RPC      RPC            `mapstructure:"rpc" validate:"required,gt=0,dive,required"`
+		Restart  RestartConfig  `mapstructure:"restart" validate:"required"`
+		FeeGrant FeeGrantConfig `mapstructure:"fee_grant" validate:"dive"`
 
 		ProviderTimeout string `mapstructure:"provider_timeout"`
 		ContractAddress string `mapstructure:"contract_address"`
@@ -87,6 +88,10 @@ type (
 		SkipError bool   `mapstructure:"skip_error"`
 	}
 
+	FeeGrantConfig struct {
+		Granter string `mapstructure:"granter" validate:"omitempty,required"`
+	}
+
 	// RPC defines RPC configuration of both the wasmd chain and Tendermint nodes.
 	RPC struct {
 		TMRPCEndpoint string `mapstructure:"tmrpc_endpoint" validate:"required"`
@@ -160,5 +165,7 @@ func ParseConfig(configPath string) (Config, error) {
 		cfg.MaxRetries = defaultRetries
 	}
 
+	fmt.Println()
+
 	return cfg, cfg.Validate()
 }
diff --git a/cw-relayer/relayer/client/client.go b/cw-relayer/relayer/client/client.go
@@ -48,6 +48,7 @@ type (
 		GasAdjustment     float64
 		KeyringPassphrase string
 		ChainHeight       *ChainHeight
+		feeGranter        sdk.AccAddress
 	}
 
 	passReader struct {
@@ -80,6 +81,7 @@ func NewRelayerClient(
 	accPrefix string,
 	gasAdjustment float64,
 	GasPrices string,
+	granter string,
 ) (RelayerClient, error) {
 	config := sdk.GetConfig()
 	config.SetBech32PrefixForAccount(accPrefix, accPrefix+sdk.PrefixPublic)
@@ -111,6 +113,17 @@ func NewRelayerClient(
 		return RelayerClient{}, err
 	}
 
+	if len(granter) > 0 {
+		feeGranterAddr, err := sdk.AccAddressFromBech32(granter)
+		if err != nil {
+			return RelayerClient{}, err
+		}
+
+		relayerClient.feeGranter = feeGranterAddr
+	} else {
+		relayerClient.feeGranter = clientCtx.GetFeeGranterAddress()
+	}
+
 	blockHeight, err := rpc.GetChainHeight(clientCtx)
 	if err != nil {
 		return RelayerClient{}, err
@@ -189,7 +202,7 @@ func (oc RelayerClient) BroadcastTx(timeoutDuration time.Duration, nextBlockHeig
 		// set last check height to latest block height
 		lastCheckHeight = latestBlockHeight
 
-		resp, err := BroadcastTx(clientCtx, factory, msgs...)
+		resp, err := BroadcastTx(oc.feeGranter, clientCtx, factory, msgs...)
 		if resp != nil && resp.Code != 0 {
 			telemetry.IncrCounter(1, "failure", "tx", "code")
 			oc.logger.Error().Msg(resp.String())
@@ -348,7 +361,8 @@ func (oc RelayerClient) CreateTxFactory() (tx.Factory, error) {
 		WithGasPrices(oc.GasPrices).
 		WithKeybase(clientCtx.Keyring).
 		WithSignMode(signing.SignMode_SIGN_MODE_DIRECT).
-		WithSimulateAndExecute(true)
+		WithSimulateAndExecute(true).
+		WithFeeGranter(oc.feeGranter)
 
 	return txFactory, nil
 }

diff --git a/cw-relayer/relayer/client/tx.go b/cw-relayer/relayer/client/tx.go
@@ -13,7 +13,7 @@ import (
 // Note, BroadcastTx is copied from the SDK except it removes a few unnecessary
 // things like prompting for confirmation and printing the response. Instead,
 // we return the TxResponse.
-func BroadcastTx(clientCtx client.Context, txf tx.Factory, msgs ...sdk.Msg) (*sdk.TxResponse, error) {
+func BroadcastTx(feeGranter sdk.AccAddress, clientCtx client.Context, txf tx.Factory, msgs ...sdk.Msg) (*sdk.TxResponse, error) {
 	txf, err := prepareFactory(clientCtx, txf)
 	if err != nil {
 		return nil, err
@@ -31,7 +31,7 @@ func BroadcastTx(clientCtx client.Context, txf tx.Factory, msgs ...sdk.Msg) (*sd
 		return nil, err
 	}
 
-	unsignedTx.SetFeeGranter(clientCtx.GetFeeGranterAddress())
+	unsignedTx.SetFeeGranter(feeGranter)
 
 	if err = tx.Sign(txf, clientCtx.GetFromName(), unsignedTx, true); err != nil {
 		return nil, err