feat: add clear drops command to wipe WSB messages in channels

src/commands/clearDrops.js

@@ -0,0 +1,72 @@
+const { ChannelType } = require('discord.js');
+const { successEmbed, errorEmbed, warnEmbed } = require('../utils/embeds');
+
+module.exports = {
+    async execute(client, message, args) {
+        // Usage: `clear <channel_id>`
+        const channelIdStr = args[0]?.replace(/[<#>]/g, '');
+        if (!channelIdStr || !/^\d{17,20}$/.test(channelIdStr)) {
+            return message.reply({
+                embeds: [errorEmbed('Invalid Channel', 'Usage: `clear <channel_id>`\nExample: `clear 1234567890` or `clear #resources`')],
+            });
+        }
+
+        const guild = await client.guilds.fetch(process.env.GUILD_ID);
+        const channel = await guild.channels.fetch(channelIdStr).catch(() => null);
+
+        if (!channel || channel.type !== ChannelType.GuildText) {
+            return message.reply({
+                embeds: [errorEmbed('Channel Not Found', 'Could not find a valid text channel with that ID.')],
+            });
+        }
+
+        await message.reply({
+            embeds: [warnEmbed('⏳ Clearing Drops', `Fetching and deleting messages posted by WSB in <#${channel.id}>...\nThis might take a moment.`)],
+        });
+
+        try {
+            let deletedCount = 0;
+            let lastId = null;
+            let fetched;
+
+            // Loop to fetch and delete messages in batches of 100
+            do {
+                const fetchOptions = { limit: 100 };
+                if (lastId) fetchOptions.before = lastId;
+
+                fetched = await channel.messages.fetch(fetchOptions);
+                if (fetched.size === 0) break;
+
+                // Filter for messages sent by the bot
+                const botMessages = fetched.filter(m => m.author.id === client.user.id);
+
+                if (botMessages.size > 0) {
+                    // Bulk delete is faster for messages under 14 days old
+                    // For safety and to handle old messages, we'll delete one by one if bulk fails
+                    try {
+                        await channel.bulkDelete(botMessages, true); // true = filter out 14+ day old ones
+                        deletedCount += botMessages.size;
+                    } catch (bulkErr) {
+                        console.warn('[Clear] Bulk delete failed or partially failed, falling back to manual deletion');
+                        // Fallback manual deletion for older messages
+                        for (const msg of botMessages.values()) {
+                            await msg.delete().catch(() => { });
+                            deletedCount++;
+                        }
+                    }
+                }
+
+                lastId = fetched.last().id;
+            } while (fetched.size === 100);
+
+            await message.reply({
+                embeds: [successEmbed('✅ Clear Complete', `Successfully deleted **${deletedCount}** WSB messages from <#${channel.id}>.`)],
+            });
+        } catch (err) {
+            console.error('[Clear Error]', err);
+            await message.reply({
+                embeds: [errorEmbed('❌ Clear Failed', `An error occurred while clearing messages: \`${err.message}\``)],
+            });
+        }
+    },
+};

src/events/messageCreate.js

@@ -17,6 +17,7 @@ const postRules = require('../commands/postRules');
 const postDisclaimer = require('../commands/postDisclaimer');
 const applyUpdates = require('../commands/applyUpdates');
 const fixPings = require('../commands/fixPings');
+const clearDrops = require('../commands/clearDrops');
 
 const OWNER_ID = process.env.OWNER_ID;
 
@@ -115,6 +116,12 @@ module.exports = {
             return message.reply({ embeds: [successEmbed('✅ Removed', `User \`${targetId}\` removed from whitelist`)] });
         }
 
+        // Clear Drops
+        if (content.startsWith('clear ')) {
+            const args = content.split(' ').slice(1);
+            return clearDrops.execute(client, message, args);
+        }
+
         if (content === 'whitelist') {
             const all = stmts.getAllWhitelist.all();
             if (all.length === 0) {
@@ -132,7 +139,7 @@ module.exports = {
 
         // Show help
         if (content === 'help') {
-            const allCommands = [...Object.keys(commands), 'drop', 'whitelist', 'whitelist <id> [limit]', 'unwhitelist <id>'];
+            const allCommands = [...Object.keys(commands), 'drop', 'whitelist', 'whitelist <id> [limit]', 'unwhitelist <id>', 'clear <channel_id>'];
             const embed = infoEmbed('WSB Commands', [
                 'All commands are **DM-only** and **Owner-only**.\n',
                 ...allCommands.map(cmd => `\`${cmd}\``),
@@ -147,8 +154,9 @@ module.exports = {
                 content.startsWith('backup') || content.startsWith('shutdown') ||
                 content.startsWith('ticket') || content.startsWith('permission') ||
                 content.startsWith('post') || content.startsWith('drop') ||
-                content.startsWith('apply') || content.startsWith('fix')) {
-                return message.reply({ embeds: [errorEmbed('Unknown Command', `Did you mean one of these?\n${[...Object.keys(commands), 'drop'].map(c => `\`${c}\``).join('\n')}`)] });
+                content.startsWith('apply') || content.startsWith('fix') ||
+                content.startsWith('clear')) {
+                return message.reply({ embeds: [errorEmbed('Unknown Command', `Did you mean one of these?\n${[...Object.keys(commands), 'drop', 'clear <channel_id>'].map(c => `\`${c}\``).join('\n')}`)] });
             }
             return;
         }