InjectiveLabs · aarmoa · Mar 5, 2024 · Feb 29, 2024 · Feb 29, 2024 · Feb 29, 2024
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -2,6 +2,16 @@
 
 All notable changes to this project will be documented in this file.
 
+## [1.4.0] - 2024-03-11
+### Added
+- Added support for all queries and messages in the chain 'distribution' module
+- Added support for all queries and messages in the chain 'exchange' module
+- Use of python-dotenv in all example scripts to load private keys from a .env file
+
+## [1.3.1] - 2024-02-29
+### Changed
+- Updated cookie assistant logic to support the Indexer exchange server not using cookies and the chain server using them
+
 ## [1.3.0] - 2024-02-12
 ### Changed
 - Removed `asyncio` from the dependencies

diff --git a/examples/chain_client/exchange/11_MsgCreateDerivativeMarketOrder.py b/examples/chain_client/exchange/11_MsgCreateDerivativeMarketOrder.py
@@ -43,10 +43,11 @@ async def main() -> None:
         subaccount_id=subaccount_id,
         fee_recipient=fee_recipient,
         price=Decimal(50000),
-        quantity=Decimal(0.01),
+        quantity=Decimal(0.1),
         margin=composer.calculate_margin(
-            quantity=Decimal(0.01), price=Decimal(50000), leverage=Decimal(3), is_reduce_only=False
+            quantity=Decimal(0.1), price=Decimal(50000), leverage=Decimal(1), is_reduce_only=False
         ),
+        order_type="BUY",
-        quantity=Decimal(0.1),
-        margin=composer.calculate_margin(
-            quantity=Decimal(0.01), price=Decimal(50000), leverage=Decimal(3), is_reduce_only=False
-            quantity=Decimal(0.1), price=Decimal(50000), leverage=Decimal(1), is_reduce_only=False
-        ),
-        order_type="BUY",
+        quantity=Decimal(0.1),
+        margin=composer.calculate_margin(
+            quantity=Decimal(0.1), price=Decimal(50000), leverage=Decimal(1), is_reduce_only=False
+        ),
+        order_type="BUY",
-        quantity=Decimal(0.1),
-        margin=composer.calculate_margin(
-            quantity=Decimal(0.01), price=Decimal(50000), leverage=Decimal(3), is_reduce_only=False
-            quantity=Decimal(0.1), price=Decimal(50000), leverage=Decimal(1), is_reduce_only=False
-        ),
-        order_type="BUY",
+        quantity=Decimal(0.1),
+        margin=composer.calculate_margin(
+            quantity=Decimal(0.1), price=Decimal(50000), leverage=Decimal(1), is_reduce_only=False
+        ),
+        order_type="BUY",
         cid=str(uuid.uuid4()),
     )
 

