release/v1_19_changes_to_master_for_v1_14_release

.pre-commit-config.yaml

@@ -6,22 +6,11 @@ repos:
     -   id: trailing-whitespace
     -   id: end-of-file-fixer
     -   id: check-yaml
--   repo: https://github.com/flakeheaven/flakeheaven
-    rev: 3.3.0
+-   repo: https://github.com/astral-sh/ruff-pre-commit
+    rev: v0.15.10
     hooks:
-    -   id: flakeheaven
-        name: flakeheaven
-        description: '`flakeheaven` is a `flake8` wrapper.'
-        entry: flakeheaven lint
-        language: python
-        types_or: [ python, jupyter, markdown, rst, yaml ]
-        require_serial: true
-        minimum_pre_commit_version: 2.9.0
--   repo: https://github.com/pycqa/isort
-    rev: 5.12.0
-    hooks:
-    -   id: isort
-        name: isort (python)
+    -   id: ruff
+        args: [--fix]
 -   repo: https://github.com/psf/black-pre-commit-mirror
     rev: 23.9.1
     hooks:

CHANGELOG.md

@@ -2,6 +2,10 @@
 
 All notable changes to this project will be documented in this file.
 
+## [1.14.0] - 2026-04-27
+### Changed
+- Updated all compiled protos for compatibility with Injective core v1.19.0 and Indexer v1.19.0
+
 ## [1.13.0] - 2026-02-13
 ### Changed
 - Updated all compiled protos for compatibility with Injective core v1.18.0 and Indexer v1.18.3

Makefile

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

README.md

@@ -72,45 +72,21 @@ 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 pyinjective.async_client import AsyncClient`
-   - Suitable for applications that need to maintain compatibility with the original exchange interface
-   - Example:
-   ```python
-   from pyinjective.async_client import AsyncClient
-   from pyinjective.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 pyinjective.async_client_v2 import AsyncClient`
-   - Recommended for new applications and when you need access to the latest exchange features
-   - Example:
-   ```python
-   from pyinjective.async_client_v2 import AsyncClient
-   from pyinjective.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.
+## Async client (exchange V2)
+
+The Injective Python SDK exposes `AsyncClient` from the `async_client_v2` module:
+
+- Import using: `from pyinjective.async_client_v2 import AsyncClient`
+- Example:
+```python
+from pyinjective.async_client_v2 import AsyncClient
+from pyinjective.network import Network
+
+async def main():
+    client = AsyncClient(network=Network.mainnet())
+    # Or use testnet
+    # client = AsyncClient(network=Network.testnet())
+```
 
 > **Market Format Differences**:
 > - V1 AsyncClient: Markets are initialized with values in chain format (raw blockchain values)

buf.gen.yaml

@@ -12,21 +12,21 @@ inputs:
   - module: buf.build/googleapis/googleapis
   - module: buf.build/cosmos/ics23
   - git_repo: https://github.com/InjectiveLabs/ibc-go
-    tag: v8.7.0-inj.3
+    tag: v8.7.0-inj.4
   - git_repo: https://github.com/InjectiveLabs/wasmd
-    tag: v0.53.3-inj.2
+    tag: v0.53.3-inj.3
   - git_repo: https://github.com/InjectiveLabs/cometbft
-    tag: v1.0.1-inj.6
+    tag: v1.0.1-inj.7
   - git_repo: https://github.com/InjectiveLabs/cosmos-sdk
-    tag: v0.50.14-inj.4
+    tag: v0.50.14-inj.9
 #  - git_repo: https://github.com/InjectiveLabs/wasmd
 #    branch: v0.51.x-inj
 #    subdir: proto
-  - git_repo: https://github.com/InjectiveLabs/hyperlane-cosmos
-    tag: v1.0.1-inj
-    subdir: proto
+  # - git_repo: https://github.com/InjectiveLabs/hyperlane-cosmos
+  #   tag: v1.0.1-inj
+  #   subdir: proto
   - git_repo: https://github.com/InjectiveLabs/injective-core
-    tag: v1.18.0
+    tag: v1.19.0
     subdir: proto
   # - git_repo: https://github.com/InjectiveLabs/injective-core
   #   branch: c-655/add_chainlink_data_streams_oracle

examples/chain_client/auction/2_MsgClaimVoucher.py

@@ -0,0 +1,54 @@
+import asyncio
+import json
+import os
+
+import dotenv
+
+from pyinjective.async_client_v2 import AsyncClient
+from pyinjective.core.broadcaster import MsgBroadcasterWithPk
+from pyinjective.core.network import Network
+from pyinjective.wallet import PrivateKey
+
+
+async def main() -> None:
+    dotenv.load_dotenv()
+    private_key_in_hexa = os.getenv("INJECTIVE_PRIVATE_KEY")
+
+    network = Network.devnet()
+
+    client = AsyncClient(network)
+    composer = await client.composer()
+
+    gas_price = await client.current_chain_gas_price()
+    gas_price = int(gas_price * 1.1)
+
+    message_broadcaster = MsgBroadcasterWithPk.new_using_simulation(
+        network=network,
+        private_key=private_key_in_hexa,
+        gas_price=gas_price,
+        client=client,
+        composer=composer,
+    )
+
+    priv_key = PrivateKey.from_hex(private_key_in_hexa)
+    pub_key = priv_key.to_public_key()
+    address = pub_key.to_address()
+
+    denom = "factory/inj1hkhdaj2a2clmq5jq6mspsggqs32vynpk228q3r/inj_test"
+
+    message = composer.msg_auction_claim_voucher(
+        sender=address.to_acc_bech32(),
+        denom=denom,
+    )
+
+    result = await message_broadcaster.broadcast([message])
+    print("---Transaction Response---")
+    print(json.dumps(result, indent=2))
+
+    gas_price = await client.current_chain_gas_price()
+    gas_price = int(gas_price * 1.1)
+    message_broadcaster.update_gas_price(gas_price=gas_price)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/chain_client/auction/query/1_Vouchers.py

