WebRTC Streaming (WHIP/WHEP)

import { WaveWebRTC } from '@wave/webrtc-sdk';

const publisher = new WaveWebRTC({
  apiKey: 'wave_live_xxxxx',
  streamId: 'str_abc123xyz'
});

// Get user media with optimal constraints
const stream = await navigator.mediaDevices.getUserMedia({
  video: {
    width: { ideal: 1920, min: 1280 },
    height: { ideal: 1080, min: 720 },
    frameRate: { ideal: 30, max: 60 },
    facingMode: 'user'
  },
  audio: {
    echoCancellation: true,
    noiseSuppression: true,
    autoGainControl: true,
    sampleRate: 48000
  }
});

// Start publishing via WHIP with simulcast
await publisher.publish(stream, {
  simulcast: true,
  layers: [
    { rid: 'h', maxBitrate: 2500000, scaleResolutionDownBy: 1 },    // 1080p
    { rid: 'm', maxBitrate: 1000000, scaleResolutionDownBy: 2 },    // 540p
    { rid: 'l', maxBitrate: 500000, scaleResolutionDownBy: 4 }      // 270p
  ],
  preferredCodec: 'VP9', // VP8, VP9, or H264
  degradationPreference: 'balanced' // or 'maintain-framerate', 'maintain-resolution'
});

// Monitor connection quality
publisher.on('stats', (stats) => {
  console.log('Connection stats:', {
    bitrate: Math.round(stats.video.bytesSent / 1024) + ' kbps',
    packetLoss: (stats.video.packetsLost / stats.video.packetsSent * 100).toFixed(2) + '%',
    rtt: Math.round(stats.video.roundTripTime * 1000) + 'ms',
    framesPerSecond: stats.video.framesPerSecond,
    qualityLimitationReason: stats.video.qualityLimitationReason
  });
});

// Handle disconnection with automatic reconnect
publisher.on('disconnected', async (reason) => {
  console.log('Disconnected:', reason);
  let delay = 1000;
  while (!publisher.connected && delay <= 8000) {
    await new Promise(r => setTimeout(r, delay));
    try {
      await publisher.reconnect();
      console.log('Reconnected successfully');
      break;
    } catch (e) {
      delay *= 2;
    }
  }
});

// Stop publishing
// await publisher.stop();