Changeset 749605a in Klonkt for src/services/ActivityPubService.js

Timestamp:

08/16/2026 03:06:18 PM (3 weeks ago)

Author:

Robin <roboburr@…>

Branches:

main

Children:

a5caa73

Parents:

a5515b4 (diff), 9026de5 (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.

Message:

Bibliotheek en album-federatie terug op main (shaer-0nh, shaer-756s)

Achttien commits, in drie brokken.

DE BIBLIOTHEEK. Een Library-skelet met een eigen volgerssoort: wie de
bibliotheek volgt krijgt de muziek en met opzet niet de gewone posts, en
die staan daarom in een eigen tabel -- een vlag die iemand vergeet te
filteren bezorgt stilletjes de Krant aan mensen die er niet om vroegen.
Daarna wat er nodig bleek om werkelijk gelezen te worden: audience
(zonder dat gaf hun create() een KeyError en dus een 500 op onze URL),
de ongeordende collectievorm, en paginering op elke collectie die first
belooft -- die laatste vond meteen dat featured hetzelfde gat had.

HET VOCABULAIRE. fw:track in de kleine vorm die Emissary ook stuurt,
artist_credit met de site-actor als Artist (mogelijk geworden door de
MusicBrainz-koppeling), en het album als ingesloten fw:Album met
released, musicbrainzId en een eigen artist_credit. Daarvoor kwamen er
twee kolommen op playlists, alleen bij kind='album' en afgedwongen in
PlaylistService -- niet in het scherm, want de API ligt open.

HET BEHEER. De vijf mediapagina's stonden op drie verschillende
ontwerpen; nu op een gedeelde ax-romp, met de primitieven op een plek in
plaats van in acht kopieen. De playlist-modal ging alsnog door i18n: die
teksten stonden hard in het script, wat niet opviel omdat het toevallig
de brontaal was.

WAT ER NIET IN ZIT: bitrate en size top-level als fw:. Dat is bewust
(shaer-3f8a). Hun eigen outbox zet ze op de Link, net als wij, en het
wordt een gesprek in plaats van een aanpassing -- briefing in
~/bewaard/funkwhale-briefing-en.md.

Gereedschap dat meekomt: scripts/funkwhale-gat.mjs meet het gat naar hun
ingest, admin-css.mjs en admin-css-gelijk.mjs ontleden en vergelijken de
beheer-CSS, render-admin-views.mjs rendert de views gevuld en leeg. Die
laatste drie omdat de testsuite geen enkele view aanraakt.

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

File:

• src/services/ActivityPubService.js (modified) (8 diffs)

src/services/ActivityPubService.js

@@ -34 +34 @@
 // De muziekkant woont in music/ (shaer-drc). Doorgeven wat hier altijd
 // vandaan kwam, zodat elke bestaande aanroep blijft werken.
+import { luisteraars } from './music/index.js';
 import { TRACK_KOLOMMEN,
   playlistOpenTracks, siteOpenTracks, openTrack, trackHostPosts,
@@ -39 +40 @@
   buildPlaylistCollection, listPlaylistsAP, playlistLinkTags,
   buildPostTrackCollection, uitgavePost,
+  buildLibrary, libraryId,
   licentieUri, channelCategory,
 } from './music/index.js';
@@ -46 +48 @@
   buildPlaylistCollection, listPlaylistsAP, playlistLinkTags, licentieUri,
   buildPostTrackCollection, uitgavePost,
+  buildLibrary, libraryId,
 };
 
@@ -354 +357 @@
   const pagina = pickLink(o.url, () => true);
   return { html: HtmlSanitizerService.sanitize(o.content || ''), atts, url: pagina ? pagina.href : null };
+}
+
+/**
+ * De site achter een library-uri, of null. Zelfde strengheid als localSlugOf:
+ * de uri moet met ONZE basis beginnen en de site moet bestaan -- anders levert
+ * andermans /library met dezelfde padstaart hier een volger op onze naam op.
+ */
+function libraryOwnerSlug(uri) {
+  const u = String(uri || '');
+  if (!u.endsWith('/library')) return null;
+  return localSlugOf(u.slice(0, -'/library'.length));
 }
 
