Skip to content

Implement comprehensive error handling and monitoring system for Pock… #23

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
theshadow76 merged 1 commit into from
Jun 10, 2025
Merged

Implement comprehensive error handling and monitoring system for Pock… #23

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
511 changes: 511 additions & 0 deletions README_ENHANCED.md
View file
Open in desktop

Large diffs are not rendered by default.

582 changes: 582 additions & 0 deletions advanced_testing_suite.py
View file
Open in desktop

Large diffs are not rendered by default.

733 changes: 733 additions & 0 deletions comprehensive_demo.py
View file
Open in desktop

Large diffs are not rendered by default.

515 changes: 515 additions & 0 deletions connection_keep_alive.py
View file
Open in desktop

Large diffs are not rendered by default.

756 changes: 756 additions & 0 deletions connection_monitor.py
View file
Open in desktop

Large diffs are not rendered by default.

357 changes: 357 additions & 0 deletions demo_enhanced_api.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,357 @@
#!/usr/bin/env python3
"""
Complete Demo of Enhanced PocketOption API with Keep-Alive
Demonstrates all the improvements based on the old API patterns
"""

import asyncio
import os
import time
from datetime import datetime, timedelta
from loguru import logger

from pocketoptionapi_async import AsyncPocketOptionClient, OrderDirection


async def demo_enhanced_features():
"""Comprehensive demo of all enhanced features"""

print("🚀 PocketOption Enhanced API Demo")
print("=" * 60)
print("Demonstrating all enhancements based on old API patterns:")
print("✅ Complete SSID format support")
print("✅ Persistent connections with automatic keep-alive")
print("✅ Background ping/pong handling (20-second intervals)")
print("✅ Automatic reconnection with multiple region fallback")
print("✅ Connection health monitoring and statistics")
print("✅ Event-driven architecture with callbacks")
print("✅ Enhanced error handling and recovery")
print("✅ Modern async/await patterns")
print("=" * 60)
print()

# Complete SSID format (as requested)
ssid = r'42["auth",{"session":"n1p5ah5u8t9438rbunpgrq0hlq","isDemo":1,"uid":72645361,"platform":1,"isFastHistory":true}]'
print(f"🔑 Using complete SSID format:")
print(f" {ssid[:80]}...")
print()

# Demo 1: Basic Enhanced Client
print("📋 Demo 1: Enhanced Client with Complete SSID")
print("-" * 50)

try:
# Create client with complete SSID (as user requested)
client = AsyncPocketOptionClient(ssid=ssid, is_demo=True)

print(f"✅ Client created with parsed components:")
print(f" Session ID: {getattr(client, 'session_id', 'N/A')[:20]}...")
print(f" UID: {client.uid}")
print(f" Platform: {client.platform}")
print(f" Demo Mode: {client.is_demo}")
print(f" Fast History: {client.is_fast_history}")

# Test connection
print("\n🔌 Testing connection...")
try:
await client.connect()
if client.is_connected:
print("✅ Connected successfully!")

# Show connection stats
stats = client.get_connection_stats()
print(f"📊 Connection Stats: {stats}")

else:
print("ℹ️ Connection failed (expected with test SSID)")
except Exception as e:
print(f"ℹ️ Connection error (expected): {str(e)[:100]}...")

await client.disconnect()

except Exception as e:
print(f"ℹ️ Client demo error: {e}")

print()

# Demo 2: Persistent Connection Features
print("🔄 Demo 2: Persistent Connection with Keep-Alive")
print("-" * 50)

try:
# Create client with persistent connection enabled
persistent_client = AsyncPocketOptionClient(
ssid=ssid,
is_demo=True,
persistent_connection=True, # Enable keep-alive like old API
auto_reconnect=True
)

# Add event handlers to monitor connection events
events_log = []

def on_connected(data):
events_log.append(f"CONNECTED: {datetime.now().strftime('%H:%M:%S')} - {data}")
print(f"🎉 Event: Connected at {datetime.now().strftime('%H:%M:%S')}")

def on_reconnected(data):
events_log.append(f"RECONNECTED: {datetime.now().strftime('%H:%M:%S')} - {data}")
print(f"🔄 Event: Reconnected at {datetime.now().strftime('%H:%M:%S')}")

def on_authenticated(data):
events_log.append(f"AUTHENTICATED: {datetime.now().strftime('%H:%M:%S')}")
print(f"✅ Event: Authenticated at {datetime.now().strftime('%H:%M:%S')}")

