async refactoring complete

Author: TexasCoding

ASYNC_MIGRATION_GUIDE.md …_reference_docs/ASYNC_MIGRATION_GUIDE.mdASYNC_MIGRATION_GUIDE.md renamed to docs/_reference_docs/ASYNC_MIGRATION_GUIDE.md ASYNC_MIGRATION_GUIDE.md renamed to docs/_reference_docs/ASYNC_MIGRATION_GUIDE.md

@@ -28,8 +28,8 @@
 
 from project_x_py import (
     ProjectX,
-    create_async_order_manager,
-    create_async_realtime_client,
+    create_order_manager,
+    create_realtime_client,
     setup_logging,
 )
 
@@ -183,15 +183,13 @@ async def main():
             print("\n🏗️ Creating async order manager...")
             try:
                 jwt_token = client.session_token
-                realtime_client = create_async_realtime_client(
-                    jwt_token, str(account.id)
-                )
-                order_manager = create_async_order_manager(client, realtime_client)
+                realtime_client = create_realtime_client(jwt_token, str(account.id))
+                order_manager = create_order_manager(client, realtime_client)
                 await order_manager.initialize(realtime_client=realtime_client)
                 print("✅ Async order manager created with real-time tracking")
             except Exception as e:
                 print(f"⚠️  Real-time client failed, using basic order manager: {e}")
-                order_manager = create_async_order_manager(client, None)
+                order_manager = create_order_manager(client, None)
                 await order_manager.initialize()
 
             # Track orders placed in this demo for cleanup

async_refactoring_issue.md …eference_docs/async_refactoring_issue.mdasync_refactoring_issue.md renamed to docs/_reference_docs/async_refactoring_issue.md async_refactoring_issue.md renamed to docs/_reference_docs/async_refactoring_issue.md

@@ -24,10 +24,10 @@
 
 from project_x_py import (
     ProjectX,
-    create_async_data_manager,
-    create_async_order_manager,
-    create_async_position_manager,
-    create_async_realtime_client,
+    create_data_manager,
+    create_order_manager,
+    create_position_manager,
+    create_realtime_client,
     setup_logging,
 )
 from project_x_py.async_realtime_data_manager import AsyncRealtimeDataManager
@@ -187,12 +187,12 @@ async def main():
                 return
 
             # Create real-time client for live updates
