diff options
| author | MohamedBassem <me@mbassem.com> | 2024-02-08 15:14:23 +0000 |
|---|---|---|
| committer | MohamedBassem <me@mbassem.com> | 2024-02-08 15:15:21 +0000 |
| commit | 80bb8a108f29331cdb2f2695f6801beee104dc89 (patch) | |
| tree | b1ae2a512963a9c916c4bfed71f7633f508de131 /shared | |
| parent | 333429adbaaa592cc96b480a5228f0e3f1de4cc2 (diff) | |
| download | karakeep-80bb8a108f29331cdb2f2695f6801beee104dc89.tar.zst | |
[refactor] Move the different packages to the package subdir
Diffstat (limited to 'shared')
| -rw-r--r-- | shared/index.ts | 1 | ||||
| -rw-r--r-- | shared/logger.ts | 15 | ||||
| -rw-r--r-- | shared/package.json | 10 | ||||
| -rw-r--r-- | shared/queues.ts | 29 |
4 files changed, 0 insertions, 55 deletions
diff --git a/shared/index.ts b/shared/index.ts deleted file mode 100644 index 8b93520f..00000000 --- a/shared/index.ts +++ /dev/null @@ -1 +0,0 @@ -export * as Queues from "./queues.ts"; diff --git a/shared/logger.ts b/shared/logger.ts deleted file mode 100644 index 8cd2f808..00000000 --- a/shared/logger.ts +++ /dev/null @@ -1,15 +0,0 @@ -import winston from "winston"; - -const logger = winston.createLogger({ - level: process.env.LOG_LEVEL || "debug", - format: winston.format.combine( - winston.format.timestamp(), - winston.format.colorize(), - winston.format.printf( - (info) => `${info.timestamp} ${info.level}: ${info.message}`, - ), - ), - transports: [new winston.transports.Console()], -}); - -export default logger; diff --git a/shared/package.json b/shared/package.json deleted file mode 100644 index b75b3ac3..00000000 --- a/shared/package.json +++ /dev/null @@ -1,10 +0,0 @@ -{ - "$schema": "https://json.schemastore.org/package.json", - "name": "@remember/shared", - "version": "0.1.0", - "private": true, - "dependencies": { - "winston": "^3.11.0" - }, - "main": "index.ts" -} diff --git a/shared/queues.ts b/shared/queues.ts deleted file mode 100644 index a607131d..00000000 --- a/shared/queues.ts +++ /dev/null @@ -1,29 +0,0 @@ -import { Queue } from "bullmq"; -import { z } from "zod"; - -export const queueConnectionDetails = { - host: process.env.REDIS_HOST || "localhost", - port: parseInt(process.env.REDIS_PORT || "6379"), -}; - -// Link Crawler -export const zCrawlLinkRequestSchema = z.object({ - linkId: z.string(), - url: z.string().url(), -}); -export type ZCrawlLinkRequest = z.infer<typeof zCrawlLinkRequestSchema>; - -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, -}); |
