Merge pull request #116 from InjectiveLabs/f/add_explorer_calls

Add more methods in ExplorerRPC

Author: achilleas-kal

README.md

@@ -80,6 +80,7 @@ Note that the [sync client](https://github.com/InjectiveLabs/sdk-python/blob/mas
 ### Changelogs
 **0.5.6.8**
 * Add skip & limit params to Exchange API methods
+* Add more methods in ExplorerRPC
 * Re-gen ini files
 
 **0.5.6.6**

examples/exchange_client/explorer_rpc/2_AccountTxs.py

@@ -0,0 +1,32 @@
+# Copyright 2021 Injective Labs
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+"""Injective Exchange API client for Python. Example only."""
+
+import asyncio
+import logging
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.constant import Network
+
+async def main() -> None:
+    network = Network.testnet()
+    client = AsyncClient(network, insecure=False)
+    address = "inj1cml96vmptgw99syqrrz8az79xer2pcgp0a885r"
+    type = "injective.exchange.v1beta1.MsgCreateDerivativeLimitOrder"
+    account = await client.get_account_txs(address=address, type=type)
+    print(account)
+
+if __name__ == '__main__':
+    logging.basicConfig(level=logging.INFO)
+    asyncio.get_event_loop().run_until_complete(main())

examples/exchange_client/explorer_rpc/3_Blocks.py

@@ -0,0 +1,31 @@
+# Copyright 2021 Injective Labs
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+"""Injective Exchange API client for Python. Example only."""
+
+import asyncio
+import logging
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.constant import Network
+
+async def main() -> None:
+    network = Network.testnet()
+    client = AsyncClient(network, insecure=False)
+    limit = 2
+    block = await client.get_blocks(limit=limit)
+    print(block)
+
+if __name__ == '__main__':
+    logging.basicConfig(level=logging.INFO)
+    asyncio.get_event_loop().run_until_complete(main())

examples/exchange_client/explorer_rpc/4_Block.py

@@ -0,0 +1,31 @@
+# Copyright 2021 Injective Labs
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+"""Injective Exchange API client for Python. Example only."""
+
+import asyncio
+import logging
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.constant import Network
+
+async def main() -> None:
+    network = Network.testnet()
+    client = AsyncClient(network, insecure=False)
+    block_height = "5825046"
+    block = await client.get_block(block_height=block_height)
+    print(block)
+
+if __name__ == '__main__':
+    logging.basicConfig(level=logging.INFO)
+    asyncio.get_event_loop().run_until_complete(main())

examples/exchange_client/explorer_rpc/5_TxsRequest.py

@@ -0,0 +1,30 @@
+# Copyright 2021 Injective Labs
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+"""Injective Exchange API client for Python. Example only."""
+
+import asyncio
+import logging
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.constant import Network
+
+async def main() -> None:
+    network = Network.testnet()
+    client = AsyncClient(network, insecure=False)
+    txs = await client.get_txs()
+    print(txs)
+
+if __name__ == '__main__':
+    logging.basicConfig(level=logging.INFO)
+    asyncio.get_event_loop().run_until_complete(main())

examples/exchange_client/explorer_rpc/6_StreamTxs.py

@@ -0,0 +1,32 @@
+# Copyright 2021 Injective Labs
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+"""Injective Exchange API client for Python. Example only."""
+
+import asyncio
+import logging
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.constant import Network
+
+async def main() -> None:
+    network = Network.testnet()
+    client = AsyncClient(network, insecure=False)
+    stream_txs = await client.stream_txs(
+    )
+    async for tx in stream_txs:
+        print(tx)
+
+if __name__ == '__main__':
+    logging.basicConfig(level=logging.INFO)
+    asyncio.get_event_loop().run_until_complete(main())

examples/exchange_client/explorer_rpc/7_StreamBlocks.py

@@ -0,0 +1,32 @@
+# Copyright 2021 Injective Labs
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+"""Injective Exchange API client for Python. Example only."""
+
+import asyncio
+import logging
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.constant import Network
+
+async def main() -> None:
+    network = Network.testnet()
+    client = AsyncClient(network, insecure=False)
+    stream_blocks = await client.stream_blocks(
+    )
+    async for block in stream_blocks:
+        print(block)
+
+if __name__ == '__main__':
+    logging.basicConfig(level=logging.INFO)
+    asyncio.get_event_loop().run_until_complete(main())

pyinjective/async_client.py

@@ -346,6 +346,47 @@ async def get_tx_by_hash(self, tx_hash: str):
         req = explorer_rpc_pb.GetTxByTxHashRequest(hash=tx_hash)
         return await self.stubExplorer.GetTxByTxHash(req)
 
+    async def get_account_txs(self, address: str, **kwargs):
+        req = explorer_rpc_pb.GetAccountTxsRequest(
+            address=address,
+            before=kwargs.get("before"),
+            after=kwargs.get("after"),
+            limit=kwargs.get("limit"),
+            skip=kwargs.get("skip"),
+            type=kwargs.get("type"),
+            module=kwargs.get("module"))
+        return await self.stubExplorer.GetAccountTxs(req)
+
+    async def get_blocks(self, **kwargs):
+        req = explorer_rpc_pb.GetBlocksRequest(
+            before=kwargs.get("before"),
+            after=kwargs.get("after"),
+            limit=kwargs.get("limit")
+            )
+        return await self.stubExplorer.GetBlocks(req)
+
+    async def get_block(self, block_height: str):
+        req = explorer_rpc_pb.GetBlockRequest(id=block_height)
+        return await self.stubExplorer.GetBlock(req)
+
+    async def get_txs(self, **kwargs):
+        req = explorer_rpc_pb.GetTxsRequest(
+            before=kwargs.get("before"),
+            after=kwargs.get("after"),
+            limit=kwargs.get("limit"),
+            skip=kwargs.get("skip"),
+            type=kwargs.get("type"),
+            module=kwargs.get("module"))
+        return await self.stubExplorer.GetTxs(req)
+
+    async def stream_txs(self):
+        req = explorer_rpc_pb.StreamTxsRequest()
+        return self.stubExplorer.StreamTxs(req)
+
+    async def stream_blocks(self):
+        req = explorer_rpc_pb.StreamBlocksRequest()
+        return self.stubExplorer.StreamBlocks(req)
+
     # AccountsRPC
 
     async def stream_subaccount_balance(self, subaccount_id: str):