Upload 8 files

Commands/eval.ts

@@ -0,0 +1,42 @@
+import { ChatInputCommandInteraction, Message } from "discord.js";
+
+export default {
+  data: {
+    name: "eval",
+    description: "Chạy mã JavaScript (chỉ chủ bot).",
+    toJSON() {
+      return {
+        name: "eval",
+        description: "Chạy mã JavaScript (chỉ chủ bot).",
+      };
+    },
+  },
+  ownersOnly: true,
+  async execute(input: ChatInputCommandInteraction | Message, args?: string[]) {
+    const code = args?.join(" ");
+    if (!code) {
+      return input instanceof Message
+        ? input.reply("❌ Không có code để chạy.")
+        : input.reply({ content: "❌ Không có code để chạy.", ephemeral: true });
+    }
+
+    try {
+      let result = eval(code);
+      if (result instanceof Promise) result = await result;
+
+      const output = typeof result === "object" ? JSON.stringify(result, null, 2) : result;
+
+      if (input instanceof Message) {
+        await input.reply(`✅ Output:\n\`\`\`js\n${output}\n\`\`\``);
+      } else {
+        await input.reply({ content: `✅ Output:\n\`\`\`js\n${output}\n\`\`\``, ephemeral: true });
+      }
+    } catch (err) {
+      if (input instanceof Message) {
+        await input.reply(`❌ Error:\n\`\`\`${err}\`\`\``);
+      } else {
+        await input.reply({ content: `❌ Error:\n\`\`\`${err}\`\`\``, ephemeral: true });
+      }
+    }
+  },
+};

Commands/help.ts

@@ -0,0 +1,29 @@
+import { ChatInputCommandInteraction, Message } from "discord.js";
+import { commands } from "../index";
+
+export default {
+  data: {
+    name: "help",
+    description: "Hiển thị danh sách lệnh có sẵn.",
+    toJSON() {
+      return {
+        name: "help",
+        description: "Hiển thị danh sách lệnh có sẵn.",
+      };
+    },
+  },
+  ownersOnly: false,
+  async execute(input: ChatInputCommandInteraction | Message) {
+    const commandList = commands
+      .map((cmd) => `- \`${cmd.data.name}\`: ${cmd.data.description}`)
+      .join("\n");
+
+    const replyText = `📜 **Danh sách lệnh:**\n${commandList}`;
+
+    if (input instanceof Message) {
+      await input.reply(replyText);
+    } else {
+      await input.reply({ content: replyText, ephemeral: true });
+    }
+  },
+};

Commands/mass-dm.ts

