Merge branch 'dev' of https://github.com/InjectiveLabs/sdk-python into feat/add_support_exchange_v2

Author: aarmoa

.github/workflows/pre-commit.yml

@@ -12,7 +12,8 @@ jobs:
         uses: actions/checkout@v4
       - name: Install Python
         uses: actions/setup-python@v5
-
+        with:
+          python-version: '>=3.9 <3.12'
       - name: Install poetry
         run: python -m pip install poetry
       - name: Cache the virtualenv

.github/workflows/run-tests.yml

@@ -9,7 +9,7 @@ jobs:
     strategy:
       matrix:
         python: ["3.9", "3.10", "3.11"]
-        os: [ubuntu-latest, macos-13, windows-latest]
+        os: [ubuntu-latest, macos-latest, windows-latest]
     runs-on: ${{ matrix.os }}
     env:
       OS: ${{ matrix.os }}
@@ -22,8 +22,13 @@ jobs:
         with:
           python-version: ${{ matrix.python }}
 
+      - name: Set ARCHFLAGS for macOS
+        if: runner.os == 'macOS'
+        run: echo "ARCHFLAGS=-arch arm64" >> $GITHUB_ENV
+
       - name: Install poetry
         run: python -m pip install poetry
+
       - name: Cache the virtualenv
         id: cache-venv
         uses: actions/cache@v4
@@ -37,7 +42,7 @@ jobs:
 
       - name: Run tests and Generate coverage
         run: |
-          poetry run pytest --cov --cov-report=xml
+          poetry run pytest --cov --cov-report=xml -v --full-trace
 
       - name: Upload coverage to Codecov
         uses: codecov/codecov-action@v4

CHANGELOG.md

@@ -2,14 +2,38 @@
 
 All notable changes to this project will be documented in this file.
 
-## [1.9.0] - 9999-99-99
+## [Unreleased] - 9999-99-99
 ### Added
 - Added support for Exchange V2 proto queries and types
 - Updated all chain exchange module examples to use the new Exchange V2 proto queries and types
 
 ### Removed
 - Removed all methods marked as deprecated in AsyncClient and Composer
 
+## [1.10.0] - 2025-04-16
+### Added
+- Added support for the queries in the new TXFees module
+
+### Changed
+- Update in the implementation of the gas limit estimator to use the same values as the chain for the fixed gas messages
+- Updated all compiled protos for compatibility with Injective core v1.15 and Indexer v1.15.6
+
+## [1.9.1] - 2025-03-03
+### Fixed
+- Added quantization in the functions that convert notional values to chain format
+
+## [1.9.0] - 2025-02-13
+### Added
+- Added support for all new queries and messages from the new Permissions module
+
+## [1.8.2] - 2024-12-13
+### Changed
+- Updated `protobuf` dependency version to make it more flexible
+
+## [1.8.1] - 2024-12-04
+### Changed
+- Updated OFAC list link and contents
+
 ## [1.8.0] - 2024-11-14
 ### Changed
 - The markets initialization in AsyncClient has been modified to get markets information from the chain endpoints instead of the Indexer endpoints

README.md

@@ -35,11 +35,11 @@ $ poetry install
 
 # connecting to Injective Exchange API
 # and listening for new orders from a specific spot market
-$ poetry run python examples/exchange_client/spot_exchange_rpc/8_StreamOrders.py
+$ poetry run python examples/exchange_client/spot_exchange_rpc/8_StreamOrderbookUpdate.py
 
 # sending a msg with bank transfer
 # signs and posts a transaction to the Injective Chain
-$ poetry run python examples/chain_client/1_MsgSend.py
+$ poetry run python examples/chain_client/bank/1_MsgSend.py
 ```
 Upgrade `pip` to the latest version, if you see these warnings:
   ```
