Analytics

// Play started first time
fetch('https://your-server.com/LiveApp/rest/v2/events/play', {
  method: 'POST',
  headers: {'Content-Type': 'application/json'},
  body: JSON.stringify({
    event: 'playStartedFirstTime',
    streamId: 'stream123',
    protocol: 'webrtc',
    subscriberId: 'user-uuid-12345',
    token: 'jwt-token-if-secured'
  })
});

// Play paused
fetch('https://your-server.com/LiveApp/rest/v2/events/play', {
  method: 'POST',
  headers: {'Content-Type': 'application/json'},
  body: JSON.stringify({
    event: 'playPaused',
    streamId: 'stream123',
    protocol: 'hls',
    subscriberId: 'user-uuid-12345'
  })
});

{
  "startTimeMs": 10000,
  "watchTimeMs": 5000
}

// Track watch time
fetch('https://your-server.com/LiveApp/rest/v2/events/watch-time', {
  method: 'POST',
  headers: {'Content-Type': 'application/json'},
  body: JSON.stringify({
    event: 'watchTime',
    streamId: 'stream123',
    protocol: 'webrtc',
    watchTimeMs: 5000,      // Watched for 5 seconds
    startTimeMs: 10000,     // Starting at 10 seconds into video
    subscriberId: 'user-uuid-12345',
    token: 'jwt-token-if-secured'
  })
});

let lastReportTime = 0;
const REPORT_INTERVAL = 10000; // Report every 10 seconds

function reportWatchTime(player) {
  const currentTime = player.getCurrentTime() * 1000; // Convert to ms
  const watchDuration = currentTime - lastReportTime;
  
  if (watchDuration >= REPORT_INTERVAL) {
    fetch('https://your-server.com/LiveApp/rest/v2/events/watch-time', {
      method: 'POST',
      headers: {'Content-Type': 'application/json'},
      body: JSON.stringify({
        event: 'watchTime',
        streamId: currentStreamId,
        protocol: 'webrtc',
        watchTimeMs: watchDuration,
        startTimeMs: lastReportTime,
        subscriberId: userId
      })
    });
    
    lastReportTime = currentTime;
  }
}

// Call periodically
setInterval(() => reportWatchTime(player), 5000);

{
  "secureAnalyticEndpoint": true,
  "jwtSecretKey": "your-secret-key-here"
}

// Example using jsonwebtoken library
const jwt = require('jsonwebtoken');

const token = jwt.sign(
  {
    streamId: 'stream123',
    type: 'play'
  },
  'your-secret-key-here',
  { expiresIn: '1h' }
);

// Include token in analytics events
fetch('https://your-server.com/LiveApp/rest/v2/events/play', {
  method: 'POST',
  headers: {'Content-Type': 'application/json'},
  body: JSON.stringify({
    event: 'playStarted',
    streamId: 'stream123',
    token: token  // Include JWT token
  })
});

{
  "event": "event-type",
  "timeMs": 1646567890000,
  "app": "LiveApp",
  "streamId": "stream123",
  "logSource": "client",
  "token": "jwt-token",
  "subscriberId": "user-id"
}

{
  "protocol": "webrtc",
  "clientIP": "192.168.1.100"
}

{
  "watchTimeMs": 5000,
  "startTimeMs": 10000
}

Analytics: {"event":"playStarted","streamId":"stream123","protocol":"webrtc",...}

class AnalyticsTracker {
  constructor(streamId, appName, subscriberId) {
    this.streamId = streamId;
    this.appName = appName;
    this.subscriberId = subscriberId;
    this.baseUrl = `https://your-server.com/${appName}/rest/v2/events`;
    this.firstPlay = true;
    this.watchStartTime = 0;
  }
  
  async sendEvent(endpoint, data) {
    try {
      await fetch(`${this.baseUrl}/${endpoint}`, {
        method: 'POST',
        headers: {'Content-Type': 'application/json'},
        body: JSON.stringify({
          streamId: this.streamId,
          subscriberId: this.subscriberId,
          protocol: 'webrtc',
          ...data
        })
      });
    } catch (error) {
      console.error('Analytics error:', error);
    }
  }
  
  onPlayStarted() {
    if (this.firstPlay) {
      this.sendEvent('play', {event: 'playStartedFirstTime'});
      this.firstPlay = false;
    }
    this.sendEvent('play', {event: 'playStarted'});
    this.watchStartTime = Date.now();
  }
  
  onPlayPaused() {
    this.sendEvent('play', {event: 'playPaused'});
    this.reportWatchTime();
  }
  
  onPlayEnded() {
    this.reportWatchTime();
    this.sendEvent('play', {event: 'playEnded'});
  }
  
  reportWatchTime() {
    const watchTimeMs = Date.now() - this.watchStartTime;
    if (watchTimeMs > 0) {
      this.sendEvent('watch-time', {
        event: 'watchTime',
        watchTimeMs: watchTimeMs,
        startTimeMs: this.watchStartTime
      });
    }
  }
}

// Usage
const analytics = new AnalyticsTracker('stream123', 'LiveApp', 'user-uuid');
player.on('play', () => analytics.onPlayStarted());
player.on('pause', () => analytics.onPlayPaused());
player.on('ended', () => analytics.onPlayEnded());

// Using hls.js with analytics
const hls = new Hls();
const analytics = new AnalyticsTracker('stream123', 'LiveApp', 'user-uuid');
const video = document.getElementById('video');

hls.loadSource('https://your-server.com/LiveApp/streams/stream123.m3u8');
hls.attachMedia(video);

video.addEventListener('play', () => analytics.onPlayStarted());
video.addEventListener('pause', () => analytics.onPlayPaused());
video.addEventListener('ended', () => analytics.onPlayEnded());

// Report watch time every 10 seconds
setInterval(() => {
  if (!video.paused) {
    analytics.reportWatchTime();
    analytics.watchStartTime = Date.now();
  }
}, 10000);

# Count playStartedFirstTime events
grep 'playStartedFirstTime' application.log | wc -l

# Sum watchTimeMs from watch-time events
grep 'watchTime' application.log | \
  jq -r '.watchTimeMs' | \
  awk '{sum+=$1; count++} END {print sum/count}'

# Get current viewer count from system resources
curl -s http://localhost:5080/rest/v2/system-resources-info | \
  jq '.localWebRTCViewers + .localHLSViewers + .localDASHViewers'

// Send to GA4
gtag('event', 'play_started', {
  'stream_id': streamId,
  'protocol': 'webrtc'
});