(feat) Added support for all chain exchange module queries. Included …

…new example scripts for all the queries and unit tests.
InjectiveLabs · Feb 27, 2024 · 4d6ce1b · 4d6ce1b
1 parent 0c61c63
commit 4d6ce1b
Show file tree

Hide file tree

Showing 87 changed files with 5,229 additions and 0 deletions.
diff --git a/...ent/distribution/10_SetWithdrawAddress.py → ...ient/distribution/1_SetWithdrawAddress.py b/...ent/distribution/10_SetWithdrawAddress.py → ...ient/distribution/1_SetWithdrawAddress.py
diff --git a/...istribution/11_WithdrawDelegatorReward.py → ...distribution/2_WithdrawDelegatorReward.py b/...istribution/11_WithdrawDelegatorReward.py → ...distribution/2_WithdrawDelegatorReward.py
diff --git a/...ibution/12_WithdrawValidatorCommission.py → ...ribution/3_WithdrawValidatorCommission.py b/...ibution/12_WithdrawValidatorCommission.py → ...ribution/3_WithdrawValidatorCommission.py
diff --git a/...ient/distribution/13_FundCommunityPool.py → ...lient/distribution/4_FundCommunityPool.py b/...ient/distribution/13_FundCommunityPool.py → ...lient/distribution/4_FundCommunityPool.py
diff --git a/...stribution/1_ValidatorDistributionInfo.py → ...tion/query/1_ValidatorDistributionInfo.py b/...stribution/1_ValidatorDistributionInfo.py → ...tion/query/1_ValidatorDistributionInfo.py
diff --git a/...ribution/2_ValidatorOutstandingRewards.py → ...on/query/2_ValidatorOutstandingRewards.py b/...ribution/2_ValidatorOutstandingRewards.py → ...on/query/2_ValidatorOutstandingRewards.py
diff --git a/...ent/distribution/3_ValidatorCommission.py → ...stribution/query/3_ValidatorCommission.py b/...ent/distribution/3_ValidatorCommission.py → ...stribution/query/3_ValidatorCommission.py
diff --git a/...client/distribution/4_ValidatorSlashes.py → .../distribution/query/4_ValidatorSlashes.py b/...client/distribution/4_ValidatorSlashes.py → .../distribution/query/4_ValidatorSlashes.py
diff --git a/...lient/distribution/5_DelegationRewards.py → ...distribution/query/5_DelegationRewards.py b/...lient/distribution/5_DelegationRewards.py → ...distribution/query/5_DelegationRewards.py
diff --git a/.../distribution/6_DelegationTotalRewards.py → ...ibution/query/6_DelegationTotalRewards.py b/.../distribution/6_DelegationTotalRewards.py → ...ibution/query/6_DelegationTotalRewards.py
diff --git a/...ent/distribution/7_DelegatorValidators.py → ...stribution/query/7_DelegatorValidators.py b/...ent/distribution/7_DelegatorValidators.py → ...stribution/query/7_DelegatorValidators.py
diff --git a/...istribution/8_DelegatorWithdrawAddress.py → ...ution/query/8_DelegatorWithdrawAddress.py b/...istribution/8_DelegatorWithdrawAddress.py → ...ution/query/8_DelegatorWithdrawAddress.py
diff --git a/...in_client/distribution/9_CommunityPool.py → ...ent/distribution/query/9_CommunityPool.py b/...in_client/distribution/9_CommunityPool.py → ...ent/distribution/query/9_CommunityPool.py
diff --git a/.../chain_client/16_MsgSubaccountTransfer.py → ...ient/exchange/10_MsgSubaccountTransfer.py b/.../chain_client/16_MsgSubaccountTransfer.py → ...ient/exchange/10_MsgSubaccountTransfer.py
diff --git a/...s/chain_client/17_MsgBatchUpdateOrders.py → ...lient/exchange/11_MsgBatchUpdateOrders.py b/...s/chain_client/17_MsgBatchUpdateOrders.py → ...lient/exchange/11_MsgBatchUpdateOrders.py
diff --git a/examples/chain_client/24_MsgRewardsOptOut.py → ...in_client/exchange/12_MsgRewardsOptOut.py b/examples/chain_client/24_MsgRewardsOptOut.py → ...in_client/exchange/12_MsgRewardsOptOut.py
diff --git a/examples/chain_client/30_ExternalTransfer.py → ...in_client/exchange/15_ExternalTransfer.py b/examples/chain_client/30_ExternalTransfer.py → ...in_client/exchange/15_ExternalTransfer.py
diff --git a/...nt/31_MsgCreateBinaryOptionsLimitOrder.py → ...ge/16_MsgCreateBinaryOptionsLimitOrder.py b/...nt/31_MsgCreateBinaryOptionsLimitOrder.py → ...ge/16_MsgCreateBinaryOptionsLimitOrder.py
diff --git a/...t/32_MsgCreateBinaryOptionsMarketOrder.py → ...e/17_MsgCreateBinaryOptionsMarketOrder.py b/...t/32_MsgCreateBinaryOptionsMarketOrder.py → ...e/17_MsgCreateBinaryOptionsMarketOrder.py
diff --git a/..._client/33_MsgCancelBinaryOptionsOrder.py → ...xchange/18_MsgCancelBinaryOptionsOrder.py b/..._client/33_MsgCancelBinaryOptionsOrder.py → ...xchange/18_MsgCancelBinaryOptionsOrder.py
diff --git a/...s/chain_client/77_MsgLiquidatePosition.py → ...lient/exchange/19_MsgLiquidatePosition.py b/...s/chain_client/77_MsgLiquidatePosition.py → ...lient/exchange/19_MsgLiquidatePosition.py
diff --git a/examples/chain_client/2_MsgDeposit.py → ...les/chain_client/exchange/1_MsgDeposit.py b/examples/chain_client/2_MsgDeposit.py → ...les/chain_client/exchange/1_MsgDeposit.py
diff --git a/...chain_client/3_MsgCreateSpotLimitOrder.py → ...ent/exchange/3_MsgCreateSpotLimitOrder.py b/...chain_client/3_MsgCreateSpotLimitOrder.py → ...ent/exchange/3_MsgCreateSpotLimitOrder.py
diff --git a/...hain_client/4_MsgCreateSpotMarketOrder.py → ...nt/exchange/4_MsgCreateSpotMarketOrder.py b/...hain_client/4_MsgCreateSpotMarketOrder.py → ...nt/exchange/4_MsgCreateSpotMarketOrder.py
diff --git a/...ples/chain_client/5_MsgCancelSpotOrder.py → ...n_client/exchange/5_MsgCancelSpotOrder.py b/...ples/chain_client/5_MsgCancelSpotOrder.py → ...n_client/exchange/5_MsgCancelSpotOrder.py
diff --git a/...client/6_MsgCreateDerivativeLimitOrder.py → ...change/6_MsgCreateDerivativeLimitOrder.py b/...client/6_MsgCreateDerivativeLimitOrder.py → ...change/6_MsgCreateDerivativeLimitOrder.py
diff --git a/...lient/7_MsgCreateDerivativeMarketOrder.py → ...hange/7_MsgCreateDerivativeMarketOrder.py b/...lient/7_MsgCreateDerivativeMarketOrder.py → ...hange/7_MsgCreateDerivativeMarketOrder.py
diff --git a/...hain_client/8_MsgCancelDerivativeOrder.py → ...nt/exchange/8_MsgCancelDerivativeOrder.py b/...hain_client/8_MsgCancelDerivativeOrder.py → ...nt/exchange/8_MsgCancelDerivativeOrder.py
diff --git a/examples/chain_client/15_MsgWithdraw.py → ...es/chain_client/exchange/9_MsgWithdraw.py b/examples/chain_client/15_MsgWithdraw.py → ...es/chain_client/exchange/9_MsgWithdraw.py
diff --git a/examples/chain_client/exchange/query/10_SpotMarkets.py b/examples/chain_client/exchange/query/10_SpotMarkets.py
@@ -0,0 +1,22 @@
+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)
+
+    spot_markets = await client.fetch_chain_spot_markets(
+        status="Active",
+        market_ids=["0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe"],
+    )
+    print(spot_markets)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/11_SpotMarket.py b/examples/chain_client/exchange/query/11_SpotMarket.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)
+
+    spot_market = await client.fetch_chain_spot_market(
+        market_id="0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe",
+    )
+    print(spot_market)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/12_FullSpotMarkets.py b/examples/chain_client/exchange/query/12_FullSpotMarkets.py
@@ -0,0 +1,23 @@
+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)
+
+    spot_markets = await client.fetch_chain_full_spot_markets(
+        status="Active",
+        market_ids=["0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe"],
+        with_mid_price_and_tob=True,
+    )
+    print(spot_markets)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/13_FullSpotMarket.py b/examples/chain_client/exchange/query/13_FullSpotMarket.py
@@ -0,0 +1,22 @@
+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)
+
+    spot_market = await client.fetch_chain_full_spot_market(
+        market_id="0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe",
+        with_mid_price_and_tob=True,
+    )
+    print(spot_market)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/14_SpotOrderbook.py b/examples/chain_client/exchange/query/14_SpotOrderbook.py
@@ -0,0 +1,26 @@
+import asyncio
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.client.model.pagination import PaginationOption
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    pagination = PaginationOption(limit=2)
+
+    orderbook = await client.fetch_chain_spot_orderbook(
+        market_id="0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe",
+        order_side="Buy",
+        pagination=pagination,
+    )
+    print(orderbook)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/15_TraderSpotOrders.py b/examples/chain_client/exchange/query/15_TraderSpotOrders.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_chain_trader_spot_orders(
+        market_id="0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe",
+        subaccount_id=subaccount_id,
+    )
+    print(orders)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/16_AccountAddressSpotOrders.py b/examples/chain_client/exchange/query/16_AccountAddressSpotOrders.py
@@ -0,0 +1,35 @@
+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())
+
+    orders = await client.fetch_chain_account_address_spot_orders(
+        market_id="0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe",
+        account_address=address.to_acc_bech32(),
+    )
+    print(orders)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/17_SpotOrdersByHashes.py b/examples/chain_client/exchange/query/17_SpotOrdersByHashes.py
@@ -0,0 +1,38 @@
+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_chain_spot_orders_by_hashes(
+        market_id="0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe",
+        subaccount_id=subaccount_id,
+        order_hashes=["0x57a01cd26f1e2080860af3264e865d7c9c034a701e30946d01c1dc7a303cf2c1"],
+    )
+    print(orders)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/18_SubaccountOrders.py b/examples/chain_client/exchange/query/18_SubaccountOrders.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_chain_subaccount_orders(
+        subaccount_id=subaccount_id,
+        market_id="0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe",
+    )
+    print(orders)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/19_TraderSpotTransientOrders.py b/examples/chain_client/exchange/query/19_TraderSpotTransientOrders.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_chain_trader_spot_transient_orders(
+        market_id="0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe",
+        subaccount_id=subaccount_id,
+    )
+    print(orders)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/1_SubaccountDeposits.py b/examples/chain_client/exchange/query/1_SubaccountDeposits.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())
+
+    subaccount_id = address.get_subaccount_id(index=0)
+
+    deposits = await client.fetch_subaccount_deposits(subaccount_id=subaccount_id)
+    print(deposits)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/20_SpotMidPriceAndTOB.py b/examples/chain_client/exchange/query/20_SpotMidPriceAndTOB.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)
+
+    prices = await client.fetch_spot_mid_price_and_tob(
+        market_id="0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe",
+    )
+    print(prices)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())
diff --git a/examples/chain_client/exchange/query/21_DerivativeMidPriceAndTOB.py b/examples/chain_client/exchange/query/21_DerivativeMidPriceAndTOB.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)
+
+    prices = await client.fetch_derivative_mid_price_and_tob(
+        market_id="0x17ef48032cb24375ba7c2e39f384e56433bcab20cbee9a7357e4cba2eb00abe6",
+    )
+    print(prices)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())