Changeset 86e6a45 in Klonkt

Timestamp:

08/08/2026 07:24:44 AM (5 weeks ago)

Author:

roboburr <roboburr@…>

Branches:

main

Children:

a9ede28

Parents:

0b0cd54

git-author:

Robin <roboburr@…> (08/08/2026 07:24:42 AM)

git-committer:

roboburr <roboburr@…> (08/08/2026 07:24:44 AM)

Message:

De apps krijgen de hulpstaat, en kunnen afhandelen (shaer-lgo)

Barts melding: afgehandelde hulpverzoeken blijven zichtbaar in de Shaer
GuardianshipView, en kan het afhandelen daar ook?

DIE TWEE ZIJN HETZELFDE PROBLEEM. De apps lazen hulpvragen uit de FEED -- losse
notes met een helpRequest-vlag -- en kregen de staat helemaal niet. Ze konden dus
niet weten of er al iemand op af was, en dan is een afgehandeld verzoek laten
staan nog het eerlijkste dat een app kan doen. Klonkt bewaarde de staat wel; hij
reisde alleen nergens heen.

Nu een queue help op de actor, met de staat PLAT erin: open, wie hem oppakte,
wie hem afsloot en wanneer. Een app hoeft hem niet af te leiden en kan hem dus
ook niet anders afleiden dan het paneel -- helpItemsFor is een plek, net als
wardGates. Twee berekeningen zouden twee guardians een ander beeld geven van
hetzelfde kind, en bij een reddingsboei is dat het gevaarlijkste dat er mis kan
gaan.

AFHANDELEN HOEFDE GEEN NIEUWE VORM. De markering IS al een gewone directe note
met shaer:helpPickup of shaer:helpHandled, precies zoals de zwaai. De outbox
herkent hem nu, dus de app stuurt letterlijk wat de PWA stuurt en het reist over
dezelfde bezorging naar de mede-guardians. Geen tweede weg.

Wel LOKAAL boeken, en daar staat een toets op: zonder dat zag de guardian die de
knop indrukt zijn eigen markering pas als hij bij zichzelf terugkwam, en die weg
bestaat niet.

Oppikken blijft OPEN. De faalstand hier is "iedereen denkt dat het geregeld is",
en die is gevaarlijker dan geen markering.

De AS2-toets ving dat help nog niet gedeclareerd stond op de actor -- precies
waarvoor die toets er is. Suite 718/718; zonder de lokale boeking valt er een om.

Files:

• src/routes/activitypub.js (modified) (1 diff)
• src/services/ActivityPubService.js (modified) (1 diff)
• src/services/guardianship/index.js (modified) (1 diff)
• src/services/guardianship/queues.js (modified) (3 diffs)
• src/services/guardianship/relations.js (modified) (1 diff)
• test/activitypub-as2.test.js (modified) (1 diff)
• test/help-c2s.test.js (added)

src/routes/activitypub.js

@@ -314 +314 @@
 // guardians' real states here and nowhere else.
 queueRoute('guardians', (id, slug) => Guardianship.guardiansCollection(id, slug));
+// De hulpvragen MET hun staat (5.2.1, shaer-lgo). De apps lazen ze uit de feed
+// en wisten dus niet of er al iemand op af was -- daarom bleef een afgehandeld
+// verzoek daar staan (Barts melding, 8-8).
+queueRoute('help', (id, slug) => Guardianship.helpCollection(id, slug));
 
 // ── Inbox read (owner only, AP C2S) ───────────────────────────────

src/services/ActivityPubService.js

@@ -3344 +3344 @@
           }
           const gateReq = Guardianship.gatereq.parseRequest(object);
-          const r = await deliverDirectNote(site, { recipients, text: plain, language: object.language || null, inReplyTo: typeof object.inReplyTo === 'string' ? object.inReplyTo : null, attachments: atts, helpRequest: help, awayUntil, gateRequest: gateReq && gateReq.feature });
+          // Een hulpvraag oppikken of afsluiten vanuit de app (5.2.1, shaer-lgo).
+          // De markering IS al een gewone directe note met een shaer:-eigenschap,
+          // dus hier hoeft niets nieuws bij: de app stuurt precies wat de PWA
+          // stuurt, en het gaat over dezelfde bezorging naar de mede-guardians.
+          //
+          // We boeken hem ook LOKAAL. Zonder dat zou de guardian die de knop
+          // indrukt zijn eigen markering pas zien als hij bij zichzelf
+          // terugkomt -- en die weg bestaat niet.
+          const mark = Guardianship.help.parseMarker(object);
+          if (mark) {
+            const base2 = (process.env.PUBLIC_BASE_URL || '').replace(/\/+$/, '');
+            Guardianship.help.record(mark.noteUri, actorId(base2, site.slug), mark.kind, `@${site.slug}`);
+          }
+          const r = await deliverDirectNote(site, { recipients, text: plain, language: object.language || null, inReplyTo: typeof object.inReplyTo === 'string' ? object.inReplyTo : null, attachments: atts, helpRequest: help, awayUntil, gateRequest: gateReq && gateReq.feature, helpMark: mark });
           if (!r || !r.id) return { status: 502, error: 'direct_failed' };
           return { status: 201, id: r.id, url: `${base}/ap/notes/${r.id}` };

