From 739c9c1bf6b4bf63a95ad0fd8098a0eb44e83f06 Mon Sep 17 00:00:00 2001
From: Chneemann <andre-kempf@mailbox.org>
Date: Fri, 4 Sep 2026 19:25:14 +0200
Subject: [PATCH] feat(db): add conversations and direct_messages tables with
 relations

---
 db/schema.ts | 75 +++++++++++++++++++++++++++++++++++++++++++++++++++-
 1 file changed, 74 insertions(+), 1 deletion(-)

diff --git a/db/schema.ts b/db/schema.ts
index 99ecf0e..22a35e2 100644
--- a/db/schema.ts
+++ b/db/schema.ts
@@ -1,6 +1,6 @@
 /**
  * @file db/schema.ts
- * @description Database schema definition using Drizzle ORM, containing enums, table definitions, relations, and TypeScript type exports for users, servers, members, channels, messages, and friendships.
+ * @description Database schema definition using Drizzle ORM, containing enums, table definitions, relations, and TypeScript type exports for users, servers, members, channels, messages, conversations, direct messages and friendships.
  */
 
 import { relations } from "drizzle-orm";
@@ -134,6 +134,36 @@ export const friendships = pgTable("friendships", {
   updatedAt: timestamp("updated_at").defaultNow().notNull(),
 });
 
+/**
+ * Database table definition for direct message conversations between two users.
+ */
+export const conversations = pgTable("conversations", {
+  id: uuid("id").primaryKey().defaultRandom(),
+  userOneId: uuid("user_one_id")
+    .references(() => users.id, { onDelete: "cascade" })
+    .notNull(),
+  userTwoId: uuid("user_two_id")
+    .references(() => users.id, { onDelete: "cascade" })
+    .notNull(),
+  createdAt: timestamp("created_at").defaultNow().notNull(),
+});
+
+/**
+ * Database table definition for direct messages sent within a conversation.
+ */
+export const directMessages = pgTable("direct_messages", {
+  id: uuid("id").primaryKey().defaultRandom(),
+  content: text("content").notNull(),
+  conversationId: uuid("conversation_id")
+    .references(() => conversations.id, { onDelete: "cascade" })
+    .notNull(),
+  senderId: uuid("sender_id")
+    .references(() => users.id, { onDelete: "cascade" })
+    .notNull(),
+  createdAt: timestamp("created_at").defaultNow().notNull(),
+  updatedAt: timestamp("updated_at").defaultNow().notNull(),
+});
+
 // ==========================================
 // Drizzle Relations
 // ==========================================
@@ -147,6 +177,13 @@ export const usersRelations = relations(users, ({ many }) => ({
   receivedFriendRequests: many(friendships, {
     relationName: "receivedFriendships",
   }),
+  conversationsInitiated: many(conversations, {
+    relationName: "userOneConversations",
+  }),
+  conversationsReceived: many(conversations, {
+    relationName: "userTwoConversations",
+  }),
+  directMessages: many(directMessages),
 }));
 
 /**
@@ -210,6 +247,40 @@ export const friendshipsRelations = relations(friendships, ({ one }) => ({
   }),
 }));
 
+/**
+ * Relational definitions for the conversations table.
+ */
+export const conversationsRelations = relations(
+  conversations,
+  ({ one, many }) => ({
+    userOne: one(users, {
+      fields: [conversations.userOneId],
+      references: [users.id],
+      relationName: "userOneConversations",
+    }),
+    userTwo: one(users, {
+      fields: [conversations.userTwoId],
+      references: [users.id],
+      relationName: "userTwoConversations",
+    }),
+    directMessages: many(directMessages),
+  }),
+);
+
+/**
+ * Relational definitions for the directMessages table.
+ */
+export const directMessagesRelations = relations(directMessages, ({ one }) => ({
+  conversation: one(conversations, {
+    fields: [directMessages.conversationId],
+    references: [conversations.id],
+  }),
+  sender: one(users, {
+    fields: [directMessages.senderId],
+    references: [users.id],
+  }),
+}));
+
 // ==========================================
 // Type Exports
 // ==========================================
@@ -222,3 +293,5 @@ export type Message = typeof messages.$inferSelect;
 export type UserStatus = (typeof userStatusEnum.enumValues)[number];
 export type Friendship = typeof friendships.$inferSelect;
 export type FriendshipStatus = (typeof friendshipStatusEnum.enumValues)[number];
+export type Conversation = typeof conversations.$inferSelect;
+export type DirectMessage = typeof directMessages.$inferSelect;