const { EmbedBuilder, ActionRowBuilder, ButtonBuilder, ButtonStyle } = require('discord.js'); const { getDb } = require('../../database/db'); const { successEmbed, dangerEmbed, warningEmbed, infoEmbed } = require('../../utils/embeds'); const config = require('../../../config.json'); async function triggerRatingFlow(interaction, job) { const clientEmbed = new EmbedBuilder() .setColor(config.colors.gold) .setTitle('⭐ Rate Your Service Provider') .setDescription('Job complete! Please rate your service provider.') .setTimestamp(); const providerEmbed = new EmbedBuilder() .setColor(config.colors.gold) .setTitle('⭐ Rate Your Client') .setDescription('Job complete! Please rate your client.') .setTimestamp(); const clientRow = new ActionRowBuilder().addComponents( new ButtonBuilder().setCustomId(`rate_provider_${job.id}_1`).setLabel('⭐ 1').setStyle(ButtonStyle.Secondary), new ButtonBuilder().setCustomId(`rate_provider_${job.id}_2`).setLabel('⭐ 2').setStyle(ButtonStyle.Secondary), new ButtonBuilder().setCustomId(`rate_provider_${job.id}_3`).setLabel('⭐ 3').setStyle(ButtonStyle.Secondary), new ButtonBuilder().setCustomId(`rate_provider_${job.id}_4`).setLabel('⭐ 4').setStyle(ButtonStyle.Primary), new ButtonBuilder().setCustomId(`rate_provider_${job.id}_5`).setLabel('⭐ 5').setStyle(ButtonStyle.Success) ); const providerRow = new ActionRowBuilder().addComponents( new ButtonBuilder().setCustomId(`rate_client_${job.id}_1`).setLabel('⭐ 1').setStyle(ButtonStyle.Secondary), new ButtonBuilder().setCustomId(`rate_client_${job.id}_2`).setLabel('⭐ 2').setStyle(ButtonStyle.Secondary), new ButtonBuilder().setCustomId(`rate_client_${job.id}_3`).setLabel('⭐ 3').setStyle(ButtonStyle.Secondary), new ButtonBuilder().setCustomId(`rate_client_${job.id}_4`).setLabel('⭐ 4').setStyle(ButtonStyle.Primary), new ButtonBuilder().setCustomId(`rate_client_${job.id}_5`).setLabel('⭐ 5').setStyle(ButtonStyle.Success) ); const thread = interaction.channel; await thread.send({ content: `<@${job.client_id}>`, embeds: [clientEmbed], components: [clientRow] }); await thread.send({ content: `<@${job.provider_id}>`, embeds: [providerEmbed], components: [providerRow] }); } module.exports = { async handle(interaction) { const id = interaction.customId; const parts = id.split('_'); const action = parts[1]; const jobId = parseInt(parts[2]); const db = getDb(); const job = db.prepare('SELECT * FROM jobs WHERE id = ?').get(jobId); if (!job || job.status !== 'active') { return interaction.reply({ content: '❌ This job is not active.', ephemeral: true }); } const isClient = interaction.user.id === job.client_id; const isProvider = interaction.user.id === job.provider_id; if (action === 'complete') { if (!isClient && !isProvider) { return interaction.reply({ content: '❌ Only the client or provider can mark this job complete.', ephemeral: true }); } let clientComplete = job.client_complete; let providerComplete = job.provider_complete; if (isClient) { if (clientComplete) return interaction.reply({ content: '✅ You have already marked this job complete. Waiting for the other party.', ephemeral: true }); clientComplete = 1; db.prepare('UPDATE jobs SET client_complete = 1 WHERE id = ?').run(jobId); } else { if (providerComplete) return interaction.reply({ content: '✅ You have already marked this job complete. Waiting for the other party.', ephemeral: true }); providerComplete = 1; db.prepare('UPDATE jobs SET provider_complete = 1 WHERE id = ?').run(jobId); } if (clientComplete && providerComplete) { db.prepare('UPDATE jobs SET status = ?, completed_at = strftime(\'%s\',\'now\') WHERE id = ?').run('completed', jobId); db.prepare(` INSERT INTO user_stats (user_id, username, total_jobs, type) VALUES (?, ?, 1, ?) ON CONFLICT(user_id) DO UPDATE SET total_jobs = total_jobs + 1 `).run(job.provider_id, 'unknown', job.type === 'bodyguard' ? 'bodyguard' : 'merc'); const completedEmbed = successEmbed( '✅ Job Complete!', `Both parties have confirmed completion of Job #${jobId}!\n\nPlease rate each other below. The thread will be archived after ratings are submitted.` ); await interaction.reply({ embeds: [completedEmbed] }); await triggerRatingFlow(interaction, job); } else { const waitingFor = isClient ? job.provider_id : job.client_id; await interaction.reply({ embeds: [infoEmbed('⏳ Waiting for Confirmation', `You've marked the job complete. Waiting for <@${waitingFor}> to also confirm.`)] }); } return; } if (action === 'trade') { if (!isClient && !isProvider) { return interaction.reply({ content: '❌ Only job participants can mark a trade complete.', ephemeral: true }); } return interaction.reply({ embeds: [successEmbed('🤝 Trade Noted', 'Trade completion noted. Both parties should also confirm the main job when ready.')], ephemeral: true }); } if (action === 'tk') { if (!isClient && !isProvider) { return interaction.reply({ content: '❌ Only job participants can report a TK.', ephemeral: true }); } const reportedId = isClient ? job.provider_id : job.client_id; const expiresAt = Math.floor(Date.now() / 1000) + (6 * 7 * 24 * 3600); const existing = db.prepare('SELECT * FROM blacklist WHERE user_id = ?').get(reportedId); if (existing) { db.prepare('UPDATE blacklist SET reason = ?, expires_at = ?, added_by = ? WHERE user_id = ?') .run('TK Report (auto)', expiresAt, 'system', reportedId); } else { db.prepare('INSERT INTO blacklist (user_id, username, reason, added_by, expires_at) VALUES (?,?,?,?,?)') .run(reportedId, 'unknown', 'TK Report (auto)', 'system', expiresAt); } db.prepare('UPDATE jobs SET status = ? WHERE id = ?').run('tk_reported', jobId); db.prepare(` INSERT INTO user_stats (user_id, username, tk_reports) VALUES (?, ?, 1) ON CONFLICT(user_id) DO UPDATE SET tk_reports = tk_reports + 1 `).run(reportedId, 'unknown'); const reportedUser = await interaction.client.users.fetch(reportedId).catch(() => null); if (reportedUser) { await reportedUser.send({ embeds: [dangerEmbed('⚠️ TK Report Filed Against You', `A TK report has been filed against you on **${interaction.guild.name}**.\nYou have been automatically blacklisted for **6 weeks** (until ).\n\nContact staff to contest this.`)] }).catch(() => {}); const blRole = interaction.guild.roles.cache.find(r => r.name === config.roles.blacklisted); const reportedMember = await interaction.guild.members.fetch(reportedId).catch(() => null); if (reportedMember && blRole) await reportedMember.roles.add(blRole).catch(() => {}); } const logChannel = interaction.guild.channels.cache.get(config.channels.blacklistLogs); if (logChannel) { await logChannel.send({ embeds: [dangerEmbed('⚠️ Auto TK Blacklist', `**Reported:** <@${reportedId}>\n**Reported By:** ${interaction.user}\n**Job ID:** ${jobId}\n**Auto-blacklisted for 6 weeks until:** `)] }); } const staffAlerts = interaction.guild.channels.cache.get(config.channels.staffAlerts); if (staffAlerts) { await staffAlerts.send({ embeds: [dangerEmbed('⚠️ TK Report Alert', `**Job ID:** ${jobId}\n**Reported User:** <@${reportedId}>\n**Reported By:** ${interaction.user}\n**Thread:** ${interaction.channel}`)], content: `<@&${interaction.guild.roles.cache.find(r => r.name === config.roles.staff)?.id}>` }); } return interaction.reply({ embeds: [dangerEmbed('⚠️ TK Reported', `TK has been reported. <@${reportedId}> has been automatically blacklisted for **6 weeks**. Staff have been notified.`)] }); } if (action === 'staff') { const staffAlerts = interaction.guild.channels.cache.get(config.channels.staffAlerts); if (staffAlerts) { await staffAlerts.send({ embeds: [warningEmbed('📞 Staff Called to Job Thread', `**Job ID:** ${jobId}\n**Called By:** ${interaction.user}\n**Thread:** ${interaction.channel}`)], content: `<@&${interaction.guild.roles.cache.find(r => r.name === config.roles.staff)?.id}>` }); } const staffMember = interaction.guild.roles.cache.find(r => r.name === config.roles.staff); if (staffMember) await interaction.channel.members.add(staffMember.id).catch(() => {}); return interaction.reply({ embeds: [infoEmbed('📞 Staff Notified', 'Staff have been alerted to this thread. They will join shortly.')] }); } } };