Changeset 484adf8 in Klonkt for src/services/ActivityPubService.js

Timestamp:

06/26/2026 11:16:45 AM (2 months ago)

Author:

Robin Genis <roboburr@…>

Branches:

main

Children:

5045c30

Parents:

5783c67

Message:

feat(cirkel): featuring is local-only; optional one-time 'boost latest 5'

Per Robin+Bart: featuring an artist = show their posts in your Cirkel (local) — it
no longer auto-Announces every incoming post to the fediverse (that flooded
followers, esp. on the follow backfill). Boosting to the fediverse is now a
deliberate, opt-in 'boost the latest 5' checkbox at follow time (off by default,
one-time). boostLatestN() reads the actor outbox and boosts the 5 newest. Labels
reworked (auto-boost -> Uitgelicht / feature in circle). nl/en/de.

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

File:

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

src/services/ActivityPubService.js

@@ -662 +662 @@
         }
         const media = JSON.stringify(_atts);
+        // "Feature" = show in the Cirkel (local only). We do NOT auto-Announce
+        // incoming posts to the fediverse — that flooded followers (esp. on the
+        // initial backfill). Boosting to the fediverse is a deliberate, one-time
+        // "boost the latest 5" action at feature time (see boostLatestN).
         for (const s of subs) {
           tlStmts().ins.run(o.id, s.slug, actorUri, ai.name, ai.handle, ai.icon, ai.url, html, o.url || null, o.published || null, media);
-          // "Feature an artist": auto-boost (re-Announce) their new posts to our own followers.
-          if (s.auto_boost) sendInteraction({ slug: s.slug }, 'boost', o.id, actorUri).catch(() => { /* best-effort */ });
         }
         console.log('[AP] timeline +', actorUri, 'x' + subs.length);
@@ -1181 +1183 @@
   catch (e) { console.warn('[AP] follow deliver failed:', e.message); }
   console.log('[AP] follow', site.slug, '→', actor.id);
-  return { ok: true, name: ai.name, handle: ai.handle };
+  return { ok: true, name: ai.name, handle: ai.handle, actor: actor.id };
 }
 
@@ -1231 +1233 @@
   console.log('[AP]', type, site.slug, '→', targetNoteId, 'delivered', delivered);
   return { ok: true, delivered };
+}
+
+// One-time "boost the latest N posts" of an account to the fediverse — the
+// deliberate, bounded alternative to auto-boosting every post. Opt-in at feature
+// time so featuring an artist never floods your followers with their whole backlog.
+export async function boostLatestN(site, actorUrl, n = 5) {
+  try {
+    const actor = await fetchActor(actorUrl).catch(() => null);
+    if (!actor || !actor.outbox) return { ok: false, boosted: 0 };
+    const getJson = async (u) => { try { const r = await fetch(u, { headers: { Accept: 'application/activity+json' } }); return r.ok ? await r.json() : null; } catch { return null; } };
+    let coll = await getJson(actor.outbox);
+    let items = (coll && coll.orderedItems) || [];
+    if (!items.length && coll && coll.first) {
+      const page = typeof coll.first === 'string' ? await getJson(coll.first) : coll.first;
+      items = (page && page.orderedItems) || [];
+    }
+    const noteIds = items
+      .filter((it) => it && it.type === 'Create' && it.object)
+      .map((it) => (typeof it.object === 'string' ? it.object : it.object.id))
+      .filter(Boolean)
+      .slice(0, n); // outbox is newest-first → the latest N
+    let boosted = 0;
+    for (const id of noteIds) { try { const r = await sendInteraction(site, 'boost', id, actorUrl); if (r && r.ok) boosted++; } catch { /* best-effort */ } }
+    return { ok: true, boosted };
+  } catch { return { ok: false, boosted: 0 }; }
 }
 
@@ -1319 +1346 @@
   listOutbox, deliverOutboxDelete,
   webfingerResolve, followActor, resolveRemoteActor, unfollowActor, listFollowing, setAutoBoost, getTimeline, sendInteraction,
-  autoBoostCount, getCirkelPosts, getCirkelMembers, autoMigrateCircles, selfHealTimeline,
+  autoBoostCount, getCirkelPosts, getCirkelMembers, autoMigrateCircles, selfHealTimeline, boostLatestN,
   getNotifications, listBlocks, isBlockedAny, blockTarget, unblock,
   deliverWithRetry, enqueueDelivery, processDeliveryQueue, startDeliveryWorker,