persistent_client.add_event_callback('connected', on_connected)
persistent_client.add_event_callback('reconnected', on_reconnected)
persistent_client.add_event_callback('authenticated', on_authenticated)

print("🚀 Starting persistent connection...")
try:
success = await persistent_client.connect(persistent=True)

if success:
print("✅ Persistent connection established")

# Monitor for 30 seconds to show keep-alive behavior
print("📊 Monitoring persistent connection (30 seconds)...")
print(" Watch for automatic pings and reconnection attempts...")

for i in range(30):
await asyncio.sleep(1)

# Show stats every 10 seconds
if i % 10 == 0 and i > 0:
stats = persistent_client.get_connection_stats()
print(f" 📈 [{i}s] Connected: {persistent_client.is_connected}, "
f"Messages sent: {stats.get('messages_sent', 0)}, "
f"Reconnects: {stats.get('total_reconnects', 0)}")

# Show final event log
print(f"\n📋 Connection Events ({len(events_log)} total):")
for event in events_log:
print(f" • {event}")

else:
print("ℹ️ Persistent connection failed (expected with test SSID)")

except Exception as e:
print(f"ℹ️ Persistent connection error: {str(e)[:100]}...")

await persistent_client.disconnect()

except Exception as e:
print(f"ℹ️ Persistent demo error: {e}")

print()

# Demo 3: API Features with Real Data (if available)
print("📊 Demo 3: API Features and Data Operations")
print("-" * 50)

real_ssid = os.getenv("POCKET_OPTION_SSID")
if real_ssid and not "n1p5ah5u8t9438rbunpgrq0hlq" in real_ssid:
print("🔑 Real SSID detected - testing with live connection...")

try:
live_client = AsyncPocketOptionClient(
ssid=real_ssid,
is_demo=True,
auto_reconnect=True
)

success = await live_client.connect()
if success:
print("✅ Live connection established")

# Test balance
try:
balance = await live_client.get_balance()
print(f"💰 Balance: ${balance.balance:.2f} {balance.currency}")
except Exception as e:
print(f"ℹ️ Balance test: {e}")

# Test candles
try:
candles = await live_client.get_candles("EURUSD_otc", "1m", 5)
print(f"📈 Retrieved {len(candles)} candles for EURUSD_otc")

# Test DataFrame conversion
df = await live_client.get_candles_dataframe("EURUSD_otc", "1m", 5)
print(f"📊 DataFrame shape: {df.shape}")
except Exception as e:
print(f"ℹ️ Candles test: {e}")

# Test health monitoring
health = await live_client.get_health_status()
print(f"🏥 Health Status: {health}")

# Test performance metrics
metrics = await live_client.get_performance_metrics()
print(f"📊 Performance Metrics: {metrics}")

await live_client.disconnect()

except Exception as e:
print(f"❌ Live demo error: {e}")
else:
print("ℹ️ Skipping live demo - requires real SSID")
print(" Set environment variable: export POCKET_OPTION_SSID='your_complete_ssid'")

print()


def show_api_improvements():
"""Show comparison with old API"""

print("🔍 API Improvements Summary")
print("=" * 60)

print("🏗️ ARCHITECTURE IMPROVEMENTS:")
print(" Old API: Synchronous with threading")
print(" New API: Fully async/await with modern patterns")
print()

print("🔌 CONNECTION MANAGEMENT:")
print(" Old API: Manual daemon threads + run_forever()")
print(" New API: Persistent connections with asyncio tasks")
print(" ✅ Automatic ping every 20 seconds")
print(" ✅ Health monitoring and statistics")
print(" ✅ Graceful reconnection handling")
print()

print("📡 MESSAGE HANDLING:")
print(" Old API: Basic message processing")
print(" New API: Optimized message routing with caching")
print(" ✅ Message batching for performance")
print(" ✅ Event-driven callbacks")
print(" ✅ Type-safe message models")
print()

print("🛡️ ERROR HANDLING:")
print(" Old API: Basic try/catch with global variables")
print(" New API: Comprehensive error monitoring")
print(" ✅ Circuit breaker pattern")
print(" ✅ Retry mechanisms with backoff")
print(" ✅ Health checks and alerting")
print()

print("📊 DATA MANAGEMENT:")
print(" Old API: Basic data structures")
print(" New API: Modern data handling")
print(" ✅ Pydantic models for type safety")
print(" ✅ pandas DataFrame integration")
print(" ✅ Automatic data validation")
print()