@@ -65,21 +65,14 @@ Upgrade `pip` to the latest version, if you see these warnings:
   pip install injective-py
   ```
 
-3. Fetch latest denom config
-```
-poetry run python pyinjective/utils/fetch_metadata.py
-```
-
-Note that the [sync client](https://github.com/InjectiveLabs/sdk-python/blob/master/pyinjective/client.py) has been deprecated as of April 18, 2022. If you are using the sync client please make sure to transition to the [async client](https://github.com/InjectiveLabs/sdk-python/blob/master/pyinjective/async_client.py), for more information read [here](https://github.com/InjectiveLabs/sdk-python/issues/101)
-
-4. Run all unit tests in a development environment
+3. Run all unit tests in a development environment
 ```
 poetry run pytest -v
 ```
 
 ## License
 
-Copyright © 2021 - 2022 Injective Labs Inc. (https://injectivelabs.org/)
+Copyright © 2021 - 2025 Injective Labs Inc. (https://injectivelabs.org/)
 
 <a href="https://drive.google.com/uc?export=view&id=1-fPQRh_D_dnun2yTtSsPW5MypVBOVYJP"><img src="https://drive.google.com/uc?export=view&id=1-fPQRh_D_dnun2yTtSsPW5MypVBOVYJP" style="width: 300px; max-width: 100%; height: auto" />
 

buf.gen.yaml

@@ -4,7 +4,7 @@ managed:
 plugins:
   - remote: buf.build/protocolbuffers/python:v26.1
     out: ./pyinjective/proto/
-  - remote: buf.build/grpc/python:v1.65.4
+  - remote: buf.build/grpc/python:v1.65.5
     out: ./pyinjective/proto/
 inputs:
   - module: buf.build/cosmos/cosmos-proto
@@ -23,7 +23,7 @@ inputs:
 #    branch: v0.51.x-inj
 #    subdir: proto
 #  - git_repo: https://github.com/InjectiveLabs/injective-core
-#    tag: v1.13.0
+#    tag: v1.15.0
 #    subdir: proto
   - git_repo: https://github.com/InjectiveLabs/injective-core
     branch: master

examples/chain_client/1_LocalOrderHash.py

@@ -6,7 +6,7 @@
 import dotenv
 
 from pyinjective.async_client import AsyncClient
-from pyinjective.constant import GAS_FEE_BUFFER_AMOUNT, GAS_PRICE
+from pyinjective.constant import GAS_FEE_BUFFER_AMOUNT
 from pyinjective.core.network import Network
 from pyinjective.orderhash import OrderHashManager
 from pyinjective.transaction import Transaction
@@ -111,7 +111,11 @@ async def main() -> None:
         .with_account_num(client.get_number())
         .with_chain_id(network.chain_id)
     )
-    gas_price = GAS_PRICE
+
+    gas_price = await client.current_chain_gas_price()
+    # adjust gas price to make it valid even if it changes between the time it is requested and the TX is broadcasted
+    gas_price = int(gas_price * 1.1)
+
     base_gas = 85000
     gas_limit = base_gas + GAS_FEE_BUFFER_AMOUNT  # add buffer for gas fee computation
     gas_fee = "{:.18f}".format((gas_price * gas_limit) / pow(10, 18)).rstrip("0")
@@ -148,7 +152,11 @@ async def main() -> None:
         .with_account_num(client.get_number())
         .with_chain_id(network.chain_id)
     )
-    gas_price = GAS_PRICE
+
+    gas_price = await client.current_chain_gas_price()
+    # adjust gas price to make it valid even if it changes between the time it is requested and the TX is broadcasted
+    gas_price = int(gas_price * 1.1)
+
     base_gas = 85000
     gas_limit = base_gas + GAS_FEE_BUFFER_AMOUNT  # add buffer for gas fee computation
     gas_fee = "{:.18f}".format((gas_price * gas_limit) / pow(10, 18)).rstrip("0")
@@ -240,7 +248,11 @@ async def main() -> None:
         .with_account_num(client.get_number())
         .with_chain_id(network.chain_id)
     )
-    gas_price = GAS_PRICE
+
+    gas_price = await client.current_chain_gas_price()
+    # adjust gas price to make it valid even if it changes between the time it is requested and the TX is broadcasted
+    gas_price = int(gas_price * 1.1)
+
     base_gas = 85000
     gas_limit = base_gas + GAS_FEE_BUFFER_AMOUNT  # add buffer for gas fee computation
     gas_fee = "{:.18f}".format((gas_price * gas_limit) / pow(10, 18)).rstrip("0")

examples/chain_client/3_MessageBroadcaster.py

@@ -1,11 +1,12 @@
 import asyncio
+import json
 import os
 import uuid
 from decimal import Decimal
 
 import dotenv
 
-from pyinjective.composer import Composer as ProtoMsgComposer
+from pyinjective.async_client import AsyncClient
 from pyinjective.core.broadcaster import MsgBroadcasterWithPk
 from pyinjective.core.network import Network
 from pyinjective.wallet import PrivateKey
@@ -17,11 +18,20 @@ async def main() -> None:
 
     # select network: local, testnet, mainnet
     network = Network.testnet()
-    composer = ProtoMsgComposer(network=network.string())
+
+    client = AsyncClient(network)
+    composer = await client.composer()
+
+    gas_price = await client.current_chain_gas_price()
+    # adjust gas price to make it valid even if it changes between the time it is requested and the TX is broadcasted
+    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)
@@ -64,7 +74,12 @@ async def main() -> None:
     # broadcast the transaction
     result = await message_broadcaster.broadcast([msg])
     print("---Transaction Response---")
-    print(result)
+    print(json.dumps(result, indent=2))
+
+    gas_price = await client.current_chain_gas_price()
+    # adjust gas price to make it valid even if it changes between the time it is requested and the TX is broadcasted
+    gas_price = int(gas_price * 1.1)
+    message_broadcaster.update_gas_price(gas_price=gas_price)
 
 
 if __name__ == "__main__":

examples/chain_client/4_MessageBroadcasterWithGranteeAccount.py

@@ -1,12 +1,12 @@
 import asyncio
+import json
 import os
 import uuid
 from decimal import Decimal
 
 import dotenv
 
 from pyinjective.async_client import AsyncClient
-from pyinjective.composer import Composer as ProtoMsgComposer
 from pyinjective.core.broadcaster import MsgBroadcasterWithPk
 from pyinjective.core.network import Network
 from pyinjective.wallet import Address, PrivateKey
@@ -19,20 +19,27 @@ async def main() -> None:
 
     # select network: local, testnet, mainnet
     network = Network.testnet()
-    composer = ProtoMsgComposer(network=network.string())
 
     # initialize grpc client
     client = AsyncClient(network)
+    composer = await client.composer()
     await client.sync_timeout_height()
 
     # load account
     priv_key = PrivateKey.from_hex(private_key_in_hexa)
     pub_key = priv_key.to_public_key()
     address = pub_key.to_address()
 
+    gas_price = await client.current_chain_gas_price()
+    # adjust gas price to make it valid even if it changes between the time it is requested and the TX is broadcasted
+    gas_price = int(gas_price * 1.1)
+
     message_broadcaster = MsgBroadcasterWithPk.new_for_grantee_account_using_simulation(
         network=network,
         grantee_private_key=private_key_in_hexa,
+        gas_price=gas_price,
+        client=client,
+        composer=composer,
     )
 
     # prepare tx msg
@@ -55,7 +62,12 @@ async def main() -> None:
     # broadcast the transaction
     result = await message_broadcaster.broadcast([msg])
     print("---Transaction Response---")
-    print(result)
+    print(json.dumps(result, indent=2))
+
+    gas_price = await client.current_chain_gas_price()
+    # adjust gas price to make it valid even if it changes between the time it is requested and the TX is broadcasted
+    gas_price = int(gas_price * 1.1)
+    message_broadcaster.update_gas_price(gas_price=gas_price)
 
 
 if __name__ == "__main__":

examples/chain_client/5_MessageBroadcasterWithoutSimulation.py

@@ -1,11 +1,12 @@
 import asyncio
+import json
 import os
 import uuid
 from decimal import Decimal
 
 import dotenv
 
-from pyinjective.composer import Composer as ProtoMsgComposer
+from pyinjective.async_client import AsyncClient
 from pyinjective.core.broadcaster import MsgBroadcasterWithPk
 from pyinjective.core.network import Network
 from pyinjective.wallet import PrivateKey
@@ -17,11 +18,21 @@ async def main() -> None:
 
     # select network: local, testnet, mainnet
     network = Network.testnet()
-    composer = ProtoMsgComposer(network=network.string())
+
+    client = AsyncClient(network)
+    composer = await client.composer()
+    await client.sync_timeout_height()
+
+    gas_price = await client.current_chain_gas_price()
+    # adjust gas price to make it valid even if it changes between the time it is requested and the TX is broadcasted
+    gas_price = int(gas_price * 1.1)
 
     message_broadcaster = MsgBroadcasterWithPk.new_without_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)
@@ -64,7 +75,12 @@ async def main() -> None:
     # broadcast the transaction
     result = await message_broadcaster.broadcast([msg])
     print("---Transaction Response---")
-    print(result)
+    print(json.dumps(result, indent=2))
+
+    gas_price = await client.current_chain_gas_price()
+    # adjust gas price to make it valid even if it changes between the time it is requested and the TX is broadcasted
+    gas_price = int(gas_price * 1.1)
+    message_broadcaster.update_gas_price(gas_price=gas_price)
 
 
 if __name__ == "__main__":