-            realtime_client = create_async_realtime_client(
+            realtime_client = create_realtime_client(
                 client.session_token, str(client.account_info.id)
             )
 
             # Create position manager with real-time integration
-            position_manager = create_async_position_manager(client, realtime_client)
+            position_manager = create_position_manager(client, realtime_client)
 
             # Connect real-time client first
             print("\n🔌 Connecting to real-time services...")
@@ -206,7 +206,7 @@ async def main():
                 # Create real-time data manager for MNQ
                 realtime_data_manager = None
                 try:
-                    realtime_data_manager = create_async_data_manager(
+                    realtime_data_manager = create_data_manager(
                         "MNQ",
                         client,
                         realtime_client,
@@ -300,7 +300,7 @@ async def main():
 
             # Create order manager for placing test position
             print("\n🏗️ Creating order manager for test position...")
-            order_manager = create_async_order_manager(client, realtime_client)
+            order_manager = create_order_manager(client, realtime_client)
             await order_manager.initialize(realtime_client=realtime_client)
 
             # Ask user if they want to place a test position

github_issue_12_metadata.md …ference_docs/github_issue_12_metadata.mdgithub_issue_12_metadata.md renamed to docs/_reference_docs/github_issue_12_metadata.md github_issue_12_metadata.md renamed to docs/_reference_docs/github_issue_12_metadata.md

@@ -29,8 +29,8 @@
 
 from project_x_py import (
     ProjectX,
-    create_async_data_manager,
-    create_async_realtime_client,
+    create_data_manager,
+    create_realtime_client,
     setup_logging,
 )
 
@@ -227,7 +227,7 @@ async def main():
 
             # Create async real-time client
             print("\n🌐 Creating async real-time client...")
-            realtime_client = create_async_realtime_client(
+            realtime_client = create_realtime_client(
                 client.session_token, str(client.account_info.id)
             )
             print("✅ Async real-time client created!")
@@ -249,7 +249,7 @@ async def main():
             timeframes = ["15sec", "1min", "5min", "15min", "1hr"]
 
             try:
-                data_manager = create_async_data_manager(
+                data_manager = create_data_manager(
                     instrument="MNQ",
                     project_x=client,
                     realtime_client=realtime_client,

examples/02_order_management.py

@@ -34,8 +34,8 @@
 
 from project_x_py import (
     ProjectX,
-    create_async_orderbook,
-    create_async_realtime_client,
+    create_orderbook,
+    create_realtime_client,
     setup_logging,
 )
 
@@ -642,9 +642,7 @@ async def main():
             print("\n🏗️ Creating async Level 2 orderbook...", flush=True)
             try:
                 jwt_token = client.session_token
-                realtime_client = create_async_realtime_client(
-                    jwt_token, str(account.id)
-                )
+                realtime_client = create_realtime_client(jwt_token, str(account.id))
 
                 # Connect the realtime client
                 print("   Connecting to real-time WebSocket feeds...", flush=True)
@@ -666,7 +664,7 @@ async def main():
                 print(f"   Contract ID: {contract_id}", flush=True)
 
                 # Note: We use the full contract ID for proper matching
-                orderbook = create_async_orderbook(
+                orderbook = create_orderbook(
                     instrument=contract_id,
                     realtime_client=realtime_client,
                     project_x=client,

examples/03_position_management.py

@@ -26,8 +26,8 @@
 
 from project_x_py import (
     ProjectX,
-    create_async_data_manager,
-    create_async_realtime_client,
+    create_data_manager,
+    create_realtime_client,
     setup_logging,
 )
 from project_x_py.indicators import (
@@ -300,11 +300,11 @@ async def main():
             print("\n📊 Setting up real-time indicator monitoring...")
 
             # Create real-time components
-            realtime_client = create_async_realtime_client(
+            realtime_client = create_realtime_client(
                 client.session_token, str(client.account_info.id)
             )
 
-            data_manager = create_async_data_manager(
+            data_manager = create_data_manager(
                 "MNQ", client, realtime_client, timeframes=["5sec", "1min", "5min"]
             )
 

examples/04_realtime_data.py

@@ -19,12 +19,14 @@
 
 import asyncio
 import sys
+from contextlib import suppress
 
 from project_x_py import ProjectX
 from project_x_py.exceptions import ProjectXError
+from project_x_py.models import Instrument
 
 
-def display_instrument(instrument, prefix=""):
+def display_instrument(instrument: Instrument, prefix: str = ""):
     """Display instrument details in a formatted way"""
     print(f"{prefix}┌─ Contract Details ─────────────────────────────")
     print(f"{prefix}│ ID:           {instrument.id}")
@@ -37,7 +39,7 @@ def display_instrument(instrument, prefix=""):
     print(f"{prefix}└" + "─" * 47)
 
 
-async def search_and_display(client, symbol):
+async def search_and_display(client: ProjectX, symbol: str):
     """Search for instruments and display results asynchronously"""
     print(f"\n{'=' * 60}")
     print(f"Searching for: '{symbol}'")
@@ -152,6 +154,9 @@ async def main():
         print("\nConnecting to ProjectX...")
         async with ProjectX.from_env() as client:
             await client.authenticate()
+            if client.account_info is None:
+                print("❌ No account info found")
+                return
             print("✓ Connected successfully!")
             print(f"✓ Using account: {client.account_info.name}")
 
@@ -174,7 +179,7 @@ async def show_stats():
                 await run_interactive_search(client)
             finally:
                 stats_task.cancel()
-                with asyncio.suppress(asyncio.CancelledError):
+                with suppress(asyncio.CancelledError):
                     await stats_task
 
     except Exception as e:

examples/05_orderbook_analysis.py

@@ -8,6 +8,7 @@
 import os
 
 from project_x_py import ProjectX
+from project_x_py.models import Instrument, Position
 
 
 async def main():
@@ -25,40 +26,47 @@ async def main():
         # Create async client using environment variables
         async with ProjectX.from_env() as client:
             print("✅ Client created successfully")
+            if client.account_info is None:
+                print("❌ No account info found")
+                return
 
             # Authenticate
             print("\n🔐 Authenticating...")
             await client.authenticate()
-            print(f"✅ Authenticated as: {client.account_info.username}")
+            print(f"✅ Authenticated as: {client.account_info.name}")
             print(f"📊 Using account: {client.account_info.name}")
             print(f"💰 Balance: ${client.account_info.balance:,.2f}")
 
             # Get positions
             print("\n📈 Fetching positions...")
-            positions = await client.get_positions()
+            positions: list[Position] = await client.get_positions()
 
             if positions:
                 print(f"Found {len(positions)} position(s):")
                 for pos in positions:
                     side = "Long" if pos.type == "LONG" else "Short"
-                    print(f"  - {pos.symbol}: {side} {pos.size} @ ${pos.averagePrice}")
+                    print(
+                        f"  - {pos.contractId}: {side} {pos.size} @ ${pos.averagePrice}"
+                    )
             else:
                 print("No open positions")
 
             # Get instrument info
             print("\n🔍 Fetching instrument information...")
             # Run multiple instrument fetches concurrently
-            instruments = await asyncio.gather(
+            instruments: tuple[
+                Instrument, Instrument, Instrument
+            ] = await asyncio.gather(
                 client.get_instrument("NQ"),
                 client.get_instrument("ES"),
                 client.get_instrument("MGC"),
             )
 
             print("Instrument details:")
             for inst in instruments:
-                print(f"  - {inst.symbol}: {inst.name}")
-                print(f"    Tick size: ${inst.tick_size}")
-                print(f"    Contract size: {inst.contract_size}")
+                print(f"  - {inst.symbolId}: {inst.name}")
+                print(f"    Tick size: ${inst.tickSize}")
+                print(f"    Contract size: {inst.tickValue}")
 
             # Show performance stats
             print("\n📊 Performance Statistics:")
@@ -88,11 +96,6 @@ async def concurrent_example():
 
         start = time.time()
 
-        # Sequential (old way)
-        pos1 = await client.get_positions()
-        inst1 = await client.get_instrument("NQ")
-        inst2 = await client.get_instrument("ES")
-
         sequential_time = time.time() - start
         print(f"Sequential operations took: {sequential_time:.2f} seconds")