Changeset 55bc7f9 in Klonkt for src/routes/posts.js

Timestamp:

06/24/2026 12:09:08 PM (3 months ago)

Author:

Robin Genis <roboburr@…>

Branches:

main

Children:

3a2c9d3

Parents:

47a0d29

Message:

feat(activitypub): reply back to the fediverse (Phase 4 outbound)

Site owner can reply to an inbound fediverse interaction from the post page. The
reply is sent as a signed Create(Note) with inReplyTo + @Mention to the remote
actor's inbox + our followers, stored in ap_outbox, shown in the thread, and
resolvable at /ap/notes/<id>.

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

File:

• src/routes/posts.js (modified) (4 diffs)

src/routes/posts.js

@@ -7 +7 @@
 import ejs from 'ejs';
 import db from '../config/database.js';
-import { requireAuth } from '../middleware/auth.js';
+import { requireAuth, requireSiteManager } from '../middleware/auth.js';
 import { renderPage } from '../middleware/render.js';
 import { recordPageview, recordPostView } from '../services/StatsService.js';
@@ -749 +749 @@
 
   // Inbound fediverse activity (replies/likes/boosts) for this post.
-  let fediverse = { replies: [], likeCount: 0, announceCount: 0, total: 0 };
+  let fediverse = { replies: [], outReplies: [], likeCount: 0, announceCount: 0, total: 0 };
   try { fediverse = ActivityPubService.getInteractions(post.id); } catch { /* non-fatal */ }
+  // Owner/admin of this site may reply back to a fediverse interaction.
+  const canManageSite = !!(req.session?.user && PermissionsService.canAdminSite(req.session.user, site));
 
   renderPage(req, res, 'pages/post', {
@@ -760 +762 @@
     totalComments,
     fediverse,
+    canManageSite,
     likeCount,
     likedByMe,
@@ -769 +772 @@
 });
 
+// ── Reply back to a fediverse interaction (site owner/admin only) ──
+router.post('/posts/:slug/fedi-reply', requireSiteManager, async (req, res) => {
+  const site = res.locals.site;
+  if (!site) return res.status(404).send('Site required');
+  const post = db.prepare('SELECT id, slug FROM posts WHERE site_id = ? AND slug = ?').get(site.id, req.params.slug);
+  if (!post) return res.status(404).send('Not found');
+  const parent = ActivityPubService.getInteractionById(req.body.interaction_id);
+  const text = (req.body.text || '').toString();
+  if (parent && parent.post_id === post.id && text.trim()) {
+    try {
+      await ActivityPubService.deliverReply(site, { postId: post.id, postSlug: post.slug, parent, text });
+    } catch (e) { console.warn('[AP] reply send failed:', e.message); }
+  }
+  res.redirect(`${res.locals.siteUrlBase || ''}/${post.slug}#fediverse`);
+});
+
 export default router;
 export { postNeighbors };