Changeset d7526bd in Klonkt

Timestamp:

06/25/2026 05:20:29 AM (3 months ago)

Author:

Robin Genis <roboburr@…>

Branches:

main

Children:

e951b7c

Parents:

5a6a457

Message:

feat(fediverse): NodeInfo 2.1 + per-note replies collection

NodeInfo (/.well-known/nodeinfo + /nodeinfo/2.1) so fediverse tools recognise the
instance (software 'klonkt', user/post counts). Notes now carry a 'replies'
OrderedCollection (/ap/notes/:id/replies) listing inbound + our own reply note
URIs, so remote servers can fetch the whole thread.

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

Location:

src

Files:

• routes/activitypub.js (modified) (2 diffs)
• services/ActivityPubService.js (modified) (2 diffs)

src/routes/activitypub.js

@@ -12 +12 @@
  */
 import express from 'express';
+import { readFileSync } from 'fs';
 import db from '../config/database.js';
 import AP from '../services/ActivityPubService.js';
 
 const router = express.Router();
+let _ver = '1.0.0';
+try { _ver = JSON.parse(readFileSync(new URL('../../package.json', import.meta.url))).version || _ver; } catch { /* keep default */ }
 
 const baseUrl = (req) => (process.env.PUBLIC_BASE_URL || `${req.protocol}://${req.get('host')}`).replace(/\/+$/, '');
@@ -85 +88 @@
 });
 
+// ── Replies collection ── lets remote servers fetch a post's whole thread.
+router.get('/ap/notes/:id/replies', (req, res) => {
+  const base = baseUrl(req);
+  const items = AP.getReplyUris(base, req.params.id);
+  AP.sendAP(res, {
+    '@context': 'https://www.w3.org/ns/activitystreams',
+    id: `${base}/ap/notes/${req.params.id}/replies`,
+    type: 'OrderedCollection',
+    totalItems: items.length,
+    orderedItems: items,
+  });
+});
+
+// ── NodeInfo ── standard instance metadata so fediverse tools recognise Klonkt.
+router.get('/.well-known/nodeinfo', (req, res) => {
+  res.type('application/json');
+  res.set('Cache-Control', 'public, max-age=3600');
+  res.send(JSON.stringify({ links: [{ rel: 'http://nodeinfo.diaspora.software/ns/schema/2.1', href: `${baseUrl(req)}/nodeinfo/2.1` }] }));
+});
+router.get('/nodeinfo/2.1', (req, res) => {
+  let users = 0; let posts = 0;
+  try { users = db.prepare('SELECT COUNT(*) c FROM users').get().c; } catch { /* */ }
+  try { posts = db.prepare("SELECT COUNT(*) c FROM posts WHERE status = 'published'").get().c; } catch { /* */ }
+  res.type('application/json; charset=utf-8');
+  res.set('Cache-Control', 'public, max-age=600');
+  res.send(JSON.stringify({
+    version: '2.1',
+    software: { name: 'klonkt', version: _ver, repository: 'https://github.com/roboburr/klonkt' },
+    protocols: ['activitypub'],
+    services: { inbound: [], outbound: [] },
+    openRegistrations: false,
+    usage: { users: { total: users }, localPosts: posts },
+    metadata: { nodeName: 'Klonkt' },
+  }));
+});
+
 // ── Inbox — Follow→Accept, Undo Follow (best-effort signature verify) ──
 const apJson = express.json({

src/services/ActivityPubService.js

@@ -153 +153 @@
     cc: [`${aId}/followers`],
     tag: Array.isArray(post.tags) ? post.tags.map((t) => ({ type: 'Hashtag', name: '#' + String(t).replace(/\s+/g, '') })) : [],
+    replies: `${id}/replies`,
   };
   if (attachment.length) note.attachment = attachment;
   return note;
+}
+
+// All reply note URIs on a local post (inbound fediverse replies + our own
+// outbound replies) — backs the Note's `replies` Collection so remote servers
+// can fetch the whole thread.
+export function getReplyUris(base, postId) {
+  const out = [];
+  try {
+    for (const r of db.prepare("SELECT object_uri FROM ap_interactions WHERE kind = 'reply' AND post_id = ? AND object_uri != '' ORDER BY created_at").all(postId)) out.push(r.object_uri);
+    for (const r of db.prepare('SELECT id FROM ap_outbox WHERE post_id = ? ORDER BY rowid').all(postId)) out.push(`${base}/ap/notes/${r.id}`);
+  } catch { /* non-fatal */ }
+  return out;
 }
 
@@ -906 +919 @@
   getNotifications, listBlocks, isBlockedAny, blockTarget, unblock,
   deliverWithRetry, enqueueDelivery, processDeliveryQueue, startDeliveryWorker,
+  getReplyUris,
 };