import { useCallback, useEffect, useRef, useState } from 'react'; import { WhepPlayer } from '../lib/whepPlayer.js'; const RESTART_DELAY_MS = 2000; const UNMUTE_RETRY_MS = 3000; function buildBatteryVisual(charge, config) { const full = config?.Full; const warn = config?.Warn; const urgent = config?.Urgent ?? null; if (charge == null || full == null || warn == null) { return { available: false }; } const span = full - warn; if (span <= 0) return { available: false }; const normalized = (charge - warn) / span; const percent = Math.min(1, Math.max(0, normalized)); const percentDisplay = Math.round(percent * 100); const depleted = normalized <= 0; const warnTriggered = urgent != null && charge <= urgent; const barClass = depleted ? 'bg-red-500 animate-pulse' : warnTriggered ? 'bg-amber-400' : 'bg-emerald-500'; return { available: true, percentDisplay, depleted, warnTriggered, barClass, }; } export default function VideoTile({ sessionInfo, audioSessionInfo, label, forceMute = false, telemetryFrame, batteryConfig, layoutFormat = 'desktop', hudVariant = 'default', driverLabel = null, }) { const videoRef = useRef(null); const audioRef = useRef(null); const restartTimer = useRef(null); const audioRestartTimer = useRef(null); const unmuteTimer = useRef(null); const [status, setStatus] = useState('idle'); const [detail, setDetail] = useState(null); const [audioStatus, setAudioStatus] = useState('idle'); const [audioDetail, setAudioDetail] = useState(null); const [restartToken, setRestartToken] = useState(0); const [audioRestartToken, setAudioRestartToken] = useState(0); const [muted, setMuted] = useState(true); const sensors = telemetryFrame?.sensors; const batteryCharge = sensors?.batteryChargeMah ?? null; const desktopLayout = layoutFormat === 'desktop'; const batteryVisual = buildBatteryVisual(batteryCharge, batteryConfig); // console.log('[BatteryBarDebug]', { // frameSensors: sensors, // batteryCharge, // batteryCapacity, // config: batteryConfig, // }); const wheelOvercurrents = sensors?.wheelOvercurrents || null; const overcurrentMotors = wheelOvercurrents == null ? [] : Object.entries(wheelOvercurrents) .filter(([, active]) => Boolean(active)) .map(([key]) => key); const scheduleRestart = useCallback(() => { clearTimeout(restartTimer.current); restartTimer.current = setTimeout(() => setRestartToken(Date.now()), RESTART_DELAY_MS); }, []); const scheduleAudioRestart = useCallback(() => { clearTimeout(audioRestartTimer.current); audioRestartTimer.current = setTimeout(() => setAudioRestartToken(Date.now()), RESTART_DELAY_MS); }, []); const ensurePlayback = useCallback(async () => { const video = videoRef.current; if (!video) return; try { video.muted = true; await video.play(); } catch { // Autoplay might still be blocked; retry logic elsewhere will handle it. } }, []); const attemptUnmute = useCallback( (delay = 0) => { if (forceMute) return; clearTimeout(unmuteTimer.current); const scheduleRetry = () => { clearTimeout(unmuteTimer.current); unmuteTimer.current = setTimeout(() => { if (!forceMute) { tryPlay(); } }, UNMUTE_RETRY_MS); }; const tryPlay = async () => { const video = videoRef.current; if (!video) return; try { await ensurePlayback(); video.muted = false; await video.play(); setMuted(false); } catch { video.muted = true; setMuted(true); scheduleRetry(); } }; unmuteTimer.current = setTimeout(tryPlay, delay); }, [ensurePlayback, forceMute], ); useEffect( () => () => { clearTimeout(restartTimer.current); clearTimeout(audioRestartTimer.current); clearTimeout(unmuteTimer.current); }, [], ); useEffect(() => { if (status === 'playing') { attemptUnmute(0); } }, [status, attemptUnmute]); useEffect(() => { if (!sessionInfo?.url || !videoRef.current) { return undefined; } let active = true; let player; const resetMuteId = setTimeout(() => setMuted(true), 0); const handleStatus = (nextStatus, info) => { if (!active) return; setStatus(nextStatus); setDetail(info || null); if (nextStatus === 'playing') { ensurePlayback(); } if (['error', 'failed', 'disconnected', 'closed'].includes(nextStatus)) { scheduleRestart(); } }; player = new WhepPlayer({ url: sessionInfo.url, token: sessionInfo.token, video: videoRef.current, onStatus: handleStatus, }); player.start().catch((err) => { if (!active) return; setStatus('error'); setDetail(err.message); scheduleRestart(); }); return () => { active = false; clearTimeout(resetMuteId); player?.stop(); }; }, [sessionInfo?.url, sessionInfo?.token, restartToken, scheduleRestart, ensurePlayback]); useEffect(() => { if (status === 'stopped' && sessionInfo?.url) { scheduleRestart(); } }, [status, sessionInfo?.url, scheduleRestart]); // Audio-only WHEP (no pausing/muting; keeps trying to play) useEffect(() => { if (!audioSessionInfo?.url || !audioRef.current) { return undefined; } let active = true; let player; const handleStatus = (nextStatus, info) => { if (!active) return; setAudioStatus(nextStatus); setAudioDetail(info || null); if (nextStatus === 'playing') { audioRef.current?.play().catch(() => {}); } if (['error', 'failed', 'disconnected', 'closed'].includes(nextStatus)) { scheduleAudioRestart(); } }; player = new WhepPlayer({ url: audioSessionInfo.url, token: audioSessionInfo.token, video: audioRef.current, audioOnly: true, onStatus: handleStatus, }); player.start().catch((err) => { if (!active) return; setAudioStatus('error'); setAudioDetail(err.message); scheduleAudioRestart(); }); return () => { active = false; player?.stop(); }; }, [audioSessionInfo?.url, audioSessionInfo?.token, audioRestartToken, scheduleAudioRestart]); const renderedStatus = !sessionInfo?.url ? 'waiting' : status === 'error' ? `Error: ${detail || 'unknown'}` : detail ? `${status} (${detail})` : status; const renderedAudioStatus = audioSessionInfo?.error ? `Error: ${audioSessionInfo.error}` : !audioSessionInfo?.url ? null : audioStatus === 'error' ? `Error: ${audioDetail || 'unknown'}` : audioDetail ? `${audioStatus} (${audioDetail})` : audioStatus; const showVerticalBattery = hudVariant === 'spectator'; return (
{!showVerticalBattery && }
); } function BatteryBar({ visual }) { if (!visual?.available) { return (

Battery telemetry unavailable

); } const percentText = `${visual.percentDisplay}%`; const barClass = visual.barClass; return (
Battery {percentText}
); } function BatteryBarVertical({ visual }) { if (!visual?.available) return null; const percentText = `${visual.percentDisplay}%`; return (
{percentText}
); } function HudOverlay({ frame, label, status, audioStatus, desktopLayout = true, variant = 'default', driverLabel = null, battery, }) { const sensors = frame?.sensors; const bumps = sensors?.bumpsAndWheelDrops || {}; const [now, setNow] = useState(() => Date.now()); useEffect(() => { const interval = setInterval(() => setNow(Date.now()), 150); return () => clearInterval(interval); }, []); const pulse = frame?.receivedAt ? now - frame.receivedAt < 200 : false; if (variant === 'spectator') { const telemetryEntries = [ ['Voltage', sensors?.voltageMv != null ? `${(sensors.voltageMv / 1000).toFixed(2)} V` : '--'], ['Current', sensors?.currentMa != null ? `${sensors.currentMa} mA` : '--'], ['Charge', sensors?.batteryChargeMah != null ? `${sensors.batteryChargeMah}` : '--'], ['OI', sensors?.oiMode?.label || '--'], ]; return (
Status: {status} {audioStatus ? Audio: {audioStatus} : null}
Telemetry
{telemetryEntries.map(([labelText, value]) => ( {labelText} {value} ))}
{label || 'Unnamed Rover'} {driverLabel ? • {driverLabel} : null}
Left bump
Left wheel drop
Right wheel drop
Right bump
); } return (
Status: {status} {audioStatus ?
Audio: {audioStatus}
: null}
Rover: "{label || 'Unnamed Rover'}" {/* {pulse ? 'Sensors active' : 'No recent sensors'} */}
{/* bump and wheel drops bar */}
Left bump
Left wheel drop
Right wheel drop
Right bump
); } const OVERCURRENT_LABELS = { leftWheel: 'Left wheel', rightWheel: 'Right wheel', mainBrush: 'Main brush', sideBrush: 'Side brush', }; function OvercurrentOverlay({ motors }) { if (!motors?.length) return null; const labels = motors.map((name) => OVERCURRENT_LABELS[name] || name); return (
OVERCURRENT
{labels.join(', ')}
); } // low battery overlay, change text based on warn / urgent. use percentage calculated same as BatteryBar. change text based on warn or urgent. function LowBatteryOverlay({ charge, config }) { if (charge == null || config == null) return null; const full = config.Full; const warn = config.Warn; const urgent = config.Urgent ?? null; const span = full - warn; if (span <= 0) return null; const normalized = (charge - warn) / span; const percent = Math.min(1, Math.max(0, normalized)); const depleted = normalized <= 0; const warnTriggered = urgent != null && charge <= urgent; if (!warnTriggered && !depleted) return null; const message = depleted ? 'Battery low! please dock and charge the rover soon.' : 'BATTERY VERY LOW, PLEASE DOCK THE ROVER AND CHARGE IMMEDIATELY!!'; return (
{message}
); }