Register handlers after db opened
This commit is contained in:
@@ -50,6 +50,7 @@ const regexTesters = [
|
|||||||
const uniqueRegexMatches = (g, i, a) => a.findIndex(v => v[1] == g[1]) == i;
|
const uniqueRegexMatches = (g, i, a) => a.findIndex(v => v[1] == g[1]) == i;
|
||||||
|
|
||||||
export async function handleMessageCreate(message: Message) {
|
export async function handleMessageCreate(message: Message) {
|
||||||
|
console.log('message created');
|
||||||
if (message.author.bot) return;
|
if (message.author.bot) return;
|
||||||
if (message.inGuild()) await Database.putMessage(message);
|
if (message.inGuild()) await Database.putMessage(message);
|
||||||
|
|
||||||
|
|||||||
+11
-10
@@ -140,20 +140,21 @@ client.on('clientReady', async () => {
|
|||||||
|
|
||||||
ScheduledTasks.forEach(task => scheduler.add(task));
|
ScheduledTasks.forEach(task => scheduler.add(task));
|
||||||
|
|
||||||
|
client.on('guildAuditLogEntryCreate', handleAuditLogCreate);
|
||||||
|
client.on('guildBanRemove', handleBanRemove);
|
||||||
|
client.on('guildCreate', handleGuildCreate);
|
||||||
|
client.on('guildMemberAdd', handleMemberJoin);
|
||||||
|
client.on('messageCreate', handleMessageCreate);
|
||||||
|
client.on('messageDelete', handleMessageDelete);
|
||||||
|
client.on('messageDeleteBulk', handleBulkMessageDelete);
|
||||||
|
client.on('messageUpdate', handleMessageUpdate);
|
||||||
|
client.on('threadCreate', handleThreadCreate);
|
||||||
|
client.on('voiceStateUpdate', handleVoiceStateUpdate);
|
||||||
|
|
||||||
ready = true;
|
ready = true;
|
||||||
console.log('Ready');
|
console.log('Ready');
|
||||||
});
|
});
|
||||||
|
|
||||||
client.on('guildAuditLogEntryCreate', handleAuditLogCreate);
|
|
||||||
client.on('guildBanRemove', handleBanRemove);
|
|
||||||
client.on('guildCreate', handleGuildCreate);
|
|
||||||
client.on('guildMemberAdd', handleMemberJoin);
|
|
||||||
client.on('messageCreate', handleMessageCreate);
|
|
||||||
client.on('messageDelete', handleMessageDelete);
|
|
||||||
client.on('messageDeleteBulk', handleBulkMessageDelete);
|
|
||||||
client.on('messageUpdate', handleMessageUpdate);
|
|
||||||
client.on('threadCreate', handleThreadCreate);
|
|
||||||
client.on('voiceStateUpdate', handleVoiceStateUpdate);
|
|
||||||
|
|
||||||
client.on('error', console.error);
|
client.on('error', console.error);
|
||||||
process.on('uncaughtException', console.error);
|
process.on('uncaughtException', console.error);
|
||||||
|
|||||||
@@ -122,6 +122,8 @@ export class Database {
|
|||||||
static async open(file: string): Promise<void> {
|
static async open(file: string): Promise<void> {
|
||||||
if (Database.db) return;
|
if (Database.db) return;
|
||||||
|
|
||||||
|
console.log('Opening SQLite database')
|
||||||
|
|
||||||
Database.db = await open({
|
Database.db = await open({
|
||||||
filename: file,
|
filename: file,
|
||||||
driver: sqlite3.Database
|
driver: sqlite3.Database
|
||||||
|
|||||||
Reference in New Issue
Block a user