Changeset 731e431 in Klonkt for src/services/ActivityPubService.js

Timestamp:

07/01/2026 07:48:48 AM (2 months ago)

Author:

Robin Genis <roboburr@…>

Branches:

main

Children:

0403187

Parents:

55a73f0

Message:

fix(fediverse): backfillFromOutbox also ingests polls (Question) with poll_json

The outbox catch-up skipped Question objects and never set poll_json, so an
existing poll (posted before you followed, or before poll support shipped)
never appeared even after a re-fetch. Now a Question is accepted like a
Note/Article and its parsed poll is stored (COALESCE preserves an existing vote).

• src/services/ActivityPubService.js — backfillFromOutbox: allow Question + set poll_json

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

File:

• src/services/ActivityPubService.js (modified) (1 diff)

src/services/ActivityPubService.js

@@ -1679 +1679 @@
       const o = (it && typeof it.object === 'object' && it.object) ? it.object : it;
       if (!o || !o.id) continue;
-      if (o.type && o.type !== 'Note' && o.type !== 'Article') continue; // skip boosts/other
+      if (o.type && o.type !== 'Note' && o.type !== 'Article' && o.type !== 'Question') continue; // skip boosts/other
       if (o.inReplyTo) continue;                                          // top-level only
       const auth = actorUriOf(o.attributedTo);
       if (auth && auth !== actorUri) continue;                            // their OWN posts only
       const html = HtmlSanitizerService.sanitize(o.content || '');
+      const poll = parsePoll(o); // a Question (poll) → carry its options/counts on backfill too
       try {
         const r = tlStmts().ins.run(o.id, slug, actorUri, ai.name, ai.handle, ai.icon, ai.url, html, o.url || null, o.published || null, mediaFromNote(o), o.sensitive ? 1 : 0, o.summary || null);
         if (r && r.changes > 0) added++;
+        // Set poll_json if this is a poll and we don't already have it (COALESCE preserves a vote).
+        if (poll) { try { db.prepare('UPDATE ap_timeline SET poll_json = COALESCE(poll_json, ?) WHERE id = ? AND slug = ?').run(JSON.stringify(poll), o.id, slug); } catch { /* ignore */ } }
       } catch { /* ignore */ }
     }