feat: Created v2 versions for AsyncClient and Composer to support the Exchange module V2 queries and types. Updated examples and tests.

Author: aarmoa

CHANGELOG.md

@@ -10,7 +10,7 @@ All notable changes to this project will be documented in this file.
 - Updated all chain exchange module examples to use the new Exchange V2 proto queries and types
 - Added examples for ERC20 queries and messages
 - Added examples for EVM queries
-- Created a new AsyncClient in the pyinjective.async_client_v2 module. This new AsyncClient provides support for the newe v2 exchange endpoints. AsyncClient in pyinjective.async_client module still provides access to the v1 exchange endpoints.
+- Created a new AsyncClient in the pyinjective.async_client_v2 module. This new AsyncClient provides support for the new v2 exchange endpoints. AsyncClient in pyinjective.async_client module still provides access to the v1 exchange endpoints.
 - Created a new Composer in the pyinjective.composer_v2 module. This new Composer provides support to create exchange v2 objects. Composer in pyinjective.composer module still provides access to the v1 exchange objects.
 - Created the IndexerClient class to have all indexer queries. AsyncClient v2 now does not include any logic related to the indexer endpoints. The original AsyncClient still does support indexer endpoints (for backwards compatibility) but it does that by using an instance of the IndexerClient
 

Makefile

@@ -31,7 +31,7 @@ clean-all:
 	$(call clean_repos)
 
 clone-injective-indexer:
-	git clone https://github.com/InjectiveLabs/injective-indexer.git -b v1.16.3 --depth 1 --single-branch
+	git clone https://github.com/InjectiveLabs/injective-indexer.git -b v1.16.20 --depth 1 --single-branch
 
 clone-all: clone-injective-indexer
 

README.md

