// Subscribe to specific topics
socket.emit('subscribe', { 
  topics: ['aircraft', 'safety', 'alerts'] 
});

socket.on('subscribed', (data) => {
  console.log('Subscribed to:', data.topics);
  console.log('Successfully joined:', data.joined);
  if (data.denied) {
    console.warn('Permission denied for:', data.denied);
  }
});

# Subscribe to specific topics
sio.emit('subscribe', {
    'topics': ['aircraft', 'safety', 'alerts']
})

@sio.event
def subscribed(data):
    print('Subscribed to:', data.get('topics'))
    print('Successfully joined:', data.get('joined'))
    if data.get('denied'):
        print('Permission denied for:', data.get('denied'))

const aircraftMap = new Map();

socket.on('aircraft:snapshot', (data) => {
  console.log(`Initial snapshot: ${data.count} aircraft`);
  data.aircraft.forEach(ac => {
    aircraftMap.set(ac.hex, ac);
  });
  renderMap(aircraftMap);
});

socket.on('aircraft:update', (aircraft) => {
  // Update or add aircraft
  if (Array.isArray(aircraft)) {
    aircraft.forEach(ac => aircraftMap.set(ac.hex, ac));
  } else {
    aircraftMap.set(aircraft.hex, aircraft);
  }
  renderMap(aircraftMap);
});

socket.on('aircraft:new', (aircraft) => {
  console.log(`New aircraft: ${aircraft.flight || aircraft.hex}`);
  aircraftMap.set(aircraft.hex, aircraft);
  renderMap(aircraftMap);
});

socket.on('aircraft:remove', (data) => {
  console.log(`Removed: ${data.hex} (${data.reason || 'timeout'})`);
  aircraftMap.delete(data.hex);
  renderMap(aircraftMap);
});

socket.on('aircraft:delta', (delta) => {
  // Merge delta into existing aircraft
  const existing = aircraftMap.get(delta.hex);
  if (existing) {
    Object.assign(existing, delta);
    renderMap(aircraftMap);
  }
});

aircraft_map = {}

@sio.event
def aircraft_snapshot(data):
    print(f"Initial snapshot: {data.get('count')} aircraft")
    for ac in data.get('aircraft', []):
        aircraft_map[ac['hex']] = ac
    render_map(aircraft_map)

@sio.event
def aircraft_update(aircraft):
    # Update or add aircraft
    if isinstance(aircraft, list):
        for ac in aircraft:
            aircraft_map[ac['hex']] = ac
    else:
        aircraft_map[aircraft['hex']] = aircraft
    render_map(aircraft_map)

@sio.event
def aircraft_new(aircraft):
    print(f"New aircraft: {aircraft.get('flight') or aircraft['hex']}")
    aircraft_map[aircraft['hex']] = aircraft
    render_map(aircraft_map)

@sio.event
def aircraft_remove(data):
    hex_code = data.get('hex')
    reason = data.get('reason', 'timeout')
    print(f"Removed: {hex_code} ({reason})")
    aircraft_map.pop(hex_code, None)
    render_map(aircraft_map)

@sio.event
def aircraft_delta(delta):
    # Merge delta into existing aircraft
    hex_code = delta.get('hex')
    if hex_code in aircraft_map:
        aircraft_map[hex_code].update(delta)
        render_map(aircraft_map)

socket.on('safety:snapshot', (data) => {
  console.log(`Active safety events: ${data.count}`);
  data.events.forEach(event => {
    displaySafetyAlert(event);
  });
});

socket.on('safety:event', (event) => {
  console.warn(`⚠️  ${event.severity.toUpperCase()}: ${event.message}`);
  
  // Play alert sound for critical events
  if (event.severity === 'critical') {
    playAlertSound();
  }
  
  // Show notification
  showNotification({
    title: `Safety Alert: ${event.event_type}`,
    body: event.message,
    icon: 'warning',
    data: event
  });
  
  // Display in UI
  displaySafetyAlert(event);
});

@sio.event
def safety_snapshot(data):
    print(f"Active safety events: {data.get('count')}")
    for event in data.get('events', []):
        display_safety_alert(event)

@sio.event
def safety_event(event):
    severity = event.get('severity', 'unknown').upper()
    message = event.get('message', '')
    print(f"⚠️  {severity}: {message}")
    
    # Play alert sound for critical events
    if event.get('severity') == 'critical':
        play_alert_sound()
    
    # Send notification
    send_notification(
        title=f"Safety Alert: {event.get('event_type')}",
        body=message,
        data=event
    )
    
    # Display in UI
    display_safety_alert(event)

socket.on('alert:triggered', (alert) => {
  console.log('Alert triggered:', alert.rule_name);
  
  // Show notification
  showNotification({
    title: alert.rule_name,
    body: `${alert.aircraft.flight || alert.aircraft.hex} - ${alert.message}`,
    icon: 'alert',
    data: alert
  });
  
  // Send push notification if enabled
  if (alert.rule.notification_channels.includes('push')) {
    sendPushNotification(alert);
  }
  
  // Log to alert history
  logAlert(alert);
});

@sio.event
def alert_triggered(alert):
    print(f"Alert triggered: {alert.get('rule_name')}")
    
    aircraft = alert.get('aircraft', {})
    flight = aircraft.get('flight') or aircraft.get('hex')
    message = alert.get('message', '')
    
    # Send notification
    send_notification(
        title=alert.get('rule_name'),
        body=f"{flight} - {message}",
        data=alert
    )
    
    # Send push notification if enabled
    rule = alert.get('rule', {})
    if 'push' in rule.get('notification_channels', []):
        send_push_notification(alert)
    
    # Log to alert history
    log_alert(alert)

// Request aircraft info
const requestId = `req_${Date.now()}`;
socket.emit('request', {
  type: 'aircraft-info',
  request_id: requestId,
  params: { icao: 'A1B2C3' }
});

socket.on('response', (data) => {
  if (data.request_id === requestId) {
    console.log('Aircraft info:', data.data);
  }
});

// Request sightings with pagination
const sightingsId = `req_${Date.now()}`;
socket.emit('request', {
  type: 'sightings',
  request_id: sightingsId,
  params: {
    hours: 24,
    limit: 50,
    offset: 0,
    icao_hex: 'A1B2C3'
  }
});

import uuid

# Request aircraft info
request_id = f"req_{uuid.uuid4().hex}"
sio.emit('request', {
    'type': 'aircraft-info',
    'request_id': request_id,
    'params': {'icao': 'A1B2C3'}
})

@sio.event
def response(data):
    if data.get('request_id') == request_id:
        print('Aircraft info:', data.get('data'))

# Request sightings with pagination
sightings_id = f"req_{uuid.uuid4().hex}"
sio.emit('request', {
    'type': 'sightings',
    'request_id': sightings_id,
    'params': {
        'hours': 24,
        'limit': 50,
        'offset': 0,
        'icao_hex': 'A1B2C3'
    }
})

socket.on('stats:update', (stats) => {
  updateDashboard({
    total: stats.total_aircraft,
    military: stats.military_count,
    commercial: stats.commercial_count,
    avgAltitude: stats.avg_altitude,
    maxDistance: stats.max_distance_nm
  });
});

@sio.event
def stats_update(stats):
    update_dashboard(
        total=stats.get('total_aircraft'),
        military=stats.get('military_count'),
        commercial=stats.get('commercial_count'),
        avg_altitude=stats.get('avg_altitude'),
        max_distance=stats.get('max_distance_nm')
    )