Save Messages to Database!

This commit is contained in:
ui_creeperlv 2024-03-06 19:26:51 +05:30
parent cbbd1db0cf
commit a2000f8a19
3 changed files with 13 additions and 9 deletions

View File

@ -1,7 +1,6 @@
class Message { class Message {
/** /**
* @typedef {Object} MessageFields * @typedef {Object} MessageFields
* @property {import('crypto').UUID} uuid
* @property {import('discord.js').Snowflake} serverId * @property {import('discord.js').Snowflake} serverId
* @property {string|null} serverName * @property {string|null} serverName
* @property {import('discord.js').Snowflake} authorId * @property {import('discord.js').Snowflake} authorId
@ -10,7 +9,6 @@ class Message {
*/ */
constructor(){ constructor(){
this.uuid = require('crypto').randomUUID();
this.serverId = 1; this.serverId = 1;
this.serverName = "[No Server]"; this.serverName = "[No Server]";
this.authorId = 1; this.authorId = 1;
@ -36,7 +34,6 @@ class Message {
toArray(){ toArray(){
return { return {
uuid : this.uuid,
serverId : this.serverId, serverId : this.serverId,
serverName : this.serverName, serverName : this.serverName,
authorId : this.authorId, authorId : this.authorId,

View File

@ -7,7 +7,7 @@ const { EmbedBuilder } = require("@discordjs/builders");
* @param {Message} message * @param {Message} message
* @param {Client} discord * @param {Client} discord
*/ */
const send = (message, database, channelId , discord) => { const send = (message, database, channelId , uuid , discord) => {
discord.channels.cache?.get(channelId).send({ discord.channels.cache?.get(channelId).send({
embeds: [ embeds: [
new EmbedBuilder() new EmbedBuilder()
@ -23,6 +23,13 @@ const send = (message, database, channelId , discord) => {
] ]
}).catch((error) => { }).catch((error) => {
console.log(`Unable to Send Message to Channel [${channelId}]`); console.log(`Unable to Send Message to Channel [${channelId}]`);
}).then((_message) => {
database.insert("xan.messageDelivery" ,{
channelId: channelId,
messageId : _message.id,
client: "discord",
link: uuid
}, (uuid) => {});
}); });
} }

View File

@ -10,11 +10,11 @@ const initMessageManager = async (
database, database,
discord discord
) => { ) => {
function postMessage(message){ function postMessage(message, uuid){
database.list("xan.guilds" , {} , (list) => { database.list("xan.guilds" , {} , (list) => {
for(var element of list){ for(var element of list){
if(element.client == "discord") discordSend(message , data , element.channelId , discord); if(element.client == "discord") discordSend(message , database , element.channelId ,uuid , discord);
} }
}); });
} }
@ -36,9 +36,9 @@ const initMessageManager = async (
_message.serverName = message.guild.name, _message.serverName = message.guild.name,
_message.message = message.content; _message.message = message.content;
delete _message.uuid; database.insert("xan.messages" , _message.toArray() , (uuid) => {
postMessage(_message.toArray(), uuid);
postMessage(_message.toArray()); });
} }
}); });
}); });