| [cb3001e] | 1 | // De outbox pagineert (Funkwhale, 11-8).
|
|---|
| 2 | //
|
|---|
| 3 | // Hun serializer weigerde onze outbox letterlijk met
|
|---|
| 4 | // {'first': ['This field is required.'], 'last': ['This field is required.']}
|
|---|
| 5 | // AS2 eist die velden niet -- een collectie mag zijn items inline dragen -- maar
|
|---|
| 6 | // bijna iedereen pagineert, en dit was de eerste CONCRETE reden die we hoorden
|
|---|
| 7 | // waarom er niets van ons binnenkwam.
|
|---|
| 8 | //
|
|---|
| 9 | // De items blijven inline op de wortel: Shaer bouwt zijn feed daaruit.
|
|---|
| 10 | import { test } from 'node:test';
|
|---|
| 11 | import assert from 'node:assert/strict';
|
|---|
| 12 |
|
|---|
| 13 | process.env.DATABASE_PATH = ':memory:';
|
|---|
| 14 | process.env.PUBLIC_BASE_URL = 'https://ons.test';
|
|---|
| 15 |
|
|---|
| 16 | const dbMod = await import('../src/config/database.js');
|
|---|
| 17 | const db = dbMod.default;
|
|---|
| 18 | dbMod.initializeDatabase();
|
|---|
| 19 | const AP = await import('../src/services/ActivityPubService.js');
|
|---|
| 20 |
|
|---|
| 21 | db.prepare('INSERT INTO users (id, username, email, password_hash, role) VALUES (?,?,?,?,?)')
|
|---|
| 22 | .run('u1', 'u1', 'u1@t', 'x', 'god');
|
|---|
| 23 | db.prepare('INSERT INTO sites (id, slug, title, owner_id) VALUES (?,?,?,?)').run('s1', 'dev', 'Dev', 'u1');
|
|---|
| 24 | const site = db.prepare("SELECT * FROM sites WHERE id = 's1'").get();
|
|---|
| 25 | const POST = { id: 'p1', slug: 'hallo', title: 'Hallo', content: '<p>x</p>', published_at: '2026-08-01T00:00:00Z' };
|
|---|
| 26 | const BASE = 'https://ons.test';
|
|---|
| 27 | const OUT = `${BASE}/ap/users/dev/outbox`;
|
|---|
| 28 |
|
|---|
| 29 | test('de wortel draagt first en last', () => {
|
|---|
| 30 | const ob = AP.buildOutbox(BASE, site, [POST]);
|
|---|
| 31 | assert.equal(ob.type, 'OrderedCollection');
|
|---|
| 32 | assert.equal(ob.first, `${OUT}?page=1`);
|
|---|
| 33 | assert.equal(ob.last, `${OUT}?page=1`);
|
|---|
| 34 | });
|
|---|
| 35 |
|
|---|
| 36 | test('en houdt zijn items inline, want Shaer leest die', () => {
|
|---|
| 37 | const ob = AP.buildOutbox(BASE, site, [POST]);
|
|---|
| 38 | assert.equal(ob.orderedItems.length, 1);
|
|---|
| 39 | assert.equal(ob.totalItems, 1);
|
|---|
| 40 | });
|
|---|
| 41 |
|
|---|
| 42 | test('de pagina is een OrderedCollectionPage die terugwijst', () => {
|
|---|
| 43 | const pg = AP.buildOutbox(BASE, site, [POST], [], { page: true });
|
|---|
| 44 | assert.equal(pg.type, 'OrderedCollectionPage');
|
|---|
| 45 | assert.equal(pg.id, `${OUT}?page=1`);
|
|---|
| 46 | assert.equal(pg.partOf, OUT, 'zonder partOf hangt een pagina in de lucht');
|
|---|
| 47 | assert.equal(pg.orderedItems.length, 1);
|
|---|
| 48 | });
|
|---|
| 49 |
|
|---|
| 50 | test('een pagina noemt zichzelf geen wortel', () => {
|
|---|
| 51 | const pg = AP.buildOutbox(BASE, site, [POST], [], { page: true });
|
|---|
| 52 | assert.equal(pg.first, undefined, 'first hoort op de wortel, niet op de pagina');
|
|---|
| 53 | assert.equal(pg.last, undefined);
|
|---|
| 54 | });
|
|---|
| 55 |
|
|---|
| 56 | test('ook een LEGE outbox draagt ze -- een geblokkeerde lezer krijgt geldige AS2', () => {
|
|---|
| 57 | // De blocked-tak levert een lege collectie. Zonder first/last zou juist die
|
|---|
| 58 | // door dezelfde serializer geweigerd worden.
|
|---|
| 59 | const leeg = AP.buildOutbox(BASE, site, []);
|
|---|
| 60 | assert.equal(leeg.totalItems, 0);
|
|---|
| 61 | assert.equal(leeg.first, `${OUT}?page=1`);
|
|---|
| 62 | assert.equal(leeg.last, `${OUT}?page=1`);
|
|---|
| 63 | });
|
|---|
| [aed0092] | 64 |
|
|---|
| 65 | // ── En de andere collecties, want compleetheid was de opdracht ────────────
|
|---|
| 66 |
|
|---|
| 67 | test('followers en following dragen ze ook, ook count-only', () => {
|
|---|
| 68 | // Publiek geven die alleen een AANTAL en houden de lijst dicht. Juist dan is
|
|---|
| 69 | // een geldige collectie belangrijk: anders is "ik mag de lijst niet zien"
|
|---|
| 70 | // niet te onderscheiden van een kapot antwoord.
|
|---|
| 71 | const f = AP.buildFollowers(BASE, site, 42, null);
|
|---|
| 72 | assert.equal(f.totalItems, 42);
|
|---|
| 73 | assert.deepEqual(f.orderedItems, []);
|
|---|
| 74 | assert.equal(f.first, `${BASE}/ap/users/dev/followers?page=1`);
|
|---|
| 75 | const g = AP.buildFollowing(BASE, site, 3, null);
|
|---|
| 76 | assert.equal(g.first, `${BASE}/ap/users/dev/following?page=1`);
|
|---|
| 77 | assert.equal(g.last, `${BASE}/ap/users/dev/following?page=1`);
|
|---|
| 78 | });
|
|---|
| 79 |
|
|---|
| 80 | test('featured ook', () => {
|
|---|
| 81 | const ft = AP.buildFeatured(BASE, site, [POST]);
|
|---|
| 82 | assert.equal(ft.first, `${BASE}/ap/users/dev/featured?page=1`);
|
|---|
| 83 | assert.equal(ft.orderedItems.length, 1, 'en de items blijven inline');
|
|---|
| 84 | });
|
|---|
| 85 |
|
|---|
| 86 | test('de muziekcollecties ook, met hun eigen velden erbij', () => {
|
|---|
| 87 | const tc = AP.buildTrackCollection(BASE, site, []);
|
|---|
| 88 | assert.equal(tc.first, `${BASE}/ap/users/dev/tracks?page=1`);
|
|---|
| 89 | assert.equal(tc.attributedTo, `${BASE}/ap/users/dev`,
|
|---|
| 90 | 'de helper mag attributedTo niet opeten');
|
|---|
| 91 | });
|
|---|
| 92 |
|
|---|
| 93 | test('de guardianship-wachtrijen ook', async () => {
|
|---|
| 94 | const q = await import('../src/services/guardianship/queues.js');
|
|---|
| 95 | const c = q.helpCollection('https://ons.test/q/help', 'dev');
|
|---|
| 96 | assert.equal(c.first, 'https://ons.test/q/help?page=1');
|
|---|
| 97 | assert.equal(c['@context'], undefined,
|
|---|
| 98 | 'de context zet de route erop -- twee keer zou hem ongeldig maken');
|
|---|
| 99 | });
|
|---|