1 files changed, 11 insertions, 0 deletions
diff --git a/shared/queues.ts b/shared/queues.ts
index ac5acc57..a607131d 100644
--- a/shared/queues.ts
+++ b/shared/queues.ts
@@ -6,6 +6,7 @@ export const queueConnectionDetails = {
   port: parseInt(process.env.REDIS_PORT || "6379"),
 };
 
+// Link Crawler
 export const zCrawlLinkRequestSchema = z.object({
   linkId: z.string(),
   url: z.string().url(),
@@ -16,3 +17,13 @@ export const LinkCrawlerQueue = new Queue<ZCrawlLinkRequest, void>(
   "link_crawler_queue",
   { connection: queueConnectionDetails },
 );
+
+// OpenAI Worker
+export const zOpenAIRequestSchema = z.object({
+  linkId: z.string(),
+});
+export type ZOpenAIRequest = z.infer<typeof zOpenAIRequestSchema>;
+
+export const OpenAIQueue = new Queue<ZOpenAIRequest, void>("openai_queue", {
+  connection: queueConnectionDetails,
+});