added logging

Author: felix314159

src/ethereum_test_rpc/rpc.py

@@ -1,5 +1,6 @@
 """JSON-RPC methods and helper functions for EEST consume based hive simulators."""
 
+import json
 import time
 from itertools import count
 from pprint import pprint
@@ -11,6 +12,7 @@
 
 from ethereum_test_base_types import Address, Bytes, Hash, to_json
 from ethereum_test_types import Transaction
+from pytest_plugins.logging import get_logger
 
 from .types import (
     ForkchoiceState,
@@ -24,6 +26,7 @@
 )
 
 BlockNumberType = Union[int, Literal["latest", "earliest", "pending"]]
+logger = get_logger(__name__)
 
 
 class SendTransactionExceptionError(Exception):
@@ -94,6 +97,11 @@ def post_request(self, method: str, *params: Any, extra_headers: Dict | None = N
         }
         headers = base_header | self.extra_headers | extra_headers
 
+        # debugging, estimate payload size
+        payload_json = json.dumps(payload)  # pydantic.json
+        payload_size_mb = len(payload_json.encode("utf-8")) / (1024 * 1024)
+        logger.info(f"I am about to send an RPC of approximated size: {payload_size_mb:.2f} MB")
+
         response = requests.post(self.url, json=payload, headers=headers)
         response.raise_for_status()
         response_json = response.json()
@@ -181,8 +189,9 @@ def gas_price(self) -> int:
     def send_raw_transaction(self, transaction_rlp: Bytes) -> Hash:
         """`eth_sendRawTransaction`: Send a transaction to the client."""
         try:
-            result_hash = Hash(self.post_request("sendRawTransaction", f"{transaction_rlp.hex()}"))
-            assert result_hash is not None
+            tx_rlp_hex = transaction_rlp.hex()
+            result_hash = Hash(self.post_request("sendRawTransaction", f"{tx_rlp_hex}"))
+            assert result_hash is not None, "result_hash seems to be None, critical error!"
             return result_hash
         except Exception as e:
             shortened_rlp_error_message = str(e)  # signal in console that you don't see full rlp

tests/osaka/eip7594_peerdas/test_get_blobs.py

@@ -18,12 +18,15 @@
     Transaction,
     TransactionException,
 )
+from pytest_plugins.logging import get_logger
 
 from .spec import ref_spec_7594
 
 REFERENCE_SPEC_GIT_PATH = ref_spec_7594.git_path
 REFERENCE_SPEC_VERSION = ref_spec_7594.version
 
+logger = get_logger(__name__)
+
 
 @pytest.fixture
 def destination_account(pre: Alloc) -> Address:
@@ -197,6 +200,8 @@ def generate_full_blob_tests(
     parametrized for each different fork.
     """
     max_blobs = fork.max_blobs_per_block()
+    logger.info(f"MAX_BLOBS value for fork {fork}: {max_blobs}")
+
     return [
         pytest.param(
             [  # Txs