|
@@ -10,7 +10,7 @@ client.on('ready', () => {
|
|
|
client.user.setPresence({ status: 'online', game: { name: config.playing } });
|
|
|
}
|
|
|
console.log(`Logged in as ${client.user.tag}!`);
|
|
|
- console.log(`To send missing messages run ${config.prefix}dump [quntity(default and limited to 99)]`);
|
|
|
+ console.log(`To send missing messages run ${config.prefix}dump [quantity(default and limited to 99)]`);
|
|
|
});
|
|
|
|
|
|
client.on('message', message => {
|
|
@@ -149,7 +149,8 @@ client.on('messageDelete', message => {
|
|
|
|
|
|
if (serverData==undefined) return;
|
|
|
|
|
|
- console.log(message);
|
|
|
+ deleteFromDB(message, serverData);
|
|
|
+
|
|
|
});
|
|
|
|
|
|
client.login(config.token);
|
|
@@ -163,6 +164,8 @@ function sendLoop(messages, serverData, delay) {
|
|
|
sendToDB(messages[0].message, serverData);
|
|
|
} else if (messages[0].action == 1) {
|
|
|
updateDB(messages[0].message, serverData);
|
|
|
+ } else if (messages[0].maction == 2) {
|
|
|
+ deleteFromDB(messages[0].message, serverData);
|
|
|
}
|
|
|
|
|
|
messages.shift();
|
|
@@ -305,3 +308,22 @@ function sendToDB(message, serverData) {
|
|
|
|
|
|
connection.end();
|
|
|
}
|
|
|
+
|
|
|
+function deleteFromDB(message, serverData) {
|
|
|
+ var connection = mysql.createConnection({
|
|
|
+ host : serverData.dbHost,
|
|
|
+ user : serverData.dbUser,
|
|
|
+ password : serverData.dbPassword,
|
|
|
+ database : serverData.db
|
|
|
+ });
|
|
|
+
|
|
|
+ var sql = 'DELETE FROM '+serverData.dbTable+' WHERE id='+message.id;
|
|
|
+ connection.connect();
|
|
|
+
|
|
|
+ connection.query(sql, function (error, results, fields) {
|
|
|
+ if (error) throw error;
|
|
|
+ console.log('Data deleted in db. Result: ', results);
|
|
|
+ });
|
|
|
+
|
|
|
+ connection.end();
|
|
|
+}
|