add: added channel purge button

back/api/channels.js

@@ -1,5 +1,20 @@
 const express = require('express');
-const { getConnection, getChannels, getChannel, addChannel, getMessages, getMessage, addMessage, deleteMessage, addMention, getMentions, getUserByUsername, deleMentions } = require('../libs/mysql');
+const {
+    getConnection,
+    getChannels,
+    getChannel,
+    addChannel,
+    getMessages,
+    getMessage,
+    addMessage,
+    deleteMessage,
+    addMention,
+    getMentions,
+    getUserByUsername,
+    deleMentions,
+    deleteChannelMentions,
+    deleteChannelMessages
+} = require('../libs/mysql');
 const { checkAuth } = require('../libs/middlewares');
 
 const router = express.Router();
@@ -23,6 +38,36 @@ router.get('/:name', async (req, res) => {
     }
 });
 
+router.use('/:name/purge', checkAuth);
+router.post('/:name/purge', async (req, res) => {
+    const name = req.params.name;
+    const user = req.user;
+
+    const connection = await getConnection();
+
+    const channel = await getChannel(connection, name);
+    if (!channel[0]) {
+        connection.end();
+        return res.status(400).send({ error: 'No channel found' });
+    }
+
+    if (user.admin !== 1) {
+        connection.end();
+        return res.status(401).send({ error: 'Unauthorized' });
+    }
+
+    await deleteChannelMentions(connection, channel[0].id);
+    await deleteChannelMessages(connection, channel[0].id);
+    connection.end();
+
+    req.sockets.emit({
+        type: 'purge_channel',
+        channel_id: channel[0].id,
+    });
+
+    res.send({ message: 'Channel purged' });
+});
+
 router.get('/:name/messages', async (req, res) => {
     const name = req.params.name;
     const connection = await getConnection();

back/libs/mysql.js

@@ -280,6 +280,21 @@ function deleteMessage(connection, message_id) {
   });
 }
 
+function deleteChannelMessages(connection, channel_id) {
+  return new Promise((resolve, reject) => {
+    connection.query(
+      `DELETE FROM messages WHERE channel_id = ?`,
+      [channel_id], // Use parameterized query
+      (error, result) => {
+        if (error) {
+          reject(new Error(error));
+        }
+        resolve(result);
+      }
+    );
+  });
+}
+
 function addMention(connection, message_id, user_id) {
   return new Promise((resolve, reject) => {
     connection.query(
@@ -327,6 +342,22 @@ function deleMentions(connection, message_id) {
   });
 }
 
+function deleteChannelMentions(connection, channel_id) {
+  return new Promise((resolve, reject) => {
+    connection.query(
+      `DELETE FROM mentions WHERE message_id IN 
+       (SELECT id FROM messages WHERE channel_id = ?)`,
+      [channel_id], // Use parameterized query
+      (error, result) => {
+        if (error) {
+          reject(new Error(error));
+        }
+        resolve(result);
+      }
+    );
+  });
+}
+
 module.exports = {
   getConnection,
   getUser,
@@ -345,7 +376,9 @@ module.exports = {
   getMessage,
   addMessage,
   deleteMessage,
+  deleteChannelMessages,
   addMention,
   getMentions,
   deleMentions,
+  deleteChannelMentions,
 };