feat(server): add BullMQ queue and worker with Redis

apps/server/package.json

@@ -12,6 +12,7 @@
 	"dependencies": {
 		"@ifinho/db": "*",
 		"@ifinho/env": "*",
+		"bullmq": "^5.70.1",
 		"cors": "^2.8.5",
 		"dotenv": "^17.2.2",
 		"express": "^5.1.0",

apps/server/src/index.ts

@@ -1,6 +1,8 @@
 import { env } from "@ifinho/env/server";
 import cors from "cors";
 import express from "express";
+import { chatQueue } from "./queue";
+import "./worker";
 import { Ollama } from "ollama";
 
 const app = express();
@@ -123,6 +125,14 @@ app.post("/api/chat", async (req, res) => {
 	}
 });
 
+app.post("/api/queue", async (req, res) => {
+	const { message } = req.body;
+
+	await chatQueue.add("chat-message", { message });
+
+	res.status(200).json({ ok: true });
+});
+
 app.listen(3000, () => {
 	console.log("Server is running on http://localhost:3000");
 });

apps/server/src/queue.ts

@@ -0,0 +1,8 @@
+import { env } from "@ifinho/env/server";
+import { Queue } from "bullmq";
+
+export const chatQueue = new Queue("chat", {
+	connection: {
+		url: env.REDIS_URL,
+	},
+});

apps/server/src/worker.ts

@@ -0,0 +1,27 @@
+import { env } from "@ifinho/env/server";
+import { Worker } from "bullmq";
+
+export const chatWorker = new Worker(
+	"chat",
+	async (job) => {
+		console.log(`Processando mensagem: ${job.data.message}`);
+
+		// Aqui vai entrar futuramente:
+		// 1. Buscar no banco vetorial (RAG)
+		// 2. Mandar pra IA
+		// 3. Retornar a resposta
+	},
+	{
+		connection: {
+			url: env.REDIS_URL,
+		},
+	},
+);
+
+chatWorker.on("completed", (job) => {
+	console.log(`Mensagem ${job.id} processada com sucesso!`);
+});
+
+chatWorker.on("failed", (job, error) => {
+	console.log(`Mensagem ${job?.id} falhou: ${error.message}`);
+});

docker-compose.yml

@@ -30,6 +30,16 @@ services:
     networks:
       - ifinho-network
 
+  redis:
+    container_name: ifinho-redis
+    image: redis:7-alpine
+    restart: unless-stopped
+    ports:
+      - "6379:6379"
+    networks:
+      - ifinho-network
+
+
   server:
     container_name: ifinho-server
     build:
@@ -42,11 +52,16 @@ services:
       DATABASE_URL: postgresql://${POSTGRES_USER}:${POSTGRES_PASSWORD}@ifinho-postgres:5432/${POSTGRES_DB}
       CORS_ORIGIN: ${CORS_ORIGIN:-http://localhost}
       OLLAMA_BASE_URL: http://ifinho-ollama:11434
+      REDIS_URL: redis://ifinho-redis:6379
       OLLAMA_MODEL: ${OLLAMA_MODEL:-llama3.2}
       NODE_ENV: production
     depends_on:
       postgres:
         condition: service_healthy
+      redis:
+        condition: service_started
+    ports:
+      - "3000:3000"
     networks:
       - ifinho-network
 
@@ -68,6 +83,7 @@ services:
 volumes:
   ifinho-postgres-data:
   ifinho-ollama-data:
+  ifinho-redis-data:
 
 networks:
   ifinho-network: