file and class renaming

Author: TexasCoding

examples/01_basic_client_connection.py

@@ -6,7 +6,7 @@
 This is the foundation for all other async examples.
 
 Usage:
-    Run with: uv run examples/async_01_basic_client_connection.py
+    Run with: uv run examples/01_basic_client_connection.py
     Or use test.sh which sets environment variables: ./test.sh
 
 Author: TexasCoding

examples/02_order_management.py

@@ -17,7 +17,7 @@
 
 Usage:
     Run with: ./test.sh (sets environment variables)
-    Or: uv run examples/async_02_order_management.py
+    Or: uv run examples/02_order_management.py
 
 Author: TexasCoding
 Date: July 2025

examples/03_position_management.py

@@ -13,7 +13,7 @@
 
 Usage:
     Run with: ./test.sh (sets environment variables)
-    Or: uv run examples/async_03_position_management.py
+    Or: uv run examples/03_position_management.py
 
 Author: TexasCoding
 Date: July 2025
@@ -30,13 +30,13 @@
     create_realtime_client,
     setup_logging,
 )
-from project_x_py.async_realtime_data_manager import AsyncRealtimeDataManager
+from project_x_py.realtime_data_manager import RealtimeDataManager
 
 
 async def get_current_market_price(
     client: ProjectX,
     symbol="MNQ",
-    realtime_data_manager: AsyncRealtimeDataManager | None = None,
+    realtime_data_manager: RealtimeDataManager | None = None,
 ):
     """Get current market price with async fallback for closed markets."""
     # Try to get real-time price first if available

examples/04_realtime_data.py

@@ -14,7 +14,7 @@
 
 Usage:
     Run with: ./test.sh (sets environment variables)
-    Or: uv run examples/async_04_realtime_data.py
+    Or: uv run examples/04_realtime_data.py
 
 Author: TexasCoding
 Date: July 2025
@@ -35,10 +35,10 @@
 )
 
 if TYPE_CHECKING:
-    from project_x_py.async_realtime_data_manager import AsyncRealtimeDataManager
+    from project_x_py.realtime_data_manager import RealtimeDataManager
 
 
-async def display_current_prices(data_manager: AsyncRealtimeDataManager):
+async def display_current_prices(data_manager: RealtimeDataManager):
     """Display current prices across all timeframes asynchronously."""
     print("\n📊 Current Prices:")
 

examples/05_orderbook_analysis.py

@@ -11,11 +11,11 @@
 - Market imbalance monitoring
 - Best bid/ask tracking
 
-Uses MNQ for Level 2 orderbook data with AsyncOrderBook.
+Uses MNQ for Level 2 orderbook data with OrderBook.
 
 Usage:
     Run with: ./test.sh (sets environment variables)
-    Or: uv run examples/async_05_orderbook_analysis.py
+    Or: uv run examples/05_orderbook_analysis.py
 
 Note: This example includes several wait periods:
     - 5 seconds for initial data population
@@ -260,8 +260,8 @@ async def monitor_orderbook_feed(orderbook, duration_seconds=60):
 
 
 async def demonstrate_all_orderbook_methods(orderbook):
-    """Comprehensive demonstration of all AsyncOrderBook methods."""
-    print("\n🔍 Testing all available AsyncOrderBook methods...", flush=True)
+    """Comprehensive demonstration of all OrderBook methods."""
+    print("\n🔍 Testing all available OrderBook methods...", flush=True)
     print(
         "📝 Note: Some methods may show zero values without live market data connection"
     )

examples/06_multi_timeframe_strategy.py

@@ -15,7 +15,7 @@
 
 Usage:
     Run with: ./test.sh (sets environment variables)
-    Or: uv run examples/async_06_multi_timeframe_strategy.py
+    Or: uv run examples/06_multi_timeframe_strategy.py
 
 Author: TexasCoding
 Date: July 2025
@@ -33,7 +33,7 @@
 from project_x_py.indicators import RSI, SMA
 
 
-class AsyncMultiTimeframeStrategy:
+class MultiTimeframeStrategy:
     """
     Async multi-timeframe trend following strategy.
 
@@ -433,7 +433,7 @@ def signal_handler(signum, frame):
                 await suite["data_manager"].start_realtime_feed()
 
             # Create and configure strategy
-            strategy = AsyncMultiTimeframeStrategy(
+            strategy = MultiTimeframeStrategy(
                 trading_suite=suite,
                 symbol="MNQ",
                 max_position_size=2,

examples/07_technical_indicators.py

@@ -1,6 +1,6 @@
 #!/usr/bin/env python3
 """
-Async Technical Indicators Analysis Example
+Technical Indicators Analysis Example
 
 Demonstrates concurrent technical analysis using async patterns:
 - Concurrent calculation of multiple indicators
@@ -12,7 +12,7 @@
 
 Usage:
     Run with: ./test.sh (sets environment variables)
-    Or: uv run examples/async_07_technical_indicators.py
+    Or: uv run examples/07_technical_indicators.py
 
 Author: TexasCoding
 Date: July 2025

examples/08_order_and_position_tracking.py

