x
', 'published'); + +let n = 0; +const nieuwePost = (slug = 'me') => db.prepare( + "INSERT INTO ap_timeline (id, slug, author_uri, content) VALUES (?,?,'https://r.test/u/a','x
')", +).run(`https://r.test/n/${++n}`, slug); + +test('een verse tijdlijnpost beweegt de merksteen', () => { + const voor = AP.feedCursor('me'); + nieuwePost(); + assert.notEqual(AP.feedCursor('me'), voor); +}); + +test('en zo ook de andere drie poten van de inbox', () => { + // De inbox voegt vier bronnen samen. Ontbreekt er een in de merksteen, dan + // wordt een client niet wakker van precies dat soort nieuws. + const bericht = () => db.prepare( + "INSERT INTO ap_mentions (slug, object_uri, actor_uri, content) VALUES ('me',?, 'https://r.test/u/a','hoi
')", + ).run(`https://r.test/m/${++n}`); + const antwoord = () => db.prepare( + `INSERT INTO ap_interactions (kind, post_id, object_uri, actor_uri, content) + VALUES ('reply','p1',?, 'https://r.test/u/a','hoi
')`, + ).run(`https://r.test/r/${++n}`); + const verstuurd = () => db.prepare( + "INSERT INTO ap_outbox (id, site_slug, post_id, content) VALUES (?,'me','p1','x
')", + ).run(`o${++n}`); + + for (const [naam, doen] of [['bericht', bericht], ['antwoord', antwoord], ['verstuurd', verstuurd]]) { + const voor = AP.feedCursor('me'); + doen(); + assert.notEqual(AP.feedCursor('me'), voor, `${naam} hoort de merksteen te bewegen`); + } +}); + +test('nieuws van een ANDER account laat je merksteen staan', () => { + const voor = AP.feedCursor('me'); + nieuwePost('buur'); + assert.equal(AP.feedCursor('me'), voor, 'anders wordt iedereen wakker van andermans post'); +}); + +test('is er al iets veranderd, dan wordt er niet gewacht', async () => { + const oud = AP.feedCursor('me'); + nieuwePost(); + const begin = Date.now(); + const uit = await AP.waitForFeedChange('me', { since: oud, waitMs: 5000, tickMs: 20 }); + assert.equal(uit.changed, true); + assert.equal(uit.waited, false, 'meteen antwoorden, niet eerst de tijd volmaken'); + assert.ok(Date.now() - begin < 500); +}); + +test('zonder sinds is het gewoon de huidige stand', async () => { + const uit = await AP.waitForFeedChange('me', { waitMs: 5000, tickMs: 20 }); + assert.equal(uit.changed, false); + assert.equal(uit.waited, false); + assert.equal(uit.cursor, AP.feedCursor('me')); +}); + +test('wachten wordt afgebroken zodra er iets binnenkomt', async () => { + const oud = AP.feedCursor('me'); + const begin = Date.now(); + setTimeout(() => nieuwePost(), 60); + const uit = await AP.waitForFeedChange('me', { since: oud, waitMs: 4000, tickMs: 20 }); + assert.equal(uit.changed, true); + assert.equal(uit.waited, true); + assert.ok(Date.now() - begin < 2000, 'hij hoort wakker te worden, niet de tijd vol te maken'); + assert.notEqual(uit.cursor, oud, 'en de nieuwe merksteen komt mee'); +}); + +test('gebeurt er niets, dan komt hij leeg terug binnen de tijd', async () => { + const oud = AP.feedCursor('me'); + const begin = Date.now(); + const uit = await AP.waitForFeedChange('me', { since: oud, waitMs: 150, tickMs: 20 }); + assert.equal(uit.changed, false); + assert.equal(uit.waited, true); + assert.equal(uit.cursor, oud); + assert.ok(Date.now() - begin >= 100, 'hij hoort wel echt gewacht te hebben'); + assert.ok(Date.now() - begin < 3000, 'en niet langer dan gevraagd'); +}); + +test('ophangen breekt het wachten af', async () => { + // Zonder dit blijft er een timer draaien voor een client die er niet meer is. + const oud = AP.feedCursor('me'); + const ac = new AbortController(); + const begin = Date.now(); + setTimeout(() => ac.abort(), 60); + const uit = await AP.waitForFeedChange('me', { since: oud, waitMs: 4000, tickMs: 20, signal: ac.signal }); + assert.equal(uit.changed, false); + assert.ok(Date.now() - begin < 2000); +}); + +test('meer dan vier wachters tegelijk: de rest krijgt meteen antwoord', async () => { + // Een client met een kapotte herverbind-lus mag de instance niet vastzetten. + // De overtolligen krijgen geen fout maar gewoon de huidige stand. + const oud = AP.feedCursor('me'); + const lopend = []; + for (let i = 0; i < 4; i++) lopend.push(AP.waitForFeedChange('me', { since: oud, waitMs: 300, tickMs: 20 })); + await new Promise((r) => setTimeout(r, 30)); + const vijfde = await AP.waitForFeedChange('me', { since: oud, waitMs: 4000, tickMs: 20 }); + assert.equal(vijfde.busy, true); + assert.equal(vijfde.waited, false); + await Promise.all(lopend); + // En daarna is er weer plek: de teller moet netjes teruglopen. + const daarna = await AP.waitForFeedChange('me', { since: oud, waitMs: 60, tickMs: 20 }); + assert.notEqual(daarna.busy, true); +});