Problem: ibc related cmd is not supported

CHANGELOG.md

@@ -16,6 +16,8 @@
 - [#109](https://github.com/crypto-com/pystarport/pull/109) add feegrants in relayer config
 - [#110](https://github.com/crypto-com/pystarport/pull/110) add event_query_tx_for to allow subscribe and wait for transaction.
 - [#112](https://github.com/crypto-com/pystarport/pull/112) add cmd for migrate keystore.
+- [#](https://github.com/crypto-com/pystarport/pull/) support ibc related cmd.
+
 
 *Feb 7, 2023*
 

pystarport/cluster.py

@@ -662,6 +662,15 @@ def event_query_tx_for(self, hash, i=0):
     def migrate_keystore(self, i=0):
         return self.cosmos_cli(i).migrate_keystore()
 
+    def ibc_query_channels(self, connid, i=0):
+        return self.cosmos_cli(i).ibc_query_channels(connid)
+
+    def icaauth_register_account(self, connid, i=0):
+        return self.cosmos_cli(i).icaauth_register_account(connid)
+
+    def icaauth_submit_tx(self, connid, tx, timeout_duration="1h", i=0):
+        return self.cosmos_cli(i).icaauth_submit_tx(connid, tx, timeout_duration)
+
 
 def start_cluster(data_dir):
     cmd = [

pystarport/cosmoscli.py

@@ -1070,3 +1070,65 @@ def event_query_tx_for(self, hash):
 
     def migrate_keystore(self):
         return self.raw("keys", "migrate", home=self.data_dir)
+
+    def ibc_query_channels(self, connid, **kwargs):
+        default_kwargs = {
+            "node": self.node_rpc,
+            "output": "json",
+        }
+        return json.loads(
+            self.raw(
+                "q",
+                "ibc",
+                "channel",
+                "connections",
+                connid,
+                **(default_kwargs | kwargs),
+            )
+        )
+
+    def icaauth_register_account(self, connid, **kwargs):
+        "execute on host chain to attach an account to the connection"
+        default_kwargs = {
+            "home": self.data_dir,
+            "node": self.node_rpc,
+            "chain_id": self.chain_id,
+            "keyring_backend": "test",
+        }
+        rsp = json.loads(
+            self.raw(
+                "tx",
+                "icaauth",
+                "register-account",
+                connid,
+                "-y",
+                **(default_kwargs | kwargs),
+            )
+        )
+        if rsp["code"] == 0:
+            rsp = self.event_query_tx_for(rsp["txhash"])
+        return rsp
+
+    def icaauth_submit_tx(self, connid, tx, timeout_duration="1h", **kwargs):
+        default_kwargs = {
+            "home": self.data_dir,
+            "node": self.node_rpc,
+            "chain_id": self.chain_id,
+            "keyring_backend": "test",
+        }
+        rsp = json.loads(
+            self.raw(
+                "tx",
+                "icaauth",
+                "submit-tx",
+                connid,
+                tx,
+                "--timeout-duration" if timeout_duration else None,
+                timeout_duration if timeout_duration else None,
+                "-y",
+                **(default_kwargs | kwargs),
+            )
+        )
+        if rsp["code"] == 0:
+            rsp = self.event_query_tx_for(rsp["txhash"])
+        return rsp