Cristiano Pires
2 years ago
parent
94c279b70c
commit
d26096eea2
@ -0,0 +1,112 @@
|
||||
const {Command, Random, ErrorMessage, ErrorType} = require('../../lib.js')
|
||||
const {EmbedBuilder, ActionRowBuilder, ButtonBuilder, ButtonStyle} = require('discord.js');
|
||||
const xmlparser = require('xml-js')
|
||||
const feedM = require('../../models/feeds');
|
||||
class setYTFeed extends Command{
|
||||
constructor(client){
|
||||
super(client, {
|
||||
name: 'setFeed',
|
||||
aliases:['setYTFeed','setytf', 'setYTF'],
|
||||
description: 'Sets the message channel where a defined youtube channel feed will be displayed. (Order: YTchannelId, discord channel id, Costum message to display when a new video is released.) You can only assign one feed per channel.',
|
||||
needsAdmin:true,
|
||||
});
|
||||
this.client = client;
|
||||
}
|
||||
async run(message, args)
|
||||
{
|
||||
|
||||
// Validate the command arguments
|
||||
const validationResult = await this.confirmArgs(message, args);
|
||||
if (validationResult.error) return new ErrorMessage(this.client).send(ErrorType.Arguments, message, [validationResult.error])
|
||||
var feed = new feedM();
|
||||
feed.ChannelId = validationResult.channelId
|
||||
feed.YTChannelId = validationResult.YTChannelId;
|
||||
feed.CostumMessage = args[3]?args.splice(2).join(' '):'New video:';
|
||||
feed.save(err=>
|
||||
{
|
||||
if(err)console.log(err);
|
||||
})
|
||||
const embed = new EmbedBuilder()
|
||||
const randomID = Random();
|
||||
embed.setFooter({text:'Rem-chan on ', iconURL:"https://i.imgur.com/g6FSNhL.png"})
|
||||
embed.setAuthor({name:"Rem-chan", iconURL:"https://i.imgur.com/g6FSNhL.png",url:'https://rem.wordfights.com/addtodiscord'});
|
||||
embed.setColor(0x110809);
|
||||
embed.setTimestamp()
|
||||
embed.setTitle(`${validationResult.name}'s feed defined on channel ${validationResult.channelName}.`)
|
||||
if(args!='New video:') embed.setDescription(`With the costum message: \n ${feed.CostumMessage}`)
|
||||
|
||||
const row = new ActionRowBuilder()
|
||||
.addComponents(
|
||||
new ButtonBuilder()
|
||||
.setCustomId(randomID)
|
||||
.setLabel('Remove this.')
|
||||
.setStyle(ButtonStyle.Primary),
|
||||
);
|
||||
const filter = i => i.customId === randomID;
|
||||
message.channel.send({embeds: [embed], components: [row] });
|
||||
const collector = message.channel.createMessageComponentCollector({ filter, time: 60000 });
|
||||
collector.on('collect', async m =>
|
||||
{
|
||||
_delete(message, m);
|
||||
});
|
||||
collector.on('end', async m=>
|
||||
{
|
||||
_delete(message,m);
|
||||
})
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
*
|
||||
* @param {Map<String,String>} message
|
||||
* @param {Array<String>} args
|
||||
* @returns {RoleModel}
|
||||
*
|
||||
*/
|
||||
async confirmArgs(message,args)
|
||||
{
|
||||
if(args.length<2) return {error:'Unsuficient amount of arguments.'}
|
||||
var YTChannelId = args[0];
|
||||
var channelId = args[1];
|
||||
const exists = await this.client.channels.fetch(channelId).then(channel=>{return channel }).catch(()=>{return });
|
||||
if(!exists) return {error:'Provided channel id does not exist.'}
|
||||
|
||||
var name = await fetch(`https://www.youtube.com/feeds/videos.xml?channel_id=${YTChannelId}`)
|
||||
.then(handleResponse)
|
||||
.then(handleData)
|
||||
.catch(handleError);
|
||||
function handleResponse(response)
|
||||
{
|
||||
return response.text()
|
||||
}
|
||||
function handleError(error)
|
||||
{
|
||||
return error;
|
||||
}
|
||||
function handleData(data)
|
||||
{
|
||||
data = xmlparser.xml2json(data,
|
||||
{
|
||||
compact: true,
|
||||
space: 4
|
||||
});
|
||||
data = JSON.parse(data);
|
||||
return data.feed.author.name._text
|
||||
}
|
||||
if(!name) return {error:'Provided Youtube channel id does not exist.'}
|
||||
const channelInUse = await feedM.findOne({ChannelId:channelId}).then(channel=>{return channel}).catch(()=>{return []});
|
||||
if(channelInUse) return {error:'Discord channel already in use. Please choose another.'}
|
||||
return {YTChannelId, channelId, name, channelName:exists.name}
|
||||
}
|
||||
|
||||
}module.exports = setYTFeed;
|
||||
|
||||
function _delete(message, m)
|
||||
{
|
||||
try {
|
||||
message.delete();
|
||||
m.delete();
|
||||
} catch (error) {
|
||||
console.log('SetYTID: Error deleting the message:',error)
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,17 @@
|
||||
const mongoose = require('mongoose');
|
||||
const Schema = mongoose.Schema;
|
||||
|
||||
let feed =
|
||||
new Schema(
|
||||
{
|
||||
ChannelId: {type:String, required: true},
|
||||
YTChannelId: {type:String, required: true},
|
||||
CostumMessage:{type:String, required:false},
|
||||
}
|
||||
);
|
||||
|
||||
const Feed = module.exports = mongoose.model('feed', feed);
|
||||
module.exports.get = (callback, limit)=>
|
||||
{
|
||||
Feed.find(callback).limit(limit);
|
||||
}
|
||||
@ -1,42 +1,53 @@
|
||||
const {Client, GatewayIntentBits,Partials, AtivityType} = require('./lib.js');
|
||||
const mongoose = require('mongoose');
|
||||
const mongoDB = process.env.mongoDB;
|
||||
|
||||
const bot = new Client(
|
||||
{
|
||||
intents:
|
||||
[
|
||||
GatewayIntentBits.Guilds,
|
||||
GatewayIntentBits.GuildMembers,
|
||||
GatewayIntentBits.GuildBans,
|
||||
GatewayIntentBits.GuildEmojisAndStickers,
|
||||
GatewayIntentBits.GuildIntegrations ,
|
||||
GatewayIntentBits.GuildWebhooks ,
|
||||
GatewayIntentBits.GuildInvites ,
|
||||
GatewayIntentBits.GuildVoiceStates,
|
||||
GatewayIntentBits.GuildPresences,
|
||||
GatewayIntentBits.GuildMessages,
|
||||
GatewayIntentBits.GuildMessageReactions,
|
||||
GatewayIntentBits.GuildMessageTyping,
|
||||
GatewayIntentBits.DirectMessages,
|
||||
GatewayIntentBits.DirectMessageReactions,
|
||||
GatewayIntentBits.DirectMessageTyping,
|
||||
GatewayIntentBits.MessageContent,
|
||||
GatewayIntentBits.GuildScheduledEvents,
|
||||
GatewayIntentBits.AutoModerationConfiguration,
|
||||
GatewayIntentBits.AutoModerationExecution
|
||||
],
|
||||
partials:
|
||||
[
|
||||
Partials.Reaction,
|
||||
Partials.Message
|
||||
]
|
||||
}
|
||||
)
|
||||
bot.login(process.env.discord_token);
|
||||
bot.on('ready', ()=>
|
||||
var channelId = 'UCRsrOaKEdy0ymNqR7Urqa2Q'
|
||||
const xmlparser = require('xml-js');
|
||||
(async function ()
|
||||
{
|
||||
mongoose.Promise = global.Promise;
|
||||
mongoose.connect(mongoDB).catch(err=>console.log(err));
|
||||
console.log('Ready');
|
||||
});
|
||||
var coiso = await fetch(`https://www.youtube.com/feeds/videos.xml?channel_id=${channelId}`)
|
||||
.then(handleResponse)
|
||||
.then(handleData)
|
||||
.catch(handleError);
|
||||
function handleResponse(response)
|
||||
{
|
||||
return response.text()
|
||||
}
|
||||
function handleError(error)
|
||||
{
|
||||
return error;
|
||||
}
|
||||
function handleData(data)
|
||||
{
|
||||
data = xmlparser.xml2json(data,
|
||||
{
|
||||
compact: true,
|
||||
space: 4
|
||||
});
|
||||
data = JSON.parse(data)
|
||||
// console.log({
|
||||
// channelName:data.feed.author.name._text,
|
||||
// lasVid:
|
||||
// {
|
||||
// link:data.feed.entry[0].link._attributes.href,
|
||||
// published:data.feed.entry[0].published._text
|
||||
// }
|
||||
// })
|
||||
console.log(data.feed.entry[0])
|
||||
|
||||
return {
|
||||
channelName:data.feed.author.name._text,
|
||||
lasVid:
|
||||
{
|
||||
link:data.feed.entry[0].link._attributes.href,
|
||||
published:data.feed.entry[0].published._text,
|
||||
link:data.feed.entry[0].link._attributes.href,
|
||||
image:data.feed.entry[0].link._attributes.href.split('=')[1],
|
||||
title:data.feed.entry[0].title._text,
|
||||
author:{
|
||||
name:data.feed.entry[0].author.name._text,
|
||||
url:data.feed.entry[0].author.url._text
|
||||
}
|
||||
|
||||
}
|
||||
}
|
||||
}
|
||||
//console.log(coiso, coiso.channelName)
|
||||
})()
|
||||
Loading…
Reference in new issue