Phase 7: Clean up unused features and dead code

- Removed unused imports (overload, Any) from multiple files
- Cleaned up commented-out code blocks in position_manager and realtime modules
- Fixed remaining linting issues (isinstance union types, bare except clauses)
- Auto-fixed import ordering and Optional type hints
- Verified no duplicate utility functions exist
- All deprecated features properly marked for v4.0.0 removal

🤖 Generated with [Claude Code](https://claude.ai/code)

Co-Authored-By: Claude <[email protected]>

Author: TexasCoding

src/project_x_py/client/http.py

@@ -52,7 +52,7 @@ async def main():
 """
 
 import time
-from typing import TYPE_CHECKING, Any, TypeVar, overload
+from typing import TYPE_CHECKING, Any, TypeVar
 
 import httpx
 

src/project_x_py/models.py

@@ -113,7 +113,7 @@
 """
 
 from dataclasses import dataclass
-from typing import Any, Union
+from typing import Union
 
 __all__ = [
     "Account",

src/project_x_py/order_manager/tracking.py

@@ -336,7 +336,6 @@ def add_callback(
         This method is provided for backward compatibility only and will be removed in v4.0.
         """
         # Deprecation warning handled by decorator
-        pass
 
     async def _trigger_callbacks(self, event_type: str, data: Any) -> None:
         """

src/project_x_py/position_manager/core.py

@@ -80,8 +80,6 @@ async def main():
 from project_x_py.position_manager.monitoring import PositionMonitoringMixin
 from project_x_py.position_manager.operations import PositionOperationsMixin
 from project_x_py.position_manager.reporting import PositionReportingMixin
-
-# from project_x_py.position_manager.risk import RiskManagementMixin # DEPRECATED
 from project_x_py.position_manager.tracking import PositionTrackingMixin
 from project_x_py.risk_manager import RiskManager
 from project_x_py.types.config_types import PositionManagerConfig

src/project_x_py/position_manager/operations.py

@@ -172,8 +172,6 @@ async def close_position_direct(
 
                     # Synchronize orders - cancel related orders when position is closed
                     # Note: Order synchronization methods will be added to AsyncOrderManager
-                    # if self._order_sync_enabled and self.order_manager:
-                    #     await self.order_manager.on_position_closed(contract_id)
 
                     self.stats["closed_positions"] += 1
                 else:
@@ -300,10 +298,6 @@ async def partially_close_position(
 
                     # Synchronize orders - update order sizes after partial close
                     # Note: Order synchronization methods will be added to AsyncOrderManager
-                    # if self._order_sync_enabled and self.order_manager:
-                    #     await self.order_manager.sync_orders_with_position(
-                    #         contract_id, account_id
-                    #     )
 
                     self.stats["positions_partially_closed"] += 1
                 else:

src/project_x_py/realtime/__init__.py

@@ -78,20 +78,8 @@ async def on_quote_update(event):
         await suite.disconnect()
 
 
-    # V3.1: Low-level direct usage (advanced users only)
-    # from project_x_py import ProjectX
-    # from project_x_py.realtime import ProjectXRealtimeClient
-    #
-    # async def low_level_example():
-    #     async with ProjectX.from_env() as client:
-    #         await client.authenticate()
-    #         # Create real-time client directly
-    #         realtime = ProjectXRealtimeClient(
-    #             jwt_token=client.session_token,
-    #             account_id=str(client.account_info.id),
-    #         )
-    #         await realtime.connect()
-    #         await realtime.subscribe_market_data(["MNQ", "ES"])
+    # V3.1: Low-level direct usage is available for advanced users
+    # See documentation for direct ProjectXRealtimeClient usage
 
     asyncio.run(main())
     ```

src/project_x_py/utils/stats_tracking.py

@@ -10,7 +10,7 @@
 import traceback
 from collections import deque
 from datetime import datetime
-from typing import Any, Optional
+from typing import Any
 
 
 class StatsTrackingMixin:
@@ -30,14 +30,14 @@ def _init_stats_tracking(self, max_errors: int = 100) -> None:
         """
         self._error_count = 0
         self._error_history: deque[dict[str, Any]] = deque(maxlen=max_errors)
-        self._last_activity: Optional[datetime] = None
+        self._last_activity: datetime | None = None
         self._start_time = time.time()
 
     def _track_error(
         self,
         error: Exception,
-        context: Optional[str] = None,
-        details: Optional[dict[str, Any]] = None,
+        context: str | None = None,
+        details: dict[str, Any] | None = None,
     ) -> None:
         """
         Track an error occurrence.
@@ -95,11 +95,11 @@ def get_memory_usage_mb(self) -> float:
                 size += sys.getsizeof(attr)
 
                 # For collections, also count items
-                if isinstance(attr, (list, dict, set, deque)):
+                if isinstance(attr, list | dict | set | deque):
                     try:
                         for item in attr.values() if isinstance(attr, dict) else attr:
                             size += sys.getsizeof(item)
-                    except:
+                    except (AttributeError, TypeError):
                         pass  # Skip if iteration fails
 
         # Convert to MB

src/project_x_py/utils/task_management.py

@@ -10,7 +10,7 @@
 
 import asyncio
 import logging
-from typing import TYPE_CHECKING, Any, Optional
+from typing import TYPE_CHECKING, Any
 from weakref import WeakSet
 
 if TYPE_CHECKING:
@@ -51,7 +51,7 @@ def _init_task_manager(self) -> None:
         self._cleanup_in_progress = False
 
     def _create_task(
-        self, coro: Any, name: Optional[str] = None, persistent: bool = False
+        self, coro: Any, name: str | None = None, persistent: bool = False
     ) -> "Task[Any]":
         """
         Create and track an async task.
@@ -136,7 +136,7 @@ async def _cleanup_tasks(self, timeout: float = 5.0) -> None:
                     asyncio.gather(*pending_tasks, return_exceptions=True),
                     timeout=timeout,
                 )
-            except asyncio.TimeoutError:
+            except TimeoutError:
                 logger.warning(
                     f"{len([t for t in pending_tasks if not t.done()])} tasks "
                     f"did not complete within {timeout}s timeout"
@@ -212,7 +212,7 @@ async def __aexit__(self, exc_type: Any, exc_val: Any, exc_tb: Any) -> None:
 
 
 def create_fire_and_forget_task(
-    coro: Any, name: Optional[str] = None, error_handler: Optional[callable] = None
+    coro: Any, name: str | None = None, error_handler: callable | None = None
 ) -> "Task[Any]":
     """
     Create a fire-and-forget task with optional error handling.