added delete message socket, message deletion is now done by socket not api

server/db/db.js

@@ -720,6 +720,7 @@ async function deleteMessage(user_id, message_id) {
       console.log("Message deleted successfully");
     } else {
       console.log("Failed to delete message");
+      return { message: "Failed to delete message" };
     }
   } catch (e) {
     console.error("Failed to delete message ", e);

server/socket/socket.js

@@ -1,7 +1,13 @@
-const { insertMessage, getConversationsForUser } = require("../db/db");
+const {
+  insertMessage,
+  getConversationsForUser,
+  deleteContact,
+  deleteMessage,
+} = require("../db/db");
 const { isValidUsername } = require("../utils/filter");
 const { verifyJwtToken } = require("../auth/jwt");
 const console = require("node:console");
+const { call } = require("express");
 
 function initializeSocket(io) {
   io.use((socket, next) => {
@@ -147,6 +153,34 @@ function initializeSocket(io) {
       }
     });
 
+    socket.on("delete message", async (msg, callback) => {
+      console.log("(socket) delete message for message_id: ", msg);
+      const { conversation_id, message_id } = msg;
+      if (!message_id) {
+        return callback({ status: "error", message: "No message id provided" });
+      }
+      if (!conversation_id) {
+        return callback({
+          status: "error",
+          message: "No conversation id provided",
+        });
+      }
+
+      const result = await deleteMessage(socket.user_id, message_id);
+      if (result?.message !== undefined) {
+        return callback({ status: "error", message: result.message });
+      } else {
+        io.to(conversation_id).emit("delete message", {
+          conversation_id,
+          message_id,
+        });
+        return callback({
+          status: "ok",
+          message: "Successfully deleted message",
+        });
+      }
+    });
+
     socket.on("disconnect", (reason) => {
       console.log("(socket)", socket.id, " disconnected due to: ", reason);
     });