import { verify_discord_signature } from "https://esm.town/v/mattx/verify_discord_signature?v=8"; import { blob } from "https://esm.town/v/std/blob"; // Bump version import { Routes } from "npm:@discord-api-types/v9"; import { REST } from "npm:@discordjs/rest"; import { createAudioPlayer, createAudioResource, joinVoiceChannel } from "npm:@discordjs/voice"; import googleTTS from "npm:google-tts-api"; let bank = await blob.getJSON("bank"); let bets = await blob.getJSON("bets"); const starting_amount = 5; if (!bank) { bank = {}; await blob.setJSON("bank", bank); } if (!bets) { bets = []; await blob.setJSON("bets", bets); } const rest = new REST({ version: "9" }).setToken(process.env.DISCORD_BOT_TOKEN); async function findUserVoiceChannel(guildId, userId) { try { const channels = await rest.get(Routes.guildChannels(guildId)); const voiceChannels = channels.filter(channel => channel.type === 2); for (const channel of voiceChannels) { const members = await rest.get(Routes.channelVoiceStates(channel.id)); if (members.some(member => member.user.id === userId)) { return channel.id; } } } catch (error) { console.error("Error finding user voice channel:", error); } return null; } async function sayMessage(guildId, channelId, message) { const url = googleTTS.getAudioUrl(message, { lang: "en", slow: false, host: "https://translate.google.com", }); const connection = joinVoiceChannel({ channelId: channelId, guildId: guildId, adapterCreator: createDiscordJSAdapter(channelId, guildId), }); const player = createAudioPlayer(); const resource = createAudioResource(url); player.play(resource); connection.subscribe(player); return new Promise((resolve) => { player.on("stateChange", (oldState, newState) => { if (newState.status === "idle") { connection.destroy(); resolve(); } }); }); } function createDiscordJSAdapter(channelId, guildId) { return { sendPayload: (payload) => { rest.post(Routes.channelMessages(channelId), { body: payload }); }, destroy: () => { rest.delete(Routes.channelVoiceState(guildId, channelId)); }, }; } export const handleDiscordInteraction = async (req: Request) => { if (req.method === "GET") return new Response("GET Method Not Allowed", { status: 405 }); const body = await req.json(); const verified = await verify_discord_signature( Deno.env.get("discordPublicKey"), JSON.stringify(body), req.headers.get("X-Signature-Ed25519"), req.headers.get("X-Signature-Timestamp"), ); // Get the user calling this slash command const userId = await body.member?.user?.id; if (bank[userId] === undefined) bank[userId] = starting_amount; if (!verified) { return new Response("signature invalid", { status: 401, statusText: "signature invalid", }); } // PING if (body.type === 1) return Response.json({ type: 1 }); // PONG // APPLICATION_COMMAND interactions if (body.type === 2) { const command = body.data?.name; const options = body.data?.options; if (command === "balance") { const amount = bank[userId]; return Response.json({ type: 4, data: { content: `You have ${amount} <:jopacoin:954159801049440297>`, }, }); } if (command === "tip") { const recipientId = options[0].value; const tipAmount = options[1].value; if (tipAmount <= 0) { return Response.json({ type: 4, data: { content: `You cannot tip less than 0 <:jopacoin:954159801049440297>, <@${userId}>. Nice try though.`, }, }); } if (tipAmount > bank[userId]) { return Response.json({ type: 4, data: { content: `You cannot tip more than you have <:jopacoin:954159801049440297>, <@${userId}>. Nice try though.`, }, }); } bank[userId] -= tipAmount; if (bank[recipientId] === undefined) { bank[recipientId] = starting_amount; } bank[recipientId] += tipAmount; await blob.setJSON("bank", bank); return Response.json({ type: 4, data: { content: `<@${userId}> has tipped <@${recipientId}> ${tipAmount} <:jopacoin:954159801049440297>!`, }, }); } if (command === "bet") { const party2 = options[0].value; const betAmount = options[1].value; const description = options[2].value; // const mediatorId = options[3].value; if (betAmount <= 0) { return Response.json({ type: 4, data: { content: `Bet amount must be greater than 0 <:jopacoin:954159801049440297>.`, }, }); } if (betAmount > bank[userId]) { return Response.json({ type: 4, data: { content: `You cannot bet more than you have <:jopacoin:954159801049440297>, <@${userId}>.`, }, }); } const newBet = { party1: userId, party2: party2, amount: betAmount, description: description, active: true, }; bets.push(newBet); await blob.setJSON("bets", bets); return Response.json({ type: 4, data: { content: `Bet registered: <@${userId}> bets ${betAmount} <:jopacoin:954159801049440297> against <@${party2}>. Description: ${description}. Use /mediate to find the bet, and /resolve to declare a winner!`, }, }); } if (command === "mediate") { const betsWithIndex = bets.map((bet, index) => ({ bet, index })); const activeBetsWithIndex = betsWithIndex.filter(({ bet }) => bet.active); if (activeBetsWithIndex.length === 0) { return Response.json({ type: 4, data: { content: `There are no active bets for you to mediate.`, }, }); } const activeBetsDescriptions = activeBetsWithIndex.map(({ bet, index }) => { return `${ index + 1 }. <@${bet.party1}> vs. <@${bet.party2}>: ${bet.amount} <:jopacoin:954159801049440297> - ${bet.description}`; }).join("\n"); return Response.json({ type: 4, data: { content: `Active bets:\n${activeBetsDescriptions}\nUse /reply with the bet number and the winner's ID to resolve, or don't enter a winner ID to cancel the bet.`, }, }); } if (command === "resolve") { const betIndex = options[0].value - 1; const result = options[1]?.value; if (betIndex < 0 || betIndex >= bets.length || !bets[betIndex].active) { return Response.json({ type: 4, data: { content: `Invalid bet number.`, }, }); } const bet = bets[betIndex]; if ([bet.party1, bet.party2].includes(userId)) { return Response.json({ type: 4, data: { content: `You can't resolve this bet!`, }, }); } if (result == undefined) { bet.active = false; await blob.setJSON("bets", bets); return Response.json({ type: 4, data: { content: `<@${userId}> has nullified: <@${bet.party1}> vs. <@${bet.party2}>.`, }, }); } const winnerId = result; if (![bet.party1, bet.party2].includes(winnerId)) { return Response.json({ type: 4, data: { content: `Invalid winner ID.`, }, }); } bet.active = false; bank[winnerId] += bet.amount; await blob.setJSON("bets", bets); await blob.setJSON("bank", bank); return Response.json({ type: 4, data: { content: `<@${userId}> has declared that <@${winnerId}> has won the bet of ${bet.amount} <:jopacoin:954159801049440297>! Bet: <@${bet.party1}> vs. <@${bet.party2}>.`, }, }); } if (command === "pingedash") { return Response.json({ type: 4, data: { content: `<@111293627199746048> https://tenor.com/view/hiash-gif-25282310`, }, }); } if (command === "pingedmichael") { return Response.json({ type: 4, data: { content: `<@842256096848773140> https://tenor.com/view/cowcow-cows-sup-chewing-gif-4536868`, }, }); } if (command === "pingedchris") { return Response.json({ type: 4, data: { content: `<@105853580757454848> https://tenor.com/view/turkey-turkey-looking-at-friend-turkey-looking-at-oven-gif-3157157109734532300`, }, }); } if (command === "pingedluke") { return Response.json({ type: 4, data: { content: `<@894313284705079336> https://tenor.com/view/cow-wrestling-gif-14704035174925808924`, }, }); } if (command === "pingedjamison") { return Response.json({ type: 4, data: { content: `<@321740768161038347> https://tenor.com/view/elmo-fire-burn-gif-5103666`, }, }); } if (command === "pingedaaron") { return Response.json({ type: 4, data: { content: `<@106840442707963904> https://tenor.com/view/truck-charge-hit-gif-10539533`, }, }); } if (command === "pingedkalvin") { return Response.json({ type: 4, data: { content: `<@620140894045077514> https://tenor.com/view/jojo-anime-shocked-mind-if-i-joint-anxious-gif-17086818`, }, }); } if (command === "pingedjon") { return Response.json({ type: 4, data: { content: `<@105927028993183744> https://tenor.com/view/he-is-the-best-player-in-the-world-caleb-sulliban-myflin-smite-commended-gif-17667891`, }, }); } if (command === "pingedandrew") { return Response.json({ type: 4, data: { content: `<@143962477665845248> https://tenor.com/view/crash-gif-26444423`, }, }); } if (command === "pingeddane") { return Response.json({ type: 4, data: { content: `<@135488149781610496> https://tenor.com/view/ginsengking-gif-2782591839599932955`, }, }); } if (command === "simonsays") { const targetUserId = options[0].value; const message = options[1].value; const voiceChannelId = await findUserVoiceChannel(body.guild_id, targetUserId); if (voiceChannelId) { const response = Response.json({ type: 4, data: { content: `Attempting to say "${message}" to <@${targetUserId}> in voice channel.`, }, }); sayMessage(body.guild_id, voiceChannelId, message).catch((error) => { console.error("Error in sayMessage:", error); }); return response; } else { return Response.json({ type: 4, data: { content: `<@${targetUserId}> is not currently in a voice channel.`, }, }); } } return new Response("Bad request", { status: 400, statusText: "Bad request", }); } return new Response("Not handled", { status: 422 }); };

ruralCrimsonGuppy