diff options
| author | MohamedBassem <me@mbassem.com> | 2025-04-12 19:37:18 +0100 |
|---|---|---|
| committer | MohamedBassem <me@mbassem.com> | 2025-04-12 19:37:40 +0100 |
| commit | 755fc36e912964863d4f46bb32adda6332b419fe (patch) | |
| tree | 3c54e9e6ed7686a119804716ccb6fdd6ad0da3c3 /apps/workers | |
| parent | 7f569042f153a55189fb28e6ef6ab127b8190afd (diff) | |
| download | karakeep-755fc36e912964863d4f46bb32adda6332b419fe.tar.zst | |
chore: Rename hoarder packages to karakeep
Diffstat (limited to 'apps/workers')
| -rw-r--r-- | apps/workers/assetPreprocessingWorker.ts | 14 | ||||
| -rw-r--r-- | apps/workers/crawlerWorker.ts | 16 | ||||
| -rw-r--r-- | apps/workers/exit.ts | 2 | ||||
| -rw-r--r-- | apps/workers/feedWorker.ts | 12 | ||||
| -rw-r--r-- | apps/workers/index.ts | 6 | ||||
| -rw-r--r-- | apps/workers/openaiWorker.ts | 20 | ||||
| -rw-r--r-- | apps/workers/package.json | 18 | ||||
| -rw-r--r-- | apps/workers/searchWorker.ts | 12 | ||||
| -rw-r--r-- | apps/workers/tidyAssetsWorker.ts | 10 | ||||
| -rw-r--r-- | apps/workers/trpc.ts | 8 | ||||
| -rw-r--r-- | apps/workers/tsconfig.json | 2 | ||||
| -rw-r--r-- | apps/workers/videoWorker.ts | 12 | ||||
| -rw-r--r-- | apps/workers/webhookWorker.ts | 10 | ||||
| -rw-r--r-- | apps/workers/workerUtils.ts | 4 |
14 files changed, 73 insertions, 73 deletions
diff --git a/apps/workers/assetPreprocessingWorker.ts b/apps/workers/assetPreprocessingWorker.ts index c0fb2665..a678b706 100644 --- a/apps/workers/assetPreprocessingWorker.ts +++ b/apps/workers/assetPreprocessingWorker.ts @@ -5,22 +5,22 @@ import PDFParser from "pdf2json"; import { fromBuffer } from "pdf2pic"; import { createWorker } from "tesseract.js"; -import type { AssetPreprocessingRequest } from "@hoarder/shared/queues"; -import { db } from "@hoarder/db"; +import type { AssetPreprocessingRequest } from "@karakeep/shared/queues"; +import { db } from "@karakeep/db"; import { assets, AssetTypes, bookmarkAssets, bookmarks, -} from "@hoarder/db/schema"; -import { newAssetId, readAsset, saveAsset } from "@hoarder/shared/assetdb"; -import serverConfig from "@hoarder/shared/config"; -import logger from "@hoarder/shared/logger"; +} from "@karakeep/db/schema"; +import { newAssetId, readAsset, saveAsset } from "@karakeep/shared/assetdb"; +import serverConfig from "@karakeep/shared/config"; +import logger from "@karakeep/shared/logger"; import { AssetPreprocessingQueue, OpenAIQueue, triggerSearchReindex, -} from "@hoarder/shared/queues"; +} from "@karakeep/shared/queues"; export class AssetPreprocessingWorker { static build() { diff --git a/apps/workers/crawlerWorker.ts b/apps/workers/crawlerWorker.ts index e75a8586..c96ca636 100644 --- a/apps/workers/crawlerWorker.ts +++ b/apps/workers/crawlerWorker.ts @@ -30,15 +30,15 @@ import StealthPlugin from "puppeteer-extra-plugin-stealth"; import { withTimeout } from "utils"; import { getBookmarkDetails, updateAsset } from "workerUtils"; -import type { ZCrawlLinkRequest } from "@hoarder/shared/queues"; -import { db } from "@hoarder/db"; +import type { ZCrawlLinkRequest } from "@karakeep/shared/queues"; +import { db } from "@karakeep/db"; import { assets, AssetTypes, bookmarkAssets, bookmarkLinks, bookmarks, -} from "@hoarder/db/schema"; +} from "@karakeep/db/schema"; import { ASSET_TYPES, getAssetSize, @@ -49,9 +49,9 @@ import { saveAssetFromFile, silentDeleteAsset, SUPPORTED_UPLOAD_ASSET_TYPES, -} from "@hoarder/shared/assetdb"; -import serverConfig from "@hoarder/shared/config"; -import logger from "@hoarder/shared/logger"; +} from "@karakeep/shared/assetdb"; +import serverConfig from "@karakeep/shared/config"; +import logger from "@karakeep/shared/logger"; import { AssetPreprocessingQueue, LinkCrawlerQueue, @@ -60,8 +60,8 @@ import { triggerVideoWorker, triggerWebhook, zCrawlLinkRequestSchema, -} from "@hoarder/shared/queues"; -import { BookmarkTypes } from "@hoarder/shared/types/bookmarks"; +} from "@karakeep/shared/queues"; +import { BookmarkTypes } from "@karakeep/shared/types/bookmarks"; const metascraperParser = metascraper([ metascraperDate({ diff --git a/apps/workers/exit.ts b/apps/workers/exit.ts index 29bfa5ef..cd50a323 100644 --- a/apps/workers/exit.ts +++ b/apps/workers/exit.ts @@ -1,4 +1,4 @@ -import logger from "@hoarder/shared/logger"; +import logger from "@karakeep/shared/logger"; export let isShuttingDown = false; diff --git a/apps/workers/feedWorker.ts b/apps/workers/feedWorker.ts index 9d5c110b..e393025a 100644 --- a/apps/workers/feedWorker.ts +++ b/apps/workers/feedWorker.ts @@ -5,12 +5,12 @@ import Parser from "rss-parser"; import { buildImpersonatingTRPCClient } from "trpc"; import { z } from "zod"; -import type { ZFeedRequestSchema } from "@hoarder/shared/queues"; -import { db } from "@hoarder/db"; -import { rssFeedImportsTable, rssFeedsTable } from "@hoarder/db/schema"; -import logger from "@hoarder/shared/logger"; -import { FeedQueue } from "@hoarder/shared/queues"; -import { BookmarkTypes } from "@hoarder/shared/types/bookmarks"; +import type { ZFeedRequestSchema } from "@karakeep/shared/queues"; +import { db } from "@karakeep/db"; +import { rssFeedImportsTable, rssFeedsTable } from "@karakeep/db/schema"; +import logger from "@karakeep/shared/logger"; +import { FeedQueue } from "@karakeep/shared/queues"; +import { BookmarkTypes } from "@karakeep/shared/types/bookmarks"; export const FeedRefreshingWorker = cron.schedule( "0 * * * *", diff --git a/apps/workers/index.ts b/apps/workers/index.ts index 3997b423..207c7f64 100644 --- a/apps/workers/index.ts +++ b/apps/workers/index.ts @@ -4,9 +4,9 @@ import { AssetPreprocessingWorker } from "assetPreprocessingWorker"; import { FeedRefreshingWorker, FeedWorker } from "feedWorker"; import { TidyAssetsWorker } from "tidyAssetsWorker"; -import serverConfig from "@hoarder/shared/config"; -import logger from "@hoarder/shared/logger"; -import { runQueueDBMigrations } from "@hoarder/shared/queues"; +import serverConfig from "@karakeep/shared/config"; +import logger from "@karakeep/shared/logger"; +import { runQueueDBMigrations } from "@karakeep/shared/queues"; import { CrawlerWorker } from "./crawlerWorker"; import { shutdownPromise } from "./exit"; diff --git a/apps/workers/openaiWorker.ts b/apps/workers/openaiWorker.ts index 64e36b82..7b0ae095 100644 --- a/apps/workers/openaiWorker.ts +++ b/apps/workers/openaiWorker.ts @@ -3,26 +3,26 @@ import { DequeuedJob, Runner } from "liteque"; import { buildImpersonatingTRPCClient } from "trpc"; import { z } from "zod"; -import type { InferenceClient } from "@hoarder/shared/inference"; -import type { ZOpenAIRequest } from "@hoarder/shared/queues"; -import { db } from "@hoarder/db"; +import type { InferenceClient } from "@karakeep/shared/inference"; +import type { ZOpenAIRequest } from "@karakeep/shared/queues"; +import { db } from "@karakeep/db"; import { bookmarks, bookmarkTags, customPrompts, tagsOnBookmarks, -} from "@hoarder/db/schema"; -import { readAsset } from "@hoarder/shared/assetdb"; -import serverConfig from "@hoarder/shared/config"; -import { InferenceClientFactory } from "@hoarder/shared/inference"; -import logger from "@hoarder/shared/logger"; -import { buildImagePrompt, buildTextPrompt } from "@hoarder/shared/prompts"; +} from "@karakeep/db/schema"; +import { readAsset } from "@karakeep/shared/assetdb"; +import serverConfig from "@karakeep/shared/config"; +import { InferenceClientFactory } from "@karakeep/shared/inference"; +import logger from "@karakeep/shared/logger"; +import { buildImagePrompt, buildTextPrompt } from "@karakeep/shared/prompts"; import { OpenAIQueue, triggerSearchReindex, triggerWebhook, zOpenAIRequestSchema, -} from "@hoarder/shared/queues"; +} from "@karakeep/shared/queues"; const openAIResponseSchema = z.object({ tags: z.array(z.string()), diff --git a/apps/workers/package.json b/apps/workers/package.json index 86d781aa..7ce1cbcf 100644 --- a/apps/workers/package.json +++ b/apps/workers/package.json @@ -1,14 +1,14 @@ { "$schema": "https://json.schemastore.org/package.json", - "name": "@hoarder/workers", + "name": "@karakeep/workers", "version": "0.1.0", "private": true, "dependencies": { "@ghostery/adblocker-puppeteer": "^2.1.1", - "@hoarder/db": "workspace:^0.1.0", - "@hoarder/shared": "workspace:^0.1.0", - "@hoarder/trpc": "workspace:^0.1.0", - "@hoarder/tsconfig": "workspace:^0.1.0", + "@karakeep/db": "workspace:^0.1.0", + "@karakeep/shared": "workspace:^0.1.0", + "@karakeep/trpc": "workspace:^0.1.0", + "@karakeep/tsconfig": "workspace:^0.1.0", "@mozilla/readability": "^0.5.0", "@tsconfig/node22": "^22.0.0", "async-mutex": "^0.4.1", @@ -46,8 +46,8 @@ "zod": "^3.22.4" }, "devDependencies": { - "@hoarder/eslint-config": "workspace:^0.2.0", - "@hoarder/prettier-config": "workspace:^0.1.0", + "@karakeep/eslint-config": "workspace:^0.2.0", + "@karakeep/prettier-config": "workspace:^0.1.0", "@types/jsdom": "^21.1.6", "@types/metascraper": "^5.14.3", "@types/node-cron": "^3.0.11" @@ -64,8 +64,8 @@ "eslintConfig": { "root": true, "extends": [ - "@hoarder/eslint-config/base" + "@karakeep/eslint-config/base" ] }, - "prettier": "@hoarder/prettier-config" + "prettier": "@karakeep/prettier-config" } diff --git a/apps/workers/searchWorker.ts b/apps/workers/searchWorker.ts index 7ad8b430..e7b827a9 100644 --- a/apps/workers/searchWorker.ts +++ b/apps/workers/searchWorker.ts @@ -1,15 +1,15 @@ import { eq } from "drizzle-orm"; import { DequeuedJob, Runner } from "liteque"; -import type { ZSearchIndexingRequest } from "@hoarder/shared/queues"; -import { db } from "@hoarder/db"; -import { bookmarks } from "@hoarder/db/schema"; -import logger from "@hoarder/shared/logger"; +import type { ZSearchIndexingRequest } from "@karakeep/shared/queues"; +import { db } from "@karakeep/db"; +import { bookmarks } from "@karakeep/db/schema"; +import logger from "@karakeep/shared/logger"; import { SearchIndexingQueue, zSearchIndexingRequestSchema, -} from "@hoarder/shared/queues"; -import { getSearchIdxClient } from "@hoarder/shared/search"; +} from "@karakeep/shared/queues"; +import { getSearchIdxClient } from "@karakeep/shared/search"; export class SearchIndexingWorker { static build() { diff --git a/apps/workers/tidyAssetsWorker.ts b/apps/workers/tidyAssetsWorker.ts index bea0b7d9..d4c8abdb 100644 --- a/apps/workers/tidyAssetsWorker.ts +++ b/apps/workers/tidyAssetsWorker.ts @@ -1,15 +1,15 @@ import { eq } from "drizzle-orm"; import { DequeuedJob, Runner } from "liteque"; -import { db } from "@hoarder/db"; -import { assets } from "@hoarder/db/schema"; -import { deleteAsset, getAllAssets } from "@hoarder/shared/assetdb"; -import logger from "@hoarder/shared/logger"; +import { db } from "@karakeep/db"; +import { assets } from "@karakeep/db/schema"; +import { deleteAsset, getAllAssets } from "@karakeep/shared/assetdb"; +import logger from "@karakeep/shared/logger"; import { TidyAssetsQueue, ZTidyAssetsRequest, zTidyAssetsRequestSchema, -} from "@hoarder/shared/queues"; +} from "@karakeep/shared/queues"; export class TidyAssetsWorker { static build() { diff --git a/apps/workers/trpc.ts b/apps/workers/trpc.ts index cd2e4c99..8bae287a 100644 --- a/apps/workers/trpc.ts +++ b/apps/workers/trpc.ts @@ -1,9 +1,9 @@ import { eq } from "drizzle-orm"; -import { db } from "@hoarder/db"; -import { users } from "@hoarder/db/schema"; -import { createCallerFactory } from "@hoarder/trpc"; -import { appRouter } from "@hoarder/trpc/routers/_app"; +import { db } from "@karakeep/db"; +import { users } from "@karakeep/db/schema"; +import { createCallerFactory } from "@karakeep/trpc"; +import { appRouter } from "@karakeep/trpc/routers/_app"; /** * This is only safe to use in the context of a worker. diff --git a/apps/workers/tsconfig.json b/apps/workers/tsconfig.json index 24b9a10d..58326836 100644 --- a/apps/workers/tsconfig.json +++ b/apps/workers/tsconfig.json @@ -1,6 +1,6 @@ { "$schema": "https://json.schemastore.org/tsconfig", - "extends": "@hoarder/tsconfig/node.json", + "extends": "@karakeep/tsconfig/node.json", "include": ["**/*.ts"], "exclude": ["node_modules"], "compilerOptions": { diff --git a/apps/workers/videoWorker.ts b/apps/workers/videoWorker.ts index 23ead8f8..b8f85ddf 100644 --- a/apps/workers/videoWorker.ts +++ b/apps/workers/videoWorker.ts @@ -4,22 +4,22 @@ import path from "path"; import { execa } from "execa";
import { DequeuedJob, Runner } from "liteque";
-import { db } from "@hoarder/db";
-import { AssetTypes } from "@hoarder/db/schema";
+import { db } from "@karakeep/db";
+import { AssetTypes } from "@karakeep/db/schema";
import {
ASSET_TYPES,
getAssetSize,
newAssetId,
saveAssetFromFile,
silentDeleteAsset,
-} from "@hoarder/shared/assetdb";
-import serverConfig from "@hoarder/shared/config";
-import logger from "@hoarder/shared/logger";
+} from "@karakeep/shared/assetdb";
+import serverConfig from "@karakeep/shared/config";
+import logger from "@karakeep/shared/logger";
import {
VideoWorkerQueue,
ZVideoRequest,
zvideoRequestSchema,
-} from "@hoarder/shared/queues";
+} from "@karakeep/shared/queues";
import { withTimeout } from "./utils";
import { getBookmarkDetails, updateAsset } from "./workerUtils";
diff --git a/apps/workers/webhookWorker.ts b/apps/workers/webhookWorker.ts index 820d3b87..fb8227e3 100644 --- a/apps/workers/webhookWorker.ts +++ b/apps/workers/webhookWorker.ts @@ -2,15 +2,15 @@ import { eq } from "drizzle-orm"; import { DequeuedJob, Runner } from "liteque"; import fetch from "node-fetch"; -import { db } from "@hoarder/db"; -import { bookmarks } from "@hoarder/db/schema"; -import serverConfig from "@hoarder/shared/config"; -import logger from "@hoarder/shared/logger"; +import { db } from "@karakeep/db"; +import { bookmarks } from "@karakeep/db/schema"; +import serverConfig from "@karakeep/shared/config"; +import logger from "@karakeep/shared/logger"; import { WebhookQueue, ZWebhookRequest, zWebhookRequestSchema, -} from "@hoarder/shared/queues"; +} from "@karakeep/shared/queues"; export class WebhookWorker { static build() { diff --git a/apps/workers/workerUtils.ts b/apps/workers/workerUtils.ts index 2b365c73..59a5a780 100644 --- a/apps/workers/workerUtils.ts +++ b/apps/workers/workerUtils.ts @@ -1,7 +1,7 @@ import { eq } from "drizzle-orm";
-import { db, HoarderDBTransaction } from "@hoarder/db";
-import { assets, AssetTypes, bookmarks } from "@hoarder/db/schema";
+import { db, HoarderDBTransaction } from "@karakeep/db";
+import { assets, AssetTypes, bookmarks } from "@karakeep/db/schema";
type DBAssetType = typeof assets.$inferInsert;
|
