Merge pull request #138 from InjectiveLabs/f/add_send_to_injective

feat: add SendToInjective

Author: achilleas-kal

examples/SendToCosmos.py examples/SendToInjective.pyexamples/SendToCosmos.py renamed to examples/SendToInjective.py

@@ -15,22 +15,24 @@ async def main() -> None:
     network = Network.testnet()
     peggo_composer = Peggo(network=network.string())
 
-    private_key = "f9db9bf330e23cb7839039e944adef6e9df447b90b503d5b4464c90bea9022f3"
-    ethereum_endpoint = "https://kovan.infura.io/v3/c518f454950e48aeab12161c49f26e30"
+    private_key = "5d386fbdbf11f1141010f81a46b40f94887367562bd33b452bbaa6ce1cd1381e"
+    ethereum_endpoint = "https://eth-goerli.g.alchemy.com/v2/q-7JVv4mTfsNh1y_djKkKn3maRBGILLL"
 
     maxFeePerGas_Gwei = 4
     maxPriorityFeePerGas_Gwei = 4
 
-    token_contract = "0x36b3d7ace7201e28040eff30e815290d7b37ffad"
+    token_contract = "0xBe8d71D26525440A03311cc7fa372262c5354A3c"
     receiver = "inj14au322k9munkmx5wrchz9q30juf5wjgz2cfqku"
     amount = 1
 
+    data = '{"@type": "/injective.exchange.v1beta1.MsgDeposit","sender": "inj14au322k9munkmx5wrchz9q30juf5wjgz2cfqku","subaccountId": "0xaf79152ac5df276d9a8e1e2e22822f9713474902000000000000000000000000","amount": {"denom": "inj","amount": "1000000000000000000"}}'
+
     import_peggo = pkg_resources.read_text(pyinjective, 'Peggo_ABI.json')
     peggo_abi = json.loads(import_peggo)
 
-    peggo_composer.SendToCosmos(ethereum_endpoint=ethereum_endpoint, private_key=private_key, token_contract=token_contract,
-                 receiver=receiver, amount=amount, maxFeePerGas=maxFeePerGas_Gwei, maxPriorityFeePerGas=maxPriorityFeePerGas_Gwei, peggo_abi=peggo_abi)
+    peggo_composer.sendToInjective(ethereum_endpoint=ethereum_endpoint, private_key=private_key, token_contract=token_contract,
+                 receiver=receiver, amount=amount, maxFeePerGas=maxFeePerGas_Gwei, maxPriorityFeePerGas=maxPriorityFeePerGas_Gwei, data=data, peggo_abi=peggo_abi)
 
 if __name__ == "__main__":
     logging.basicConfig(level=logging.INFO)
-    asyncio.get_event_loop().run_until_complete(main())
+    asyncio.get_event_loop().run_until_complete(main())

pyinjective/Peggo_ABI.json

@@ -110,9 +110,15 @@
                 "internalType": "uint256",
                 "name": "_eventNonce",
                 "type": "uint256"
+            },
+            {
+                "indexed": false,
+                "internalType": "string",
+                "name": "_data",
+                "type": "string"
             }
         ],
-        "name": "SendToCosmosEvent",
+        "name": "SendToInjectiveEvent",
         "type": "event"
     },
     {
@@ -393,9 +399,14 @@
                 "internalType": "uint256",
                 "name": "_amount",
                 "type": "uint256"
+            },
+            {
+                "internalType": "string",
+                "name": "_data",
+                "type": "string"
             }
         ],
-        "name": "sendToCosmos",
+        "name": "sendToInjective",
         "outputs":
         [],
         "stateMutability": "nonpayable",

pyinjective/sendtocosmos.py

@@ -8,14 +8,16 @@
 class Peggo:
     def __init__(self, network: str):
         self.network = network
-    def SendToCosmos(self, ethereum_endpoint: str, private_key: str, token_contract: str, receiver: str, amount: int,
-                     maxFeePerGas: int, maxPriorityFeePerGas: int, peggo_abi: str, decimals=18):
+    def sendToInjective(self, ethereum_endpoint: str, private_key: str, token_contract: str, receiver: str, amount: int,
+                     maxFeePerGas: int, maxPriorityFeePerGas: int, peggo_abi: str, data: str, decimals=18):
         if self.network == 'testnet':
             peggy_proxy_address = "0xd2C6753F6B1783EF0a3857275e16e79D91b539a3"
         elif self.network == 'mainnet':
             peggy_proxy_address = "0xF955C57f9EA9Dc8781965FEaE0b6A2acE2BAD6f3"
+        elif self.network == 'devnet':
+            peggy_proxy_address = "0x4F38F75606d046819638f909b66B112aF1095e8d"
         else:
-            logging.info("SendToCosmos is only supported on Mainnet & Testnet")
+            logging.info("Network is not supported")
         web3 = Web3(Web3.HTTPProvider(ethereum_endpoint))
         contract = web3.eth.contract(address=peggy_proxy_address, abi=peggo_abi)
 
@@ -35,10 +37,11 @@ def SendToCosmos(self, ethereum_endpoint: str, private_key: str, token_contract:
 
         amount_to_send = int(amount * pow(10, decimals))
 
-        gas = contract.functions.sendToCosmos(
+        gas = contract.functions.sendToInjective(
             token_contract_address,
             destination,
             amount_to_send,
+            data
         ).estimateGas({'from': sender_address_checksum})
 
         transaction_body = {
@@ -48,10 +51,11 @@ def SendToCosmos(self, ethereum_endpoint: str, private_key: str, token_contract:
             'maxPriorityFeePerGas': web3.toWei(maxPriorityFeePerGas, 'gwei'),
         }
 
-        tx = contract.functions.sendToCosmos(
+        tx = contract.functions.sendToInjective(
             token_contract_address,
             destination,
             amount_to_send,
+            data
         ).buildTransaction(transaction_body)
 
         signed_tx = web3.eth.account.signTransaction(tx, private_key=private_key)