Merge pull request #309 from InjectiveLabs/feat/add_trade_reward_campaign_endpoint

Feat/add trade reward campaign endpoint

Author: aarmoa

CHANGELOG.md

@@ -2,6 +2,16 @@
 
 All notable changes to this project will be documented in this file.
 
+## [1.4.0] - 2024-03-11
+### Added
+- Added support for all queries and messages in the chain 'distribution' module
+- Added support for all queries and messages in the chain 'exchange' module
+- Use of python-dotenv in all example scripts to load private keys from a .env file
+
+## [1.3.1] - 2024-02-29
+### Changed
+- Updated cookie assistant logic to support the Indexer exchange server not using cookies and the chain server using them
+
 ## [1.3.0] - 2024-02-12
 ### Changed
 - Removed `asyncio` from the dependencies

examples/chain_client/exchange/11_MsgCreateDerivativeMarketOrder.py

@@ -43,10 +43,11 @@ async def main() -> None:
         subaccount_id=subaccount_id,
         fee_recipient=fee_recipient,
         price=Decimal(50000),
-        quantity=Decimal(0.01),
+        quantity=Decimal(0.1),
         margin=composer.calculate_margin(
-            quantity=Decimal(0.01), price=Decimal(50000), leverage=Decimal(3), is_reduce_only=False
+            quantity=Decimal(0.1), price=Decimal(50000), leverage=Decimal(1), is_reduce_only=False
         ),
+        order_type="BUY",
         cid=str(uuid.uuid4()),
     )
 

examples/chain_client/exchange/query/41_TradeRewardCampaign.py

@@ -0,0 +1,32 @@
+import asyncio
+import os
+
+import dotenv
+
+from pyinjective import PrivateKey
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+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)
+
+    # 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())
+
+    campaign = await client.fetch_trade_reward_campaign()
+    print(campaign)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/chain_client/exchange/query/42_FeeDiscountAccountInfo.py

@@ -0,0 +1,34 @@
+import asyncio
+import os
+
+import dotenv
+
+from pyinjective import PrivateKey
+from pyinjective.async_client import AsyncClient
+from pyinjective.core.network import Network
+
+
+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)
+
+    # 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())
+
+    fee_discount = await client.fetch_fee_discount_account_info(
+        account=address.to_acc_bech32(),
+    )
+    print(fee_discount)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/chain_client/exchange/query/43_FeeDiscountSchedule.py

@@ -0,0 +1,19 @@
+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)
+
+    schedule = await client.fetch_fee_discount_schedule()
+    print(schedule)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/chain_client/exchange/query/44_BalanceMismatches.py

@@ -0,0 +1,19 @@
+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)
+
+    mismatches = await client.fetch_balance_mismatches(dust_factor=1)
+    print(mismatches)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/chain_client/exchange/query/45_BalanceWithBalanceHolds.py

@@ -0,0 +1,19 @@
+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)
+
+    balance = await client.fetch_balance_with_balance_holds()
+    print(balance)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/chain_client/exchange/query/46_FeeDiscountTierStatistics.py

@@ -0,0 +1,19 @@
+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)
+
+    statistics = await client.fetch_fee_discount_tier_statistics()
+    print(statistics)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/chain_client/exchange/query/47_MitoVaultInfos.py

@@ -0,0 +1,19 @@
+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)
+
+    infos = await client.fetch_mito_vault_infos()
+    print(infos)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())

examples/chain_client/exchange/query/48_QueryMarketIDFromVault.py

@@ -0,0 +1,19 @@
+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)
+
+    market_id = await client.fetch_market_id_from_vault(vault_address="inj1qg5ega6dykkxc307y25pecuufrjkxkag6xhp6y")
+    print(market_id)
+
+
+if __name__ == "__main__":
+    asyncio.get_event_loop().run_until_complete(main())