implemented mario feedback

Author: felix314159

src/ethereum_test_rpc/rpc.py

@@ -26,7 +26,6 @@
 )
 
 logger = get_logger(__name__)
-
 BlockNumberType = int | Literal["latest", "earliest", "pending"]
 
 
@@ -81,14 +80,17 @@ def post_request(
         self,
         *,
         method: str,
-        params: Any | None = None,
+        params: List[Any] | None = None,
         extra_headers: Dict | None = None,
         request_id: int | str | None = None,
         timeout: int | None = None,
     ) -> Any:
         """Send JSON-RPC POST request to the client RPC server at port defined in the url."""
         if extra_headers is None:
             extra_headers = {}
+        if params is None:
+            params = []
+
         assert self.namespace, "RPC namespace not set"
 
         next_request_id_counter = next(self.request_id_counter)
@@ -106,8 +108,7 @@ def post_request(
         }
         headers = base_header | extra_headers
 
-        # print(f"Sending RPC request to {self.url}, timeout is set to {timeout}...")
-        print(f"Sending RPC request, timeout is set to {timeout}...")  # don't leak url in logs
+        logger.debug(f"Sending RPC request, timeout is set to {timeout}...")
         response = requests.post(self.url, json=json, headers=headers, timeout=timeout)
         response.raise_for_status()
         response_json = response.json()
@@ -145,7 +146,7 @@ def config(self, timeout: int | None = None):
         try:
             response = self.post_request(method="config", timeout=timeout)
             if response is None:
