src/utils/setTimeout.ts

/**
* This file is part of SudoBot.
* 
* Copyright (C) 2021-2022 OSN Inc.
*
* SudoBot is free software; you can redistribute it and/or modify it
* under the terms of the GNU Affero General Public License as published by 
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
* 
* SudoBot is distributed in the hope that it will be useful, but
* WITHOUT ANY WARRANTY; without even the implied warranty of 
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License 
* along with SudoBot. If not, see <https://www.gnu.org/licenses/>.
*/

import path from "path";
import DiscordClient from "../client/Client";
import Timeout from "../models/Timeout";

const timeouts = new Map();

export const runTimeouts = async () => {
    const data = (await Timeout.find());

    // await console.log(data);

    if (data && data.length > 0) {
        console.log('Running timeouts...');
        for await (const row of data) {
            let timeout = await setTimeout(async () => {
                await console.log('TIMEOUT');
                await row.delete();
                await timeouts.delete(row.get('id'));
                (await import(row.get('filePath') as string)).default(DiscordClient.client, ...JSON.parse(row.get('params') as string));
            }, new Date(row.get('time') as string).getTime() - Date.now());

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

export const setTimeoutv2 = async (file: string, time: number, guild_id: string, cmd: string, ...params: any[]) => {
    await console.log('SETTING');
    const row = await Timeout.create({
        createdAt: new Date(),
        filePath: path.resolve(__dirname, '../queues', file), 
        time: new Date(Date.now() + time).toISOString(), 
        params: JSON.stringify(params), 
        guild_id, 
        cmd
    })

    const timeout = await setTimeout(async () => {
        await console.log('TIMEOUT_SET');
        await timeouts.delete(row.id);   
        await row.delete();   
        (await import(path.resolve(__dirname, '../queues', file))).default(DiscordClient.client, ...params);
    }, time);
    
    const data = {
        row,
        timeout
    };

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

export const clearTimeoutv2 = async ({ row, timeout }: any) => {
    await clearTimeout(timeout);
    await timeouts.delete(row.id);
    await row.delete();
}; 

export const getTimeout = (id: string | number) => timeouts.get(id);

export const hasTimeout = (id: string | number) => timeouts.has(id);

export const getTimeouts = () => timeouts;
1	rakinar2	577	/**
2			* This file is part of SudoBot.
3			*
4			* Copyright (C) 2021-2022 OSN Inc.
5			*
6			* SudoBot is free software; you can redistribute it and/or modify it
7			* under the terms of the GNU Affero General Public License as published by
8			* the Free Software Foundation, either version 3 of the License, or
9			* (at your option) any later version.
10			*
11			* SudoBot is distributed in the hope that it will be useful, but
12			* WITHOUT ANY WARRANTY; without even the implied warranty of
13			* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14			* GNU Affero General Public License for more details.
15			*
16			* You should have received a copy of the GNU Affero General Public License
17			* along with SudoBot. If not, see <https://www.gnu.org/licenses/>.
18			*/
19
20			import path from "path";
21			import DiscordClient from "../client/Client";
22			import Timeout from "../models/Timeout";
23
24			const timeouts = new Map();
25
26			export const runTimeouts = async () => {
27			const data = (await Timeout.find());
28
29			// await console.log(data);
30
31			if (data && data.length > 0) {
32			console.log('Running timeouts...');
33			for await (const row of data) {
34			let timeout = await setTimeout(async () => {
35			await console.log('TIMEOUT');
36			await row.delete();
37			await timeouts.delete(row.get('id'));
38			(await import(row.get('filePath') as string)).default(DiscordClient.client, ...JSON.parse(row.get('params') as string));
39			}, new Date(row.get('time') as string).getTime() - Date.now());
40
41			// await timeouts.set(row.get('id'), {
42			// row,
43			// timeout
44			// });
45			}
46			}
47			};
48
49			export const setTimeoutv2 = async (file: string, time: number, guild_id: string, cmd: string, ...params: any[]) => {
50			await console.log('SETTING');
51			const row = await Timeout.create({
52			createdAt: new Date(),
53			filePath: path.resolve(__dirname, '../queues', file),
54			time: new Date(Date.now() + time).toISOString(),
55			params: JSON.stringify(params),
56			guild_id,
57			cmd
58			})
59
60			const timeout = await setTimeout(async () => {
61			await console.log('TIMEOUT_SET');
62			await timeouts.delete(row.id);
63			await row.delete();
64			(await import(path.resolve(__dirname, '../queues', file))).default(DiscordClient.client, ...params);
65			}, time);
66
67			const data = {
68			row,
69			timeout
70			};
71
72			await timeouts.set(row.id, data);
73			return data;
74			};
75
76			export const clearTimeoutv2 = async ({ row, timeout }: any) => {
77			await clearTimeout(timeout);
78			await timeouts.delete(row.id);
79			await row.delete();
80			};
81
82			export const getTimeout = (id: string \| number) => timeouts.get(id);
83
84			export const hasTimeout = (id: string \| number) => timeouts.has(id);
85
86			export const getTimeouts = () => timeouts;