From b7268c2fb611688047849a0bea72567d830bcea8 Mon Sep 17 00:00:00 2001
From: repi <repi@repi.fun>
Date: Mon, 1 Jan 2001 00:00:00 +0000
Subject: [PATCH] feat: add BullMQ queue singleton

---
 apps/web/src/lib/queue.ts | 13 +++++++++++++
 1 file changed, 13 insertions(+)
 create mode 100644 apps/web/src/lib/queue.ts

diff --git a/apps/web/src/lib/queue.ts b/apps/web/src/lib/queue.ts
new file mode 100644
index 0000000..98ea40e
--- /dev/null
+++ b/apps/web/src/lib/queue.ts
@@ -0,0 +1,13 @@
+import { Queue } from "bullmq";
+import { getRedis } from "./redis";
+
+let queue: Queue | null = null;
+
+export function getQueue(): Queue {
+  if (!queue) {
+    queue = new Queue("codeboard:generate", {
+      connection: getRedis(),
+    });
+  }
+  return queue;
+}