Cosmos gas price config

rust/Cargo.toml

@@ -55,6 +55,7 @@ async-trait = "0.1"
 auto_impl = "1.0"
 backtrace = "0.3"
 base64 = "0.21.2"
+bigdecimal = "0.4.2"
 bincode = "1.3"
 borsh = "0.9"
 bs58 = "0.5.0"

rust/agents/relayer/Cargo.toml

@@ -39,6 +39,7 @@ hyperlane-base = { path = "../../hyperlane-base" }
 hyperlane-ethereum = { path = "../../chains/hyperlane-ethereum" }
 
 [dev-dependencies]
+once_cell.workspace = true
 tokio-test.workspace = true
 hyperlane-test = { path = "../../hyperlane-test" }
 hyperlane-base = { path = "../../hyperlane-base", features = ["test-utils"] }

rust/agents/relayer/src/msg/gas_payment/mod.rs

@@ -4,7 +4,7 @@ use async_trait::async_trait;
 use eyre::Result;
 use hyperlane_base::db::HyperlaneRocksDB;
 use hyperlane_core::{
-    GasPaymentKey, HyperlaneMessage, InterchainGasExpenditure, InterchainGasPayment,
+    BigFloat, GasPaymentKey, HyperlaneMessage, InterchainGasExpenditure, InterchainGasPayment,
     TxCostEstimate, TxOutcome, U256,
 };
 use tracing::{debug, error, trace};
@@ -135,7 +135,7 @@ impl GasPaymentEnforcer {
         self.db.process_gas_expenditure(InterchainGasExpenditure {
             message_id: message.id(),
             gas_used: outcome.gas_used,
-            tokens_used: outcome.gas_used * outcome.gas_price,
+            tokens_used: (BigFloat::try_from(outcome.gas_used)? * outcome.gas_price).try_into()?,
         })?;
         Ok(())
     }

rust/agents/relayer/src/msg/gas_payment/policies/minimum.rs

@@ -59,7 +59,7 @@ async fn test_gas_payment_policy_minimum() {
                 &current_expenditure,
                 &TxCostEstimate {
                     gas_limit: U256::from(100000u32),
-                    gas_price: U256::from(100000u32),
+                    gas_price: U256::from(100000u32).try_into().unwrap(),
                     l2_gas_limit: None,
                 },
             )
@@ -83,7 +83,7 @@ async fn test_gas_payment_policy_minimum() {
                 &current_expenditure,
                 &TxCostEstimate {
                     gas_limit: U256::from(100000u32),
-                    gas_price: U256::from(100001u32),
+                    gas_price: U256::from(100001u32).try_into().unwrap(),
                     l2_gas_limit: None,
                 },
             )
@@ -101,7 +101,7 @@ async fn test_gas_payment_policy_minimum() {
                 &current_expenditure,
                 &TxCostEstimate {
                     gas_limit: U256::from(100000u32),
-                    gas_price: U256::from(100001u32),
+                    gas_price: U256::from(100001u32).try_into().unwrap(),
                     l2_gas_limit: Some(U256::from(22222u32)),
                 },
             )

rust/agents/relayer/src/msg/gas_payment/policies/none.rs

@@ -52,7 +52,7 @@ async fn test_gas_payment_policy_none() {
                 &current_expenditure,
                 &TxCostEstimate {
                     gas_limit: U256::from(100000u32),
-                    gas_price: U256::from(100001u32),
+                    gas_price: U256::from(100001u32).try_into().unwrap(),
                     l2_gas_limit: None,
                 },
             )
@@ -70,7 +70,7 @@ async fn test_gas_payment_policy_none() {
                 &current_expenditure,
                 &TxCostEstimate {
                     gas_limit: U256::from(100000u32),
-                    gas_price: U256::from(100001u32),
+                    gas_price: U256::from(100001u32).try_into().unwrap(),
                     l2_gas_limit: Some(U256::from(22222u32)),
                 },
             )

rust/agents/relayer/src/msg/gas_payment/policies/on_chain_fee_quoting.rs