-                print("eth_config request: failed to get response")
+                logger.warning("eth_config request: failed to get response")
                 return None
             return EthConfigResponse.model_validate(
                 response, context=self.response_validation_context
@@ -154,7 +155,7 @@ def config(self, timeout: int | None = None):
             pprint(e.errors())
             raise e
         except Exception as e:
-            print(f"exception occurred when sending JSON-RPC request: {e}")
+            logger.error(f"exception occurred when sending JSON-RPC request: {e}")
             raise e
 
     def chain_id(self) -> int:
@@ -211,7 +212,7 @@ def get_transaction_by_hash(self, transaction_hash: Hash) -> TransactionByHashRe
         """`eth_getTransactionByHash`: Returns transaction details."""
         try:
             response = self.post_request(
-                method="getTransactionByHash", params=f"{transaction_hash}"
+                method="getTransactionByHash", params=[f"{transaction_hash}"]
             )
             if response is None:
                 return None
@@ -245,7 +246,7 @@ def send_raw_transaction(
         try:
             response = self.post_request(
                 method="sendRawTransaction",
-                params=f"{transaction_rlp.hex()}",
+                params=[transaction_rlp.hex()],
                 request_id=request_id,  # noqa: E501
             )
 
@@ -261,7 +262,7 @@ def send_transaction(self, transaction: Transaction) -> Hash:
         try:
             response = self.post_request(
                 method="sendRawTransaction",
-                params=f"{transaction.rlp().hex()}",
+                params=[transaction.rlp().hex()],
                 request_id=transaction.metadata_string(),  # noqa: E501
             )
 
@@ -431,7 +432,7 @@ def forkchoice_updated(
         if payload_attributes is None:
             params = [to_json(forkchoice_state)]
         else:
-            params = [to_json(forkchoice_state), to_json(payload_attributes)]
+            params = [to_json(forkchoice_state), None]
 
         return ForkchoiceUpdateResponse.model_validate(
             self.post_request(
@@ -456,7 +457,7 @@ def get_payload(
         return GetPayloadResponse.model_validate(
             self.post_request(
                 method=method,
-                params=f"{payload_id}",
+                params=[f"{payload_id}"],
             ),
             context=self.response_validation_context,
         )
@@ -499,4 +500,4 @@ class AdminRPC(BaseRPC):
 
     def add_peer(self, enode: str) -> bool:
         """`admin_addPeer`: Add a peer by enode URL."""
-        return self.post_request(method="addPeer", params=enode)
+        return self.post_request(method="addPeer", params=[enode])

src/pytest_plugins/execute/eth_config/eth_config.py

@@ -58,10 +58,10 @@ def pytest_addoption(parser):
         action="store",
         dest="clients",
         type=str,
-        default="besu,erigon,geth,nethermind,reth",
-        help="Comma-separated list of clients to be tested in majority mode. This flag will be "
-        "ignored when you pass a value for the network-config-file flag. Default: "
-        "besu,erigon,geth,nethermind,reth",
+        default=None,
+        help="Comma-separated list of clients to be tested in majority mode. Example: "
+        '"besu,erigon,geth,nethermind,nimbusel,reth"\nIf you do not pass a value, majority mode '
+        "testing will be disabled.",
     )
     eth_config_group.addoption(
         "--genesis-config-file",
@@ -167,15 +167,15 @@ def pytest_configure(config: pytest.Config) -> None:
     # Test out the RPC endpoint to be able to fail fast if it's not working
     eth_rpc = EthRPC(rpc_endpoint)
     try:
-        print("Will now perform a connection check (request chain_id)..")
+        logger.debug("Will now perform a connection check (request chain_id)..")
         chain_id = eth_rpc.chain_id()
-        print(f"Connection check ok (successfully got chain id {chain_id})")
+        logger.debug(f"Connection check ok (successfully got chain id {chain_id})")
     except Exception as e:
         pytest.exit(f"Could not connect to RPC endpoint {rpc_endpoint}: {e}")
     try:
-        print("Will now briefly check whether eth_config is supported by target rpc..")
+        logger.debug("Will now briefly check whether eth_config is supported by target rpc..")
         eth_rpc.config()
-        print("Connection check ok (successfully got eth_config response)")
+        logger.debug("Connection check ok (successfully got eth_config response)")
     except Exception as e:
         pytest.exit(f"RPC endpoint {rpc_endpoint} does not support `eth_config`: {e}")
 
@@ -186,12 +186,6 @@ def rpc_endpoint(request) -> str:
     return request.config.getoption("rpc_endpoint")
 
 
-# @pytest.fixture(autouse=True, scope="session")
-# def eth_rpc(rpc_endpoint: str) -> EthRPC:
-#     """Initialize ethereum RPC client for the execution client under test."""
-#     return EthRPC(rpc_endpoint)
-
-
 def all_rpc_endpoints(config) -> Dict[str, List[EthRPC]]:
     """Derive a mapping of exec clients to the RPC URLs they are reachable at."""
     rpc_endpoint = config.getoption("rpc_endpoint")
@@ -231,7 +225,9 @@ def pytest_generate_tests(metafunc: pytest.Metafunc):
     if metafunc.definition.name == "test_eth_config_majority":
         if len(all_rpc_endpoints_dict) < 2:
             # The test function is not run because we only have a single client, so no majority comparison  # noqa: E501
-            print("Skipping eth_config majority because less than 2 exec clients were passed")
+            logger.info(
+                "Skipping eth_config majority because less than 2 exec clients were passed"
+            )
             metafunc.parametrize(
                 ["all_rpc_endpoints"],
                 [],

src/pytest_plugins/execute/eth_config/execute_eth_config.py

@@ -8,9 +8,12 @@
 import pytest
 
 from ethereum_test_rpc import EthConfigResponse, EthRPC
+from pytest_plugins.logging import get_logger
 
 from .types import NetworkConfig
 
+logger = get_logger(__name__)
+
 
 @pytest.fixture(scope="function")
 def eth_config_response(eth_rpc: List[EthRPC]) -> EthConfigResponse | None:
@@ -34,7 +37,6 @@ def current_time() -> int:
 @pytest.fixture(scope="function")
 def expected_eth_config(network: NetworkConfig, current_time: int) -> EthConfigResponse:
     """Calculate the current fork value to verify against the client's response."""
-    print(f"Network provided: {network}, Type: {type(network)}")
     return network.get_eth_config(current_time)
 
 
@@ -191,7 +193,7 @@ def test_eth_config_majority(
             response = eth_rpc_target.config(timeout=10)
             if response is None:
                 # safely split url to not leak rpc_endpoint in logs
-                print(
+                logger.warning(
                     f"When trying to get eth_config from {eth_rpc_target} a problem occurred"  # problem itself is logged by .config() call # noqa: E501
                 )
                 continue
@@ -201,7 +203,7 @@ def test_eth_config_majority(
             client_to_url_used_dict[exec_client] = (
                 eth_rpc_target.url
             )  # remember which cl+el combination was used  # noqa: E501
-            print(f"Response of {exec_client}: {response_str}\n\n")
+            logger.info(f"Response of {exec_client}: {response_str}\n\n")
 
             break  # no need to gather more responses for this client
 
@@ -218,7 +220,7 @@ def test_eth_config_majority(
     for client in responses.keys():
         response_bytes = json.dumps(responses[client], sort_keys=True).encode("utf-8")
         response_hash = sha256(response_bytes).digest().hex()
-        print(f"Response hash of client {client}: {response_hash}")
+        logger.info(f"Response hash of client {client}: {response_hash}")
         client_to_hash_dict[client] = response_hash
 
     # if not all responses have the same hash there is a critical consensus issue
@@ -236,4 +238,4 @@ def test_eth_config_majority(
         )
     assert expected_hash != ""
 
-    print("All clients returned the same eth_config response. Test has been passed!")
+    logger.info("All clients returned the same eth_config response. Test has been passed!")