Guess Song Command

commands/games-sp/guess-song.js

@@ -0,0 +1,124 @@
+const Command = require('../../structures/Command');
+const csvParse = require('csv-parse');
+const { Readable } = require('stream');
+const { reactIfAble, base64, list } = require('../../util/Util');
+const otherSongs = require('../../assets/json/guess-song');
+const { SPOTIFY_KEY, SPOTIFY_SECRET } = process.env;
+
+module.exports = class GuessSongCommand extends Command {
+	constructor(client) {
+		super(client, {
+			name: 'guess-song',
+			aliases: ['song-guess', 'song-game', 'music-guess', 'guess-music', 'music-game'],
+			group: 'games-sp',
+			memberName: 'guess-song',
+			description: 'Guess what song is playing.',
+			throttling: {
+				usages: 1,
+				duration: 30
+			},
+			guildOnly: true,
+			userPermissions: ['CONNECT', 'SPEAK'],
+			clientPermissions: ['ATTACH_FILES'],
+			credit: [
+				{
+					name: 'Spotify',
+					url: 'https://www.spotify.com/us/',
+					reason: 'API',
+					reasonURL: 'https://developer.spotify.com/'
+				}
+			]
+		});
+
+		this.token = null;
+		this.charts = null;
+		this.cache = new Map();
+	}
+
+	async run(msg) {
+		const connection = this.client.voice.connections.get(msg.guild.id);
+		if (!connection) {
+			const usage = this.client.registry.commands.get('join').usage();
+			return msg.reply(`I am not in a voice channel. Use ${usage} to fix that!`);
+		}
+		const current = this.client.games.get(msg.channel.id);
+		if (current) return msg.reply(`Please wait until the current game of \`${current.name}\` is finished.`);
+		if (this.client.dispatchers.has(msg.guild.id)) return msg.reply('I am already playing audio in this server.');
+		this.client.games.set(msg.channel.id, { name: this.name });
+		try {
+			if (!this.token) await this.fetchToken();
+			if (!this.charts) await this.fetchCharts();
+			const song = await this.fetchRandomSong();
+			const data = await this.fetchSongPreview(song);
+			const { body: previewBody } = await request.get(data.preview);
+			const dispatcher = connection.play(Readable.from([previewBody]));
+			this.client.dispatchers.set(msg.guild.id, dispatcher);
+			dispatcher.once('finish', () => this.client.dispatchers.delete(msg.guild.id));
+			dispatcher.once('error', () => this.client.dispatchers.delete(msg.guild.id));
+			await reactIfAble(msg, this.client.user, '🔉');
+			await msg.reply('**You have 30 seconds, what song is this?**');
+			const msgs = await msg.channel.awaitMessages(res => res.author.id === msg.author.id, {
+				max: 1,
+				time: 30000
+			});
+			this.client.games.delete(msg.channel.id);
+			dispatcher.end();
+			this.client.dispatchers.delete(msg.guild.id);
+			if (!msgs.size) return msg.reply(`Time! It's **${data.name}** by **${data.artist}**!`);
+			const guess = msgs.first().content.toLowerCase();
+			if (guess.includes(data.name.toLowerCase())) {
+				return msg.reply(`Nope! It's **${data.name}** by **${data.artist}**!`);
+			}
+			return msg.reply(`Nice! It's **${data.name}** by **${data.artist}**!`);
+		} catch (err) {
+			this.client.dispatchers.delete(msg.guild.id);
+			this.client.games.delete(msg.channel.id);
+			return msg.reply(`Oh no, an error occurred: \`${err.message}\`. Try again later!`);
+		}
+	}
+
+	async fetchCharts() {
+		if (this.charts) return this.charts;
+		const { text } = await request.get('https://spotifycharts.com/regional/us/daily/latest/download');
+		return new Promise((res, rej) => {
+			csvParse(text, { comment: '#' }, (err, output) => {
+				if (err) return rej(error);
+				this.charts = output.slice(2).map(song => song[4].replace('https://open.spotify.com/track/', ''));
+				setTimeout(() => { this.charts = null; }, 4.32e+7);
+				return res(this.charts);
+			});
+		});
+	}
+
+	async fetchRandomSong() {
+		const songs = [...this.charts, otherSongs];
+		const choice = songs[Math.floor(Math.random() * songs.length)];
+		return choice;
+	}
+
+	async fetchSongPreview(id) {
+		if (this.cache.has(id)) return this.cache.get(id);
+		const { body } = await request
+			.get(`https://api.spotify.com/v1/tracks/${id}`)
+			.set({ Authorization: `Bearer ${this.token}` })
+			.query({ market: 'us' });
+		const result = {
+			id,
+			name: body.name,
+			artist: list(body.artists.map(artist => artist.name)),
+			preview: body.preview_url
+		};
+		this.cache.set(id, result);
+		return result;
+	}
+
+	async fetchToken() {
+		const { body } = await request
+			.post('https://accounts.spotify.com/api/token')
+			.set({ Authorization: `Basic ${base64(`${SPOTIFY_KEY}:${SPOTIFY_SECRET}`)}` })
+			.send('grant_type=client_credentials');
+		this.token = body.access_token;
+		setTimeout(() => { this.token = null; }, body.expires_in);
+		return body;
+	}
+};

commands/games-sp/whos-that-pokemon-cry.js

@@ -85,12 +85,16 @@ module.exports = class WhosThatPokemonCryCommand extends Command {
 		}
 		const current = this.client.games.get(msg.channel.id);
 		if (current) return msg.reply(`Please wait until the current game of \`${current.name}\` is finished.`);
+		if (this.client.dispatchers.has(msg.guild.id)) return msg.reply('I am already playing audio in this server.');
 		this.client.games.set(msg.channel.id, { name: this.name });
 		try {
 			const data = await this.client.pokemon.fetch(pokemon.toString());
 			const names = data.names.map(name => name.name.toLowerCase());
 			const attachment = await this.client.registry.commands.get('whos-that-pokemon').createImage(data, false);
-			connection.play(data.cry);
+			const dispatcher = connection.play(data.cry);
+			this.client.dispatchers.set(msg.guild.id, dispatcher);
+			dispatcher.once('finish', () => this.client.dispatchers.delete(msg.guild.id));
+			dispatcher.once('error', () => this.client.dispatchers.delete(msg.guild.id));
 			await reactIfAble(msg, this.client.user, '🔉');
 			await msg.reply('**You have 15 seconds, who\'s that Pokémon?**');
 			const msgs = await msg.channel.awaitMessages(res => res.author.id === msg.author.id, {
@@ -107,6 +111,7 @@ module.exports = class WhosThatPokemonCryCommand extends Command {
 			}
 			return msg.reply(`Nice! It's **${data.name}**!`, { files: [attachment] });
 		} catch (err) {
+			this.client.dispatchers.delete(msg.guild.id);
 			this.client.games.delete(msg.channel.id);
 			return msg.reply(`Oh no, an error occurred: \`${err.message}\`. Try again later!`);
 		}