Changeset 6e9bc70 in Klonkt for src/services

Timestamp:

10/12/2026 04:15:08 PM (2 days ago)

Author:

Bart <bart@…>

Branches:

main

Children:

61d52ed

Parents:

746d98a

Message:

Zachte groepen: een gesprek is de set deelnemers, niet één tegenpartij

Een direct bericht aan Anna en Ben bestond al als groep -- to_actors droeg de
hele set -- maar elke lezing sleutelde op één other. Een uitgaand bericht
aan twee mensen viel in twee gesprekken uiteen, en een binnenkomend bericht
van Anna aan jou en Ben kwam alleen bij Anna terecht: Ben viel eruit, want de
adressering van een binnenkomer werd nergens bewaard.

Nu is er een sleutel, één keer berekend bij het schrijven
(conversation-key.js): voor één ander zijn kale URI, precies zoals het altijd
was, dus bestaande gesprekken, leesmarkeringen en ?with=-URL's blijven geldig
zonder migratie; voor een groep de gesorteerde set, gescheiden door een
spatie. Koppen, geschiedenis, leesmarkeringen en ongelezen lezen hem allemaal
via dezelfde unie, en werken daarmee per gesprek zonder dat er in die queries
iets hoefde te veranderen. Oude rijen hebben geen sleutel en lezen zoals ze
altijd lazen.

Alleen directe berichten groeperen: een openbare post aan jou en Ben is geen
besloten gesprek met z'n drieën.

/messages neemt meer dan één with, en elk item draagt shaer:conversation en
shaer:participants. Uitgaande directe notes krijgen een FEP-7888 context --
die van de ouder als het een antwoord is, anders een nieuwe -- die bewaard en
uitgestuurd wordt, maar geen bubbels samenvoegt: een bubbel die Carla toont
terwijl je antwoord haar niet bereikt, zou liegen over wie meeleest.

shaer-mbji
Co-Authored-By: Claude Opus 5.5 <claude@…>

Location:

src/services

Files:

• ActivityPubService.js (modified) (1 diff)
• ap-inbox.js (modified) (2 diffs)
• ap-timeline.js (modified) (2 diffs)
• conversation-key.js (added)
• guardianship/delivery.js (modified) (3 diffs)

src/services/ActivityPubService.js

@@ -549 +549 @@
       attributedTo: meR,
       inReplyTo: post.in_reply_to || undefined,
+      // FEP-7888 (shaer-mbji): het gesprek waar dit bij hoort, in AS2 dat
+      // andere servers ook lezen. Alleen op wat er een heeft -- oude rijen en
+      // gewone antwoorden blijven precies zoals ze waren.
+      context: post.context || undefined,
       content: post.content,
       // Reply language (rich replies): the AS2 language map next to `content`.

src/services/ap-inbox.js

@@ -30 +30 @@
 import { fwStmts } from './ap-following.js';
 import * as HubInvite from './hub-invite.js';
+import * as ConversationKey from './conversation-key.js';
 
 /**
@@ -852 +853 @@
             // laten voor iedereen die de objectvorm stuurt.
             const ouder = safeUrl(typeof o.inReplyTo === 'string' ? o.inReplyTo : (o.inReplyTo && o.inReplyTo.id)) || null;
-            const r = db.prepare(`INSERT OR IGNORE INTO ap_mentions (slug, object_uri, note_url, actor_uri, actor_name, actor_handle, actor_icon, actor_url, content, published, in_reply_to, help_request, wave, has_guardians, emoji_json, actor_emoji_json, media_json, created_at)
-                                  VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,${NU_ISO})`)
+            // WIE ER NOG MEER BIJ WAS (shaer-mbji). De afzender plus iedere
+            // persoon in to/cc, zonder ons. Zonder dit wist een bericht van
+            // Anna aan jou en Ben niet meer dat Ben erbij was, en kwam het
+            // alleen in het gesprek met Anna terecht.
+            //
+            // ALLEEN VOOR EEN DIRECT BERICHT. Deze tabel draagt ook publieke
+            // posts die ons noemen, en een openbare post aan jou en Ben is geen
+            // besloten gesprek met z'n drieën -- dat zou een groep verzinnen
+            // die niemand begon. Die blijft bij zijn afzender, zoals altijd.
+            const ander = noteVisibility(o) === 'direct'
+              ? ConversationKey.participantsOf(o, actorUri, actorId(base, slug))
+              : [actorUri];
+            const conv = ConversationKey.conversationKey(ander) || actorUri;
+            const r = db.prepare(`INSERT OR IGNORE INTO ap_mentions (slug, object_uri, note_url, actor_uri, actor_name, actor_handle, actor_icon, actor_url, content, published, in_reply_to, help_request, wave, has_guardians, emoji_json, actor_emoji_json, media_json, conv, participants, context, created_at)
+                                  VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,${NU_ISO})`)
               .run(slug, o.id, safeUrl(o.url) || null, actorUri, ai.name, ai.handle, ai.icon, ai.url, html, o.published || null, ouder, help ? 1 : 0, wave ? 1 : 0, hasG ? 1 : 0,
-                extractEmojiTags(o.tag), emojiJsonOf(ai.emojis), mediaFromNote(o));
+                extractEmojiTags(o.tag), emojiJsonOf(ai.emojis), mediaFromNote(o),
+                conv, JSON.stringify(ander), ConversationKey.contextOf(o));
             if (r.changes) {
               // The quote / link-preview card resolves out of band (a remote

src/services/ap-timeline.js

@@ -248 +248 @@
  */
 
