add gas price config and set feeAmount when broadcast Tx

Author: vuong177

price-feeder/cmd/price-feeder.go

@@ -141,6 +141,7 @@ func priceFeederCmdHandler(cmd *cobra.Command, args []string) error {
 		cfg.Account.Validator,
 		cfg.RPC.GRPCEndpoint,
 		cfg.GasAdjustment,
+		cfg.GasPrice,
 	)
 	if err != nil {
 		return err

price-feeder/config.toml

@@ -1,6 +1,6 @@
 gas_adjustment = 1.5
 provider_min_override = true
-
+gas_price = "0.0001stake"
 [server]
 listen_addr = "0.0.0.0:7171"
 read_timeout = "20s"
@@ -80,9 +80,9 @@ providers = [
 quote = "USDT"
 
 [account]
-address = "juno15x87cdlt9ed0xhgtsdutdec3njg42q3a9vw7fn"
+address = "juno1dykyy8sqfw78frjt9th6k2s0c64q3nqwdy7eh7"
 chain_id = "test-1"
-validator = "junovaloper15x87cdlt9ed0xhgtsdutdec3njg42q3a63c3j2"
+validator = "junovaloper1dykyy8sqfw78frjt9th6k2s0c64q3nqwjegkv8"
 prefix = "juno"
 
 [keyring]

price-feeder/config/config.go

@@ -77,6 +77,7 @@ type (
 		ProviderTimeout     string              `mapstructure:"provider_timeout"`
 		ProviderMinOverride bool                `mapstructure:"provider_min_override"`
 		ProviderEndpoints   []provider.Endpoint `mapstructure:"provider_endpoints" validate:"dive"`
+		GasPrice            string              `mapstructure:"gas_price"`
 	}
 
 	// Server defines the API server configuration.

price-feeder/oracle/client/client.go

@@ -66,6 +66,7 @@ func NewOracleClient(
 	validatorAddrString string,
 	grpcEndpoint string,
 	gasAdjustment float64,
+	gasPrice string,
 ) (OracleClient, error) {
 
 	oracleAddr, err := sdk.AccAddressFromBech32(oracleAddrString)
@@ -87,6 +88,7 @@ func NewOracleClient(
 		Encoding:            junoapp.MakeEncodingConfig(),
 		GasAdjustment:       gasAdjustment,
 		GRPCEndpoint:        grpcEndpoint,
+		GasPrices:           gasPrice,
 	}
 
 	clientCtx, err := oracleClient.CreateClientContext()
@@ -163,7 +165,7 @@ func (oc OracleClient) BroadcastTx(nextBlockHeight, timeoutHeight int64, msgs ..
 		// set last check height to latest block height
 		lastCheckHeight = latestBlockHeight
 
-		resp, err := BroadcastTx(clientCtx, factory, msgs...)
+		resp, err := BroadcastTx(clientCtx, factory, oc.GasPrices, msgs...)
 		if resp != nil && resp.Code != 0 {
 			telemetry.IncrCounter(1, "failure", "tx", "code")
 			err = fmt.Errorf("invalid response code from tx: %d", resp.Code)

price-feeder/oracle/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(clientCtx client.Context, txf tx.Factory, gasPrice string, msgs ...sdk.Msg) (*sdk.TxResponse, error) {
 	txf, err := prepareFactory(clientCtx, txf)
 	if err != nil {
 		return nil, err
@@ -31,6 +31,9 @@ func BroadcastTx(clientCtx client.Context, txf tx.Factory, msgs ...sdk.Msg) (*sd
 		return nil, err
 	}
 
+	feeAmount, err := calculateFeeAmount(gasPrice, adjusted)
+	unsignedTx.SetFeeAmount(feeAmount)
+
 	unsignedTx.SetFeeGranter(clientCtx.GetFeeGranterAddress())
 	// unsignedTx.SetFeePayer(clientCtx.GetFeePayerAddress())
 
@@ -75,3 +78,19 @@ func prepareFactory(clientCtx client.Context, txf tx.Factory) (tx.Factory, error
 
 	return txf, nil
 }
+
+func calculateFeeAmount(gasPrice string, gas uint64) (sdk.Coins, error) {
+	var feeAmount sdk.Coins
+	coins, err := sdk.ParseDecCoins(gasPrice)
+	if err != nil {
+		return nil, err
+	}
+
+	for _, coin := range coins {
+		intGas := sdk.NewIntFromUint64(gas)
+		amount := coin.Amount.Mul(sdk.NewDecFromInt(intGas)).Ceil().TruncateInt()
+
+		feeAmount = append(feeAmount, sdk.NewCoin(coin.Denom, amount))
+	}
+	return feeAmount, nil
+}