119 lines
2.7 KiB
JavaScript
119 lines
2.7 KiB
JavaScript
var discord = require("discord.js");
|
|
|
|
class Radio
|
|
{
|
|
constructor(config, radioconfig)
|
|
{
|
|
this.config = config;
|
|
|
|
this.name = radioconfig.name;
|
|
this.url = radioconfig.url;
|
|
|
|
this.client = new discord.Client({
|
|
intents: [
|
|
// List of intents: https://discord.com/developers/docs/topics/gateway#list-of-intents
|
|
discord.Intents.FLAGS.GUILDS,
|
|
discord.Intents.FLAGS.GUILD_VOICE_STATES,
|
|
],
|
|
});
|
|
|
|
this.running = false;
|
|
this.voice_connection = false;
|
|
this.voice_dispatcher = false;
|
|
|
|
this.channel = false;
|
|
|
|
this.client.on("ready", () => {
|
|
console.log("Radio client \"" + this.name + "\" connected!");
|
|
|
|
this.client.channels.fetch(radioconfig.channel).then(channel => {
|
|
this.channel = channel;
|
|
if (channel.members.size > 0) {
|
|
this.joinChannel();
|
|
}
|
|
});
|
|
});
|
|
|
|
this.client.on("error", (e) => {
|
|
console.log("Radio bot error:", e);
|
|
});
|
|
|
|
this.client.on("voiceStateUpdate", (o, n) => {
|
|
if (n.channel == this.channel) {
|
|
console.log("Someone joined \"" + this.name + "\": " + this.channel.members.size);
|
|
if (!this.running) {
|
|
this.running = true;
|
|
this.joinChannel();
|
|
}
|
|
} else if (o.channel == this.channel && n.channel != this.channel) {
|
|
console.log("Someone left \"" + this.name + "\": " + this.channel.members.size);
|
|
if (this.running && this.channel.members.size == 1) {
|
|
this.running = false;
|
|
this.leaveChannel();
|
|
}
|
|
}
|
|
});
|
|
|
|
this.client.login(radioconfig.token);
|
|
}
|
|
|
|
stop()
|
|
{
|
|
console.log("Stopping radio \"" + this.name + "\"...");
|
|
return this.client.destroy();
|
|
}
|
|
|
|
joinChannel()
|
|
{
|
|
console.log("Joining and starting \"" + this.name + "\"!");
|
|
this.running = true;
|
|
|
|
this.channel.join().then((conn) => {
|
|
this.voice_connection = conn;
|
|
this.voice_connection.on("disconnect", () => {
|
|
this.voice_connection = false;
|
|
});
|
|
this.voice_connection.on("newSession", () => {
|
|
this.startBroadcast();
|
|
});
|
|
this.voice_connection.on("error", (err) => {
|
|
console.log("Error: " + err);
|
|
});
|
|
this.startBroadcast();
|
|
}).catch(console.error);
|
|
}
|
|
|
|
leaveChannel()
|
|
{
|
|
console.log("Leaving \"" + this.name + "\".");
|
|
this.running = false;
|
|
|
|
if (this.voice_dispatcher !== false) {
|
|
this.voice_dispatcher.end();
|
|
}
|
|
|
|
if (this.voice_connection !== false) {
|
|
this.voice_connection.disconnect();
|
|
}
|
|
}
|
|
|
|
startBroadcast()
|
|
{
|
|
if (this.voice_connection === false) {
|
|
return;
|
|
}
|
|
|
|
if (this.voice_dispatcher !== false) {
|
|
this.voice_dispatcher.end();
|
|
}
|
|
|
|
this.voice_dispatcher = this.voice_connection.play(this.url, this.config.voice);
|
|
this.voice_dispatcher.on("end", (reason) => {
|
|
console.log("Radio voice \"" + this.name + "\" ended: \"" + reason + "\"");
|
|
this.voice_dispatcher = false;
|
|
});
|
|
}
|
|
}
|
|
|
|
module.exports = Radio;
|