Changeset eb071a7 in Klonkt for test

Timestamp:

08/14/2026 12:12:58 AM (4 weeks ago)

Author:

Robin <roboburr@…>

Branches:

main

Children:

919b82d

Parents:

98acb97

Message:

Een tweede ronde vult aan in plaats van over te slaan

Robin vroeg of hij eerst moest opschonen. Bij het uitzoeken bleek dat het
antwoord "ja" had moeten zijn, en dat dat een val in mijn eigen ontwerp was.

De ingest onthield per bron-URI dat hij hem gehad had, en passeerde hem daarna
altijd. Dat is prima zolang er niets verandert, maar er kwam juist iets bij:
hoezen, duur en playlists. Wie al opgehaald had zat vast. Opnieuw drukken sloeg
alles over, en opruimen hielp niet, want die blokkade zat in ap_migration en
niet in de tracks. Je zou drie dingen tegelijk moeten wissen om er los te komen,
en dat is geen opdracht die je een gebruiker geeft.

Nu kijkt hij op waar een bron-URI hier terechtkwam, en vult LEGE velden aan op
de rij die er al staat. Wat je zelf hebt aangepast blijft staan: een migratie
hoort je correcties niet terug te draaien. Het geluidsbestand wordt niet opnieuw
gedownload. Playlists werken hetzelfde: dezelfde rij, en de volgorde opnieuw
gezet, want een half bijgewerkte volgorde is erger dan een verse.

Gemeten op de gemeten stand van soundfabrics.nl (139 nummers met bestand, geen
hoes, geen duur, geen playlist), nagebouwd met 3 nummers:

ronde 1 3 nummers binnen, geen hoes, duur 212s uit PT212S
ronde 2 0 erbij, 3 aangevuld, 1 playlist, geen dubbele, mp3 niet opnieuw
ronde 3 0 aangevuld, alles compleet, niets verandert

Changed files:
src/services/MigrationService.js

• migrationTarget(): waar kwam deze bron-URI terecht
• tracks worden aangevuld in plaats van gepasseerd; alleen lege velden
• de trackkaart wordt OOK in die tak gevuld, anders vinden de playlists hun nummers niet en komt er geen plaat
• playlists werken dezelfde kant op, met hun eigen mapping

src/views/pages/admin-migrate.ejs

• "nummers aangevuld" en playlists in het ophaalverslag; anders meldt een ronde die drie nummers compleet maakte "0 erbij gekomen"

src/services/i18n.js

• mig.r_tracks_updated in nl/en/de

remarks: het verslag zegt ook "1 playlists" als er niets aan die plaat
veranderde, want de volgorde wordt elke ronde opnieuw gezet. Klopt wel, leest
iets te groot. Robin hoeft nu niets op te schonen: een keer ophalen na de uitrol
volstaat.

-robo
Co-Authored-By: Claude Opus 4.8 <noreply@…>

File:

• test/fep1580-migration.test.js (modified) (1 diff)

test/fep1580-migration.test.js

@@ -398 +398 @@
 });
 
+test('een tweede ronde VULT AAN en slaat niet over', async () => {
+  // De val die Robin bijna in liep: de eerste versie van de ingest onthield per
+  // bron-URI "al gehad" en passeerde die daarna altijd. Kwam er later iets bij
+  // (hoezen, duur, playlists), dan kon je opnieuw drukken zoveel je wilde en
+  // gebeurde er niets. Opruimen hielp ook niet, want ap_migration hield de
+  // blokkade in stand. Dus: aanvullen, niet overslaan.
+  const s = site({ aliases: [BRON] });
+  const AUDIO = `${BRON}/audio/x.mp3`;
+  const HOES = `${BRON}/media/hoes.png`;
+  const maakKaart = (metHoes) => new Map([
+    [BRON, { id: BRON, type: 'Person', movedTo: IK, outbox: `${BRON}/outbox`, streams: [`${BRON}/tracks`] }],
+    [`${BRON}/outbox`, { type: 'OrderedCollection', orderedItems: [] }],
+    [`${BRON}/tracks`, {
+      type: 'OrderedCollection',
+      orderedItems: [{
+        id: `${BRON}/tracks/t1`, type: 'Audio', name: 'Nummer', summary: 'Robo', duration: 'PT212S',
+        url: [{ type: 'Link', href: AUDIO, mediaType: 'audio/mpeg' }],
+        ...(metHoes ? { icon: { type: 'Image', url: HOES } } : {}),
+      }],
+    }],
+  ]);
+  const gehaald = [];
+  const deps = (metHoes) => ({
+    getJson: async (_slug, url) => maakKaart(metHoes).get(url) || null,
+    noteId: (b, id) => `${b}/ap/notes/${id}`,
+    noteVisibility: AP.noteVisibility,
+    audioRoot: '/nep/audio', mediaRoot: '/nep/media',
+    signHeaders: () => ({ Signature: 'nep' }),
+    safeFetch: async (url) => {
+      gehaald.push(url);
+      return { ok: true, arrayBuffer: async () => Buffer.from('x'), headers: { get: () => 'audio/mpeg' } };
+    },
+    fs: { mkdirSync() {}, writeFileSync() {} },
+    path,
+  });
+
+  // Ronde 1: zonder hoes, zoals de eerste uitrol.
+  const r1 = await stil(() => Mig.ingestFromSource(s, { deps: deps(false) }));
+  assert.equal(r1.tracksBinnen, 1);
+  const na1 = db.prepare('SELECT id, cover_url, duration FROM audio_tracks').get();
+  assert.equal(na1.cover_url, null);
+  assert.equal(na1.duration, 212, 'PT212S hoort 212 seconden te worden');
+
+  // Ronde 2: nu MET hoes. Hij moet aanvullen, niet passeren en niet verdubbelen.
+  const voor = gehaald.length;
+  const r2 = await stil(() => Mig.ingestFromSource(s, { deps: deps(true) }));
+  assert.equal(r2.tracksBinnen, 0, 'er komt niets nieuws bij');
+  assert.equal(r2.tracksBijgewerkt, 1, 'maar het bestaande nummer wordt wel aangevuld');
+  assert.equal(db.prepare('SELECT COUNT(*) n FROM audio_tracks').get().n, 1, 'geen dubbele');
+  const na2 = db.prepare('SELECT id, cover_url FROM audio_tracks').get();
+  assert.equal(na2.id, na1.id, 'dezelfde rij, niet een nieuwe');
+  assert.ok(na2.cover_url, 'en de hoes is er nu wel');
+  assert.ok(!gehaald.slice(voor).includes(AUDIO), 'het geluidsbestand wordt NIET opnieuw gedownload');
+
+  // Ronde 3: alles compleet, dus er valt niets meer aan te vullen.
+  const r3 = await stil(() => Mig.ingestFromSource(s, { deps: deps(true) }));
+  assert.equal(r3.tracksBijgewerkt, 0);
+  assert.equal(r3.overgeslagenTracks, 1);
+});
+
 test('een niet-publiek bericht komt wel mee maar niet in de publieke tabel', async () => {
   const s = site({ aliases: [BRON] });