chore: fix mypy errors [no-untyped-def] (#638)

* chore: fix mypy errors [no-untyped-def]

* chore: `mypyc` for python3.8

* chore: `black .`

* chore: `mypyc` for python3.9

* chore: `mypyc` for python3.10

* chore: `mypyc` for python3.11

* chore: `mypyc` for python3.12

---------

Co-authored-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>

Author: BobTheBuidler

build/ops.txt

@@ -18,7 +18,7 @@
 patch_eth_utils()
 
 
-def _configure_concurrent_future_work_queue_size():
+def _configure_concurrent_future_work_queue_size() -> None:
     """
     Configures the concurrent futures process pool to allow for a larger number of queued calls.
 

dank_mids/__init__.py

@@ -54,7 +54,7 @@ def __init__(
         controller: "DankMiddlewareController",
         multicalls: Multicalls,
         rpc_calls: JSONRPCBatch,
-    ):
+    ) -> None:
         self.controller = controller
         """The controller managing this batch."""
 
@@ -64,7 +64,7 @@ def __init__(
         self.rpc_calls = rpc_calls
         """A list of individual RPC calls or multicalls."""
 
-    def __repr__(self):
+    def __repr__(self) -> str:
         return f"<dank_mids.DankBatch object at {hex(id(self))}>"
 
     def __await__(self) -> Generator[Any, None, None]:

dank_mids/_batch.py

@@ -19,7 +19,7 @@
 class _FileHelper(metaclass=abc.ABCMeta):
     path = f"{os.path.expanduser('~')}/.dank_mids/debug"
 
-    def __init__(self, chainid: int):
+    def __init__(self, chainid: int) -> None:
         if not isinstance(chainid, int):
             raise TypeError(f"`chainid` must be an integer. You passed {chainid}") from None
 

dank_mids/_debugging/_base.py

@@ -27,7 +27,7 @@ class FailedRequestWriter(_CSVWriter):
     column_names = "request_type", "request_uid", "request_length", "error", "request_data"
     """The names of the columns in the CSV file."""
 
-    def __init__(self, chainid: int, failure_type: Type[BaseException]):
+    def __init__(self, chainid: int, failure_type: Type[BaseException]) -> None:
         """
         Initialize the FailedRequestWriter.
 
@@ -65,7 +65,7 @@ async def _record_failure(
         request_uid: Union[str, int],
         request_length: Union[int, Literal["unknown"]],
         request_data: Union[List["Request"], List["PartialRequest"], bytes],
-    ):
+    ) -> None:
         """
         Record a failed request to the CSV file.
 

dank_mids/_debugging/failures.py

@@ -1,5 +1,8 @@
 from a_sync.functools import cached_property_unsafe as cached_property
 
+from typing_extensions import Self
+
+
 MODES = "default", "application", "infura"
 
 
@@ -38,7 +41,7 @@ def infura(self):
         return self.mode == "infura"
 
     @property
-    def mode(self):
+    def mode(self) -> Self:
         """
         Retrieves the current operation mode.
 

dank_mids/_mode.py

@@ -226,7 +226,7 @@ def __init__(
         method: RPCEndpoint,
         params: Any,
         uid: Optional[str] = None,
-    ):  # sourcery skip: hoist-statement-from-if
+    ) -> None:  # sourcery skip: hoist-statement-from-if
         _request_base_init(self, controller, uid)
         if method[-4:] == "_raw":
             self.method = method[:-4]
@@ -534,7 +534,7 @@ def __set_exception(self, data: Exception) -> None:
             self.__log_set_exception(error_logger_log_debug, data)
         self._fut.set_exception(data)
 
-    def __log_set_exception(self, log_func: Callable[..., None], exc: Exception):
+    def __log_set_exception(self, log_func: Callable[..., None], exc: Exception) -> None:
         exc_type = type(exc).__name__
         log_func("%s for %s", exc_type, self)
         log_func("exception set: %s", repr(exc))
@@ -636,7 +636,7 @@ class _Batch(_RequestBase[List[_Response]], Iterable[_Request]):
 
     __slots__ = "calls", "_batcher", "_lock", "_done", "_daemon", "__dict__"
 
-    def __init__(self, controller: "DankMiddlewareController", calls: Iterable[_Request]):
+    def __init__(self, controller: "DankMiddlewareController", calls: Iterable[_Request]) -> None:
         _request_base_init(self, controller)
         self.calls = WeakList(calls)
         self._batcher = controller.batcher
@@ -746,7 +746,7 @@ def __init__(
         controller: "DankMiddlewareController",
         calls: Iterable[eth_call] = [],
         bid: Optional[BatchId] = None,
-    ):
+    ) -> None:
         # sourcery skip: default-mutable-arg
         _batch_init(self, controller, calls)
         self.bid = bid or self.controller.multicall_uid.next

dank_mids/_requests.py

