Index: src/routes/activitypub.js
===================================================================
--- src/routes/activitypub.js (revision 7ccdced94ed9434ec28142de104082d14bd8cd78)
+++ src/routes/activitypub.js (revision e4119c22651ba589d6fceee5bc1802a11716f279)
@@ -965,4 +965,54 @@
}, 'private, no-store');
}
+ // ── Ouder dan wat je hebt (shaer-ewrt) ──────────────────────────
+ //
+ // De volle lezing hieronder is vier poten van de nieuwste zestig, en wat
+ // daaronder lag was nergens te vragen: een 'load more' had geen adres. Dit is
+ // dat adres, met een samengestelde cursor zoals bij /messages, en het antwoord
+ // is een OrderedCollectionPage met partOf -- een deel, en dat zegt het ook.
+ //
+ // De pagina's volgen elkaar via `next`; de client bouwt er geen na.
+ const inboxId = `${base}/ap/users/${auth.site.slug}/inbox`;
+ const size = req.query.limit ? `&limit=${encodeURIComponent(String(req.query.limit))}` : '';
+ const ouderLink = (pagina) => (pagina.more && pagina.oldest
+ ? `${inboxId}?before=${encodeURIComponent(pagina.oldest)}${size}` : undefined);
+ if (req.query.before) {
+ const pagina = AP.inboxPage(auth.site.slug, { before: String(req.query.before), limit: req.query.limit });
+ const ids = (leg) => pagina.rows.filter((r) => r.leg === leg).map((r) => r.ref);
+ const tl = new Map(AP.timelineRowsByIds(auth.site.slug, ids('timeline')).map((r) => [r.id, r]));
+ const mn = new Map(AP.messageRowsByUri(auth.site.slug, ids('message')).map((r) => [r.object_uri, r]));
+ const rp = new Map(AP.replyRowsByUri(auth.site.slug, ids('reply')).map((r) => [r.object_uri, r]));
+ const reacties = AP.getReactionsFor(auth.site.slug, [...tl.keys()]);
+ const ctx = { base, me, myHandle, p: P };
+ const mine = AP.selfAuthor(base, auth.site);
+ const items = [];
+ for (const r of pagina.rows) {
+ if (r.leg === 'timeline') {
+ const t = tl.get(r.ref);
+ if (t) items.push(timelineItem(t, { p: P, reactions: reacties }));
+ } else if (r.leg === 'message') {
+ // Dezelfde poort als de volle lezing: een dichte berichtenpoort houdt
+ // vreemden buiten, nooit de hulpvraag en nooit de guardians.
+ const m = mn.get(r.ref);
+ if (m && (messagesAllowed || m.help_request || guardianUris.has(m.actor_uri))) items.push(messageItem(m, ctx));
+ } else if (r.leg === 'reply') {
+ const m = rp.get(r.ref);
+ if (m) items.push(replyItem(m, ctx));
+ } else {
+ const n = AP.getOutboxNote(base, r.ref);
+ if (n) items.push(sentItem(n, { me, mine }));
+ }
+ }
+ return AP.sendAP(res, {
+ '@context': AP.AP_CONTEXT,
+ id: `${inboxId}?before=${encodeURIComponent(String(req.query.before))}${size}`,
+ type: 'OrderedCollectionPage',
+ partOf: inboxId,
+ orderedItems: items,
+ // Ontbreekt next, dan is de inbox op. De client hoort dat te weten zonder
+ // te gokken, anders kan zijn knop niet eerlijk verdwijnen.
+ next: ouderLink(pagina),
+ }, 'private, no-store');
+ }
const rows = AP.getTimeline(auth.site.slug, 60);
// Eén query voor de hele pagina (shaer-9e9 fase 2): shaer:liked komt uit de
@@ -1021,4 +1071,16 @@
totalItems: items.length,
orderedItems: items,
+ // Waar het oudere begint (shaer-ewrt). Een `next` op de wortel en geen
+ // `first`, en dat is een afweging: de items hierboven ZIJN de eerste
+ // pagina, en een `first` ernaast laat een lezer die de paginaweg voorrang
+ // geeft -- de onze, op iOS en op Android -- bij elke verversing de hele
+ // inbox opnieuw in pagina's binnenhalen. `next` volgt niemand vanzelf; hij
+ // is er voor wie erom vraagt.
+ //
+ // De cursor komt uit dezelfde unie als de pagina's, over de nieuwste zestig
+ // van alle poten samen. Die zitten hier allemaal tussen, dus de volgende
+ // pagina sluit aan zonder gat; wat de wortel per poot dieper had komt daar
+ // hooguit nog een keer langs.
+ next: ouderLink(AP.inboxPage(auth.site.slug, { limit: req.query.limit || 60 })),
});
return undefined;
Index: src/services/ActivityPubService.js
===================================================================
--- src/services/ActivityPubService.js (revision 7ccdced94ed9434ec28142de104082d14bd8cd78)
+++ src/services/ActivityPubService.js (revision e4119c22651ba589d6fceee5bc1802a11716f279)
@@ -55,5 +55,5 @@
getTimeline, replyRowsByUri, timelineRowsByIds, getReplyMessages,
feedCursor, feedChangesSince, waitForFeedChange,
- conversationHeads, conversationHistory, messageRowsByUri,
+ conversationHeads, conversationHistory, inboxPage, messageRowsByUri,
readMarkers, markRead, unreadPerConversation, getDirectMessages,
isoStamp, timelineAttachments, extractEmojiTags, gateAttachments,
@@ -64,5 +64,5 @@
getTimeline, replyRowsByUri, timelineRowsByIds, getReplyMessages,
feedCursor, feedChangesSince, waitForFeedChange,
- conversationHeads, conversationHistory, messageRowsByUri,
+ conversationHeads, conversationHistory, inboxPage, messageRowsByUri,
readMarkers, markRead, unreadPerConversation, getDirectMessages,
isoStamp, timelineAttachments, extractEmojiTags, gateAttachments,
@@ -4395,5 +4395,5 @@
getInteractions, getInteractionById, setInteractionBoosted, setInteractionLiked, buildReplyNote, getOutboxNote, getSentNotes, deliverReply, resolveRemoteNote, noteAudience, mayReadNote,
listOutbox, deliverOutboxDelete, deliverOutboxUpdate, deliverDirectNote,
- webfingerResolve, followActor, resolveRemoteActor, unfollowActor, handleMoveInbox, moveAccount, listFollowing, setAutoBoost, backfillFromOutbox, getTimeline, timelineRowsByIds, contentWarning, getDirectMessages, readMarkers, markRead, unreadPerConversation, messageRowsByUri, replyRowsByUri, conversationHeads, conversationHistory, isoStamp, timelineAttachments, timelineEmojis, timelineObjectLinks, timelineQuote, timelineEmbed, applyQuoteProps, deliverToActor, sendInteraction, voteOnPoll, voteOnRemotePoll,
+ webfingerResolve, followActor, resolveRemoteActor, unfollowActor, handleMoveInbox, moveAccount, listFollowing, setAutoBoost, backfillFromOutbox, getTimeline, timelineRowsByIds, contentWarning, getDirectMessages, readMarkers, markRead, unreadPerConversation, messageRowsByUri, replyRowsByUri, conversationHeads, conversationHistory, inboxPage, isoStamp, timelineAttachments, timelineEmojis, timelineObjectLinks, timelineQuote, timelineEmbed, applyQuoteProps, deliverToActor, sendInteraction, voteOnPoll, voteOnRemotePoll,
acceptGatedFollow, rejectGatedFollow, isWardGuardian, outboxAudience, sendFollowDecision,
gateOutgoingFollow, performApprovedFollow, recordGuardianEvent, listGuardianEvents, GUARDIAN_EVENT_KEEP,
Index: src/services/ap-timeline.js
===================================================================
--- src/services/ap-timeline.js (revision 7ccdced94ed9434ec28142de104082d14bd8cd78)
+++ src/services/ap-timeline.js (revision e4119c22651ba589d6fceee5bc1802a11716f279)
@@ -351,4 +351,55 @@
}
+/**
+ * Een pagina van de inbox, nieuwste eerst, met een cursor (shaer-ewrt).
+ *
+ * De inbox-lezing is vier poten van elk de nieuwste zestig, en daaronder hield
+ * het op: wat ouder was kon de app nergens vragen. Dit is de weg naar beneden.
+ *
+ * EEN LIMIET VOOR ALLE VIER SAMEN, om dezelfde reden als bij een gesprek: per
+ * poot afkappen geeft een pagina die bij de ene poot tot vorige week reikt en
+ * bij de andere tot gisteren, en dan valt er bij de volgende pagina iets in het
+ * gat ertussen. Over de unie afgekapt is een pagina compleet voor zijn periode.
+ *
+ * Alleen referenties: welke poot, welk object, welk stempel. Het kaartwerk doet
+ * de route met dezelfde bouwers als de verschil-lezing, zodat een kaart er
+ * hetzelfde uitziet hoe hij ook binnenkwam.
+ *
+ * De poten zijn dezelfde als in de volle lezing: de berichtpoot slaat over wat
+ * ook in de tijdlijn staat (getDirectMessages), en de stempels zijn die waarop
+ * elke poot daar sorteert.
+ */
+const INBOX_UNION = `
+ SELECT 'timeline' AS leg, t.id AS ref, ${STEMPEL('COALESCE(t.published, t.created_at)')} AS stamp
+ FROM ap_timeline t WHERE t.slug = @slug
+ UNION ALL
+ SELECT 'message', m.object_uri, ${STEMPEL('COALESCE(m.published, m.created_at)')}
+ FROM ap_mentions m
+ WHERE m.slug = @slug
+ AND NOT EXISTS (SELECT 1 FROM ap_timeline t WHERE t.slug = m.slug AND t.id = m.object_uri)
+ UNION ALL
+ SELECT 'reply', i.object_uri, ${STEMPEL('COALESCE(i.published, i.created_at)')}
+ FROM ap_interactions i JOIN posts p ON p.id = i.post_id JOIN sites s ON s.id = p.site_id
+ WHERE s.slug = @slug AND i.kind = 'reply'
+ UNION ALL
+ SELECT 'sent', o.id, ${STEMPEL('o.created_at')}
+ FROM ap_outbox o WHERE o.site_slug = @slug`;
+
+export function inboxPage(slug, { before = null, limit = 60 } = {}) {
+ try {
+ const n = Math.min(Math.max(parseInt(limit, 10) || 60, 1), 200);
+ const sep = String(before || '').indexOf('|');
+ const bStamp = before && sep > 0 ? String(before).slice(0, sep) : null;
+ const bRef = before && sep > 0 ? String(before).slice(sep + 1) : null;
+ const rows = db.prepare(`
+ SELECT leg, ref, stamp FROM (${INBOX_UNION})
+ WHERE (@bStamp IS NULL OR stamp < @bStamp OR (stamp = @bStamp AND ref < @bRef))
+ ORDER BY stamp DESC, ref DESC LIMIT @n`).all({ slug, bStamp, bRef, n: n + 1 });
+ const more = rows.length > n;
+ const page = more ? rows.slice(0, n) : rows;
+ return { rows: page, more, oldest: cursorOf(page[page.length - 1]) };
+ } catch { return { rows: [], more: false, oldest: null }; }
+}
+
// De kolommen die een bericht tot kaart maken. Een constante, want de
// gesprekslezing haalt dezelfde rows op: twee lijsten die uiteenlopen leveren
Index: test/inbox-ouder.test.js
===================================================================
--- test/inbox-ouder.test.js (revision e4119c22651ba589d6fceee5bc1802a11716f279)
+++ test/inbox-ouder.test.js (revision e4119c22651ba589d6fceee5bc1802a11716f279)
@@ -0,0 +1,156 @@
+// Ouder dan wat je hebt (shaer-ewrt).
+//
+// De inbox-lezing gaf vier poten van de nieuwste zestig en daaronder niets: een
+// 'load more' in de app had geen adres. Deze toetsen leggen vast dat er nu een
+// weg naar beneden is, dat die over ALLE poten samen loopt (een pagina is
+// compleet voor zijn periode), dat er niets dubbel komt of tussenuit valt --
+// ook niet bij berichten in dezelfde seconde -- en dat de volle lezing verder
+// niet verandert.
+//
+// In-memory SQLite. Run: npm test
+import { test } from 'node:test';
+import assert from 'node:assert/strict';
+
+process.env.DATABASE_PATH = ':memory:';
+process.env.PUBLIC_BASE_URL = 'https://klonkt.test';
+
+const dbMod = await import('../src/config/database.js');
+const db = dbMod.default;
+dbMod.initializeDatabase();
+const AP = await import('../src/services/ActivityPubService.js');
+
+db.prepare('INSERT INTO users (id, username, email, password_hash, role) VALUES (?,?,?,?,?)')
+ .run('u1', 'u1', 'u1@t', 'x', 'god');
+db.prepare('INSERT INTO sites (id, slug, title, owner_id, is_primary) VALUES (?,?,?,?,1)').run('s1', 'lezer', 'Lezer', 'u1');
+db.prepare('INSERT INTO sites (id, slug, title, owner_id) VALUES (?,?,?,?)').run('s2', 'stil', 'Stil', 'u1');
+
+// Een minuut per stap terug vanaf het middaguur, zodat de volgorde vastligt.
+const stempel = (min) => new Date(Date.UTC(2026, 9, 1, 12, 0) - min * 60_000).toISOString();
+const post = (id, min, slug = 'lezer') => db.prepare(
+ `INSERT INTO ap_timeline (id, slug, author_uri, author_name, author_handle, content, published)
+ VALUES (?, ?, 'https://elders/u/til', 'Til', '@til@elders', 'post
', ?)`).run(id, slug, stempel(min));
+const bericht = (uri, min) => db.prepare(
+ `INSERT INTO ap_mentions (slug, object_uri, actor_uri, actor_name, content, published)
+ VALUES ('lezer', ?, 'https://elders/u/oma', 'Oma', 'hoi
', ?)`).run(uri, stempel(min));
+// Zoals SQLite's CURRENT_TIMESTAMP het schrijft: met een spatie en zonder Z.
+// De unie moet die vorm naast de ISO-vorm van de andere poten goed sorteren.
+const verstuurd = (id, min) => db.prepare(
+ `INSERT INTO ap_outbox (id, site_slug, post_id, to_actor, to_actors, content, visibility, created_at)
+ VALUES (?, 'lezer', 'p1', 'https://elders/u/oma', ?, 'terug
', 'direct', ?)`)
+ .run(id, JSON.stringify(['https://elders/u/oma']), stempel(min).replace('T', ' ').replace(/\.\d+Z$/, ''));
+
+// 90 posts, om de drie minuten een bericht, om de vijf een eigen antwoord.
+for (let i = 0; i < 90; i++) post(`https://elders/n/${i}`, i * 2);
+for (let i = 0; i < 40; i++) bericht(`https://elders/m/${i}`, i * 3 + 1);
+for (let i = 0; i < 30; i++) verstuurd(`mijn-${i}`, i * 5 + 2);
+// Drie in DEZELFDE seconde, precies op een plek waar een paginagrens kan
+// vallen. Met 'stamp < before' zouden die stil overgeslagen worden.
+for (const x of ['a', 'b', 'c']) post(`https://elders/n/zelfde-${x}`, 61);
+const ALLES = 90 + 40 + 30 + 3;
+
+const crypto = await import('crypto');
+const express = (await import('express')).default;
+const routes = (await import('../src/routes/activitypub.js')).default;
+const tokens = {};
+for (const slug of ['lezer', 'stil']) {
+ tokens[slug] = `test-token-${slug}-` + 'f'.repeat(24);
+ db.prepare('INSERT INTO oauth_tokens (token_hash, client_id, user_id, site_slug, scope) VALUES (?,?,?,?,?)')
+ .run(crypto.createHash('sha256').update(tokens[slug]).digest('base64url'), 'c', 'u1', slug, 'read write');
+}
+const app = express();
+app.use(routes);
+const server = app.listen(0);
+await new Promise((r) => server.once('listening', r));
+const poort = server.address().port;
+server.unref();
+
+const haal = async (url, slug = 'lezer') => {
+ const r = await fetch(url.replace('https://klonkt.test', `http://127.0.0.1:${poort}`),
+ { headers: { Authorization: `Bearer ${tokens[slug]}` } });
+ assert.equal(r.status, 200, `${url} gaf ${r.status}`);
+ return r.json();
+};
+const wortel = (slug = 'lezer') => haal(`http://127.0.0.1:${poort}/ap/users/${slug}/inbox`, slug);
+const idVan = (item) => (item.object && item.object.id) || item.id;
+
+test('de pagina\'s lopen over alle poten samen, zonder gat en zonder dubbel', () => {
+ const gezien = [];
+ let before = null;
+ for (let ronde = 0; ronde < 20; ronde++) {
+ const p = AP.inboxPage('lezer', { before, limit: 25 });
+ gezien.push(...p.rows);
+ if (!p.more) break;
+ before = p.oldest;
+ }
+ assert.equal(gezien.length, ALLES, 'elke rij precies een keer');
+ assert.equal(new Set(gezien.map((r) => `${r.leg}|${r.ref}`)).size, ALLES, 'niets dubbel');
+ for (let i = 1; i < gezien.length; i++) {
+ assert.ok(gezien[i - 1].stamp >= gezien[i].stamp, `aflopend op ${i}: ${gezien[i - 1].stamp} vóór ${gezien[i].stamp}`);
+ }
+ // De poten zijn door elkaar gevlochten, niet achter elkaar geplakt.
+ const eerste25 = new Set(gezien.slice(0, 25).map((r) => r.leg));
+ assert.deepEqual([...eerste25].sort(), ['message', 'sent', 'timeline']);
+ // De drie van dezelfde seconde zijn er alle drie.
+ assert.equal(gezien.filter((r) => r.ref.includes('zelfde-')).length, 3);
+});
+
+test('de wortel blijft wat hij was, met een next erbij', async () => {
+ const w = await wortel();
+ assert.equal(w.type, 'OrderedCollection', 'de app leest een Page als verschil; dit mag geen Page worden');
+ assert.equal(w.first, undefined, 'geen first: dan zou een paginalezer de hele inbox opnieuw doorlopen');
+ assert.ok(w['shaer:cursor'], 'de wachtlus heeft zijn cursor nog');
+ // Per poot de nieuwste zestig, zoals altijd: 60 posts + 40 berichten + 30 eigen.
+ assert.equal(w.orderedItems.length, 60 + 40 + 30);
+ assert.ok(w.next && w.next.includes('/inbox?before='), 'en de weg naar beneden');
+});
+
+test('next volgen geeft het oudere, als pagina, tot hij op is', async () => {
+ const w = await wortel();
+ const ids = new Set(w.orderedItems.map(idVan));
+ let url = w.next;
+ let paginas = 0;
+ let nieuw = 0;
+ let vorigeOudste = null;
+ while (url && paginas < 10) {
+ const p = await haal(url);
+ paginas++;
+ assert.equal(p.type, 'OrderedCollectionPage');
+ assert.ok(p.partOf.endsWith('/ap/users/lezer/inbox'));
+ assert.equal(p.id, url, 'de pagina noemt zichzelf zoals je hem vroeg');
+ // Ouder dan de vorige pagina, nooit nieuwer.
+ const stempels = p.orderedItems.map((x) => x.published).filter(Boolean);
+ if (vorigeOudste) assert.ok(stempels.every((s) => Date.parse(s) <= Date.parse(vorigeOudste)));
+ vorigeOudste = stempels.reduce((a, b) => (Date.parse(a) < Date.parse(b) ? a : b), stempels[0]);
+ for (const it of p.orderedItems) if (!ids.has(idVan(it))) { ids.add(idVan(it)); nieuw++; }
+ url = p.next;
+ }
+ assert.equal(url, undefined, 'de laatste pagina heeft geen next');
+ // Wat de wortel niet had: de dertig oudste posts (en de drie van dezelfde
+ // seconde, die daar tussen zitten).
+ assert.equal(nieuw, ALLES - (60 + 40 + 30));
+ assert.ok(ids.has('https://elders/n/89'), 'de allereerste post is bereikbaar');
+});
+
+test('de kaarten op een pagina hebben dezelfde vorm als in de volle lezing', async () => {
+ const w = await wortel();
+ const p = await haal(w.next);
+ const kaart = p.orderedItems.find((x) => x.object && x.object.id && x.object.id.startsWith('https://elders/n/'));
+ assert.ok(kaart, 'er staat een post op');
+ assert.equal(kaart.type, 'Create');
+ assert.equal(kaart.object.attributedTo.name, 'Til', 'met byline, net als bovenin');
+ const eigen = p.orderedItems.find((x) => String(x.id).endsWith('#create') && x.actor && x.actor.endsWith('/lezer'));
+ if (eigen) assert.ok(eigen.object.attributedTo, 'een eigen antwoord draagt de eigen byline');
+});
+
+test('een kleine inbox heeft geen next', async () => {
+ post('https://elders/n/stil-1', 1, 'stil');
+ const w = await wortel('stil');
+ assert.equal(w.orderedItems.length, 1);
+ assert.equal(w.next, undefined, 'niets ouder, dus geen knop');
+});
+
+test('limit reist mee in next', async () => {
+ const p = await haal(`http://127.0.0.1:${poort}/ap/users/lezer/inbox?before=${encodeURIComponent(AP.inboxPage('lezer', { limit: 10 }).oldest)}&limit=10`);
+ assert.equal(p.orderedItems.length, 10);
+ assert.ok(p.next.endsWith('&limit=10'), 'anders wordt de tweede pagina stilletjes de standaard');
+});