diff options
Diffstat (limited to 'tools')
| -rw-r--r-- | tools/feed-live-test.js | 170 | ||||
| -rw-r--r-- | tools/profile-batch-test.js | 16 |
2 files changed, 180 insertions, 6 deletions
diff --git a/tools/feed-live-test.js b/tools/feed-live-test.js new file mode 100644 index 0000000..fd50191 --- /dev/null +++ b/tools/feed-live-test.js @@ -0,0 +1,170 @@ +// Two things about a feed you leave and come back to. +// +// A backgrounded tab is frozen by the phone: timers stop and the relay +// sockets are cut, so every post made while you were away is simply missing +// and the feed sits there looking stale until you pull it down by hand. It +// catches up by itself now. +// +// And a post that lands while you are reading halfway down must not shove the +// page under your thumb. It waits behind a pill that says how many, and the +// tap that shows them takes you up to them. +// +// Run: bun tools/feed-live-test.js +import puppeteer from 'puppeteer-core'; +import { generateMnemonic } from '@scure/bip39'; +import { wordlist } from '@scure/bip39/wordlists/english'; +import { cacheKeyFor } from '../src/wallet.js'; +import { generateSecretKey, getPublicKey, finalizeEvent } from 'nostr-tools/pure'; +import { buildHtml } from '../build.js'; +const sleep = (ms) => new Promise((r) => setTimeout(r, ms)); +let ok = true; +const check = (n, c, d = '') => { console.log(` ${c ? '✓' : '✗'} ${n}${d ? ' — ' + d : ''}`); if (!c) ok = false; }; + +// A real key, because a post arriving on a subscription is signature-checked +// on the way in — an unsigned fake would be dropped and prove nothing. +const SK = generateSecretKey(); +const AUTHOR = getPublicKey(SK); +const signed = (content, ago) => finalizeEvent( + { kind: 1, created_at: Math.floor(Date.now() / 1000) - ago, tags: [], content }, SK); +// enough to scroll past; these ride in through the cache, which is trusted +const seeded = Array.from({ length: 25 }, (_, i) => signed('post number ' + (i + 1), 600 + i * 60)); + +const html = await buildHtml({ minify: true, pwa: false }); +const server = Bun.serve({ port: 5296, fetch: () => new Response(html, { headers: { 'content-type': 'text/html' } }) }); +const browser = await puppeteer.launch({ executablePath: '/usr/bin/google-chrome', headless: 'new', args: ['--no-sandbox'] }); +const page = await browser.newPage(); +await page.evaluateOnNewDocument(() => { + window.__feedReqs = 0; + const subs = []; // [socket, subId] for every open kind-1 subscription + const Real = window.WebSocket; + window.WebSocket = function (...a) { + const ws = new Real(...a); + const send = ws.send.bind(ws); + ws.send = (data) => { + try { + const m = JSON.parse(data); + if (m[0] === 'REQ' && m[2] && Array.isArray(m[2].kinds) && m[2].kinds.includes(1)) { + window.__feedReqs++; + subs.push([ws, m[1]]); + } + } catch {} + return send(data); + }; + return ws; + }; + window.WebSocket.prototype = Real.prototype; + Object.assign(window.WebSocket, Real); + // Hand a real event to the app exactly as a relay would: down an open + // subscription, through the signature gate, into mergeFeed. + window.__inject = (ev) => { + let n = 0; + for (const [ws, id] of subs) { + if (ws.readyState !== 1) continue; + ws.dispatchEvent(new MessageEvent('message', { data: JSON.stringify(['EVENT', id, ev]) })); + n++; + } + return n; + }; +}); +const errs = []; +page.on('pageerror', (e) => errs.push(String(e))); +const click = (t) => page.evaluate((x) => { const e = [...document.querySelectorAll('button')].find((n) => n.textContent.trim().toLowerCase().includes(x)); if (e) { e.click(); return true; } return false; }, t); +const waitText = async (x, ms = 25000) => { for (let i = 0; i < ms / 250; i++) { if ((await page.evaluate(() => document.body.innerText)).toLowerCase().includes(x)) return true; await sleep(250); } return false; }; + +try { + await page.setViewport({ width: 390, height: 844 }); + await page.goto('http://localhost:5296/', { waitUntil: 'domcontentloaded' }); + await page.evaluate(() => localStorage.setItem('btc-wallet-network', 'regtest')); + await page.reload({ waitUntil: 'domcontentloaded' }); + await sleep(400); + await click('create a new wallet'); await sleep(500); + await click('import existing'); await sleep(400); + await page.waitForSelector('textarea'); + const mn = generateMnemonic(wordlist); + await page.type('textarea', mn); + await click('open wallet'); + await waitText('receive', 20000); + const base = cacheKeyFor(mn + '\n'); + await page.evaluate(([k, pk, ns]) => { + localStorage.setItem(k + ':follows', JSON.stringify({ tags: [['p', pk]], c: '', at: Math.floor(Date.now() / 1000) })); + localStorage.setItem(k + ':feedNotes', JSON.stringify(ns)); + }, [base, AUTHOR, seeded]); + await page.reload({ waitUntil: 'domcontentloaded' }); + await waitText('receive', 20000); + await page.evaluate(() => { const b = [...document.querySelectorAll('button')].find((e) => /message/i.test(e.getAttribute('aria-label') || '')); if (b) b.click(); }); + await sleep(1000); + await page.evaluate(() => { const e = [...document.querySelectorAll('.item')].find((n) => /feed/i.test(n.textContent)); if (e) e.click(); }); + await sleep(4000); + check('the feed has posts in it', (await page.evaluate(() => document.querySelectorAll('.notes-feed > .row').length)) > 0); + + console.log('\n[a post arriving while you read]'); + // scroll down: this is someone reading, not someone sitting at the top + await page.evaluate(() => window.scrollTo(0, 900)); + await sleep(500); + const before = await page.evaluate(() => ({ + y: Math.round(window.scrollY), + first: (document.querySelector('.notes-feed > .row') || {}).innerText || '', + })); + check('...reading further down', before.y > 400, 'scrollY ' + before.y); + + // a brand new post lands on the live subscription + const fresh = signed('BRAND NEW POST', 0); + const delivered = await page.evaluate((ev) => window.__inject(ev), fresh); + check('...a post really arrives on a live subscription', delivered > 0, delivered + ' socket(s)'); + await sleep(900); + const after = await page.evaluate(() => ({ + y: Math.round(window.scrollY), + pill: (document.querySelector('.feed-new-pill') || {}).textContent || '', + inFeed: /BRAND NEW POST/.test(document.querySelector('.notes-feed')?.innerText || ''), + })); + check('it does not shove itself into the page', !after.inFeed); + check('...it says so in a pill instead', /1 new post/i.test(after.pill), after.pill || 'no pill'); + check('...and the page has not moved under you', Math.abs(after.y - before.y) < 40, + `scrollY ${before.y} → ${after.y}`); + + await page.evaluate(() => document.querySelector('.feed-new-pill').click()); + await sleep(1400); + const opened = await page.evaluate(() => ({ + y: Math.round(window.scrollY), + inFeed: /BRAND NEW POST/.test(document.querySelector('.notes-feed')?.innerText || ''), + pill: !!document.querySelector('.feed-new-pill'), + })); + check('tapping it shows the post', opened.inFeed); + check('...and takes you up to it', opened.y < 120, 'scrollY ' + opened.y); + check('...and the pill is done', !opened.pill); + + console.log('\n[scrolling back up on your own]'); + await page.evaluate(() => window.scrollTo(0, 900)); + await sleep(400); + await page.evaluate((ev) => window.__inject(ev), signed('ANOTHER ONE', 0)); + await sleep(800); + check('a pill again', !!(await page.$('.feed-new-pill'))); + await page.evaluate(() => window.scrollTo(0, 0)); + await sleep(900); + check('...and scrolling to the top lets it in by itself', + await page.evaluate(() => /ANOTHER ONE/.test(document.querySelector('.notes-feed')?.innerText || '') + && !document.querySelector('.feed-new-pill'))); + + console.log('\n[coming back after being away]'); + // the throttle would otherwise swallow a refresh this soon after the last + // the app was hidden for a while, then focused again + await page.evaluate(() => { + Object.defineProperty(document, 'visibilityState', { value: 'hidden', configurable: true }); + document.dispatchEvent(new Event('visibilitychange')); + }); + // longer than the five seconds that count as a blink between apps + await sleep(6500); + const reqsBefore = await page.evaluate(() => window.__feedReqs || 0); + await page.evaluate(() => { + Object.defineProperty(document, 'visibilityState', { value: 'visible', configurable: true }); + document.dispatchEvent(new Event('visibilitychange')); + }); + await sleep(3500); + const reqsAfter = await page.evaluate(() => window.__feedReqs || 0); + check('coming back re-asks the relays without being told', + reqsAfter > reqsBefore, `${reqsBefore} → ${reqsAfter} kind-1 requests`); + + check('no page errors', errs.length === 0, errs.slice(0, 2).join(' | ')); +} finally { await browser.close(); server.stop(true); } +console.log(ok ? '\n✅ the feed keeps up, without moving the page' : '\n❌ failed'); +process.exit(ok ? 0 : 1); diff --git a/tools/profile-batch-test.js b/tools/profile-batch-test.js index bf8dcf4..8f8250c 100644 --- a/tools/profile-batch-test.js +++ b/tools/profile-batch-test.js @@ -89,13 +89,17 @@ try { const reqs = await page.evaluate(() => window.__k0); const rowCount = await page.evaluate(() => document.querySelectorAll('.notes-feed > .row').length); - // A screenful of faces must cost a handful of asks, not one per row. (A few - // singles are expected and fine: our own profile, which onboarding reads - // before it writes a name, and the outbox fallback chasing one straggler to - // the relay only they publish to.) + // A screenful of faces must cost a fixed handful of asks — the number must + // not grow with the rows, which is the bug this whole thing is about (one + // REQ per row, eighty at once, most refused). The bound is a constant, not + // a fraction of the rows, because that is the actual property: a couple of + // debounced batches, each of which may also ask the profile-index relays + // and then chase stragglers to their own relays. Singles are expected among + // them — our own profile, and one straggler on a relay only they use. + const ASK_CEILING = 12; const asks = await page.evaluate(() => [...(window.__k0asks || [])].length); - check('a screenful of faces costs a handful of asks, not one per row', - reqs.length > 0 && asks <= Math.max(4, rowCount / 4), + check('a screenful of faces costs a fixed handful of asks, however many rows', + reqs.length > 0 && asks <= ASK_CEILING, `${asks} asks for ${rowCount} rows, batches of ${[...new Set(reqs)].filter((n) => n > 1).join(',')}`); check('...one request covers the screen', Math.max(0, ...reqs) >= 8, 'biggest carried ' + Math.max(0, ...reqs) + ' pubkeys'); |