@@ -70,6 +70,62 @@ Upgrade `pip` to the latest version, if you see these warnings:
 poetry run pytest -v
 ```
 
+---
+
+## Choose Exchange V1 or Exchange V2 queries
+
+The Injective Python SDK provides two different clients for interacting with the exchange:
+
+1. **Exchange V1 Client** (`async_client` module):
+   - Use this client if you need to interact with the original Injective Exchange API
+   - Import using: `from injective.async_client import AsyncClient`
+   - Suitable for applications that need to maintain compatibility with the original exchange interface
+   - Example:
+   ```python
+   from injective.async_client import AsyncClient
+   from injective.network import Network
+
+   async def main():
+       # Initialize client with mainnet
+       client = AsyncClient(network=Network.mainnet())
+       # Or use testnet
+       # client = AsyncClient(network=Network.testnet())
+       # Use V1 exchange queries here
+   ```
+
+2. **Exchange V2 Client** (`async_client_v2` module):
+   - Use this client for the latest exchange features and improvements
+   - Import using: `from injective.async_client_v2 import AsyncClient`
+   - Recommended for new applications and when you need access to the latest exchange features
+   - Example:
+   ```python
+   from injective.async_client_v2 import AsyncClient
+   from injective.network import Network
+
+   async def main():
+       # Initialize client with mainnet
+       client = AsyncClient(network=Network.mainnet())
+       # Or use testnet
+       # client = AsyncClient(network=Network.testnet())
+       # Use V2 exchange queries here
+   ```
+
+Both clients provide similar interfaces but with different underlying implementations. Choose V2 for new projects unless you have specific requirements for V1 compatibility.
+
+> **Market Format Differences**:
+> - V1 AsyncClient: Markets are initialized with values in chain format (raw blockchain values)
+> - V2 AsyncClient: Markets are initialized with values in human-readable format (converted to standard decimal numbers)
+>
+> **Exchange Endpoint Format Differences**:
+> - V1 Exchange endpoints: All values (amounts, prices, margins, notionals) are returned in chain format
+> - V2 Exchange endpoints:
+>   - Human-readable format for: amounts, prices, margins, and notionals
+>   - Chain format for: deposit-related information (to maintain consistency with the Bank module)
+>
+> **Important Note**: The ChainClient (V1) will not receive any new endpoints added to the Exchange module. If you need access to new exchange-related endpoints or features, you should migrate to the V2 client. The V2 client ensures you have access to all the latest exchange functionality and improvements.
+
+___
+
 ## License
 
 Copyright © 2021 - 2025 Injective Labs Inc. (https://injectivelabs.org/)

buf.gen.yaml

@@ -14,7 +14,7 @@ inputs:
   - git_repo: https://github.com/InjectiveLabs/ibc-go
     tag: v8.7.0-evm-comet1-inj
   - git_repo: https://github.com/InjectiveLabs/wasmd
-    tag: v0.53.2-evm-comet1-inj
+    tag: v0.53.3-evm-comet1-inj
   - git_repo: https://github.com/InjectiveLabs/cometbft
     tag: v1.0.1-inj.2
   - git_repo: https://github.com/InjectiveLabs/cosmos-sdk
@@ -23,7 +23,7 @@ inputs:
 #    branch: v0.51.x-inj
 #    subdir: proto
   - git_repo: https://github.com/InjectiveLabs/injective-core
-    tag: v1.16.0-beta.2
+    tag: v1.16.0-beta.3
     subdir: proto
 #  - git_repo: https://github.com/InjectiveLabs/injective-core
 #    branch: master

examples/chain_client/erc20/query/1_AllTokenPairs.py

@@ -6,6 +6,7 @@
 
 from pyinjective import PrivateKey
 from pyinjective.async_client_v2 import AsyncClient
+from pyinjective.client.model.pagination import PaginationOption
 from pyinjective.core.network import Network
 
 
@@ -25,7 +26,12 @@ async def main() -> None:
     address = pub_key.to_address()
     await client.fetch_account(address.to_acc_bech32())
 
-    pairs = await client.fetch_erc20_all_token_pairs()
+    pairs = await client.fetch_erc20_all_token_pairs(
+        pagination=PaginationOption(
+            skip=0,
+            limit=100,
+        ),
+    )
     print(json.dumps(pairs, indent=2))
 
 

pyinjective/async_client.py

@@ -986,12 +986,14 @@ async def fetch_contract_txs_v2(
         address: str,
         height: Optional[int] = None,
         token: Optional[str] = None,
+        status: Optional[str] = None,
         pagination: Optional[PaginationOption] = None,
     ) -> Dict[str, Any]:
         return await self.indexer_client.fetch_contract_txs_v2(
             address=address,
             height=height,
             token=token,
+            status=status,
             pagination=pagination,
         )
 
@@ -1124,12 +1126,16 @@ async def fetch_wasm_contracts(
         code_id: Optional[int] = None,
         assets_only: Optional[bool] = None,
         label: Optional[str] = None,
+        token: Optional[str] = None,
+        lookup: Optional[str] = None,
         pagination: Optional[PaginationOption] = None,
     ) -> Dict[str, Any]:
         return await self.indexer_client.fetch_wasm_contracts(
             code_id=code_id,
             assets_only=assets_only,
             label=label,
+            token=token,
+            lookup=lookup,
             pagination=pagination,
         )
 

pyinjective/async_client_v2.py

@@ -1187,8 +1187,8 @@ async def fetch_eip_base_fee(self) -> Dict[str, Any]:
 
     # -------------------------
     # region Chain ERC20 module
-    async def fetch_erc20_all_token_pairs(self) -> Dict[str, Any]:
-        return await self.chain_erc20_api.fetch_all_token_pairs()
+    async def fetch_erc20_all_token_pairs(self, pagination: Optional[PaginationOption] = None) -> Dict[str, Any]:
+        return await self.chain_erc20_api.fetch_all_token_pairs(pagination=pagination)
 
     async def fetch_erc20_token_pair_by_denom(self, bank_denom: str) -> Dict[str, Any]:
         return await self.chain_erc20_api.fetch_token_pair_by_denom(bank_denom=bank_denom)

pyinjective/client/chain/grpc/chain_grpc_erc20_api.py

@@ -1,7 +1,8 @@
-from typing import Any, Callable, Dict
+from typing import Any, Callable, Dict, Optional
 
 from grpc.aio import Channel
 
+from pyinjective.client.model.pagination import PaginationOption
 from pyinjective.core.network import CookieAssistant
 from pyinjective.proto.injective.erc20.v1beta1 import query_pb2 as erc20_query_pb, query_pb2_grpc as erc20_query_grpc
 from pyinjective.utils.grpc_api_request_assistant import GrpcApiRequestAssistant
@@ -18,8 +19,16 @@ async def fetch_erc20_params(self) -> Dict[str, Any]:
 
         return response
 
-    async def fetch_all_token_pairs(self) -> Dict[str, Any]:
-        request = erc20_query_pb.QueryAllTokenPairsRequest()
+    async def fetch_all_token_pairs(
+        self,
+        pagination: Optional[PaginationOption] = None,
+    ) -> Dict[str, Any]:
+        pagination_request = None
+        if pagination is not None:
+            pagination_request = pagination.create_pagination_request()
+        request = erc20_query_pb.QueryAllTokenPairsRequest(
+            pagination=pagination_request,
+        )
         response = await self._execute_call(call=self._stub.AllTokenPairs, request=request)
 
         return response

pyinjective/client/indexer/grpc/indexer_grpc_explorer_api.py

@@ -73,6 +73,7 @@ async def fetch_contract_txs_v2(
         address: str,
         height: Optional[int] = None,
         token: Optional[str] = None,
+        status: Optional[str] = None,
         pagination: Optional[PaginationOption] = None,
     ) -> Dict[str, Any]:
         pagination = pagination or PaginationOption()
@@ -85,7 +86,9 @@ async def fetch_contract_txs_v2(
         if pagination is not None:
             setattr(request, "from", pagination.start_time)
             request.to = pagination.end_time
-            request.limit = pagination.limit
+            request.per_page = pagination.limit
+        if status is not None:
+            request.status = status
 
         response = await self._execute_call(call=self._stub.GetContractTxsV2, request=request)
 
@@ -265,6 +268,8 @@ async def fetch_wasm_contracts(
         code_id: Optional[int] = None,
         assets_only: Optional[bool] = None,
         label: Optional[str] = None,
+        token: Optional[str] = None,
+        lookup: Optional[str] = None,
         pagination: Optional[PaginationOption] = None,
     ) -> Dict[str, Any]:
         pagination = pagination or PaginationOption()
@@ -276,6 +281,8 @@ async def fetch_wasm_contracts(
             assets_only=assets_only,
             skip=pagination.skip,
             label=label,
+            token=token,
+            lookup=lookup,
         )
 
         response = await self._execute_call(call=self._stub.GetWasmContracts, request=request)

pyinjective/indexer_client.py

@@ -989,12 +989,14 @@ async def fetch_contract_txs_v2(
         address: str,
         height: Optional[int] = None,
         token: Optional[str] = None,
+        status: Optional[str] = None,
         pagination: Optional[PaginationOption] = None,
     ) -> Dict[str, Any]:
         return await self.explorer_api.fetch_contract_txs_v2(
             address=address,
             height=height,
             token=token,
+            status=status,
             pagination=pagination,
         )
 
@@ -1103,12 +1105,16 @@ async def fetch_wasm_contracts(
         code_id: Optional[int] = None,
         assets_only: Optional[bool] = None,
         label: Optional[str] = None,
+        token: Optional[str] = None,
+        lookup: Optional[str] = None,
         pagination: Optional[PaginationOption] = None,
     ) -> Dict[str, Any]:
         return await self.explorer_api.fetch_wasm_contracts(
             code_id=code_id,
             assets_only=assets_only,
             label=label,
+            token=token,
+            lookup=lookup,
             pagination=pagination,
         )