fix(types): resolve all mypy type assignment errors

- Add proper type annotations to mixin __init__ methods
- Fix type assignment errors in realtime/core.py, client/base.py, and realtime_data_manager/core.py
- Add account_info initialization to AuthenticationMixin
- Add __init__ methods to ConnectionManagementMixin and MemoryManagementMixin
- Fix volatility.py indicator calculate method signatures to use **kwargs
- Remove unreachable code in position_manager/tracking.py
- Fix config.py json.load() return type handling

All mypy errors resolved - project now passes type checking with 0 errors

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

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

Author: TexasCoding

TEST_REFACTORING_ISSUE.md

@@ -164,6 +164,7 @@ ignore = [
     "N815",  # Variable in class scope should not be mixedCase (API compatibility)
     "N818",  # Exception name should be named with an Error suffix
     "UP007", # Use X | Y for type annotations (optional)
+    "N811", # Variable in class scope should not be mixedCase (API compatibility)
 ]
 
 fixable = ["ALL"]
@@ -283,6 +284,7 @@ dev = [
     "pytest-mock>=3.14.1",
     "pre-commit>=4.2.0",
     "types-requests>=2.32.4.20250611",
+    "types-pytz>=2025.2.0.20250516",
 ]
 test = [
     "pytest>=8.4.1",

pyproject.toml

@@ -100,4 +100,4 @@ class ProjectX(ProjectXBase):
     """
 
 
-__all__ = ["ProjectX", "RateLimiter"]
+__all__ = ["ProjectX", "ProjectXBase", "RateLimiter"]

src/project_x_py/client/__init__.py

@@ -21,11 +21,12 @@
 class AuthenticationMixin:
     """Mixin class providing authentication functionality."""
 
-    def __init__(self):
+    def __init__(self) -> None:
         """Initialize authentication attributes."""
         self.session_token = ""
         self.token_expiry: datetime.datetime | None = None
         self._authenticated = False
+        self.account_info: Account | None = None
 
     async def _refresh_authentication(self: "ProjectXClientProtocol") -> None:
         """Refresh authentication if token is expired or about to expire."""
@@ -82,9 +83,9 @@ async def authenticate(self: "ProjectXClientProtocol") -> None:
             token_parts = self.session_token.split(".")
             if len(token_parts) >= 2:
                 # Add padding if necessary
-                payload = token_parts[1]
-                payload += "=" * (4 - len(payload) % 4)
-                decoded = base64.urlsafe_b64decode(payload)
+                token_payload = token_parts[1]
+                token_payload += "=" * (4 - len(token_payload) % 4)
+                decoded = base64.urlsafe_b64decode(token_payload)
                 token_data = json.loads(decoded)
                 self.token_expiry = datetime.datetime.fromtimestamp(
                     token_data["exp"], tz=pytz.UTC

src/project_x_py/client/auth.py

@@ -4,6 +4,7 @@
 import os
 from collections.abc import AsyncGenerator
 from contextlib import asynccontextmanager
+from typing import Any
 
 import httpx
 
@@ -73,7 +74,7 @@ async def __aenter__(self) -> "ProjectXBase":
         self._client = await self._create_client()
         return self
 
-    async def __aexit__(self, exc_type, exc_val, exc_tb):
+    async def __aexit__(self, exc_type: Any, exc_val: Any, exc_tb: Any) -> None:
         """Async context manager exit."""
         if self._client:
             await self._client.aclose()

src/project_x_py/client/base.py

@@ -18,7 +18,7 @@
 class CacheMixin:
     """Mixin class providing caching functionality."""
 
-    def __init__(self):
+    def __init__(self) -> None:
         """Initialize cache attributes."""
         # Cache for instrument data (symbol -> instrument)
         self._instrument_cache: dict[str, Instrument] = {}

src/project_x_py/client/cache.py

@@ -24,7 +24,7 @@
 class HttpMixin:
     """Mixin class providing HTTP client functionality."""
 
-    def __init__(self):
+    def __init__(self) -> None:
         """Initialize HTTP client attributes."""
         self._client: httpx.AsyncClient | None = None
         self.api_call_count = 0

src/project_x_py/client/http.py

@@ -41,7 +41,7 @@ def __init__(self, config_file: str | Path | None = None):
         Args:
             config_file: Optional path to configuration file
         """
-        self.config_file = Path(config_file) if config_file else None
+        self.config_file: Path | None = Path(config_file) if config_file else None
         self._config: ProjectXConfig | None = None
 
     def load_config(self) -> ProjectXConfig:
@@ -79,8 +79,9 @@ def _load_config_file(self) -> dict[str, Any]:
             return {}
 
         try:
-            with open(self.config_file) as f:
-                return json.load(f)
+            with open(self.config_file, encoding="utf-8") as f:
+                data = json.load(f)
+                return dict(data) if isinstance(data, dict) else {}
         except (json.JSONDecodeError, OSError) as e:
             logger.error(f"Error loading config file: {e}")
             return {}
@@ -117,7 +118,11 @@ def _load_env_config(self) -> dict[str, Any]:
 
         return env_config
 
-    def save_config(self, config: ProjectXConfig, file_path: str | Path | None = None):
+    def save_config(
+        self,
+        config: ProjectXConfig,
+        file_path: str | Path | None = None,
+    ) -> None:
         """
         Save configuration to file.
 
@@ -136,7 +141,7 @@ def save_config(self, config: ProjectXConfig, file_path: str | Path | None = Non
 
             # Convert config to dict and save as JSON
             config_dict = asdict(config)
-            with open(target_file, "w") as f:
+            with open(target_file, "w", encoding="utf-8") as f:
                 json.dump(config_dict, f, indent=2)
 
             logger.info(f"Configuration saved to {target_file}")
@@ -183,10 +188,15 @@ def validate_config(self, config: ProjectXConfig) -> bool:
         Raises:
             ValueError: If configuration is invalid
         """
-        errors = []
+        errors: list[str] = []
 
         # Validate URLs
-        required_urls = ["api_url", "realtime_url", "user_hub_url", "market_hub_url"]
+        required_urls: list[str] = [
+            "api_url",
+            "realtime_url",
+            "user_hub_url",
+            "market_hub_url",
+        ]
         for url_field in required_urls:
             url = getattr(config, url_field)
             if not url or not isinstance(url, str):
@@ -242,7 +252,7 @@ def load_topstepx_config() -> ProjectXConfig:
 
 
 def create_custom_config(
-    user_hub_url: str, market_hub_url: str, **kwargs
+    user_hub_url: str, market_hub_url: str, **kwargs: Any
 ) -> ProjectXConfig:
     """
     Create custom configuration with specified URLs.
@@ -275,7 +285,7 @@ def create_config_template(file_path: str | Path) -> None:
         file_path: Path where to create the template
     """
     template_config = ProjectXConfig()
-    config_dict = asdict(template_config)
+    config_dict: dict[str, Any] = asdict(template_config)
 
     # Add comments to the template
     template = {
@@ -298,7 +308,7 @@ def create_config_template(file_path: str | Path) -> None:
     file_path = Path(file_path)
     file_path.parent.mkdir(parents=True, exist_ok=True)
 
-    with open(file_path, "w") as f:
+    with open(file_path, "w", encoding="utf-8") as f:
         json.dump(template, f, indent=2)
 
     logger.info(f"Configuration template created at {file_path}")
@@ -334,7 +344,7 @@ def check_environment() -> dict[str, Any]:
     Returns:
         Dictionary with environment status
     """
-    status = {
+    status: dict[str, Any] = {
         "auth_configured": False,
         "config_file_exists": False,
         "environment_overrides": [],
@@ -357,13 +367,13 @@ def check_environment() -> dict[str, Any]:
         status["missing_required"].extend(["PROJECT_X_API_KEY", "PROJECT_X_USERNAME"])
 
     # Check for config file
-    default_path = get_default_config_path()
+    default_path: Path = get_default_config_path()
     if default_path.exists():
         status["config_file_exists"] = True
         status["config_file_path"] = str(default_path)
 
     # Check for environment overrides
-    env_vars = [
+    env_vars: list[str] = [
         "PROJECTX_API_URL",
         "PROJECTX_REALTIME_URL",
         "PROJECTX_USER_HUB_URL",

src/project_x_py/config.py

@@ -8,6 +8,8 @@
 
 """
 
+from typing import Any
+
 
 class ProjectXError(Exception):
     """Base exception for ProjectX API errors."""
@@ -16,7 +18,7 @@ def __init__(
         self,
         message: str,
         error_code: int | None = None,
-        response_data: dict | None = None,
+        response_data: dict[str, Any] | None = None,
     ):
         """
         Initialize ProjectX error.