discord-home-cinema/main.js

import { overrideConsole } from 'nodejs-better-console';
import createFastify from 'fastify';
import Eris from 'eris';

import {
    webPort,
    webApiKey,
    webRequestInterval,
    botToken,
    botWhitelist
} from './config.js';

overrideConsole();

const
    fastify = createFastify(),
    eris = new Eris(
        botToken,
        { intents: ['directMessages'] }
    );

fastify.addHook(
    'onError',
    error => console.error(error)
);

eris.on(
    'error',
    error => console.error(error)
);

let
    getUrl,
    nextRequestTimeout;

fastify.get(
    '/',
    async (
        request,
        reply
    ) => {
        if(request.query['apiKey'] !== webApiKey)
            return reply.code(401).send();
        reply.send(getUrl ? await getUrl() : undefined);
        clearTimeout(nextRequestTimeout);
        nextRequestTimeout = setTimeout(
            async () => {
                await eris.editStatus('idle');
            },
            webRequestInterval
        );
        await eris.editStatus('online');
    }
);

eris.on(
    'messageCreate',
    async message => {
        const {
            guildID,
            author: { id: authorID },
            channel: { id: channelID },
            id: messageID,
            content
        } = message;
        if(
            guildID
            ||
            !botWhitelist.includes(authorID)
        ) return;
        const reply = content => eris.createMessage(
            channelID,
            {
                content,
                messageReference: { messageID }
            }
        );
        if(content){
            try {
                new URL(content);
                getUrl = () => new Promise(async resolve => {
                    resolve(content);
                    getUrl = undefined;
                    await message.addReaction('✅');
                });
                await message.addReaction('⏳');
            }
            catch {
                await message.addReaction('❌');
            }
        }
    }
);

(async () => {
    await fastify.listen({ port: webPort });
    await Promise.all([
        eris.connect(),
        new Promise(resolve => eris.once('ready', resolve))
    ]);
    await eris.editStatus('idle');
    console.log('Ready');
})().catch(error => console.error(error));