Merge pull request #402 from InjectiveLabs/release/chain_v1_17_0_support_to_master

Release/chain v1.17.0 support to master

Author: aarmoa

CHANGELOG.md

@@ -2,6 +2,13 @@
 
 All notable changes to this project will be documented in this file.
 
+## [1.12.0] - 2025-11-10
+### Changed
+- Updated all compiled protos for compatibility with Injective core v1.17.0 and Indexer v1.17.16
+- Included the OpenNotionalCap in derivative markets
+- Added support for market orders creation with the MsgBatchUpdateOrders message
+- Support for order failure events and conditional orders trigger failures in the chainstrem updates
+
 ## [1.11.2] - 2025-09-24
 ### Added
 - Added support in v2 Composer to create the new exchange module MsgCancelPostOnlyMode message

Makefile

@@ -19,19 +19,14 @@ fix-generated-proto-imports:
 	@find ./pyinjective/proto -type f -name "*.py" -exec sed -i "" -e "s/from google.api/from pyinjective.proto.google.api/g" {} \;
 
 define clean_repos
-	rm -Rf cosmos-sdk
-	rm -Rf ibc-go
-	rm -Rf cometbft
-	rm -Rf wasmd
-	rm -Rf injective-core
 	rm -Rf injective-indexer
 endef
 
 clean-all:
 	$(call clean_repos)
 
 clone-injective-indexer:
-	git clone https://github.com/InjectiveLabs/injective-indexer.git -b v1.16.91 --depth 1 --single-branch
+	git clone https://github.com/InjectiveLabs/injective-indexer.git -b v1.17.16 --depth 1 --single-branch
 
 clone-all: clone-injective-indexer
 

buf.gen.yaml

@@ -12,18 +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-evm-comet1-inj
+    tag: v8.7.0-inj.3
   - git_repo: https://github.com/InjectiveLabs/wasmd
-    tag: v0.53.3-evm-comet1-inj
+    tag: v0.53.3-inj.2
   - git_repo: https://github.com/InjectiveLabs/cometbft
-    tag: v1.0.1-inj.3
+    tag: v1.0.1-inj.4
   - git_repo: https://github.com/InjectiveLabs/cosmos-sdk
-    tag: v0.50.13-evm-comet1-inj.6
+    tag: v0.50.14-inj
 #  - 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/injective-core
-    tag: v1.16.4
+    tag: v1.17.0
     subdir: proto
 #  - git_repo: https://github.com/InjectiveLabs/injective-core
 #    branch: master

examples/chain_client/10_SearchLiquidablePositions.py

@@ -0,0 +1,76 @@
+import asyncio
+from decimal import Decimal
+
+from pyinjective.async_client_v2 import AsyncClient
+from pyinjective.core.network import Network
+
+
+def adjusted_margin(
+    quantity: Decimal, margin: Decimal, is_long: bool, cumulative_funding_entry: Decimal, cumulative_funding: Decimal
+) -> Decimal:
+    unrealized_funding_payment = (cumulative_funding - cumulative_funding_entry) * quantity * (-1 if is_long else 1)
+    return margin + unrealized_funding_payment
+
+
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.mainnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    positions_per_market = dict()
+
+    positions_dict = await client.fetch_chain_positions()
+    liquidable_positions = []
+
+    for position in positions_dict["state"]:
+        if position["marketId"] not in positions_per_market:
+            positions_per_market[position["marketId"]] = []
+        positions_per_market[position["marketId"]].append(position)
+
+    derivative_markets = await client.fetch_chain_derivative_markets(
+        status="Active",
+        market_ids=list(positions_per_market.keys()),
+    )
+
+    for market in derivative_markets["markets"]:
+        client_market = (await client.all_derivative_markets())[market["market"]["marketId"]]
+        market_mark_price = client_market._from_extended_chain_format(Decimal(market["markPrice"]))
+        for position in positions_per_market[client_market.id]:
+            is_long = position["position"]["isLong"]
+            quantity = client_market._from_extended_chain_format(Decimal(position["position"]["quantity"]))
+            entry_price = client_market._from_extended_chain_format(Decimal(position["position"]["entryPrice"]))
+            margin = client_market._from_extended_chain_format(Decimal(position["position"]["margin"]))
+            cumulative_funding_entry = client_market._from_extended_chain_format(
+                Decimal(position["position"]["cumulativeFundingEntry"])
+            )
+            market_cumulative_funding = client_market._from_extended_chain_format(
+                Decimal(market["perpetualInfo"]["fundingInfo"]["cumulativeFunding"])
+            )
+
+            adj_margin = adjusted_margin(quantity, margin, is_long, cumulative_funding_entry, market_cumulative_funding)
+            adjusted_unit_margin = (adj_margin / quantity) * (-1 if is_long else 1)
+            maintenance_margin_ratio = client_market.maintenance_margin_ratio * (-1 if is_long else 1)
+
+            liquidation_price = (entry_price + adjusted_unit_margin) / (Decimal(1) + maintenance_margin_ratio)
+
+            should_be_liquidated = (is_long and market_mark_price <= liquidation_price) or (
+                not is_long and market_mark_price >= liquidation_price
+            )
+
+            if should_be_liquidated:
+                position_side = "Long" if is_long else "Short"
+                print(
+                    f"{position_side} position for market {client_market.id} and subaccount "
+                    f"{position['subaccountId']} should be liquidated (liquidation price: "
+                    f"{liquidation_price.normalize()} / mark price: {market_mark_price.normalize()})"
+                )
+                liquidable_positions.append(position)
+
+    # print(f"\n\n\n")
+    # print(json.dumps(liquidable_positions, indent=4))
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/chain_client/7_ChainStream.py