+// `other` is hier DE GESPREKSSLEUTEL (shaer-mbji, conversation-key.js), en niet
+// meer per se één persoon. Voor één ander is dat zijn URI, precies zoals
+// altijd; voor een groep de gesorteerde set. De naam van de kolom bleef, want
+// koppen, geschiedenis, leesmarkeringen en ongelezen lezen hem allemaal -- en
+// die werken nu per gesprek in plaats van per persoon zonder dat er een regel
+// in hoefde te veranderen.
+//
+// Oude rijen hebben geen `conv` en lezen zoals ze altijd lazen: een binnenkomer
+// bij zijn afzender, een uitgaande bij elke ontvanger afzonderlijk. Geen
+// migratie die de geschiedenis herschikt; alleen wat nieuw is, groepeert.
 const CONVERSATION_UNION = `
-  SELECT m.actor_uri AS other, ${STEMPEL('COALESCE(m.published, m.created_at)')} AS stamp,
+  SELECT COALESCE(NULLIF(m.conv, ''), m.actor_uri) AS other,
+         ${STEMPEL('COALESCE(m.published, m.created_at)')} AS stamp,
          'in' AS direction, m.object_uri AS ref
     FROM ap_mentions m
    WHERE m.slug = @slug AND m.actor_uri IS NOT NULL AND m.actor_uri <> ''
+  UNION ALL
+  SELECT o.conv AS other, ${STEMPEL('o.created_at')} AS stamp,
+         'out' AS direction, o.id AS ref
+    FROM ap_outbox o
+   WHERE o.site_slug = @slug AND o.visibility = 'direct'
+     AND o.conv IS NOT NULL AND o.conv <> ''
   UNION ALL
   SELECT j.value AS other, ${STEMPEL('o.created_at')} AS stamp,
@@ -259 +276 @@
     JOIN json_each(COALESCE(NULLIF(o.to_actors, ''), json_array(o.to_actor))) j
    WHERE o.site_slug = @slug AND o.visibility = 'direct'
+     AND (o.conv IS NULL OR o.conv = '')
      AND j.value IS NOT NULL AND j.value <> ''`;
 

src/services/guardianship/delivery.js

@@ -14 +14 @@
 import db, { NU_ISO } from '../../config/database.js';
 import { carriesGuardians } from './context.js';
+import * as ConversationKey from '../conversation-key.js';
 
 const PUBLIC = 'https://www.w3.org/ns/activitystreams#Public';
@@ -33 +34 @@
   if (!to.length && !cc.length) return 'public';   // no addressing at all: legacy client, keep old behavior
   return 'direct';
+}
+
+/**
+ * De context (FEP-7888) van het bericht waarop geantwoord wordt, als we die
+ * kennen: uit wat binnenkwam of uit wat we zelf stuurden. Een antwoord hoort in
+ * het gesprek van zijn ouder, en niet in een vers gesprek ernaast.
+ */
+function contextFor(slug, inReplyTo) {
+  if (!inReplyTo) return null;
+  try {
+    const binnen = db.prepare('SELECT context FROM ap_mentions WHERE slug = ? AND object_uri = ? AND context IS NOT NULL')
+      .get(slug, inReplyTo);
+    if (binnen && binnen.context) return binnen.context;
+    // Een eigen note heeft als uri .../ap/notes/<id>; de id is de outbox-sleutel.
+    const eigen = /\/ap\/notes\/([^/?#]+)$/.exec(String(inReplyTo));
+    if (eigen) {
+      const rij = db.prepare('SELECT context FROM ap_outbox WHERE site_slug = ? AND id = ? AND context IS NOT NULL')
+        .get(slug, eigen[1]);
+      if (rij && rij.context) return rij.context;
+    }
+  } catch { /* geen context is ook een antwoord */ }
+  return null;
 }
 
@@ -144 +167 @@
     .map((a) => ({ url: a.url, mediaType: String(a.mediaType), name: String(a.name || '').slice(0, 120) }));
   const id = crypto.randomUUID();
-  db.prepare(`INSERT INTO ap_outbox (id, site_slug, post_id, post_slug, in_reply_to, to_actor, to_handle, content, language, attachments, visibility, to_actors, help_request, wave, away_until, created_at)
-              VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,${NU_ISO})`)
-    .run(id, site.slug, '', null, inReplyTo || null, resolved[0].uri, resolved[0].handle, content, lang, media.length ? JSON.stringify(media) : null, 'direct', JSON.stringify(resolved.map((r) => r.uri)), helpRequest ? 1 : 0, wave ? 1 : 0, awayUntil || null);
+  // Het gesprek waar dit bij hoort (shaer-mbji): de set ontvangers. Aan Anna en
+  // Ben samen is één gesprek, en niet twee die elk de helft dragen.
+  const conv = ConversationKey.conversationKey(resolved.map((r) => r.uri));
+  // FEP-7888: het gesprek een naam geven die andere servers ook lezen. Is dit
+  // een antwoord op iets met een context, dan hoort het in diezelfde; anders
+  // begint hier een nieuwe.
+  const context = contextFor(site.slug, inReplyTo) || `${base}/ap/contexts/${crypto.randomUUID()}`;
+  db.prepare(`INSERT INTO ap_outbox (id, site_slug, post_id, post_slug, in_reply_to, to_actor, to_handle, content, language, attachments, visibility, to_actors, help_request, wave, away_until, conv, context, created_at)
+              VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,${NU_ISO})`)
+    .run(id, site.slug, '', null, inReplyTo || null, resolved[0].uri, resolved[0].handle, content, lang, media.length ? JSON.stringify(media) : null, 'direct', JSON.stringify(resolved.map((r) => r.uri)), helpRequest ? 1 : 0, wave ? 1 : 0, awayUntil || null, conv, context);
   const row = getOutboxRow(id);
   const note = buildReplyNote(base, site, row);