forked from cerc-io/laconicd-deprecated
15db2d3849
121 lines
3.7 KiB
Python
121 lines
3.7 KiB
Python
import base64
|
|||
import json
|
|||
import subprocess
|
|||
from pathlib import Path
|
|||
|
|||
import pytest
|
|||
import requests
|
|||
from pystarport import ports
|
|||
|
|||
from .network import setup_custom_ethermint
|
|||
from .utils import (
|
|||
CONTRACTS,
|
|||
decode_bech32,
|
|||
deploy_contract,
|
|||
supervisorctl,
|
|||
wait_for_port,
|
|||
)
|
|||
|
|||
|
|||
@pytest.fixture(scope="module")
|
|||
def custom_ethermint(tmp_path_factory):
|
|||
path = tmp_path_factory.mktemp("grpc-only")
|
|||
|
|||
# reuse rollback-test config because it has an extra fullnode
|
|||
yield from setup_custom_ethermint(
|
|||
path,
|
|||
26400,
|
|||
Path(__file__).parent / "configs/rollback-test.jsonnet",
|
|||
)
|
|||
|
|||
|
|||
def grpc_eth_call(port: int, args: dict, chain_id=None, proposer_address=None):
|
|||
"""
|
|||
do a eth_call through grpc gateway directly
|
|||
"""
|
|||
params = {
|
|||
"args": base64.b64encode(json.dumps(args).encode()).decode(),
|
|||
}
|
|||
if chain_id is not None:
|
|||
params["chain_id"] = str(chain_id)
|
|||
if proposer_address is not None:
|
|||
params["proposer_address"] = str(proposer_address)
|
|||
return requests.get(
|
|||
f"http://localhost:{port}/ethermint/evm/v1/eth_call", params
|
|||
).json()
|
|||
|
|||
|
|||
@pytest.mark.skip(
|
|||
reason="undeterministic test - https://github.com/evmos/ethermint/issues/1530"
|
|||
)
|
|||
def test_grpc_mode(custom_ethermint):
|
|||
"""
|
|||
- restart a fullnode in grpc-only mode
|
|||
- test the grpc queries all works
|
|||
"""
|
|||
w3 = custom_ethermint.w3
|
|||
contract, _ = deploy_contract(w3, CONTRACTS["TestChainID"])
|
|||
assert 9000 == contract.caller.currentChainID()
|
|||
|
|||
msg = {
|
|||
"to": contract.address,
|
|||
"data": contract.encodeABI(fn_name="currentChainID"),
|
|||
}
|
|||
api_port = ports.api_port(custom_ethermint.base_port(2))
|
|||
# in normal mode, grpc query works even if we don't pass chain_id explicitly
|
|||
rsp = grpc_eth_call(api_port, msg)
|
|||
print(rsp)
|
|||
assert "code" not in rsp, str(rsp)
|
|||
assert 9000 == int.from_bytes(base64.b64decode(rsp["ret"].encode()), "big")
|
|||
|
|||
supervisorctl(
|
|||
custom_ethermint.base_dir / "../tasks.ini", "stop", "ethermint_9000-1-node2"
|
|||
)
|
|||
|
|||
# run grpc-only mode directly with existing chain state
|
|||
with (custom_ethermint.base_dir / "node2.log").open("w") as logfile:
|
|||
proc = subprocess.Popen(
|
|||
[
|
|||
"ethermintd",
|
|||
"start",
|
|||
"--grpc-only",
|
|||
"--home",
|
|||
custom_ethermint.base_dir / "node2",
|
|||
],
|
|||
stdout=logfile,
|
|||
stderr=subprocess.STDOUT,
|
|||
)
|
|||
try:
|
|||
# wait for grpc and rest api ports
|
|||
grpc_port = ports.grpc_port(custom_ethermint.base_port(2))
|
|||
wait_for_port(grpc_port)
|
|||
wait_for_port(api_port)
|
|||
|
|||
# in grpc-only mode, grpc query don't work if we don't pass chain_id
|
|||
rsp = grpc_eth_call(api_port, msg)
|
|||
assert rsp["code"] != 0, str(rsp)
|
|||
assert "invalid chain ID" in rsp["message"]
|
|||
|
|||
# it don't works without proposer address neither
|
|||
rsp = grpc_eth_call(api_port, msg, chain_id=9000)
|
|||
assert rsp["code"] != 0, str(rsp)
|
|||
assert "validator does not exist" in rsp["message"]
|
|||
|
|||
# pass the first validator's consensus address to grpc query
|
|||
cons_addr = decode_bech32(
|
|||
custom_ethermint.cosmos_cli(0).consensus_address()
|
|||
)
|
|||
|
|||
# should work with both chain_id and proposer_address set
|
|||
rsp = grpc_eth_call(
|
|||
api_port,
|
|||
msg,
|
|||
chain_id=100,
|
|||
proposer_address=base64.b64encode(cons_addr).decode(),
|
|||
)
|
|||
assert "code" not in rsp, str(rsp)
|
|||
assert 100 == int.from_bytes(base64.b64decode(rsp["ret"].encode()), "big")
|
|||
finally:
|
|||
proc.terminate()
|
|||
proc.wait()
|