feat(redis): Comprehensive Redis integration (#177)

src/api/routes/community.js

@@ -12,12 +12,16 @@ import { getConfig } from '../../modules/config.js';
 import { computeLevel } from '../../modules/reputation.js';
 import { REPUTATION_DEFAULTS } from '../../modules/reputationDefaults.js';
 import { cacheGetOrSet, TTL } from '../../utils/cache.js';
-import { rateLimit } from '../middleware/rateLimit.js';
+import { redisRateLimit } from '../middleware/redisRateLimit.js';
 
 const router = Router();
 
 /** Aggressive rate limiter for public endpoints: 30 req/min per IP */
-const communityRateLimit = rateLimit({ windowMs: 60 * 1000, max: 30 });
+const communityRateLimit = redisRateLimit({
+  windowMs: 60 * 1000,
+  max: 30,
+  keyPrefix: 'rl:community',
+});
 router.use(communityRateLimit);
 
 /**

src/api/server.js

@@ -7,7 +7,7 @@ import express from 'express';
 import { error, info, warn } from '../logger.js';
 import { PerformanceMonitor } from '../modules/performanceMonitor.js';
 import apiRouter from './index.js';
-import { rateLimit } from './middleware/rateLimit.js';
+import { redisRateLimit } from './middleware/redisRateLimit.js';
 import { stopAuthCleanup } from './routes/auth.js';
 import { swaggerSpec } from './swagger.js';
 import { stopGuildCacheCleanup } from './utils/discordApi.js';
@@ -17,7 +17,7 @@ import { setupLogStream, stopLogStream } from './ws/logStream.js';
 /** @type {import('node:http').Server | null} */
 let server = null;
 
-/** @type {ReturnType<typeof rateLimit> | null} */
+/** @type {ReturnType<typeof redisRateLimit> | null} */
 let rateLimiter = null;
 
 /**
@@ -64,7 +64,7 @@ export function createApp(client, dbPool) {
     rateLimiter.destroy();
     rateLimiter = null;
   }
-  rateLimiter = rateLimit();
+  rateLimiter = redisRateLimit();
   app.use(rateLimiter);
 
   // Raw OpenAPI spec (JSON) — public for Mintlify

src/commands/leaderboard.js

@@ -9,6 +9,7 @@ import { EmbedBuilder, SlashCommandBuilder } from 'discord.js';
 import { getPool } from '../db.js';
 import { error as logError } from '../logger.js';
 import { getConfig } from '../modules/config.js';
+import { getLeaderboardCached } from '../utils/reputationCache.js';
 import { safeEditReply } from '../utils/safeSend.js';
 
 export const data = new SlashCommandBuilder()
@@ -30,14 +31,17 @@ export async function execute(interaction) {
 
   try {
     const pool = getPool();
-    const { rows } = await pool.query(
-      `SELECT user_id, xp, level
-     FROM reputation
-     WHERE guild_id = $1
-     ORDER BY xp DESC
-     LIMIT 10`,
-      [interaction.guildId],
-    );
+    const rows = await getLeaderboardCached(interaction.guildId, async () => {
+      const result = await pool.query(
+        `SELECT user_id, xp, level
+       FROM reputation
+       WHERE guild_id = $1
+       ORDER BY xp DESC
+       LIMIT 10`,
+        [interaction.guildId],
+      );
+      return result.rows;
+    });
 
     if (rows.length === 0) {
       await safeEditReply(interaction, {

src/commands/rank.js

@@ -11,6 +11,11 @@ import { error as logError } from '../logger.js';
 import { getConfig } from '../modules/config.js';
 import { buildProgressBar, computeLevel } from '../modules/reputation.js';
 import { REPUTATION_DEFAULTS } from '../modules/reputationDefaults.js';
+import {
+  getRankCached,
+  getReputationCached,
+  setReputationCache,
+} from '../utils/reputationCache.js';
 import { safeEditReply } from '../utils/safeSend.js';
 
 export const data = new SlashCommandBuilder()
@@ -43,15 +48,23 @@ export async function execute(interaction) {
     const repCfg = { ...REPUTATION_DEFAULTS, ...cfg.reputation };
     const thresholds = repCfg.levelThresholds;
 
-    // Fetch reputation row
-    const { rows } = await pool.query(
-      'SELECT xp, level, messages_count FROM reputation WHERE guild_id = $1 AND user_id = $2',
-      [interaction.guildId, target.id],
-    );
+    // Fetch reputation row (cached)
+    const cachedRep = await getReputationCached(interaction.guildId, target.id);
+    let repRow = cachedRep;
+    if (!repRow) {
+      const { rows } = await pool.query(
+        'SELECT xp, level, messages_count FROM reputation WHERE guild_id = $1 AND user_id = $2',
+        [interaction.guildId, target.id],
+      );
+      repRow = rows[0] ?? null;
+      if (repRow) {
+        await setReputationCache(interaction.guildId, target.id, repRow);
+      }
+    }
 
-    const xp = rows[0]?.xp ?? 0;
+    const xp = repRow?.xp ?? 0;
     const level = computeLevel(xp, thresholds);
-    const messagesCount = rows[0]?.messages_count ?? 0;
+    const messagesCount = repRow?.messages_count ?? 0;
 
     // XP within current level and needed for next
     const currentThreshold = level > 0 ? thresholds[level - 1] : 0;
@@ -62,14 +75,16 @@ export async function execute(interaction) {
     const progressBar =
       nextThreshold !== null ? buildProgressBar(xpInLevel, xpNeeded) : `${'▓'.repeat(10)} MAX`;
 
-    // Rank position in guild
-    const rankRow = await pool.query(
-      `SELECT COUNT(*) + 1 AS rank
-     FROM reputation
-     WHERE guild_id = $1 AND xp > $2`,
-      [interaction.guildId, xp],
-    );
-    const rank = Number(rankRow.rows[0]?.rank ?? 1);
+    // Rank position in guild (cached)
+    const rank = await getRankCached(interaction.guildId, target.id, async () => {
+      const rankRow = await pool.query(
+        `SELECT COUNT(*) + 1 AS rank
+       FROM reputation
+       WHERE guild_id = $1 AND xp > $2`,
+        [interaction.guildId, xp],
+      );
+      return { rank: Number(rankRow.rows[0]?.rank ?? 1) };
+    }).then((r) => r?.rank ?? 1);
 
     const levelLabel = `Level ${level}`;
     const xpLabel = nextThreshold !== null ? `${xp} / ${nextThreshold} XP` : `${xp} XP (Max Level)`;

src/commands/review.js

@@ -15,6 +15,7 @@ import {
   STATUS_LABELS,
   updateReviewMessage,
 } from '../modules/reviewHandler.js';
+import { fetchChannelCached } from '../utils/discordCache.js';
 import { safeEditReply } from '../utils/safeSend.js';
 
 export const data = new SlashCommandBuilder()
@@ -159,10 +160,10 @@ async function handleRequest(interaction, pool, guildConfig) {
   let targetChannel = interaction.channel;
 
   if (reviewChannelId && reviewChannelId !== interaction.channelId) {
-    try {
-      const fetched = await interaction.client.channels.fetch(reviewChannelId);
-      if (fetched) targetChannel = fetched;
-    } catch {
+    const fetched = await fetchChannelCached(interaction.client, reviewChannelId);
+    if (fetched) {
+      targetChannel = fetched;
+    } else {
       warn('Review channel not found, using current channel', {
         reviewChannelId,
         guildId: interaction.guildId,

src/commands/welcome.js

@@ -6,6 +6,7 @@ import {
   buildRulesAgreementMessage,
   normalizeWelcomeOnboardingConfig,
 } from '../modules/welcomeOnboarding.js';
+import { fetchChannelCached } from '../utils/discordCache.js';
 import { isModerator } from '../utils/permissions.js';
 import { safeEditReply, safeSend } from '../utils/safeSend.js';
 
@@ -36,9 +37,7 @@ export async function execute(interaction) {
   const resultLines = [];
 
   if (onboarding.rulesChannel) {
-    const rulesChannel =
-      interaction.guild.channels.cache.get(onboarding.rulesChannel) ||
-      (await interaction.guild.channels.fetch(onboarding.rulesChannel).catch(() => null));
+    const rulesChannel = await fetchChannelCached(interaction.client, onboarding.rulesChannel);
 
     if (rulesChannel?.isTextBased?.()) {
       const rulesMsg = buildRulesAgreementMessage();
@@ -53,9 +52,10 @@ export async function execute(interaction) {
 
   const roleMenuMsg = buildRoleMenuMessage(guildConfig?.welcome);
   if (roleMenuMsg && guildConfig?.welcome?.channelId) {
-    const welcomeChannel =
-      interaction.guild.channels.cache.get(guildConfig.welcome.channelId) ||
-      (await interaction.guild.channels.fetch(guildConfig.welcome.channelId).catch(() => null));
+    const welcomeChannel = await fetchChannelCached(
+      interaction.client,
+      guildConfig.welcome.channelId,
+    );
 
     if (welcomeChannel?.isTextBased?.()) {
       await safeSend(welcomeChannel, roleMenuMsg);