aboutsummaryrefslogtreecommitdiffstats
path: root/shared
diff options
context:
space:
mode:
authorMohamedBassem <me@mbassem.com>2024-02-08 15:14:23 +0000
committerMohamedBassem <me@mbassem.com>2024-02-08 15:15:21 +0000
commit80bb8a108f29331cdb2f2695f6801beee104dc89 (patch)
treeb1ae2a512963a9c916c4bfed71f7633f508de131 /shared
parent333429adbaaa592cc96b480a5228f0e3f1de4cc2 (diff)
downloadkarakeep-80bb8a108f29331cdb2f2695f6801beee104dc89.tar.zst
[refactor] Move the different packages to the package subdir
Diffstat (limited to 'shared')
-rw-r--r--shared/index.ts1
-rw-r--r--shared/logger.ts15
-rw-r--r--shared/package.json10
-rw-r--r--shared/queues.ts29
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,
-});