Changes in src/routes/posts.js [fb9a8ad:72ec6a4] in Klonkt

File:

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

src/routes/posts.js

@@ -256 +256 @@
 
   renderPage(req, res, 'pages/post-edit', {
-    // post-edit neemt de playlist-editor op.
-    pageJs: 'post-edit playlist-editor',
     post: {
       id: uuid(),
@@ -797 +795 @@
   }
   renderPage(req, res, 'pages/authorize-interaction', {
-    pageJs: 'authorize-interaction',
     pageTitleKey: 'fedi.remote_interact', // i18n: was hardcoded Dutch on non-NL sites
     bodyClass: 'on-special',
@@ -809 +806 @@
     liked: !!req.query.liked,
     boosted: !!req.query.boosted,
-    reacted: (site && uri) ? ActivityPubService.getReaction(site.slug, uri) : { liked: false, boosted: false },
+    reacted: (site && uri) ? ActivityPubService.getMyReactions(site.slug, uri) : { liked: false, boosted: false },
     siteTitle: site ? site.title : '',
   });
@@ -842 +839 @@
   let on = false;
   if (site && uri) {
-    on = !ActivityPubService.getReaction(site.slug, uri).liked;
+    on = !ActivityPubService.getMyReactions(site.slug, uri).liked;
     ActivityPubService.resolveRemoteNote(uri)
       .then((note) => note && ActivityPubService.sendInteraction(site, on ? 'like' : 'unlike', note.object_uri || uri, note.actor_uri))
       .catch((e) => console.warn('[AP] remote like failed:', e.message));
-    // Eén schrijfpad (shaer-9e9): tussentabel + afgeleide vlag.
-    ActivityPubService.setReaction(site.slug, uri, 'like', on);
+    ActivityPubService.setMyReaction(site.slug, uri, 'like', on);
   }
   if (req.get('X-Requested-With') === 'fetch') return res.json({ ok: true, on });
@@ -860 +856 @@
   let on = false;
   if (site && uri) {
-    on = !ActivityPubService.getReaction(site.slug, uri).boosted;
+    on = !ActivityPubService.getMyReactions(site.slug, uri).boosted;
     ActivityPubService.resolveRemoteNote(uri)
       .then((note) => {
@@ -866 +862 @@
         const id = note.object_uri || uri;
         return Promise.resolve(ActivityPubService.sendInteraction(site, on ? 'boost' : 'unboost', id, note.actor_uri))
-          // De note gaat mee: een boost zet niet alleen een vlag maar trekt de
-          // post je tijdlijn in, ook als je de auteur niet volgt, zodat hij in
-          // de Cirkel verschijnt.
-          .then(() => ActivityPubService.setReaction(site.slug, uri, 'boost', on, { flagUri: id, note: on ? note : null }));
+          // Boost → store the post in the timeline (even if you don't follow the author) so it
+          // surfaces in the Cirkel; unboost → just clear the flag.
+          .then(() => on ? ActivityPubService.upsertBoostedNote(site.slug, note) : ActivityPubService.unmarkBoosted(site.slug, id));
       })
       .catch((e) => console.warn('[AP] remote boost failed:', e.message));
-    // Meteen zetten, zodat de knop klopt voordat de resolve terug is. Via
-    // setReaction en niet via setMyReaction: ook dit korte moment mag geen
-    // halve schrijfactie zijn. De resolve hierboven werkt hem daarna bij met de
-    // note, zodat de post ook in je tijdlijn belandt.
-    ActivityPubService.setReaction(site.slug, uri, 'boost', on);
+    ActivityPubService.setMyReaction(site.slug, uri, 'boost', on);
   }
   if (req.get('X-Requested-With') === 'fetch') return res.json({ ok: true, on });
@@ -939 +930 @@
     : []).filter((o) => o['shaer:ward'] === gMe && o['shaer:needsMyAccept']);
   renderPage(req, res, 'pages/messages', {
-    pageTitleKey: 'msg.title', bodyClass: 'on-special', pageJs: 'messages', items, seenAt,
+    pageTitleKey: 'msg.title', bodyClass: 'on-special', items, seenAt,
     hasMore, nextOffset: offset + FEED_PAGE, moreBase, guardianOffers,
     success: req.query.success || null, error: req.query.error || null,
@@ -974 +965 @@
   } catch { /* fall through */ }
   res.redirect(back + '?error=quickreply');
-});
-
-// Antwoorden vanuit een gesprek in Berichten. Twee paden, en welke het wordt
-// bepaalt de draad zelf (zie groupConversations → replyTo):
-//   - hangt de draad aan een post van jou, dan is dit een gewone reply op het
-//     nieuwste ontvangen bericht erin: deliverReply, publiek zoals de thread;
-//   - hangt hij aan een persoon, dan is het een direct bericht terug.
-// Rijk in beide gevallen: `content` is de HTML uit de reply-editor, `text` de
-// platte versie die de editor er altijd bij levert (en die het no-JS-formulier
-// als enige stuurt).
-router.post('/messages/reply', requireSiteManager, async (req, res) => {
-  const site = res.locals.site;
-  const back = `${res.locals.siteUrlBase || ''}/messages`;
-  if (!site) return res.status(404).send('Site required');
-  const text = String(req.body.text || '');
-  const html = String(req.body.content || '');
-  let attachments = [];
-  try { attachments = JSON.parse(req.body.attachments || '[]'); } catch { /* geen media */ }
-  let mentions;
-  try { if (req.body.mentions !== undefined) mentions = JSON.parse(req.body.mentions || '[]'); } catch { mentions = undefined; }
-  const language = String(req.body.language || '');
-  // Leeg is leeg: een bericht zonder tekst EN zonder media is geen bericht.
-  if (!text.trim() && !html.trim() && !attachments.length) return res.redirect(back + '?error=reply_empty');
-
-  const interactionId = parseInt(req.body.interaction_id, 10) || 0;
-  const postSlug = String(req.body.post_slug || '');
-  const toActor = String(req.body.to || '');
-  try {
-    if (interactionId && postSlug) {
-      const post = db.prepare('SELECT id, slug FROM posts WHERE site_id = ? AND slug = ?').get(site.id, postSlug);
-      const parent = ActivityPubService.getInteractionById(interactionId);
-      // De parent MOET bij deze post horen: anders zou een gemanipuleerd
-      // formulier een antwoord onder andermans draad kunnen hangen.
-      if (!post || !parent || parent.post_id !== post.id) return res.redirect(back + '?error=reply_target');
-      await ActivityPubService.deliverReply(site, {
-        postId: post.id, postSlug: post.slug, parent, text, html, attachments, mentions, language,
-      });
-    } else if (/^https?:\/\//i.test(toActor)) {
-      const r = await Guardianship.deliverDirectNote(site, { recipients: [toActor], text, html, language, attachments });
-      if (!r) return res.redirect(back + '?error=reply_failed');
-    } else {
-      return res.redirect(back + '?error=reply_target');
-    }
-  } catch (e) {
-    console.warn('[AP] reply from Berichten failed:', e.message);
-    return res.redirect(back + '?error=reply_failed');
-  }
-  res.redirect(back + '?success=reply_sent');
 });
 
