events/message/MessageCreateEvent.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 BaseEvent from '../../utils/structures/BaseEvent';
import { FileOptions, Message } from 'discord.js';
import DiscordClient from '../../client/Client';
import CommandOptions from '../../types/CommandOptions';
import path from 'path';
import MessageEmbed from '../../client/MessageEmbed';
import { emoji } from '../../utils/Emoji';
import { isDisabledServer } from '../../utils/util';

export default class MessageCreateEvent extends BaseEvent {
    constructor() {
        super('messageCreate');
    }

    async run(client: DiscordClient, message: Message) {
        if (message.author.bot || !message.guild || message.channel.type === 'DM') 
            return;

        if (isDisabledServer(message.guildId!)) {
            if (message.content.startsWith(client.config.props[message.guildId!].prefix)) {
                const [cmdName, ...args] = await message.content
                    .slice(client.config.props[message.guildId!].prefix.length)
                    .trim()
                    .split(/ +/);
                    
                const command = client.commands.get(cmdName.toLowerCase());
    
                if (command && command.supportsLegacy) {
                    message.reply({
                        content: `This service was terminated in this server. Learn more at [Why did my server got terminated](https://docs.sudobot.onesoftnet.eu.org/legal/why_did_my_server_get_terminated/)?`
                    }).catch(console.error);
                }
            }

            return;
        }

        await client.setMessage(message);

        const boostTypes = ['USER_PREMIUM_GUILD_SUBSCRIPTION', 'USER_PREMIUM_GUILD_SUBSCRIPTION_TIER_1', 'USER_PREMIUM_GUILD_SUBSCRIPTION_TIER_2', 'USER_PREMIUM_GUILD_SUBSCRIPTION_TIER_3'];
        
        if (boostTypes.includes(message.type)) {
            console.log('Server boosted');
            client.logger.onServerBoost(message.member!, message.type === 'USER_PREMIUM_GUILD_SUBSCRIPTION_TIER_1' ? 1 : (
                message.type === 'USER_PREMIUM_GUILD_SUBSCRIPTION_TIER_2' ? 2 : (
                    message.type === 'USER_PREMIUM_GUILD_SUBSCRIPTION_TIER_3' ? 3 : 0
                )
            )).catch(console.error);
        }

        await client.commonService.run(message);
        await client.spamFilter.start(message);
        await client.messageFilter.start(message);
        await client.messageRules.onMessageCreate(message);
        client.aiMessageFilter.scanMessage(message).catch(console.log);
        await client.autoResponder.run(message);

        if (client.aiChat.enabled && message.content.trim() !== '' && message.mentions.users.has(client.user!.id)) {
            if (message.content.length >= 2000) {
                message.reply(`${emoji('error')} Message content is too long.`).catch(console.log);
            }
            else {
                await message.channel.sendTyping();
                const reply = await client.aiChat.generateReply(message.content, message);
                message.reply(reply ?? `${emoji('error')} An error has occurred.`).catch(console.log);
            }            
        }
        
        if (message.content.startsWith(client.config.get('prefix'))) {
            const [cmdName, ...args] = await message.content
                .slice(client.config.get('prefix').length)
                .trim()
                .split(/ +/);
                
            const command = await client.commands.get(cmdName.toLowerCase());

            if (command && command.supportsLegacy) {
                const allowed = await client.auth.verify(message.member!, command);
                
                if (allowed) {
                    if (!(await client.cooldown.onMessageCreate(message, command))) {
                        console.log(`Skipping execution of command \'${cmdName}\' - Cooldown`);
                        return;
                    }

                    const options = {
                        cmdName,
                        args,
                        argv: [cmdName, ...args],
                        normalArgs: args.filter(a => a[0] !== '-'),
                        options: args.filter(a => a[0] === '-'),
                        isInteraction: false
                    } as CommandOptions;
                    
                    await command.execute(client, message, options);    
                }
                else {
                    await message.reply({
                        embeds: [
                            new MessageEmbed()
                            .setColor('#f14a60')
                            .setDescription(":x: You don't have permission to run this command.")
                        ]
                    });
                }

                return;
            }
            
            const snippet = await client.snippetManager.getParsed(message.guild!.id, cmdName.toLowerCase());

            if (snippet) {                
                try {
                    await message.channel.send({
                        content: snippet.content.trim() === '' ? undefined : snippet.content,
                        files: snippet.files.map(name => {
                            return {
                                name,
                                attachment: path.resolve(process.env.SUDO_PREFIX ?? path.join(__dirname, '../../..'), 'storage', name)
                            } as FileOptions
                        }),
                        embeds: snippet.embeds
                    });
                }
                catch (e) {
                    console.log(e);                    
                }

                return;
            }
        }

        await client.afkEngine.start(message);
        await client.utils.checkStaffAway(message).catch(console.error);
    }
}
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 BaseEvent from '../../utils/structures/BaseEvent';
21			import { FileOptions, Message } from 'discord.js';
22			import DiscordClient from '../../client/Client';
23			import CommandOptions from '../../types/CommandOptions';
24			import path from 'path';
25			import MessageEmbed from '../../client/MessageEmbed';
26			import { emoji } from '../../utils/Emoji';
27			import { isDisabledServer } from '../../utils/util';
28
29			export default class MessageCreateEvent extends BaseEvent {
30			constructor() {
31			super('messageCreate');
32			}
33
34			async run(client: DiscordClient, message: Message) {
35			if (message.author.bot \|\| !message.guild \|\| message.channel.type === 'DM')
36			return;
37
38			if (isDisabledServer(message.guildId!)) {
39			if (message.content.startsWith(client.config.props[message.guildId!].prefix)) {
40			const [cmdName, ...args] = await message.content
41			.slice(client.config.props[message.guildId!].prefix.length)
42			.trim()
43			.split(/ +/);
44
45			const command = client.commands.get(cmdName.toLowerCase());
46
47			if (command && command.supportsLegacy) {
48			message.reply({
49			content: `This service was terminated in this server. Learn more at [Why did my server got terminated](https://docs.sudobot.onesoftnet.eu.org/legal/why_did_my_server_get_terminated/)?`
50			}).catch(console.error);
51			}
52			}
53
54			return;
55			}
56
57			await client.setMessage(message);
58
59			const boostTypes = ['USER_PREMIUM_GUILD_SUBSCRIPTION', 'USER_PREMIUM_GUILD_SUBSCRIPTION_TIER_1', 'USER_PREMIUM_GUILD_SUBSCRIPTION_TIER_2', 'USER_PREMIUM_GUILD_SUBSCRIPTION_TIER_3'];
60
61			if (boostTypes.includes(message.type)) {
62			console.log('Server boosted');
63			client.logger.onServerBoost(message.member!, message.type === 'USER_PREMIUM_GUILD_SUBSCRIPTION_TIER_1' ? 1 : (
64			message.type === 'USER_PREMIUM_GUILD_SUBSCRIPTION_TIER_2' ? 2 : (
65			message.type === 'USER_PREMIUM_GUILD_SUBSCRIPTION_TIER_3' ? 3 : 0
66			)
67			)).catch(console.error);
68			}
69
70			await client.commonService.run(message);
71			await client.spamFilter.start(message);
72			await client.messageFilter.start(message);
73			await client.messageRules.onMessageCreate(message);
74			client.aiMessageFilter.scanMessage(message).catch(console.log);
75			await client.autoResponder.run(message);
76
77			if (client.aiChat.enabled && message.content.trim() !== '' && message.mentions.users.has(client.user!.id)) {
78			if (message.content.length >= 2000) {
79			message.reply(`${emoji('error')} Message content is too long.`).catch(console.log);
80			}
81			else {
82			await message.channel.sendTyping();
83			const reply = await client.aiChat.generateReply(message.content, message);
84			message.reply(reply ?? `${emoji('error')} An error has occurred.`).catch(console.log);
85			}
86			}
87
88			if (message.content.startsWith(client.config.get('prefix'))) {
89			const [cmdName, ...args] = await message.content
90			.slice(client.config.get('prefix').length)
91			.trim()
92			.split(/ +/);
93
94			const command = await client.commands.get(cmdName.toLowerCase());
95
96			if (command && command.supportsLegacy) {
97			const allowed = await client.auth.verify(message.member!, command);
98
99			if (allowed) {
100			if (!(await client.cooldown.onMessageCreate(message, command))) {
101			console.log(`Skipping execution of command \'${cmdName}\' - Cooldown`);
102			return;
103			}
104
105			const options = {
106			cmdName,
107			args,
108			argv: [cmdName, ...args],
109			normalArgs: args.filter(a => a[0] !== '-'),
110			options: args.filter(a => a[0] === '-'),
111			isInteraction: false
112			} as CommandOptions;
113
114			await command.execute(client, message, options);
115			}
116			else {
117			await message.reply({
118			embeds: [
119			new MessageEmbed()
120			.setColor('#f14a60')
121			.setDescription(":x: You don't have permission to run this command.")
122			]
123			});
124			}
125
126			return;
127			}
128
129			const snippet = await client.snippetManager.getParsed(message.guild!.id, cmdName.toLowerCase());
130
131			if (snippet) {
132			try {
133			await message.channel.send({
134			content: snippet.content.trim() === '' ? undefined : snippet.content,
135			files: snippet.files.map(name => {
136			return {
137			name,
138			attachment: path.resolve(process.env.SUDO_PREFIX ?? path.join(__dirname, '../../..'), 'storage', name)
139			} as FileOptions
140			}),
141			embeds: snippet.embeds
142			});
143			}
144			catch (e) {
145			console.log(e);
146			}
147
148			return;
149			}
150			}
151
152			await client.afkEngine.start(message);
153			await client.utils.checkStaffAway(message).catch(console.error);
154			}
155			}