@@ -70,10 +70,10 @@ def get_mapper(
 class IteratorProxy(Iterable[TValue]):
     """Wraps an iterator to return when iterated upon"""
 
-    def __init__(self, iterator: Iterator[TValue]):
+    def __init__(self, iterator: Iterator[TValue]) -> None:
         self.__wrapped = iterator
 
-    def __iter__(self):
+    def __iter__(self) -> Iterator[TValue]:
         try:
             return self.__dict__.pop("_IteratorProxy__wrapped")
         except KeyError as e:

dank_mids/_web3/abi.py

@@ -204,7 +204,7 @@ def bypass_get_code_formatter(eth: Type[BaseEth]) -> None:
 )
 
 
-def bypass_formatters(eth):
+def bypass_formatters(eth) -> None:
     """Executes a sequence of bypass methods to remove default formatters for ETH methods.
 
     Utilizes a predefined list of bypass methods to systematically modify the corresponding

dank_mids/_web3/method.py

@@ -13,7 +13,7 @@ class FunctionABI:
     for each unique set of ABI parameters, optimizing memory usage and performance.
     """
 
-    def __init__(self, **abi: Any):
+    def __init__(self, **abi: Any) -> None:
         """
         Initialize a FunctionABI instance with the given ABI information.
 

dank_mids/brownie_patch/_abi.py

@@ -1,5 +1,16 @@
 from decimal import Decimal
-from typing import Any, Awaitable, Callable, Dict, Generic, Iterable, List, Optional, TypeVar
+from typing import (
+    Any,
+    Awaitable,
+    Callable,
+    Dict,
+    Generator,
+    Generic,
+    Iterable,
+    List,
+    Optional,
+    TypeVar,
+)
 
 from a_sync import igather
 from brownie.convert.datatypes import EthAddress
@@ -27,7 +38,7 @@ class _DankMethodMixin(Generic[_EVMType]):
 
     _prep_request_data: Callable[..., Awaitable[BytesLike]]
 
-    def __init__(self):
+    def __init__(self) -> None:
         self._len_inputs = len(self.abi["inputs"])
 
         # cache `_call` on this object to prevent repeated imports due to circ import
@@ -44,7 +55,7 @@ def __init__(self):
 
         self._skip_decoder_proc_pool = self._address in call._skip_proc_pool
 
-    def __await__(self):
+    def __await__(self) -> Generator[Any, None, _EVMType]:
         """
         Allow the contract method to be awaited.
 

dank_mids/brownie_patch/_method.py

@@ -152,7 +152,7 @@ def from_explorer(
     signatures: Dict[Method, Signature]
     """A dictionary mapping method names to their corresponding signatures."""
 
-    def __init__(self, *args, **kwargs):
+    def __init__(self, *args, **kwargs) -> None:
         """
         Initialize the Contract instance.
 
@@ -241,7 +241,7 @@ def __get_method_object__(self, name: str) -> DankContractMethod:
         return overloaded  # type: ignore [return-value]
 
 
-def _is_function_abi(abi: dict):
+def _is_function_abi(abi: dict) -> bool:
     return abi["type"] == "function"
 
 

dank_mids/brownie_patch/contract.py

@@ -43,7 +43,7 @@ def revert_logger_log_debug(msg: str, *args) -> None:
 }
 
 
-def log_internal_error(logger: Logger, batch: "_Batch", exc: Exception):
+def log_internal_error(logger: Logger, batch: "_Batch", exc: Exception) -> None:
     try:
         batch_objs = list(batch)
     except TypeError:
@@ -68,7 +68,7 @@ def format_error_response(request: PartialRequest, error: Error) -> RPCError:
     return response
 
 
-def needs_full_request_spec(response: PartialResponse):
+def needs_full_request_spec(response: PartialResponse) -> bool:
     """
     Determine if a response indicates that the node requires the full request specification.
 
@@ -97,7 +97,7 @@ def is_call_revert(e: BadResponse) -> bool:
     return any(map(f"{e}".lower().__contains__, INDIVIDUAL_CALL_REVERT_STRINGS))
 
 
-def log_request_type_switch():
+def log_request_type_switch() -> None:
     error_logger_debug(
         "your node says the partial request was invalid but its okay, we can use the full jsonrpc spec instead"
     )

dank_mids/helpers/_errors.py

@@ -62,7 +62,7 @@ class BlockSemaphore(_AbstractPrioritySemaphore):
     _top_priority: Literal[-1]
     """The highest priority value, set to -1."""
 
-    def __init__(self, value=1, *, name=None):
+    def __init__(self, value=1, *, name=None) -> None:
         super().__init__(_BlockSemaphoreContextManager, -1, int(value), name=name)
 
     def __getitem__(self, block: Union[int, HexStr, Literal["latest", None]]) -> "_BlockSemaphoreContextManager":  # type: ignore [override]

dank_mids/semaphores.py

@@ -340,7 +340,7 @@ def _log_list_types(self, values, level: _LogLevel = DEVHINT) -> None:
 class _Collector:
     """Handles the collection and computation of stats-related data."""
 
-    def __init__(self):
+    def __init__(self) -> None:
         self.errd_batches: Deque["JSONRPCBatch"] = deque(maxlen=500)
         """
         A deque that stores information about failed JSON-RPC batches.