@@ -1,6 +1,6 @@
 #!/usr/bin/env python3
 """
-Async Order and Position Tracking Demo
+Order and Position Tracking Demo
 
 This demo script demonstrates the automatic order cleanup functionality when positions are closed,
 using proper async components (AsyncOrderManager, AsyncPositionManager, AsyncRealtimeDataManager).
@@ -17,7 +17,7 @@
 - Concurrent operations for improved performance
 
 Usage:
-    python examples/async_08_order_and_position_tracking.py
+    python examples/08_order_and_position_tracking.py
 
 Manual Testing:
     - Let the script create a bracket order
@@ -37,8 +37,8 @@
 from project_x_py import ProjectX, create_trading_suite
 
 
-class AsyncOrderPositionDemo:
-    """Async demo class for order and position tracking with automatic cleanup."""
+class OrderPositionDemo:
+    """Demo class for order and position tracking with automatic cleanup."""
 
     def __init__(self):
         self.client = None
@@ -443,7 +443,7 @@ async def run(self, client: ProjectX):
 
 async def main():
     """Main async entry point."""
-    demo = AsyncOrderPositionDemo()
+    demo = OrderPositionDemo()
     try:
         async with ProjectX.from_env() as client:
             success = await demo.run(client)

src/project_x_py/__init__.py

@@ -27,15 +27,7 @@
 __author__ = "TexasCoding"
 
 # Core client classes - renamed from Async* to standard names
-from .async_client import AsyncProjectX as ProjectX
-from .async_order_manager import AsyncOrderManager as OrderManager
-from .async_orderbook import (
-    AsyncOrderBook as OrderBook,
-    create_async_orderbook as create_orderbook,
-)
-from .async_position_manager import AsyncPositionManager as PositionManager
-from .async_realtime import AsyncProjectXRealtimeClient as ProjectXRealtimeClient
-from .async_realtime_data_manager import AsyncRealtimeDataManager as RealtimeDataManager
+from .client import ProjectX
 
 # Configuration management
 from .config import (
@@ -88,6 +80,14 @@
     ProjectXConfig,
     Trade,
 )
+from .order_manager import OrderManager
+from .orderbook import (
+    OrderBook,
+    create_orderbook,
+)
+from .position_manager import PositionManager
+from .realtime import ProjectXRealtimeClient as ProjectXRealtimeClient
+from .realtime_data_manager import RealtimeDataManager
 
 # Utility functions
 from .utils import (

src/project_x_py/async_client.py src/project_x_py/client.pysrc/project_x_py/async_client.py renamed to src/project_x_py/client.py

@@ -58,7 +58,7 @@
 )
 
 
-class AsyncRateLimiter:
+class RateLimiter:
     """Simple async rate limiter using sliding window."""
 
     def __init__(self, max_requests: int, window_seconds: int):
@@ -90,7 +90,7 @@ async def acquire(self) -> None:
             self.requests.append(now)
 
 
-class AsyncProjectX:
+class ProjectX:
     """
     Async core ProjectX client for the ProjectX Python SDK.
 
@@ -127,10 +127,10 @@ class AsyncProjectX:
     Example:
         >>> # Basic async SDK usage with environment variables (recommended)
         >>> import asyncio
-        >>> from project_x_py import AsyncProjectX
+        >>> from project_x_py import ProjectX
         >>>
         >>> async def main():
-        >>>     async with AsyncProjectX.from_env() as client:
+        >>>     async with ProjectX.from_env() as client:
         >>>         await client.authenticate()
         >>>         positions = await client.get_positions()
         >>>         print(f"Found {len(positions)} positions")
@@ -191,11 +191,11 @@ def __init__(
         self.cache_hit_count = 0
 
         # Rate limiting - 100 requests per minute by default
-        self.rate_limiter = AsyncRateLimiter(max_requests=100, window_seconds=60)
+        self.rate_limiter = RateLimiter(max_requests=100, window_seconds=60)
 
         self.logger = logging.getLogger(__name__)
 
-    async def __aenter__(self) -> "AsyncProjectX":
+    async def __aenter__(self) -> "ProjectX":
         """Async context manager entry."""
         self._client = await self._create_client()
         return self
@@ -210,7 +210,7 @@ async def __aexit__(self, exc_type, exc_val, exc_tb):
     @asynccontextmanager
     async def from_env(
         cls, config: ProjectXConfig | None = None, account_name: str | None = None
-    ) -> AsyncGenerator["AsyncProjectX", None]:
+    ) -> AsyncGenerator["ProjectX", None]:
         """
         Create async ProjectX client using environment variables (recommended approach).
 
@@ -229,7 +229,7 @@ async def from_env(
             account_name: Optional account name (overrides environment variable)
 
         Yields:
-            AsyncProjectX: Configured async client instance ready for building trading applications
+            ProjectX: Configured async client instance ready for building trading applications
 
         Raises:
             ValueError: If required environment variables are not set
@@ -245,10 +245,10 @@ async def from_env(
             >>>
             >>> # Create async client (recommended approach)
             >>> import asyncio
-            >>> from project_x_py import AsyncProjectX
+            >>> from project_x_py import ProjectX
             >>>
             >>> async def main():
-            >>>     async with AsyncProjectX.from_env() as client:
+            >>>     async with ProjectX.from_env() as client:
             >>>         await client.authenticate()
             >>> # Use the client...
             >>>
@@ -275,7 +275,7 @@ async def from_env(
     @asynccontextmanager
     async def from_config_file(
         cls, config_file: str, account_name: str | None = None
-    ) -> AsyncGenerator["AsyncProjectX", None]:
+    ) -> AsyncGenerator["ProjectX", None]:
         """Create async ProjectX client using a configuration file.
 
         Alternative initialization method that loads configuration and credentials
@@ -294,7 +294,7 @@ async def from_config_file(
                 specified in the config file.
 
         Yields:
-            AsyncProjectX: Configured client instance ready for trading operations
+            ProjectX: Configured client instance ready for trading operations
 
         Raises:
             FileNotFoundError: If config file doesn't exist
@@ -312,7 +312,7 @@ async def from_config_file(
             ... }
             >>>
             >>> # Use client with config file
-            >>> async with AsyncProjectX.from_config_file("config.json") as client:
+            >>> async with ProjectX.from_config_file("config.json") as client:
             ...     await client.authenticate()
             ...     # Client is ready for trading