All Prices API - One Call, All Commodities

import websocket
import json
import threading

class PriceAlertSystem:
    def __init__(self, api_key, alert_threshold=2.0):
        self.api_key = api_key
        self.alert_threshold = alert_threshold
        self.ws = None

    def on_message(self, ws, message):
        data = json.loads(message)

        if data.get('type') == 'ping':
            return

        if 'message' in data:
            self.handle_price_update(data['message'])

    def handle_price_update(self, data):
        if data.get('type') == 'price_update':
            price_data = data['data']

            # Check alert condition: >2% daily change
            change_percent = abs(price_data.get('change_24h_percent', 0))
            if change_percent > self.alert_threshold:
                self.trigger_alert(price_data, change_percent)

    def trigger_alert(self, price_data, change_percent):
        direction = "📈" if price_data.get('change_24h', 0) > 0 else "📉"
        print(f"🚨 PRICE ALERT: {price_data['name']} {direction}")
        print(f"   Current: ${price_data['price']}")
        print(f"   Change: {change_percent:.2f}% in 24h")
        print(f"   Time: {price_data['created_at']}\n")

        # Add your alert logic here:
        # - Send email notification
        # - Push to mobile app
        # - Log to database
        # - Trigger trading bot

    def on_error(self, ws, error):
        print(f"WebSocket error: {error}")

    def on_close(self, ws):
        print("Price alert connection closed")

    def on_open(self, ws):
        print("✅ Connected to real-time price alerts")

        # Subscribe to all commodity price updates
        subscribe_message = {
            'command': 'subscribe',
            'identifier': json.dumps({
                'channel': 'EnergyPricesChannel',
                'api_key': self.api_key
            })
        }
        ws.send(json.dumps(subscribe_message))

    def start_monitoring(self):
        websocket.enableTrace(False)
        self.ws = websocket.WebSocketApp(
            "wss://api.oilpriceapi.com/cable",
            on_message=self.on_message,
            on_error=self.on_error,
            on_close=self.on_close,
            on_open=self.on_open
        )

        # Run forever - use threading for background operation
        self.ws.run_forever()

# Usage - Real-time alerts with 2% threshold
alert_system = PriceAlertSystem('YOUR_API_KEY', alert_threshold=2.0)

# Start monitoring in background thread
monitor_thread = threading.Thread(target=alert_system.start_monitoring)
monitor_thread.daemon = True
monitor_thread.start()

print("🔄 Price alert system running...")
print("Will alert on price moves >2%")

# Keep main thread alive
try:
    while True:
        time.sleep(1)
except KeyboardInterrupt:
    print("\n⏹️  Stopping price alerts...")