@@ -0,0 +1,125 @@
+import { Colors, EmbedBuilder, Guild, Message } from "discord.js";
+import type { Command } from "../types";
+import { clients } from "..";
+import { getJsonFromURL } from "../utils/discohook";
+
+export default <Command>{
+  data: {
+    name: "mass-dm",
+    description: "Gửi tin nhắn đến toàn bộ thành viên trong server.",
+    toJSON() {
+      return {
+        name: "mass-dm",
+        description: "Gửi tin nhắn đến toàn bộ thành viên trong server.",
+      };
+    },
+  },
+  ownersOnly: true,
+  execute: async (message: Message, args?: string[]) => {
+    if (!message.guild || !args || args.length === 0) {
+      return message.reply("Vui lòng cung cấp nội dung tin nhắn.");
+    }
+
+    const contentInput = args.join(" ").trim();
+    const guild = message.guild as Guild;
+
+    const clientsInGuild = clients.filter((client) =>
+      client.guilds.cache.has(guild.id)
+    );
+    if (clientsInGuild.length === 0) {
+      return message.reply("❌ Không có client nào trong server.");
+    }
+
+    const DISCOHOOK_URL_REGEX =
+      /^(https?:\/\/)?(www\.)?(discohook\.app|discohook\.org)\/\?data=/;
+    let content = contentInput;
+    const embeds: any[] = [];
+
+    if (DISCOHOOK_URL_REGEX.test(contentInput)) {
+      const discohook = getJsonFromURL(contentInput);
+      if (discohook) {
+        if (discohook.embeds && discohook.embeds.length > 0) {
+          embeds.push(...discohook.embeds);
+        }
+        if (discohook.content) {
+          content = discohook.content;
+        }
+      }
+    }
+
+    const variables: Map<string, string> = new Map();
+    variables.set("guild.name", guild.name);
+    variables.set("guild.id", guild.id);
+    variables.set("guild.memberCount", guild.memberCount.toString());
+
+    const allMembers = guild.members.cache.filter((m) => !m.user.bot);
+    const done: { clientId: string; done: number; failed: number }[] =
+      clientsInGuild.map((client) => ({
+        clientId: client.user?.id as string,
+        done: 0,
+        failed: 0,
+      }));
+
+    const getTotallDone = () => done.reduce((acc, cur) => acc + cur.done, 0);
+    const getTotallFailed = () =>
+      done.reduce((acc, cur) => acc + cur.failed, 0);
+    const isDone = () => getTotallDone() + getTotallFailed() === allMembers.size;
+
+    const getEmbed = () =>
+      new EmbedBuilder()
+        .setTitle("📬 Mass DM Status")
+        .setDescription(
+          `Total: ${allMembers.size}\nDone: ${getTotallDone()}\nFailed: ${getTotallFailed()}\nStatus: ${isDone() ? "✅ Done" : "⏳ In Progress"}`
+        )
+        .setColor(isDone() ? Colors.Green : Colors.Yellow)
+        .setTimestamp();
+
+    const statusMessage = await message.reply({
+      embeds: [getEmbed()],
+    });
+
+    let clientIndex = 0;
+    for (const member of allMembers.values()) {
+      if (!clientsInGuild[clientIndex]) clientIndex = 0;
+
+      const client = clientsInGuild[clientIndex];
+      const clientDone = done.find((d) => d.clientId === client.user?.id)!;
+      clientIndex = (clientIndex + 1) % clientsInGuild.length;
+
+      // Tạo nội dung riêng biệt mỗi user
+      const personalizedVariables = new Map(variables);
+      personalizedVariables.set("user.username", member.user.username);
+      personalizedVariables.set("user.id", member.user.id);
+      personalizedVariables.set("user.tag", member.user.tag);
+      personalizedVariables.set("user.avatar", member.user.displayAvatarURL());
+      personalizedVariables.set("user.mention", member.user.toString());
+      personalizedVariables.set("user.nickname", member.nickname ?? member.user.username);
+
+      let personalizedContent = content;
+      for (const [key, value] of personalizedVariables.entries()) {
+        personalizedContent = personalizedContent.replace(new RegExp(`{${key}}`, "g"), value);
+      }
+
+      try {
+        await client.users.send(member.user.id, {
+          content: personalizedContent,
+          embeds: embeds,
+        });
+        clientDone.done++;
+      } catch (error) {
+        console.error(`❌ Không gửi được đến ${member.user.tag}:`, error);
+        clientDone.failed++;
+      }
+
+      try {
+        await statusMessage.edit({
+          embeds: [getEmbed()],
+        });
+      } catch (err) {
+        console.error("Không thể cập nhật tiến độ:", err);
+      }
+
+      await new Promise((res) => setTimeout(res, 400)); // delay nhẹ tránh bị rate limit
+    }
+  },
+};

Commands/ping.ts

@@ -0,0 +1,19 @@
+import { ChatInputCommandInteraction, Message } from "discord.js";
+
+export default {
+  data: {
+    name: "ping",
+    description: "Replies with Pong!",
+    toJSON() {
+      return { name: "ping", description: "Replies with Pong!" };
+    },
+  },
+  ownersOnly: false,
+  async execute(input: ChatInputCommandInteraction | Message) {
+    if (input instanceof Message) {
+      await input.reply("🏓 Pong! (prefix command)");
+    } else {
+      await input.reply("🏓 Pong! (slash command)");
+    }
+  },
+};

