// Recommended: Sec-WebSocket-Protocol Header
const ws = new WebSocket(url, ['Bearer', 'eyJhbGciOiJIUzI1NiIs...']);

// Discouraged: Query String
const ws = new WebSocket('wss://example.com/ws/all/?token=eyJhbGciOiJIUzI1NiIs...');

{
  "action": "subscribe",
  "topics": ["aircraft", "safety"]
}

{
  "type": "aircraft:update",
  "data": { }
}

{
  "type": "batch",
  "messages": [
    { "type": "aircraft:update", "data": {} },
    { "type": "aircraft:update", "data": {} }
  ],
  "count": 2,
  "timestamp": "2024-01-15T10:30:00.000Z"
}

{
  "action": "request",
  "type": "aircraft-info",
  "request_id": "req_abc123",
  "params": {
    "icao": "A1B2C3"
  }
}

{
  "type": "response",
  "request_id": "req_abc123",
  "request_type": "aircraft-info",
  "data": {
    "icao_hex": "A1B2C3",
    "registration": "N12345",
    "type_code": "B738",
    "operator": "Southwest Airlines"
  }
}

{
  "type": "error",
  "request_id": "req_abc123",
  "message": "Aircraft not found"
}

{
  "type": "aircraft:snapshot",
  "data": {
    "aircraft": [
      {
        "hex": "A1B2C3",
        "flight": "SWA1234",
        "lat": 33.9425,
        "lon": -118.4081,
        "alt_baro": 35000,
        "gs": 450,
        "track": 270,
        "baro_rate": 0,
        "squawk": "1200",
        "category": "A3",
        "is_military": false,
        "distance_nm": 25.4
      }
    ],
    "count": 42,
    "timestamp": "2024-01-15T10:30:00.000Z"
  }
}

{
  "type": "aircraft:delta",
  "data": {
    "hex": "A1B2C3",
    "changes": {
      "lat": 33.9430,
      "lon": -118.4090,
      "alt": 35100
    }
  }
}

{
  "type": "aircraft:new",
  "data": {
    "hex": "A1B2C3",
    "flight": "UAL456",
    "lat": 34.0522,
    "lon": -118.2437,
    "alt_baro": 5000
  }
}

{
  "type": "aircraft:remove",
  "data": {
    "hex": "A1B2C3",
    "reason": "timeout"
  }
}

{
  "type": "safety:event",
  "data": {
    "id": 124,
    "timestamp": "2024-01-15T10:31:00.000Z",
    "event_type": "emergency_squawk",
    "severity": "critical",
    "icao_hex": "A1B2C3",
    "callsign": "N12345",
    "message": "Emergency squawk 7700 detected",
    "details": {
      "squawk": "7700",
      "altitude": 10000,
      "position": { "lat": 34.05, "lon": -118.25 }
    }
  }
}

{
  "type": "safety:snapshot",
  "data": {
    "events": [
      {
        "id": 123,
        "timestamp": "2024-01-15T10:30:00.000Z",
        "event_type": "TCAS_RA",
        "severity": "high",
        "icao_hex": "A1B2C3",
        "icao_hex_2": "D4E5F6",
        "callsign": "UAL123",
        "callsign_2": "DAL456",
        "message": "TCAS Resolution Advisory - Climb",
        "acknowledged": false
      }
    ],
    "count": 1,
    "timestamp": "2024-01-15T10:30:00.000Z"
  }
}

{
  "type": "alert:triggered",
  "data": {
    "id": 457,
    "rule_id": 12,
    "rule_name": "Low Altitude Alert",
    "icao_hex": "A1B2C3",
    "callsign": "N12345",
    "message": "Aircraft below 1000ft detected",
    "priority": "medium",
    "aircraft_data": {
      "hex": "A1B2C3",
      "alt_baro": 800,
      "lat": 34.05,
      "lon": -118.25
    },
    "triggered_at": "2024-01-15T10:31:00.000Z"
  }
}

{
  "type": "acars:message",
  "data": {
    "id": 790,
    "timestamp": "2024-01-15T10:31:00.000Z",
    "source": "ACARS",
    "channel": 3,
    "frequency": "131.550",
    "icao_hex": "A1B2C3",
    "registration": "N12345",
    "callsign": "UAL123",
    "label": "SQ",
    "block_id": "A",
    "msg_num": "001",
    "text": "REQUEST OCEANIC CLEARANCE",
    "decoded": {
      "message_type": "clearance_request",
      "route": "NATU TRACK A"
    },
    "signal_level": -42.5
  }
}

{
  "type": "notams:tfr_new",
  "data": {
    "id": 302,
    "notam_id": "1/2346",
    "type": "TFR",
    "location": "KSFO",
    "latitude": 37.6213,
    "longitude": -122.3790,
    "radius_nm": 10,
    "floor_ft": 0,
    "ceiling_ft": 18000,
    "reason": "Stadium Event",
    "effective_start": "2024-01-15T18:00:00.000Z",
    "effective_end": "2024-01-15T23:00:00.000Z"
  }
}

