feat: add publish on send message

gabrielcanali · Feb 18, 2024 · 92a9978 · 92a9978
1 parent 4588014
commit 92a9978
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/server/src/api/routes/send-message.ts b/server/src/api/routes/send-message.ts
@@ -2,6 +2,7 @@ import { FastifyInstance } from "fastify";
 import z from "zod";
 import { prisma } from "../../lib/prisma";
 import { randomUUID } from "crypto";
+import { messageDisplay } from "../../utils/message-pub-sub";
 
 export async function sendMessage(app: FastifyInstance) {
     app.post('/api/message/:channel', async (request, reply) => {
@@ -50,6 +51,12 @@ export async function sendMessage(app: FastifyInstance) {
             }
         })
 
+        messageDisplay.publish(channel, {
+            userId: message.userId,
+            content: message.content,
+            created_at: message.created_at
+        })
+
         return reply.status(201).send({ 
             message,
             sessionCookieId,