feat: starboard — showcase popular messages (#48)

config.json

@@ -95,6 +95,14 @@
       "flushIntervalMs": 5000
     }
   },
+  "starboard": {
+    "enabled": false,
+    "channelId": null,
+    "threshold": 3,
+    "emoji": "*",
+    "selfStarAllowed": false,
+    "ignoredChannels": []
+  },
   "permissions": {
     "enabled": true,
     "adminRoleId": null,

migrations/002_starboard-posts.cjs

@@ -0,0 +1,27 @@
+/**
+ * Migration: starboard_posts table
+ *
+ * Tracks which messages have been reposted to the starboard channel,
+ * enabling dedup (update instead of repost) and star-count syncing.
+ */
+
+/** @param {import('node-pg-migrate').MigrationBuilder} pgm */
+exports.up = (pgm) => {
+  pgm.sql(`
+    CREATE TABLE IF NOT EXISTS starboard_posts (
+      id SERIAL PRIMARY KEY,
+      guild_id TEXT NOT NULL,
+      source_message_id TEXT NOT NULL UNIQUE,
+      source_channel_id TEXT NOT NULL,
+      starboard_message_id TEXT NOT NULL,
+      star_count INTEGER NOT NULL DEFAULT 0,
+      created_at TIMESTAMPTZ DEFAULT NOW()
+    )
+  `);
+  // No explicit index needed — UNIQUE constraint on source_message_id creates one implicitly
+};
+
+/** @param {import('node-pg-migrate').MigrationBuilder} pgm */
+exports.down = (pgm) => {
+  pgm.sql('DROP TABLE IF EXISTS starboard_posts CASCADE');
+};

src/index.js

@@ -17,7 +17,7 @@ import './sentry.js';
 import { existsSync, mkdirSync, readFileSync, writeFileSync } from 'node:fs';
 import { dirname, join } from 'node:path';
 import { fileURLToPath } from 'node:url';
-import { Client, Collection, Events, GatewayIntentBits } from 'discord.js';
+import { Client, Collection, Events, GatewayIntentBits, Partials } from 'discord.js';
 import { config as dotenvConfig } from 'dotenv';
 import { startServer, stopServer } from './api/server.js';
 import { closeRedis } from './api/utils/redisClient.js';
@@ -104,7 +104,9 @@ const client = new Client({
     GatewayIntentBits.MessageContent,
     GatewayIntentBits.GuildMembers,
     GatewayIntentBits.GuildVoiceStates,
+    GatewayIntentBits.GuildMessageReactions,
   ],
+  partials: [Partials.Message, Partials.Reaction],
   allowedMentions: { parse: ['users'] },
 });
 

src/modules/events.js

@@ -14,6 +14,7 @@ import { getConfig } from './config.js';
 import { checkLinks } from './linkFilter.js';
 import { checkRateLimit } from './rateLimit.js';
 import { isSpam, sendSpamAlert } from './spam.js';
+import { handleReactionAdd, handleReactionRemove } from './starboard.js';
 import { accumulateMessage, evaluateNow } from './triage.js';
 import { recordCommunityActivity, sendWelcomeMessage } from './welcome.js';
 
@@ -56,6 +57,12 @@ export function registerReadyHandler(client, config, healthMonitor) {
     if (config.moderation?.enabled) {
       info('Moderation enabled');
     }
+    if (config.starboard?.enabled) {
+      info('Starboard enabled', {
+        channelId: config.starboard.channelId,
+        threshold: config.starboard.threshold,
+      });
+    }
   });
 }
 
@@ -214,6 +221,70 @@ export function registerMessageCreateHandler(client, _config, healthMonitor) {
   });
 }
 
+/**
+ * Register reaction event handlers for the starboard feature.
+ * Listens to both MessageReactionAdd and MessageReactionRemove to
+ * post, update, or remove starboard embeds based on star count.
+ *
+ * @param {Client} client - Discord client instance
+ * @param {Object} _config - Unused (kept for API compatibility); handler resolves per-guild config via getConfig().
+ */
+export function registerReactionHandlers(client, _config) {
+  client.on(Events.MessageReactionAdd, async (reaction, user) => {
+    // Ignore bot reactions
+    if (user.bot) return;
+
+    // Fetch partial messages so we have full guild/channel data
+    if (reaction.message.partial) {
+      try {
+        await reaction.message.fetch();
+      } catch {
+        return;
+      }
+    }
+    const guildId = reaction.message.guild?.id;
+    if (!guildId) return;
+
+    const guildConfig = getConfig(guildId);
+    if (!guildConfig.starboard?.enabled) return;
+
+    try {
+      await handleReactionAdd(reaction, user, client, guildConfig);
+    } catch (err) {
+      logError('Starboard reaction add handler failed', {
+        messageId: reaction.message.id,
+        error: err.message,
+      });
+    }
+  });
+
+  client.on(Events.MessageReactionRemove, async (reaction, user) => {
+    if (user.bot) return;
+
+    if (reaction.message.partial) {
+      try {
+        await reaction.message.fetch();
+      } catch {
+        return;
+      }
+    }
+    const guildId = reaction.message.guild?.id;
+    if (!guildId) return;
+
+    const guildConfig = getConfig(guildId);
+    if (!guildConfig.starboard?.enabled) return;
+
+    try {
+      await handleReactionRemove(reaction, user, client, guildConfig);
+    } catch (err) {
+      logError('Starboard reaction remove handler failed', {
+        messageId: reaction.message.id,
+        error: err.message,
+      });
+    }
+  });
+}
+
 /**
  * Register error event handlers
  * @param {Client} client - Discord client
@@ -241,5 +312,6 @@ export function registerEventHandlers(client, config, healthMonitor) {
   registerReadyHandler(client, config, healthMonitor);
   registerGuildMemberAddHandler(client, config);
   registerMessageCreateHandler(client, config, healthMonitor);
+  registerReactionHandlers(client, config);
   registerErrorHandlers(client);
 }