aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/commands/play.js111
-rw-r--r--src/music.js67
2 files changed, 124 insertions, 54 deletions
diff --git a/src/commands/play.js b/src/commands/play.js
index a53a8de..50911b9 100644
--- a/src/commands/play.js
+++ b/src/commands/play.js
@@ -1,60 +1,63 @@
module.exports.run = async (client, message, args) => {
-if (!args[0]) return await message.channel.createMessage('A name of the song of a link is needed.');
-if (!message.member.voiceState.channelID) return await message.channel.createMessage('You are not in a voice channel');
-const YouTube = require('simple-youtube-api');
-const moment = require('moment');
-const youtube = new YouTube(process.env.GOOGLE);
-const url = args.join(' ').replace(/<(.+)>/g, '$1');
-if (!url) return;
-await youtube.getVideo(url)
- .then(results => {
- YTVideo(results);
- })
- .catch(() => {
- youtube.searchVideos(args.join(' '), 1)
- .then(results => {
- youtube.getVideo(results[0].url)
- .then(vid => {
- YTVideo(vid);
- });
- });
- });
-async function YTVideo(video) {
- if (video.durationSeconds === 0) {
- return message.channel.createMessage('Live streams are not available');
- }
- const d = moment.duration({
- s: video.durationSeconds
- });
+ if (!args[0]) return await message.channel.send('A name of the song of a link is needed.');
+ if (!message.member.voiceChannelID) return await message.channel.send('You are not in a voice channel');
+ const YouTube = require('simple-youtube-api');
+ const moment = require('moment');
+ const youtube = new YouTube(process.env.GOOGLE);
+ const url = args.join(' ').replace(/<(.+)>/g, '$1');
+ if (!url) return;
+ await youtube.getVideo(url)
+ .then(results => {
+ YTVideo(results);
+ })
+ .catch(() => {
+ youtube.searchVideos(args.join(' '), 1)
+ .then(results => {
+ youtube.getVideo(results[0].url)
+ .then(vid => {
+ YTVideo(vid);
+ });
+ });
+ });
+
+ const music = require('../music.js');
+ async function YTVideo(video) {
+ if (video.durationSeconds === 0) {
+ return message.channel.send('Live streams are not available');
+ }
+ const d = moment.duration({
+ s: video.durationSeconds
+ });
- const server = bot.MusicVariables(message.member.guild.id);
- const time = moment().startOf('day').add(d).format('HH:mm:ss');
- server.queue.push({
- url: video.url,
- title: video.title,
- thumbnail: video.thumbnails.high.url,
- duration: video.durationSeconds,
- requested: message.author.mention,
- playing: false
- });
- const embed = new bot.RichEmbed()
- .setTitle('A song has been queued')
- .setAuthor(video.title, video.thumbnails.high.url)
- .setColor(0x00afff)
- .setTimestamp()
- .addField('Title', video.title)
- .addField('Link', video.url)
- .addField('Duration', time)
- .setThumbnail(video.thumbnails.high.url)
- .setFootor('Beat Music Player');
- await message.channel.createMessage({embed});
- if (!bot.voiceConnections.get(message.member.guild.id))
- bot.joinVoiceChannel(message.member.voiceState.channelID).then(function(connection) {
- //Pass the song into the music handler
- bot.playYT(connection, message);
+ const server = music.MusicVariables(client, message.member.guild.id);
+ const time = moment().startOf('day').add(d).format('HH:mm:ss');
+ server.queue.push({
+ url: video.url,
+ title: video.title,
+ thumbnail: video.thumbnails.high.url,
+ duration: video.durationSeconds,
+ requested: message.author.mention,
+ playing: false
});
- return null;
-}};
+ const { RichEmbed } = require('discord.js');
+
+ const embed = new RichEmbed()
+ .setTitle('A song has been queued')
+ .setAuthor(video.title, video.thumbnails.high.url)
+ .setColor(0x00afff)
+ .setTimestamp()
+ .addField('Title', video.title)
+ .addField('Link', video.url)
+ .addField('Duration', time)
+ .setThumbnail(video.thumbnails.high.url)
+ .setFootor('Beat Music Player');
+ await message.channel.send({embed});
+ if (!client.voiceConnections.get(message.member.guild.id))
+ message.member.voiceChannel.join().then(function(connection) {
+ music.playYT(client, connection, message);
+ });
+ return null;
+ }};
exports.conf = {
aliases: [],
diff --git a/src/music.js b/src/music.js
new file mode 100644
index 0000000..81c6326
--- /dev/null
+++ b/src/music.js
@@ -0,0 +1,67 @@
+// Created by jtsshieh#6434 in the BonGon project: https://github.com/jtsshieh/BonGon
+
+const YTDL = require('ytdl-core');
+module.exports.playYT = async (bot, connection, msg) => {
+ const EventEmitter = require('events');
+ class MyEmitter extends EventEmitter {}
+ bot.musicEmit = new MyEmitter();
+
+ const server = bot.MusicVariables(msg.member.guild.id);
+
+ server.dispatcher = connection;
+
+ connection.play(YTDL(server.queue[0].url, {
+ filter: 'audioonly'
+ }));
+
+ server.nowPlaying = server.queue[0];
+ server.beforeNowPlaying = server.nowPlaying;
+
+
+ server.queue.shift();
+
+ server.nowPlaying.playing = true;
+
+ let time = 0;
+ let counter = setInterval(
+ function() {
+ time = time + 1;
+ server.dispatcher.time = time;
+ }, 1000);
+
+ bot.musicEmit.on('paused', () => {
+ clearInterval(counter);
+ });
+
+ bot.musicEmit.on('resumed',() =>{
+ counter = setInterval(
+ function() {
+ time = time + 1;
+ server.dispatcher.time = time;
+ }, 1000);
+ });
+
+ connection.once('end', function() {
+ clearInterval(counter);
+
+ if (server.queue[0] || server.beforeNowPlaying) {
+ if (server.repeat) {
+ server.queue.push(server.beforeNowPlaying);
+ }
+
+ server.nowPlaying = null;
+ bot.playYT(connection, msg);
+ }
+
+ else {
+ bot.leaveVoiceChannel(connection.channelID);
+ bot.servers[msg.member.guild.id] = null;
+ }
+ });
+};
+module.exports.MusicVariables = (bot, guildID) => {
+ if (!bot.servers[guildID]) {
+ bot.servers[guildID] = {'queue' : [], 'dispatcher': null, 'repeat': false};
+ }
+ return bot.servers[guildID];
+};