{
  "type": "audio:transcription_completed",
  "data": {
    "id": 501,
    "transcript": "United four five six heavy, runway two five left, cleared for takeoff",
    "transcript_confidence": 0.95,
    "identified_airframes": ["UAL456"],
    "transcription_completed_at": "2024-01-15T10:30:15.000Z"
  }
}

{
  "type": "threats",
  "data": [
    {
      "hex": "A1B2C3",
      "callsign": "N12345",
      "category": "Law Enforcement",
      "description": "Police Helicopter",
      "distance_nm": 2.5,
      "bearing": 45,
      "relative_bearing": 315,
      "direction": "NE",
      "altitude": 1500,
      "ground_speed": 80,
      "trend": "approaching",
      "threat_level": "warning",
      "is_law_enforcement": true,
      "is_helicopter": true,
      "confidence": "high",
      "lat": 34.06,
      "lon": -118.24
    }
  ],
  "count": 1,
  "position": { "lat": 34.05, "lon": -118.25 },
  "timestamp": "2024-01-15T10:30:00.000Z"
}

import { useState, useEffect, useCallback, useRef } from 'react';

function useSkySpy(endpoint = 'all', topics = ['aircraft']) {
  const [connected, setConnected] = useState(false);
  const [aircraft, setAircraft] = useState([]);
  const wsRef = useRef(null);
  const reconnectAttempt = useRef(0);

  const connect = useCallback(() => {
    const protocol = window.location.protocol === 'https:' ? 'wss:' : 'ws:';
    const url = `${protocol}//${window.location.host}/ws/${endpoint}/`;

    const ws = new WebSocket(url);
    wsRef.current = ws;

    ws.onopen = () => {
      setConnected(true);
      reconnectAttempt.current = 0;

      // Subscribe to topics
      ws.send(JSON.stringify({
        action: 'subscribe',
        topics: topics
      }));
    };

    ws.onmessage = (event) => {
      const data = JSON.parse(event.data);

      // Handle batch messages
      if (data.type === 'batch') {
        data.messages.forEach(handleMessage);
        return;
      }

      handleMessage(data);
    };

    ws.onclose = (event) => {
      setConnected(false);

      // Reconnect unless normal close or auth failure
      if (event.code !== 1000 && event.code !== 1001 && event.code !== 4001) {
        const delay = Math.min(1000 * Math.pow(2, reconnectAttempt.current), 30000);
        reconnectAttempt.current++;
        setTimeout(connect, delay);
      }
    };
  }, [endpoint, topics]);

  const handleMessage = useCallback((data) => {
    switch (data.type) {
      case 'aircraft:snapshot':
      case 'aircraft:update':
        setAircraft(data.data.aircraft || []);
        break;
      case 'aircraft:new':
        setAircraft(prev => [...prev, data.data]);
        break;
      case 'aircraft:remove':
        setAircraft(prev => prev.filter(a => a.hex !== data.data.hex));
        break;
    }
  }, []);

  useEffect(() => {
    connect();
    return () => {
      if (wsRef.current) {
        wsRef.current.close(1000);
      }
    };
  }, [connect]);

  return { connected, aircraft };
}

import asyncio
import json
import websockets

async def skyspy_client():
    uri = "wss://example.com/ws/all/"

    async with websockets.connect(uri) as websocket:
        # Subscribe to topics
        await websocket.send(json.dumps({
            "action": "subscribe",
            "topics": ["aircraft", "safety"]
        }))

        # Listen for messages
        async for message in websocket:
            data = json.loads(message)

            if data["type"] == "batch":
                for msg in data["messages"]:
                    process_message(msg)
            else:
                process_message(data)

def process_message(data):
    msg_type = data.get("type", "")

    if msg_type == "aircraft:snapshot":
        aircraft = data["data"]["aircraft"]
        print(f"Received {len(aircraft)} aircraft")

    elif msg_type == "safety:event":
        event = data["data"]
        print(f"Safety event: {event['event_type']} - {event['message']}")

# Run the client
asyncio.run(skyspy_client())

# Using websocat for testing
websocat wss://example.com/ws/all/

# Send subscription
{"action": "subscribe", "topics": ["aircraft"]}

# Send request
{"action": "request", "type": "aircraft-stats", "request_id": "test1", "params": {}}

{
  "type": "error",
  "message": "Description of the error",
  "request_id": "abc123"
}

localStorage.setItem('ws_debug', 'true');

LOGGING = {
    'loggers': {
        'skyspy.channels': {
            'level': 'DEBUG',
        },
    },
}