refactor(backend): Implement unified Message collection to fix 16MB limit (#25)

server/src/models/Chat.js

@@ -1,21 +1,10 @@
 import mongoose from "mongoose";
-
 const chatSchema = new mongoose.Schema({
   server_id: String,
   channels: [
     {
       channel_id: String,
       channel_name: String,
-      chat_details: [
-        {
-          content: String,
-          sender_id: String,
-          sender_name: String,
-          sender_pic: String,
-          sender_tag: String,
-          timestamp: String,
-        },
-      ],
     },
   ],
 });

server/src/models/DirectMessageThread.js

@@ -2,16 +2,9 @@ import mongoose from "mongoose";
 
 const directMessageThreadSchema = new mongoose.Schema({
   participants: [String],
-  messages: [
-    {
-      sender_id: String,
-      sender_name: String,
-      sender_tag: String,
-      sender_pic: String,
-      content: String,
-      timestamp: Number,
-    },
-  ],
 });
 
-export default mongoose.model("direct_message_threads", directMessageThreadSchema);
+export default mongoose.model(
+  "direct_message_threads",
+  directMessageThreadSchema,
+);

server/src/models/Message.js

@@ -0,0 +1,40 @@
+import mongoose from "mongoose";
+
+const messageSchema = new mongoose.Schema(
+  {
+    sender: {
+      type: mongoose.Schema.Types.ObjectId,
+      ref: "User",
+      required: true,
+    },
+    channelId: {
+      type: mongoose.Schema.Types.ObjectId,
+      ref: "Chat",
+    },
+    threadId: {
+      type: mongoose.Schema.Types.ObjectId,
+      ref: "DirectMessageThread",
+    },
+    content: {
+      type: String,
+      required: true,
+    },
+    sender_name: String,
+    sender_pic: String,
+    sender_tag: String,
+    timestamp: {
+      type: Date,
+      default: Date.now,
+    },
+    isEdited: {
+      type: Boolean,
+      default: false,
+    },
+  },
+  { timestamps: true },
+);
+
+messageSchema.index({ channelId: 1, timestamp: -1 });
+messageSchema.index({ threadId: 1, timestamp: -1 });
+
+export default mongoose.model("Message", messageSchema);