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

Timestamp:

07/24/2026 06:04:03 PM (7 weeks ago)

Author:

Robin Genis <roboburr@…>

Branches:

main

Children:

780a7c6

Parents:

1a2d8ac

Message:

Guardian-PWA: duidelijker + verstuurde offer altijd zichtbaar

Twee klachten opgelost.

"Ik zie niet dat ik verstuurd heb": de offer werd wél opgeslagen, maar als de
directe bezorging aan de remote ward faalde gaf de flow 502 en ververste de
PWA niet, dus de kaart verscheen niet. Nu: bezorging is async met retry (de
delivery-queue), de handshake geeft altijd 202 (opgeslagen) met een
delivered-vlag, en de PWA ververst altijd en toont de offer onder een eigen
sectie "Verzonden aanvragen · wacht op antwoord". Faalt de eerste bezorging,
dan meldt de UI dat we blijven proberen.

"Mag allemaal duidelijker": de pagina is herzien met vaste secties met kop en
uitleg: Hulpverzoeken (met teller), Ward adopteren (met uitleg wat er gebeurt),
Verzonden aanvragen, Mijn wards (actief-tag), Meldingen. Statussen als tags,
nette lege staten, alles via i18n (nl/en/de).

Changed files:
src/services/ActivityPubService.js

• deliverToActor: enqueue+retry+logging, geeft {delivered, inbox}

src/services/guardianship/handshake.js

• Offer/Accept/Reject: altijd 202 (opgeslagen) + delivered-vlag

src/routes/guardian.js

• /adopt niet meer hard falen op bezorg-hik; delivered terug; meer strings

src/views/pages/guardian.ejs

• herziene, duidelijke secties

src/assets/js/guardian.js

• aparte "Verzonden aanvragen"-sectie, altijd verversen na adopt

src/assets/css/guardian.css

• sectie-koppen, status-tags, nette lege staten

src/services/i18n.js

• uitgebreide guardian.*-teksten nl/en/de

remarks: als de offer "niet binnenkomt" bij de ward, moet diens Klonkt de
nieuwe code draaien (demo/beta/demohub zijn bij); een oude Klonkt of Mastodon
snapt de Offer-Relationship niet.

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

File:

• src/services/ActivityPubService.js (modified) (1 diff)

src/services/ActivityPubService.js

@@ -3129 +3129 @@
   return actorId(base, slug);
 }
-// Deliver one activity to one actor's inbox, signed; queued on failure.
+// Deliver one activity to one actor's inbox, signed; queued + retried on any
+// hiccup so a slow or briefly-down ward server never loses the offer. Returns
+// { delivered, inbox }: delivered=false means the account could not be
+// resolved at all (a bad handle) — the offer stays recorded regardless.
 async function deliverToActor(site, actorUri, activity) {
-  const a = await fetchActor(actorUri).catch(() => null);
-  const inbox = a && (a.inbox || (a.endpoints && a.endpoints.sharedInbox));
-  if (!inbox) return false;
   const me = selfActorId(site.slug);
   const keys = getOrCreateKeys(site.slug);
   const payload = { '@context': AP_CONTEXT, ...activity };
+  const a = await fetchActor(actorUri).catch(() => null);
+  const inbox = a && (a.inbox || (a.endpoints && a.endpoints.sharedInbox));
+  if (!inbox) {
+    console.warn('[AP] guardianship: could not resolve an inbox for', actorUri, '(offer recorded, not sent)');
+    return { delivered: false, inbox: null };
+  }
   try {
     const st = await deliver(inbox, payload, `${me}#main-key`, keys.private_pem);
-    if (st >= 200 && st < 300) return true;
-  } catch { /* fall through to the queue */ }
+    if (st >= 200 && st < 300) { console.log('[AP] guardianship', activity.type, 'delivered →', inbox, st); return { delivered: true, inbox }; }
+    console.warn('[AP] guardianship', activity.type, 'got', st, 'from', inbox, '→ queued for retry');
+  } catch (e) { console.warn('[AP] guardianship', activity.type, 'to', inbox, 'failed:', e.message, '→ queued for retry'); }
   enqueueDelivery(site.slug, inbox, payload);
-  return true;   // queued: it will arrive
+  return { delivered: true, inbox };   // queued: the retry worker gets it there
 }
 Guardianship.wireDelivery({