@@ -0,0 +1,17 @@
+import asyncio
+
+from pyinjective.async_client_v2 import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    network = Network.testnet()
+    client = AsyncClient(network)
+
+    denom = "inj"
+    vouchers = await client.fetch_auction_vouchers(denom=denom)
+    print(vouchers)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/chain_client/auction/query/2_Voucher.py

@@ -0,0 +1,18 @@
+import asyncio
+
+from pyinjective.async_client_v2 import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    network = Network.testnet()
+    client = AsyncClient(network)
+
+    denom = "inj"
+    address = "inj1knhahceyp57j5x7xh69p7utegnnnfgxavmahjr"
+    voucher = await client.fetch_auction_voucher(denom=denom, address=address)
+    print(voucher)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/chain_client/distribution/1_SetWithdrawAddress.py

@@ -4,7 +4,8 @@
 
 import dotenv
 
-from pyinjective import AsyncClient, PrivateKey
+from pyinjective import PrivateKey
+from pyinjective.async_client_v2 import AsyncClient
 from pyinjective.core.broadcaster import MsgBroadcasterWithPk
 from pyinjective.core.network import Network
 

examples/chain_client/distribution/4_FundCommunityPool.py

@@ -5,7 +5,8 @@
 
 import dotenv
 
-from pyinjective import AsyncClient, PrivateKey
+from pyinjective import PrivateKey
+from pyinjective.async_client_v2 import AsyncClient
 from pyinjective.core.broadcaster import MsgBroadcasterWithPk
 from pyinjective.core.network import Network
 

examples/chain_client/insurance/4_MsgClaimVoucher.py

@@ -0,0 +1,54 @@
+import asyncio
+import json
+import os
+
+import dotenv
+
+from pyinjective.async_client_v2 import AsyncClient
+from pyinjective.core.broadcaster import MsgBroadcasterWithPk
+from pyinjective.core.network import Network
+from pyinjective.wallet import PrivateKey
+
+
+async def main() -> None:
+    dotenv.load_dotenv()
+    private_key_in_hexa = os.getenv("INJECTIVE_PRIVATE_KEY")
+
+    network = Network.devnet()
+
+    client = AsyncClient(network)
+    composer = await client.composer()
+
+    gas_price = await client.current_chain_gas_price()
+    gas_price = int(gas_price * 1.1)
+
+    message_broadcaster = MsgBroadcasterWithPk.new_using_simulation(
+        network=network,
+        private_key=private_key_in_hexa,
+        gas_price=gas_price,
+        client=client,
+        composer=composer,
+    )
+
+    priv_key = PrivateKey.from_hex(private_key_in_hexa)
+    pub_key = priv_key.to_public_key()
+    address = pub_key.to_address()
+
+    denom = "factory/inj1hkhdaj2a2clmq5jq6mspsggqs32vynpk228q3r/inj_test"
+
+    message = composer.msg_insurance_claim_voucher(
+        sender=address.to_acc_bech32(),
+        denom=denom,
+    )
+
+    result = await message_broadcaster.broadcast([message])
+    print("---Transaction Response---")
+    print(json.dumps(result, indent=2))
+
+    gas_price = await client.current_chain_gas_price()
+    gas_price = int(gas_price * 1.1)
+    message_broadcaster.update_gas_price(gas_price=gas_price)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/chain_client/insurance/query/1_Vouchers.py

@@ -0,0 +1,17 @@
+import asyncio
+
+from pyinjective.async_client_v2 import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    network = Network.testnet()
+    client = AsyncClient(network)
+
+    denom = "inj"
+    vouchers = await client.fetch_insurance_vouchers(denom=denom)
+    print(vouchers)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/chain_client/insurance/query/2_Voucher.py

@@ -0,0 +1,18 @@
+import asyncio
+
+from pyinjective.async_client_v2 import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    network = Network.testnet()
+    client = AsyncClient(network)
+
+    denom = "inj"
+    address = "inj1knhahceyp57j5x7xh69p7utegnnnfgxavmahjr"
+    voucher = await client.fetch_insurance_voucher(denom=denom, address=address)
+    print(voucher)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/exchange_client/oracle_rpc/1_StreamPrices.py

@@ -23,13 +23,14 @@ async def main() -> None:
     # select network: local, testnet, mainnet
     network = Network.testnet()
     client = IndexerClient(network)
-    market = (await client.all_derivative_markets())[
-        "0x17ef48032cb24375ba7c2e39f384e56433bcab20cbee9a7357e4cba2eb00abe6"
-    ]
+    market_response = await client.fetch_derivative_market(
+        market_id="0x17ef48032cb24375ba7c2e39f384e56433bcab20cbee9a7357e4cba2eb00abe6"
+    )
+    market = market_response["market"]
 
-    base_symbol = market.oracle_base
-    quote_symbol = market.oracle_quote
-    oracle_type = market.oracle_type.lower()
+    base_symbol = market["oracleBase"]
+    quote_symbol = market["oracleQuote"]
+    oracle_type = market["oracleType"].lower()
 
     task = asyncio.get_event_loop().create_task(
         client.listen_oracle_prices_updates(