trunk/src/setTimeout.js

const path = require('path');

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

    // await console.log(data);

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

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

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

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

module.exports = { runTimeouts, setTimeoutv2 };
1	rakin	45	const path = require('path');
2
3			const runTimeouts = async () => {
4			const data = await app.db.allAsync("SELECT * FROM timeouts");
5
6			// await console.log(data);
7
8			if (data && data.length > 0) {
9			for await (const row of data) {
10			// console.log(row);
11
12			await setTimeout(async () => {
13			await console.log('TIMEOUT');
14			await app.db.runAsync("DELETE FROM timeouts WHERE id = ?", [row.id]);
15			await require(row.filePath)(...JSON.parse(row.params));
16			}, new Date(row.time).getTime() - Date.now());
17			}
18			}
19			};
20
21			const setTimeoutv2 = async (file, time, ...params) => {
22			await console.log('SETTING');
23			await app.db.allAsync("INSERT INTO timeouts(created_at, filePath, time, params) VALUES(?, ?, ?, ?)", [new Date().toISOString(), path.resolve(__dirname, '../queues', file), new Date(Date.now() + time).toISOString(), JSON.stringify(params)]);
24			const id = (await app.db.getAsync('SELECT * FROM timeouts ORDER BY id DESC LIMIT 0, 1'))?.id;
25
26			await setTimeout(async () => {
27			await console.log('TIMEOUT_SET');
28			await app.db.runAsync("DELETE FROM timeouts WHERE id = ?", [id]);
29			await require(path.resolve(__dirname, '../queues', file))(...params);
30			}, time);
31			};
32
33			module.exports = { runTimeouts, setTimeoutv2 };