From f7dbd901043961ebbc96abe90adf4fba6a01dfb0 Mon Sep 17 00:00:00 2001
From: Adam Soltys <adam@coinos.io>
Date: Sun, 18 Oct 2026 22:55:35 -0700
Subject: 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.
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_013ZDf1cyCQLkfjftYhymZAg
---
 tools/go-live-test.js | 30 ++++++++++++++++++++++++++++++
 1 file changed, 30 insertions(+)

(limited to 'tools/go-live-test.js')

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);
-- 
cgit v1.2.3