feat: add autoflake pre-commit hook to remove unused imports

.pre-commit-config.yaml

@@ -9,6 +9,11 @@ repos:
       - id: check-merge-conflict
       - id: no-commit-to-branch
         args: ["--branch", "main"]
+  - repo: https://github.com/PyCQA/autoflake
+    rev: v2.3.1
+    hooks:
+      - id: autoflake
+        args: ["--remove-all-unused-imports", "--in-place"]
   # Copied from https://black.readthedocs.io/en/stable/integrations/source_version_control.html
   - repo: https://github.com/psf/black-pre-commit-mirror
     rev: 24.4.2

asgi.py

@@ -4,7 +4,6 @@
 """
 
 import os
-import sys
 
 # Set production environment
 os.environ.setdefault("UVICORN_WORKER", "true")

backend/consensus/base.py

@@ -101,8 +101,6 @@
 class NoValidatorsAvailableError(Exception):
     """Raised when no validators are available to process a transaction."""
 
-    pass
-
 
 def _redact_consensus_data_for_log(consensus_data_dict: dict) -> dict:
     """
@@ -1392,7 +1390,6 @@ async def handle(
         Args:
             context (TransactionContext): The context of the transaction.
         """
-        pass
 
 
 class PendingState(TransactionState):

backend/consensus/monitoring.py

@@ -8,8 +8,7 @@
 import psutil
 import threading
 from typing import Dict, Any, Optional, Set
-from dataclasses import dataclass, field
-from datetime import datetime
+from dataclasses import dataclass
 from loguru import logger
 from contextlib import asynccontextmanager, contextmanager
 

backend/consensus/worker.py

@@ -3,21 +3,14 @@
 import os
 import asyncio
 import time
-import traceback
-import threading
 import uuid
 from contextlib import asynccontextmanager
 from typing import Callable, Optional, Any
-from datetime import datetime, timedelta
 from sqlalchemy.orm import Session
 from sqlalchemy import text
 
 from backend.database_handler.models import Transactions, TransactionStatus
 from backend.database_handler.transactions_processor import TransactionsProcessor
-from backend.database_handler.chain_snapshot import ChainSnapshot
-from backend.database_handler.contract_snapshot import ContractSnapshot
-from backend.database_handler.contract_processor import ContractProcessor
-from backend.database_handler.accounts_manager import AccountsManager
 from backend.database_handler.errors import ContractNotFoundError
 from backend.domain.types import Transaction
 from backend.node.genvm.error_codes import GenVMInternalError

backend/consensus/worker_service.py

@@ -20,7 +20,6 @@
 from backend.protocol_rpc.configuration import GlobalConfiguration
 from backend.rollup.consensus_service import ConsensusService
 import backend.validators as validators
-from backend.database_handler.models import Base
 from loguru import logger
 
 from backend.protocol_rpc.app_lifespan import create_genvm_manager
@@ -609,7 +608,6 @@ def health_check():
                 except Exception as e:
                     # Log the error but don't fail the health check
                     logger.error(f"Error parsing blocked_at timestamp: {e}")
-                    pass
             current_txs.append(tx)
 
     return {

backend/database_handler/chain_snapshot.py

@@ -1,15 +1,14 @@
 # database_handler/chain_snapshot.py
 
 from typing import List
-from sqlalchemy.orm import Session, selectinload, load_only
+from sqlalchemy.orm import Session, selectinload
 from collections import defaultdict
 
 from backend.database_handler.transactions_processor import (
     TransactionStatus,
     Transactions,
 )
 from .transactions_processor import TransactionsProcessor
-from backend.database_handler.validators_registry import ValidatorsRegistry
 
 
 class ChainSnapshot:

backend/database_handler/contract_processor.py

@@ -1,6 +1,5 @@
 # database_handler/contract_processor.py
 from .models import CurrentState
-from .contract_snapshot import ContractSnapshot
 from sqlalchemy.orm import Session
 
 

backend/database_handler/migration/versions/3bc34e44eb72_add_providers_unique_constraint.py

@@ -9,7 +9,6 @@
 from typing import Sequence, Union
 
 from alembic import op
-import sqlalchemy as sa
 
 
 # revision identifiers, used by Alembic.

backend/database_handler/migration/versions/67943badcbe9_add_activated_status.py

@@ -10,7 +10,6 @@
 
 from alembic import op
 import sqlalchemy as sa
-from sqlalchemy.dialects import postgresql
 
 
 # revision identifiers, used by Alembic.

backend/database_handler/migration/versions/6fd3e2cea05b_add_default_to_llm_providers.py

@@ -10,7 +10,6 @@
 
 from alembic import op
 import sqlalchemy as sa
-from sqlalchemy.orm import Session
 from sqlalchemy import table, column
 from backend.node.create_nodes.providers import get_default_providers
 

backend/database_handler/migration/versions/99015c5b5b78_add_snapshot_table.py

@@ -10,7 +10,6 @@
 
 from alembic import op
 import sqlalchemy as sa
-from sqlalchemy.dialects import postgresql
 
 # revision identifiers, used by Alembic.
 revision: str = "99015c5b5b78"

backend/database_handler/migration/versions/ab256b41602a_remove_invalid_models.py

@@ -9,7 +9,6 @@
 from typing import Sequence, Union
 
 from alembic import op
-import sqlalchemy as sa
 
 
 # revision identifiers, used by Alembic.

backend/database_handler/migration/versions/db38e78684a8_add_providers_table.py

@@ -10,10 +10,8 @@
 
 from alembic import op
 import sqlalchemy as sa
-from sqlalchemy.orm import sessionmaker
 from sqlalchemy.dialects import postgresql
 
-from backend.database_handler.llm_providers import LLMProviderRegistry
 
 # revision identifiers, used by Alembic.
 revision: str = "db38e78684a8"

backend/database_handler/transactions_processor.py

@@ -15,7 +15,6 @@
 import time
 from backend.domain.types import TransactionType
 from web3 import Web3
-import os
 from backend.consensus.types import ConsensusRound
 from backend.consensus.utils import determine_consensus_from_votes
 from backend.rollup.web3_pool import Web3ConnectionPool

backend/domain/types.py

@@ -4,7 +4,6 @@
 
 from dataclasses import dataclass, field
 import datetime
-import decimal
 from enum import Enum, IntEnum
 import os
 from backend.database_handler.models import TransactionStatus

backend/node/base.py

@@ -1,5 +1,3 @@
-from contextlib import redirect_stdout
-from dataclasses import asdict
 import datetime
 import functools
 import json
@@ -22,7 +20,6 @@
 from backend.database_handler.contract_snapshot import ContractSnapshot
 from backend.node.types import Receipt, ExecutionMode, Vote, ExecutionResultStatus
 from backend.protocol_rpc.message_handler.base import IMessageHandler
-from .genvm.origin import base_host
 from .genvm.origin import logger as genvm_logger
 from .genvm.origin import public_abi
 

backend/node/genvm/base.py

@@ -21,11 +21,9 @@
 import base64
 import asyncio
 import socket
-import logging
 import backend.node.genvm.origin.base_host as genvmhost
 import collections.abc
 import functools
-import datetime
 import abc
 import time
 import copy
@@ -197,7 +195,7 @@ def provide_result(
                     error_code=error_code,
                 )
         elif res.result_kind == ResultCode.INTERNAL_ERROR:
-            from loguru import logger as _ilog
+            pass
 
             error_ctx = None
 

backend/node/genvm/origin/base_host.py

@@ -3,7 +3,6 @@
 import collections.abc
 import asyncio
 import os
-import sys
 import abc
 import json
 import time
@@ -12,7 +11,6 @@
 
 from dataclasses import dataclass
 
-from pathlib import Path
 
 from . import calldata as gvm_calldata
 from . import host_fns

backend/node/genvm/origin/host_fns.py

@@ -1,7 +1,6 @@
 # This file is auto-generated. Do not edit!
 
-from enum import IntEnum, StrEnum
-import typing
+from enum import IntEnum
 
 
 class Methods(IntEnum):

backend/protocol_rpc/app_lifespan.py

@@ -314,7 +314,6 @@ def get_session() -> Session:
 
     # Import registers RPC methods via decorators (module import has side effects).
     logger.info("[STARTUP] Registering RPC methods")
-    from backend.protocol_rpc import rpc_methods
 
     rpc_method_count = 0
     for definition in rpc.to_list():

backend/protocol_rpc/broadcast.py

@@ -6,7 +6,6 @@
 from collections import defaultdict
 from contextlib import AbstractAsyncContextManager
 from dataclasses import dataclass
-from types import SimpleNamespace
 from typing import Dict, Iterable
 
 

backend/protocol_rpc/calls_intercept/__init__.py

@@ -8,9 +8,7 @@ class CallHandler(ABC):
     @abstractmethod
     def can_handle(self, data: str) -> bool:
         """Check if this handler can process the given call data."""
-        pass
 
     @abstractmethod
     def handle(self, transactions_processor: TransactionsProcessor, data: str) -> str:
         """Handle the contract call and return the result."""
-        pass

backend/protocol_rpc/contract_linter.py

@@ -3,7 +3,7 @@
 Provides validation and linting for GenLayer smart contracts.
 """
 
-from typing import Dict, List, Any, Optional
+from typing import Dict, Any
 from backend.protocol_rpc.exceptions import JSONRPCError
 
 
@@ -12,7 +12,6 @@ class ContractLinter:
 
     def __init__(self):
         """Initialize the ContractLinter."""
-        pass
 
     def lint_contract(
         self, source_code: str, filename: str = "contract.py"
@@ -38,7 +37,6 @@ def lint_contract(
 
         try:
             from genvm_linter.linter import GenVMLinter
-            from genvm_linter.rules import Severity
 
             linter = GenVMLinter()
             results = linter.lint_source(source_code, filename)

backend/protocol_rpc/endpoints.py

@@ -27,7 +27,6 @@
 from backend.database_handler.accounts_manager import AccountsManager
 from backend.database_handler.validators_registry import (
     ValidatorsRegistry,
-    ModifiableValidatorsRegistry,
 )
 
 from backend.node.create_nodes.create_nodes import (

backend/protocol_rpc/explorer/queries.py

@@ -4,7 +4,7 @@
 import math
 from typing import Optional
 
-from sqlalchemy import func, or_, text
+from sqlalchemy import func, or_
 from sqlalchemy.orm import Session, defer
 
 from backend.database_handler.models import (

backend/protocol_rpc/fastapi_endpoint_generator.py

@@ -9,7 +9,7 @@
 import collections.abc
 import dataclasses
 import base64
-from functools import partial, wraps
+from functools import partial
 from typing import Callable, Dict, Any, Optional
 
 from backend.protocol_rpc.message_handler.fastapi_handler import MessageHandler

backend/protocol_rpc/fastapi_rpc_handler.py

@@ -2,8 +2,6 @@
 FastAPI RPC handler that uses the endpoint generator for proper registration.
 """
 
-import asyncio
-import inspect
 from typing import Any, Dict, List, Optional, Union
 from pydantic import BaseModel, ConfigDict
 from sqlalchemy.orm import Session

backend/protocol_rpc/fastapi_server.py

@@ -8,7 +8,6 @@
 from fastapi import Depends, FastAPI, Request, Response, WebSocket
 from fastapi.middleware.cors import CORSMiddleware
 from fastapi.responses import JSONResponse
-from fastapi.staticfiles import StaticFiles
 from starlette.requests import ClientDisconnect
 
 # Load environment variables early so SENTRY_DSN is available for initialization

backend/protocol_rpc/message_handler/fastapi_handler.py

@@ -4,7 +4,6 @@
 import json
 import os
 import sys
-import traceback
 from functools import wraps
 from typing import Any
 

backend/protocol_rpc/message_handler/worker_handler.py

@@ -5,7 +5,6 @@
 """
 
 import os
-import json
 import asyncio
 from typing import Optional
 import aiohttp

backend/protocol_rpc/rpc_endpoint_manager.py

@@ -3,7 +3,6 @@
 from __future__ import annotations
 
 import inspect
-import json
 import traceback
 from contextlib import AsyncExitStack
 from dataclasses import dataclass, field

backend/protocol_rpc/transactions_parser.py

@@ -1,7 +1,7 @@
 # rpc/transaction_utils.py
 
 import rlp
-from rlp.sedes import text, binary, big_endian_int
+from rlp.sedes import binary, big_endian_int
 from rlp.exceptions import DeserializationError, SerializationError
 from eth_account import Account
 from eth_account._utils.legacy_transactions import Transaction

backend/protocol_rpc/validators_init.py

@@ -110,7 +110,7 @@ async def initialize_validators(
 
     # Import necessary dependencies for validator creation
     from backend.database_handler.accounts_manager import AccountsManager
-    from backend.domain.types import Validator, LLMProvider
+    from backend.domain.types import Validator
     from backend.node.create_nodes.providers import get_default_provider_for
 
     accounts_manager = AccountsManager(db_session)

backend/rollup/consensus_service.py

@@ -1,6 +1,4 @@
 import json
-import os
-from web3 import Web3
 from eth_utils import keccak, to_bytes, to_hex
 from typing import Optional, Dict, Any
 from pathlib import Path

backend/validators/__init__.py

@@ -4,12 +4,10 @@
 import typing
 import contextlib
 import dataclasses
-import logging
 import os
 import random
 
 from copy import deepcopy
-from pathlib import Path
 
 import backend.database_handler.validators_registry as vr
 from sqlalchemy.orm import Session