Changeset f06ed56 in Klonkt for src/services/ActivityPubService.js

Timestamp:

08/10/2026 03:42:31 AM (4 weeks ago)

Author:

Bart <bart@…>

Branches:

main

Children:

7e53594

Parents:

8064da1

Message:

Een logboek, zodat de reden ergens blijft staan

Guardianship-events waren vluchtig: onGuardianshipEvent wekte de long-poll,
zocht in een tabel van zeven soorten of er een push bij hoorde, en liet de rest
vallen. Elf van de achttien soorten verdwenen spoorloos, met hun inhoud. Een
weigering droeg reason: 'not_a_teapot' tot precies daar en niet verder --
terwijl §4.2 eist dat de ward en zijn guardians die reden te HOREN krijgen, en
niet dat ze hem afleiden uit een aanbod dat opeens weg is.

Vastleggen en melden zijn nu twee dingen. Alles komt in ap_guardian_events;
welke gebeurtenis een mens wakker maakt blijft de aparte, korte lijst die het
altijd al was.

Ingeklapt en onderaan, want hier vraagt niets om een antwoord. Zou dit tussen
de wachtrijen staan, dan wordt "moet ik iets doen" onleesbaar -- dezelfde reden
waarom de afgehandelde hulpvragen daar al staan.

200 per account, jongste eerst. Een logboek dat oneindig groeit wordt er een
die niemand opent, en afkappen aan de verkeerde kant zou hem onbruikbaar maken
op het moment dat er juist iets gebeurt. Schrijffouten worden geslikt: het
logboek is bijzaak en mag de commit of de weigering zelf nooit meesleuren.

Onbekende soorten vallen in de PWA terug op hun ruwe naam. Zichtbaar en lelijk
is beter dan netjes en afwezig.

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

File:

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

src/services/ActivityPubService.js

@@ -6048 +6048 @@
  * was hij onbereikbaar, en een mutatie die het wekken weghaalde bleef groen.
  */
+/**
+ * Hoeveel er van bewaard blijft. Een logboek dat oneindig groeit is een
+ * logboek dat niemand meer opent, en dit is geschiedenis, geen archief: wat
+ * ertoe doet staat vooraan.
+ */
+export const GUARDIAN_EVENT_KEEP = 200;
+
+/**
+ * Leg de gebeurtenis vast VOOR de melding.
+ *
+ * De meldingstabel beslist wie er wakker van wordt, en dat is terecht een korte
+ * lijst -- maar hij besliste daarmee ook wat er onthouden werd, en dat was niet
+ * de bedoeling. Elf van de achttien soorten verdwenen spoorloos, met hun inhoud:
+ * een geweigerd aanbod droeg de REDEN mee tot hier en niet verder, terwijl §4.2
+ * eist dat de ward en zijn guardians die te horen krijgen.
+ *
+ * Vastleggen en melden zijn nu twee dingen. Alles komt in het logboek; alleen
+ * wat een mens moet wekken gaat ook als push de deur uit.
+ */
+export function recordGuardianEvent(slug, ev) {
+  if (!slug || !ev || !ev.kind) return;
+  try {
+    db.prepare('INSERT INTO ap_guardian_events (slug, kind, payload, created_at) VALUES (?,?,?,CURRENT_TIMESTAMP)')
+      .run(slug, String(ev.kind), JSON.stringify(ev));
+    db.prepare(`DELETE FROM ap_guardian_events WHERE slug = ? AND id NOT IN
+                (SELECT id FROM ap_guardian_events WHERE slug = ? ORDER BY id DESC LIMIT ?)`)
+      .run(slug, slug, GUARDIAN_EVENT_KEEP);
+  } catch { /* een logboek mag nooit de gebeurtenis zelf breken */ }
+}
+
+/** De laatste gebeurtenissen voor dit account, nieuwste eerst. */
+export function listGuardianEvents(slug, limit = 50) {
+  try {
+    return db.prepare('SELECT id, kind, payload, created_at FROM ap_guardian_events WHERE slug = ? ORDER BY id DESC LIMIT ?')
+      .all(slug, Math.max(1, Math.min(Number(limit) || 50, GUARDIAN_EVENT_KEEP)))
+      .map((r) => ({ id: r.id, kind: r.kind, created: r.created_at, ...safeJson(r.payload) }));
+  } catch { return []; }
+}
+
+function safeJson(s) { try { return JSON.parse(s) || {}; } catch { return {}; } }
+
 export function onGuardianshipEvent(slug, ev) {
+  recordGuardianEvent(slug, ev);
   wakeGuardian(slug);
   const p = guardianEventPush(slug, ev);
@@ -6141 +6183 @@
   webfingerResolve, followActor, resolveRemoteActor, unfollowActor, handleMoveInbox, moveAccount, listFollowing, setAutoBoost, backfillFromOutbox, getTimeline, getDirectMessages, isoStamp, timelineAttachments, timelineEmojis, timelineObjectLinks, timelineQuote, timelineEmbed, applyQuoteProps, deliverToActor, sendInteraction, voteOnPoll, voteOnRemotePoll,
   acceptGatedFollow, rejectGatedFollow, isWardGuardian, outboxAudience, sendFollowDecision,
-  gateOutgoingFollow, performApprovedFollow,
+  gateOutgoingFollow, performApprovedFollow, recordGuardianEvent, listGuardianEvents, GUARDIAN_EVENT_KEEP,
   parseOwnPoll, pollTally, ownPollView, deliverPollUpdate, maybeCrawlThread, sendReport, localMentionSlugs, previewCard,
   autoBoostCount, boostedCount, setReaction, getReaction, getReactionsFor, canonicalReactionUri, migrateReactions, upsertBoostedNote, getCirkelPosts, getCirkelMembers, selfHealTimeline,