Changeset 5a6a457 in Klonkt for src/services/Scheduler.js

Timestamp:

06/25/2026 05:15:48 AM (3 months ago)

Author:

Robin Genis <roboburr@…>

Branches:

main

Children:

d7526bd

Parents:

99234c3

Message:

feat(fediverse): federate on save+scheduler, delivery retry-queue, music as listen-link

#1 Posts now federate to followers not only on create, but also when a draft/

scheduled post becomes published (editor save) and when the Scheduler flips a
scheduled post live — previously those silently didn't reach followers.

#2 Delivery retry-queue (ap_delivery): a failed delivery (down server/timeout) is

queued and retried with backoff (1/5/15/60/180/360 min, 6 tries) by a worker,
instead of fire-and-forget. Signing key re-derived from the slug, never stored.

#3 Music posts: audio shortcodes federate as a '🎵 listen on the site' link to the

post (protected player) instead of the raw mp3 — keeps Klonkt's audio friction
intact (no downloadable file handed to Mastodon).

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

File:

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

src/services/Scheduler.js

@@ -10 +10 @@
 import db from '../config/database.js';
 import HtmlSanitizerService from './HtmlSanitizerService.js';
+import ActivityPubService from './ActivityPubService.js';
 
 export function flipScheduledPosts() {
   try {
     const due = db.prepare(`
-      SELECT p.id, p.title, p.content, u.username
+      SELECT p.id, p.site_id, p.slug, p.title, p.content, p.cover_image_url, p.fan_only,
+             p.published_at, p.publish_at, p.created_at, u.username
       FROM posts p JOIN users u ON u.id = p.author_id
       WHERE p.status = 'scheduled' AND p.publish_at IS NOT NULL AND datetime(p.publish_at) <= datetime('now')
@@ -23 +25 @@
     );
     const fts = db.prepare('INSERT INTO posts_fts(content, title, author, post_id) VALUES (?, ?, ?, ?)');
+    const siteStmt = db.prepare('SELECT * FROM sites WHERE id = ?');
     for (const p of due) {
       upd.run(p.id);
       try { fts.run(HtmlSanitizerService.toPlainText(p.content || ''), p.title || '', p.username || '', p.id); } catch { /* FTS failure is non-fatal */ }
+      // ActivityPub: federate the now-published post to followers.
+      if (!p.fan_only) {
+        try {
+          const site = siteStmt.get(p.site_id);
+          if (site) {
+            ActivityPubService.deliverCreate(site, {
+              id: p.id, slug: p.slug, title: p.title || p.slug,
+              content: p.content, cover_image_url: p.cover_image_url || null,
+              published_at: p.published_at || p.publish_at, created_at: p.created_at,
+            }).catch(() => { /* best-effort */ });
+          }
+        } catch { /* non-fatal */ }
+      }
     }
     return due.length;