fixup! Mock ledger services in integration tests

apps/src/lib/node/ledger/shell/testing/node.rs

@@ -547,6 +547,7 @@ impl<'a> Client for &'a MockNode {
         height: Option<BlockHeight>,
         prove: bool,
     ) -> std::result::Result<EncodedResponseQuery, Self::Error> {
+        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<abci_info::AbciInfo, RpcError> {
+        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<tendermint_rpc::endpoint::broadcast::tx_sync::Response, RpcError>
     {
+        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<tendermint_rpc::endpoint::block_search::Response, RpcError>
     {
+        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<namada::tendermint::block::Height> + 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(())
     }
 }