(feat) Updated proto definitions to injective-core v1.17.0-beta.3 and indexer v1.17.0-beta

Author: aarmoa

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.0-beta --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-beta.3
     subdir: proto
 #  - git_repo: https://github.com/InjectiveLabs/injective-core
 #    branch: master

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,69 @@
+import asyncio
+import json
+import os
+from decimal import Decimal
+
+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

examples/chain_client/exchange/9_MsgBatchUpdateOrders.py

@@ -104,6 +104,21 @@ async def main() -> None:
         ),
     ]
 
+    derivative_market_orders_to_create = [
+        composer.derivative_order(
+            market_id=derivative_market_id_create,
+            subaccount_id=subaccount_id,
+            fee_recipient=fee_recipient,
+            price=Decimal(25100),
+            quantity=Decimal(0.1),
+            margin=composer.calculate_margin(
+                quantity=Decimal(0.1), price=Decimal(25100), leverage=Decimal(1), is_reduce_only=False
+            ),
+            order_type="BUY",
+            cid=str(uuid.uuid4()),
+        ),
+    ]
+
     spot_orders_to_create = [
         composer.spot_order(
             market_id=spot_market_id_create,
@@ -125,13 +140,27 @@ async def main() -> None:
         ),
     ]
 
+    spot_market_orders_to_create = [
+        composer.spot_order(
+            market_id=spot_market_id_create,
+            subaccount_id=subaccount_id,
+            fee_recipient=fee_recipient,
+            price=Decimal("3.5"),
+            quantity=Decimal("1"),
+            order_type="BUY",
+            cid=str(uuid.uuid4()),
+        ),
+    ]
+
     # prepare tx msg
     msg = composer.msg_batch_update_orders(
         sender=address.to_acc_bech32(),
         derivative_orders_to_create=derivative_orders_to_create,
         spot_orders_to_create=spot_orders_to_create,
         derivative_orders_to_cancel=derivative_orders_to_cancel,
         spot_orders_to_cancel=spot_orders_to_cancel,
+        spot_market_orders_to_create=spot_market_orders_to_create,
+        derivative_market_orders_to_create=derivative_market_orders_to_create,
     )
 
     # broadcast the transaction

examples/chain_client/exchange/query/66_OpenInterest.py

@@ -0,0 +1,24 @@
+import asyncio
+import json
+
+from pyinjective.async_client_v2 import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    """
+    Demonstrate fetching denom min notionals using AsyncClient.
+    """
+    # Select network: choose between Network.mainnet(), Network.testnet(), or Network.devnet()
+    network = Network.testnet()
+
+    # Initialize the Async Client
+    client = AsyncClient(network)
+
+    market_id = "0x17ef48032cb24375ba7c2e39f384e56433bcab20cbee9a7357e4cba2eb00abe6"
+    open_interest = await client.fetch_open_interest(market_id=market_id)
+    print(json.dumps(open_interest, indent=2))
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())