Problem: no stateful precompiled contract for ica

CHANGELOG.md

@@ -22,6 +22,7 @@
 - (deps) [#1121](https://github.com/crypto-org-chain/cronos/pull/1121) Bump Cosmos-SDK to v0.47.5 and ibc-go to v7.2.0.
 - [cronos#1014](https://github.com/crypto-org-chain/cronos/pull/1014) Support stateful precompiled contract for relayer.
 - [cronos#1165](https://github.com/crypto-org-chain/cronos/pull/1165) Icaauth module is not adjusted correctly in ibc-go v7.2.0.
+- [cronos#1163](https://github.com/crypto-org-chain/cronos/pull/1163) Support stateful precompiled contract for ica.
 - [cronos#837](https://github.com/crypto-org-chain/cronos/pull/837) Support stateful precompiled contract for bank.
 
 ### Bug Fixes

app/app.go

@@ -551,6 +551,7 @@ func New(
 		[]vm.PrecompiledContract{
 			cronosprecompiles.NewBankContract(app.BankKeeper, appCodec),
 			cronosprecompiles.NewRelayerContract(app.IBCKeeper, appCodec),
+			cronosprecompiles.NewIcaContract(&app.ICAAuthKeeper, appCodec),
 		},
 		allKeys,
 	)

go.mod

@@ -233,7 +233,7 @@ replace (
 	// TODO: remove it: https://github.com/cosmos/cosmos-sdk/issues/13134
 	github.com/dgrijalva/jwt-go => github.com/golang-jwt/jwt/v4 v4.4.2
 	github.com/ethereum/go-ethereum => github.com/evmos/go-ethereum v1.10.26-evmos-rc1
-	github.com/evmos/ethermint => github.com/crypto-org-chain/ethermint v0.6.1-0.20230921025237-ae144329ecaf
+	github.com/evmos/ethermint => github.com/crypto-org-chain/ethermint v0.6.1-0.20230922012232-7867b60ee617
 	// Fix upstream GHSA-h395-qcrw-5vmq and GHSA-3vp4-m3rf-835h vulnerabilities.
 	// TODO Remove it: https://github.com/cosmos/cosmos-sdk/issues/10409
 	github.com/gin-gonic/gin => github.com/gin-gonic/gin v1.9.0

go.sum

@@ -482,8 +482,8 @@ github.com/crypto-org-chain/cometbft-db v0.0.0-20230921030527-0d47d7537e32 h1:Vq
 github.com/crypto-org-chain/cometbft-db v0.0.0-20230921030527-0d47d7537e32/go.mod h1:V32HRAjDsAYLfAT90mk0O9UH+sE7P5apfiCmmmVLt3Q=
 github.com/crypto-org-chain/cosmos-sdk v0.46.0-beta2.0.20230905040840-b3af5590283b h1:d2GOFR3i3BjDlPsmJkp8Gsrt9LK2nq2IVEnE/rMv1Fo=
 github.com/crypto-org-chain/cosmos-sdk v0.46.0-beta2.0.20230905040840-b3af5590283b/go.mod h1:EHwCeN9IXonsjKcjpS12MqeStdZvIdxt3VYXhus3G3c=
-github.com/crypto-org-chain/ethermint v0.6.1-0.20230921025237-ae144329ecaf h1:XvwFJ6kPHOYevfNjshq4n2nazvYzoSaQ8AjSYWSfUhI=
-github.com/crypto-org-chain/ethermint v0.6.1-0.20230921025237-ae144329ecaf/go.mod h1:KtjU2MHMCTcLnAoS9C3U3f+vx4f9HHNQRcOlxXiVDxY=
+github.com/crypto-org-chain/ethermint v0.6.1-0.20230922012232-7867b60ee617 h1:C+fE3fWSxTFGM/8eVOpIe3Qjr1146EVydfHX8yS2v20=
+github.com/crypto-org-chain/ethermint v0.6.1-0.20230922012232-7867b60ee617/go.mod h1:KtjU2MHMCTcLnAoS9C3U3f+vx4f9HHNQRcOlxXiVDxY=
 github.com/crypto-org-chain/gravity-bridge/module/v2 v2.0.1-0.20230825054824-75403cd90c6e h1:rSTc35OBjjCBx47rHPWBCIHNGPbMnEj8f7fNcK2TjVI=
 github.com/crypto-org-chain/gravity-bridge/module/v2 v2.0.1-0.20230825054824-75403cd90c6e/go.mod h1:HBaDqlFjlaXJwVQtA7jHejyaA7xwjXI2o6pU/ccP3tE=
 github.com/cyphar/filepath-securejoin v0.2.3/go.mod h1:aPGpWjXOXUn2NCNjFvBE6aRxGGx79pTxQpKOJNYHHl4=

gomod2nix.toml

@@ -213,8 +213,8 @@ schema = 3
     hash = "sha256-GgcReGsIIuBE2TabDYqDO9sBGogdVr9RSh4arQzdPnE="
     replaced = "github.com/evmos/go-ethereum"
   [mod."github.com/evmos/ethermint"]
-    version = "v0.6.1-0.20230921025237-ae144329ecaf"
-    hash = "sha256-ZDzwB65qROKNIB4Yv1i+5FTJoejeuRCcUzUacyuFBFw="
+    version = "v0.6.1-0.20230922012232-7867b60ee617"
+    hash = "sha256-VXLEsA+853W0/38zD4aZyMUqmlYk4+TU7AzD6fKFEPI="
     replaced = "github.com/crypto-org-chain/ethermint"
   [mod."github.com/felixge/httpsnoop"]
     version = "v1.0.2"

integration_tests/configs/ibc.jsonnet

@@ -100,6 +100,7 @@ config {
             params: {
               allow_messages: [
                 '/cosmos.bank.v1beta1.MsgSend',
+                '/cosmos.staking.v1beta1.MsgDelegate',
               ],
             },
           },

integration_tests/contracts/contracts/TestICA.sol

@@ -0,0 +1,81 @@
+// SPDX-License-Identifier: MIT
+pragma solidity >0.6.6;
+
+contract TestICA {
+    address constant icaContract = 0x0000000000000000000000000000000000000066;
+
+    function encodeRegister(string memory connectionID) internal view returns (bytes memory) {
+        return abi.encodeWithSignature(
+            "registerAccount(string,string)",
+            connectionID, msg.sender, ""
+        );
+    }
+
+    function callRegister(string memory connectionID) public returns (bool) {
+        (bool result, ) = icaContract.call(encodeRegister(connectionID));
+        require(result, "call failed");
+        return true;
+    }
+
+    function delegateRegister(string memory connectionID) public returns (bool) {
+        (bool result,) = icaContract.delegatecall(encodeRegister(connectionID));
+        require(result, "call failed");
+        return true;
+    }
+
+    function staticRegister(string memory connectionID) public returns (bool) {
+        (bool result,) = icaContract.staticcall(encodeRegister(connectionID));
+        require(result, "call failed");
+        return true;
+    }
+
+    function encodeQueryAccount(string memory connectionID, address addr) internal view returns (bytes memory) {
+        return abi.encodeWithSignature(
+            "queryAccount(string,address)",
+            connectionID, addr
+        );
+    }
+
+    function callQueryAccount(string memory connectionID, address addr) public returns (string memory) {
+        (bool result, bytes memory data) = icaContract.call(encodeQueryAccount(connectionID, addr));
+        require(result, "call failed");
+        return abi.decode(data, (string));
+    }
+
+    function delegateQueryAccount(string memory connectionID, address addr) public returns (string memory) {
+        (bool result, bytes memory data) = icaContract.delegatecall(encodeQueryAccount(connectionID, addr));
+        require(result, "call failed");
+        return abi.decode(data, (string));
+    }
+
+    function staticQueryAccount(string memory connectionID, address addr) public returns (string memory) {
+        (bool result, bytes memory data) = icaContract.staticcall(encodeQueryAccount(connectionID, addr));
+        require(result, "call failed");
+        return abi.decode(data, (string));
+    }
+
+    function encodeSubmitMsgs(string memory connectionID, string memory data) internal view returns (bytes memory) {
+        return abi.encodeWithSignature(
+            "submitMsgs(string,string,uint256)",
+            connectionID, msg.sender, data, 300000000000
+        );
+    }
+
+    function callSubmitMsgs(string memory connectionID, string memory data) public returns (uint64) {
+        (bool result, bytes memory data) = icaContract.call(encodeSubmitMsgs(connectionID, data));
+        require(result, "call failed");
+        return abi.decode(data, (uint64));
+    }
+
+    function delegateSubmitMsgs(string memory connectionID, string memory data) public returns (uint64) {
+        (bool result, bytes memory data) = icaContract.delegatecall(encodeSubmitMsgs(connectionID, data));
+        require(result, "call failed");
+        return abi.decode(data, (uint64));
+    }
+
+    function staticSubmitMsgs(string memory connectionID, string memory data) public returns (uint64) {
+        (bool result, bytes memory data) = icaContract.staticcall(encodeSubmitMsgs(connectionID, data));
+        require(result, "call failed");
+        return abi.decode(data, (uint64));
+    }
+}

integration_tests/cosmoscli.py

@@ -1062,10 +1062,10 @@ def set_delegate_keys(self, val_addr, acc_addr, eth_addr, signature, **kwargs):
         )
 
     def query_gravity_params(self):
-        return json.loads(self.raw("query", "gravity", "params", home=self.data_dir))
+        return self.query_params("gravity")
 
-    def query_evm_params(self):
-        return json.loads(self.raw("query", "evm", "params", home=self.data_dir))
+    def query_params(self, module="cronos"):
+        return json.loads(self.raw("query", module, "params", home=self.data_dir))
 
     def query_signer_set_txs(self):
         return json.loads(
@@ -1275,7 +1275,7 @@ def icaauth_register_account(self, connid, **kwargs):
             rsp = self.event_query_tx_for(rsp["txhash"])
         return rsp
 
-    def icaauth_submit_tx(self, connid, tx, **kwargs):
+    def icaauth_submit_tx(self, connid, tx, timeout_duration="1h", **kwargs):
         default_kwargs = {
             "home": self.data_dir,
             "node": self.node_rpc,
@@ -1289,6 +1289,8 @@ def icaauth_submit_tx(self, connid, tx, **kwargs):
                 "submit-tx",
                 connid,
                 tx,
+                "--timeout-duration" if timeout_duration else None,
+                timeout_duration if timeout_duration else None,
                 "-y",
                 **(default_kwargs | kwargs),
             )
@@ -1586,17 +1588,6 @@ def turn_bridge(self, enable, **kwargs):
             )
         )
 
-    def query_params(self):
-        "query cronos params"
-        return json.loads(
-            self.raw(
-                "query",
-                "cronos",
-                "params",
-                home=self.data_dir,
-            )
-        )
-
     def evm_params(self, **kwargs):
         default_kwargs = {
             "node": self.node_rpc,

integration_tests/ibc_utils.py

@@ -5,6 +5,7 @@
 from pathlib import Path
 from typing import NamedTuple
 
+from eth_utils import keccak
 from pystarport import cluster, ports
 
 from .network import Chainmain, Cronos, Hermes, setup_custom_cronos
@@ -597,6 +598,28 @@ def funds_ica(cli, adr):
     rsp = cli.transfer("signer2", adr, "1cro", gas_prices="1000000basecro")
     assert rsp["code"] == 0, rsp["raw_log"]
     wait_for_new_blocks(cli, 1)
-
+    amt = 100000000
     # check if the funds are received in interchain account
-    assert cli.balance(adr, denom="basecro") == 100000000
+    assert cli.balance(adr, denom="basecro") == amt
+    return amt
+
+
+def assert_channel_open_init(rsp):
+    assert rsp["code"] == 0, rsp["raw_log"]
+    port_id, channel_id = next(
+        (
+            evt["attributes"][0]["value"],
+            evt["attributes"][1]["value"],
+        )
+        for evt in rsp["events"]
+        if evt["type"] == "channel_open_init"
+    )
+    print("port-id", port_id, "channel-id", channel_id)
+    return port_id, channel_id
+
+
+def update_client():
+    return {
+        "clientId": keccak(text="07-tendermint-0"),
+        "clientType": keccak(text="07-tendermint"),
+    }

integration_tests/test_ibc_rly.py

@@ -4,10 +4,8 @@
 import subprocess
 
 import pytest
-from eth_utils import abi, keccak, to_checksum_address
+from eth_utils import keccak, to_checksum_address
 from pystarport import cluster
-from web3._utils.contracts import abi_to_signature, find_matching_event_abi
-from web3._utils.events import get_event_data
 from web3.datastructures import AttributeDict
 
 from .ibc_utils import (
@@ -18,20 +16,24 @@
     ibc_denom,
     ibc_incentivized_transfer,
     prepare_network,
+    update_client,
 )
 from .utils import (
     ADDRS,
     CONTRACT_ABIS,
     bech32_to_eth,
     eth_to_bech32,
+    get_logs_since,
+    get_method_map,
+    get_topic_data,
     module_address,
     wait_for_fn,
     wait_for_new_blocks,
 )
 
 CONTRACT = "0x0000000000000000000000000000000000000065"
-method_map = None
-contract_info = None
+contract_info = json.loads(CONTRACT_ABIS["IRelayerModule"].read_text())
+method_map = get_method_map(contract_info)
 cronos_signer2 = ADDRS["signer2"]
 src_amount = 10
 src_denom = "basecro"
@@ -81,41 +83,6 @@ def rly_transfer(ibc):
     subprocess.run(cmd, check=True, shell=True)
 
 
-def get_method_map():
-    global contract_info
-    if contract_info is None:
-        contract_info = json.loads(CONTRACT_ABIS["IRelayerModule"].read_text())
-    global method_map
-    if method_map is None:
-        method_map = {}
-        for item in contract_info:
-            event_abi = find_matching_event_abi(contract_info, item["name"])
-            signature = abi_to_signature(event_abi)
-            key = f"0x{abi.event_signature_to_log_topic(signature).hex()}"
-            method_map[key] = signature
-    return method_map, contract_info
-
-
-def get_topic_data(w3, log):
-    method_map, info = get_method_map()
-    method = method_map[log.topics[0].hex()]
-    name = method.split("(")[0]
-    event_abi = find_matching_event_abi(info, name)
-    event_data = get_event_data(w3.codec, event_abi, log)
-    return name, event_data.args
-
-
-def get_logs(w3, start):
-    end = w3.eth.get_block_number()
-    return w3.eth.get_logs(
-        {
-            "fromBlock": start,
-            "toBlock": end,
-            "address": [CONTRACT],
-        }
-    )
-
-
 def coin_received(receiver, amt, denom):
     return {
         "receiver": receiver,
@@ -168,13 +135,6 @@ def burn(burner, amt, denom):
     }
 
 
-def update_client():
-    return {
-        "clientId": keccak(text="07-tendermint-0"),
-        "clientType": keccak(text="07-tendermint"),
-    }
-
-
 def recv_packet(src, dst, amt, denom):
     return {
         "packetDataHex": (dst, src, [(amt, denom)]),
@@ -245,7 +205,7 @@ def check_balance_change():
 
     wait_for_fn("balance change", check_balance_change)
     assert old_dst_balance + dst_amount == new_dst_balance
-    logs = get_logs(w3, start)
+    logs = get_logs_since(w3, CONTRACT, start)
     relayer0 = ibc.chainmain.cosmos_cli().address("relayer")
     relayer = to_checksum_address(bech32_to_eth(relayer0))
     cronos_addr = module_address("cronos")
@@ -262,7 +222,7 @@ def check_balance_change():
     ]
 
     for i, log in enumerate(logs):
-        method_name, args = get_topic_data(w3, log)
+        method_name, args = get_topic_data(w3, method_map, contract_info, log)
         assert args == AttributeDict(expected[i]), [i, method_name]
 
 
@@ -278,7 +238,7 @@ def test_ibc_incentivized_transfer(ibc):
     wait_for_new_blocks(cli, 1)
     start = w3.eth.get_block_number()
     amount = ibc_incentivized_transfer(ibc)
-    logs = get_logs(w3, start)
+    logs = get_logs_since(w3, CONTRACT, start)
     fee_denom = "ibcfee"
     fee = f"{src_amount}{fee_denom}"
     transfer_denom = "transfer/channel-0/basetcro"
@@ -305,7 +265,7 @@ def test_ibc_incentivized_transfer(ibc):
     ]
     assert len(logs) == len(expected)
     for i, log in enumerate(logs):
-        method_name, args = get_topic_data(w3, log)
+        method_name, args = get_topic_data(w3, method_map, contract_info, log)
         assert args == AttributeDict(expected[i]), [i, method_name]
 
 
@@ -335,13 +295,13 @@ def test_cronos_transfer_source_tokens(ibc):
     w3 = ibc.cronos.w3
     start = w3.eth.get_block_number()
     amount, contract = cronos_transfer_source_tokens(ibc)
-    logs = get_logs(w3, start)
+    logs = get_logs_since(w3, CONTRACT, start)
     escrow = get_escrow_address(cli, channel)
     dst_adr = ibc.chainmain.cosmos_cli().address("signer2")
     expected = get_transfer_source_tokens_topics(dst_adr, amount, contract, escrow)
     assert len(logs) == len(expected)
     for i, log in enumerate(logs):
-        method_name, args = get_topic_data(w3, log)
+        method_name, args = get_topic_data(w3, method_map, contract_info, log)
         assert args == AttributeDict(expected[i]), [i, method_name]
 
 
@@ -351,11 +311,11 @@ def test_cronos_transfer_source_tokens_with_proxy(ibc):
     w3 = ibc.cronos.w3
     start = w3.eth.get_block_number()
     amount, contract = cronos_transfer_source_tokens_with_proxy(ibc)
-    logs = get_logs(w3, start)
+    logs = get_logs_since(w3, CONTRACT, start)
     escrow = get_escrow_address(cli, channel)
     dst_adr = ibc.chainmain.cosmos_cli().address("signer2")
     expected = get_transfer_source_tokens_topics(dst_adr, amount, contract, escrow)
     assert len(logs) == len(expected)
     for i, log in enumerate(logs):
-        method_name, args = get_topic_data(w3, log)
+        method_name, args = get_topic_data(w3, method_map, contract_info, log)
         assert args == AttributeDict(expected[i]), [i, method_name]