diff --git a/examples/chain_client/exchange/query/41_TradeRewardCampaign.py b/examples/chain_client/exchange/query/41_TradeRewardCampaign.py
@@ -0,0 +1,32 @@
+import asyncio
+import os
+
+import dotenv
+
+from pyinjective import PrivateKey
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    dotenv.load_dotenv()
+    configured_private_key = os.getenv("INJECTIVE_PRIVATE_KEY")
+
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    # load account
+    priv_key = PrivateKey.from_hex(configured_private_key)
+    pub_key = priv_key.to_public_key()
+    address = pub_key.to_address()
+    await client.fetch_account(address.to_acc_bech32())
+
+    campaign = await client.fetch_trade_reward_campaign()
+    print(campaign)
+
+
+if __name__ == "__main__":
-async def main() -> None:
-    dotenv.load_dotenv()
-    configured_private_key = os.getenv("INJECTIVE_PRIVATE_KEY")
-
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    # load account
-    priv_key = PrivateKey.from_hex(configured_private_key)
-    pub_key = priv_key.to_public_key()
-    address = pub_key.to_address()
-    await client.fetch_account(address.to_acc_bech32())
-
-    campaign = await client.fetch_trade_reward_campaign()
-    print(campaign)
-
-
-if __name__ == "__main__":
+async def main() -> None:
+    dotenv.load_dotenv()
+    configured_private_key = os.getenv("INJECTIVE_PRIVATE_KEY")
+ if configured_private_key is None:
+     raise ValueError("INJECTIVE_PRIVATE_KEY environment variable is not set.")
+
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    # load account
+    priv_key = PrivateKey.from_hex(configured_private_key)
+    pub_key = priv_key.to_public_key()
+    address = pub_key.to_address()
+    await client.fetch_account(address.to_acc_bech32())
+
+ try:
+     campaign = await client.fetch_trade_reward_campaign()
+     print(campaign)
+ except Exception as e:
+     print(f"Failed to fetch trade reward campaign: {e}")
+
+
+if __name__ == "__main__":
-async def main() -> None:
-    dotenv.load_dotenv()
-    configured_private_key = os.getenv("INJECTIVE_PRIVATE_KEY")
-
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    # load account
-    priv_key = PrivateKey.from_hex(configured_private_key)
-    pub_key = priv_key.to_public_key()
-    address = pub_key.to_address()
-    await client.fetch_account(address.to_acc_bech32())
-
-    campaign = await client.fetch_trade_reward_campaign()
-    print(campaign)
-
-
-if __name__ == "__main__":
+async def main() -> None:
+    dotenv.load_dotenv()
+    configured_private_key = os.getenv("INJECTIVE_PRIVATE_KEY")
+ if configured_private_key is None:
+     raise ValueError("INJECTIVE_PRIVATE_KEY environment variable is not set.")
+
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    # load account
+    priv_key = PrivateKey.from_hex(configured_private_key)
+    pub_key = priv_key.to_public_key()
+    address = pub_key.to_address()
+    await client.fetch_account(address.to_acc_bech32())
+
+ try:
+     campaign = await client.fetch_trade_reward_campaign()
+     print(campaign)
+ except Exception as e:
+     print(f"Failed to fetch trade reward campaign: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/42_FeeDiscountAccountInfo.py b/examples/chain_client/exchange/query/42_FeeDiscountAccountInfo.py
@@ -0,0 +1,34 @@
+import asyncio
+import os
+
+import dotenv
+
+from pyinjective import PrivateKey
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    dotenv.load_dotenv()
+    configured_private_key = os.getenv("INJECTIVE_PRIVATE_KEY")
+
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    # load account
+    priv_key = PrivateKey.from_hex(configured_private_key)
+    pub_key = priv_key.to_public_key()
+    address = pub_key.to_address()
+    await client.fetch_account(address.to_acc_bech32())
+
+    fee_discount = await client.fetch_fee_discount_account_info(
+        account=address.to_acc_bech32(),
+    )
+    print(fee_discount)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    dotenv.load_dotenv()
-    configured_private_key = os.getenv("INJECTIVE_PRIVATE_KEY")
-
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    # load account
-    priv_key = PrivateKey.from_hex(configured_private_key)
-    pub_key = priv_key.to_public_key()
-    address = pub_key.to_address()
-    await client.fetch_account(address.to_acc_bech32())
-
-    fee_discount = await client.fetch_fee_discount_account_info(
-        account=address.to_acc_bech32(),
-    )
-    print(fee_discount)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    dotenv.load_dotenv()
+    configured_private_key = os.getenv("INJECTIVE_PRIVATE_KEY")
+ if configured_private_key is None:
+     raise ValueError("INJECTIVE_PRIVATE_KEY environment variable is not set.")
+
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    # load account
+    priv_key = PrivateKey.from_hex(configured_private_key)
+    pub_key = priv_key.to_public_key()
+    address = pub_key.to_address()
+    await client.fetch_account(address.to_acc_bech32())
+
+ try:
+     fee_discount = await client.fetch_fee_discount_account_info(
+         account=address.to_acc_bech32(),
+     )
+     print(fee_discount)
+ except Exception as e:
+     print(f"Failed to fetch fee discount account info: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    dotenv.load_dotenv()
-    configured_private_key = os.getenv("INJECTIVE_PRIVATE_KEY")
-
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    # load account
-    priv_key = PrivateKey.from_hex(configured_private_key)
-    pub_key = priv_key.to_public_key()
-    address = pub_key.to_address()
-    await client.fetch_account(address.to_acc_bech32())
-
-    fee_discount = await client.fetch_fee_discount_account_info(
-        account=address.to_acc_bech32(),
-    )
-    print(fee_discount)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    dotenv.load_dotenv()
+    configured_private_key = os.getenv("INJECTIVE_PRIVATE_KEY")
+ if configured_private_key is None:
+     raise ValueError("INJECTIVE_PRIVATE_KEY environment variable is not set.")
+
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    # load account
+    priv_key = PrivateKey.from_hex(configured_private_key)
+    pub_key = priv_key.to_public_key()
+    address = pub_key.to_address()
+    await client.fetch_account(address.to_acc_bech32())
+
+ try:
+     fee_discount = await client.fetch_fee_discount_account_info(
+         account=address.to_acc_bech32(),
+     )
+     print(fee_discount)
+ except Exception as e:
+     print(f"Failed to fetch fee discount account info: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/43_FeeDiscountSchedule.py b/examples/chain_client/exchange/query/43_FeeDiscountSchedule.py
@@ -0,0 +1,19 @@
+import asyncio
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    schedule = await client.fetch_fee_discount_schedule()
+    print(schedule)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    schedule = await client.fetch_fee_discount_schedule()
-    print(schedule)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    try:
+        schedule = await client.fetch_fee_discount_schedule()
+        # Consider adding more detailed formatting or processing here
+        print(schedule)
+    except Exception as e:
+        print(f"Failed to fetch Fee Discount Schedule: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    schedule = await client.fetch_fee_discount_schedule()
-    print(schedule)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    try:
+        schedule = await client.fetch_fee_discount_schedule()
+        # Consider adding more detailed formatting or processing here
+        print(schedule)
+    except Exception as e:
+        print(f"Failed to fetch Fee Discount Schedule: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/44_BalanceMismatches.py b/examples/chain_client/exchange/query/44_BalanceMismatches.py
@@ -0,0 +1,19 @@
+import asyncio
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    mismatches = await client.fetch_balance_mismatches(dust_factor=1)
+    print(mismatches)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    mismatches = await client.fetch_balance_mismatches(dust_factor=1)
-    print(mismatches)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    try:
+        mismatches = await client.fetch_balance_mismatches(dust_factor=1)
+        # Suggest enhancing output formatting for data clarity
+        print(mismatches)
+    except Exception as e:
+        print(f"Failed to fetch Balance Mismatches: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    mismatches = await client.fetch_balance_mismatches(dust_factor=1)
-    print(mismatches)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    try:
+        mismatches = await client.fetch_balance_mismatches(dust_factor=1)
+        # Suggest enhancing output formatting for data clarity
+        print(mismatches)
+    except Exception as e:
+        print(f"Failed to fetch Balance Mismatches: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/45_BalanceWithBalanceHolds.py b/examples/chain_client/exchange/query/45_BalanceWithBalanceHolds.py
@@ -0,0 +1,19 @@
+import asyncio
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    balance = await client.fetch_balance_with_balance_holds()
+    print(balance)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    balance = await client.fetch_balance_with_balance_holds()
-    print(balance)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    try:
+        balance = await client.fetch_balance_with_balance_holds()
+        # Enhance output formatting for better clarity
+        print(balance)
+    except Exception as e:
+        print(f"Failed to fetch Balance with Balance Holds: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    balance = await client.fetch_balance_with_balance_holds()
-    print(balance)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    try:
+        balance = await client.fetch_balance_with_balance_holds()
+        # Enhance output formatting for better clarity
+        print(balance)
+    except Exception as e:
+        print(f"Failed to fetch Balance with Balance Holds: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/46_FeeDiscountTierStatistics.py b/examples/chain_client/exchange/query/46_FeeDiscountTierStatistics.py
@@ -0,0 +1,19 @@
+import asyncio
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    statistics = await client.fetch_fee_discount_tier_statistics()
+    print(statistics)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    statistics = await client.fetch_fee_discount_tier_statistics()
-    print(statistics)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    try:
+        statistics = await client.fetch_fee_discount_tier_statistics()
+        # Recommend improving output formatting for clarity
+        print(statistics)
+    except Exception as e:
+        print(f"Failed to fetch Fee Discount Tier Statistics: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    statistics = await client.fetch_fee_discount_tier_statistics()
-    print(statistics)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    try:
+        statistics = await client.fetch_fee_discount_tier_statistics()
+        # Recommend improving output formatting for clarity
+        print(statistics)
+    except Exception as e:
+        print(f"Failed to fetch Fee Discount Tier Statistics: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/47_MitoVaultInfos.py b/examples/chain_client/exchange/query/47_MitoVaultInfos.py
@@ -0,0 +1,19 @@
+import asyncio
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    infos = await client.fetch_mito_vault_infos()
+    print(infos)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    infos = await client.fetch_mito_vault_infos()
-    print(infos)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    try:
+        infos = await client.fetch_mito_vault_infos()
+        # Consider adding more detailed formatting or processing here
+        print(infos)
+    except Exception as e:
+        print(f"Failed to fetch Mito Vault Infos: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    infos = await client.fetch_mito_vault_infos()
-    print(infos)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    try:
+        infos = await client.fetch_mito_vault_infos()
+        # Consider adding more detailed formatting or processing here
+        print(infos)
+    except Exception as e:
+        print(f"Failed to fetch Mito Vault Infos: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/48_QueryMarketIDFromVault.py b/examples/chain_client/exchange/query/48_QueryMarketIDFromVault.py
@@ -0,0 +1,19 @@
+import asyncio
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    market_id = await client.fetch_market_id_from_vault(vault_address="inj1qg5ega6dykkxc307y25pecuufrjkxkag6xhp6y")
+    print(market_id)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    market_id = await client.fetch_market_id_from_vault(vault_address="inj1qg5ega6dykkxc307y25pecuufrjkxkag6xhp6y")
-    print(market_id)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    try:
+        market_id = await client.fetch_market_id_from_vault(vault_address="inj1qg5ega6dykkxc307y25pecuufrjkxkag6xhp6y")
+        # Suggest adding detailed output formatting
+        print(market_id)
+    except Exception as e:
+        print(f"Failed to fetch Market ID from Vault: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    market_id = await client.fetch_market_id_from_vault(vault_address="inj1qg5ega6dykkxc307y25pecuufrjkxkag6xhp6y")
-    print(market_id)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    try:
+        market_id = await client.fetch_market_id_from_vault(vault_address="inj1qg5ega6dykkxc307y25pecuufrjkxkag6xhp6y")
+        # Suggest adding detailed output formatting
+        print(market_id)
+    except Exception as e:
+        print(f"Failed to fetch Market ID from Vault: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/49_HistoricalTradeRecords.py b/examples/chain_client/exchange/query/49_HistoricalTradeRecords.py
@@ -0,0 +1,21 @@
+import asyncio
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    records = await client.fetch_historical_trade_records(
+        market_id="0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe"
+    )
+    print(records)
+
+
+if __name__ == "__main__":
-async def main() -> None:
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    records = await client.fetch_historical_trade_records(
-        market_id="0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe"
-    )
-    print(records)
-
-
-if __name__ == "__main__":
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    try:
+        records = await client.fetch_historical_trade_records(
+            market_id="0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe"
+        )
+        # Recommend enhancing output formatting for clarity
+        print(records)
+    except Exception as e:
+        print(f"Failed to fetch Historical Trade Records: {e}")
+
+
+if __name__ == "__main__":
-async def main() -> None:
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    records = await client.fetch_historical_trade_records(
-        market_id="0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe"
-    )
-    print(records)
-
-
-if __name__ == "__main__":
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    try:
+        records = await client.fetch_historical_trade_records(
+            market_id="0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe"
+        )
+        # Recommend enhancing output formatting for clarity
+        print(records)
+    except Exception as e:
+        print(f"Failed to fetch Historical Trade Records: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/50_IsOptedOutOfRewards.py b/examples/chain_client/exchange/query/50_IsOptedOutOfRewards.py
@@ -0,0 +1,34 @@
+import asyncio
+import os
+
+import dotenv
+
+from pyinjective import PrivateKey
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    dotenv.load_dotenv()
+    configured_private_key = os.getenv("INJECTIVE_PRIVATE_KEY")
+
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    # load account
+    priv_key = PrivateKey.from_hex(configured_private_key)
+    pub_key = priv_key.to_public_key()
+    address = pub_key.to_address()
+    await client.fetch_account(address.to_acc_bech32())
+
+    is_opted_out = await client.fetch_is_opted_out_of_rewards(
+        account=address.to_acc_bech32(),
+    )
+    print(is_opted_out)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    dotenv.load_dotenv()
-    configured_private_key = os.getenv("INJECTIVE_PRIVATE_KEY")
-
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    # load account
-    priv_key = PrivateKey.from_hex(configured_private_key)
-    pub_key = priv_key.to_public_key()
-    address = pub_key.to_address()
-    await client.fetch_account(address.to_acc_bech32())
-
-    is_opted_out = await client.fetch_is_opted_out_of_rewards(
-        account=address.to_acc_bech32(),
-    )
-    print(is_opted_out)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    dotenv.load_dotenv()
+    configured_private_key = os.getenv("INJECTIVE_PRIVATE_KEY")
+
+    if configured_private_key is None:
+        raise ValueError("INJECTIVE_PRIVATE_KEY environment variable is not set.")
+
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    # load account
+    priv_key = PrivateKey.from_hex(configured_private_key)
+    pub_key = priv_key.to_public_key()
+    address = pub_key.to_address()
+    await client.fetch_account(address.to_acc_bech32())
+
+    try:
+        is_opted_out = await client.fetch_is_opted_out_of_rewards(
+            account=address.to_acc_bech32(),
+        )
+        print(is_opted_out)
+    except Exception as e:
+        print(f"Failed to check if opted out of rewards: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    dotenv.load_dotenv()
-    configured_private_key = os.getenv("INJECTIVE_PRIVATE_KEY")
-
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    # load account
-    priv_key = PrivateKey.from_hex(configured_private_key)
-    pub_key = priv_key.to_public_key()
-    address = pub_key.to_address()
-    await client.fetch_account(address.to_acc_bech32())
-
-    is_opted_out = await client.fetch_is_opted_out_of_rewards(
-        account=address.to_acc_bech32(),
-    )
-    print(is_opted_out)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    dotenv.load_dotenv()
+    configured_private_key = os.getenv("INJECTIVE_PRIVATE_KEY")
+
+    if configured_private_key is None:
+        raise ValueError("INJECTIVE_PRIVATE_KEY environment variable is not set.")
+
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    # load account
+    priv_key = PrivateKey.from_hex(configured_private_key)
+    pub_key = priv_key.to_public_key()
+    address = pub_key.to_address()
+    await client.fetch_account(address.to_acc_bech32())
+
+    try:
+        is_opted_out = await client.fetch_is_opted_out_of_rewards(
+            account=address.to_acc_bech32(),
+        )
+        print(is_opted_out)
+    except Exception as e:
+        print(f"Failed to check if opted out of rewards: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/51_OptedOutOfRewardsAccounts.py b/examples/chain_client/exchange/query/51_OptedOutOfRewardsAccounts.py
@@ -0,0 +1,19 @@
+import asyncio
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    opted_out = await client.fetch_opted_out_of_rewards_accounts()
+    print(opted_out)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    opted_out = await client.fetch_opted_out_of_rewards_accounts()
-    print(opted_out)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    try:
+        opted_out = await client.fetch_opted_out_of_rewards_accounts()
+        # Suggest adding detailed output formatting
+        print(opted_out)
+    except Exception as e:
+        print(f"Failed to fetch Opted Out of Rewards Accounts: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    opted_out = await client.fetch_opted_out_of_rewards_accounts()
-    print(opted_out)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    try:
+        opted_out = await client.fetch_opted_out_of_rewards_accounts()
+        # Suggest adding detailed output formatting
+        print(opted_out)
+    except Exception as e:
+        print(f"Failed to fetch Opted Out of Rewards Accounts: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/52_MarketVolatility.py b/examples/chain_client/exchange/query/52_MarketVolatility.py
@@ -0,0 +1,30 @@
+import asyncio
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    market_id = "0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe"
+    trade_grouping_sec = 10
+    max_age = 0
+    include_raw_history = True
+    include_metadata = True
+    volatility = await client.fetch_market_volatility(
+        market_id=market_id,
+        trade_grouping_sec=trade_grouping_sec,
+        max_age=max_age,
+        include_raw_history=include_raw_history,
+        include_metadata=include_metadata,
+    )
+    print(volatility)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    market_id = "0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe"
-    trade_grouping_sec = 10
-    max_age = 0
-    include_raw_history = True
-    include_metadata = True
-    volatility = await client.fetch_market_volatility(
-        market_id=market_id,
-        trade_grouping_sec=trade_grouping_sec,
-        max_age=max_age,
-        include_raw_history=include_raw_history,
-        include_metadata=include_metadata,
-    )
-    print(volatility)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    market_id = "0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe"
+    trade_grouping_sec = 10
+    max_age = 0
+    include_raw_history = True
+    include_metadata = True
+    try:
+        volatility = await client.fetch_market_volatility(
+            market_id=market_id,
+            trade_grouping_sec=trade_grouping_sec,
+            max_age=max_age,
+            include_raw_history=include_raw_history,
+            include_metadata=include_metadata,
+        )
+        print(volatility)
+    except Exception as e:
+        print(f"Failed to fetch market volatility: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    market_id = "0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe"
-    trade_grouping_sec = 10
-    max_age = 0
-    include_raw_history = True
-    include_metadata = True
-    volatility = await client.fetch_market_volatility(
-        market_id=market_id,
-        trade_grouping_sec=trade_grouping_sec,
-        max_age=max_age,
-        include_raw_history=include_raw_history,
-        include_metadata=include_metadata,
-    )
-    print(volatility)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    market_id = "0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe"
+    trade_grouping_sec = 10
+    max_age = 0
+    include_raw_history = True
+    include_metadata = True
+    try:
+        volatility = await client.fetch_market_volatility(
+            market_id=market_id,
+            trade_grouping_sec=trade_grouping_sec,
+            max_age=max_age,
+            include_raw_history=include_raw_history,
+            include_metadata=include_metadata,
+        )
+        print(volatility)
+    except Exception as e:
+        print(f"Failed to fetch market volatility: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/53_BinaryOptionsMarkets.py b/examples/chain_client/exchange/query/53_BinaryOptionsMarkets.py
@@ -0,0 +1,19 @@
+import asyncio
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    markets = await client.fetch_chain_binary_options_markets(status="Active")
+    print(markets)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    markets = await client.fetch_chain_binary_options_markets(status="Active")
-    print(markets)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    try:
+        markets = await client.fetch_chain_binary_options_markets(status="Active")
+        # Recommend improving output formatting for better data clarity
+        print(markets)
+    except Exception as e:
+        print(f"Failed to fetch Binary Options Markets: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    markets = await client.fetch_chain_binary_options_markets(status="Active")
-    print(markets)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    try:
+        markets = await client.fetch_chain_binary_options_markets(status="Active")
+        # Recommend improving output formatting for better data clarity
+        print(markets)
+    except Exception as e:
+        print(f"Failed to fetch Binary Options Markets: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/54_TraderDerivativeConditionalOrders.py b/examples/chain_client/exchange/query/54_TraderDerivativeConditionalOrders.py
@@ -0,0 +1,37 @@
+import asyncio
+import os
+
+import dotenv
+
+from pyinjective import PrivateKey
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    dotenv.load_dotenv()
+    configured_private_key = os.getenv("INJECTIVE_PRIVATE_KEY")
+
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    # load account
+    priv_key = PrivateKey.from_hex(configured_private_key)
+    pub_key = priv_key.to_public_key()
+    address = pub_key.to_address()
+    await client.fetch_account(address.to_acc_bech32())
+
+    subaccount_id = address.get_subaccount_id(index=0)
+
+    orders = await client.fetch_trader_derivative_conditional_orders(
+        subaccount_id=subaccount_id,
+        market_id="0x17ef48032cb24375ba7c2e39f384e56433bcab20cbee9a7357e4cba2eb00abe6",
+    )
+    print(orders)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    dotenv.load_dotenv()
-    configured_private_key = os.getenv("INJECTIVE_PRIVATE_KEY")
-
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    # load account
-    priv_key = PrivateKey.from_hex(configured_private_key)
-    pub_key = priv_key.to_public_key()
-    address = pub_key.to_address()
-    await client.fetch_account(address.to_acc_bech32())
-
-    subaccount_id = address.get_subaccount_id(index=0)
-
-    orders = await client.fetch_trader_derivative_conditional_orders(
-        subaccount_id=subaccount_id,
-        market_id="0x17ef48032cb24375ba7c2e39f384e56433bcab20cbee9a7357e4cba2eb00abe6",
-    )
-    print(orders)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    dotenv.load_dotenv()
+    configured_private_key = os.getenv("INJECTIVE_PRIVATE_KEY")
+
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    # load account
+    priv_key = PrivateKey.from_hex(configured_private_key)
+    pub_key = priv_key.to_public_key()
+    address = pub_key.to_address()
+    await client.fetch_account(address.to_acc_bech32())
+
+    subaccount_id = address.get_subaccount_id(index=0)
+
+    try:
+        orders = await client.fetch_trader_derivative_conditional_orders(
+            subaccount_id=subaccount_id,
+            market_id="0x17ef48032cb24375ba7c2e39f384e56433bcab20cbee9a7357e4cba2eb00abe6",
+        )
+        print(orders)
+    except Exception as e:
+        print(f"Failed to fetch trader derivative conditional orders: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
-async def main() -> None:
-    dotenv.load_dotenv()
-    configured_private_key = os.getenv("INJECTIVE_PRIVATE_KEY")
-
-    # select network: local, testnet, mainnet
-    network = Network.testnet()
-
-    # initialize grpc client
-    client = AsyncClient(network)
-
-    # load account
-    priv_key = PrivateKey.from_hex(configured_private_key)
-    pub_key = priv_key.to_public_key()
-    address = pub_key.to_address()
-    await client.fetch_account(address.to_acc_bech32())
-
-    subaccount_id = address.get_subaccount_id(index=0)
-
-    orders = await client.fetch_trader_derivative_conditional_orders(
-        subaccount_id=subaccount_id,
-        market_id="0x17ef48032cb24375ba7c2e39f384e56433bcab20cbee9a7357e4cba2eb00abe6",
-    )
-    print(orders)
-
-
-if __name__ == "__main__":
-    asyncio.get_event_loop().run_until_complete(main())
+async def main() -> None:
+    dotenv.load_dotenv()
+    configured_private_key = os.getenv("INJECTIVE_PRIVATE_KEY")
+
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    # load account
+    priv_key = PrivateKey.from_hex(configured_private_key)
+    pub_key = priv_key.to_public_key()
+    address = pub_key.to_address()
+    await client.fetch_account(address.to_acc_bech32())
+
+    subaccount_id = address.get_subaccount_id(index=0)
+
+    try:
+        orders = await client.fetch_trader_derivative_conditional_orders(
+            subaccount_id=subaccount_id,
+            market_id="0x17ef48032cb24375ba7c2e39f384e56433bcab20cbee9a7357e4cba2eb00abe6",
+        )
+        print(orders)
+    except Exception as e:
+        print(f"Failed to fetch trader derivative conditional orders: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())