Changeset f0a33e1 in Klonkt for src/services/ActivityPubService.js

Timestamp:

08/10/2026 03:32:22 PM (4 weeks ago)

Author:

Robin <roboburr@…>

Branches:

main

Children:

41de7cb

Parents:

3bbf73d

Message:

De wachtende lezing antwoordt met het verschil, als je erom vraagt

shaer-pq4, tweede helft van stap 1. Samentrekken van de twee waiters bespaart
het RONDJE; dit bespaart de VRACHT. Beide paden eindigden tot nu toe in een
volledige inboxlezing -- vier legs van zestig met al hun media-, quote- en
embed-JSON -- voor een enkel nieuw bericht.

Het verschil lag al klaar en werd nooit uitgedeeld: ap_feed_state houdt per
object bij wat er wanneer veranderde, en feedChangesSince had geen enkele
aanroeper. Nu wel, achter ?changes=1.

OPT-IN, en dat is geen franje: een app in het veld stuurt since al mee en
vervangt haar hele feed door wat er terugkomt. Zou since opeens een verschil
betekenen, dan wist die app zichzelf leeg. Een toets bewaakt dat de oude lezing
zonder changes=1 exact hetzelfde blijft.

Het antwoord is een OrderedCollectionPage met partOf, want dat is wat het IS.
Een generieke lezer ziet dat verschil ook.

GRAFSTENEN GAAN MEE. Een verwijdering reisde tot nu toe als AFWEZIGHEID: de
volledige lezing bevatte hem simpelweg niet meer. Juist die volledigheid valt
hier weg, dus zonder Tombstone zou een weggehaalde post voor altijd in de app
blijven staan -- en dat faalt stil. Bart noemde de voorwaarde terecht niet
hard, maar de rijen lagen er al (kind='deleted') en AS2 heeft er een vorm voor.

Om de kaartvorm niet twee keer te beschrijven zijn ook de tijdlijn- en
antwoordvorm uit de handler gehesen (timelineItem/replyItem), net als eerder
messageItem/sentItem. Zelfde gedrag, 855/855 groen.

Co-Authored-By: Claude Opus 5 <noreply@…>

File:

• src/services/ActivityPubService.js (modified) (2 diffs)

src/services/ActivityPubService.js

@@ -4095 +4095 @@
 // everywhere EXCEPT in the other's app (Robins melding, 30-7: "komt niet
 // binnen bij de ander").
+const REPLY_COLUMNS = `
+      i.object_uri, i.actor_uri, i.actor_name, i.actor_handle, i.actor_icon, i.actor_url,
+      i.content, i.published, i.created_at, i.parent_uri, i.post_id,
+      i.emoji_json, i.actor_emoji_json, i.media_json, i.quote_json, i.embed_json`;
+
+/** Dezelfde antwoordrijen, maar op object-uri -- voor de verschil-lezing. */
+export function replyRowsByUri(slug, uris) {
+  const list = (uris || []).filter((u) => typeof u === 'string' && u);
+  if (!list.length) return [];
+  try {
+    const holes = list.map(() => '?').join(',');
+    return db.prepare(`SELECT ${REPLY_COLUMNS} FROM ap_interactions i
+                        JOIN posts p ON p.id = i.post_id
+                        JOIN sites s ON s.id = p.site_id
+                       WHERE s.slug = ? AND i.kind = 'reply' AND i.object_uri IN (${holes})`)
+      .all(slug, ...list);
+  } catch { return []; }
+}
+
+/** Tijdlijnrijen op id, met dezelfde afgeleide liked/boosted als getTimeline. */
+export function timelineRowsByIds(slug, ids) {
+  const list = (ids || []).filter((u) => typeof u === 'string' && u);
+  if (!list.length) return [];
+  try {
+    const holes = list.map(() => '?').join(',');
+    const rows = db.prepare(`SELECT * FROM ap_timeline WHERE slug = ? AND id IN (${holes})`).all(slug, ...list);
+    const reacties = getReactionsFor(slug, rows.map((r) => r.id));
+    for (const r of rows) {
+      const x = reacties.get(r.id);
+      r.liked = !!(x && x.liked);
+      r.boosted = !!(x && x.boosted);
+    }
+    return rows;
+  } catch { return []; }
+}
+
 export function getReplyMessages(slug, limit) {
   try {
     return db.prepare(`
-      SELECT i.object_uri, i.actor_uri, i.actor_name, i.actor_handle, i.actor_icon, i.actor_url,
-             i.content, i.published, i.created_at, i.parent_uri, i.post_id,
-             i.emoji_json, i.actor_emoji_json, i.media_json, i.quote_json, i.embed_json
+      SELECT ${REPLY_COLUMNS}
       FROM ap_interactions i
       JOIN posts p ON p.id = i.post_id
@@ -6391 +6425 @@
   getInteractions, getInteractionById, setInteractionBoosted, setInteractionLiked, buildReplyNote, getOutboxNote, getSentNotes, deliverReply, resolveRemoteNote, noteAudience, mayReadNote,
   listOutbox, deliverOutboxDelete, deliverOutboxUpdate, deliverDirectNote,
-  webfingerResolve, followActor, resolveRemoteActor, unfollowActor, handleMoveInbox, moveAccount, listFollowing, setAutoBoost, backfillFromOutbox, getTimeline, getDirectMessages, messageRowsByUri, conversationHeads, conversationHistory, isoStamp, timelineAttachments, timelineEmojis, timelineObjectLinks, timelineQuote, timelineEmbed, applyQuoteProps, deliverToActor, sendInteraction, voteOnPoll, voteOnRemotePoll,
+  webfingerResolve, followActor, resolveRemoteActor, unfollowActor, handleMoveInbox, moveAccount, listFollowing, setAutoBoost, backfillFromOutbox, getTimeline, timelineRowsByIds, getDirectMessages, messageRowsByUri, replyRowsByUri, conversationHeads, conversationHistory, isoStamp, timelineAttachments, timelineEmojis, timelineObjectLinks, timelineQuote, timelineEmbed, applyQuoteProps, deliverToActor, sendInteraction, voteOnPoll, voteOnRemotePoll,
   acceptGatedFollow, rejectGatedFollow, isWardGuardian, outboxAudience, sendFollowDecision,
   gateOutgoingFollow, performApprovedFollow, recordGuardianEvent, listGuardianEvents, GUARDIAN_EVENT_KEEP,