136 lines
3.6 KiB
JavaScript
136 lines
3.6 KiB
JavaScript
require("dotenv").config();
|
|
|
|
const fs = require('fs');
|
|
const mariadb = require("mariadb");
|
|
const pool = mariadb.createPool({
|
|
host: process.env.DB_HOST,
|
|
port: process.env.DB_PORT || 3306,
|
|
user: process.env.DB_USER,
|
|
password: process.env.DB_PASS,
|
|
database: "asterisk",
|
|
connectionLimit: 5,
|
|
});
|
|
|
|
const FreepbxManager = require("./freepbx");
|
|
const fpbx = new FreepbxManager({
|
|
url: process.env.FREEPBX_URL,
|
|
clientId: process.env.FREEPBX_CLIENT_ID,
|
|
clientSecret: process.env.FREEPBX_CLIENT_SECRET,
|
|
dbPool: pool,
|
|
});
|
|
|
|
const Discord = require('discord.js');
|
|
const client = new Discord.Client({
|
|
intents: ["GuildMembers", "Guilds", "GuildPresences"]
|
|
});
|
|
|
|
const colors = require('colors');
|
|
|
|
const log = {
|
|
log: (msg) => {
|
|
console.log(msg);
|
|
},
|
|
info: (msg) => {
|
|
console.log(`${colors.cyan("[INFO]")} ${msg}`);
|
|
},
|
|
warn: (msg) => {
|
|
console.log(`${colors.yellow("[WARN]")} ${msg}`);
|
|
},
|
|
error: (msg) => {
|
|
console.log(`${colors.red("[ERROR]")} ${msg}`);
|
|
},
|
|
success: (msg) => {
|
|
console.log(`${colors.green("[SUCCESS]")} ${msg}`);
|
|
},
|
|
debug: (msg) => {
|
|
console.log(`${colors.magenta("[DEBUG]")} ${msg}`);
|
|
}
|
|
}
|
|
|
|
// Put clients in global for use elsewhere.
|
|
global.pool = pool;
|
|
global.fpbx = fpbx;
|
|
global.client = client;
|
|
global.log = log;
|
|
|
|
client.on('ready', async () => {
|
|
log.success(`Logged in as ${client.user.displayName}`);
|
|
const commands = require("./commands")
|
|
// Command registration
|
|
log.info("Registering commands...")
|
|
await (async () => {
|
|
try {
|
|
const rest = new Discord.REST().setToken(client.token);
|
|
// Global Commands
|
|
log.info(`Registering global commands`);
|
|
rest.put(Discord.Routes.applicationCommands(client.user.id), { body: commands }).then(() => {
|
|
log.success("Global commands registered")
|
|
}).catch((error) => {
|
|
log.error(error)
|
|
});
|
|
|
|
} catch (error) {
|
|
log.error(error)
|
|
}
|
|
})();
|
|
});
|
|
|
|
client.on('interactionCreate', async interaction => {
|
|
if (!interaction.inGuild()) return interaction.reply({ content: "This bot is not designed to be used in DMs.", ephemeral: true });
|
|
switch (interaction.type) {
|
|
case Discord.InteractionType.ApplicationCommand:
|
|
const command = require(`./interactionHandlers/commands/${interaction.commandName}`);
|
|
|
|
if (!command) return;
|
|
|
|
try {
|
|
await command.execute(interaction);
|
|
} catch (error) {
|
|
log.error(error);
|
|
await interaction.reply({ content: 'There was an error while executing this command!', ephemeral: true });
|
|
}
|
|
break;
|
|
case Discord.InteractionType.MessageComponent:
|
|
const component = require(`./interactionHandlers/components/${interaction.customId}`);
|
|
|
|
if (!component) return;
|
|
|
|
try {
|
|
await component.execute(interaction);
|
|
} catch (error) {
|
|
log.error(error);
|
|
await interaction.reply({ content: 'There was an error while executing this component!', ephemeral: true });
|
|
}
|
|
break;
|
|
}
|
|
});
|
|
|
|
if (fs.existsSync("./import.json")) {
|
|
const importData = JSON.parse(fs.readFileSync("./import.json", "utf8"));
|
|
|
|
const insertData = async () => {
|
|
try {
|
|
const conn = await pool.getConnection();
|
|
for (const ext in importData) {
|
|
const discordId = importData[ext];
|
|
await conn.query("INSERT INTO discord_users (extension, discordId) VALUES (?, ?)", [ext, discordId]);
|
|
}
|
|
conn.release();
|
|
log.success("Data imported successfully.");
|
|
} catch (error) {
|
|
log.error(`Failed to import data: ${error}`);
|
|
}
|
|
};
|
|
|
|
insertData();
|
|
}
|
|
|
|
// Startup
|
|
require("./migrations")(pool).then(() => {
|
|
log.success("Database migrations complete.");
|
|
log.info("Starting Discord client...");
|
|
client.login(process.env.DISCORD_TOKEN);
|
|
}).catch((err) => {
|
|
log.error(`Database migrations failed: ${err}`);
|
|
process.exit(1);
|
|
}); |