Changeset 8ed36de in Klonkt for src

Timestamp:

08/21/2026 04:57:20 PM (3 weeks ago)

Author:

Robin <roboburr@…>

Branches:

main

Children:

b0ccd0d

Parents:

4e5fe29

Message:

Een verwijderde track kondigt zichzelf aan, net als een post

Een post stuurt bij verwijderen een Delete(Tombstone) naar zijn volgers; een
track deed dat niet. De rij ging weg, het Audio-object gaf 404, en elke server
die hem had geindexeerd bleef ernaar wijzen. Op de hub stond het er vandaag als
een kaartje met een dode link, en het viel alleen op doordat robo het zag.

Sinds shaer-0nh is een track een eersterangs Audio-object met een eigen id, dus
hij hoort ook een eigen afmelding te krijgen.

• deliverObjectDelete(site, objectId) is de gedeelde romp; deliverDelete en het nieuwe deliverTrackDelete leunen er allebei op. Het object-id komt van de aanroeper, want bij verwijderen is de rij vaak al weg.
• trackUri() staat nu op EEN plek in music/index.js. Het formaat werd eerder alleen door de bouwkant gekend, en een tweede plek die het opnieuw in elkaar zet is precies hoe je een Delete stuurt die de ontvanger niet herkent.
• Beide verwijderroutes in admin-audio melden af: de losse verwijdering en de opruiming van wezen. Een wees is voor ONS een track zonder bestand, maar de buitenwereld heeft een gewoon Audio-object opgeslagen.

Twee tests door de echte route. Een testhaak op deliver() bestaat niet, dus de
proef kijkt in ap_delivery: de volger krijgt een inbox op een dichte poort, de
directe poging faalt, en de activiteit hoort in de wachtrij te belanden. Die
tabel was in het echte geval leeg, dus dat is precies het bewijs. Controleproef
gedraaid: zonder de aankondiging valt de test om.

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

Location:

src

Files:

• routes/admin-audio.js (modified) (3 diffs)
• services/ActivityPubService.js (modified) (4 diffs)
• services/music/index.js (modified) (2 diffs)

src/routes/admin-audio.js

@@ -23 +23 @@
 import { audioUrl } from '../services/AudioStreamService.js';
 import { mediaDir } from '../config/paths.js';
+import * as ActivityPubService from '../services/ActivityPubService.js';
 
 const __dirname = path.dirname(fileURLToPath(import.meta.url));
@@ -301 +302 @@
   if (!track) return res.redirect('/admin/audio?error=Not+found');
 
+  // Zeg de fediverse dat de track weg is, VOOR de rij verdwijnt -- zelfde
+  // volgorde en zelfde reden als bij een post (posts.js). Zonder dit blijft
+  // elke server die hem indexeerde ernaar wijzen terwijl het object 404 geeft;
+  // op de hub stond daardoor op 21-8 een track met een dode link.
+  ActivityPubService.deliverTrackDelete(site, track.track_id).catch(() => { /* best-effort */ });
+
   db.prepare('DELETE FROM audio_tracks WHERE id = ?').run(track.track_id);
   if (track.media_id) {
@@ -371 +378 @@
     if (o.media_id) db.prepare('DELETE FROM media WHERE id = ?').run(o.media_id);
   });
-  for (const o of orphans) deleteOne(o);
+  for (const o of orphans) {
+    // Ook hier aankondigen. Een wees is voor ONS een track zonder bestand, maar
+    // voor de buitenwereld was het een gewoon Audio-object dat zij hebben
+    // opgeslagen; stil weggooien laat hun kopie staan.
+    ActivityPubService.deliverTrackDelete(site, o.track_id).catch(() => { /* best-effort */ });
+    deleteOne(o);
+  }
 
   res.json({ ok: true, deleted: orphans.length });

src/services/ActivityPubService.js

