Changeset 7d932ce in Klonkt for src/routes

Timestamp:

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

Author:

Robin Genis <roboburr@…>

Branches:

main

Children:

a885afc

Parents:

cc24fa1

Message:

feat(activitypub): nested threading + delete your own replies

Inbox now stores replies-to-comments nested (findThreadTarget resolves the post
via the parent comment); getInteractions builds a thread tree shown on the post
(fedi-node partial). deliverReply also cc's the post author's inbox so their
Klonkt threads it. Owners can delete their outbound replies (Delete+Tombstone)
inline + via /fediverse manage list. Schema: ap_interactions.parent_uri.

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

File:

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

src/routes/posts.js

@@ -86 +86 @@
   'tag', 'type', 'user', 'users', 'artiesten', 'leden', 'favorieten', 'feed.xml', 'atom.xml', 'sitemap.xml',
   'manifest.webmanifest', 'sw.js', 'favicon.ico', 'favicon.svg', 'assets',
-  'authorize_interaction',
+  'authorize_interaction', 'fediverse',
 ]);
 
@@ -542 +542 @@
   }
   res.redirect('/authorize_interaction?sent=1&uri=' + encodeURIComponent(uri));
+});
+
+// Manage / delete your own outbound fediverse replies (site owner only).
+router.get('/fediverse', requireSiteManager, (req, res) => {
+  const site = res.locals.site;
+  const items = site ? ActivityPubService.listOutbox(site.slug) : [];
+  renderPage(req, res, 'pages/authorize-interaction', {
+    pageTitle: 'Mijn fediverse-reacties', bodyClass: 'on-special',
+    manage: items, uri: '', target: null, sent: false, siteTitle: site ? site.title : '',
+  });
+});
+
+router.post('/fediverse/:id/delete', requireSiteManager, async (req, res) => {
+  const site = res.locals.site;
+  if (site) {
+    try { await ActivityPubService.deliverOutboxDelete(site, req.params.id); }
+    catch (e) { console.warn('[AP] outbox delete failed:', e.message); }
+  }
+  res.redirect(req.get('Referer') || `${res.locals.siteUrlBase || ''}/fediverse`);
 });
 
@@ -783 +802 @@
     db.prepare('SELECT 1 FROM post_likes WHERE post_id = ? AND user_id = ?').get(post.id, req.session.user.id));
 
-  // Inbound fediverse activity (replies/likes/boosts) for this post.
-  let fediverse = { replies: [], outReplies: [], likeCount: 0, announceCount: 0, total: 0 };
-  try { fediverse = ActivityPubService.getInteractions(post.id); } catch { /* non-fatal */ }
+  // Inbound fediverse activity (threaded) for this post.
+  let fediverse = { thread: [], likeCount: 0, announceCount: 0, total: 0 };
+  try {
+    const _apBase = (process.env.PUBLIC_BASE_URL || `${req.protocol}://${req.get('host')}`).replace(/\/+$/, '');
+    fediverse = ActivityPubService.getInteractions(post.id, _apBase);
+  } 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));