Changeset df70d8e in Klonkt

Timestamp:

08/08/2026 09:47:27 PM (4 weeks ago)

Author:

roboburr <roboburr@…>

Branches:

main

Children:

1d76e0e

Parents:

f3c7a05

git-author:

Robin <roboburr@…> (08/08/2026 09:47:26 PM)

git-committer:

roboburr <roboburr@…> (08/08/2026 09:47:27 PM)

Message:

Het Offer IS de toestemming van de kandidaat (shaer-6wt)

Uitgezocht, en de fout was van mij. Ik gaf gisteren een "lead" af naar
handshake.js regel 600 -- de inkomende accept-tak die geen fanout doet. Die lead
was onjuist en ik trek hem terug.

Klonkt zegt het met zoveel woorden, en die regel had ik moeten lezen voordat ik
naar zijn code wees:

"The Offer carries the candidate's agreement -- a free ward then commits on

its own accept."

De afsluitende Accept van de kandidaat waar mijn daemon op wachtte, komt bij een
VRIJE ward nooit, en dat hoort ook niet. Dev deed precies wat het moest doen; de
daemon bleef wachten op iets dat het protocol niet stuurt. Dat verklaart ook @mee
meteen: haar Klonkt implementeert dit goed en committeerde op haar eigen ja.

De daemon telt nu echt. Partijen zijn de kandidaat, de ward zelf en de bestaande
guardians uit to; de kandidaat staat er meteen als ja in. Committen als
IEDEREEN ja heeft gezegd -- niet "commit bij mijn eigen ja", want dat werkt voor
de eerste guardian en is stilletjes fout voor de tweede. Wat nog ontbreekt wordt
gelogd, zodat een half afgemaakte handshake zichtbaar is in plaats van stil.

En de telling in offer-many: 202 is hier de NORMALE uitkomst, geen mislukking.
Het scherm zei "verstuurd 0" terwijl alles goed ging, en een verzonnen
mislukking is net zo verwarrend als een verzwegen fout.

RESULTAAT: 100 wards, beide kanten eens, over http met HTTP-signatures en zonder
TLS. Eerste meting van de caseload: 1414 poortrijen in 26 ms, maar de wards-queue
die de apps elke verversing ophalen is 222 KB.

Location:

tools/ward-farm

Files:

• farm.mjs (modified) (4 diffs)
• offer-many.mjs (modified) (1 diff)

tools/ward-farm/farm.mjs

@@ -123 +123 @@
 // juist dit het moment waarop iemand moet nadenken; dat staat er hier expliciet
 // bij zodat deze code nooit ergens anders terechtkomt.
