trunk/src/setTimeout.js

const path = require('path');
const timeouts = new Map();

const runTimeouts = async () => {
    const data = await app.db.allAsync("SELECT * FROM timeouts");

    // await console.log(data);

    if (data && data.length > 0) {
        console.log('Running timeouts...');
        for await (const row of data) {
            // console.log(row)

            let timeout = await setTimeout(async () => {
                await console.log('TIMEOUT');
                await app.db.runAsync("DELETE FROM timeouts WHERE id = ?", [row.id]);
                await timeouts.delete(row.id);
                await require(row.filePath)(...JSON.parse(row.params));
            }, new Date(row.time).getTime() - Date.now());

            await timeouts.set(row.id, {
                row,
                timeout
            });
        }
    }
};

const setTimeoutv2 = async (file, time, guild_id, cmd, ...params) => {
    await console.log('SETTING');
    await app.db.allAsync("INSERT INTO timeouts(created_at, filePath, time, params, guild_id, cmd) VALUES(?, ?, ?, ?, ?, ?)", [new Date().toISOString(), path.resolve(__dirname, '../queues', file), new Date(Date.now() + time).toISOString(), JSON.stringify(params), guild_id, cmd]);
    const row = await app.db.getAsync('SELECT * FROM timeouts ORDER BY id DESC LIMIT 0, 1');

    const timeout = await setTimeout(async () => {
        await console.log('TIMEOUT_SET');
        await app.db.runAsync("DELETE FROM timeouts WHERE id = ?", [row.id]);
        await timeouts.delete(row.id);
        await require(path.resolve(__dirname, '../queues', file))(...params);
    }, time);
    
    const data = {
        row,
        timeout
    };

    await timeouts.set(row.id, data);
    return data;
};

const clearTimeoutv2 = async ({ row, timeout }) => {
    await clearTimeout(timeout);
    await app.db.runAsync("DELETE FROM timeouts WHERE id = ?", [row.id]);
    await timeouts.delete(row.id);
}; 

const getTimeout = id => timeouts.get(id);

const hasTimeout = id => timeouts.has(id);

const getTimeouts = () => timeouts;

module.exports = { runTimeouts, setTimeoutv2, clearTimeoutv2, getTimeout, hasTimeout, getTimeouts };
1	rakin	45	const path = require('path');
2	rakin	46	const timeouts = new Map();
3	rakin	45
4			const runTimeouts = async () => {
5			const data = await app.db.allAsync("SELECT * FROM timeouts");
6
7			// await console.log(data);
8
9			if (data && data.length > 0) {
10	rakin	46	console.log('Running timeouts...');
11	rakin	45	for await (const row of data) {
12	rakin	46	// console.log(row)
13	rakin	45
14	rakin	46	let timeout = await setTimeout(async () => {
15	rakin	45	await console.log('TIMEOUT');
16			await app.db.runAsync("DELETE FROM timeouts WHERE id = ?", [row.id]);
17	rakin	46	await timeouts.delete(row.id);
18	rakin	45	await require(row.filePath)(...JSON.parse(row.params));
19			}, new Date(row.time).getTime() - Date.now());
20	rakin	46
21			await timeouts.set(row.id, {
22			row,
23			timeout
24			});
25	rakin	45	}
26			}
27			};
28
29	rakin	49	const setTimeoutv2 = async (file, time, guild_id, cmd, ...params) => {
30	rakin	45	await console.log('SETTING');
31	rakin	49	await app.db.allAsync("INSERT INTO timeouts(created_at, filePath, time, params, guild_id, cmd) VALUES(?, ?, ?, ?, ?, ?)", [new Date().toISOString(), path.resolve(__dirname, '../queues', file), new Date(Date.now() + time).toISOString(), JSON.stringify(params), guild_id, cmd]);
32	rakin	46	const row = await app.db.getAsync('SELECT * FROM timeouts ORDER BY id DESC LIMIT 0, 1');
33	rakin	45
34	rakin	46	const timeout = await setTimeout(async () => {
35	rakin	45	await console.log('TIMEOUT_SET');
36	rakin	46	await app.db.runAsync("DELETE FROM timeouts WHERE id = ?", [row.id]);
37			await timeouts.delete(row.id);
38	rakin	45	await require(path.resolve(__dirname, '../queues', file))(...params);
39			}, time);
40	rakin	46
41			const data = {
42			row,
43			timeout
44			};
45
46			await timeouts.set(row.id, data);
47			return data;
48	rakin	45	};
49
50	rakin	46	const clearTimeoutv2 = async ({ row, timeout }) => {
51			await clearTimeout(timeout);
52			await app.db.runAsync("DELETE FROM timeouts WHERE id = ?", [row.id]);
53			await timeouts.delete(row.id);
54			};
55
56			const getTimeout = id => timeouts.get(id);
57
58			const hasTimeout = id => timeouts.has(id);
59
60			const getTimeouts = () => timeouts;
61
62			module.exports = { runTimeouts, setTimeoutv2, clearTimeoutv2, getTimeout, hasTimeout, getTimeouts };