ibc: Add functions for killing and starting relayer.

timewave-computer · Aug 14, 2024 · b547c5c · b547c5c
1 parent 6272c78
commit b547c5c
Show file tree

Hide file tree

Showing 2 changed files with 27 additions and 1 deletion.
diff --git a/examples/neutron_osmosis.rs b/examples/neutron_osmosis.rs
@@ -18,6 +18,10 @@ fn main() -> Result<(), Box<dyn Error>> {
         .with_transfer_channels("osmosis", "neutron")
         .build()?;
 
+    // Kill and restart the relayer
+    ctx.stop_relayer();
+    ctx.start_relayer();
+
     ctx.build_tx_create_tokenfactory_token()
         .with_chain_name("neutron")
         .with_subdenom("bruhtoken")

diff --git a/src/utils/setup/ibc.rs b/src/utils/setup/ibc.rs
@@ -1,5 +1,7 @@
 use super::super::{
-    super::{error::Error, DEFAULT_KEY, DEFAULT_TRANSFER_PORT, NEUTRON_CHAIN_NAME},
+    super::{
+        error::Error, DEFAULT_KEY, DEFAULT_TRANSFER_PORT, NEUTRON_CHAIN_ID, NEUTRON_CHAIN_NAME,
+    },
     test_context::{LocalChain, TestContext},
 };
 
@@ -134,4 +136,24 @@ impl TestContext {
 
         Ok(())
     }
+
+    pub fn start_relayer(&mut self) {
+        let neutron = self.get_chain(NEUTRON_CHAIN_NAME);
+
+        reqwest::blocking::Client::default()
+            .post(&neutron.rb.api)
+            .json(&serde_json::json!({ "chain_id": NEUTRON_CHAIN_ID, "action": "start-relayer"}))
+            .send()
+            .unwrap();
+    }
+
+    pub fn stop_relayer(&mut self) {
+        let neutron = self.get_chain(NEUTRON_CHAIN_NAME);
+
+        reqwest::blocking::Client::default()
+            .post(&neutron.rb.api)
+            .json(&serde_json::json!({ "chain_id": NEUTRON_CHAIN_ID, "action": "stop-relayer"}))
+            .send()
+            .unwrap();
+    }
 }