aboutsummaryrefslogtreecommitdiffstats
path: root/apps/workers
diff options
context:
space:
mode:
authorMohamedBassem <me@mbassem.com>2025-04-12 19:37:18 +0100
committerMohamedBassem <me@mbassem.com>2025-04-12 19:37:40 +0100
commit755fc36e912964863d4f46bb32adda6332b419fe (patch)
tree3c54e9e6ed7686a119804716ccb6fdd6ad0da3c3 /apps/workers
parent7f569042f153a55189fb28e6ef6ab127b8190afd (diff)
downloadkarakeep-755fc36e912964863d4f46bb32adda6332b419fe.tar.zst
chore: Rename hoarder packages to karakeep
Diffstat (limited to 'apps/workers')
-rw-r--r--apps/workers/assetPreprocessingWorker.ts14
-rw-r--r--apps/workers/crawlerWorker.ts16
-rw-r--r--apps/workers/exit.ts2
-rw-r--r--apps/workers/feedWorker.ts12
-rw-r--r--apps/workers/index.ts6
-rw-r--r--apps/workers/openaiWorker.ts20
-rw-r--r--apps/workers/package.json18
-rw-r--r--apps/workers/searchWorker.ts12
-rw-r--r--apps/workers/tidyAssetsWorker.ts10
-rw-r--r--apps/workers/trpc.ts8
-rw-r--r--apps/workers/tsconfig.json2
-rw-r--r--apps/workers/videoWorker.ts12
-rw-r--r--apps/workers/webhookWorker.ts10
-rw-r--r--apps/workers/workerUtils.ts4
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;