Changeset 06bae1e in Klonkt for src/services/ActivityPubService.js

Timestamp:

08/08/2026 04:09:04 AM (5 weeks ago)

Author:

Robin <roboburr@…>

Branches:

main

Children:

0517013

Parents:

3b43e4c

git-author:

Robin <roboburr@…> (08/08/2026 04:08:53 AM)

git-committer:

Robin <roboburr@…> (08/08/2026 04:09:04 AM)

Message:

Een Accept die ons follow-id niet teruggeeft, telt nu ook

Gevonden tegen Funkwhale (audio.pepemoss.com, 7 augustus). Wij stuurden een
Follow met id

.../ap/users/dev#follow-1786161977286-bb2de32f

en de Accept kwam terug met een door Funkwhale ZELF verzonnen id, in onze
eigen namespace:

.../ap/users/dev#follows/19fd8b00-8f66-4362-b233-542eadfa40fc

De update matchte op follow_id en raakte dus niets. De rij bleef eeuwig op
'pending' en er kwam nooit iets binnen -- terwijl de logregel doodleuk
'follow accepted' riep. Een stille no-op, en precies daarom viel het pas op
toen de muziek uitbleef.

Twee dingen veranderd:

TERUGVAL raakt het follow-id niets, dan telt het paar dat we wel zeker

weten: (deze site, deze actor), en alleen als die rij nog op
pending staat. De Accept is handtekening-geverifieerd en
actorUri is de ondertekenaar, dus dit kan niets anders openzetten
dan een follow die wij zelf verstuurd hebben.

EERLIJK de logregel zegt nu 'accept UNMATCHED' als er niets geraakt is,
LOGGEN met het ontvangen id erbij. Zonder dat was dit onvindbaar.

5 tests, waaronder de Funkwhale-vorm en twee die bewaken dat een vreemde
Accept niet andermans rij kan openzetten.

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

File:

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

src/services/ActivityPubService.js

@@ -2506 +2506 @@
   if (type === 'Accept' && act.object) {
     const fid = typeof act.object === 'string' ? act.object : (act.object && act.object.id);
-    if (fid) { try { fwStmts().acc.run(fid); } catch { /* ignore */ } }
-    console.log('[AP] follow accepted', actorUri);
+    let raak = 0;
+    if (fid) { try { raak = fwStmts().acc.run(fid).changes; } catch { /* ignore */ } }
+    // TERUGVAL, en die is nodig gebleken tegen Funkwhale. Een Accept hoort de
+    // Follow terug te geven die hij beantwoordt, maar Funkwhale verzint er een
+    // EIGEN id voor, in ONZE namespace:
+    //
+    //   wij stuurden   .../ap/users/dev#follow-1786161977286-bb2de32f
+    //   Funkwhale zegt .../ap/users/dev#follows/19fd8b00-8f66-...
+    //
+    // Matchen op follow_id raakt dan niets, en de volgrelatie bleef eeuwig op
+    // 'pending' staan terwijl de logregel 'accepted' riep -- een stille no-op
+    // die pas opviel toen er nooit iets binnenkwam.
+    //
+    // Het paar dat we WEL zeker weten is (deze site, deze actor): de Accept is
+    // handtekening-geverifieerd, en actorUri is de ondertekenaar. Alleen een
+    // rij die nog op pending staat wordt geraakt, dus dit kan niets anders
+    // openzetten dan een follow die wij zelf hebben verstuurd.
+    if (!raak && slugParam && actorUri) {
+      try { raak = fwStmts().accByActor.run(slugParam, actorUri).changes; } catch { /* ignore */ }
+    }
+    // Eerlijk loggen: zonder treffer is er niets geaccepteerd, en dat hoort te
+    // zien te zijn in plaats van als succes voorbij te komen.
+    console.log('[AP] follow', raak ? 'accepted' : 'accept UNMATCHED', actorUri, fid ? '(' + fid + ')' : '');
     // The moment a friendship exists is the moment the history comes along
     // (Robins besluit, 30-7): delivery cannot reach into the past, so the
@@ -3725 +3746 @@
 }
 
-let _insFw, _delFw, _listFw, _accFw, _oneFw, _setAB;
+let _insFw, _delFw, _listFw, _accFw, _accFwByActor, _oneFw, _setAB;
 function fwStmts() {
   if (!_insFw) {
@@ -3732 +3753 @@
     _listFw = db.prepare('SELECT * FROM ap_following WHERE slug = ? ORDER BY created_at DESC');
     _accFw = db.prepare("UPDATE ap_following SET status = 'accepted' WHERE follow_id = ?");
+    // Terugval als de Accept ons follow-id niet teruggeeft (zie de Accept-tak
+    // in handleInbox): dan is het paar dat we WEL zeker weten (deze site, deze
+    // actor) genoeg, mits de rij nog op pending staat.
+    _accFwByActor = db.prepare("UPDATE ap_following SET status = 'accepted' WHERE slug = ? AND actor_uri = ? AND status = 'pending'");
     _oneFw = db.prepare('SELECT * FROM ap_following WHERE slug = ? AND actor_uri = ?');
     _setAB = db.prepare('UPDATE ap_following SET auto_boost = ? WHERE slug = ? AND actor_uri = ?');
   }
-  return { ins: _insFw, del: _delFw, list: _listFw, acc: _accFw, one: _oneFw, setAB: _setAB };
+  return { ins: _insFw, del: _delFw, list: _listFw, acc: _accFw, accByActor: _accFwByActor, one: _oneFw, setAB: _setAB };
 }
 export function listFollowing(slug) { return fwStmts().list.all(slug); }