Problem: no suppport when query exposed by the external community pool

CHANGELOG.md

@@ -28,6 +28,7 @@
 - [#141](https://github.com/crypto-com/pystarport/pull/141) make cmd flag support multiple chains.
 - [#142](https://github.com/crypto-com/pystarport/pull/142) add coin type when create account.
 - [#145](https://github.com/crypto-com/pystarport/pull/145) Backward compatible with binary that don't have event-query-tx-for.
+- [#147](https://github.com/crypto-com/pystarport/pull/147) suppport query exposed by the external community pool.
 
 *Feb 7, 2023*
 

pystarport/cluster.py

@@ -369,8 +369,8 @@ def query_all_txs(self, addr, i=0):
     def distribution_commission(self, addr, i=0):
         return self.cosmos_cli(i).distribution_commission(addr)
 
-    def distribution_community(self, i=0):
-        return self.cosmos_cli(i).distribution_community()
+    def distribution_community(self, i=0, **kwargs):
+        return self.cosmos_cli(i).distribution_community(**kwargs)
 
     def distribution_reward(self, delegator_addr, i=0):
         return self.cosmos_cli(i).distribution_reward(delegator_addr)

pystarport/cosmoscli.py

@@ -295,17 +295,28 @@ def distribution_commission(self, addr):
             res = res["commission"]
         return parse_amount(res[0])
 
-    def distribution_community(self):
-        res = json.loads(
-            self.raw(
-                "query",
-                "distribution",
-                "community-pool",
-                output="json",
-                node=self.node_rpc,
-            )
-        )
-        return parse_amount(res["pool"][0])
+    def distribution_community(self, **kwargs):
+        for module in ["distribution", "protocolpool"]:
+            try:
+                res = json.loads(
+                    self.raw(
+                        "query",
+                        module,
+                        "community-pool",
+                        output="json",
+                        node=self.node_rpc,
+                        **kwargs,
+                    )
+                )
+                return parse_amount(res["pool"][0])
+            except Exception as e:
+                if (
+                    module == "distribution"
+                    and "CommunityPool query exposed by the external community pool"
+                    in str(e)
+                ):
+                    continue
+                raise
 
     def distribution_reward(self, delegator_addr):
         res = json.loads(