Commands/play.ts

@@ -0,0 +1,100 @@
+import { Message, EmbedBuilder } from 'discord.js';
+import {
+  joinVoiceChannel,
+  createAudioResource,
+  AudioPlayerStatus,
+} from '@discordjs/voice';
+import { get } from 'https';
+import { MusicQueue } from '../utils/MusicQueue';
+import { queues } from '../index';
+import type { Command } from '../types';
+
+async function playSong(queue: MusicQueue, guildId: string) {
+  if (queue.songs.length === 0) {
+    queue.playing = false;
+    return;
+  }
+
+  queue.playing = true;
+  queue.currentSong = queue.songs.shift()!;
+
+  try {
+    const stream = await new Promise<Readable>((resolve, reject) => {
+      get(queue.currentSong.url, (res) => {
+        if (res.statusCode !== 200) return reject(new Error('Failed to fetch MP3'));
+        resolve(res);
+      }).on('error', reject);
+    });
+
+    const resource = createAudioResource(stream);
+    queue.player.play(resource);
+
+    queue.player.once(AudioPlayerStatus.Idle, () => playSong(queue, guildId));
+  } catch (error) {
+    console.error('Error playing mp3:', error);
+    queue.playing = false;
+  }
+}
+
+export default <Command>{
+  data: {
+    name: 'play',
+    description: 'Phát nhạc từ link .mp3',
+    toJSON() {
+      return { name: 'play', description: 'Phát nhạc từ link .mp3' };
+    },
+  },
+  ownersOnly: false,
+  async execute(message: Message, args: string[]) {
+    const guildId = message.guild?.id;
+    if (!guildId) return message.reply('❌ Lệnh này chỉ hoạt động trong server.');
+
+    const voiceChannel = message.member?.voice.channel;
+    if (!voiceChannel) {
+      return message.reply('❌ Bạn cần tham gia voice channel để phát nhạc.');
+    }
+
+    const query = args.join(' ').trim();
+    if (!query || !query.endsWith('.mp3')) {
+      return message.reply('❌ Vui lòng cung cấp một link `.mp3` hợp lệ.');
+    }
+
+    if (!queues.has(guildId)) {
+      queues.set(guildId, new MusicQueue());
+    }
+    const queue = queues.get(guildId)!;
+
+    const song = {
+      title: query.split('/').pop() || 'MP3 File',
+      url: query,
+      duration: 0,
+      thumbnail: '',
+      requestedBy: message.author.id,
+    };
+
+    queue.songs.push(song);
+
+    if (!queue.playing) {
+      if (!queue.connection) {
+        queue.connection = joinVoiceChannel({
+          channelId: voiceChannel.id,
+          guildId: guildId,
+          adapterCreator: message.guild!.voiceAdapterCreator,
+        });
+        queue.connection.subscribe(queue.player);
+      }
+      playSong(queue, guildId);
+    }
+
+    const embed = new EmbedBuilder()
+      .setColor('#00ff00')
+      .setTitle('🎵 Đã thêm vào hàng đợi')
+      .setDescription(`**${song.title}**`)
+      .addFields(
+        { name: 'Vị trí', value: queue.songs.length.toString(), inline: true },
+        { name: 'Người yêu cầu', value: `<@${song.requestedBy}>`, inline: true }
+      );
+
+    await message.reply({ embeds: [embed] });
+  },
+};

Commands/reload.ts

