gizmo4487/O-Bot
1
0
Fork 0
mirror of https://github.com/gizmo4487/O-Bot.git synced 2026-07-14 00:25:54 -05:00
Code Issues Packages Projects Releases Wiki Activity

Complete rewrite - Added slash commands

Browse Source
This commit is contained in:
Max Gorley
2025-05-04 18:55:40 -05:00
parent 382ac41d7f
commit 6cae1d1eea
13 changed files with 3478 additions and 711 deletions
Download Patch File Download Diff File Expand all files Collapse all files

386
o-bot.js
View File

@@ -1,345 +1,81 @@
const Discord = require('discord.js');
const XMLHttpRequest = require("xmlhttprequest").XMLHttpRequest;
const Constants = require('discord.js/src/util/Constants.js');
const fs = require('fs');
Constants.DefaultOptions.ws.properties.$browser='Discord Android';
const auth = require('./auth.json');
var sound;
const {exec} = require("child_process");
const { Client, Collection, Events, GatewayIntentBits } = require('discord.js');
const fetch = require('node-fetch');
const fs = require('node:fs');
const path = require('node:path');
// Create bot object
const bot = new Discord.Client({autoReconnect:true});
const bot = new Client({
intents: [
GatewayIntentBits.Guilds,
GatewayIntentBits.GuildVoiceStates,
],
autoReconnect:true,
});
bot.commands = new Collection();
// Begin slash command setup
const cmdFoldersPath = path.join(__dirname, 'cmd');
const cmdFolders = fs.readdirSync(cmdFoldersPath);
for(const folder of cmdFolders) {
const cmdPath = path.join(cmdFoldersPath, folder);
const cmdFiles = fs.readdirSync(cmdPath).filter(file => file.endsWith('.js'));
for(const file of cmdFiles) {
const filePath = path.join(cmdPath, file);
const cmd = require(filePath);
if('data' in cmd && 'execute' in cmd) {
console.log('Adding command: ' + cmd.data.name);
bot.commands.set(cmd.data.name, cmd);
}
else {
console.log('[WARN] The command at ' + filePath + ' is missing a required "data" or "execute" property!');
}
}
}
// End slash command setup
// Display console message when logged in
bot.once('ready', () => {
console.log('O-Bot is ready!');
bot.user.setActivity('Puyo Puyo\u2122Tetris\u00AE 2',{type: 'PLAYING'});
// Uncomment to set status to "idle"
/*bot.user.setPresence({
status: 'idle'
});*/
});
// Reconnecting
bot.on("reconnecting", () => {
console.log("Reconnecting!");
});
// Resume
bot.on("resume", () => {
console.log("Connection restored!");
bot.user.setActivity('Puyo Puyo\u2122Tetris\u00AE 2',{type: 'PLAYING'});
});
//bot.on('debug', console.log);
bot.on('message', message => {
bot.user.setActivity('Puyo Puyo\u2122Tetris\u00AE 2',{type: 'PLAYING'});
// Prefix is 'o!'
if (message.content.substring(0, 2) == 'o!') {
var args = message.content.substring(2).split(' ');
var cmd = args[0];
args = args.splice(1);
// Commands
switch(cmd) {
// o!help
case 'help':
message.channel.send("Commands:\n\n**General**\n``o!help``: Display this message\n``o!pi``: Make O speak\n\n**Voice**\n``o!voice``: Make O speak for real\n``o!altvoice``: Make O speak in his alternate voice\n``o!jvoice``: Play one of O's Japanese voice lines\n``o!jaltvoice``: Play one of O's alternate Japanese voice lines\n``o!listen``: O-Bot will record your voice and send it back to you! (These recordings are NOT stored locally.)\n``o!dc``: Make O-Bot leave the voice channel\n\n**Other**\n``o!tetrio-rooms``: Show all open rooms in TETR.IO\n``o!twitch``: Get link for O-Bot creator's Twitch channel\n``o!donate``: Feed O-Bot");
break;
// o!pi
case 'pi':
message.channel.send('Pipi? Pipi-pipipipipi!');
break;
// o!voice
case 'voice':
play(message, "o_sound/000000" + randomHex() + ".wav");
break;
// o!altvoice
case 'altvoice':
play(message, "o_sound/alt/000000" + randomHex() + ".wav");
break;
// o!jvoice
case 'jvoice':
play(message, "o_sound/j/000000" + randomHex() + ".wav");
break;
// o!jaltvoice
case 'jaltvoice':
play(message, "o_sound/j_alt/000000" + randomHex() + ".wav");
break;
// Handle slash commands
bot.on(Events.InteractionCreate, async interaction => {
if(!interaction.isChatInputCommand()) return;
// o!twitch
case 'twitch':
message.channel.send('Pipi!\nhttps://twitch.tv/notengonombreusario');
break;
// o!donate
case 'donate':
message.channel.send('Pipipiii!!\nhttps://streamlabs.com/notengonombreusario');
break;
// o!dc
case 'dc':
if(!message.member.voice.channel){
message.channel.send("``o!dc`` can only be run while you are in a voice channel!");
}
else{
message.channel.send("Disconnecting!");
message.member.voice.channel.leave();
}
break;
case 'leave':
if(!message.member.voice.channel){
message.channel.send("``o!leave`` can only be run while you are in a voice channel!");
}
else{
message.channel.send("Disconnecting!");
message.member.voice.channel.leave();
}
break;
// o!randomhex
case 'randomhex':
message.channel.send("Your random hexadecimal number is " + randomHex());
break;
// o!time
case 'time':
message.channel.send("The current time is " + getTime());
break;
// o!listen
case 'listen':
listen(message);
break;
// o!tetrio-rooms
case 'tetrio-rooms':
message.channel.startTyping();
httpGet(message, "https://tetr.io/api/rooms");
//message.channel.send("Command temporarily unavailable");
break;
// Invalid command
default:
message.channel.send("Pipi...\nInvalid command! Use ``o!help`` to list available commands!");
break;
const cmd = interaction.client.commands.get(interaction.commandName);
if(!cmd) {
console.error('No matching command ' + interaction.commandName + ' was found!');
return;
}
// End of command list
}
}
try {
await cmd.execute(interaction);
}
catch(error) {
const errorMsg = `Uh-oh...something went wrong. Try again later!`;
console.error(error);
if(interaction.replied || interaction.deferred) {
await interaction.followUp({
content: errorMsg,
flags: MessageFlags.Ephemeral
});
}
else {
await interaction.reply({
content: errorMsg,
flags: MessageFlags.Ephemeral
});
}
}
});
async function play(message, sound){
try{
const VC = message.member.voice.channel;
if(!message.guild){
message.channel.send("The bot cannot join private voice chats.")
}
else if(!VC){
message.channel.send("Join a voice channel and try again!");
}
else if (!VC.permissionsFor(message.client.user).has('CONNECT') || !VC.permissionsFor(message.client.user).has('SPEAK')) {
message.channel.send('Missing join/speak permissions!');
}
else{
// Here we try to join the voicechat and save our connection into our object.
var connection = await VC.join();
//message.channel.send("Playing!");
console
const dispatcher = connection.play(sound);
dispatcher.on("finish", () => {
//message.channel.send("Disconnecting!");
dispatcher.destroy();
//VC.leave();
})
.on('error', error => {
console.error(error);
});
}
} catch(error){
console.log(error);
}
}
function randomHex(){
let hex="";
let randNum = 0;
randNum = (Math.floor(Math.random()*Math.floor(41)));
if(randNum<16){
hex = "0" + randNum.toString(16);
}
else{
hex = randNum.toString(16);
}
return hex;
}
function getTime(){
var date = new Date();
var hr = date.getHours();
var AMPM = hr>=12?"PM":"AM";
hr=((hr+11)%12+1);
var min = date.getMinutes();
if(min < 10){
min = "0" + min;
}
var sec = date.getSeconds();
if(sec < 10){
sec = "0" + sec;
}
var time = hr + ":" + min + ":" + sec + " " + AMPM;
return time;
}
async function listen(message){
try{
var date = new Date();
const VC = message.member.voice.channel;
if(!message.guild){
message.channel.send("The bot cannot join private voice chats.");
}
else if(!VC){
message.channel.send("Join a voice channel and try again!");
}
else if (!VC.permissionsFor(message.client.user).has('CONNECT') || !VC.permissionsFor(message.client.user).has('SPEAK')) {
message.channel.send('Missing join/speak permissions!');
}
else{
// Play silence, then start listening
var connection = await VC.join();
var user = message.member.user;
play(message, "ready.wav");
setTimeout(async () => {
message.channel.send("Speak now!");
const audio = connection.receiver.createStream(user,{mode: 'pcm'});
var filename = message.member.user.username + "_" + date.getTime();
audio.pipe(fs.createWriteStream(filename));
var cmd = "sox -t raw -r 48000 -e signed -b 16 -c 2 " + filename + " " + filename + ".wav";
var delcmd = "rm " + filename + ".wav" + " && rm " + filename;
var wavfile = filename + ".wav";
audio.on('end', async (filename) => {
message.channel.send("Finished!");
audio.destroy();
exec(cmd, (error, stdout, stderr) => {
if(error){
console.log(error.message);
return;
}
if(stderr){
console.log(stderr);
return;
}
console.log(stdout);
});
setTimeout(() =>{
message.channel.send({
files: [wavfile]
});
},500);
setTimeout(() => {
exec(delcmd, (error, stdout, stderr) => {
if(error){
console.log(error.message);
return;
}
if(stderr){
console.log(stderr);
return;
}
console.log(stdout);
})
},1000);
})
.on('error', error => {
console.error(error);
});
}, 200);
}
}
catch(error){
console.log(error);
}
}
function printRooms(message, jsonInput){
var additionalText = "";
var roomList = "";
var roomState = "";
roomStats = JSON.parse(jsonInput);
message.channel.send("Room list:");
for(i in roomStats.rooms){
additionalText = "";
if(roomStats.rooms[i].meta.userlimit>0){
additionalText = "/" + roomStats.rooms[i].meta.userlimit;
}
if(roomStats.rooms[i].playercount > roomStats.rooms[i].playingplayers){
additionalText = additionalText + " " + "+" + (roomStats.rooms[i].playercount - roomStats.rooms[i].playingplayers);
}
roomList = roomList + "\n" + roomStats.rooms[i].meta.name + " -- " + roomStats.rooms[i].playingplayers + additionalText + "\n" + roomStats.rooms[i].state + "\nhttps://tetr.io/#" + roomStats.rooms[i].id + "\n\n";
}
message.channel.send(roomList);
message.channel.stopTyping();
//console.log(jsonInput);
//console.log(roomStats.rooms);
}
function httpGet(message, URL)
{
var xmlHttp = new XMLHttpRequest();
xmlHttp.open( "GET", URL, true);
xmlHttp.setRequestHeader("Authorization", "Bearer " + auth.tetrio_token);
xmlHttp.onload = function(e){
if(xmlHttp.readyState === 4){
if(xmlHttp.status === 200){
printRooms(message, xmlHttp.responseText);
} else{
console.error(xmlHttp.statusText);
message.channel.stopTyping();
}
}
};
xmlHttp.onerror = function (e){
console.error(xmlHttp.statusText);
message.channel.stopTyping();
};
xmlHttp.send( null );
}
bot.login(auth.token);
bot.login(process.env.TOKEN);