trunk/src/App.js

const { Client, Intents } = require("discord.js");
const { config } = require("dotenv");
const CommandManager = require("./CommandManager");
const path = require("path");
const fs = require("fs");
const Config = require("./Config");
const Database = require("./Database");
const Logger = require("./Logger");
const SpamFilter = require("./SpamFilter");
const server = require("./server");
const AntiRaid = require("./AntiRaid");
const MessageFilter = require("./MessageFilter");
const { random } = require("../commands/pixabay");
const AFKEngine = require("./AFKEngine");

class App {
    constructor(rootdir) {
        global.app = App.app = this;
        this.rootdir = rootdir;
        this.loadConfig();
        this.env = process.env;

        this.client = new Client({
            partials: ["CHANNEL"],
            intents: [
                Intents.FLAGS.GUILDS,
                Intents.FLAGS.GUILD_MESSAGES,
                Intents.FLAGS.DIRECT_MESSAGES, 
                Intents.FLAGS.DIRECT_MESSAGE_TYPING,
                Intents.FLAGS.GUILD_PRESENCES,
                Intents.FLAGS.GUILD_MEMBERS,
                Intents.FLAGS.GUILD_BANS
            ]
        });

        this.config = new Config();
        this.db = new Database(path.resolve(__dirname, '..', 'database.db'));
        this.commandManager = new CommandManager(path.resolve(__dirname, rootdir, "commands"));
        this.logger = new Logger();
        this.spamFilter = new SpamFilter();
        this.antiRaid = new AntiRaid();
        this.messageFilter = new MessageFilter();
        this.afkEngine = new AFKEngine();
        this.boot();
    }

    boot() {
        this.on('ready', () => {
            console.log("Logged in as " + this.client.user.tag);

            this.client.user.setStatus(random(['dnd', 'idle']));
            this.client.user.setActivity("over the server", { type: "WATCHING" });

            server();
        });

        this.on('messageCreate', async (message) => {
            if (message.author.bot || !message.guild || message.channel.type == 'dm') {
                return;
            }

            await (this.msg = message);
            
            await this.spamFilter.start(message);
            await this.messageFilter.start(message, this.commandManager);

            await this.commandManager.setMessage(message);

            const valid = await this.commandManager.valid();
            const has = await this.commandManager.has();
            const snippet = await this.commandManager.snippet();
            const allowed = await this.commandManager.verify();
            
            if (valid && has && allowed) {
                await this.exec();
            }
            else if (valid && snippet !== undefined) {
                await message.channel.send({
                    content: snippet.content,
                    files: snippet.files.map(f => {
                        return {
                            attachment: path.resolve(__dirname, '..', 'storage', f)
                        }
                    })
                });
            }
            else if (valid && !has) {
                await this.commandManager.notFound();
            }
            else if (valid && has && !allowed) {
                await this.commandManager.notAllowed();
            }
            else if(!valid) {
                await this.afkEngine.start(message);
            }
        });

        this.on("messageUpdate", async (oldMessage, newMessage) => {
            if (oldMessage.author.bot || oldMessage.content === newMessage.content)
                return;

            await this.logger.logEdit(oldMessage, newMessage);
        });


        this.on('guildBanAdd', async (ban) => {
            console.log('test');
            await this.logger.logBanned(ban);
        });

        this.on('guildBanRemove', async (ban) => {
            console.log('test');
            await this.logger.logUnbanned(ban);
        });

        this.on("messageDelete", async (message) => {
            if (message.author.bot)
                return;

            await this.logger.logDelete(message);
        });

        this.on("guildCreate", guild => {
            console.log("Joined a new guild: " + guild.name);

            this.config.props[guild.id] = {
                prefix: "-",
                debug: false,
            };

            this.config.write();
        })
        
        this.on("guildDelete", guild => {
            console.log("Left a guild: " + guild.name);
            delete this.config.props[guild.id];
            this.config.write();
        })

        this.on('guildMemberAdd', async (member) => {
            console.log('Joined');
            await this.antiRaid.start(member);
            await this.logger.logJoined(member);
        });

        this.on('guildMemberRemove', async (member) => {
            await this.logger.logLeft(member);
        });
    }

    loadConfig() {
        if (fs.existsSync(path.join(__dirname, this.rootdir, '.env'))) {
            console.log("Loading .env file");
            config();
        }
    }

    on(event, handler) {
        this.client.on(event, handler);
    }

    exec() {
        this.commandManager.exec();
    }

    run() {
        this.client.login(process.env.TOKEN);
    }

    tempFileCreate(name) {
        const fullname = path.join(__dirname, '..', 'tmp', name);
        const file = fs.createWriteStream(fullname);

        return {
            name: fullname,
            file
        };
    }
}