@@ -1186 +1200 @@
 // these as the "Featured" tab (pinned to the profile). Posts come ordered by pin
 // rank; embedded as full Notes so a remote server doesn't need extra fetches.
-export function buildFeatured(base, site, posts) {
+export function buildFeatured(base, site, posts, { page = false } = {}) {
   const id = `${actorId(base, site.slug)}/featured`;
   const items = (posts || []).map((p) => buildNote(base, site, p));
-  return pagedCollection(id, items);
+  return pagedCollection(id, items, { page });
 }
 
@@ -2354 +2368 @@
   if (type === 'Follow') {
     const who = typeof act.actor === 'string' ? act.actor : (act.actor && act.actor.id);
+    // EERST: volgt iemand onze BIBLIOTHEEK in plaats van onze actor? (shaer-0nh)
+    //
+    // Een luisteraar krijgt de muziek en NIET de gewone posts -- wie zich
+    // abonneert op een platenkast heeft niet om de Krant gevraagd. Vandaar een
+    // eigen tabel: zolang ze daar staan kan een postbezorging ze niet per
+    // ongeluk meenemen.
+    //
+    // De bibliotheek is openbaar (alles erin is fedi_open), dus dit accepteert
+    // meteen. Er valt niets goed te keuren, en dan is wachten oneerlijk.
+    const libSlug = libraryOwnerSlug(typeof act.object === 'string' ? act.object : (act.object && act.object.id));
+    if (who && libSlug) {
+      const remote = await fetchActor(who);
+      if (!remote || !remote.inbox) return 202;
+      const fi = actorInfo(remote, who);
+      luisteraars.voegToe(libSlug, {
+        actorUri: who, inbox: remote.inbox,
+        sharedInbox: (remote.endpoints && remote.endpoints.sharedInbox) || null,
+        name: fi.name, handle: fi.handle, icon: fi.icon,
+      });
+      const keys = getOrCreateKeys(libSlug);
+      const accept = {
+        '@context': AP_CONTEXT,
+        id: `${actorId(base, libSlug)}#accept-library-${Date.now()}-${rid()}`,
+        type: 'Accept', actor: actorId(base, libSlug), object: act,
+      };
+      deliver(remote.inbox, accept, `${actorId(base, libSlug)}#main-key`, keys.privatePem)
+        .catch(() => { /* de volger staat er; een mislukte Accept mag dat niet omgooien */ });
+      console.log('[AP] library follow from', who, '->', libSlug);
+      return 202;
+    }
     // slugParam is de eigenaar van een per-actor inbox; op de GEDEELDE inbox is
     // die er niet en werd de slug uit act.object geraden. Zonder hostcontrole
@@ -2437 +2481 @@
     return 202;
   }
+  // Een luisteraar die weggaat, hoort meteen weg te zijn.
+  if (type === 'Undo' && act.object && act.object.type === 'Follow') {
+    const doel = typeof act.object.object === 'string' ? act.object.object : (act.object.object && act.object.object.id);
+    const libSlug = libraryOwnerSlug(doel);
+    const wie = typeof act.actor === 'string' ? act.actor : (act.actor && act.actor.id);
+    if (libSlug && wie && luisteraars.verwijder(libSlug, wie)) {
+      console.log('[AP] library unfollow from', wie, '->', libSlug);
+      return 202;
+    }
+  }
+
   if (type === 'Undo' && act.object) {
     const who = typeof act.actor === 'string' ? act.actor : (act.actor && act.actor.id);
@@ -6809 +6864 @@
   buildPlaylistCollection, playlistOpenTracks, listPlaylistsAP, playlistLinkTags,
   buildPostTrackCollection, uitgavePost,
+  buildLibrary, libraryId,
   followerCount, deliver, fetchActor, verifyRequest, handleInbox, deliverCreate, deliverDelete, deliverUpdate, deliverActorUpdate, resyncFeaturedPins,
   feedCursor, feedChangesSince, waitForFeedChange,