// ============================================================== // 🎫 DISCORD TICKET BOT + MINECRAFT CHAT BRIDGE // ============================================================== const { Client, GatewayIntentBits, Collection, EmbedBuilder, ActionRowBuilder, StringSelectMenuBuilder, ButtonBuilder, ButtonStyle, SlashCommandBuilder, REST, Routes, PermissionFlagsBits, ChannelType, WebhookClient } = require('discord.js'); const express = require('express'); const { Rcon } = require('rcon-client'); // ======================= CONFIG ======================= // WKLEJ SWOJE WARTOSCI PONIZEJ: const TOKEN = "TOKEN"; // ← WKLEJ TOKEN BOTA const CLIENT_ID = "1492839109037920427"; // ← ID APLIKACJI BOTA const GUILD_ID = "1264335386537099265"; // ← ID SERWERA DISCORD const SUPPORT_ROLE_ID = "1421880497138569387"; // ← ID ROLI SUPPORT const CHAT_CHANNEL_ID = "1492987160893329489"; // ← ID KANALU CHAT MC<->DC // MINECRAFT RCON CONFIG const MC_RCON_HOST = "localhost"; // ← IP SERWERA MC const MC_RCON_PORT = 25575; // ← PORT RCON (domyslnie 25575) const MC_RCON_PASSWORD = "your_rcon_password"; // ← HASLO RCON Z server.properties // WEBHOOK SERVER PORT (do odbierania wiadomosci z MC) const WEBHOOK_PORT = 3000; // ← PORT SERWERA WEBHOOK // ====================================================== const config = require('./config.json'); const client = new Client({ intents: [ GatewayIntentBits.Guilds, GatewayIntentBits.GuildMessages, GatewayIntentBits.MessageContent, GatewayIntentBits.GuildMembers ] }); client.cooldowns = new Collection(); client.activeTickets = new Map(); // RCON Connection let rconClient = null; // Express server for MC webhooks const app = express(); app.use(express.json()); // ==================== READY EVENT ==================== client.once('ready', async () => { console.log(`✅ ʙᴏᴛ ᴊᴇsᴛ ɢᴏᴛᴏᴡʏ! ${client.user.tag}`); // Connect to MC RCON try { rconClient = await Rcon.connect({ host: MC_RCON_HOST, port: MC_RCON_PORT, password: MC_RCON_PASSWORD }); console.log('✅ ᴘᴏʟᴀᴄᴢᴏɴᴏ ᴢ ᴍɪɴᴇᴄʀᴀғᴛ ʀᴄᴏɴ'); } catch (error) { console.error('❌ ʙʟᴀᴅ ᴘᴏʟᴀᴄᴢᴇɴɪᴀ ʀᴄᴏɴ:', error.message); } const commands = [ new SlashCommandBuilder() .setName('setup') .setDescription('sᴇᴛᴜᴘ ᴛɪᴄᴋᴇᴛ ᴘᴀɴᴇʟ') .setDefaultMemberPermissions(PermissionFlagsBits.Administrator) ]; const rest = new REST({ version: '10' }).setToken(TOKEN); try { console.log('🔄 ʀᴇᴊᴇsᴛʀᴀᴄᴊᴀ ᴋᴏᴍᴇɴᴅ...'); await rest.put( Routes.applicationGuildCommands(CLIENT_ID, GUILD_ID), { body: commands } ); console.log('✅ ᴋᴏᴍᴇɴᴅʏ ᴢᴀʀᴇᴊᴇsᴛʀᴏᴡᴀɴᴇ'); } catch (error) { console.error('❌ ʙʟᴀᴅ ʀᴇᴊᴇsᴛʀᴀᴄᴊɪ ᴋᴏᴍᴇɴᴅ:', error); } client.user.setActivity('ᴛɪᴄᴋᴇᴛ sʏsᴛᴇᴍ 🎫', { type: 3 }); }); // ==================== INTERACTION CREATE EVENT ==================== client.on('interactionCreate', async (interaction) => { if (interaction.isChatInputCommand()) { if (interaction.commandName === 'setup') { await handleSetupCommand(interaction); } } else if (interaction.isStringSelectMenu()) { if (interaction.customId === 'ticket_category') { await handleTicketCreation(interaction); } } else if (interaction.isButton()) { if (interaction.customId === 'close_ticket') { await handleCloseTicket(interaction); } else if (interaction.customId === 'claim_ticket') { await handleClaimTicket(interaction); } else if (interaction.customId === 'add_user') { await handleAddUser(interaction); } } }); // ==================== MC <-> DC CHAT BRIDGE ==================== // DC -> MC client.on('messageCreate', async (message) => { if (message.author.bot) return; if (message.channel.id !== CHAT_CHANNEL_ID) return; const username = message.member?.displayName || message.author.username; const content = message.content; if (!rconClient) { console.error('❌ ʀᴄᴏɴ ɴɪᴇ ᴘᴏʟᴀᴄᴢᴏɴʏ'); return; } try { // Escape quotes in message const escaped = content.replace(/"/g, '\\"'); // Send to MC using tellraw const command = `tellraw @a ["",{"text":"[","color":"dark_gray"},{"text":"DC","color":"#5865F2","bold":true},{"text":"] ","color":"dark_gray"},{"text":"${username}","color":"white"},{"text":": ","color":"gray"},{"text":"${escaped}","color":"white"}]`; await rconClient.send(command); } catch (error) { console.error('❌ ʙʟᴀᴅ ᴡʏsʏʟᴀɴɪᴀ ᴅᴏ ᴍᴄ:', error.message); } }); // MC -> DC (webhook endpoint) app.post('/minecraft-chat', async (req, res) => { try { const { player, message, prefix } = req.body; if (!player || !message) { return res.status(400).json({ error: 'ʙʀᴀᴋ ᴅᴀɴʏᴄʜ' }); } const channel = client.channels.cache.get(CHAT_CHANNEL_ID); if (!channel) { return res.status(404).json({ error: 'ᴋᴀɴᴀʟ ɴɪᴇ ᴢɴᴀʟᴇᴢɪᴏɴʏ' }); } // Format message with LuckyPerms prefix if available let formattedMessage; if (prefix) { formattedMessage = `**[MC]** ${prefix} **${player}**: ${message}`; } else { formattedMessage = `**[MC]** **${player}**: ${message}`; } await channel.send(formattedMessage); res.status(200).json({ success: true }); } catch (error) { console.error('❌ ʙʟᴀᴅ ᴡᴇʙʜᴏᴏᴋᴀ:', error); res.status(500).json({ error: 'ʙʟᴀᴅ sᴇʀᴡᴇʀᴀ' }); } }); // Start webhook server app.listen(WEBHOOK_PORT, () => { console.log(`✅ ᴡᴇʙʜᴏᴏᴋ sᴇʀᴡᴇʀ: ᴘᴏʀᴛ ${WEBHOOK_PORT}`); }); // ==================== SETUP COMMAND ==================== async function handleSetupCommand(interaction) { const { cooldowns } = client; const cooldownKey = 'setup'; if (!cooldowns.has(cooldownKey)) { cooldowns.set(cooldownKey, new Map()); } const now = Date.now(); const timestamps = cooldowns.get(cooldownKey); const cooldownAmount = 5 * 1000; if (timestamps.has(interaction.user.id)) { const expirationTime = timestamps.get(interaction.user.id) + cooldownAmount; if (now < expirationTime) { const timeLeft = (expirationTime - now) / 1000; return interaction.reply({ content: `⏰ ᴘᴏᴄᴢᴇᴋᴀᴊ ${timeLeft.toFixed(1)}s ᴘʀᴢᴇᴅ ᴜᴢʏᴄɪᴇᴍ ᴛᴇᴊ ᴋᴏᴍᴇɴᴅʏ`, ephemeral: true }); } } timestamps.set(interaction.user.id, now); setTimeout(() => timestamps.delete(interaction.user.id), cooldownAmount); try { const embed = new EmbedBuilder() .setTitle('ᴄᴇɴᴛʀᴜᴍ ᴘᴏᴍᴏᴄʏ') .setDescription('ᴘᴏᴛʀᴢᴇʙᴜᴊᴇsᴢ ᴘᴏᴍᴏᴄʏ?\nᴡʏʙɪᴇʀᴢ ᴋᴀᴛᴇɢᴏʀɪᴇ ᴘᴏɴɪᴢᴇᴊ ɪ ᴏᴛᴡᴏʀᴢ ᴛɪᴄᴋᴇᴛ') .setColor('#5865F2') .setFooter({ text: 'ᴛɪᴄᴋᴇᴛ sʏsᴛᴇᴍ ᴠ1.0' }) .setTimestamp(); const options = []; for (const [key, category] of Object.entries(config.categories)) { options.push({ label: category.label, description: category.description, value: key, emoji: category.emoji }); } const selectMenu = new StringSelectMenuBuilder() .setCustomId('ticket_category') .setPlaceholder('🎫 ᴡʏʙɪᴇʀᴢ ᴋᴀᴛᴇɢᴏʀɪᴇ') .addOptions(options); const row = new ActionRowBuilder().addComponents(selectMenu); await interaction.reply({ content: '✅ ᴘᴀɴᴇʟ ᴛɪᴄᴋᴇᴛᴏᴡ ᴢᴏsᴛᴀʟ ᴜᴛᴡᴏʀᴢᴏɴʏ', ephemeral: true }); await interaction.channel.send({ embeds: [embed], components: [row] }); } catch (error) { console.error('❌ ʙʟᴀᴅ sᴇᴛᴜᴘ:', error); if (interaction.replied || interaction.deferred) { await interaction.followUp({ content: '❌ ᴡʏsᴛᴀᴘɪʟ ʙʟᴀᴅ ᴘᴏᴅᴄᴢᴀs ᴛᴡᴏʀᴢᴇɴɪᴀ ᴘᴀɴᴇʟᴜ', ephemeral: true }); } else { await interaction.reply({ content: '❌ ᴡʏsᴛᴀᴘɪʟ ʙʟᴀᴅ ᴘᴏᴅᴄᴢᴀs ᴛᴡᴏʀᴢᴇɴɪᴀ ᴘᴀɴᴇʟᴜ', ephemeral: true }); } } } // ==================== TICKET CREATION ==================== async function handleTicketCreation(interaction) { const category = interaction.values[0]; const userId = interaction.user.id; const userTickets = Array.from(client.activeTickets.values()).filter(t => t.userId === userId); if (userTickets.length >= config.maxTicketsPerUser) { return interaction.reply({ content: `⚠️ ᴍᴀsᴢ ᴊᴜᴢ ᴍᴀᴋsʏᴍᴀʟɴᴀ ʟɪᴄᴢʙᴇ ᴛɪᴄᴋᴇᴛᴏᴡ (${config.maxTicketsPerUser})`, ephemeral: true }); } await interaction.deferReply({ ephemeral: true }); const categoryConfig = config.categories[category]; const channelName = `${config.ticketChannelPrefix}${interaction.user.username}`.toLowerCase().replace(/[^a-z0-9-_]/g, ''); try { const ticketChannel = await interaction.guild.channels.create({ name: channelName, type: ChannelType.GuildText, permissionOverwrites: [ { id: interaction.guild.id, deny: [PermissionFlagsBits.ViewChannel] }, { id: interaction.user.id, allow: [ PermissionFlagsBits.ViewChannel, PermissionFlagsBits.SendMessages, PermissionFlagsBits.ReadMessageHistory, PermissionFlagsBits.AttachFiles ] }, { id: SUPPORT_ROLE_ID, allow: [ PermissionFlagsBits.ViewChannel, PermissionFlagsBits.SendMessages, PermissionFlagsBits.ReadMessageHistory, PermissionFlagsBits.ManageChannels ] } ] }); client.activeTickets.set(ticketChannel.id, { userId: userId, category: category, claimedBy: null, createdAt: Date.now() }); const embed = new EmbedBuilder() .setTitle('ᴛɪᴄᴋᴇᴛ ᴢᴏsᴛᴀʟ ᴜᴛᴡᴏʀᴢᴏɴʏ') .setDescription( `📌 ᴋᴀᴛᴇɢᴏʀɪᴀ: **${categoryConfig.label}** ━━━━━━━━━━━━━━━━━━━━━━ 📜 ɪɴsᴛʀᴜᴋᴄᴊᴇ: ━━━━━━━━━━━━━━━━━━━━━━ • ᴏᴘɪsᴢ sᴡᴏᴊ ᴘʀᴏʙʟᴇᴍ ᴅᴏᴋʟᴀᴅɴɪᴇ • ɴɪᴇ sᴘᴀᴍᴜᴊ ᴡɪᴀᴅᴏᴍᴏsᴄɪᴀᴍɪ • ᴄᴢᴇᴋᴀᴊ ᴄɪᴇʀᴘʟɪᴡɪᴇ ɴᴀ ᴏᴅᴘᴏᴡɪᴇᴅᴢ • ᴍᴏᴢᴇsᴢ ᴅᴏʟᴀᴄᴢʏᴄ sᴄʀᴇᴇɴʏ ━━━━━━━━━━━━━━━━━━━━━━ ⏳ ᴘʀᴢᴇᴅ ᴢᴀᴍᴋɴɪᴇᴄɪᴇᴍ: ━━━━━━━━━━━━━━━━━━━━━━ • ᴜᴘᴇᴡɴɪᴊ sɪᴇ, ᴢᴇ ᴘʀᴏʙʟᴇᴍ ᴢᴏsᴛᴀʟ ʀᴏᴢᴡɪᴀᴢᴀɴʏ • ᴋʟɪᴋɴɪᴊ 🔒 ᴢᴀᴍᴋɴɪᴊ ᴀʙʏ ᴢᴀᴋᴏɴᴄᴢʏᴄ ᴛɪᴄᴋᴇᴛ` ) .setColor(categoryConfig.color) .setFooter({ text: 'sᴜᴘᴘᴏʀᴛ ᴡᴋʀᴏᴛᴄᴇ ᴏᴅᴘᴏᴡɪᴇ' }) .setTimestamp(); const buttons = new ActionRowBuilder() .addComponents( new ButtonBuilder() .setCustomId('close_ticket') .setLabel('ᴢᴀᴍᴋɴɪᴊ') .setEmoji('🔒') .setStyle(ButtonStyle.Danger), new ButtonBuilder() .setCustomId('claim_ticket') .setLabel('ᴘʀᴢᴇᴊᴍɪᴊ') .setEmoji('📌') .setStyle(ButtonStyle.Primary), new ButtonBuilder() .setCustomId('add_user') .setLabel('ᴅᴏᴅᴀᴊ') .setEmoji('👤') .setStyle(ButtonStyle.Secondary) ); await ticketChannel.send({ content: `${categoryConfig.emoji} ᴡɪᴛᴀᴊ, <@${userId}>\nᴛᴡᴏᴊ ᴛɪᴄᴋᴇᴛ ᴢᴏsᴛᴀʟ ᴜᴛᴡᴏʀᴢᴏɴʏ\nᴢᴀᴄᴢɴɪᴊ ᴏᴘɪsʏᴡᴀᴄ ᴘʀᴏʙʟᴇᴍ`, embeds: [embed], components: [buttons] }); await interaction.editReply({ content: `✅ ᴛɪᴄᴋᴇᴛ ᴢᴏsᴛᴀʟ ᴜᴛᴡᴏʀᴢᴏɴʏ: <#${ticketChannel.id}>` }); } catch (error) { console.error('❌ ʙʟᴀᴅ ᴛᴡᴏʀᴢᴇɴɪᴀ ᴛɪᴄᴋᴇᴛᴀ:', error); await interaction.editReply({ content: '❌ ɴɪᴇ ᴜᴅᴀʟᴏ sɪᴇ ᴜᴛᴡᴏʀᴢʏᴄ ᴛɪᴄᴋᴇᴛᴀ' }); } } // ==================== CLOSE TICKET ==================== async function handleCloseTicket(interaction) { const ticketData = client.activeTickets.get(interaction.channel.id); if (!ticketData) { return interaction.reply({ content: '❌ ᴛᴏ ɴɪᴇ ᴊᴇsᴛ ᴋᴀɴᴀʟ ᴛɪᴄᴋᴇᴛᴏᴡʏ', ephemeral: true }); } const isCreator = ticketData.userId === interaction.user.id; const isStaff = interaction.member.roles.cache.has(SUPPORT_ROLE_ID); const isClaimer = ticketData.claimedBy === interaction.user.id; if (!isCreator && !isStaff && !isClaimer) { return interaction.reply({ content: '❌ ɴɪᴇ ᴍᴀsᴢ ᴜᴘʀᴀᴡɴɪᴇɴ ᴅᴏ ᴢᴀᴍᴋɴɪᴇᴄɪᴀ ᴛᴇɢᴏ ᴛɪᴄᴋᴇᴛᴀ', ephemeral: true }); } await interaction.reply({ content: '🔒 ᴢᴀᴍʏᴋᴀɴɪᴇ ᴛɪᴄᴋᴇᴛᴀ ᴡ 3 sᴇᴋᴜɴᴅʏ...', ephemeral: true }); client.activeTickets.delete(interaction.channel.id); setTimeout(async () => { try { await interaction.channel.delete(); } catch (error) { console.error('❌ ʙʟᴀᴅ ᴜsᴜᴡᴀɴɪᴀ ᴋᴀɴᴀʟᴜ:', error); } }, 3000); } // ==================== CLAIM TICKET ==================== async function handleClaimTicket(interaction) { const ticketData = client.activeTickets.get(interaction.channel.id); if (!ticketData) { return interaction.reply({ content: '❌ ᴛᴏ ɴɪᴇ ᴊᴇsᴛ ᴋᴀɴᴀʟ ᴛɪᴄᴋᴇᴛᴏᴡʏ', ephemeral: true }); } const isStaff = interaction.member.roles.cache.has(SUPPORT_ROLE_ID); if (!isStaff) { return interaction.reply({ content: '❌ ᴛʏʟᴋᴏ sᴛᴀғғ ᴍᴏᴢᴇ ᴘʀᴢᴇᴊᴀᴄ ᴛɪᴄᴋᴇᴛʏ', ephemeral: true }); } if (ticketData.claimedBy) { return interaction.reply({ content: `⚠️ ᴛɪᴄᴋᴇᴛ ᴊᴜᴢ ᴢᴏsᴛᴀʟ ᴘʀᴢᴇᴊᴇᴛʏ ᴘʀᴢᴇᴢ <@${ticketData.claimedBy}>`, ephemeral: true }); } ticketData.claimedBy = interaction.user.id; client.activeTickets.set(interaction.channel.id, ticketData); await interaction.channel.permissionOverwrites.edit(interaction.guild.id, { ViewChannel: false, SendMessages: false }); await interaction.channel.permissionOverwrites.edit(ticketData.userId, { ViewChannel: true, SendMessages: true, ReadMessageHistory: true }); await interaction.channel.permissionOverwrites.edit(interaction.user.id, { ViewChannel: true, SendMessages: true, ReadMessageHistory: true, ManageChannels: true }); await interaction.reply({ content: `📌 <@${interaction.user.id}> ᴘʀᴢᴇᴊᴀʟ ᴛᴇɴ ᴛɪᴄᴋᴇᴛ\nᴛʏʟᴋᴏ ᴛʏ ɪ <@${ticketData.userId}> ᴍᴏᴢᴇᴄɪᴇ ᴛᴇʀᴀᴢ ᴘɪsᴀᴄ` }); } // ==================== ADD USER ==================== async function handleAddUser(interaction) { const ticketData = client.activeTickets.get(interaction.channel.id); if (!ticketData) { return interaction.reply({ content: '❌ ᴛᴏ ɴɪᴇ ᴊᴇsᴛ ᴋᴀɴᴀʟ ᴛɪᴄᴋᴇᴛᴏᴡʏ', ephemeral: true }); } if (!ticketData.claimedBy) { return interaction.reply({ content: '❌ ᴛɪᴄᴋᴇᴛ ᴍᴜsɪ ʙʏᴄ ᴘʀᴢᴇᴊᴇᴛʏ, ᴀʙʏ ᴅᴏᴅᴀᴄ ᴜᴢʏᴛᴋᴏᴡɴɪᴋᴀ', ephemeral: true }); } if (ticketData.claimedBy !== interaction.user.id) { return interaction.reply({ content: '❌ ᴛʏʟᴋᴏ ᴏsᴏʙᴀ ᴋᴛᴏʀᴀ ᴘʀᴢᴇᴊᴇʟᴀ ᴍᴏᴢᴇ ᴅᴏᴅᴀᴡᴀᴄ ᴜᴢʏᴛᴋᴏᴡɴɪᴋᴏᴡ', ephemeral: true }); } await interaction.reply({ content: '👤 ᴡᴘɪsᴢ ID ᴜᴢʏᴛᴋᴏᴡɴɪᴋᴀ ᴋᴛᴏʀᴇɢᴏ ᴄʜᴄᴇsᴢ ᴅᴏᴅᴀᴄ (ᴍᴀsᴢ 30 sᴇᴋᴜɴᴅ)', ephemeral: true }); const filter = m => m.author.id === interaction.user.id; try { const collected = await interaction.channel.awaitMessages({ filter, max: 1, time: 30000, errors: ['time'] }); const targetUserId = collected.first().content.replace(/[<@!>]/g, ''); try { const targetMember = await interaction.guild.members.fetch(targetUserId); await interaction.channel.permissionOverwrites.edit(targetMember.id, { ViewChannel: true, SendMessages: true, ReadMessageHistory: true }); await interaction.followUp({ content: `✅ ᴅᴏᴅᴀɴᴏ <@${targetUserId}> ᴅᴏ ᴛɪᴄᴋᴇᴛᴀ`, ephemeral: true }); await collected.first().delete().catch(() => {}); } catch (error) { await interaction.followUp({ content: '❌ ɴɪᴇ ᴢɴᴀʟᴇᴢɪᴏɴᴏ ᴜᴢʏᴛᴋᴏᴡɴɪᴋᴀ', ephemeral: true }); } } catch (error) { await interaction.followUp({ content: '❌ ᴘʀᴢᴇᴋʀᴏᴄᴢᴏɴᴏ ᴄᴢᴀs ᴏᴄᴢᴇᴋɪᴡᴀɴɪᴀ', ephemeral: true }); } } // ==================== ERROR HANDLING ==================== process.on('unhandledRejection', error => { console.error('❌ ɴɪᴇᴏʙsʟᴜɢɪᴡᴀɴʏ ʙʟᴀᴅ:', error); }); // ==================== LOGIN ==================== client.login(TOKEN);