diff --git a/apps/src/lib/node/ledger/shell/testing/node.rs b/apps/src/lib/node/ledger/shell/testing/node.rs index a158459643a..88cb7786997 100644 --- a/apps/src/lib/node/ledger/shell/testing/node.rs +++ b/apps/src/lib/node/ledger/shell/testing/node.rs @@ -547,6 +547,7 @@ impl<'a> Client for &'a MockNode { height: Option, prove: bool, ) -> std::result::Result { + self.drive_mock_services().await; let rpc = RPC; let data = data.unwrap_or_default(); let latest_height = { @@ -592,6 +593,7 @@ impl<'a> Client for &'a MockNode { /// `/abci_info`: get information about the ABCI application. async fn abci_info(&self) -> Result { + self.drive_mock_services().await; let locked = self.shell.lock().unwrap(); Ok(AbciInfo { data: "Namada".to_string(), @@ -623,6 +625,7 @@ impl<'a> Client for &'a MockNode { tx: namada::tendermint::abci::Transaction, ) -> Result { + self.drive_mock_services().await; let mut resp = tendermint_rpc::endpoint::broadcast::tx_sync::Response { code: Default::default(), data: Default::default(), @@ -662,6 +665,7 @@ impl<'a> Client for &'a MockNode { _order: namada::tendermint_rpc::Order, ) -> Result { + self.drive_mock_services().await; let matcher = parse_tm_query(query); let borrowed = self.shell.lock().unwrap(); // we store an index into the event log as a block @@ -731,6 +735,7 @@ impl<'a> Client for &'a MockNode { where H: Into + Send, { + self.drive_mock_services().await; let height = height.into(); let encoded_event = EncodedEvent(height.value()); let locked = self.shell.lock().unwrap(); @@ -789,6 +794,7 @@ impl<'a> Client for &'a MockNode { /// Returns empty result (200 OK) on success, no response in case of an /// error. async fn health(&self) -> Result<(), RpcError> { + self.drive_mock_services().await; Ok(()) } }