aboutsummaryrefslogtreecommitdiffstats
path: root/packages/shared/queues.ts
diff options
context:
space:
mode:
Diffstat (limited to 'packages/shared/queues.ts')
-rw-r--r--packages/shared/queues.ts7
1 files changed, 4 insertions, 3 deletions
diff --git a/packages/shared/queues.ts b/packages/shared/queues.ts
index 571df568..a434414c 100644
--- a/packages/shared/queues.ts
+++ b/packages/shared/queues.ts
@@ -32,9 +32,10 @@ export const LinkCrawlerQueue = new SqliteQueue<ZCrawlLinkRequest>(
},
);
-// OpenAI Worker
+// Inference Worker
export const zOpenAIRequestSchema = z.object({
bookmarkId: z.string(),
+ type: z.enum(["summarize", "tag"]).default("tag"),
});
export type ZOpenAIRequest = z.infer<typeof zOpenAIRequestSchema>;
@@ -171,7 +172,7 @@ export const AssetPreprocessingQueue =
// Webhook worker
export const zWebhookRequestSchema = z.object({
bookmarkId: z.string(),
- operation: z.enum(["crawled", "created", "edited", "ai tagged"]),
+ operation: z.enum(["crawled", "created", "edited", "ai tagged", "deleted"]),
});
export type ZWebhookRequest = z.infer<typeof zWebhookRequestSchema>;
export const WebhookQueue = new SqliteQueue<ZWebhookRequest>(
@@ -195,7 +196,7 @@ export async function triggerWebhook(
});
}
-// RuleEgine worker
+// RuleEngine worker
export const zRuleEngineRequestSchema = z.object({
bookmarkId: z.string(),
events: z.array(zRuleEngineEventSchema),