Update gitignore

.gitignore

@@ -1,2 +1,3 @@
 .env
 node_modules/*
+*.json

commands/autodelete.js

@@ -3,9 +3,60 @@ let deleteQueue = [];
 let isProcessingQueue = false;
 let messageTimers = new Map();
 let ignoredMessages = new Set();
+let ignoredChannels = new Set();
+let ignoredUsers = new Set();
+let ignoredGuilds = new Set();
 let isFirstDeletion = true;
 let deletedMessages = new Set();
 const CACHE_CLEANUP_INTERVAL = 30 * 60 * 1000;
+const { sendCommandResponse } = require('../utils/messageUtils');
+const fs = require('fs');
+const path = require('path');
+
+const DATA_DIR = path.join(__dirname, '..', 'data');
+const IGNORE_FILE = path.join(DATA_DIR, 'autodelete_ignores.json');
+
+if (!fs.existsSync(DATA_DIR)) {
+    try {
+        fs.mkdirSync(DATA_DIR, { recursive: true });
+        console.log('[AUTODELETE] Created data directory');
+    } catch (error) {
+        console.error('[AUTODELETE] Error creating data directory:', error);
+    }
+}
+
+function loadIgnoreLists() {
+    try {
+        if (fs.existsSync(IGNORE_FILE)) {
+            const data = JSON.parse(fs.readFileSync(IGNORE_FILE, 'utf8'));
+            
+            if (data.ignoredChannels) ignoredChannels = new Set(data.ignoredChannels);
+            if (data.ignoredUsers) ignoredUsers = new Set(data.ignoredUsers);
+            if (data.ignoredGuilds) ignoredGuilds = new Set(data.ignoredGuilds);
+            
+            console.log('[AUTODELETE] Loaded ignore lists from file');
+        }
+    } catch (error) {
+        console.error('[AUTODELETE] Error loading ignore lists:', error);
+    }
+}
+
+function saveIgnoreLists() {
+    try {
+        const data = {
+            ignoredChannels: Array.from(ignoredChannels),
+            ignoredUsers: Array.from(ignoredUsers),
+            ignoredGuilds: Array.from(ignoredGuilds)
+        };
+        
+        fs.writeFileSync(IGNORE_FILE, JSON.stringify(data, null, 2), 'utf8');
+        console.log('[AUTODELETE] Saved ignore lists to file');
+    } catch (error) {
+        console.error('[AUTODELETE] Error saving ignore lists:', error);
+    }
+}
+
+loadIgnoreLists();
 
 const DELETION_DELAY = 5 * 60 * 1000;
 let DELETE_INTERVAL_MIN = 8000;
@@ -173,6 +224,33 @@ const handleNewMessage = (message) => {
         return;
     }
     
+    if (message.content.includes('```') && message.content.length > 100) {
+        console.log(`[AUTODELETE] Skipping command response message: ${message.id}`);
+        ignoredMessages.add(message.id);
+        return;
+    }
+    
+    if (message.scheduledForDeletion) {
+        console.log(`[AUTODELETE] Skipping message already scheduled for deletion: ${message.id}`);
+        ignoredMessages.add(message.id);
+        return;
+    }
+
+    if (message.channel && ignoredChannels.has(message.channel.id)) {
+        console.log(`[AUTODELETE] Skipping message in ignored channel: ${message.channel.id}`);
+        return;
+    }
+    
+    if (message.guild && ignoredGuilds.has(message.guild.id)) {
+        console.log(`[AUTODELETE] Skipping message in ignored guild: ${message.guild.id}`);
+        return;
+    }
+    
+    if (!message.guild && message.channel && ignoredUsers.has(message.channel.recipient?.id)) {
+        console.log(`[AUTODELETE] Skipping message to ignored user: ${message.channel.recipient.id}`);
+        return;
+    }
+
     console.log(`[AUTODELETE] New message tracked: ${message.id}`);
     console.log(`[AUTODELETE] Content preview: ${message.content.slice(0, 30)}...`);
 
@@ -198,93 +276,288 @@ module.exports = {
     async execute(message, args, deleteTimeout) {
         ignoredMessages.add(message.id);
 
-        if (args[0]?.toLowerCase() === 'stop') {
-            isAutoDeleteActive = false;
-
-            for (const [messageId, timer] of messageTimers) {
-                clearTimeout(timer);
-                console.log(`[AUTODELETE] Cleared timer for message: ${messageId}`);
+        if (args.length === 0 || args[0].toLowerCase() === 'status') {
+            let ignoreStatus = '';
+            if (ignoredChannels.size > 0 || ignoredGuilds.size > 0 || ignoredUsers.size > 0) {
+                ignoreStatus = `\nIgnored: ${ignoredChannels.size} channels, ${ignoredGuilds.size} servers, ${ignoredUsers.size} users`;
             }
             
-            messageTimers.clear();
-            deleteQueue = [];
-            isProcessingQueue = false;
-            isFirstDeletion = true;
+            const statusText = isAutoDeleteActive
+                ? `Auto-delete is ON - Messages will be deleted after approximately ${Math.round(DELETION_DELAY / 1000 / 60)} minutes.`
+                : 'Auto-delete is OFF.';
 
-            DELETE_INTERVAL_MIN = 8000;
-            DELETE_INTERVAL_MAX = 15000;
-            currentBatchCount = 0;
-
-            console.log('[AUTODELETE] System deactivated - All timers cleared');
-            message.channel.send('Auto-delete has been deactivated.')
-                .then(msg => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
+            await sendCommandResponse(
+                message,
+                `${statusText}\nQueue size: ${deleteQueue.length} messages | Tracked messages: ${messageTimers.size}${ignoreStatus}`,
+                deleteTimeout, 
+                true
+            );
             return;
         }
 
-        if (args[0]?.toLowerCase() === 'delay' && args[1]) {
-            const newDelay = parseInt(args[1], 10);
-            if (!isNaN(newDelay) && newDelay >= 1) {
-                const oldDelay = Math.round(DELETION_DELAY / 1000 / 60);
-                DELETION_DELAY = newDelay * 1000 * 60;
-                message.channel.send(`Auto-delete delay changed from ${oldDelay} to ${newDelay} minutes.`)
-                    .then(msg => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
+        const command = args[0].toLowerCase();
+
+        if (command === 'on' || command === 'start' || command === 'enable') {
+            if (isAutoDeleteActive) {
+                await sendCommandResponse(message, 'Auto-delete is already active.', deleteTimeout, true);
                 return;
-            } else {
-                message.channel.send('Please provide a valid delay in minutes (minimum 1 minute).')
-                    .then(msg => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
-                return;
-            }
             }
 
-        if (args[0]?.toLowerCase() === 'speed') {
-            if (args[1]?.toLowerCase() === 'slow') {
-                DELETE_INTERVAL_MIN = 15000;
-                DELETE_INTERVAL_MAX = 30000;
-                PAUSE_CHANCE = 0.25;
-                message.channel.send('Auto-delete speed set to slow mode (very human-like with frequent pauses).')
-                    .then(msg => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
-                return;
-            } else if (args[1]?.toLowerCase() === 'medium') {
-                DELETE_INTERVAL_MIN = 8000;
-                DELETE_INTERVAL_MAX = 15000;
-                PAUSE_CHANCE = 0.15;
-                message.channel.send('Auto-delete speed set to medium mode (balanced human-like behavior).')
-                    .then(msg => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
-                return;
-            } else if (args[1]?.toLowerCase() === 'fast') {
-                DELETE_INTERVAL_MIN = 5000;
-                DELETE_INTERVAL_MAX = 10000;
-                PAUSE_CHANCE = 0.05;
-                message.channel.send('Auto-delete speed set to fast mode (less human-like but quicker progress).')
-                    .then(msg => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
-                return;
-            } else {
-                message.channel.send('Please specify a valid speed: slow, medium, or fast.')
-                    .then(msg => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
-                return;
-            }
-        }
-
-        if (!isAutoDeleteActive) {
             isAutoDeleteActive = true;
-            isFirstDeletion = true;
-            currentBatchCount = 0;
-            console.log('[AUTODELETE] System activated - Now tracking new messages');
-
-            message.client.removeListener('messageCreate', handleNewMessage);
             message.client.on('messageCreate', handleNewMessage);
 
-            const delayInMinutes = Math.round(DELETION_DELAY / 1000 / 60);
-            message.channel.send(
-                `Auto-delete activated. Messages will be deleted after ~${delayInMinutes} minutes ` +
-                `with human-like timing. Use \`.autodelete speed slow/medium/fast\` to adjust deletion speed.`
-            ).then(msg => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
-        } else {
-            const delayInMinutes = Math.round(DELETION_DELAY / 1000 / 60);
-            message.channel.send(
-                `Auto-delete is already active. Current delay: ~${delayInMinutes} minutes. ` +
-                `Use \`.autodelete speed slow/medium/fast\` to adjust deletion speed.`
-            ).then(msg => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
+            await sendCommandResponse(
+                message,
+                `Auto-delete enabled. Your messages will be deleted after approximately ${Math.round(DELETION_DELAY / 1000 / 60)} minutes.`,
+                deleteTimeout,
+                true
+            );
+            return;
         }
+
+        if (command === 'off' || command === 'stop' || command === 'disable') {
+            if (!isAutoDeleteActive) {
+                await sendCommandResponse(message, 'Auto-delete is not active.', deleteTimeout, true);
+                return;
+            }
+
+            isAutoDeleteActive = false;
+            message.client.off('messageCreate', handleNewMessage);
+
+            for (const timer of messageTimers.values()) {
+                clearTimeout(timer);
+            }
+            messageTimers.clear();
+
+            await sendCommandResponse(message, 'Auto-delete disabled. Messages will no longer be automatically deleted.', deleteTimeout, true);
+            return;
+        }
+
+        if (command === 'clear') {
+            const queueSize = deleteQueue.length;
+            const trackCount = messageTimers.size;
+            
+            deleteQueue = [];
+            for (const timer of messageTimers.values()) {
+                clearTimeout(timer);
+            }
+            messageTimers.clear();
+            currentBatchCount = 0;
+            
+            await sendCommandResponse(message, `Cleared auto-delete queue (${queueSize} pending, ${trackCount} tracked).`, deleteTimeout, true);
+            return;
+        }
+
+        if (command === 'speed') {
+            const speedOption = args[1]?.toLowerCase();
+            
+            if (!speedOption || !['slow', 'normal', 'fast'].includes(speedOption)) {
+                await sendCommandResponse(message, 'Please specify a valid speed: slow, normal, or fast.', deleteTimeout, true);
+                return;
+            }
+            
+            if (speedOption === 'slow') {
+                DELETE_INTERVAL_MIN = 12000;
+                DELETE_INTERVAL_MAX = 25000;
+                JITTER_FACTOR = 0.5;
+                PAUSE_CHANCE = 0.25;
+                PAUSE_LENGTH_MIN = 45000;
+                PAUSE_LENGTH_MAX = 180000;
+                BATCH_SIZE = 2;
+            } else if (speedOption === 'fast') {
+                DELETE_INTERVAL_MIN = 5000;
+                DELETE_INTERVAL_MAX = 10000;
+                JITTER_FACTOR = 0.3;
+                PAUSE_CHANCE = 0.1;
+                PAUSE_LENGTH_MIN = 15000;
+                PAUSE_LENGTH_MAX = 60000;
+                BATCH_SIZE = 5;
+            } else {
+                DELETE_INTERVAL_MIN = 8000;
+                DELETE_INTERVAL_MAX = 15000;
+                JITTER_FACTOR = 0.4;
+                PAUSE_CHANCE = 0.15;
+                PAUSE_LENGTH_MIN = 30000;
+                PAUSE_LENGTH_MAX = 120000;
+                BATCH_SIZE = 3;
+            }
+            
+            await sendCommandResponse(message, `Auto-delete speed set to ${speedOption}.`, deleteTimeout, true);
+            return;
+        }
+
+        if (command === 'ignore') {
+            if (args.length < 2) {
+                await sendCommandResponse(
+                    message,
+                    'Please specify what to ignore. Usage: `.autodelete ignore [channel/server/user] [ID]`',
+                    deleteTimeout,
+                    true
+                );
+                return;
+            }
+            
+            const ignoreType = args[1].toLowerCase();
+            const id = args[2];
+            
+            if (!id || !/^\d{17,19}$/.test(id)) {
+                await sendCommandResponse(
+                    message,
+                    'Please provide a valid ID (channel, server, or user ID).',
+                    deleteTimeout,
+                    true
+                );
+                return;
+            }
+            
+            if (ignoreType === 'channel' || ignoreType === 'c') {
+                ignoredChannels.add(id);
+                saveIgnoreLists();
+                await sendCommandResponse(
+                    message,
+                    `Channel ${id} will now be ignored by auto-delete.`,
+                    deleteTimeout,
+                    true
+                );
+            } else if (ignoreType === 'server' || ignoreType === 'guild' || ignoreType === 's' || ignoreType === 'g') {
+                ignoredGuilds.add(id);
+                saveIgnoreLists();
+                await sendCommandResponse(
+                    message,
+                    `Server ${id} will now be ignored by auto-delete.`,
+                    deleteTimeout,
+                    true
+                );
+            } else if (ignoreType === 'user' || ignoreType === 'u' || ignoreType === 'dm') {
+                ignoredUsers.add(id);
+                saveIgnoreLists();
+                await sendCommandResponse(
+                    message,
+                    `User ${id} (DMs) will now be ignored by auto-delete.`,
+                    deleteTimeout,
+                    true
+                );
+            } else {
+                await sendCommandResponse(
+                    message,
+                    'Invalid ignore type. Use "channel", "server", or "user".',
+                    deleteTimeout,
+                    true
+                );
+            }
+            return;
+        }
+        
+        if (command === 'unignore') {
+            if (args.length < 2) {
+                await sendCommandResponse(
+                    message,
+                    'Please specify what to unignore. Usage: `.autodelete unignore [channel/server/user] [ID]`',
+                    deleteTimeout,
+                    true
+                );
+                return;
+            }
+            
+            const ignoreType = args[1].toLowerCase();
+            const id = args[2];
+            
+            if (!id || !/^\d{17,19}$/.test(id)) {
+                await sendCommandResponse(
+                    message,
+                    'Please provide a valid ID (channel, server, or user ID).',
+                    deleteTimeout,
+                    true
+                );
+                return;
+            }
+            
+            if (ignoreType === 'channel' || ignoreType === 'c') {
+                if (ignoredChannels.has(id)) {
+                    ignoredChannels.delete(id);
+                    saveIgnoreLists();
+                    await sendCommandResponse(
+                        message,
+                        `Channel ${id} will no longer be ignored by auto-delete.`,
+                        deleteTimeout,
+                        true
+                    );
+                } else {
+                    await sendCommandResponse(
+                        message,
+                        `Channel ${id} is not in the ignore list.`,
+                        deleteTimeout,
+                        true
+                    );
+                }
+            } else if (ignoreType === 'server' || ignoreType === 'guild' || ignoreType === 's' || ignoreType === 'g') {
+                if (ignoredGuilds.has(id)) {
+                    ignoredGuilds.delete(id);
+                    saveIgnoreLists();
+                    await sendCommandResponse(
+                        message,
+                        `Server ${id} will no longer be ignored by auto-delete.`,
+                        deleteTimeout,
+                        true
+                    );
+                } else {
+                    await sendCommandResponse(
+                        message,
+                        `Server ${id} is not in the ignore list.`,
+                        deleteTimeout,
+                        true
+                    );
+                }
+            } else if (ignoreType === 'user' || ignoreType === 'u' || ignoreType === 'dm') {
+                if (ignoredUsers.has(id)) {
+                    ignoredUsers.delete(id);
+                    saveIgnoreLists();
+                    await sendCommandResponse(
+                        message,
+                        `User ${id} (DMs) will no longer be ignored by auto-delete.`,
+                        deleteTimeout,
+                        true
+                    );
+                } else {
+                    await sendCommandResponse(
+                        message,
+                        `User ${id} is not in the ignore list.`,
+                        deleteTimeout,
+                        true
+                    );
+                }
+            } else {
+                await sendCommandResponse(
+                    message,
+                    'Invalid ignore type. Use "channel", "server", or "user".',
+                    deleteTimeout,
+                    true
+                );
+            }
+            return;
+        }
+        
+        if (command === 'ignorelist' || command === 'list') {
+            let ignoredChannelsList = Array.from(ignoredChannels).join(', ');
+            let ignoredGuildsList = Array.from(ignoredGuilds).join(', ');
+            let ignoredUsersList = Array.from(ignoredUsers).join(', ');
+            
+            const ignoredInfo = `**Ignored Channels:** ${ignoredChannels.size > 0 ? ignoredChannelsList : 'None'}\n**Ignored Servers:** ${ignoredGuilds.size > 0 ? ignoredGuildsList : 'None'}\n**Ignored Users (DMs):** ${ignoredUsers.size > 0 ? ignoredUsersList : 'None'}`;
+            
+            await sendCommandResponse(
+                message,
+                `**Auto-delete Ignore List**\n\n${ignoredInfo}`,
+                deleteTimeout,
+                true
+            );
+            return;
+        }
+
+        await sendCommandResponse(
+            message,
+            'Unknown command. Valid commands: on, off, status, ignore, unignore, ignorelist',
+            deleteTimeout,
+            true
+        );
     },
 };

commands/delete.js

@@ -1,5 +1,15 @@
 let isDeleting = false;
 let cancelDelete = false;
+let deletedMessages = new Set();
+const CACHE_CLEANUP_INTERVAL = 30 * 60 * 1000;
+const { sendCommandResponse } = require('../utils/messageUtils');
+
+setInterval(() => {
+  if (deletedMessages.size > 1000) {
+    console.log(`[DELETE] Cleaning message cache (size: ${deletedMessages.size})`);
+    deletedMessages.clear();
+  }
+}, CACHE_CLEANUP_INTERVAL);
 
 module.exports = {
   name: 'delete',
@@ -7,135 +17,330 @@ module.exports = {
   async execute(message, args, deleteTimeout) {
     if (args[0] && args[0].toLowerCase() === 'cancel') {
       cancelDelete = true;
-      const cancelMsg = await message.channel.send('Delete operation canceled.');
-      setTimeout(() => cancelMsg.delete().catch(console.error), deleteTimeout);
+      await sendCommandResponse(message, 'Delete operation canceled.', deleteTimeout, true);
       return;
     }
 
     if (isDeleting) {
-      const inProgressMsg = await message.channel.send('A delete operation is already in progress. Please wait or cancel it with `.delete cancel`.');
-      setTimeout(() => inProgressMsg.delete().catch(console.error), deleteTimeout);
+      await sendCommandResponse(message, 'A delete operation is already in progress. Please wait or cancel it with `.delete cancel`.', deleteTimeout, true);
       return;
     }
 
     isDeleting = true;
     cancelDelete = false;
 
+    let speed = 'medium';
+    if (args[0] && ['slow', 'medium', 'fast'].includes(args[0].toLowerCase())) {
+      speed = args[0].toLowerCase();
+      args.shift();
+    }
+
     const deleteCount = parseInt(args[0], 10);
     const targetGuildId = args[1];
 
     if (!isNaN(deleteCount) && deleteCount > 0) {
-      await deleteMessagesFromChannel(message, deleteCount, deleteTimeout);
+      await deleteMessagesFromChannel(message, deleteCount, deleteTimeout, speed);
     } else if (targetGuildId) {
-      await deleteMessagesFromServer(message, targetGuildId, deleteTimeout);
+      await deleteMessagesFromServer(message, targetGuildId, deleteTimeout, speed);
     } else {
-      const errorMsg = await message.channel.send('Please provide a valid number of messages or server ID.');
-      setTimeout(() => errorMsg.delete().catch(console.error), deleteTimeout);
+      await sendCommandResponse(message, 'Please specify how many messages to delete or a server ID. You can also set speed: `.delete [slow/medium/fast] [count/server]`', deleteTimeout, true);
     }
 
     isDeleting = false;
   },
 };
 
-async function deleteMessagesFromChannel(message, deleteCount, deleteTimeout) {
-  const getRandomDelay = () => Math.floor(Math.random() * (3000 - 1000 + 1)) + 1000;
-  const getBatchDelay = () => Math.floor(Math.random() * (10000 - 5000 + 1)) + 5000;
-  const BATCH_SIZE = 10;
+async function deleteMessagesFromChannel(message, deleteCount, deleteTimeout, speed = 'medium') {
+  let deleteIntervalMin, deleteIntervalMax, jitterFactor, pauseChance, pauseLengthMin, pauseLengthMax, batchSize;
+  
+  switch(speed) {
+    case 'slow':
+      deleteIntervalMin = 3000;
+      deleteIntervalMax = 6000;
+      jitterFactor = 0.5;
+      pauseChance = 0.25;
+      pauseLengthMin = 15000;
+      pauseLengthMax = 45000;
+      batchSize = 5;
+      break;
+    case 'fast':
+      deleteIntervalMin = 1500;
+      deleteIntervalMax = 3000;
+      jitterFactor = 0.3;
+      pauseChance = 0.05;
+      pauseLengthMin = 5000;
+      pauseLengthMax = 15000;
+      batchSize = 15;
+      break;
+    case 'medium':
+    default:
+      deleteIntervalMin = 2000;
+      deleteIntervalMax = 4500;
+      jitterFactor = 0.4;
+      pauseChance = 0.15;
+      pauseLengthMin = 10000;
+      pauseLengthMax = 30000;
+      batchSize = 10;
+  }
+  
+  const getHumanlikeDelay = () => {
+    const baseInterval = Math.floor(Math.random() * (deleteIntervalMax - deleteIntervalMin + 1)) + deleteIntervalMin;
+    const jitterAmount = baseInterval * jitterFactor;
+    const jitter = Math.random() * jitterAmount * 2 - jitterAmount;
+    return Math.max(1000, Math.floor(baseInterval + jitter));
+  };
+  
+  const getReadingDelay = () => Math.floor(Math.random() * 3000) + 1000;
 
   try {
-    let remainingMessages = deleteCount;
+    console.log(`[DELETE] Starting deletion of up to ${deleteCount} messages with ${speed} speed`);
+    let deletedCount = 0;
+    let batchCount = 0;
     
-    while (remainingMessages > 0 && !cancelDelete) {
-      const fetchLimit = Math.min(remainingMessages, BATCH_SIZE);
-      const messages = await message.channel.messages.fetch({ limit: fetchLimit + 1 });
+    while (deletedCount < deleteCount && !cancelDelete) {
+      if (deletedCount > 0 && deletedCount % 25 === 0) {
+        console.log(`[DELETE] Progress: ${deletedCount}/${deleteCount} messages deleted`);
+      }
+      
+      const fetchLimit = Math.min(deleteCount - deletedCount, batchSize);
+      const messages = await message.channel.messages.fetch({ limit: 100 });
+      
+      const filteredMessages = messages.filter(msg => 
+        msg.author.id === message.author.id && 
+        !deletedMessages.has(msg.id)
+      );
+      
+      if (filteredMessages.size === 0) {
+        console.log(`[DELETE] No more messages found in this channel`);
+        break;
+      }
+      
+      batchCount++;
+      let messagesInThisBatch = 0;
       
-      const filteredMessages = messages.filter(msg => msg.author.id === message.author.id);
       for (const msg of filteredMessages.values()) {
-        if (cancelDelete) return;
-        try {
-          if (msg.deletable && !msg.deleted) {
-            const delay = getRandomDelay();
-            await new Promise(resolve => setTimeout(resolve, delay));
-            await msg.delete().catch(err => {
-              if (err.code !== 10008) {
-                console.error('Failed to delete message:', err);
-              }
-            });
-          }
-        } catch (error) {
-          console.error('Error deleting message:', error);
-        }
-      }
-
-      remainingMessages -= filteredMessages.size;
-
-      if (remainingMessages > 0 && !cancelDelete) {
-        const batchDelay = getBatchDelay();
-        await new Promise(resolve => setTimeout(resolve, batchDelay));
-      }
-    }
-  } catch (error) {
-    console.error('Failed to delete messages:', error);
-    const errorMsg = await message.channel.send('There was an error while trying to delete messages.');
-    setTimeout(() => errorMsg.delete().catch(console.error), deleteTimeout);
-  }
-}
-
-async function deleteMessagesFromServer(message, guildId, deleteTimeout) {
-  const guild = message.client.guilds.cache.get(guildId);
-
-  if (!guild) {
-    const errorMsg = await message.channel.send('I am not in the server with the specified ID.');
-    setTimeout(() => errorMsg.delete().catch(console.error), deleteTimeout);
+        if (cancelDelete) {
+          console.log(`[DELETE] Operation canceled by user`);
           return;
         }
         
-  const getRandomDelay = () => Math.floor(Math.random() * (3000 - 1000 + 1)) + 1000;
-  const getBatchDelay = () => Math.floor(Math.random() * (10000 - 5000 + 1)) + 5000;
-  const BATCH_SIZE = 10;
+        if (deletedCount >= deleteCount) break;
+        
+        try {
+          if (msg.deletable && !msg.deleted && !deletedMessages.has(msg.id)) {
+            if (Math.random() < 0.25) {
+              const readingDelay = getReadingDelay();
+              console.log(`[DELETE] Taking ${readingDelay}ms to "read" before deleting message ${msg.id}`);
+              await new Promise(resolve => setTimeout(resolve, readingDelay));
+            }
+            
+            const preDeleteDelay = Math.floor(Math.random() * 1000) + 250;
+            await new Promise(resolve => setTimeout(resolve, preDeleteDelay));
+            
+            await msg.delete().catch(err => {
+              if (err.code === 10008) {
+                console.log(`[DELETE] Message ${msg.id} already deleted`);
+                deletedMessages.add(msg.id);
+              } else if (err.code === 429) {
+                console.log(`[DELETE] Rate limited. Taking a longer break...`);
+                return;
+              } else {
+                console.error(`[DELETE] Failed to delete message:`, err);
+              }
+            });
+            
+            deletedMessages.add(msg.id);
+            deletedCount++;
+            messagesInThisBatch++;
+            
+            const delay = getHumanlikeDelay();
+            console.log(`[DELETE] Waiting ${delay}ms before next deletion`);
+            await new Promise(resolve => setTimeout(resolve, delay));
+          }
+        } catch (error) {
+          console.error('[DELETE] Error deleting message:', error);
+        }
+      }
+      
+      if (messagesInThisBatch === 0) {
+        console.log(`[DELETE] No deletable messages found in batch`);
+        break;
+      }
+      
+      if (!cancelDelete && deletedCount < deleteCount) {
+        const adjustedPauseChance = pauseChance * (1 + (Math.min(batchCount, 5) / 10));
+        
+        if (Math.random() < adjustedPauseChance) {
+          const pauseDuration = Math.floor(Math.random() * (pauseLengthMax - pauseLengthMin + 1)) + pauseLengthMin;
+          console.log(`[DELETE] Taking a break for ${Math.round(pauseDuration/1000)} seconds. Progress: ${deletedCount}/${deleteCount}`);
+          await new Promise(resolve => setTimeout(resolve, pauseDuration));
+          batchCount = 0;
+        }
+      }
+    }
+    
+    if (cancelDelete) {
+      await sendCommandResponse(message, `Delete operation canceled after removing ${deletedCount} messages.`, deleteTimeout, true);
+    } else {
+      await sendCommandResponse(message, `Finished deleting ${deletedCount} messages.`, deleteTimeout, true);
+    }
+  } catch (error) {
+    console.error('[DELETE] Failed to delete messages:', error);
+    await sendCommandResponse(message, 'There was an error while trying to delete messages.', deleteTimeout, true);
+  }
+}
+
+async function deleteMessagesFromServer(message, guildId, deleteTimeout, speed = 'medium') {
+  const guild = message.client.guilds.cache.get(guildId);
+
+  if (!guild) {
+    await sendCommandResponse(message, `Guild with ID ${guildId} not found.`, deleteTimeout, true);
+    return;
+  }
+  
+  let deleteIntervalMin, deleteIntervalMax, jitterFactor, pauseChance, pauseLengthMin, pauseLengthMax, batchSize;
+  
+  switch(speed) {
+    case 'slow':
+      deleteIntervalMin = 3000;
+      deleteIntervalMax = 6000;
+      jitterFactor = 0.5;
+      pauseChance = 0.4;
+      pauseLengthMin = 30000;
+      pauseLengthMax = 90000;
+      batchSize = 5;
+      break;
+    case 'fast':
+      deleteIntervalMin = 1500;
+      deleteIntervalMax = 3000;
+      jitterFactor = 0.3;
+      pauseChance = 0.2;
+      pauseLengthMin = 15000;
+      pauseLengthMax = 45000;
+      batchSize = 15;
+      break;
+    case 'medium':
+    default:
+      deleteIntervalMin = 2000;
+      deleteIntervalMax = 4500;
+      jitterFactor = 0.4;
+      pauseChance = 0.3;
+      pauseLengthMin = 20000;
+      pauseLengthMax = 60000;
+      batchSize = 10;
+  }
+  
+  const getHumanlikeDelay = () => {
+    const baseInterval = Math.floor(Math.random() * (deleteIntervalMax - deleteIntervalMin + 1)) + deleteIntervalMin;
+    const jitterAmount = baseInterval * jitterFactor;
+    const jitter = Math.random() * jitterAmount * 2 - jitterAmount;
+    return Math.max(1000, Math.floor(baseInterval + jitter));
+  };
+
+  console.log(`[DELETE] Starting server-wide deletion in server: ${guild.name}`);
+  let totalDeleted = 0;
 
   try {
     const channels = guild.channels.cache.filter(channel => channel.isText());
+    let processedChannels = 0;
+    
     for (const [channelId, channel] of channels) {
-      if (cancelDelete) return;
+      if (cancelDelete) {
+        console.log(`[DELETE] Operation canceled by user`);
+        break;
+      }
+      
+      processedChannels++;
+      console.log(`[DELETE] Processing channel ${processedChannels}/${channels.size}: ${channel.name}`);
+      
       let hasMoreMessages = true;
+      let messagesDeletedInChannel = 0;
+      let batchCount = 0;
+      
       while (hasMoreMessages && !cancelDelete) {
-        const messages = await channel.messages.fetch({ limit: BATCH_SIZE });
+        const messages = await channel.messages.fetch({ limit: 100 });
 
         if (messages.size === 0) {
           hasMoreMessages = false;
           continue;
         }
 
-        const filteredMessages = messages.filter(msg => msg.author.id === message.author.id);
+        const filteredMessages = messages.filter(msg => 
+          msg.author.id === message.author.id && 
+          !deletedMessages.has(msg.id)
+        );
+        
+        if (filteredMessages.size === 0) {
+          hasMoreMessages = false;
+          continue;
+        }
+
+        batchCount++;
+        let messagesInThisBatch = 0;
+        
         for (const msg of filteredMessages.values()) {
           if (cancelDelete) return;
+          
           try {
-            if (msg.deletable && !msg.deleted) {
-              const delay = getRandomDelay();
-              await new Promise(resolve => setTimeout(resolve, delay));
+            if (msg.deletable && !msg.deleted && !deletedMessages.has(msg.id)) {
+              const preDeleteDelay = Math.floor(Math.random() * 1000) + 250;
+              await new Promise(resolve => setTimeout(resolve, preDeleteDelay));
+              
               await msg.delete().catch(err => {
-                if (err.code !== 10008) {
-                  console.error('Failed to delete message:', err);
+                if (err.code === 10008) {
+                  console.log(`[DELETE] Message ${msg.id} already deleted`);
+                  deletedMessages.add(msg.id);
+                } else if (err.code === 429) {
+                  console.log(`[DELETE] Rate limited. Taking a longer break...`);
+                  return new Promise(resolve => setTimeout(resolve, 30000 + Math.random() * 30000));
+                } else {
+                  console.error(`[DELETE] Failed to delete message:`, err);
                 }
               });
+              
+              deletedMessages.add(msg.id);
+              totalDeleted++;
+              messagesDeletedInChannel++;
+              messagesInThisBatch++;
+              
+              const delay = getHumanlikeDelay();
+              await new Promise(resolve => setTimeout(resolve, delay));
             }
           } catch (error) {
-            console.error('Error deleting message:', error);
+            console.error('[DELETE] Error deleting message:', error);
+          }
+          
+          if (messagesInThisBatch >= batchSize) break;
+        }
+
+        if (messagesInThisBatch < batchSize) {
+          hasMoreMessages = false;
+        } else {
+          const shouldPause = Math.random() < pauseChance;
+          if (shouldPause && !cancelDelete) {
+            const pauseDuration = Math.floor(Math.random() * (pauseLengthMin - pauseLengthMin/2 + 1)) + pauseLengthMin/2;
+            console.log(`[DELETE] Taking a short break for ${Math.round(pauseDuration/1000)} seconds in channel ${channel.name}. Deleted so far: ${messagesDeletedInChannel}`);
+            await new Promise(resolve => setTimeout(resolve, pauseDuration));
+          }
         }
       }
       
-        if (filteredMessages.size < BATCH_SIZE) {
-          hasMoreMessages = false;
+      console.log(`[DELETE] Completed channel ${channel.name}: ${messagesDeletedInChannel} messages deleted`);
+      
+      if (!cancelDelete && processedChannels < channels.size) {
+        const pauseDuration = Math.floor(Math.random() * (pauseLengthMax - pauseLengthMin + 1)) + pauseLengthMin;
+        console.log(`[DELETE] Moving to next channel in ${Math.round(pauseDuration/1000)} seconds. Total deleted so far: ${totalDeleted}`);
+        await new Promise(resolve => setTimeout(resolve, pauseDuration));
+      }
+    }
+    
+    if (cancelDelete) {
+      await sendCommandResponse(message, `Delete operation canceled after removing ${totalDeleted} messages across ${processedChannels} channels.`, deleteTimeout, true);
     } else {
-          const batchDelay = getBatchDelay();
-          await new Promise(resolve => setTimeout(resolve, batchDelay));
-        }
-      }
+      await sendCommandResponse(message, `Finished cleaning up ${guild.name}: ${totalDeleted} messages deleted across ${processedChannels} channels.`, deleteTimeout, true);
     }
   } catch (error) {
-    console.error('Failed to delete messages in the server:', error);
-    const errorMsg = await message.channel.send('There was an error while trying to delete messages from the server.');
-    setTimeout(() => errorMsg.delete().catch(console.error), deleteTimeout);
+    console.error('[DELETE] Failed to delete messages in the server:', error);
+    await sendCommandResponse(message, 'There was an error while trying to delete messages from the server.', deleteTimeout, true);
   }
 }

commands/groupadd.js

@@ -2,20 +2,34 @@ let targetUserIds = new Set();
 let isActive = false;
 let channelToWatch = null;
 let lastAddTimes = new Map();
+let failedAttempts = new Map();
+let recentAdds = new Map();
+const { sendCommandResponse } = require('../utils/messageUtils');
 
-const getRandomDelay = () => {
-    return Math.floor(Math.random() * 200) + 150;
+const getBackoffDelay = (userId) => {
+    const attempts = failedAttempts.get(userId) || 0;
+    
+    if (attempts <= 1) return 2000;
+    if (attempts <= 3) return 4000;
+    if (attempts <= 5) return 7000;
+    if (attempts <= 10) return 15000;
+    return 30000;
+};
+
+const getAddDelay = () => {
+    const baseDelay = Math.floor(Math.random() * 700) + 800;
+    const jitter = Math.floor(Math.random() * 300) - 150;
+    return Math.max(500, baseDelay + jitter);
 };
 
 module.exports = {
     name: 'groupadd',
-    description: 'Automatically re-adds users to group when they leave. Use multiple IDs for multiple targets.',
+    description: 'Automatically re-adds users to group when they leave.',
     async execute(message, args, deleteTimeout) {
         const { extractUserId } = require('../utils/userUtils');
         
         if (message.channel.type !== 'GROUP_DM') {
-            message.channel.send('This command only works in group DMs.')
-                .then(msg => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
+            await sendCommandResponse(message, 'This command only works in group DMs.', deleteTimeout, true);
             return;
         }
 
@@ -23,11 +37,12 @@ module.exports = {
             isActive = false;
             targetUserIds.clear();
             lastAddTimes.clear();
+            failedAttempts.clear();
+            recentAdds.clear();
             channelToWatch = null;
             console.log('[GROUPADD] System deactivated');
 
-            message.channel.send('Group auto-add deactivated.')
-                .then(msg => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
+            await sendCommandResponse(message, 'Group auto-add deactivated.', deleteTimeout, true);
             return;
         }
 
@@ -36,14 +51,15 @@ module.exports = {
             .filter(id => id !== null);
             
         if (validIds.length === 0) {
-            message.channel.send('Please provide at least one valid user ID or @mention.')
-                .then(msg => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
+            await sendCommandResponse(message, 'Please provide at least one valid user ID or @mention.', deleteTimeout, true);
             return;
         }
 
         channelToWatch = message.channel;
         targetUserIds = new Set(validIds);
         isActive = true;
+        failedAttempts.clear();
+        recentAdds.clear();
 
         console.log(`[GROUPADD] System activated - Targeting users: ${Array.from(targetUserIds).join(', ')}`);
 
@@ -51,42 +67,93 @@ module.exports = {
             try {
                 if (!channelToWatch.recipients.has(userId)) {
                     console.log(`[GROUPADD] Target ${userId} not in group, attempting initial add`);
+                    
+                    const initialDelay = Math.floor(Math.random() * 500) + 300;
+                    await new Promise(resolve => setTimeout(resolve, initialDelay));
+                    
                     await channelToWatch.addUser(userId);
+                    lastAddTimes.set(userId, Date.now());
+                    recentAdds.set(userId, true);
+                    
+                    setTimeout(() => {
+                        recentAdds.delete(userId);
+                    }, 10000);
+                    
                     console.log(`[GROUPADD] Initial add successful for ${userId}`);
                 }
             } catch (error) {
                 console.log(`[GROUPADD] Initial add failed for ${userId}:`, error);
+                failedAttempts.set(userId, (failedAttempts.get(userId) || 0) + 1);
             }
         }
 
-        message.client.on('channelRecipientRemove', async (channel, user) => {
+        const handleRecipientRemove = async (channel, user) => {
             if (!isActive || channel.id !== channelToWatch.id || !targetUserIds.has(user.id)) return;
 
             const currentTime = Date.now();
             const lastAddTime = lastAddTimes.get(user.id) || 0;
             const timeSinceLastAdd = currentTime - lastAddTime;
             
-            if (timeSinceLastAdd < 1000) {
-                console.log(`[GROUPADD] Rate limiting for ${user.id}, waiting...`);
-                await new Promise(resolve => setTimeout(resolve, 1000 - timeSinceLastAdd));
+            const isRecentlyAdded = recentAdds.has(user.id);
+            const failCount = failedAttempts.get(user.id) || 0;
+
+            console.log(`[GROUPADD] User ${user.id} left. Time since last add: ${timeSinceLastAdd}ms, Recent add: ${isRecentlyAdded}, Failed attempts: ${failCount}`);
+            
+            if (isRecentlyAdded) {
+                console.log(`[GROUPADD] User ${user.id} was recently added and left immediately. Waiting longer.`);
+                await new Promise(resolve => setTimeout(resolve, 5000 + Math.random() * 5000));
             }
             
-            const delay = getRandomDelay();
-            console.log(`[GROUPADD] User ${user.id} left, waiting ${delay}ms before re-adding`);
+            if (timeSinceLastAdd < 2000) {
+                const backoffTime = getBackoffDelay(user.id);
+                console.log(`[GROUPADD] Rate limiting for ${user.id}, waiting ${backoffTime}ms...`);
+                await new Promise(resolve => setTimeout(resolve, backoffTime));
+            }
 
-            await new Promise(resolve => setTimeout(resolve, delay));
+            const addDelay = getAddDelay();
+            console.log(`[GROUPADD] Will readd user ${user.id} after ${addDelay}ms`);
+            
+            await new Promise(resolve => setTimeout(resolve, addDelay));
+            
+            if (!isActive) {
+                console.log(`[GROUPADD] Command was deactivated during delay, cancelling re-add for ${user.id}`);
+                return;
+            }
 
             try {
                 await channel.addUser(user.id);
                 lastAddTimes.set(user.id, Date.now());
+                recentAdds.set(user.id, true);
+                
+                setTimeout(() => {
+                    recentAdds.delete(user.id);
+                }, 10000);
+                
                 console.log(`[GROUPADD] Successfully re-added user ${user.id}`);
+                
+                if (failedAttempts.get(user.id) > 0) {
+                    failedAttempts.set(user.id, Math.max(0, failedAttempts.get(user.id) - 1));
+                }
             } catch (error) {
                 console.log(`[GROUPADD] Failed to re-add user ${user.id}:`, error);
+                failedAttempts.set(user.id, (failedAttempts.get(user.id) || 0) + 1);
+                
+                if (Math.random() < 0.4 && timeSinceLastAdd > 5000) {
+                    console.log(`[GROUPADD] Will try again after a pause`);
+                    setTimeout(() => {
+                        if (isActive && !channel.recipients.has(user.id)) {
+                            channel.addUser(user.id).catch(e => 
+                                console.log(`[GROUPADD] Retry failed for ${user.id}:`, e)
+                            );
                         }
-        });
+                    }, 3000 + Math.random() * 2000);
+                }
+            }
+        };
+
+        message.client.on('channelRecipientRemove', handleRecipientRemove);
 
         const targetCount = targetUserIds.size;
-        message.channel.send(`Now watching for ${targetCount} user${targetCount > 1 ? 's' : ''} to leave the group.`)
-            .then(msg => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
+        await sendCommandResponse(message, `Now watching for ${targetCount} user${targetCount > 1 ? 's' : ''} to leave the group.`, deleteTimeout, true);
     },
 };

commands/help.js

@@ -1,7 +1,9 @@
+const { sendCommandResponse } = require('../utils/messageUtils');
+
 module.exports = {
   name: 'help',
   description: 'List all of my commands or info about a specific command.',
-  execute(message, args, deleteTimeout) {
+  async execute(message, args, deleteTimeout) {
     let reply = '```';
     reply += 'Here are the available commands:\n\n';
 
@@ -12,9 +14,7 @@ module.exports = {
 
     reply += '```';
 
-    message.channel.send(reply).then(sentMessage => {
-      setTimeout(() => sentMessage.delete().catch(console.error), deleteTimeout);
-    });
+    await sendCommandResponse(message, reply, deleteTimeout, false);
   },
 };
 

commands/ip.js

@@ -1,4 +1,5 @@
 let vpnRangesCache = null;
+const { sendCommandResponse } = require('../utils/messageUtils');
 
 function ipToInt(ip) {
     return ip.split('.').reduce((acc, oct) => (acc << 8) + parseInt(oct, 10), 0) >>> 0;
@@ -23,14 +24,30 @@ function isVpnIp(ip) {
     return false;
 }
 
+function isValidIp(ip) {
+    const ipRegex = /^(?:(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)\.){3}(?:25[0-5]|2[0-4][0-9]|[01]?[0-9][0-9]?)$/;
+    return ipRegex.test(ip);
+}
+
 module.exports = {
     name: 'ip',
-    description: 'Fetches IP info and checks if the IP is a VPN.',
+    description: 'Fetches IP info and checks if the IP is a VPN. Usage: .ip [ip_address]',
     async execute(message, args, deleteTimeout) {
         const { default: fetch } = await import('node-fetch');
         try {
+            let targetIp;
+            
+            if (args.length > 0) {
+                targetIp = args[0];
+                if (!isValidIp(targetIp)) {
+                    await sendCommandResponse(message, "Invalid IP address format. Please use format: x.x.x.x", deleteTimeout, true);
+                    return;
+                }
+            } else {
                 const ipRes = await fetch('http://ip-api.com/json/');
                 const data = await ipRes.json();
+                targetIp = data.query;
+            }
 
             if (!vpnRangesCache) {
                 const vpnRes = await fetch('https://raw.githubusercontent.com/X4BNet/lists_vpn/main/ipv4.txt');
@@ -38,6 +55,14 @@ module.exports = {
                 vpnRangesCache = vpnText.split('\n').map(line => line.trim()).filter(line => line);
             }
 
+            const ipRes = await fetch(`http://ip-api.com/json/${targetIp}`);
+            const data = await ipRes.json();
+
+            if (data.status === 'fail') {
+                await sendCommandResponse(message, `Error: ${data.message}`, deleteTimeout, true);
+                return;
+            }
+
             const ip = data.query || "Unknown";
             const vpnCheck = isVpnIp(ip);
 
@@ -52,7 +77,8 @@ module.exports = {
             const as = data.as || "Unknown";
 
             const output =
-                `Hostname: ${hostname}
+                `IP: ${ip}
+Hostname: ${hostname}
 City: ${city}
 Region: ${region}
 Country: ${country}
@@ -63,12 +89,10 @@ Organization: ${org}
 AS: ${as}
 VPN: ${vpnCheck ? "True" : "False"}`;
 
-            message.channel.send(`\`\`\`\n${output}\n\`\`\``)
-                .then(sentMsg => setTimeout(() => sentMsg.delete().catch(console.error), 30000));
+            await sendCommandResponse(message, `\`\`\`\n${output}\n\`\`\``, 30000, true);
         } catch (error) {
             console.error("Error fetching IP info:", error);
-            message.channel.send("Error fetching IP info.")
-                .then(sentMsg => setTimeout(() => sentMsg.delete().catch(console.error), deleteTimeout));
+            await sendCommandResponse(message, "Error fetching IP info.", deleteTimeout, true);
         }
     },
 };

commands/kickvc.js

@@ -1,176 +1,268 @@
-let targetUserIds = [];
-let isKickActive = false;
-let voiceStateHandler = null;
-let lastKickTime = 0;
-let consecutiveKicks = 0;
-let cooldownTime = 0;
-let checkInterval = null;
+const { extractUserId } = require('../utils/userUtils');
+const { sendCommandResponse } = require('../utils/messageUtils');
 
-const getRandomDelay = () => {
-    const delay = Math.floor(Math.random() * 250) + 100;
-    console.log(`[KICKVC] Generated event delay: ${delay}ms`);
-    return delay;
+let activeKicks = new Map();
+let cooldowns = new Map();
+let voiceStateUpdateHandlers = new Map();
+let checkIntervals = new Map();
+
+const getKickDelay = () => {
+    const baseDelay = Math.floor(Math.random() * 400) + 600;
+    const jitter = Math.floor(Math.random() * 200) - 100;
+    return Math.max(400, baseDelay + jitter);
 };
 
-const getRandomCheckDelay = () => {
-    const delay = Math.floor(Math.random() * 250) + 200;
-    console.log(`[KICKVC] Generated interval check delay: ${delay}ms`);
-    return delay;
+const calculateCooldown = (kickCount) => {
+    if (kickCount <= 2) return 0;
+    if (kickCount <= 5) return Math.min((kickCount - 2) * 300, 900);
+    if (kickCount <= 10) return Math.min(900 + (kickCount - 5) * 400, 2900);
+    return Math.min(2900 + (kickCount - 10) * 500, 5000);
 };
 
-const getCooldown = (kicks) => {
-    let cooldown;
-    if (kicks <= 3) cooldown = 200;
-    else if (kicks <= 5) cooldown = 500;
-    else if (kicks <= 10) cooldown = 1000;
-    else cooldown = 2500;
-    console.log(`[KICKVC] New cooldown calculated for ${kicks} kicks: ${cooldown}ms`);
-    return cooldown;
+const getSafetyPause = () => {
+    if (Math.random() < 0.25) {
+        return Math.floor(Math.random() * 4000) + 3000;
+    }
+    return 0;
+};
+
+const performUserKick = async (userId, guild, voiceChannel, kickData) => {
+    if (!activeKicks.has(userId)) return false;
+    
+    try {
+        const member = guild.members.cache.get(userId);
+        if (!member || !member.voice.channelId) return false;
+        
+        console.log(`[KICKVC] Found user ${userId} in VC: ${voiceChannel.name}`);
+        
+        const currentTime = Date.now();
+        const lastKickTime = kickData.lastKick;
+        const timeSinceLastKick = currentTime - lastKickTime;
+        
+        let cooldownTime = cooldowns.get(userId) || 0;
+        
+        if (timeSinceLastKick < 3000) {
+            cooldownTime = calculateCooldown(kickData.count);
+            cooldowns.set(userId, cooldownTime);
+        }
+        
+        if (cooldownTime > 0) {
+            console.log(`[KICKVC] Cooldown active for ${userId}: ${cooldownTime}ms`);
+            await new Promise(resolve => setTimeout(resolve, cooldownTime));
+        }
+        
+        const safetyPause = getSafetyPause();
+        if (safetyPause > 0) {
+            console.log(`[KICKVC] Adding safety pause of ${safetyPause}ms before kicking ${userId}`);
+            await new Promise(resolve => setTimeout(resolve, safetyPause));
+        }
+        
+        const delay = getKickDelay();
+        console.log(`[KICKVC] Will kick ${userId} after ${delay}ms delay`);
+        
+        await new Promise(resolve => setTimeout(resolve, delay));
+        
+        if (!activeKicks.has(userId)) {
+            console.log(`[KICKVC] Kick for ${userId} was stopped during delay`);
+            return false;
+        }
+        
+        if (member && member.voice.channelId) {
+            await member.voice.disconnect();
+            
+            kickData.count++;
+            kickData.lastKick = Date.now();
+            activeKicks.set(userId, kickData);
+            
+            console.log(`[KICKVC] Successfully kicked ${userId} (${kickData.count} kicks so far)`);
+            
+            if (kickData.count % 5 === 0) {
+                cooldowns.set(userId, calculateCooldown(kickData.count) + 2000);
+                console.log(`[KICKVC] Increased cooldown after ${kickData.count} kicks`);
+            }
+            
+            return true;
+        }
+        
+        return false;
+    } catch (error) {
+        console.log(`[KICKVC] Failed to kick ${userId}:`, error);
+        
+        if (Math.random() < 0.3 && kickData.count > 0) {
+            setTimeout(() => {
+                try {
+                    const member = guild.members.cache.get(userId);
+                    if (member && member.voice.channelId) {
+                        member.voice.disconnect().catch(e => 
+                            console.log(`[KICKVC] Retry failed for ${userId}:`, e)
+                        );
+                    }
+                } catch (retryError) {
+                    console.log(`[KICKVC] Retry setup failed for ${userId}:`, retryError);
+                }
+            }, 2000 + Math.random() * 1000);
+        }
+        
+        return false;
+    }
 };
 
 module.exports = {
     name: 'kickvc',
     description: 'Automatically kicks specified users from voice channels.',
     async execute(message, args, deleteTimeout) {
-        if (args[0]?.toLowerCase() === 'stop') {
-            if (voiceStateHandler) {
-                message.client.removeListener('voiceStateUpdate', voiceStateHandler);
-                voiceStateHandler = null;
-            }
-            if (checkInterval) {
-                clearInterval(checkInterval);
-                checkInterval = null;
-            }
-            isKickActive = false;
-            targetUserIds = [];
-            lastKickTime = 0;
-            consecutiveKicks = 0;
-            cooldownTime = 0;
-            console.log('[KICKVC] System deactivated - all variables reset');
-            message.channel.send('Voice kick has been deactivated.')
-                .then(msg => setTimeout(() => msg.delete().catch(console.error), deleteTimeout));
+        if (args.length === 0) {
+            await sendCommandResponse(message, 'Please provide a command: `start <userId(s)>` or `stop <userId or "all">`', deleteTimeout, true);
             return;
         }
-        const userIds = args.filter(arg => /^\d{17,19}$/.test(arg));
-        if (!userIds.length) {
-            console.log('[KICKVC] Invalid user IDs provided');
-            message.channel.send('Please provide at least one valid user ID.')
-                .then(msg => setTimeout(() => msg.delete().catch(console.error), deleteTimeout));
+
+        const command = args[0].toLowerCase();
+
+        if (command === 'stop') {
+            if (args.length < 2) {
+                await sendCommandResponse(message, 'Please specify a user ID or "all" to stop kicking.', deleteTimeout, true);
                 return;
             }
-        targetUserIds = userIds;
-        isKickActive = true;
-        console.log(`[KICKVC] System activated - Targeting user IDs: ${targetUserIds.join(', ')}`);
-        if (voiceStateHandler) {
-            message.client.removeListener('voiceStateUpdate', voiceStateHandler);
-            console.log('[KICKVC] Removed old voice state handler');
+
+            const target = args[1].toLowerCase();
+            
+            if (target === 'all') {
+                for (const [userId, handler] of voiceStateUpdateHandlers.entries()) {
+                    message.client.off('voiceStateUpdate', handler);
+                    activeKicks.delete(userId);
+                    cooldowns.delete(userId);
+                    clearInterval(checkIntervals.get(userId));
+                    checkIntervals.delete(userId);
+                    console.log(`[KICKVC] Stopped kicking user: ${userId}`);
                 }
-        if (checkInterval) {
-            clearInterval(checkInterval);
-            console.log('[KICKVC] Cleared old check interval');
-        }
-        const kickUser = async (member, guild, fromEvent = false) => {
-            if (!isKickActive) return;
-            const currentTime = Date.now();
-            const timeSinceLastKick = currentTime - lastKickTime;
-            if (timeSinceLastKick < cooldownTime) {
-                console.log(`[KICKVC] On cooldown - ${cooldownTime - timeSinceLastKick}ms remaining`);
+                voiceStateUpdateHandlers.clear();
+                
+                await sendCommandResponse(message, 'Stopped all active VC kicks.', deleteTimeout, true);
+                return;
+            } else {
+                const userId = extractUserId(target);
+                
+                if (!userId) {
+                    await sendCommandResponse(message, 'Invalid user ID.', deleteTimeout, true);
                     return;
                 }
-            try {
-                const selfMember = await guild.members.fetch(member.client.user.id);
-                if (!selfMember.permissions.has("ADMINISTRATOR")) {
-                    console.log(`[KICKVC] No admin permissions in ${guild.name}, skipping`);
+
+                if (voiceStateUpdateHandlers.has(userId)) {
+                    message.client.off('voiceStateUpdate', voiceStateUpdateHandlers.get(userId));
+                    activeKicks.delete(userId);
+                    cooldowns.delete(userId);
+                    clearInterval(checkIntervals.get(userId));
+                    checkIntervals.delete(userId);
+                    console.log(`[KICKVC] Stopped kicking user: ${userId}`);
+                    
+                    await sendCommandResponse(message, `Stopped kicking user: ${userId}`, deleteTimeout, true);
+                } else {
+                    await sendCommandResponse(message, `No active kick for user: ${userId}`, deleteTimeout, true);
+                }
                 return;
             }
-                const delay = fromEvent ? getRandomDelay() : getRandomCheckDelay();
-                console.log(`[KICKVC] Admin check passed in ${guild.name}, waiting ${delay}ms before kick...`);
-                await new Promise(resolve => setTimeout(resolve, delay));
-                if (!member.voice.channel) return;
-                console.log(`[KICKVC] Target in voice: ${member.user.tag} | ${guild.name} | ${member.voice.channel.name}`);
-                await member.voice.disconnect();
-                lastKickTime = currentTime;
-                consecutiveKicks++;
-                cooldownTime = getCooldown(consecutiveKicks);
-                setTimeout(() => {
-                    if (consecutiveKicks > 0) {
-                        consecutiveKicks--;
-                        cooldownTime = getCooldown(consecutiveKicks);
         }
-                }, 15000);
-            } catch (error) {
-                console.log(`[KICKVC] Error kicking in ${guild.name}:`, error);
-                try {
-                    await member.voice.setChannel(null);
-                    console.log('[KICKVC] Succeeded with alternate method (setChannel null)');
-                } catch {
-                    try {
-                        await member.voice.channel.permissionOverwrites.create(member, {
-                            Connect: false,
-                            Speak: false
-                        });
-                        await member.voice.disconnect();
-                        console.log('[KICKVC] Succeeded with permissions override');
-                    } catch {
-                        console.log('[KICKVC] All disconnect methods failed');
+
+        if (command === 'start') {
+            if (args.length < 2) {
+                await sendCommandResponse(message, 'Please provide at least one user ID to kick.', deleteTimeout, true);
+                return;
             }
+
+            const userIds = args.slice(1)
+                .map(arg => extractUserId(arg))
+                .filter(id => id !== null);
+
+            if (userIds.length === 0) {
+                await sendCommandResponse(message, 'No valid user IDs provided.', deleteTimeout, true);
+                return;
             }
+
+            const startedKicking = [];
+            const alreadyKicking = [];
+
+            for (const userId of userIds) {
+                if (activeKicks.has(userId)) {
+                    alreadyKicking.push(userId);
+                    continue;
                 }
-        };
-        voiceStateHandler = async (oldState, newState) => {
-            if (!isKickActive || targetUserIds.length === 0) return;
-            const id = newState?.member?.id || oldState?.member?.id;
-            if (!targetUserIds.includes(id)) return;
-            const voiceState = newState?.channelId ? newState : oldState;
-            if (!voiceState?.channel) return;
-            console.log('[KICKVC] Voice state update detected for target');
-            try {
-                const guild = voiceState.guild;
-                const member = await guild.members.fetch(id).catch(() => null);
-                if (member?.voice?.channel) {
-                    await kickUser(member, guild, true);
-                }
-            } catch (error) {
-                console.log('[KICKVC] Error in voice state handler:', error);
-            }
-        };
-        const intervalTime = Math.floor(Math.random() * 500) + 1000;
-        console.log(`[KICKVC] Setting up interval check every ${intervalTime}ms`);
-        checkInterval = setInterval(async () => {
-            if (!isKickActive) return;
+
+                activeKicks.set(userId, { count: 0, lastKick: 0 });
+                cooldowns.set(userId, 0);
+
                 for (const guild of message.client.guilds.cache.values()) {
-                for (const id of targetUserIds) {
                     try {
-                        const member = await guild.members.fetch(id).catch(() => null);
-                        if (member?.voice?.channel) {
-                            await kickUser(member, guild, false);
+                        const member = await guild.members.fetch(userId).catch(() => null);
+                        if (member && member.voice.channelId) {
+                            const kickData = activeKicks.get(userId);
+                            console.log(`[KICKVC] Found target ${userId} already in voice in ${guild.name}`);
+                            performUserKick(userId, guild, member.voice.channel, kickData);
+                            break;
                         }
-                    } catch { }
-                }
-            }
-        }, intervalTime);
-        message.client.on('voiceStateUpdate', voiceStateHandler);
-        console.log('[KICKVC] New voice state handler and check interval registered');
-        try {
-            const users = await Promise.all(targetUserIds.map(id => message.client.users.fetch(id).catch(() => null)));
-            const userTags = users.filter(u => u).map(u => `${u.tag} (${u.id})`);
-            console.log(`[KICKVC] Successfully fetched target users: ${userTags.join(', ')}`);
-            message.channel.send(`Now automatically kicking: ${userTags.join(', ')} from voice channels.`)
-                .then(msg => setTimeout(() => msg.delete().catch(console.error), deleteTimeout));
-            console.log('[KICKVC] Performing initial guild check');
-            message.client.guilds.cache.forEach(async (guild) => {
-                for (const id of targetUserIds) {
-                    const member = await guild.members.fetch(id).catch(() => null);
-                    if (member?.voice?.channel) {
-                        console.log(`[KICKVC] Target found in voice during initial check - Server: ${guild.name}`);
-                        await kickUser(member, guild, true);
-                    }
-                }
-            });
                     } catch (error) {
-            console.log('[KICKVC] Could not fetch user information:', error);
-            message.channel.send(`Now automatically kicking user IDs: ${targetUserIds.join(', ')} from voice channels.`)
-                .then(msg => setTimeout(() => msg.delete().catch(console.error), deleteTimeout));
+                        console.log(`[KICKVC] Error checking guild ${guild.name} for user ${userId}:`, error);
+                    }
+                }
+
+                const checkInterval = setInterval(async () => {
+                    if (!activeKicks.has(userId)) {
+                        clearInterval(checkInterval);
+                        return;
+                    }
+                    
+                    const kickData = activeKicks.get(userId);
+                    
+                    for (const guild of message.client.guilds.cache.values()) {
+                        try {
+                            const member = await guild.members.fetch(userId).catch(() => null);
+                            if (member && member.voice.channelId) {
+                                performUserKick(userId, guild, member.voice.channel, kickData);
+                                return;
+                            }
+                        } catch (error) {}
+                    }
+                }, 4000 + Math.floor(Math.random() * 2000));
+                
+                checkIntervals.set(userId, checkInterval);
+
+                const handleVoiceStateUpdate = async (oldState, newState) => {
+                    if (!activeKicks.has(userId)) return;
+                    
+                    const member = newState.member || oldState.member;
+                    if (!member || member.user.id !== userId) return;
+                    
+                    const kickData = activeKicks.get(userId);
+                    
+                    if ((!oldState.channelId && newState.channelId) || 
+                        (oldState.channelId !== newState.channelId && newState.channelId)) {
+                        
+                        const guild = newState.guild;
+                        const voiceChannel = newState.channel;
+                        
+                        console.log(`[KICKVC] Target user ${userId} joined/moved to VC: ${voiceChannel.name}`);
+                        performUserKick(userId, guild, voiceChannel, kickData);
+                    }
+                };
+
+                voiceStateUpdateHandlers.set(userId, handleVoiceStateUpdate);
+                message.client.on('voiceStateUpdate', handleVoiceStateUpdate);
+                startedKicking.push(userId);
+                console.log(`[KICKVC] Started kicking user: ${userId}`);
+            }
+
+            if (startedKicking.length > 0) {
+                await sendCommandResponse(
+                    message,
+                    `Started kicking: ${startedKicking.join(', ')}${alreadyKicking.length > 0 ? `\nAlready kicking: ${alreadyKicking.join(', ')}` : ''}`,
+                    deleteTimeout,
+                    true
+                );
+            } else if (alreadyKicking.length > 0) {
+                await sendCommandResponse(message, `Already kicking: ${alreadyKicking.join(', ')}`, deleteTimeout, true);
+            }
+            return;
+        }
+
+        await sendCommandResponse(message, 'Unknown command. Use `start <userId(s)>` or `stop <userId or "all">`.', deleteTimeout, true);
     }
-    },
 };

commands/react.js

@@ -1,20 +1,23 @@
+const { sendCommandResponse } = require('../utils/messageUtils');
+
 module.exports = {
   name: 'react',
-  description: `Automatically react with specified emojis to multiple users' messages, or stop reacting.`,
+  description: `Automatically react with specified emojis to multiple users' messages, or stop reacting. Usage: .react [user1,user2,...] [emoji1] [emoji2] ...`,
   async execute(message, args, deleteTimeout) {
     const { processUserInput } = require('../utils/userUtils');
     
     if (args.length === 0) {
       if (message.client.targetReactUserIds && message.client.reactEmojis) {
-        const statusMsg = await message.channel.send(
+        await sendCommandResponse(
+          message,
           `Currently reacting to messages from the following users: ${message.client.targetReactUserIds
             .map(id => `User ID: ${id}`)
-            .join(', ')} with the following emojis: ${message.client.reactEmojis.join(' ')}.`
+            .join(', ')} with the following emojis: ${message.client.reactEmojis.join(' ')}.`,
+          deleteTimeout,
+          false
         );
-        setTimeout(() => statusMsg.delete().catch(console.error), deleteTimeout);
       } else {
-        const noTargetMsg = await message.channel.send('No active reaction target.');
-        setTimeout(() => noTargetMsg.delete().catch(console.error), deleteTimeout);
+        await sendCommandResponse(message, 'No active reaction target.', deleteTimeout, false);
       }
       return;
     }
@@ -26,50 +29,126 @@ module.exports = {
         message.client.targetReactUserIds = null;
         message.client.reactEmojis = null;
 
-        const stopMsg = await message.channel.send('Stopped reacting to messages.');
-        setTimeout(() => stopMsg.delete().catch(console.error), deleteTimeout);
+        await sendCommandResponse(message, 'Stopped reacting to messages.', deleteTimeout, false);
       } else {
-        const noActiveReactMsg = await message.channel.send('No active reactions to stop.');
-        setTimeout(() => noActiveReactMsg.delete().catch(console.error), deleteTimeout);
+        await sendCommandResponse(message, 'No active reactions to stop.', deleteTimeout, false);
       }
       return;
     }
 
-    const targetIds = processUserInput(args[0]);
-    const emojis = args.slice(1);
+    // Find where the emojis start
+    let emojiStartIndex = -1;
+    for (let i = 0; i < args.length; i++) {
+      // Check if this argument looks like an emoji (contains : or is a single character)
+      if (args[i].includes(':') || args[i].length <= 2) {
+        emojiStartIndex = i;
+        break;
+      }
+    }
 
-    if (targetIds.length === 0 || emojis.length === 0) {
-      const errorMsg = await message.channel.send('Please provide valid user IDs or @mentions and at least one emoji.');
-      setTimeout(() => errorMsg.delete().catch(console.error), deleteTimeout);
+    if (emojiStartIndex === -1) {
+      await sendCommandResponse(message, 'Please provide at least one emoji to react with.', deleteTimeout, false);
       return;
     }
 
+    // All arguments before emojiStartIndex are user IDs
+    const userInput = args.slice(0, emojiStartIndex).join(' ');
+    const emojis = args.slice(emojiStartIndex);
+
+    console.log(`[REACT] Processing user input: "${userInput}"`);
+    const targetIds = processUserInput(userInput);
+    console.log(`[REACT] Extracted user IDs: ${targetIds.join(', ')}`);
+    
+    if (targetIds.length === 0) {
+      await sendCommandResponse(message, 'Please provide valid user IDs or @mentions. You can use multiple users separated by spaces or commas.', deleteTimeout, false);
+      return;
+    }
+
+    // Process emojis to handle custom emojis
+    const processedEmojis = emojis.map(emoji => {
+      // Check if it's a custom emoji (format: :name:)
+      const customEmojiMatch = emoji.match(/^:([a-zA-Z0-9_]+):$/);
+      if (customEmojiMatch) {
+        // For custom emojis, we need to find the emoji ID from the guild
+        const emojiName = customEmojiMatch[1];
+        const customEmoji = message.guild?.emojis.cache.find(e => e.name === emojiName);
+        if (customEmoji) {
+          return customEmoji.id;
+        }
+      }
+      // For standard emojis, just return as is
+      return emoji;
+    });
+
     message.client.targetReactUserIds = targetIds;
-    message.client.reactEmojis = emojis;
+    message.client.reactEmojis = processedEmojis;
 
-    const confirmationMsg = await message.channel.send(
-      `I will now react to messages from the following users: ${targetIds
-        .map(id => `User ID: ${id}`)
-        .join(', ')} with the following emojis: ${emojis.join(' ')}.`
+    // Create a more detailed confirmation message with a different format
+    let userListText = '';
+    if (targetIds.length === 1) {
+      userListText = `User ID: ${targetIds[0]}`;
+    } else {
+      userListText = targetIds.map((id, index) => `User ID ${index + 1}: ${id}`).join('\n');
+    }
+    
+    const confirmationMessage = `I will now react to messages from:\n${userListText}\n\nWith the following emojis: ${emojis.join(' ')}`;
+    
+    console.log(`[REACT] Confirmation message: ${confirmationMessage}`);
+    
+    await sendCommandResponse(
+      message,
+      confirmationMessage,
+      deleteTimeout,
+      false
     );
-    setTimeout(() => confirmationMsg.delete().catch(console.error), deleteTimeout);
 
     if (message.client.reactListener) {
       message.client.off('messageCreate', message.client.reactListener);
     }
 
-    const getRandomDelay = () => Math.floor(Math.random() * (5000 - 2000 + 1)) + 2000;
+    const getHumanizedDelay = () => {
+      const baseDelay = Math.floor(Math.random() * (3000 - 1000 + 1)) + 1000;
+      const jitter = Math.floor(Math.random() * 1000) - 500; 
+      return Math.max(800, baseDelay + jitter);
+    };
 
     message.client.reactListener = async (msg) => {
       if (message.client.targetReactUserIds && message.client.targetReactUserIds.includes(msg.author.id)) {
-        for (const emoji of emojis) {
         try {
-            const delay = getRandomDelay();
-            await new Promise((resolve) => setTimeout(resolve, delay));
-            await msg.react(emoji);
-          } catch (error) {
-            console.error('Failed to react:', error);
+          const shouldReact = Math.random() < 0.95; 
+          
+          if (!shouldReact) {
+            console.log(`[REACT] Randomly skipping reaction to message ${msg.id}`);
+            return;
           }
+          
+          const initialDelay = getHumanizedDelay();
+          await new Promise(resolve => setTimeout(resolve, initialDelay));
+          
+          for (const emoji of processedEmojis) {
+            if (Math.random() < 0.05) {
+              console.log(`[REACT] Skipping emoji ${emoji} for more human-like behavior`);
+              continue;
+            }
+            
+            try {
+              const reactDelay = getHumanizedDelay();
+              
+              if (Math.random() < 0.08) {
+                const extraDelay = Math.floor(Math.random() * 4000) + 1000;
+                console.log(`[REACT] Adding ${extraDelay}ms extra delay before reacting with ${emoji}`);
+                await new Promise(resolve => setTimeout(resolve, extraDelay));
+              }
+              
+              await new Promise(resolve => setTimeout(resolve, reactDelay));
+              await msg.react(emoji);
+              
+            } catch (error) {
+              console.error(`[REACT] Failed to react with ${emoji}:`, error);
+            }
+          }
+        } catch (error) {
+          console.error('[REACT] Error in reaction handler:', error);
         }
       }
     };

commands/reply.js

@@ -1,20 +1,23 @@
+const { sendCommandResponse } = require('../utils/messageUtils');
+
 module.exports = {
     name: 'reply',
-    description: `Automatically reply with a specified message to multiple users' messages, or stop replying.`,
+    description: `Automatically reply with a specified message to multiple users' messages, or stop replying. Usage: .reply [user1,user2,...] [message]`,
     async execute(message, args, deleteTimeout) {
       const { processUserInput } = require('../utils/userUtils');
       
       if (args.length === 0) {
         if (message.client.targetReplyUserIds && message.client.replyMessage) {
-          const statusMsg = await message.channel.send(
+          await sendCommandResponse(
+            message,
             `Currently replying to messages from the following users: ${message.client.targetReplyUserIds
               .map(id => `User ID: ${id}`)
-              .join(', ')} with the message: "${message.client.replyMessage}".`
+              .join(', ')} with the message: "${message.client.replyMessage}".`,
+            deleteTimeout,
+            false
           );
-          setTimeout(() => statusMsg.delete().catch(console.error), deleteTimeout);
         } else {
-          const noTargetMsg = await message.channel.send('No active reply target.');
-          setTimeout(() => noTargetMsg.delete().catch(console.error), deleteTimeout);
+          await sendCommandResponse(message, 'No active reply target.', deleteTimeout, false);
         }
         return;
       }
@@ -26,33 +29,62 @@ module.exports = {
           message.client.targetReplyUserIds = null;
           message.client.replyMessage = null;
   
-          const stopMsg = await message.channel.send('Stopped replying to messages.');
-          setTimeout(() => stopMsg.delete().catch(console.error), deleteTimeout);
+          await sendCommandResponse(message, 'Stopped replying to messages.', deleteTimeout, false);
         } else {
-          const noActiveReplyMsg = await message.channel.send('No active replies to stop.');
-          setTimeout(() => noActiveReplyMsg.delete().catch(console.error), deleteTimeout);
+          await sendCommandResponse(message, 'No active replies to stop.', deleteTimeout, false);
         }
         return;
       }
   
-      const targetIds = processUserInput(args[0]);
-      const replyMessage = args.slice(1).join(' ');
+      // Find where the message starts (after all user IDs)
+      let messageStartIndex = -1;
+      for (let i = 0; i < args.length; i++) {
+        // If this argument looks like a message (contains spaces or is longer than a user ID)
+        if (args[i].includes(' ') || args[i].length > 20) {
+          messageStartIndex = i;
+          break;
+        }
+      }
       
-      if (targetIds.length === 0 || !replyMessage) {
-        const errorMsg = await message.channel.send('Please provide valid user IDs or @mentions and a message to reply with.');
-        setTimeout(() => errorMsg.delete().catch(console.error), deleteTimeout);
+      if (messageStartIndex === -1) {
+        await sendCommandResponse(message, 'Please provide a message to reply with.', deleteTimeout, false);
+        return;
+      }
+  
+      // All arguments before messageStartIndex are user IDs
+      const userInput = args.slice(0, messageStartIndex).join(' ');
+      const replyMessage = args.slice(messageStartIndex).join(' ');
+  
+      console.log(`[REPLY] Processing user input: "${userInput}"`);
+      const targetIds = processUserInput(userInput);
+      console.log(`[REPLY] Extracted user IDs: ${targetIds.join(', ')}`);
+      
+      if (targetIds.length === 0) {
+        await sendCommandResponse(message, 'Please provide valid user IDs or @mentions. You can use multiple users separated by spaces or commas.', deleteTimeout, false);
         return;
       }
   
       message.client.targetReplyUserIds = targetIds;
       message.client.replyMessage = replyMessage;
   
-      const confirmationMsg = await message.channel.send(
-        `I will now reply to messages from the following users: ${targetIds
-          .map(id => `User ID: ${id}`)
-          .join(', ')} with the message: "${replyMessage}".`
+      // Create a more detailed confirmation message with a different format
+      let userListText = '';
+      if (targetIds.length === 1) {
+        userListText = `User ID: ${targetIds[0]}`;
+      } else {
+        userListText = targetIds.map((id, index) => `User ID ${index + 1}: ${id}`).join('\n');
+      }
+      
+      const confirmationMessage = `I will now reply to messages from:\n${userListText}\n\nWith the message: "${replyMessage}"`;
+      
+      console.log(`[REPLY] Confirmation message: ${confirmationMessage}`);
+      
+      await sendCommandResponse(
+        message,
+        confirmationMessage,
+        deleteTimeout,
+        false
       );
-      setTimeout(() => confirmationMsg.delete().catch(console.error), deleteTimeout);
   
       if (message.client.replyListener) {
         message.client.off('messageCreate', message.client.replyListener);

commands/ssh.js

@@ -1,135 +0,0 @@
-const { Client: SSHClient } = require('ssh2');
-
-let sshConnection = null;
-
-module.exports = {
-    name: 'ssh',
-    description: 'Manage an SSH connection. Subcommands: connect, exec, disconnect',
-    async execute(message, args, deleteTimeout) {
-        if (!args.length) {
-            return message.channel
-                .send("Usage: `.ssh <connect|exec|disconnect> ...`")
-                .then((msg) => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
-        }
-
-        const subcommand = args.shift().toLowerCase();
-
-        if (subcommand === 'connect') {
-            if (args.length < 3) {
-                return message.channel
-                    .send("Usage: `.ssh connect <host> <username> <password> [port]`")
-                    .then((msg) => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
-            }
-
-            if (sshConnection) {
-                return message.channel
-                    .send("Already connected. Disconnect first using `.ssh disconnect`.")
-                    .then((msg) => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
-            }
-
-            const host = args[0];
-            const username = args[1];
-            const password = args[2];
-            const port = args[3] ? parseInt(args[3]) : 22;
-
-            sshConnection = new SSHClient();
-
-            sshConnection
-                .on('ready', () => {
-                    message.channel
-                        .send(`Connected to ${host}`)
-                        .then((msg) => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
-                })
-                .on('error', (err) => {
-                    message.channel
-                        .send(`SSH Connection error: ${err.message}`)
-                        .then((msg) => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
-                    sshConnection = null;
-                })
-                .on('close', () => {
-                    message.channel
-                        .send(`SSH Connection closed.`)
-                        .then((msg) => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
-                    sshConnection = null;
-                });
-
-            sshConnection.connect({ host, port, username, password });
-            return;
-        }
-
-        else if (subcommand === 'exec') {
-            if (!sshConnection) {
-                return message.channel
-                    .send("No active SSH connection. Connect first using `.ssh connect ...`")
-                    .then((msg) => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
-            }
-            if (!args.length) {
-                return message.channel
-                    .send("Usage: `.ssh exec <command>`")
-                    .then((msg) => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
-            }
-
-            const cmd = args.join(' ');
-
-            sshConnection.exec(cmd, (err, stream) => {
-                if (err) {
-                    return message.channel
-                        .send(`Error executing command: ${err.message}`)
-                        .then((msg) => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
-                }
-
-                let outputBuffer = '';
-
-                message.channel.send(`Executing command: \`${cmd}\`\n\`\`\`\n...\n\`\`\``)
-                    .then((sentMsg) => {
-                        const updateInterval = setInterval(() => {
-                            let display = outputBuffer;
-                            if (display.length > 1900) {
-                                display = display.slice(-1900);
-                            }
-                            sentMsg.edit(`Executing command: \`${cmd}\`\n\`\`\`\n${display}\n\`\`\``)
-                                .catch(() => { });
-                        }, 2000);
-
-                        stream.on('data', (data) => {
-                            outputBuffer += data.toString();
-                        });
-                        stream.stderr.on('data', (data) => {
-                            outputBuffer += data.toString();
-                        });
-                        stream.on('close', (code, signal) => {
-                            clearInterval(updateInterval);
-                            outputBuffer += `\nProcess exited with code ${code}${signal ? ' and signal ' + signal : ''}`;
-                            let display = outputBuffer;
-                            if (display.length > 1900) {
-                                display = display.slice(-1900);
-                            }
-                            sentMsg.edit(`Executing command: \`${cmd}\`\n\`\`\`\n${display}\n\`\`\``)
-                                .catch(() => { });
-                        });
-                    })
-                    .catch(console.error);
-            });
-            return;
-        }
-
-        else if (subcommand === 'disconnect') {
-            if (!sshConnection) {
-                return message.channel
-                    .send("No active SSH connection.")
-                    .then((msg) => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
-            }
-            sshConnection.end();
-            sshConnection = null;
-            return message.channel
-                .send("Disconnecting SSH...")
-                .then((msg) => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
-        }
-
-        else {
-            return message.channel
-                .send("Unknown subcommand. Use `connect`, `exec`, or `disconnect`.")
-                .then((msg) => setTimeout(() => msg.delete().catch(() => { }), deleteTimeout));
-        }
-    },
-};

index.js

@@ -2,6 +2,7 @@ require('dotenv').config();
 const { Client } = require('discord.js-selfbot-v13');
 const client = new Client();
 const fs = require('fs');
+const readline = require('readline');
 
 const PREFIX = process.env.PREFIX || '.';
 const MESSAGE_DELETE_TIMEOUT = 10000
@@ -16,6 +17,56 @@ for (const file of commandFiles) {
 
 client.on('ready', () => {
   console.log(`Logged in as ${client.user.tag}! (DZ Loves you 2k25).`);
+  
+  const rl = readline.createInterface({
+    input: process.stdin,
+    output: process.stdout,
+    prompt: `Console > `
+  });
+  
+  console.log('Type commands without the prefix to execute them in console mode.');
+  console.log('--------------------------------------------------------');
+  rl.prompt();
+
+  rl.on('line', async (line) => {
+    const input = line.trim();
+    if (!input) {
+      rl.prompt();
+      return;
+    }
+
+    const args = input.split(/ +/);
+    const commandName = args.shift().toLowerCase();
+
+    if (!client.commands.has(commandName)) {
+      console.log(`Command not found: ${commandName}`);
+      rl.prompt();
+      return;
+    }
+
+    try {
+      const mockMessage = {
+        author: { id: client.user.id },
+        client: client,
+        channel: {
+          id: 'console',
+          send: (content) => {
+            console.log('\nCommand output:');
+            console.log(content);
+            return Promise.resolve({ delete: () => Promise.resolve() });
+          }
+        },
+        delete: () => Promise.resolve()
+      };
+
+      console.log(`Executing command: ${commandName}`);
+      await client.commands.get(commandName).execute(mockMessage, args, MESSAGE_DELETE_TIMEOUT);
+    } catch (error) {
+      console.error('Error executing command:', error);
+    }
+    
+    rl.prompt();
+  });
 });
 
 client.on('messageCreate', async message => {

utils/messageUtils.js

@@ -0,0 +1,53 @@
+const getHumanizedDeleteDelay = (baseDelay = 5000) => {
+    const jitter = Math.floor(Math.random() * 2000) - 1000;
+    return Math.max(1500, baseDelay + jitter);
+};
+
+const sendTempMessage = async (channel, content, baseDeleteDelay = 5000) => {
+    if (channel.id === 'console') {
+        return channel.send(content);
+    }
+    
+    try {
+        const deleteDelay = getHumanizedDeleteDelay(baseDeleteDelay);
+        const sentMessage = await channel.send(content);
+        
+        sentMessage.scheduledForDeletion = true;
+        
+        console.log(`[MESSAGE] Sending temp message in ${channel.id}, will delete in ${deleteDelay}ms`);
+        
+        setTimeout(() => {
+            if (Math.random() < 0.1) {
+                const extraDelay = Math.floor(Math.random() * 3000) + 1000;
+                console.log(`[MESSAGE] Adding ${extraDelay}ms extra delay before deletion`);
+                setTimeout(() => sentMessage.delete().catch(err => console.error('[MESSAGE] Delete error:', err)), extraDelay);
+            } else {
+                sentMessage.delete().catch(err => console.error('[MESSAGE] Delete error:', err));
+            }
+        }, deleteDelay);
+        
+        return sentMessage;
+    } catch (error) {
+        console.error('[MESSAGE] Error sending temporary message:', error);
+        return null;
+    }
+};
+
+const sendCommandResponse = async (message, content, baseDeleteDelay = 5000, deleteOriginal = true) => {
+    if (deleteOriginal) {
+        try {
+            const cmdDeleteDelay = Math.floor(Math.random() * 1000) + 500;
+            setTimeout(() => message.delete().catch(() => {}), cmdDeleteDelay);
+        } catch (error) {
+            console.error('[MESSAGE] Error deleting original command:', error);
+        }
+    }
+    
+    return await sendTempMessage(message.channel, content, baseDeleteDelay);
+};
+
+module.exports = {
+    getHumanizedDeleteDelay,
+    sendTempMessage,
+    sendCommandResponse
+}; 

utils/userUtils.js

@@ -14,9 +14,15 @@ function extractUserId(input) {
 }
 
 function processUserInput(input) {
-    return input
-        .split(',')
-        .map(part => part.trim())
+    // First try to split by commas
+    let parts = input.split(',').map(part => part.trim()).filter(part => part !== '');
+    
+    // If we only have one part, try splitting by spaces
+    if (parts.length === 1) {
+        parts = input.split(/\s+/).filter(part => part !== '');
+    }
+    
+    return parts
         .map(part => extractUserId(part))
         .filter(id => id !== null);
 }