@@ -50,6 +50,12 @@ async def main() -> None:
         subaccount_ids=[subaccount_id], market_ids=[inj_usdt_perp_market]
     )
     oracle_price_filter = composer.chain_stream_oracle_price_filter(symbols=["INJ", "USDT"])
+    order_failures_filter = composer.chain_stream_order_failures_filter(
+        accounts=["inj1hkhdaj2a2clmq5jq6mspsggqs32vynpk228q3r"]
+    )
+    conditional_order_trigger_failures_filter = composer.chain_stream_conditional_order_trigger_failures_filter(
+        subaccount_ids=[subaccount_id], market_ids=[inj_usdt_perp_market]
+    )
 
     task = asyncio.get_event_loop().create_task(
         client.listen_chain_stream_updates(
@@ -66,6 +72,8 @@ async def main() -> None:
             derivative_orderbooks_filter=derivative_orderbooks_filter,
             positions_filter=positions_filter,
             oracle_price_filter=oracle_price_filter,
+            order_failures_filter=order_failures_filter,
+            conditional_order_trigger_failures_filter=conditional_order_trigger_failures_filter,
         )
     )
 

examples/chain_client/exchange/13_MsgInstantBinaryOptionsMarketLaunch.py

@@ -57,6 +57,7 @@ async def main() -> None:
         min_price_tick_size=Decimal("0.01"),
         min_quantity_tick_size=Decimal("0.01"),
         min_notional=Decimal("1"),
+        open_notional_cap=composer.uncapped_open_notional_cap(),
     )
 
     # broadcast the transaction

examples/chain_client/exchange/25_MsgUpdateDerivativeMarket.py

@@ -52,6 +52,7 @@ async def main() -> None:
         new_initial_margin_ratio=Decimal("0.40"),
         new_maintenance_margin_ratio=Decimal("0.085"),
         new_reduce_margin_ratio=Decimal("3.5"),
+        new_open_notional_cap=composer.uncapped_open_notional_cap(),
     )
 
     # broadcast the transaction

examples/chain_client/exchange/30_MsgOffsetPosition.py

@@ -0,0 +1,68 @@
+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()
+    configured_private_key = os.getenv("INJECTIVE_PRIVATE_KEY")
+
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+    await client.initialize_tokens_from_chain_denoms()
+    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=configured_private_key,
+        gas_price=gas_price,
+        client=client,
+        composer=composer,
+    )
+
+    # 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())
+
+    offsetting_subaccount_ids = {
+        "0xbdaedec95d563fb05240d6e01821008454c24c36000000000000000000000000",
+        "0xaf79152ac5df276d9a8e1e2e22822f9713474902000000000000000000000000",
+    }
+
+    # prepare tx msg
+    message = composer.msg_offset_position(
+        sender=address.to_acc_bech32(),
+        subaccount_id=address.get_subaccount_id(index=0),
+        market_id="0x17ef48032cb24375ba7c2e39f384e56433bcab20cbee9a7357e4cba2eb00abe6",
+        offsetting_subaccount_ids=offsetting_subaccount_ids,
+    )
+
+    # broadcast the transaction
+    result = await message_broadcaster.broadcast([message])
+    print("---Transaction Response---")
+    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__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/chain_client/exchange/4_MsgInstantPerpetualMarketLaunch.py

@@ -58,6 +58,7 @@ async def main() -> None:
         min_price_tick_size=Decimal("0.001"),
         min_quantity_tick_size=Decimal("0.01"),
         min_notional=Decimal("1"),
+        open_notional_cap=composer.uncapped_open_notional_cap(),
     )
 
     # broadcast the transaction

examples/chain_client/exchange/5_MsgInstantExpiryFuturesMarketLaunch.py

@@ -58,6 +58,7 @@ async def main() -> None:
         min_price_tick_size=Decimal("0.001"),
         min_quantity_tick_size=Decimal("0.01"),
         min_notional=Decimal("1"),
+        open_notional_cap=composer.uncapped_open_notional_cap(),
     )
 
     # broadcast the transaction