api: implement POST and GET messages

Author: te-ce

src/app/api/[[...slugs]]/messages.ts

@@ -2,6 +2,8 @@ import z from "zod";
 import { authMiddleware } from "./auth";
 import Elysia from "elysia";
 import { redis } from "@/lib/redis";
+import { Message, realtime } from "@/lib/realtime";
+import { nanoid } from "nanoid";
 
 export const messages = new Elysia({ prefix: "/messages" })
   .use(authMiddleware)
@@ -17,9 +19,24 @@ export const messages = new Elysia({ prefix: "/messages" })
         throw new Error("Room not found");
       }
 
-      console.log("SENDING MESSAGE", { sender, text });
+      const message: Message = {
+        id: nanoid(),
+        sender,
+        text,
+        timestamp: Date.now(),
+        roomId,
+      };
 
-      return { message: "Message sent" };
+      await redis.rpush(`messages:${roomId}`, {
+        ...message,
+        token: auth.token,
+      });
+      await realtime.channel(`chat:${roomId}`).emit("chat.message", message);
+
+      const remaining = await redis.ttl(`meta:${roomId}`);
+      await redis.expire(`messages:${roomId}`, remaining);
+      await redis.expire(`history:${roomId}`, remaining);
+      await redis.expire(roomId, remaining);
     },
     {
       query: z.object({ roomId: z.string() }),
@@ -28,4 +45,22 @@ export const messages = new Elysia({ prefix: "/messages" })
         text: z.string().max(1000),
       }),
     },
+  )
+  .get(
+    "/",
+    async ({ auth }) => {
+      const messages = await redis.lrange<Message>(
+        `messages:${auth.roomId}`,
+        0,
+        -1,
+      );
+
+      return {
+        messages: messages.map((m) => ({
+          ...m,
+          token: m.token === auth.token ? auth.token : undefined,
+        })),
+      };
+    },
+    { query: z.object({ roomId: z.string() }) },
   );