// Ship/Vessel Tracking — aisstream.io (free real-time global AIS)
// Also includes fallback to public vessel tracking data
// Detects: dark ships, sanctions evasion, naval deployments, port congestion

import { safeFetch } from '../utils/fetch.mjs';

// aisstream.io requires a WebSocket connection for real-time data
// For briefing mode, we'll use snapshot-based approaches

// MarineTraffic-style density estimation via public endpoints
// The real power comes from running a persistent WebSocket listener

// Key maritime chokepoints to monitor
const CHOKEPOINTS = {
  straitOfHormuz: { label: 'Strait of Hormuz', lat: 26.5, lon: 56.5, note: '20% of world oil' },
  suezCanal: { label: 'Suez Canal', lat: 30.5, lon: 32.3, note: '12% of world trade' },
  straitOfMalacca: { label: 'Strait of Malacca', lat: 2.5, lon: 101.5, note: '25% of world trade' },
  babElMandeb: { label: 'Bab el-Mandeb', lat: 12.6, lon: 43.3, note: 'Red Sea gateway' },
  taiwanStrait: { label: 'Taiwan Strait', lat: 24.0, lon: 119.0, note: '88% of largest container ships' },
  bosporusStrait: { label: 'Bosphorus', lat: 41.1, lon: 29.1, note: 'Black Sea access' },
  panamaCanal: { label: 'Panama Canal', lat: 9.1, lon: -79.7, note: '5% of world trade' },
  capeOfGoodHope: { label: 'Cape of Good Hope', lat: -34.4, lon: 18.5, note: 'Suez alternative' },
};

// For non-realtime briefing, use web-searchable vessel data
export async function briefing() {
  const hasKey = !!process.env.AISSTREAM_API_KEY;

  return {
    source: 'Maritime/AIS',
    timestamp: new Date().toISOString(),
    status: hasKey ? 'ready' : 'limited',
    message: hasKey
      ? 'AIS stream connected — use WebSocket listener for real-time data'
      : 'Set AISSTREAM_API_KEY for real-time global vessel tracking (free at aisstream.io)',
    chokepoints: CHOKEPOINTS,
    monitoringCapabilities: [
      'Dark ship detection (AIS transponder shutoffs)',
      'Sanctions evasion (ship-to-ship transfers)',
      'Naval deployment tracking',
      'Port congestion (vessel dwell time)',
      'Chokepoint traffic anomalies',
      'Oil tanker route changes',
    ],
    hint: 'For now, I can use web search to check maritime news and shipping disruptions',
  };
}

// WebSocket listener setup (for persistent monitoring)
export function getWebSocketConfig(apiKey) {
  return {
    url: 'wss://stream.aisstream.io/v0/stream',
    message: JSON.stringify({
      APIKey: apiKey,
      BoundingBoxes: Object.values(CHOKEPOINTS).map(cp => [
        [cp.lat - 2, cp.lon - 2],
        [cp.lat + 2, cp.lon + 2],
      ]),
    }),
  };
}

if (process.argv[1]?.endsWith('ships.mjs')) {
  const data = await briefing();
  console.log(JSON.stringify(data, null, 2));
}