import { useCallback, useEffect, useRef, useState } from 'react'; import { WhepPlayer } from '../lib/whepPlayer.js'; const RESTART_DELAY_MS = 2000; const UNMUTE_RETRY_MS = 3000; export default function VideoTile({ sessionInfo, label, forceMute = false, telemetryFrame, batteryConfig }) { const videoRef = useRef(null); const restartTimer = useRef(null); const unmuteTimer = useRef(null); const [status, setStatus] = useState('idle'); const [detail, setDetail] = useState(null); const [restartToken, setRestartToken] = useState(0); const [muted, setMuted] = useState(true); const sensors = telemetryFrame?.sensors; const batteryCharge = sensors?.batteryChargeMah ?? sensors?.batteryCharge ?? sensors?.battery?.charge ?? null; const batteryCapacity = sensors?.batteryCapacityMah ?? sensors?.batteryCapacity ?? sensors?.battery?.capacity ?? null; console.log('[BatteryBarDebug]', { frameSensors: sensors, batteryCharge, batteryCapacity, config: batteryConfig, }); const wheelOvercurrents = sensors?.wheelOvercurrents || null; const overcurrentActive = Boolean( wheelOvercurrents && Object.values(wheelOvercurrents).some((value) => Boolean(value)), ); const scheduleRestart = useCallback(() => { clearTimeout(restartTimer.current); restartTimer.current = setTimeout(() => setRestartToken(Date.now()), RESTART_DELAY_MS); }, []); 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 { video.muted = false; await video.play(); setMuted(false); } catch { video.muted = true; setMuted(true); scheduleRetry(); } }; unmuteTimer.current = setTimeout(tryPlay, delay); }, [forceMute], ); useEffect( () => () => { clearTimeout(restartTimer.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 (['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]); useEffect(() => { if (status === 'stopped' && sessionInfo?.url) { scheduleRestart(); } }, [status, sessionInfo?.url, scheduleRestart]); const renderedStatus = !sessionInfo?.url ? 'waiting' : status === 'error' ? `Error: ${detail || 'unknown'}` : detail ? `${status} (${detail})` : status; return (
Battery telemetry unavailable