+//
+// HET OFFER IS AL DE TOESTEMMING VAN DE KANDIDAAT, en daar zat mijn fout. Ik
+// wachtte op een afsluitende Accept van de kandidaat, en die komt bij een VRIJE
+// ward nooit -- terecht. Klonkt zegt het met zoveel woorden in handshake.js:
+// "The Offer carries the candidate's agreement -- a free ward then commits on
+// its own accept." Dev deed dus precies wat het hoorde te doen; mijn daemon
+// bleef wachten op iets dat het protocol niet stuurt.
+//
+// De afsluitende Accept van de kandidaat bestaat WEL, maar in het meerpartijen-
+// geval: heeft het kind al guardians, dan moeten die eerst ja zeggen en sluit de
+// kandidaat af. Vandaar de telling hieronder in plaats van "commit bij mijn
+// eigen ja" -- dat laatste zou werken voor de eerste guardian en stilletjes fout
+// zijn voor de tweede.
 
 /**
@@ -139 +152 @@
 }
 
+/**
+ * Een ja bijschrijven, en committen zodra iedereen ja heeft gezegd.
+ *
+ * Dezelfde regel als readyToCommit in Klonkt: de ward, de kandidaat, en -- als
+ * het kind er al had -- minstens een van de bestaande guardians.
+ */
+function telAccept(w, offerId, wie) {
+  const off = w.offers[offerId];
+  if (!off || off.commit) return 'onbekend offer';
+  if (wie && !off.accepts.includes(wie)) off.accepts.push(wie);
+  const iedereen = off.partijen.every((p) => off.accepts.includes(p));
+  if (!iedereen) { noteer(w, { wacht_op: off.partijen.filter((p) => !off.accepts.includes(p)) }); return 'nog niet compleet'; }
+  off.commit = new Date().toISOString();
+  if (!w.guardians.includes(off.kandidaat)) w.guardians.push(off.kandidaat);
+  noteer(w, { commit: off.kandidaat });
+  return 'guardian erbij';
+}
+
 async function verwerkInbox(w, activity) {
   const type = Array.isArray(activity.type) ? activity.type[0] : activity.type;
@@ -151 +182 @@
     if (subject !== uriVan(w.naam)) return 'niet voor mij';
     const kandidaat = typeof o.object === 'string' ? o.object : (o.object && o.object.id);
-    w.offers[activity.id] = { kandidaat, at: Date.now() };
+    // De partijen: de kandidaat, ikzelf, en mijn bestaande guardians (die staan
+    // in `to`). De kandidaat telt meteen als ja -- zijn Offer IS zijn instemming.
+    const partijen = [...new Set([
+      kandidaat,
+      uriVan(w.naam),
+      ...(Array.isArray(activity.to) ? activity.to : []),
+    ])].filter(Boolean);
+    w.offers[activity.id] = { kandidaat, at: Date.now(), partijen, accepts: [kandidaat] };
     bewaarStaat(staat);
     // Accepteren, gericht aan iedereen die in `to` stond plus de kandidaat, zodat
@@ -174 +212 @@
       } catch (e) { noteer(w, { fout: String(e.message), naar: doel }); }
     }
-    bewaarStaat(staat);
+    telAccept(w, activity.id, uriVan(w.naam));
     return 'geaccepteerd';
   }
 
   if (type === 'Accept') {
-    // De laatste Accept van de kandidaat is de commit (3.1.3). Wij houden hem
-    // gewoon bij: wie ons bewaakt is het enige dat wij hoeven te weten.
-    const binnenste = o && o.object;
-    const rel = binnenste && (Array.isArray(binnenste.type) ? binnenste.type[0] : binnenste.type) === 'Relationship'
-      ? binnenste : (relType === 'Relationship' ? o : null);
-    const kandidaat = rel && (typeof rel.object === 'string' ? rel.object : (rel.object && rel.object.id));
-    const wie = kandidaat || actor;
-    if (wie && !w.guardians.includes(wie)) {
-      w.guardians.push(wie);
-      bewaarStaat(staat);
-      return 'guardian erbij';
-    }
-    return 'al bekend';
+    // Een ja van een mede-partij (een bestaande guardian, of de kandidaat die in
+    // het meerpartijengeval afsluit). `object` is de offer-id.
+    const offerId = typeof o === 'string' ? o : (o && o.id);
+    if (!offerId || !w.offers[offerId]) return 'onbekend offer';
+    return telAccept(w, offerId, actor);
   }
 

tools/ward-farm/offer-many.mjs

@@ -69 +69 @@
   try {
     const uit = await AP.ingestOutboxActivity(site, { id: site.owner_id, username: slug }, activity);
-    if (uit && (uit.status === 201 || uit.status === 200)) gestuurd++;
+    // 202 is hier de NORMALE uitkomst: de handshake is aangenomen en loopt, de
+    // commit valt pas als de ward antwoordt. Ik telde hem als mislukt, en de
+    // eindregel zei daardoor "verstuurd 0" terwijl alles goed ging -- een
+    // verzonnen mislukking is net zo verwarrend als een verzwegen fout.
+    if (uit && uit.status >= 200 && uit.status < 300) gestuurd++;
     else { mislukt++; console.warn(`  ${naam}: ${uit && uit.status} ${uit && uit.error}`); }
   } catch (e) {