zebra-spaces: deploy Double Dragon controller
This commit is contained in:
parent
52866ed779
commit
4885cab72e
1 changed files with 132 additions and 2 deletions
|
|
@ -2060,6 +2060,130 @@ async function refreshLipSyncForUuid(uuid){
|
|||
logLine('', 'lip-sync pub='+pubHex.slice(0,4)+' delay='+med.toFixed(2)+'s ('+e.videoReceivers.size+' video rx, history median of '+e.history.length+')');
|
||||
}
|
||||
|
||||
/* ==================================================================
|
||||
* Double Dragon — twin-stream auto-engage controller.
|
||||
*
|
||||
* Fox 2026-06-04 framing: "think of it like a CD that is literally
|
||||
* being skipped in a physical disc man and solve it with two lasers
|
||||
* one moving fast mesh as fast as possible and one for the broadcast
|
||||
* also as fast as possible … double headed hydra! double dragon!"
|
||||
*
|
||||
* Per-publisher health monitor. Every telemetry tick (5s), we look
|
||||
* at the active mesh receiver's stats. If the publisher's network or
|
||||
* encoder is hitting the listener with loss/jitter, auto-engage the
|
||||
* HTTP /stream path (deeper buffer, glitch-free, ~2.5s behind). When
|
||||
* the publisher's mesh path is clean for sustained time, auto-
|
||||
* disengage and return to low-latency mesh.
|
||||
*
|
||||
* State per pubHex:
|
||||
* 'mesh' — listening via worklet (mesh source), HTTP off
|
||||
* 'http' — auto-engaged HTTP, worklet muted
|
||||
* 'manual-on' — user toggled HTTP manually; we don't touch it
|
||||
* 'manual-off' — user toggled HTTP off; we don't auto-engage
|
||||
*
|
||||
* Transitions (auto only):
|
||||
* mesh → http: 2 consecutive samples show instability
|
||||
* http → mesh: 6 consecutive clean samples (~30s)
|
||||
*
|
||||
* Manual state is sticky — if the user clicks the toggle, that
|
||||
* intent overrides the controller until they leave + re-enter.
|
||||
*
|
||||
* The switch is audibly a ~2.5s time-jump (mesh latency vs HTTP
|
||||
* latency). Listener hears past content briefly. Phase 3 (deferred)
|
||||
* does sample-aligned dual-decode via cross-correlation to remove
|
||||
* the jump. */
|
||||
const doubleDragon = new Map(); /* pubHex → state */
|
||||
const DD_LOSS_PER_SEC_THRESH = 2; /* > 2 loss/sec = unstable */
|
||||
const DD_JITTER_THRESH_SEC = 0.030; /* > 30ms = unstable */
|
||||
const DD_UNSTABLE_SAMPLES_NEEDED = 2;
|
||||
const DD_CLEAN_SAMPLES_NEEDED = 6; /* 6 × 5s = 30s clean → recover */
|
||||
const DD_TELEMETRY_TICK_SEC = 5;
|
||||
|
||||
function ddEntry(pubHex){
|
||||
let e = doubleDragon.get(pubHex);
|
||||
if (!e){
|
||||
e = { state: 'mesh', unstableStreak: 0, cleanStreak: 0,
|
||||
lastLost: 0, lastSeenStatsAt: 0 };
|
||||
doubleDragon.set(pubHex, e);
|
||||
}
|
||||
return e;
|
||||
}
|
||||
function ddNoteManualToggle(pubHex, isOn){
|
||||
const e = ddEntry(pubHex);
|
||||
e.state = isOn ? 'manual-on' : 'manual-off';
|
||||
e.unstableStreak = 0; e.cleanStreak = 0;
|
||||
logLine('', 'double-dragon pub='+pubHex.slice(0,4)+' → '+e.state+' (manual)');
|
||||
}
|
||||
|
||||
async function evaluateDoubleDragonForPub(pubHex){
|
||||
const e = doubleDragon.get(pubHex) || ddEntry(pubHex);
|
||||
/* manual state: hands off */
|
||||
if (e.state === 'manual-on' || e.state === 'manual-off') return;
|
||||
/* find the publisher's audio receiver — prefer mesh receiver from
|
||||
* lipSync entry (which gets updated to whichever source is currently
|
||||
* feeding the worklet). Fall back to SFU. */
|
||||
const ls = lipSync.get(pubHex);
|
||||
const audRx = (ls && ls.audioReceiver) || sfuAudioReceivers.get(pubHex);
|
||||
if (!audRx) return;
|
||||
/* find the uuid for the publisher (needed for start/stopStream) */
|
||||
let uuid = null;
|
||||
for (const [u, mm] of members){
|
||||
try {
|
||||
if (mm.pubkey && hex(unb64(mm.pubkey)) === pubHex){ uuid = u; break; }
|
||||
} catch(_){}
|
||||
}
|
||||
if (!uuid) return;
|
||||
/* read stats */
|
||||
let lossRate = 0, jitter = 0;
|
||||
try {
|
||||
const stats = await audRx.getStats();
|
||||
stats.forEach(r => {
|
||||
if (r.type === 'inbound-rtp' && r.kind === 'audio'){
|
||||
const nowMs = Date.now();
|
||||
const dtSec = e.lastSeenStatsAt
|
||||
? (nowMs - e.lastSeenStatsAt) / 1000
|
||||
: DD_TELEMETRY_TICK_SEC;
|
||||
const lostDelta = Math.max(0, (r.packetsLost|0) - (e.lastLost|0));
|
||||
lossRate = dtSec > 0 ? lostDelta / dtSec : 0;
|
||||
e.lastLost = (r.packetsLost|0);
|
||||
e.lastSeenStatsAt = nowMs;
|
||||
jitter = r.jitter || 0;
|
||||
}
|
||||
});
|
||||
} catch(_){ return; }
|
||||
const unstable = (lossRate > DD_LOSS_PER_SEC_THRESH) ||
|
||||
(jitter > DD_JITTER_THRESH_SEC);
|
||||
if (unstable){
|
||||
e.unstableStreak++; e.cleanStreak = 0;
|
||||
if (e.state === 'mesh' && e.unstableStreak >= DD_UNSTABLE_SAMPLES_NEEDED){
|
||||
e.state = 'http';
|
||||
logLine('', 'double-dragon pub='+pubHex.slice(0,4)+
|
||||
' AUTO-ENGAGE HTTP (loss/s='+lossRate.toFixed(1)+
|
||||
' jitter='+(jitter*1000).toFixed(0)+'ms)');
|
||||
streamMode.add(pubHex);
|
||||
try { await startStream(uuid, pubHex); } catch(_){}
|
||||
try { renderRoom(); } catch(_){}
|
||||
}
|
||||
} else {
|
||||
e.cleanStreak++; e.unstableStreak = 0;
|
||||
if (e.state === 'http' && e.cleanStreak >= DD_CLEAN_SAMPLES_NEEDED){
|
||||
e.state = 'mesh';
|
||||
logLine('', 'double-dragon pub='+pubHex.slice(0,4)+
|
||||
' AUTO-DISENGAGE (clean '+e.cleanStreak+' samples)');
|
||||
streamMode.delete(pubHex);
|
||||
try { stopStream(uuid); } catch(_){}
|
||||
try { renderRoom(); } catch(_){}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
function evaluateDoubleDragon(){
|
||||
/* run once per telemetry tick for every publisher we know about */
|
||||
for (const pubHex of lipSync.keys()){
|
||||
evaluateDoubleDragonForPub(pubHex).catch(()=>{});
|
||||
}
|
||||
}
|
||||
|
||||
/* Force a one-shot lip-sync application for a specific publisher.
|
||||
* Bypasses the worklet-driven 'buffered' cadence — used when an
|
||||
* external event (HTTP /stream toggle) changes the audio source and
|
||||
|
|
@ -4361,6 +4485,10 @@ function stopAlivePings(){
|
|||
const TELEMETRY_INTERVAL_MS = 5000;
|
||||
let telemetryTimer = null;
|
||||
async function dumpTelemetry(){
|
||||
/* Run the Double Dragon controller off the same 5s cadence — same
|
||||
* getStats traffic is being read anyway, evaluating per-publisher
|
||||
* stability here is essentially free. */
|
||||
try { evaluateDoubleDragon(); } catch(_){}
|
||||
const parts = [];
|
||||
parts.push('role=' + myRole);
|
||||
parts.push('sub=' + (sfuSubPC ? sfuSubPC.connectionState + '/' + sfuSubPC.iceConnectionState : 'none'));
|
||||
|
|
@ -5633,9 +5761,11 @@ function toggleStreamFor(uuid, pubHex){
|
|||
if (streamMode.has(pubHex)){
|
||||
streamMode.delete(pubHex);
|
||||
stopStream(uuid);
|
||||
ddNoteManualToggle(pubHex, false);
|
||||
} else {
|
||||
streamMode.add(pubHex);
|
||||
startStream(uuid, pubHex);
|
||||
ddNoteManualToggle(pubHex, true);
|
||||
}
|
||||
renderRoom();
|
||||
}
|
||||
|
|
@ -6564,8 +6694,8 @@ logLine('', 'ready — pick a handle, type a rendezvous code, enter the space');
|
|||
|
||||
<footer style="margin:2.2rem auto 0;font-size:0.65rem;color:#999;line-height:1.7;word-break:break-all;font-family:monospace">
|
||||
<span id="pi-seal" style="color:#777;cursor:default;user-select:none" title="">page integrity</span> · built <span class="stamp-date">2026-06-04</span><br>
|
||||
md5 <span class="stamp-md5">bb1d3911fdc9a91535d0042523fbd5be</span><br>
|
||||
sha256 <span class="stamp-sha">becc93e6ff940bcebf1b3423c945090f971f1889f7a44730448797350b086fc2</span><br>
|
||||
md5 <span class="stamp-md5">0146cbc9be2f6f26292bedf734f66c0c</span><br>
|
||||
sha256 <span class="stamp-sha">bfd85c39d05fa3733f0beb026cc9e8329797f6daf6da13973192a72006bb040c</span><br>
|
||||
<span style="color:#bbb">hashes are of this page with these two fields zeroed — to verify, blank them and re-hash</span><br>
|
||||
<span style="color:#bbb">one self-contained file — <strong>save a copy</strong> and verify against these hashes; point at your own servers with ?signal= and ?turncred=, or <a href="host-your-own.html" style="color:#999">host your own community</a></span>
|
||||
</footer>
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue