feat: optimize controller attr lookups (#346)

dank_mids/_requests.py

@@ -874,7 +874,7 @@ def _post_future_cleanup(self) -> None:
         try:
             with controller.pools_closed_lock:
                 # This will have already taken place in a full json batch of multicalls
-                controller.pending_eth_calls.pop(self.block)
+                controller._pending_eth_calls_pop(self.block)
         except KeyError:
             pass
 

dank_mids/controller.py

@@ -169,6 +169,11 @@ def __init__(self, w3: Web3) -> None:
         )
         """A dictionary of pending Multicalls by block. The Multicalls hold all pending eth_calls."""
 
+        self._pending_eth_calls_pop = self.pending_eth_calls.pop
+        self._pending_eth_calls_copy = self.pending_eth_calls.copy
+        self._pending_eth_calls_clear = self.pending_eth_calls.clear
+        self._pending_eth_calls_values = self.pending_eth_calls.values
+
         self.pending_rpc_calls = JSONRPCBatch(self)
         """A JSONRPCBatch containing all pending rpc requests."""
 
@@ -270,8 +275,8 @@ async def execute_batch(self) -> None:
         and executes them as a single batch.
         """
         with self.pools_closed_lock:  # Do we really need this?  # NOTE: yes we do
-            multicalls = self.pending_eth_calls.copy()
-            self.pending_eth_calls.clear()
+            multicalls = self._pending_eth_calls_copy()
+            self._pending_eth_calls_clear()
             rpc_calls = self.pending_rpc_calls
             self.pending_rpc_calls = JSONRPCBatch(self)
         demo_logger.info(f"executing dank batch (current cid: {self.call_uid.latest})")  # type: ignore
@@ -290,7 +295,7 @@ def queue_is_full(self) -> bool:
         with self.pools_closed_lock:
             if ENVS.OPERATION_MODE.infura:  # type: ignore [attr-defined]
                 return sum(len(call) for call in self.pending_rpc_calls) >= ENVS.MAX_JSONRPC_BATCH_SIZE  # type: ignore [attr-defined,operator]
-            eth_calls = sum(len(calls) for calls in self.pending_eth_calls.values())
+            eth_calls = sum(len(calls) for calls in self._pending_eth_calls_values())
             other_calls = sum(len(call) for call in self.pending_rpc_calls)
             return eth_calls + other_calls >= self.batcher.step
 
@@ -304,8 +309,8 @@ def early_start(self):
         are queued to form a full batch.
         """
         with self.pools_closed_lock:
-            self.pending_rpc_calls.extend(self.pending_eth_calls.values(), skip_check=True)
-            self.pending_eth_calls.clear()
+            self.pending_rpc_calls.extend(self._pending_eth_calls_values(), skip_check=True)
+            self._pending_eth_calls_clear()
             self.pending_rpc_calls.start()
 
     def reduce_multicall_size(self, num_calls: int) -> None: