Changeset f63cbc2 in Klonkt for src/services/CircleFederation.js

Timestamp:

06/16/2026 06:33:38 AM (3 months ago)

Author:

roboburr <roboburr@…>

Branches:

main

Children:

4fee228

Parents:

1b4d5dd

Message:

Circles: protocol version enforced via signature binding (update enforcement)

KLONKT_PROTO is now part of the signed basis (signingInput:
"klonkt/proto/N\n"+body). An instance on a different proto cannot verify
the signed outbox and vice versa → staying up to date is cryptographically
enforced, not a patchable check. Both sides verify the proto
(actor.klonkt.proto + Klonkt-Proto header → 426); too-old/too-new sources
are excluded with status 'outdated' + a clear message. Couple security to
every proto bump. Proto starts at 2; roll out in lockstep.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@…>

File:

• src/services/CircleFederation.js (modified) (5 diffs)

src/services/CircleFederation.js

@@ -15 +15 @@
 import db from '../config/database.js';
 import { getSetting, setSetting } from './SettingsService.js';
+
+// ── Protocol-versie (federatie) ───────────────────────────────
+// KLONKT_PROTO zit IN de ondertekende grondslag (zie signingInput): een instance
+// die niet op deze proto draait kan onze getekende outbox NIET verifiëren, en wij
+// de hare niet. Bijblijven is dus geen beleefde check die je wegpatcht, maar
+// cryptografisch afgedwongen — de enige manier om mee te doen is dezelfde proto
+// draaien (= de update). Bump KLONKT_PROTO bij elke release die federatie/security
+// raakt, en koppel een securityfix aan elke bump → outdated = buiten + onveilig.
+// MIN_PROTO = de laagste proto waarmee we nog federeren.
+export const KLONKT_PROTO = 2;
+export const MIN_PROTO = 2;
+
+function signingInput(proto, body) {
+  return `klonkt/proto/${proto}\n${body}`;
+}
 
 // ── Sleutelbeheer ─────────────────────────────────────────────
@@ -37 +52 @@
 }
 
-/** Tekent een exacte body-string met de instance-privésleutel (Ed25519). */
-export function signBody(rawString) {
+/** Tekent een body-string, gebonden aan de protocol-versie (Ed25519). */
+export function signBody(rawString, proto = KLONKT_PROTO) {
   const key = crypto.createPrivateKey(getKeys().priv);
-  return crypto.sign(null, Buffer.from(rawString, 'utf8'), key).toString('base64');
+  return crypto.sign(null, Buffer.from(signingInput(proto, rawString), 'utf8'), key).toString('base64');
 }
 
-/** Verifieert een body tegen een SPKI-DER-base64 publieke sleutel (voor sync/tests). */
-export function verifyBody(rawString, sigB64, pubDerB64) {
+/** Verifieert een body tegen een SPKI-DER-base64 publieke sleutel, voor de gegeven
+ *  proto. Een mismatch in proto = mismatch in grondslag = ongeldige handtekening. */
+export function verifyBody(rawString, sigB64, pubDerB64, proto = KLONKT_PROTO) {
   try {
     const key = crypto.createPublicKey({
       key: Buffer.from(pubDerB64, 'base64'), format: 'der', type: 'spki',
     });
-    return crypto.verify(null, Buffer.from(rawString, 'utf8'), key, Buffer.from(sigB64, 'base64'));
+    return crypto.verify(null, Buffer.from(signingInput(proto, rawString), 'utf8'), key, Buffer.from(sigB64, 'base64'));
   } catch {
     return false;
@@ -101 +117 @@
       publicKeyBase64: getPublicKeyB64(),
     },
-    klonkt: { version: 1, allowCircle: allowsCircle(site) },
+    klonkt: { version: 1, proto: KLONKT_PROTO, allowCircle: allowsCircle(site) },
   };
 }
@@ -111 +127 @@
   const empty = {
     '@context': 'https://www.w3.org/ns/activitystreams',
-    type: 'OrderedCollection', id, totalItems: 0, orderedItems: [],
+    type: 'OrderedCollection', id, totalItems: 0, orderedItems: [], klonkt: { proto: KLONKT_PROTO },
   };
   if (!allowsCircle(site)) return empty;
@@ -148 +164 @@
     '@context': 'https://www.w3.org/ns/activitystreams',
     type: 'OrderedCollection', id, totalItems: orderedItems.length, orderedItems,
+    klonkt: { proto: KLONKT_PROTO },
   };
 }