@@ -1196 +1139 @@
   }
   renderPage(req, res, 'pages/news', {
-    pageJs: 'news',
     pageTitle: 'News', bodyClass: 'on-special',
     timeline, hasMore, nextOffset: offset + FEED_PAGE, moreBase,
@@ -1287 +1229 @@
   let on = false;
   if (site && note) {
-    on = !ActivityPubService.getReaction(site.slug, note).liked;
+    on = !ActivityPubService.getTimelineReaction(site.slug, note).liked;
     try { await ActivityPubService.sendInteraction(site, on ? 'like' : 'unlike', note, (req.body.author || '').toString()); } catch (e) { /* ignore */ }
-    ActivityPubService.setReaction(site.slug, note, 'like', on);
+    if (on) ActivityPubService.markLiked(site.slug, note); else ActivityPubService.unmarkLiked(site.slug, note);
   }
   if (req.get('X-Requested-With') === 'fetch') return res.json({ ok: true, on });
@@ -1301 +1243 @@
   let on = false;
   if (site && note) {
-    on = !ActivityPubService.getReaction(site.slug, note).boosted;
+    on = !ActivityPubService.getTimelineReaction(site.slug, note).boosted;
     try { await ActivityPubService.sendInteraction(site, on ? 'boost' : 'unboost', note, (req.body.author || '').toString()); } catch (e) { /* ignore */ }
-    ActivityPubService.setReaction(site.slug, note, 'boost', on); // instant UI state
     if (on) {
+      ActivityPubService.markBoosted(site.slug, note); // instant UI state
       // Fire-and-forget: re-resolve the note so the cached row is refreshed
       // (cover/content) — boosting again heals a stale copy from EVERY boost
       // path, not just the interact page.
       ActivityPubService.resolveRemoteNote(note)
-        .then((n) => { if (n) ActivityPubService.setReaction(site.slug, note, 'boost', true, { note: n }); })
+        .then((n) => { if (n) ActivityPubService.upsertBoostedNote(site.slug, n); })
         .catch(() => { /* best-effort */ });
+    } else {
+      ActivityPubService.unmarkBoosted(site.slug, note);
     }
   }
@@ -1394 +1338 @@
     const { newerPost, olderPost } = postNeighbors(site, post);
     return renderPage(req, res, 'pages/paid-gate', {
-    pageJs: 'paid-gate',
       pageTitle: post.title || 'Voor supporters',
       bodyClass: 'on-special',
@@ -1511 +1454 @@
 
   renderPage(req, res, 'pages/post', {
-    pageJs: 'post',
     post,
     poll: ActivityPubService.ownPollView(post),
@@ -1563 +1505 @@
   const kind = req.body.kind === 'boost' ? 'boost' : 'like';
   if (parent && parent.post_id === post.id && parent.object_uri) {
-    // Toggle: react, or retract it (Undo Announce / Undo Like) if already on.
-    // De stand komt uit dezelfde bron als de knop die je zag; leest de toggle uit
-    // de kolom en de knop uit de tussentabel, dan draait een divergentie de
-    // richting om en stuur je een Undo voor iets dat nooit is verstuurd.
-    const ik = ActivityPubService.getReaction(site.slug, parent.object_uri);
-    const on = kind === 'boost' ? !ik.boosted : !ik.liked;
-    ActivityPubService.sendInteraction(site, on ? kind : `un${kind}`, parent.object_uri, parent.actor_uri)
-      .catch((e) => console.warn('[AP] reaction failed:', e.message));
-    // De tussentabel is de waarheid (shaer-ipb), gesleuteld op object_uri -- net
-    // als de Like die hierboven de fediverse in gaat. acted_* blijft voorlopig
-    // als afgeleide meelopen, hetzelfde vangnet dat ap_timeline.liked na
-    // shaer-9e9 is: pas weghalen als deze migratie een release heeft ingelopen.
-    ActivityPubService.setReaction(site.slug, parent.object_uri, kind, on);
-    if (kind === 'boost') ActivityPubService.setInteractionBoosted(parent.id, on);
-    else ActivityPubService.setInteractionLiked(parent.id, on);
+    if (kind === 'boost') {
+      // Toggle: boost an unboosted comment, or retract it (Undo Announce) if already boosted.
+      const on = !parent.acted_boost;
+      ActivityPubService.sendInteraction(site, on ? 'boost' : 'unboost', parent.object_uri, parent.actor_uri)
+        .catch((e) => console.warn('[AP] reaction failed:', e.message));
+      ActivityPubService.setInteractionBoosted(parent.id, on);
+    } else {
+      // Toggle: like an unliked comment, or un-favourite (Undo Like) if already liked.
+      const on = !parent.acted_like;
+      ActivityPubService.sendInteraction(site, on ? 'like' : 'unlike', parent.object_uri, parent.actor_uri)
+        .catch((e) => console.warn('[AP] reaction failed:', e.message));
+      ActivityPubService.setInteractionLiked(parent.id, on);
+    }
   }
   res.redirect(`${res.locals.siteUrlBase || ''}/${post.slug}#fediverse`);