Changeset f1e0c1f in Klonkt

Timestamp:

06/25/2026 07:08:31 AM (3 months ago)

Author:

Robin Genis <roboburr@…>

Branches:

main

Children:

5085b1d

Parents:

75bda38

Message:

fediverse: push actor Update on pin/unpin so Mastodon refreshes the featured collection

Mastodon only re-fetches an actor's featured (pinned) collection on actor refresh, and
there is no 'featured changed' activity. deliverActorUpdate sends Update(Person) to
followers; /save fires it when a post's pin rank changes → pins propagate promptly.

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

Location:

src

Files:

• routes/posts.js (modified) (1 diff)
• services/ActivityPubService.js (modified) (2 diffs)

src/routes/posts.js

@@ -365 +365 @@
     if (post.status !== 'published') ActivityPubService.deliverCreate(site, apPost).catch(() => { /* best-effort */ });
     else ActivityPubService.deliverUpdate(site, apPost).catch(() => { /* best-effort */ });
+  }
+
+  // Pin/unpin changed → push an actor Update so Mastodon re-fetches the featured
+  // (pinned) collection promptly instead of waiting for its own actor refresh.
+  if ((post.pinned || 0) !== parsePinnedRank(pinned)) {
+    ActivityPubService.deliverActorUpdate(site).catch(() => { /* best-effort */ });
   }
 

src/services/ActivityPubService.js

@@ -651 +651 @@
     type: 'Update', actor: me, to: [PUBLIC], cc: [`${me}/followers`],
     object: note,
+  };
+  for (const inbox of inboxes) deliverWithRetry(site.slug, inbox, update, `${me}#main-key`, keys.private_pem);
+}
+
+// Tell followers the ACTOR changed (Update + Person) so Mastodon re-processes the
+// account AND re-fetches the featured (pinned) collection — there is no standard
+// "featured changed" activity, so this is how a pin/unpin propagates promptly.
+export async function deliverActorUpdate(site) {
+  const base = (process.env.PUBLIC_BASE_URL || '').replace(/\/+$/, '');
+  if (!base || !site || !site.slug) return;
+  const followers = fStmts().list.all(site.slug);
+  if (!followers.length) return;
+  const inboxes = [...new Set(followers.map((f) => f.shared_inbox || f.inbox).filter(Boolean))];
+  const keys = getOrCreateKeys(site.slug);
+  const me = actorId(base, site.slug);
+  const update = {
+    '@context': ['https://www.w3.org/ns/activitystreams', 'https://w3id.org/security/v1'],
+    id: `${me}#update-${Date.now()}`,
+    type: 'Update', actor: me, to: [PUBLIC], cc: [`${me}/followers`],
+    object: buildActor(base, site),
   };
   for (const inbox of inboxes) deliverWithRetry(site.slug, inbox, update, `${me}#main-key`, keys.private_pem);
@@ -985 +1005 @@
   getOrCreateKeys, apWants, sendAP, actorId, noteId,
   buildActor, buildNote, buildCreate, buildOutbox, buildFollowers, buildFeatured,
-  followerCount, deliver, fetchActor, verifyRequest, handleInbox, deliverCreate, deliverDelete, deliverUpdate,
+  followerCount, deliver, fetchActor, verifyRequest, handleInbox, deliverCreate, deliverDelete, deliverUpdate, deliverActorUpdate,
   getInteractions, getInteractionById, buildReplyNote, getOutboxNote, deliverReply, resolveRemoteNote,
   listOutbox, deliverOutboxDelete,