bot.js

const Ruqqus = require('ruqqus-js')
const fs = require('fs')
const mongoose = require('mongoose')
const { hasCommand, getCommands, sleep } = require('./helpers/tools')
const { getComic, getLatestComic } = require('./helpers/comic')
require('dotenv').config();
const chalk = require('chalk');
const log = console.log;
var db = JSON.parse(fs.readFileSync(process.env.JSONDB).toString());

mongoose.connect(process.env.DBURL, {
	useCreateIndex: true,
	useNewUrlParser: true,
	useUnifiedTopology: true
})
	.then(() => console.log('Connected to xkcd database'))
	.catch((err) => console.log(err));

const prefix = process.env.PREFIX

const client = new Ruqqus.Client({
	id: process.env.CLIENT_ID,
	token: process.env.CLIENT_SECRET,
	refresh: process.env.REFRESH_TOKEN,
	agent: process.env.AGENT,

})

var commands = getCommands()
commands.forEach(c => log(`Registered command: ${chalk.green(c.command.name)}`))

client.on("login", () => {
	check()
	log('Logged in');
});

client.on('comment', (comment) => {
	const commentText = comment.content.text
	if (commentText.startsWith(prefix)) {
		log(`${chalk.red('COMMENT')}: ${chalk.greenBright(comment.content.text)} - ${chalk.red('AUTHOR')}: ${chalk.greenBright(comment.author.username)} - ${chalk.red('GUILD')}: +${chalk.greenBright(comment.post.guild.name)} - ${chalk.red('POST')}: ${chalk.greenBright(comment.post.full_link)}`)
		const content = commentText.substring(prefix.length + 1, commentText.length)
		if (!(content.length > 1)) {
			getLatestComic().then((res) => {
				comment.reply(`Here is the latest XKCD comic:  <br>  ![](${res.img})`);
			})

		}
		else if (!isNaN(Number(content))) {
			getComic(content, db).then((res) => {
				comment.reply(`You requested XKCD comic number ${content}, here it is:  <br>  ![](${res.img})`);
			}).catch(num => {
				log(`${num} out of range`)
			})

		}
		else {
			const args = content.trim().split(/ +/);
			const command = args.shift().toLowerCase();

			hasCommand(commands, command)
				.then(c => {
					c.command.execute(client, comment, args, db)
					log(`run command: ${command}`)
				})
				.catch(c => {
					log(c)
					log(`Invalid command ${command}`)
				})
		}
	}
})

process.on('unhandledRejection', (error) => {
	if (!Boolean(process.env.PRODUCTION)) {
		log(error)
	}
	return
})


/* Check for new xkcd every 6 hours*/
setInterval(() => {
	check()

}, 21600000)


if (db.scrap) {
	var i = 0
	setInterval(() => {
		i++
		scrap(i)

	}, 500)
}


function check() {
	getLatestComic().then(res => {
		if (db.latest.num < res.num) {
			db.latest.num = res.num
			try {
				scrap(res.num)
				sleep(5000)
				log(`Scraped and added comic ${res.num} to the database`)
			} catch (error) {
				log(`Failed to scrap comic ${res.num}`)
				log(error)
			}

			fs.writeFile(process.env.JSONDB, JSON.stringify(db), (err) => {
				if (err) return log(err)
				log(`Saved latest comic to the database (${res.num})`)
			});

			client.guilds.fetch('xkcd').then(guild => {

				guild.post(`${res.title} #${res.num}`, { body: `${res.alt}<br>  <hr>  <br>Date: ${res.month}/${res.day}/${res.year}<br>https://xkcd.com/${res.num}`, url: res.img })
				log('Posted new XKCD')
			});


		}

	})
}

function scrap(num) {
	hasCommand(commands, 'scrap')
		.then(c => {
			c.command.execute(client, '', [num], db)
		})
		.catch(c => {
			log(`Could not scrap comic ${num}`)
		})
}