add: added emojis

back/libs/mysql.js

@@ -477,6 +477,95 @@ function deleteUserMentions(connection, user_id) {
   });
 }
 
+function getEmojis(connection) {
+  return new Promise((resolve, reject) => {
+    connection.query(
+      `SELECT id, name FROM emojis`,
+      (error, result) => {
+        if (error) {
+          reject(new Error(error));
+        }
+        resolve(result);
+      }
+    );
+  });
+}
+
+function addEmoji(connection, name, file) {
+  return new Promise((resolve, reject) => {
+    connection.query(
+      `INSERT INTO emojis (name, file) VALUES (?, ?)`,
+      [name, file], // Use parameterized query
+      (error, result) => {
+        if (error) {
+          reject(new Error(error));
+        }
+        resolve(result);
+      }
+    );
+  });
+}
+
+function deleteEmoji(connection, id) {
+  return new Promise((resolve, reject) => {
+    connection.query(
+      `DELETE FROM emojis WHERE id = ?`,
+      [id], // Use parameterized query
+      (error, result) => {
+        if (error) {
+          reject(new Error(error));
+        }
+        resolve(result);
+      }
+    );
+  });
+}
+
+function getEmoji(connection, id) {
+  return new Promise((resolve, reject) => {
+    connection.query(
+      `SELECT * FROM emojis WHERE id = ?`,
+      [id], // Use parameterized query
+      (error, result) => {
+        if (error) {
+          reject(new Error(error));
+        }
+        resolve(result);
+      }
+    );
+  });
+}
+
+function getEmojiByName(connection, name) {
+  return new Promise((resolve, reject) => {
+    connection.query(
+      `SELECT * FROM emojis WHERE name = ?`,
+      [name], // Use parameterized query
+      (error, result) => {
+        if (error) {
+          reject(new Error(error));
+        }
+        resolve(result);
+      }
+    );
+  });
+}
+
+function searchEmojis(connection, search) {
+  return new Promise((resolve, reject) => {
+    connection.query(
+      `SELECT * FROM emojis WHERE name LIKE ? LIMIT 5`,
+      [`%${search}%`], // Use parameterized query
+      (error, result) => {
+        if (error) {
+          reject(new Error(error));
+        }
+        resolve(result);
+      }
+    );
+  });
+}
+
 module.exports = {
   getUsers,
   getConnection,
@@ -508,4 +597,10 @@ module.exports = {
   deleMentions,
   deleteUserMentions,
   deleteChannelMentions,
+  getEmojis,
+  addEmoji,
+  deleteEmoji,
+  getEmoji,
+  getEmojiByName,
+  searchEmojis,
 };