aboutsummaryrefslogtreecommitdiffstats
path: root/packages/trpc/routers/bookmarks.ts
diff options
context:
space:
mode:
authorMohamed Bassem <me@mbassem.com>2025-01-19 13:55:40 +0000
committerMohamed Bassem <me@mbassem.com>2025-01-19 19:06:48 +0000
commitcddaefd9420507318d71f56355ff5a6648dcd951 (patch)
treecf196ef12c36fdb0502b5ebf0f722ab32de8e2c0 /packages/trpc/routers/bookmarks.ts
parent64f24acb9a1835ea7f0bec241c233c3e4a202d46 (diff)
downloadkarakeep-cddaefd9420507318d71f56355ff5a6648dcd951.tar.zst
feat: Change webhooks to be configurable by users
Diffstat (limited to 'packages/trpc/routers/bookmarks.ts')
-rw-r--r--packages/trpc/routers/bookmarks.ts6
1 files changed, 6 insertions, 0 deletions
diff --git a/packages/trpc/routers/bookmarks.ts b/packages/trpc/routers/bookmarks.ts
index 349ff688..4426ab14 100644
--- a/packages/trpc/routers/bookmarks.ts
+++ b/packages/trpc/routers/bookmarks.ts
@@ -48,6 +48,7 @@ import {
OpenAIQueue,
triggerSearchDeletion,
triggerSearchReindex,
+ triggerWebhook,
} from "@hoarder/shared/queues";
import { getSearchIdxClient } from "@hoarder/shared/search";
import { parseSearchQuery } from "@hoarder/shared/searchQueryParser";
@@ -442,6 +443,7 @@ export const bookmarksAppRouter = router({
}
}
await triggerSearchReindex(bookmark.id);
+ await triggerWebhook(bookmark.id, "created");
return bookmark;
}),
@@ -474,6 +476,7 @@ export const bookmarksAppRouter = router({
});
}
await triggerSearchReindex(input.bookmarkId);
+ await triggerWebhook(input.bookmarkId, "edited");
return res[0];
}),
@@ -500,6 +503,7 @@ export const bookmarksAppRouter = router({
});
}
await triggerSearchReindex(input.bookmarkId);
+ await triggerWebhook(input.bookmarkId, "edited");
}),
deleteBookmark: authedProcedure
@@ -1012,6 +1016,7 @@ export const bookmarksAppRouter = router({
.onConflictDoNothing();
await triggerSearchReindex(input.bookmarkId);
+ await triggerWebhook(input.bookmarkId, "edited");
return {
bookmarkId: input.bookmarkId,
attached: allIds,
@@ -1254,6 +1259,7 @@ Content: ${bookmark.content ?? ""}
})
.where(eq(bookmarks.id, input.bookmarkId));
await triggerSearchReindex(input.bookmarkId);
+ await triggerWebhook(input.bookmarkId, "edited");
return {
bookmarkId: input.bookmarkId,