forked from Supositware/Haha-Yes
Trying to make a queue for the ytp command
This commit is contained in:
parent
793cea3fcd
commit
db764ce166
1 changed files with 265 additions and 0 deletions
265
commands/fun/ytp.js.dev
Normal file
265
commands/fun/ytp.js.dev
Normal file
|
|
@ -0,0 +1,265 @@
|
||||||
|
const { Command } = require('discord-akairo');
|
||||||
|
const YTPGenerator = require('ytpplus-node');
|
||||||
|
const os = require('os');
|
||||||
|
const fs = require('fs');
|
||||||
|
const youtubedl = require('youtube-dl');
|
||||||
|
let queue = 0;
|
||||||
|
|
||||||
|
class ytpCommand extends Command {
|
||||||
|
constructor() {
|
||||||
|
super('ytp', {
|
||||||
|
aliases: ['ytp', 'ytpplus', 'ytp+'],
|
||||||
|
category: 'fun',
|
||||||
|
clientPermissions: ['ATTACH_FILES', 'SEND_MESSAGES'],
|
||||||
|
args: [
|
||||||
|
{
|
||||||
|
id: 'add',
|
||||||
|
match: 'flag',
|
||||||
|
flag: ['--add']
|
||||||
|
},
|
||||||
|
{
|
||||||
|
id: 'pool',
|
||||||
|
match: 'flag',
|
||||||
|
flag: ['--pool']
|
||||||
|
},
|
||||||
|
{
|
||||||
|
id: 'force',
|
||||||
|
match: 'flag',
|
||||||
|
flag: ['--force']
|
||||||
|
},
|
||||||
|
{
|
||||||
|
id: 'randomSound',
|
||||||
|
match: 'flag',
|
||||||
|
flag: ['--randomSound']
|
||||||
|
},
|
||||||
|
{
|
||||||
|
id: 'randomSoundMute',
|
||||||
|
match: 'flag',
|
||||||
|
flag: ['--randomSoundMute']
|
||||||
|
},
|
||||||
|
{
|
||||||
|
id: 'reverse',
|
||||||
|
match: 'flag',
|
||||||
|
flag: ['--reverse']
|
||||||
|
},
|
||||||
|
{
|
||||||
|
id: 'chorus',
|
||||||
|
match: 'flag',
|
||||||
|
flag: ['--chorus']
|
||||||
|
},
|
||||||
|
{
|
||||||
|
id: 'vibrato',
|
||||||
|
match: 'flag',
|
||||||
|
flag: ['--vibrato']
|
||||||
|
},
|
||||||
|
{
|
||||||
|
id: 'highPitch',
|
||||||
|
match: 'flag',
|
||||||
|
flag: ['--highPitch']
|
||||||
|
},
|
||||||
|
{
|
||||||
|
id: 'lowPitch',
|
||||||
|
match: 'flag',
|
||||||
|
flag: ['--lowPitch']
|
||||||
|
},
|
||||||
|
{
|
||||||
|
id: 'speedUp',
|
||||||
|
match: 'flag',
|
||||||
|
flag: ['--speedUp']
|
||||||
|
},
|
||||||
|
{
|
||||||
|
id: 'slowDown',
|
||||||
|
match: 'flag',
|
||||||
|
flag: ['--slowDown']
|
||||||
|
},
|
||||||
|
{
|
||||||
|
id: 'dance',
|
||||||
|
match: 'flag',
|
||||||
|
flag: ['--dance']
|
||||||
|
},
|
||||||
|
{
|
||||||
|
id: 'squidward',
|
||||||
|
match: 'flag',
|
||||||
|
flag: ['--squidward']
|
||||||
|
},
|
||||||
|
{
|
||||||
|
id: 'debug',
|
||||||
|
match: 'flag',
|
||||||
|
flag: ['--debug']
|
||||||
|
},
|
||||||
|
{
|
||||||
|
id: 'link',
|
||||||
|
type: 'string'
|
||||||
|
}
|
||||||
|
],
|
||||||
|
description: {
|
||||||
|
content: 'Generate random ytp | --add with a link or attachment to add a video to the pool, only .mp4 work | --pool to see how many vid there is currently in the pool | --force to make the command work outside of nsfw channel BE AWARE THAT IT WON\'T CHANGE THE FINAL RESULT SO NSFW CAN STILL HAPPEN',
|
||||||
|
usage: '',
|
||||||
|
examples: ['']
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
async exec(message, args) {
|
||||||
|
console.log(queue);
|
||||||
|
let prefix = this.client.commandHandler.prefix[0];
|
||||||
|
let MAX_CLIPS = 20;
|
||||||
|
|
||||||
|
if (args.pool) {
|
||||||
|
let mp4 = [];
|
||||||
|
fs.readdirSync('./asset/ytp/userVid/').forEach(file => {
|
||||||
|
if (file.endsWith('mp4')) {
|
||||||
|
mp4.push(file);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
return message.channel.send(`There is currently ${mp4.length} videos, you can add yours by doing \`\`${prefix}ytp --add (link or attachment)\`\``);
|
||||||
|
}
|
||||||
|
|
||||||
|
if (args.add) {
|
||||||
|
let loadingmsg = await message.channel.send('Downloading <a:loadingmin:527579785212329984>');
|
||||||
|
let Attachment = (message.attachments).array();
|
||||||
|
let url = args.link;
|
||||||
|
// Get attachment link
|
||||||
|
if (Attachment[0] && !args.link) {
|
||||||
|
url = Attachment[0].url;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (url) {
|
||||||
|
return youtubedl.exec(url, ['--no-playlist','--max-filesize', '50m', '--format=mp4', '-o', `./asset/ytp/userVid/${message.id}.mp4`], {}, function(err, output) {
|
||||||
|
console.log(output);
|
||||||
|
if (err) {
|
||||||
|
console.error(err);
|
||||||
|
loadingmsg.delete();
|
||||||
|
return message.channel.send('An error has occured, I can\'t download from the link you provided. Is it an mp4?');
|
||||||
|
} else {
|
||||||
|
if (output[2]) {
|
||||||
|
if (output[2].includes('File is larger than max-filesize')) {
|
||||||
|
loadingmsg.delete();
|
||||||
|
return message.channel.send(output[2]);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
let mp4 = [];
|
||||||
|
fs.readdirSync('./asset/ytp/userVid/').forEach(file => {
|
||||||
|
if (file.endsWith('mp4')) {
|
||||||
|
mp4.push(file);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
loadingmsg.delete();
|
||||||
|
return message.reply(`Video sucessfully added to the pool! There is now ${mp4.length} videos`);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
} else {
|
||||||
|
loadingmsg.delete();
|
||||||
|
return message.channel.send('You need a valid video link!');
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
if (!message.channel.nsfw && !args.force) return message.channel.send(`Please execute this command in an NSFW channel ( Content might not be NSFW but since the video are user submitted better safe than sorry ) OR do \`\`${prefix}ytp --force\`\` to make the command work outside of nsfw channel BE AWARE THAT IT WON'T CHANGE THE FINAL RESULT SO NSFW CAN STILL HAPPEN`);
|
||||||
|
|
||||||
|
if (queue >= 1) {
|
||||||
|
let curQueue = queue;
|
||||||
|
message.channel.send(`The execution of this command has been placed in a queue, you are #${curQueue}/${queue} in the queue`);
|
||||||
|
|
||||||
|
let reminder = setInterval(() => {
|
||||||
|
message.channel.send(`The execution of this command has been placed in a queue, you are #${curQueue}/${queue} in the queue`);
|
||||||
|
}, 30000);
|
||||||
|
|
||||||
|
let checkQueue = setInterval(() => {
|
||||||
|
console.log(queue);
|
||||||
|
console.log(curQueue);
|
||||||
|
if (curQueue < 1) {
|
||||||
|
clearInterval(checkQueue);
|
||||||
|
clearInterval(reminder);
|
||||||
|
makeYTP();
|
||||||
|
}
|
||||||
|
if (queue < curQueue) curQueue = queue;
|
||||||
|
}, 1000);
|
||||||
|
//queue++;
|
||||||
|
} else {
|
||||||
|
//queue++;
|
||||||
|
makeYTP();
|
||||||
|
}
|
||||||
|
|
||||||
|
queue++;
|
||||||
|
|
||||||
|
async function makeYTP() {
|
||||||
|
console.log('making ytp');
|
||||||
|
// Read userVid folder and select random vid and only take .mp4
|
||||||
|
let mp4 = [];
|
||||||
|
let asset = [];
|
||||||
|
let files = fs.readdirSync('./asset/ytp/userVid/');
|
||||||
|
// Count number of total vid
|
||||||
|
files.forEach(file => {
|
||||||
|
if (file.endsWith('mp4')) {
|
||||||
|
mp4.push(file);
|
||||||
|
}
|
||||||
|
});
|
||||||
|
// Select random vid depending on the amount of MAX_CLIPS
|
||||||
|
for (let i = 0; i < MAX_CLIPS; i++) {
|
||||||
|
let random = Math.floor(Math.random() * files.length);
|
||||||
|
let vid = `./asset/ytp/userVid/${files[random]}`;
|
||||||
|
if (files[random].endsWith('mp4')) {
|
||||||
|
if (!asset.includes(vid)) {
|
||||||
|
asset.push(vid);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
let loadingmsg = await message.channel.send(`Processing, this can take a **long** time, i'll ping you when i finished <a:loadingmin:527579785212329984>\nSome info: There is currently ${mp4.length} videos, you can add yours by doing \`\`${prefix}ytp --add (link or attachment)\`\``);
|
||||||
|
|
||||||
|
|
||||||
|
let options = {
|
||||||
|
debug: args.debug,
|
||||||
|
MAX_STREAM_DURATION: args.link ? args.link : Math.floor((Math.random() * 3) + 1), // Random duration of video clip
|
||||||
|
sources: './asset/ytp/sources/',
|
||||||
|
sounds: './asset/ytp/sounds/',
|
||||||
|
music: './asset/ytp/music/',
|
||||||
|
resources: './asset/ytp/resources/',
|
||||||
|
temp: os.tmpdir(),
|
||||||
|
sourceList: asset,
|
||||||
|
outro: './asset/ytp/outro.mp4', // Need an outro or it won't work
|
||||||
|
OUTPUT_FILE: `${os.tmpdir()}/${message.id}_YTP.mp4`,
|
||||||
|
MAX_CLIPS: MAX_CLIPS,
|
||||||
|
transitions: true,
|
||||||
|
effects: {
|
||||||
|
effect_RandomSound: args.randomSound,
|
||||||
|
effect_RandomSoundMute: args.randomSoundMute,
|
||||||
|
effect_Reverse: args.reverse,
|
||||||
|
effect_Chorus: args.chorus,
|
||||||
|
effect_Vibrato: args.vibrato,
|
||||||
|
effect_HighPitch: args.highPitch,
|
||||||
|
effect_LowPitch: args.lowPitch,
|
||||||
|
effect_SpeedUp: args.speedUp,
|
||||||
|
effect_SlowDown: args.slowDown,
|
||||||
|
effect_Dance: args.dance,
|
||||||
|
effect_Squidward: args.squidward
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
new YTPGenerator().configurateAndGo(options)
|
||||||
|
.then(() => {
|
||||||
|
queue--;
|
||||||
|
loadingmsg.delete();
|
||||||
|
return message.reply('Here is your YTP!', {files: [`${os.tmpdir()}/${message.id}_YTP.mp4`]})
|
||||||
|
.catch(() => {
|
||||||
|
return message.channel.send('Whoops, look like the vid might be too big for discord, my bad, please try again');
|
||||||
|
});
|
||||||
|
})
|
||||||
|
.catch(err => {
|
||||||
|
queue--;
|
||||||
|
console.error(err);
|
||||||
|
loadingmsg.delete();
|
||||||
|
return message.reply('Oh no! An error has occured!');
|
||||||
|
});
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
module.exports = ytpCommand;
|
||||||
Loading…
Reference in a new issue