RTMP Protocol Deep Dive

import { WaveClient } from '@wave/api-client';

import { DesignTokens, getContainer, getSection } from '@/lib/design-tokens';
const wave = new WaveClient({ apiKey: 'wave_live_xxxxx' });

// Create RTMP stream with custom configuration
const stream = await wave.streams.create({
  title: 'Professional RTMP Broadcast',
  protocol: 'rtmp',
  rtmp: {
    // Encoder will connect to this URL
    chunkSize: 4096,           // Larger chunks for better performance

    // Platform-specific settings
    platform: 'custom',        // 'youtube' | 'facebook' | 'twitch' | 'custom'

    // Recording options
    recording: {
      enabled: true,
      format: 'mp4',
      quality: 'source'        // Record at source quality
    },

    // Transcoding options (server-side ABR)
    transcoding: {
      enabled: true,
      profiles: [
        { resolution: '1080p', bitrate: 6000, fps: 60 },
        { resolution: '720p', bitrate: 4500, fps: 60 },
        { resolution: '720p', bitrate: 2500, fps: 30 },
        { resolution: '480p', bitrate: 1000, fps: 30 }
      ]
    }
  }
});

console.log('RTMP URL:', stream.ingest.rtmp.url);
console.log('Stream Key:', stream.ingest.rtmp.streamKey);
console.log('Full URL for OBS:', `${stream.ingest.rtmp.url}${stream.ingest.rtmp.streamKey}`);

// Monitor stream health
const health = await wave.streams.getHealth(stream.id);
console.log('Stream Status:', health.status);           // 'live' | 'idle' | 'error'
console.log('Current Bitrate:', health.rtmp.bitrate);   // Kbps
console.log('Dropped Frames:', health.rtmp.droppedFrames);
console.log('FPS:', health.rtmp.fps);
console.log('Resolution:', health.rtmp.resolution);
console.log('Codec:', health.rtmp.codec);               // 'h264' | 'hevc'

// Get stream analytics
const analytics = await wave.streams.getAnalytics(stream.id, {
  period: '1h',
  metrics: ['bitrate', 'fps', 'viewers', 'dropped_frames']
});

console.log('Average Bitrate:', analytics.bitrate.avg);
console.log('Peak Viewers:', analytics.viewers.max);
console.log('Total Dropped Frames:', analytics.dropped_frames.total);

// Multi-platform simulcast
const simulcast = await wave.streams.createSimulcast({
  sourceStream: stream.id,
  destinations: [
    {
      platform: 'youtube',
      rtmpUrl: 'rtmp://a.rtmp.youtube.com/live2',
      streamKey: 'your-youtube-key'
    },
    {
      platform: 'facebook',
      rtmpUrl: 'rtmps://live-api-s.facebook.com:443/rtmp/',
      streamKey: 'your-facebook-key'
    },
    {
      platform: 'twitch',
      rtmpUrl: 'rtmp://live.twitch.tv/app/',
      streamKey: 'your-twitch-key'
    }
  ]
});

console.log('Simulcast Active:', simulcast.destinations.map(d => d.platform));

// Handle stream events via webhook
wave.webhooks.on('stream.started', (event) => {
  console.log('Stream started:', event.stream.id);
  console.log('Encoder:', event.stream.rtmp.encoder);
  console.log('Resolution:', event.stream.rtmp.resolution);
});

wave.webhooks.on('stream.health.warning', (event) => {
  console.warn('Stream health warning:', event.message);
  console.warn('Dropped frames:', event.rtmp.droppedFrames);
  // Send alert to streamer
});

wave.webhooks.on('stream.ended', (event) => {
  console.log('Stream ended:', event.stream.id);
  console.log('Duration:', event.duration);
  console.log('Recording URL:', event.recording.url);
});