From 80bb8a108f29331cdb2f2695f6801beee104dc89 Mon Sep 17 00:00:00 2001 From: MohamedBassem Date: Thu, 8 Feb 2024 15:14:23 +0000 Subject: [refactor] Move the different packages to the package subdir --- shared/index.ts | 1 - shared/logger.ts | 15 --------------- shared/package.json | 10 ---------- shared/queues.ts | 29 ----------------------------- 4 files changed, 55 deletions(-) delete mode 100644 shared/index.ts delete mode 100644 shared/logger.ts delete mode 100644 shared/package.json delete mode 100644 shared/queues.ts (limited to 'shared') 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; - -export const LinkCrawlerQueue = new Queue( - "link_crawler_queue", - { connection: queueConnectionDetails }, -); - -// OpenAI Worker -export const zOpenAIRequestSchema = z.object({ - linkId: z.string(), -}); -export type ZOpenAIRequest = z.infer; - -export const OpenAIQueue = new Queue("openai_queue", { - connection: queueConnectionDetails, -}); -- cgit v1.2.3-70-g09d2