@@ -64,6 +64,7 @@ impl GasPaymentPolicy for GasPaymentPolicyOnChainFeeQuoting {
 #[cfg(test)]
 mod test {
     use hyperlane_core::H256;
+    use once_cell::sync::Lazy;
 
     use super::*;
 
@@ -85,11 +86,11 @@ mod test {
     }
 
     const MIN: U256 = U256([1000, 0, 0, 0]);
-    const COST_ESTIMATE: TxCostEstimate = TxCostEstimate {
+    static COST_ESTIMATE: Lazy<TxCostEstimate> = Lazy::new(|| TxCostEstimate {
         gas_limit: U256([2000, 0, 0, 0]), // MIN * 2
-        gas_price: U256([100001, 0, 0, 0]),
+        gas_price: U256([100001, 0, 0, 0]).try_into().unwrap(),
         l2_gas_limit: None,
-    };
+    });
 
     #[test]
     fn ensure_little_endian() {
@@ -203,7 +204,7 @@ mod test {
 
         let tx_cost_estimate = TxCostEstimate {
             gas_limit: MIN * 100, // Large gas limit
-            gas_price: COST_ESTIMATE.gas_price,
+            gas_price: COST_ESTIMATE.gas_price.clone().try_into().unwrap(),
             l2_gas_limit: Some(MIN * 2),
         };
 
@@ -217,7 +218,7 @@ mod test {
                     &current_expenditure(0),
                     &TxCostEstimate {
                         l2_gas_limit: None,
-                        ..tx_cost_estimate
+                        ..tx_cost_estimate.clone()
                     }
                 )
                 .await

rust/agents/relayer/src/msg/pending_message.rs

@@ -238,7 +238,7 @@ impl PendingOperation for PendingMessage {
             "processing message"
         );
 
-        op_try!(critical: self.ctx.origin_gas_payment_enforcer.record_tx_outcome(&self.message, tx_outcome), "recording tx outcome");
+        op_try!(critical: self.ctx.origin_gas_payment_enforcer.record_tx_outcome(&self.message, tx_outcome.clone()), "recording tx outcome");
         if tx_outcome.executed {
             info!(
                 txid=?tx_outcome.transaction_id,

rust/chains/hyperlane-cosmos/src/error.rs

@@ -34,6 +34,9 @@ pub enum HyperlaneCosmosError {
     /// protobuf error
     #[error("{0}")]
     Protobuf(#[from] prost::DecodeError),
+    /// The string is not a valid number
+    #[error("Failed to parse number from string")]
+    NumStrParse,
 }
 
 impl From<HyperlaneCosmosError> for ChainCommunicationError {

rust/chains/hyperlane-cosmos/src/mailbox.rs

@@ -215,7 +215,7 @@ impl Mailbox for CosmosMailbox {
 
         let result = TxCostEstimate {
             gas_limit: gas_limit.into(),
-            gas_price: U256::from(2500),
+            gas_price: self.provider.grpc().gas_price(),
             l2_gas_limit: None,
         };
 

rust/chains/hyperlane-cosmos/src/providers/grpc.rs

@@ -22,19 +22,16 @@ use cosmrs::{
         traits::Message,
     },
     tx::{self, Fee, MessageExt, SignDoc, SignerInfo},
-    Amount, Coin,
+    Coin,
 };
-use hyperlane_core::{ChainCommunicationError, ChainResult, ContractLocator, U256};
+use hyperlane_core::{BigFloat, ChainCommunicationError, ChainResult, ContractLocator, U256};
 use serde::Serialize;
 use tonic::transport::{Channel, Endpoint};
 
-use crate::address::CosmosAddress;
 use crate::HyperlaneCosmosError;
+use crate::{address::CosmosAddress, CosmosAmount};
 use crate::{signers::Signer, ConnectionConf};
 
-/// The gas price to use for transactions.
-/// TODO: is there a nice way to get a suggested price dynamically?
-const DEFAULT_GAS_PRICE: f64 = 0.05;
 /// A multiplier applied to a simulated transaction's gas usage to
 /// calculate the estimated gas.
 const GAS_ESTIMATE_MULTIPLIER: f64 = 1.25;
@@ -91,12 +88,14 @@ pub struct WasmGrpcProvider {
     /// GRPC Channel that can be cheaply cloned.
     /// See https://docs.rs/tonic/latest/tonic/transport/struct.Channel.html#multiplexing-requests
     channel: Channel,
+    gas_price: CosmosAmount,
 }
 
 impl WasmGrpcProvider {
     /// Create new CosmWasm GRPC Provider.
     pub fn new(
         conf: ConnectionConf,
+        gas_price: CosmosAmount,
         locator: Option<ContractLocator>,
         signer: Option<Signer>,
     ) -> ChainResult<Self> {
@@ -112,6 +111,7 @@ impl WasmGrpcProvider {
             contract_address,
             signer,
             channel,
+            gas_price,
         })
     }
 
@@ -121,9 +121,12 @@ impl WasmGrpcProvider {
             .as_ref()
             .ok_or(ChainCommunicationError::SignerUnavailable)
     }
-}
 
-impl WasmGrpcProvider {
+    /// Get the gas price
+    pub fn gas_price(&self) -> BigFloat {
+        self.gas_price.amount.clone()
+    }
+
     /// Generates an unsigned SignDoc for a transaction.
     async fn generate_unsigned_sign_doc(
         &self,
@@ -147,7 +150,8 @@ impl WasmGrpcProvider {
 
         let auth_info = signer_info.auth_info(Fee::from_amount_and_gas(
             Coin::new(
-                Amount::from((gas_limit as f64 * DEFAULT_GAS_PRICE) as u64),
+                // The fee to pay is the gas limit * the gas price
+                (BigFloat::from(gas_limit) * self.gas_price()).try_into()?,
                 self.conf.get_canonical_asset().as_str(),
             )
             .map_err(Into::<HyperlaneCosmosError>::into)?,

rust/chains/hyperlane-cosmos/src/providers/mod.rs

@@ -5,7 +5,7 @@ use hyperlane_core::{
 };
 use tendermint_rpc::{client::CompatMode, HttpClient};
 
-use crate::{ConnectionConf, HyperlaneCosmosError, Signer};
+use crate::{ConnectionConf, CosmosAmount, HyperlaneCosmosError, Signer};
 
 use self::grpc::WasmGrpcProvider;
 
@@ -31,7 +31,8 @@ impl CosmosProvider {
         locator: Option<ContractLocator>,
         signer: Option<Signer>,
     ) -> ChainResult<Self> {
-        let grpc_client = WasmGrpcProvider::new(conf.clone(), locator, signer)?;
+        let gas_price = CosmosAmount::try_from(conf.get_minimum_gas_price().clone())?;
+        let grpc_client = WasmGrpcProvider::new(conf.clone(), gas_price.clone(), locator, signer)?;
         let rpc_client = HttpClient::builder(
             conf.get_rpc_url()
                 .parse()