@@ -0,0 +1,56 @@
+import { ChatInputCommandInteraction, Message } from "discord.js";
+import fs from "fs";
+import path from "path";
+import { commands } from "../index";
+
+export default {
+  data: {
+    name: "reload",
+    description: "Tải lại toàn bộ lệnh từ thư mục Commands.",
+    toJSON() {
+      return {
+        name: "reload",
+        description: "Tải lại toàn bộ lệnh từ thư mục Commands.",
+      };
+    },
+  },
+  ownersOnly: true,
+  async execute(input: ChatInputCommandInteraction | Message) {
+    const dir = path.join(__dirname);
+    const newCommands = [];
+
+    try {
+      const files = fs.readdirSync(dir).filter((file) =>
+        file.endsWith(".ts") || file.endsWith(".js")
+      );
+
+      for (const file of files) {
+        if (file === "reload.ts" || file === "reload.js") continue;
+
+        const filePath = path.join(dir, file);
+        delete require.cache[require.resolve(filePath)];
+
+        const command = require(filePath).default;
+        if (command) newCommands.push(command);
+      }
+
+      commands.length = 0;
+      newCommands.forEach((cmd) => commands.push(cmd));
+
+      const replyText = `✅ Đã reload ${newCommands.length} lệnh.`;
+
+      if (input instanceof Message) {
+        await input.reply(replyText);
+      } else {
+        await input.reply({ content: replyText, ephemeral: true });
+      }
+    } catch (error) {
+      console.error(error);
+      if (input instanceof Message) {
+        await input.reply("❌ Lỗi khi reload command.");
+      } else {
+        await input.reply({ content: "❌ Lỗi khi reload command.", ephemeral: true });
+      }
+    }
+  },
+};

Commands/skip.ts

@@ -0,0 +1,33 @@
+import { Message, EmbedBuilder } from 'discord.js';
+import { MusicQueue } from '../utils/MusicQueue';
+import { queues } from '../index';
+import type { Command } from '../types';
+
+export default <Command>{
+  data: {
+    name: 'skip',
+    description: 'Skip the current song',
+    toJSON() {
+      return { name: 'skip', description: 'Skip the current song' };
+    },
+  },
+  ownersOnly: false,
+  async execute(message: Message) {
+    const guildId = message.guild?.id;
+    if (!guildId) return message.reply('❌ This command can only be used in a server.');
+
+    const queue = queues.get(guildId);
+    if (!queue || !queue.playing || !queue.currentSong) {
+      return message.reply('❌ No song is currently playing!');
+    }
+
+    queue.player.stop();
+
+    const embed = new EmbedBuilder()
+      .setColor('#ff9900')
+      .setTitle('⏭️ Song Skipped')
+      .setDescription(`Skipped: **${queue.currentSong.title}**`);
+
+    await message.reply({ embeds: [embed] });
+  },
+};

Commands/stop.ts

@@ -0,0 +1,40 @@
+import { Message, EmbedBuilder } from 'discord.js';
+import { MusicQueue } from '../utils/MusicQueue';
+import { queues } from '../index';
+import type { Command } from '../types';
+
+export default <Command>{
+  data: {
+    name: 'stop',
+    description: 'Stop playing and clear the queue',
+    toJSON() {
+      return { name: 'stop', description: 'Stop playing and clear the queue' };
+    },
+  },
+  ownersOnly: false,
+  async execute(message: Message) {
+    const guildId = message.guild?.id;
+    if (!guildId) return message.reply('❌ This command can only be used in a server.');
+
+    const queue = queues.get(guildId);
+    if (!queue || !queue.playing) {
+      return message.reply('❌ No music is currently playing!');
+    }
+
+    queue.songs = [];
+    queue.playing = false;
+    queue.currentSong = null;
+    queue.player.stop();
+    if (queue.connection) {
+      queue.connection.destroy();
+      queue.connection = null;
+    }
+
+    const embed = new EmbedBuilder()
+      .setColor('#ff0000')
+      .setTitle('⏹️ Music Stopped')
+      .setDescription('Stopped playing and cleared the queue.');
+
+    await message.reply({ embeds: [embed] });
+  },
+};