aboutsummaryrefslogtreecommitdiff
path: root/src/commands/play.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/commands/play.ts')
-rw-r--r--src/commands/play.ts47
1 files changed, 29 insertions, 18 deletions
diff --git a/src/commands/play.ts b/src/commands/play.ts
index 5ef4c1d..d1ab940 100644
--- a/src/commands/play.ts
+++ b/src/commands/play.ts
@@ -10,13 +10,13 @@ import {TYPES} from '../types.js';
import {QueuedSong, STATUS} from '../services/player.js';
import PlayerManager from '../managers/player.js';
import {getMostPopularVoiceChannel, getMemberVoiceChannel} from '../utils/channels.js';
-import errorMsg from '../utils/error-msg.js';
import GetSongs from '../services/get-songs.js';
import {prisma} from '../utils/db.js';
import ThirdParty from '../services/third-party.js';
import getYouTubeAndSpotifySuggestionsFor from '../utils/get-youtube-and-spotify-suggestions-for.js';
import KeyValueCacheProvider from '../services/key-value-cache.js';
import {ONE_HOUR_IN_SECONDS} from '../utils/constants.js';
+import {buildPlayingMessageEmbed} from '../utils/build-embed.js';
@injectable()
export default class implements Command {
@@ -68,31 +68,33 @@ export default class implements Command {
if (!query) {
if (player.status === STATUS.PLAYING) {
- await interaction.reply({content: errorMsg('already playing, give me a song name'), ephemeral: true});
- return;
+ throw new Error('already playing, give me a song name');
}
// Must be resuming play
if (!wasPlayingSong) {
- await interaction.reply({content: errorMsg('nothing to play'), ephemeral: true});
- return;
+ throw new Error('nothing to play');
}
await player.connect(targetVoiceChannel);
await player.play();
- await interaction.reply('the stop-and-go light is now green');
+ await interaction.reply({
+ content: 'the stop-and-go light is now green',
+ embeds: [buildPlayingMessageEmbed(player)],
+ });
+
return;
}
const addToFrontOfQueue = interaction.options.getBoolean('immediate');
const shuffleAdditions = interaction.options.getBoolean('shuffle');
- let newSongs: Array<Except<QueuedSong, 'addedInChannelId'>> = [];
- let extraMsg = '';
-
await interaction.deferReply();
+ let newSongs: Array<Except<QueuedSong, 'addedInChannelId' | 'requestedBy'>> = [];
+ let extraMsg = '';
+
// Test if it's a complete URL
try {
const url = new URL(query);
@@ -111,14 +113,12 @@ export default class implements Command {
// YouTube playlist
newSongs.push(...await this.getSongs.youtubePlaylist(url.searchParams.get('list')!));
} else {
- // Single video
const song = await this.getSongs.youtubeVideo(url.href);
if (song) {
newSongs.push(song);
} else {
- await interaction.editReply(errorMsg('that doesn\'t exist'));
- return;
+ throw new Error('that doesn\'t exist');
}
}
} else if (url.protocol === 'spotify:' || url.host === 'open.spotify.com') {
@@ -149,14 +149,12 @@ export default class implements Command {
if (song) {
newSongs.push(song);
} else {
- await interaction.editReply(errorMsg('that doesn\'t exist'));
- return;
+ throw new Error('that doesn\'t exist');
}
}
if (newSongs.length === 0) {
- await interaction.editReply(errorMsg('no songs found'));
- return;
+ throw new Error('no songs found');
}
if (shuffleAdditions) {
@@ -164,7 +162,7 @@ export default class implements Command {
}
newSongs.forEach(song => {
- player.add({...song, addedInChannelId: interaction.channel?.id}, {immediate: addToFrontOfQueue ?? false});
+ player.add({...song, addedInChannelId: interaction.channel!.id, requestedBy: interaction.member!.user.id}, {immediate: addToFrontOfQueue ?? false});
});
const firstSong = newSongs[0];
@@ -180,6 +178,10 @@ export default class implements Command {
if (wasPlayingSong) {
statusMsg = 'resuming playback';
}
+
+ await interaction.editReply({
+ embeds: [buildPlayingMessageEmbed(player)],
+ });
}
// Build response message
@@ -206,9 +208,18 @@ export default class implements Command {
const query = interaction.options.getString('query')?.trim();
if (!query || query.length === 0) {
- return interaction.respond([]);
+ await interaction.respond([]);
+ return;
}
+ try {
+ // Don't return suggestions for URLs
+ // eslint-disable-next-line no-new
+ new URL(query);
+ await interaction.respond([]);
+ return;
+ } catch {}
+
const suggestions = await this.cache.wrap(
getYouTubeAndSpotifySuggestionsFor,
query,