Changeset d988fa0 in Klonkt for src/services

Timestamp:

06/24/2026 03:23:01 PM (3 months ago)

Author:

Robin Genis <roboburr@…>

Branches:

main

Children:

00f669b

Parents:

914eb9f

Message:

feat(fediverse-client): like/boost/reply on timeline items

Timeline posts get ⭐ like, 🔁 boost (sendInteraction → signed Like/Announce to
the author + followers) and ↩ reply (reuses the remote-interaction popover).

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

File:

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

src/services/ActivityPubService.js

@@ -714 +714 @@
 }
 
+// Send a Like or Announce (boost) on a remote note FROM this site.
+export async function sendInteraction(site, kind, targetNoteId, authorUri) {
+  const base = (process.env.PUBLIC_BASE_URL || '').replace(/\/+$/, '');
+  if (!base || !site || !site.slug || !targetNoteId) return { error: 'config' };
+  const type = kind === 'boost' ? 'Announce' : 'Like';
+  const me = actorId(base, site.slug);
+  const keys = getOrCreateKeys(site.slug);
+  const act = {
+    '@context': 'https://www.w3.org/ns/activitystreams',
+    id: `${me}#${type.toLowerCase()}-${Date.now()}`,
+    type, actor: me, object: targetNoteId,
+  };
+  if (type === 'Announce') { act.to = [PUBLIC]; act.cc = [`${me}/followers`]; }
+  const inboxes = new Set();
+  if (authorUri) { const a = await fetchActor(authorUri).catch(() => null); if (a) inboxes.add((a.endpoints && a.endpoints.sharedInbox) || a.inbox); }
+  // A boost is public → also deliver to our own followers so it shows for them.
+  if (type === 'Announce') { for (const f of fStmts().list.all(site.slug)) inboxes.add(f.shared_inbox || f.inbox); }
+  let delivered = 0;
+  for (const inbox of [...inboxes].filter(Boolean)) { try { const st = await deliver(inbox, act, `${me}#main-key`, keys.private_pem); if (st >= 200 && st < 300) delivered++; } catch { /* best-effort */ } }
+  console.log('[AP]', type, site.slug, '→', targetNoteId, 'delivered', delivered);
+  return { ok: true, delivered };
+}
+
 export default {
   getOrCreateKeys, apWants, sendAP, actorId, noteId,
@@ -720 +743 @@
   getInteractions, getInteractionById, buildReplyNote, getOutboxNote, deliverReply, resolveRemoteNote,
   listOutbox, deliverOutboxDelete,
-  webfingerResolve, followActor, unfollowActor, listFollowing, getTimeline,
+  webfingerResolve, followActor, unfollowActor, listFollowing, getTimeline, sendInteraction,
 };