src/services/guardianship/index.js

@@ -19 +19 @@
 export { wireDelivery, c2sVisibility, deliverDirectNote } from './delivery.js';
 export { wireHandshake, handleOutbox as handleGuardianshipOutbox, handleInbox as handleGuardianshipInbox, parseRelationship, parseUndoRelationship, endGuardianship } from './handshake.js';
-export { offersCollection, followsCollection, outgoingFollowsCollection, wardsCollection, guardiansCollection } from './queues.js';
+export { offersCollection, followsCollection, outgoingFollowsCollection, wardsCollection, guardiansCollection, helpCollection } from './queues.js';
 export * as availability from './availability.js';
 export { wireAvailability } from './availability.js';

src/services/guardianship/queues.js

@@ -16 +16 @@
 import * as gated from './gated.js';
 import * as gatereq from './gatereq.js';
+import * as help from './help.js';
+import db from '../../config/database.js';
 import * as handshake from './handshake.js';
 
@@ -116 +118 @@
 }
 
-export default { offersCollection, followsCollection, outgoingFollowsCollection, wardsCollection, guardiansCollection, wardGates, wardGuardianStatuses };
+export default { offersCollection, followsCollection, outgoingFollowsCollection, wardsCollection, guardiansCollection, helpCollection, helpItemsFor, wardGates, wardGuardianStatuses };
 
 // ── Wat er voor een ward gated is (shaer-ahy.1) ─────────────────────────
@@ -179 +181 @@
   });
 }
+
+
+// ── Hulpvragen met hun staat (shaer-lgo, shaer-ahy.1) ───────────────────
+//
+// De PWA had dit al; de apps kregen alleen de losse notes uit de feed en wisten
+// dus NIET of er al iemand op af was. Daarom bleef een afgehandeld verzoek daar
+// gewoon staan -- Barts melding. De staat wordt hier een keer berekend, zoals bij
+// wardGates: twee berekeningen zouden twee guardians een ander beeld geven van
+// hetzelfde kind.
+
+/** De hulpvragen van deze guardian, met wie erop af is en of het dicht is. */
+export function helpItemsFor(slug, limit = 50) {
+  let rijen = [];
+  try {
+    rijen = db.prepare(
+      `SELECT object_uri, actor_uri, actor_name, actor_handle, actor_icon, content, published, created_at
+       FROM ap_mentions WHERE slug = ? AND help_request = 1 ORDER BY created_at DESC LIMIT ?`,
+    ).all(slug, limit);
+  } catch { return []; }
+  const staat = help.statusFor(rijen.map((r) => r.object_uri));
+  const mijn = new Set(relations.listWards(slug).map((w) => w.other_uri));
+  return rijen.map((r) => ({
+    ...r,
+    // Bij twijfel OPEN. Een hulpvraag die er afgehandeld uitziet terwijl hij dat
+    // niet is, is de gevaarlijke fout -- niet andersom.
+    state: help.withWardship(
+      staat.get(r.object_uri) || { open: true, pickedUpBy: [], handled: null, ageMs: null },
+      mijn.has(r.actor_uri),
+    ),
+  }));
+}
+
+/** Dezelfde vragen als collectie voor de apps (5.2.1). */
+export function helpCollection(id, slug) {
+  const items = helpItemsFor(slug).map((h) => ({
+    id: h.object_uri,
+    type: 'Note',
+    attributedTo: h.actor_uri,
+    'shaer:handle': h.actor_handle || undefined,
+    content: h.content || '',
+    published: h.published || h.created_at,
+    'shaer:helpRequest': true,
+    // De staat als platte velden: een app hoeft hem niet af te leiden, en kan
+    // hem dus ook niet anders afleiden dan het paneel.
+    'shaer:open': h.state.open,
+    'shaer:handledBy': h.state.handled ? (h.state.handled.handle || h.state.handled.uri) : undefined,
+    'shaer:handledAt': h.state.handled ? h.state.handled.at : undefined,
+    'shaer:pickedUpBy': h.state.pickedUpBy.map((p) => p.handle || p.uri),
+    'shaer:formerWard': h.state.formerWard || undefined,
+  }));
+  return collection(id, items);
+}

src/services/guardianship/relations.js

@@ -80 +80 @@
       wards: `${id}/queues/wards`,
       guardians: `${id}/queues/guardians`,
+      help: `${id}/queues/help`,
     },
   };

test/activitypub-as2.test.js

@@ -40 +40 @@
   // `outgoingFollows` is §5.3 turned around: the ward's own follow requests,
   // waiting for the guardians (shaer-p729).
-  'shaer:queues', 'offers', 'follows', 'outgoingFollows', 'wards', 'guardians',
+  // `help` is de vragenlijst met haar STAAT (5.2.1): de apps lazen hulpvragen uit
+  // de feed en wisten niet of er al iemand op af was.
+  'shaer:queues', 'offers', 'follows', 'outgoingFollows', 'wards', 'guardians', 'help',
   // ActivityPub §4.1 `endpoints` vocabulary (same category as sharedInbox), used for C2S.
   'oauthAuthorizationEndpoint', 'oauthTokenEndpoint', 'uploadMedia',