refactor: centralize hardhat configuration

Author: danieljrc888

backend/config/__init__.py

@@ -0,0 +1 @@
+"""Configuration package for backend services."""

backend/config/hardhat_config.py

@@ -0,0 +1,31 @@
+"""Centralized configuration for Hardhat settings."""
+
+import os
+from web3 import Web3
+
+
+class HardhatConfig:
+    """Configuration class for Hardhat network settings."""
+
+    @staticmethod
+    def get_port() -> str:
+        """Get the Hardhat port from environment variable."""
+        return os.environ.get("HARDHAT_PORT", "8545")
+
+    @staticmethod
+    def get_base_url() -> str:
+        """Get the Hardhat base URL from environment variable."""
+        return os.environ.get("HARDHAT_URL", "http://localhost")
+
+    @staticmethod
+    def get_full_url() -> str:
+        """Get the complete Hardhat URL with port."""
+        port = HardhatConfig.get_port()
+        url = HardhatConfig.get_base_url()
+        return f"{url}:{port}"
+
+    @staticmethod
+    def get_web3_instance() -> Web3:
+        """Get a Web3 instance connected to Hardhat network."""
+        hardhat_url = HardhatConfig.get_full_url()
+        return Web3(Web3.HTTPProvider(hardhat_url))

backend/database_handler/transactions_processor.py

@@ -15,7 +15,7 @@
 import time
 from backend.domain.types import TransactionType
 from web3 import Web3
-import os
+from backend.config.hardhat_config import HardhatConfig
 
 
 class TransactionAddressFilter(Enum):
@@ -105,10 +105,7 @@ def __init__(
         self.session = session
 
         # Connect to Hardhat Network
-        port = os.environ.get("HARDHAT_PORT")
-        url = os.environ.get("HARDHAT_URL")
-        hardhat_url = f"{url}:{port}"
-        self.web3 = Web3(Web3.HTTPProvider(hardhat_url))
+        self.web3 = HardhatConfig.get_web3_instance()
 
     @staticmethod
     def _parse_transaction_data(transaction_data: Transactions) -> dict:

backend/protocol_rpc/endpoint_generator.py

@@ -11,10 +11,10 @@
 from flask_jsonrpc.exceptions import JSONRPCError
 from functools import partial, wraps
 import requests
-import os
 import traceback
 from backend.protocol_rpc.aio import run_in_main_server_loop
 from backend.protocol_rpc.message_handler.base import MessageHandler
+from backend.config.hardhat_config import HardhatConfig
 
 
 def get_json_rpc_method_name(function: Callable, method_name: str | None = None):
@@ -67,9 +67,7 @@ def unfold(x: typing.Any):
 def setup_eth_method_handler(jsonrpc: JSONRPC):
     """Forwards eth_ methods to Hardhat if no own implementation is available"""
     app = jsonrpc.app
-    port = os.environ.get("HARDHAT_PORT")
-    url = os.environ.get("HARDHAT_URL")
-    HARDHAT_URL = f"{url}:{port}"
+    hardhat_url = HardhatConfig.get_full_url()
 
     @app.before_request
     def handle_eth_methods():
@@ -89,7 +87,7 @@ def handle_eth_methods():
                         try:
                             with requests.Session() as http:
                                 result = http.post(
-                                    HARDHAT_URL,
+                                    hardhat_url,
                                     json=request_json,
                                     headers={"Content-Type": "application/json"},
                                 ).json()

backend/rollup/consensus_service.py

@@ -1,6 +1,4 @@
 import json
-import os
-from web3 import Web3
 from typing import Optional, Dict, Any
 from pathlib import Path
 from hexbytes import HexBytes
@@ -9,6 +7,7 @@
 from backend.rollup.default_contracts.consensus_main import (
     get_default_consensus_main_contract,
 )
+from backend.config.hardhat_config import HardhatConfig
 
 
 class ConsensusService:
@@ -17,10 +16,7 @@ def __init__(self):
         Initialize the ConsensusService class
         """
         # Connect to Hardhat Network
-        port = os.environ.get("HARDHAT_PORT")
-        url = os.environ.get("HARDHAT_URL")
-        hardhat_url = f"{url}:{port}"
-        self.web3 = Web3(Web3.HTTPProvider(hardhat_url))
+        self.web3 = HardhatConfig.get_web3_instance()
 
         self.web3_connected = self.web3.is_connected()
 

tests/hardhat/docker-compose.yml

@@ -30,4 +30,5 @@ services:
       hardhat:
         condition: service_healthy
     environment:
-      - HARDHAT_URL=http://hardhat:8545
+      - HARDHAT_URL=http://hardhat
+      - HARDHAT_PORT=8545

tests/hardhat/test_hardhat.py

@@ -1,7 +1,6 @@
-from web3 import Web3
 import json
 from eth_account import Account
-import os
+from backend.config.hardhat_config import HardhatConfig
 
 
 def test_eth_account():
@@ -41,8 +40,7 @@ def connect_to_hardhat():
     Raises:
         Exception: If the connection to the Hardhat network fails.
     """
-    hardhat_url = os.environ.get("HARDHAT_URL")
-    web3 = Web3(Web3.HTTPProvider(hardhat_url))
+    web3 = HardhatConfig.get_web3_instance()
 
     # Check connection
     if not web3.is_connected():