|
| 1 | +import asyncio |
| 2 | + |
| 3 | +from pyinjective.composer import Composer as ProtoMsgComposer |
| 4 | +from pyinjective.core.broadcaster import MsgBroadcasterWithPk |
| 5 | +from pyinjective.constant import Network |
| 6 | +from pyinjective.wallet import PrivateKey |
| 7 | + |
| 8 | + |
| 9 | +async def main() -> None: |
| 10 | + # select network: local, testnet, mainnet |
| 11 | + network = Network.testnet() |
| 12 | + composer = ProtoMsgComposer(network=network.string()) |
| 13 | + private_key_in_hexa = "f9db9bf330e23cb7839039e944adef6e9df447b90b503d5b4464c90bea9022f3" |
| 14 | + |
| 15 | + message_broadcaster = MsgBroadcasterWithPk.new_using_simulation( |
| 16 | + network=network, |
| 17 | + private_key=private_key_in_hexa, |
| 18 | + use_secure_connection=True |
| 19 | + ) |
| 20 | + |
| 21 | + priv_key = PrivateKey.from_hex(private_key_in_hexa) |
| 22 | + pub_key = priv_key.to_public_key() |
| 23 | + address = pub_key.to_address() |
| 24 | + subaccount_id = address.get_subaccount_id(index=0) |
| 25 | + |
| 26 | + # prepare trade info |
| 27 | + fee_recipient = "inj1hkhdaj2a2clmq5jq6mspsggqs32vynpk228q3r" |
| 28 | + |
| 29 | + spot_market_id_create = "0x0611780ba69656949525013d947713300f56c37b6175e02f26bffa495c3208fe" |
| 30 | + |
| 31 | + spot_orders_to_create = [ |
| 32 | + composer.SpotOrder( |
| 33 | + market_id=spot_market_id_create, |
| 34 | + subaccount_id=subaccount_id, |
| 35 | + fee_recipient=fee_recipient, |
| 36 | + price=3, |
| 37 | + quantity=55, |
| 38 | + is_buy=True, |
| 39 | + is_po=False |
| 40 | + ), |
| 41 | + composer.SpotOrder( |
| 42 | + market_id=spot_market_id_create, |
| 43 | + subaccount_id=subaccount_id, |
| 44 | + fee_recipient=fee_recipient, |
| 45 | + price=300, |
| 46 | + quantity=55, |
| 47 | + is_buy=False, |
| 48 | + is_po=False |
| 49 | + ), |
| 50 | + ] |
| 51 | + |
| 52 | + # prepare tx msg |
| 53 | + msg = composer.MsgBatchUpdateOrders( |
| 54 | + sender=address.to_acc_bech32(), |
| 55 | + spot_orders_to_create=spot_orders_to_create, |
| 56 | + ) |
| 57 | + |
| 58 | + # broadcast the transaction |
| 59 | + result = await message_broadcaster.broadcast([msg]) |
| 60 | + print("---Transaction Response---") |
| 61 | + print(result) |
| 62 | + |
| 63 | +if __name__ == "__main__": |
| 64 | + asyncio.get_event_loop().run_until_complete(main()) |
0 commit comments