Files
Civita/dist/events/messageCreate.js
2025-10-12 10:47:58 +02:00

36 lines
1.5 KiB
JavaScript

import { Events } from 'discord.js';
import { withConn } from '../db/pool.js';
import { chatAnswerWithMemory } from '../ai/gemini.js';
import filter from 'leo-profanity';
filter.loadDictionary('en');
export function registerMessageCreate(client) {
client.on(Events.MessageCreate, async (message) => {
if (!message.guild || message.author.bot)
return;
const guildId = message.guild.id;
const cfg = await withConn(async (conn) => {
const rows = await conn.query('SELECT ai_enabled, profanity_filter_enabled FROM guild_config WHERE guild_id = ? LIMIT 1', [guildId]);
return rows[0];
});
// Profanity filter
if (cfg?.profanity_filter_enabled) {
if (filter.check(message.content)) {
await message.delete().catch(() => null);
return;
}
}
// XP system: 10 XP per message
await withConn(async (conn) => {
await conn.query('INSERT INTO user_xp (guild_id, user_id, xp) VALUES (?, ?, 10) ON DUPLICATE KEY UPDATE xp = xp + 10', [guildId, message.author.id]);
});
// Mention AI
if (cfg?.ai_enabled && message.mentions.has(client.user)) {
const question = message.content.replace(/<@!?\d+>/g, '').trim();
if (!question)
return;
const answer = await chatAnswerWithMemory(guildId, message.author.id, question).catch(() => 'Sorry, I could not process that right now.');
await message.reply(answer);
}
});
}