(feat) Updated proto definitions with the chain and indexer versions used for the v1.14 Testnet upgrade. Included the new fields and endpoints in the SDK API components and updated the example scripts

Author: aarmoa

Makefile

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

buf.gen.yaml

@@ -12,18 +12,18 @@ inputs:
   - module: buf.build/googleapis/googleapis
   - module: buf.build/cosmos/ics23
   - git_repo: https://github.com/InjectiveLabs/cosmos-sdk
-    tag: v0.50.8-inj-0
+    tag: v0.50.9-inj-2
   - git_repo: https://github.com/InjectiveLabs/ibc-go
     tag: v8.3.2-inj-0
   - git_repo: https://github.com/InjectiveLabs/wasmd
-    tag: v0.51.0-inj-0
+    tag: v0.53.2-inj-1
 #  - git_repo: https://github.com/InjectiveLabs/wasmd
 #    branch: v0.51.x-inj
 #    subdir: proto
 #  - git_repo: https://github.com/InjectiveLabs/injective-core
 #    tag: v1.13.0
 #    subdir: proto
   - git_repo: https://github.com/InjectiveLabs/injective-core
-    branch: f/permissions-rework
+    branch: testnet
     subdir: proto
   - directory: proto

examples/chain_client/exchange/query/56_L3DerivativeOrderBook.py

@@ -0,0 +1,21 @@
+import asyncio
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    orderbook = await client.fetch_l3_derivative_orderbook(
+        market_id="0x17ef48032cb24375ba7c2e39f384e56433bcab20cbee9a7357e4cba2eb00abe6",
+    )
+    print(orderbook)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/chain_client/exchange/query/57_L3SpotOrderBook.py

@@ -0,0 +1,21 @@
+import asyncio
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    # select network: local, testnet, mainnet
+    network = Network.testnet()
+
+    # initialize grpc client
+    client = AsyncClient(network)
+
+    orderbook = await client.fetch_l3_spot_orderbook(
+        market_id="0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe",
+    )
+    print(orderbook)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/chain_client/exchange/query/58_MarketBalance.py

@@ -0,0 +1,31 @@
+import asyncio
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    """
+    Demonstrate fetching market balance using AsyncClient.
+    """
+    # Select network: choose between Network.mainnet(), Network.testnet(), or Network.devnet()
+    network = Network.testnet()
+
+    # Initialize the Async Client
+    client = AsyncClient(network)
+
+    try:
+        # Example market ID (replace with an actual market ID from the network)
+        market_id = "0x17ef48032cb24375ba7c2e39f384e56433bcab20cbee9a7357e4cba2eb00abe6"
+
+        # Fetch market balance
+        market_balance = await client.fetch_market_balance(market_id=market_id)
+        print("Market Balance:")
+        print(market_balance)
+
+    except Exception as ex:
+        print(f"Error occurred: {ex}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/chain_client/exchange/query/59_MarketBalances.py

@@ -0,0 +1,28 @@
+import asyncio
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    """
+    Demonstrate fetching market balances using AsyncClient.
+    """
+    # Select network: choose between Network.mainnet(), Network.testnet(), or Network.devnet()
+    network = Network.testnet()
+
+    # Initialize the Async Client
+    client = AsyncClient(network)
+
+    try:
+        # Fetch market balances
+        market_balances = await client.fetch_market_balances()
+        print("Market Balances:")
+        print(market_balances)
+
+    except Exception as ex:
+        print(f"Error occurred: {ex}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/chain_client/exchange/query/60_DenomMinNotional.py

@@ -0,0 +1,31 @@
+import asyncio
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main() -> None:
+    """
+    Demonstrate fetching denom min notional using AsyncClient.
+    """
+    # Select network: choose between Network.mainnet(), Network.testnet(), or Network.devnet()
+    network = Network.testnet()
+
+    # Initialize the Async Client
+    client = AsyncClient(network)
+
+    try:
+        # Example denom
+        denom = "factory/inj1hkhdaj2a2clmq5jq6mspsggqs32vynpk228q3r/inj_test"
+
+        # Fetch market balance
+        min_notional = await client.fetch_denom_min_notional(denom=denom)
+        print("Min Notional:")
+        print(min_notional)
+
+    except Exception as ex:
+        print(f"Error occurred: {ex}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/chain_client/exchange/query/61_DenomMinNotionals.py

@@ -0,0 +1,28 @@
+import asyncio
+
+from pyinjective.async_client 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)
+
+    try:
+        # Fetch market balance
+        min_notionals = await client.fetch_denom_min_notionals()
+        print("Min Notionals:")
+        print(min_notionals)
+
+    except Exception as ex:
+        print(f"Error occurred: {ex}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/exchange_client/auctions_rpc/4_InjBurntEndpoint.py

@@ -0,0 +1,25 @@
+import asyncio
+
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+async def main():
+    # Select network: testnet, mainnet, or local
+    network = Network.testnet()
+
+    # Initialize AsyncClient
+    client = AsyncClient(network)
+
+    try:
+        # Fetch INJ burnt amount
+        inj_burnt_response = await client.fetch_inj_burnt()
+        print("INJ Burnt Endpoint Response:")
+        print(inj_burnt_response)
+
+    except Exception as e:
+        print(f"Error fetching INJ burnt amount: {e}")
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/exchange_client/derivative_exchange_rpc/9_StreamPositions.py

@@ -27,7 +27,7 @@ async def main() -> None:
     subaccount_ids = ["0xea98e3aa091a6676194df40ac089e40ab4604bf9000000000000000000000000"]
 
     task = asyncio.get_event_loop().create_task(
-        client.listen_derivative_positions_updates(
+        client.listen_derivative_positions_v2_updates(
             callback=positions_event_processor,
             on_end_callback=stream_closed_processor,
             on_status_callback=stream_error_processor,