@@ -37 +37 @@
 import { TRACK_KOLOMMEN,
   playlistOpenTracks, siteOpenTracks, openTrack, trackHostPosts,
-  buildTrackAudio, buildTrackCollection, buildTrackCreate,
+  buildTrackAudio, buildTrackCollection, buildTrackCreate, trackUri,
   buildPlaylistCollection, listPlaylistsAP, playlistLinkTags,
   buildPostTrackCollection, uitgavePost,
@@ -3107 +3107 @@
 
 // Tell followers a post is gone (Delete + Tombstone) so it's removed from their feeds.
-export async function deliverDelete(site, post) {
+/**
+ * Delete(Tombstone) voor een van onze EIGEN objecten, naar alle volgers.
+ *
+ * De romp staat apart omdat een post niet het enige is dat wij de draad op
+ * sturen. Een track is een eersterangs Audio-object met een eigen id
+ * (shaer-0nh), en die werd bij verwijderen nergens aangekondigd: de rij ging
+ * weg, het object ging 404 en elke server die hem had geindexeerd hield hem
+ * voor altijd. Op de hub kwam dat op 21-8 aan het licht als een track die naar
+ * een dode URL wees.
+ *
+ * Het object-id komt van de aanroeper. Dat moet ook wel: bij verwijderen is de
+ * rij vaak al weg, dus er valt niets meer op te zoeken.
+ */
+export async function deliverObjectDelete(site, objectId) {
   const base = (process.env.PUBLIC_BASE_URL || '').replace(/\/+$/, '');
-  if (!base || !site || !site.slug || !post || !post.id) return;
+  if (!base || !site || !site.slug || !objectId) return;
   const followers = fStmts().list.all(site.slug);
   if (!followers.length) return;
@@ -3115 +3128 @@
   const keys = getOrCreateKeys(site.slug);
   const me = actorId(base, site.slug);
-  const nid = noteId(base, post.id);
   const del = {
     '@context': AP_CONTEXT,
-    id: `${nid}#delete-${Date.now()}-${rid()}`,
+    id: `${objectId}#delete-${Date.now()}-${rid()}`,
     type: 'Delete',
     actor: me,
     to: [PUBLIC],
-    object: { id: nid, type: 'Tombstone' },
+    object: { id: objectId, type: 'Tombstone' },
   };
   for (const inbox of inboxes) deliverWithRetry(site.slug, inbox, del, `${me}#main-key`, keys.private_pem);
+}
+
+export async function deliverDelete(site, post) {
+  const base = (process.env.PUBLIC_BASE_URL || '').replace(/\/+$/, '');
+  if (!base || !post || !post.id) return;
+  return deliverObjectDelete(site, noteId(base, post.id));
+}
+
+/**
+ * Zelfde voor een track. Roep dit aan VOOR het verwijderen van de rij, net als
+ * bij een post: daarna is `id` er nog wel maar de context niet meer.
+ */
+export async function deliverTrackDelete(site, trackId) {
+  const base = (process.env.PUBLIC_BASE_URL || '').replace(/\/+$/, '');
+  if (!base || !site || !site.slug || !trackId) return;
+  return deliverObjectDelete(site, trackUri(base, site, trackId));
 }
 
@@ -6966 +6994 @@
   buildPostTrackCollection, uitgavePost,
   buildLibrary, libraryId,
-  followerCount, deliver, fetchActor, verifyRequest, handleInbox, deliverCreate, deliverDelete, deliverUpdate, deliverActorUpdate, resyncFeaturedPins,
+  followerCount, deliver, fetchActor, verifyRequest, handleInbox, deliverCreate, deliverDelete, deliverObjectDelete, deliverTrackDelete, deliverUpdate, deliverActorUpdate, resyncFeaturedPins,
   feedCursor, feedChangesSince, waitForFeedChange,
   getInteractions, getInteractionById, setInteractionBoosted, setInteractionLiked, buildReplyNote, getOutboxNote, getSentNotes, deliverReply, resolveRemoteNote, noteAudience, mayReadNote,

src/services/music/index.js

@@ -165 +165 @@
 }
 
+/**
+ * De identiteit van een track op de draad.
+ *
+ * Staat apart omdat hij op TWEE momenten nodig is die ver uit elkaar liggen:
+ * bij het bouwen van het Audio-object, en bij het verwijderen ervan, wanneer de
+ * rij al weg is en er dus niets meer te bouwen valt. Toen dit nog inline stond,
+ * kende alleen de bouwkant de vorm en ging er bij verwijderen geen Delete uit --
+ * elke server die de track had geindexeerd hield hem voor altijd (21-8).
+ */
+export function trackUri(base, site, id) {
+  return `${actorId(base, site.slug)}/tracks/${encodeURIComponent(id)}`;
+}
+
 export function buildTrackAudio(base, site, r, opts = {}) {
   const abs = (u) => !u ? null : (/^https?:/i.test(u) ? u : `${base}${u.startsWith('/') ? '' : '/'}${u}`);
@@ -187 +200 @@
   const a = {
     ...(opts.standalone ? { '@context': AP_CONTEXT } : {}),
-    id: `${actorId(base, site.slug)}/tracks/${encodeURIComponent(r.id)}`,
+    id: trackUri(base, site, r.id),
     type: 'Audio',
     name: r.title || 'Audio',