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	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 };