Index: src/services/ActivityPubService.js =================================================================== --- src/services/ActivityPubService.js (revision 44c9f3f0c84f78f0ffcb9f810d8c0724be501de8) +++ src/services/ActivityPubService.js (revision 4c1e327b9d8a84ba2ac7075f7748a6b4a0a171e8) @@ -4902,5 +4902,18 @@ const wardDoc = await fetchActor(wardUri).catch(() => null); const fai = actorInfo(await fetchActor(follower).catch(() => null), follower); - Guardianship.follows.recordReview(gslug, { id: followId, wardUri, wardInbox: wardDoc && wardDoc.inbox, follower, followerHandle: fai.handle, followerIcon: fai.icon, followJson: JSON.stringify(fo) }); + // De RICHTING bewaren (shaer-jdb). shaer:direction wordt sinds de uitgaande + // gate meegestuurd maar werd nergens gelezen, dus een uitgaande belandde + // hier als "deze ward wil deze ward volgen" met het doel weggegooid. + // Terugval voor oudere afzenders: is de volger de ward zelf, dan is het + // uitgaand -- dat volgt uit de vorm en hoeft niet geloofd te worden. + const uitgaand = act['shaer:direction'] === 'outgoing' || follower === wardUri; + const doel = uitgaand ? (typeof fo.object === 'string' ? fo.object : (fo.object && fo.object.id)) : null; + const dai = uitgaand ? actorInfo(await fetchActor(doel).catch(() => null), doel) : null; + Guardianship.follows.recordReview(gslug, { + id: followId, wardUri, wardInbox: wardDoc && wardDoc.inbox, + follower, followerHandle: fai.handle, followerIcon: fai.icon, followJson: JSON.stringify(fo), + direction: uitgaand ? 'outgoing' : 'incoming', + target: doel || null, targetHandle: dai ? dai.handle : null, + }); const L = pushLang(gslug); pushEvent(gslug, { type: 'guardian', title: i18nT(L, 'push.n_guard_cog_t'), body: i18nT(L, 'push.n_guard_cog_b', { who: fai.name || fai.handle || i18nT(L, 'notif.someone') }), url: `${pushPrefix(gslug)}/guardian` }); Index: src/services/guardianship/follows.js =================================================================== --- src/services/guardianship/follows.js (revision 44c9f3f0c84f78f0ffcb9f810d8c0724be501de8) +++ src/services/guardianship/follows.js (revision 4c1e327b9d8a84ba2ac7075f7748a6b4a0a171e8) @@ -81,6 +81,7 @@ _r = { ins: db.prepare(`INSERT OR IGNORE INTO ap_follow_reviews - (id, guardian_slug, ward_uri, ward_inbox, follower_uri, follower_handle, follower_icon, follow_json, created_at) - VALUES (?,?,?,?,?,?,?,?, CURRENT_TIMESTAMP)`), + (id, guardian_slug, ward_uri, ward_inbox, follower_uri, follower_handle, follower_icon, follow_json, + direction, target_uri, target_handle, created_at) + VALUES (?,?,?,?,?,?,?,?,?,?,?, CURRENT_TIMESTAMP)`), get: db.prepare('SELECT * FROM ap_follow_reviews WHERE guardian_slug = ? AND id = ?'), bySlug: db.prepare("SELECT * FROM ap_follow_reviews WHERE guardian_slug = ? AND status = 'pending' ORDER BY created_at DESC"), @@ -91,7 +92,55 @@ } +/** + * De guardian-zijdige kopie van een gate-verzoek op een REMOTE ward. + * + * `direction` is niet cosmetisch (shaer-jdb). Bij een INKOMENDE is de follower + * iemand anders en de ward het doel. Bij een UITGAANDE is de ward zelf de + * follower en staat het doel in het Follow-object -- die werd hiervoor + * opgeslagen als "deze ward wil deze ward volgen", met het doel weggegooid. + */ export function recordReview(guardianSlug, r) { - rstmts().ins.run(r.id, guardianSlug, r.wardUri, r.wardInbox || null, r.follower, r.followerHandle || null, r.followerIcon || null, r.followJson || null); + const richting = r.direction === 'outgoing' ? 'outgoing' : 'incoming'; + rstmts().ins.run(r.id, guardianSlug, r.wardUri, r.wardInbox || null, r.follower, r.followerHandle || null, + r.followerIcon || null, r.followJson || null, richting, r.target || null, r.targetHandle || null); return rstmts().get.get(guardianSlug, r.id); +} + +/** + * Een openstaande review als wachtrij-item, in dezelfde vorm die de clients al + * lezen (offers en outgoing-follows doen het net zo). + */ +export function reviewQueueItem(r, me, guardianCount) { + // guardianCount blijft WEG als we hem niet kennen. Bij een remote ward wordt + // de guardian-set op diens eigen server bijgehouden, en 0 sturen zou lezen als + // "dit kind heeft geen guardians" -- het tegenovergestelde van onbekend. + const stemmen = (() => { + try { return db.prepare('SELECT guardian_uri, decision FROM ap_pending_follow_approvals WHERE follow_id = ?').all(r.id); } + catch { return []; } + })(); + const uitgaand = r.direction === 'outgoing'; + return { + id: r.id, + type: 'Follow', + // Bij een uitgaande is de WARD de volger; bij een inkomende is dat de vreemde. + actor: uitgaand ? r.ward_uri : r.follower_uri, + object: uitgaand ? (r.target_uri || '') : r.ward_uri, + 'shaer:direction': uitgaand ? 'outgoing' : 'incoming', + 'shaer:ward': r.ward_uri, + 'shaer:target': uitgaand ? (r.target_uri || undefined) : undefined, + 'shaer:targetHandle': uitgaand ? (r.target_handle || undefined) : undefined, + 'shaer:follower': uitgaand ? undefined : r.follower_uri, + 'shaer:followerHandle': uitgaand ? undefined : (r.follower_handle || undefined), + 'shaer:quorum': 'all', + 'shaer:approvals': stemmen.filter((x) => x.decision === 'approve').length, + 'shaer:guardianCount': guardianCount || undefined, + 'shaer:myVote': stemmen.some((x) => x.guardian_uri === me), + published: r.created_at, + }; +} + +/** De openstaande reviews van een guardian, per richting. */ +export function listReviewsByDirection(guardianSlug, direction) { + return listReviews(guardianSlug).filter((r) => (r.direction === 'outgoing' ? 'outgoing' : 'incoming') === direction); } export function getReview(guardianSlug, id) { return rstmts().get.get(guardianSlug, id); } @@ -102,3 +151,4 @@ recordPending, getPending, listForWard, decide, remove, recordReview, getReview, listReviews, removeReview, + listReviewsByDirection, reviewQueueItem, }; Index: src/services/guardianship/queues.js =================================================================== --- src/services/guardianship/queues.js (revision 44c9f3f0c84f78f0ffcb9f810d8c0724be501de8) +++ src/services/guardianship/queues.js (revision 4c1e327b9d8a84ba2ac7075f7748a6b4a0a171e8) @@ -6,5 +6,5 @@ * - offers: pending handshake offers where I am a party (§3), with the full * accept tally so the client shows the right action - * - follows: pending gated follows for my wards (§5.3) — Fase 2, empty for now + * - follows: pending gated follows ON my wards (§5.3), Fase 2 (shaer-jdb) * - wards: my committed wards */ @@ -13,4 +13,5 @@ import * as availability from './availability.js'; import * as outgoing from './outgoing.js'; +import * as follows from './follows.js'; import * as handshake from './handshake.js'; @@ -35,12 +36,57 @@ } -/** Gated follows awaiting guardian approval — not built in Klonkt yet (Fase 2). */ -export function followsCollection(id) { - return collection(id, []); +/** + * Gate-verzoeken OP mijn wards die op mijn antwoord wachten (Guardianship Fase 2, + * shaer-jdb). Dit was een lege stub: de gating zelf werkt sinds shaer-hxg, maar + * werd nooit aan een C2S-client doorgegeven omdat de koers toen op de PWA lag. + * + * Twee bronnen, want een guardian kan wards op andere servers hebben en (nog) + * op deze: + * - ap_follow_reviews: de doorgestuurde kopie van een REMOTE ward + * - ap_pending_follows: een ward op deze instance + * Zie shaer-h6u: die tweede hoort op termijn ook over de lijn te gaan. + */ +export function followsCollection(id, slug, me) { + const items = follows.listReviewsByDirection(slug, 'incoming') + .map((r) => follows.reviewQueueItem(r, me)); + for (const w of relations.listWards(slug)) { + const wardSlug = slugOf(w.other_uri); + if (!wardSlug) continue; + for (const p of follows.listForWard(wardSlug)) { + items.push({ + id: p.id, type: 'Follow', actor: p.follower_uri, object: w.other_uri, + 'shaer:direction': 'incoming', 'shaer:ward': w.other_uri, + 'shaer:follower': p.follower_uri, 'shaer:followerHandle': p.follower_handle || undefined, + 'shaer:quorum': p.quorum || 'any', published: p.created_at, + }); + } + } + return collection(id, items); } -/** §5.3 outbound: this ward's own follow requests, waiting for its guardians. */ +/** De slug van een actor-uri op DEZE instance, of null als hij elders woont. */ +function slugOf(uri) { + const base = (process.env.PUBLIC_BASE_URL || '').replace(/\/+$/, ''); + if (!base || !String(uri || '').startsWith(`${base}/ap/users/`)) return null; + return decodeURIComponent(String(uri).slice(`${base}/ap/users/`.length).split(/[/?#]/)[0]) || null; +} + +/** + * §5.3 uitgaand. Twee lezers, een wachtrij, en dat kan omdat §1 een ward en een + * guardian wederzijds uitsluit: je bent het een of het ander. + * + * ALS WARD wat IK wil volgen en waar mijn guardians nog over moeten + * ALS GUARDIAN wat mijn WARDS willen volgen en waar IK over moet (shaer-jdb) + * + * Dat tweede ontbrak. De wachtrij serveerde alleen listForWard(slug), en voor + * een guardian is dat per definitie leeg -- dus het scherm "Your wards want to + * follow" kon nooit iets tonen. + */ export function outgoingFollowsCollection(id, slug, me) { - return collection(id, outgoing.listForWard(slug).map((o) => outgoing.queueItem(o, me))); + const items = outgoing.listForWard(slug).map((o) => outgoing.queueItem(o, me)); + for (const r of follows.listReviewsByDirection(slug, 'outgoing')) { + items.push(follows.reviewQueueItem(r, me)); + } + return collection(id, items); }