module.exports = App;
1	rakin	5	const { Client, Intents } = require("discord.js");
2			const { config } = require("dotenv");
3			const CommandManager = require("./CommandManager");
4			const path = require("path");
5			const fs = require("fs");
6			const Config = require("./Config");
7			const Database = require("./Database");
8			const Logger = require("./Logger");
9			const SpamFilter = require("./SpamFilter");
10	rakin	10	const server = require("./server");
11			const AntiRaid = require("./AntiRaid");
12	rakin	22	const MessageFilter = require("./MessageFilter");
13	rakin	23	const { random } = require("../commands/pixabay");
14	rakin	26	const AFKEngine = require("./AFKEngine");
15	rakin	5
16			class App {
17			constructor(rootdir) {
18			global.app = App.app = this;
19			this.rootdir = rootdir;
20			this.loadConfig();
21	rakin	10	this.env = process.env;
22	rakin	5
23			this.client = new Client({
24			partials: ["CHANNEL"],
25			intents: [
26			Intents.FLAGS.GUILDS,
27			Intents.FLAGS.GUILD_MESSAGES,
28			Intents.FLAGS.DIRECT_MESSAGES,
29	rakin	10	Intents.FLAGS.DIRECT_MESSAGE_TYPING,
30			Intents.FLAGS.GUILD_PRESENCES,
31			Intents.FLAGS.GUILD_MEMBERS,
32	rakin	25	Intents.FLAGS.GUILD_BANS
33	rakin	5	]
34			});
35
36			this.config = new Config();
37			this.db = new Database(path.resolve(__dirname, '..', 'database.db'));
38			this.commandManager = new CommandManager(path.resolve(__dirname, rootdir, "commands"));
39			this.logger = new Logger();
40			this.spamFilter = new SpamFilter();
41	rakin	10	this.antiRaid = new AntiRaid();
42	rakin	22	this.messageFilter = new MessageFilter();
43	rakin	26	this.afkEngine = new AFKEngine();
44	rakin	5	this.boot();
45			}
46
47			boot() {
48			this.on('ready', () => {
49			console.log("Logged in as " + this.client.user.tag);
50	rakin	23
51			this.client.user.setStatus(random(['dnd', 'idle']));
52			this.client.user.setActivity("over the server", { type: "WATCHING" });
53
54	rakin	10	server();
55	rakin	5	});
56
57			this.on('messageCreate', async (message) => {
58	rakin	11	if (message.author.bot \|\| !message.guild \|\| message.channel.type == 'dm') {
59	rakin	5	return;
60			}
61
62			await (this.msg = message);
63
64	rakin	20	await this.spamFilter.start(message);
65	rakin	22	await this.messageFilter.start(message, this.commandManager);
66	rakin	5
67			await this.commandManager.setMessage(message);
68
69			const valid = await this.commandManager.valid();
70			const has = await this.commandManager.has();
71			const snippet = await this.commandManager.snippet();
72	rakin	11	const allowed = await this.commandManager.verify();
73	rakin	5
74	rakin	11	if (valid && has && allowed) {
75	rakin	5	await this.exec();
76			}
77			else if (valid && snippet !== undefined) {
78			await message.channel.send({
79	rakin	27	content: snippet.content,
80			files: snippet.files.map(f => {
81			return {
82			attachment: path.resolve(__dirname, '..', 'storage', f)
83			}
84			})
85	rakin	5	});
86			}
87			else if (valid && !has) {
88			await this.commandManager.notFound();
89			}
90	rakin	11	else if (valid && has && !allowed) {
91			await this.commandManager.notAllowed();
92			}
93	rakin	26	else if(!valid) {
94			await this.afkEngine.start(message);
95			}
96	rakin	5	});
97
98			this.on("messageUpdate", async (oldMessage, newMessage) => {
99	rakin	25	if (oldMessage.author.bot \|\| oldMessage.content === newMessage.content)
100	rakin	5	return;
101
102			await this.logger.logEdit(oldMessage, newMessage);
103			});
104
105	rakin	25
106			this.on('guildBanAdd', async (ban) => {
107			console.log('test');
108			await this.logger.logBanned(ban);
109			});
110
111			this.on('guildBanRemove', async (ban) => {
112			console.log('test');
113			await this.logger.logUnbanned(ban);
114			});
115
116	rakin	5	this.on("messageDelete", async (message) => {
117			if (message.author.bot)
118			return;
119
120			await this.logger.logDelete(message);
121			});
122
123			this.on("guildCreate", guild => {
124			console.log("Joined a new guild: " + guild.name);
125
126			this.config.props[guild.id] = {
127			prefix: "-",
128			debug: false,
129			};
130
131			this.config.write();
132			})
133
134			this.on("guildDelete", guild => {
135			console.log("Left a guild: " + guild.name);
136			delete this.config.props[guild.id];
137			this.config.write();
138			})
139	rakin	10
140			this.on('guildMemberAdd', async (member) => {
141			console.log('Joined');
142			await this.antiRaid.start(member);
143	rakin	25	await this.logger.logJoined(member);
144	rakin	10	});
145	rakin	25
146			this.on('guildMemberRemove', async (member) => {
147			await this.logger.logLeft(member);
148			});
149	rakin	5	}
150
151			loadConfig() {
152			if (fs.existsSync(path.join(__dirname, this.rootdir, '.env'))) {
153			console.log("Loading .env file");
154			config();
155			}
156			}
157
158			on(event, handler) {
159			this.client.on(event, handler);
160			}
161
162			exec() {
163			this.commandManager.exec();
164			}
165
166			run() {
167			this.client.login(process.env.TOKEN);
168			}
169	rakin	10
170			tempFileCreate(name) {
171			const fullname = path.join(__dirname, '..', 'tmp', name);
172			const file = fs.createWriteStream(fullname);
173
174			return {
175			name: fullname,
176			file
177			};
178			}
179	rakin	5	}
180
181			module.exports = App;