From cddaefd9420507318d71f56355ff5a6648dcd951 Mon Sep 17 00:00:00 2001 From: Mohamed Bassem Date: Sun, 19 Jan 2025 13:55:40 +0000 Subject: feat: Change webhooks to be configurable by users --- packages/trpc/routers/bookmarks.ts | 6 ++++++ 1 file changed, 6 insertions(+) (limited to 'packages/trpc/routers/bookmarks.ts') 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, -- cgit v1.2.3-70-g09d2