Streams: one our live server has ended reads ended, whatever its last announcement says (an app closed mid-stream never says so, and it read live for an hour with no way to stop it); its host gets End — on the stream and on their profile — which publishes the ended announcement with the recording. Each announcement is now newer than the last to the second (an ended stamped the same second as the live before it lost to it). A recording that is a web page (zap.stream's Rumble links) gets a Watch the recording link instead of a player that can't play it.

Co-Authored-By: Claude Opus 5.5 <[email protected]>
Claude-Session: https://claude.ai/code/session_013ZDf1cyCQLkfjftYhymZAg

1 files changed, 30 insertions, 0 deletions

diff --git a/tools/go-live-test.js b/tools/go-live-test.js
index 61e3c02..fcc0bbf 100644
--- a/tools/go-live-test.js
+++ b/tools/go-live-test.js
@@ -46,6 +46,8 @@ const browser = await puppeteer.launch({ executablePath: '/usr/bin/google-chrome
   args: ['--no-sandbox', '--use-fake-device-for-media-stream', '--use-fake-ui-for-media-stream', '--autoplay-policy=no-user-gesture-required'] });
 
 const relayStub = (fx) => {
+  // what the relays held before a reload (a test can carry events across one)
+  try { fx = [...fx, ...JSON.parse(sessionStorage.getItem('__fx') || '[]')]; } catch {}
   window.__published = [];
   const match = (f, e) => (!f.kinds || f.kinds.includes(e.kind)) && (!f.authors || f.authors.includes(e.pubkey))
     && Object.keys(f).filter((k) => k[0] === '#').every((k) => e.tags.some((x) => x[0] === k.slice(1) && f[k].includes(x[1])));
@@ -168,6 +170,34 @@ try {
   await sleep(1500);
   const rec = await (await fetch(tag(fin, 'recording'))).text();
   check('...and the recording is whole', /ENDLIST/.test(rec) && (rec.match(/\.ts/g) || []).length >= 3, (rec.match(/\.ts/g) || []).length + ' segments');
+
+  console.log('\n[a stream the app lost]');
+  await page.goto(`http://localhost:${PORT}/`, { waitUntil: 'domcontentloaded' });
+  await waitText('receive');
+  await page.evaluate(() => document.querySelector('.app-nav-button[aria-label="Feed"]')?.click());
+  if (!(await waitFor(() => !!document.querySelector('.feed-post-fab, .go-live-tool'), 15000))) console.log('    at:', await page.evaluate(() => location.pathname + ' ' + document.body.innerText.slice(0, 300).replace(/\s+/g, ' ')));
+  if (!(await page.$('.go-live-tool'))) await page.evaluate(() => document.querySelector('.feed-post-fab').click());
+  await waitFor(() => !!document.querySelector('.go-live-tool'), 5000);
+  await page.evaluate(() => document.querySelector('.go-live-tool').click());
+  await waitFor(() => { const v = document.querySelector('video.bc-preview'); return !!v && v.videoWidth > 0; }, 10000);
+  await page.type('.go-live-title', 'Lost stream');
+  const n0 = (await lives(page)).length;
+  await page.evaluate(() => document.querySelector('.go-live-start').click());
+  await waitFor((n) => window.__published.filter((e) => e.kind === 30311).length > n, 40000, n0);
+  const lost = (await lives(page)).at(-1);
+  // the tab goes (a reload): the relays still say live; the server waits a minute for the sender, then ends it
+  await page.evaluate((e) => sessionStorage.setItem('__fx', JSON.stringify([e])), lost);
+  await page.goto(`http://localhost:${PORT}/` + naddrEncode({ kind: 30311, pubkey: lost.pubkey, identifier: tag(lost, 'd') }), { waitUntil: 'domcontentloaded' });
+  await sleep(64000);
+  check('opened, it says it\'s over (the server ended it), not live', await waitFor(() => !!document.querySelector('.live-page') && /This stream has ended/.test(document.body.innerText) && !document.querySelector('.live-page .live-badge.live'), 30000),
+    await page.evaluate(() => document.querySelector('.live-page')?.innerText.slice(0, 200)));
+  check('...and its host gets End', await waitFor(() => !!document.querySelector('.live-end-stale'), 5000));
+  const n1 = (await lives(page)).length;
+  await page.evaluate(() => document.querySelector('.live-end-stale').click());
+  check('End says it ended', await waitFor((n) => window.__published.filter((e) => e.kind === 30311).slice(n).some((e) => e.tags.some((x) => x[0] === 'status' && x[1] === 'ended')), 10000, n1));
+  const endedEv = (await lives(page)).at(-1);
+  check('...the same stream, with its recording', tag(endedEv, 'd') === tag(lost, 'd') && /index\.m3u8$/.test(tag(endedEv, 'recording') || ''), JSON.stringify(endedEv.tags));
+  check('...and the End button goes', await waitFor(() => !document.querySelector('.live-end-stale'), 5000));
   check('no page errors', !errs.length, errs.join(' | '));
 } catch (e) { console.error(e); ok = false; } finally {
   await browser.close(); server.stop(true); names.stop(true);