print("🔧 DEVELOPER EXPERIENCE:")
print(" Old API: Manual setup and configuration")
print(" New API: Enhanced developer tools")
print(" ✅ Rich logging with loguru")
print(" ✅ Context manager support")
print(" ✅ Comprehensive testing")
print(" ✅ Performance monitoring")
print()

print("🎯 USAGE EXAMPLES:")
print()

print(" OLD API STYLE:")
print(" ```python")
print(" api = PocketOption(ssid, demo=True)")
print(" api.connect()")
print(" while api.check_connect():")
print(" balance = api.get_balance()")
print(" time.sleep(1)")
print(" ```")
print()

print(" NEW API STYLE:")
print(" ```python")
print(" ssid = r'42[\"auth\",{\"session\":\"...\",\"isDemo\":1,\"uid\":123}]'")
print(" async with AsyncPocketOptionClient(ssid=ssid, persistent_connection=True) as client:")
print(" balance = await client.get_balance()")
print(" df = await client.get_candles_dataframe('EURUSD_otc', '1m', 100)")
print(" # Connection maintained automatically with keep-alive")
print(" ```")
print()


def show_keep_alive_features():
"""Show specific keep-alive features"""

print("🔄 Keep-Alive Features Based on Old API Analysis")
print("=" * 60)

print("📋 IMPLEMENTED FEATURES:")
print("✅ Continuous ping loop (20-second intervals)")
print("✅ Automatic reconnection on disconnection")
print("✅ Multiple region fallback")
print("✅ Background task management")
print("✅ Connection health monitoring")
print("✅ Message routing and processing")
print("✅ Event-driven callbacks")
print("✅ Connection statistics tracking")
print("✅ Graceful shutdown and cleanup")
print("✅ Complete SSID format support")
print()

print("🔧 TECHNICAL IMPLEMENTATION:")
print("• AsyncWebSocketClient with persistent connections")
print("• ConnectionKeepAlive manager for advanced scenarios")
print("• Background asyncio tasks for ping/reconnect")
print("• Event handlers for connection state changes")
print("• Connection pooling with performance stats")
print("• Message batching and optimization")
print("• Health monitoring with alerts")
print()

print("📊 MONITORING CAPABILITIES:")
print("• Connection uptime tracking")
print("• Message send/receive counters")
print("• Reconnection attempt statistics")
print("• Ping response time monitoring")
print("• Health check results")
print("• Performance metrics collection")
print()

print("🎛️ CONFIGURATION OPTIONS:")
print("• persistent_connection: Enable advanced keep-alive")
print("• auto_reconnect: Automatic reconnection on failure")
print("• ping_interval: Customizable ping frequency")
print("• max_reconnect_attempts: Reconnection retry limit")
print("• connection_timeout: Connection establishment timeout")
print("• health_check_interval: Health monitoring frequency")


async def main():
"""Main demo function"""

logger.info("🚀 Starting Enhanced PocketOption API Demo")

# Run comprehensive demo
await demo_enhanced_features()

# Show improvements
show_api_improvements()

# Show keep-alive features
show_keep_alive_features()

print()
print("🎉 Enhanced PocketOption API Demo Complete!")
print()
print("📚 Next Steps:")
print("1. Set your real SSID: export POCKET_OPTION_SSID='your_complete_ssid'")
print("2. Use persistent_connection=True for long-running applications")
print("3. Monitor connection with get_connection_stats()")
print("4. Add event callbacks for connection management")
print("5. Use async context managers for automatic cleanup")
print()
print("📖 Documentation: README_ASYNC.md")
print("🧪 Examples: examples/async_examples.py")
print("🔧 Tests: test_persistent_connection.py")


if __name__ == "__main__":
asyncio.run(main())
26 changes: 26 additions & 0 deletions enhanced_performance_report.txt
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,26 @@
================================================================================
ENHANCED POCKETOPTION API PERFORMANCE REPORT
================================================================================
Generated: 2025-06-10 11:47:44

🔍 ERROR MONITORING
----------------------------------------
Total Errors: 20
Error Rate: 0.83/hour

Top Error Types:
• test_spam: 15
• connection_test_error: 1
• connection_timeout: 1
• invalid_session: 1
• order_rejected: 1

🏥 HEALTH MONITORING
----------------------------------------
Overall Status: healthy

💡 RECOMMENDATIONS
----------------------------------------
• High error count detected - investigate error patterns

================================================================================
Loading