From 140fa2595f62cf23dd49df03a51e82189448dd73 Mon Sep 17 00:00:00 2001
From: Prem Palanisamy <i.prem.tsd@gmail.com>
Date: Sat, 21 Mar 2026 21:45:30 +0000
Subject: [PATCH] (fix): migrate webhooks from projects service to dedicated
 webhooks service

---
 src/lib/stores/sdk.ts                         |  4 +++-
 .../settings/webhooks/+page.ts                |  2 +-
 .../settings/webhooks/[webhook]/+layout.ts    |  3 +--
 .../settings/webhooks/[webhook]/delete.svelte |  6 ++---
 .../webhooks/[webhook]/details.svelte         |  3 +--
 .../webhooks/[webhook]/regenerate.svelte      |  3 +--
 .../webhooks/[webhook]/updateEvents.svelte    |  3 +--
 .../webhooks/[webhook]/updateName.svelte      |  3 +--
 .../webhooks/[webhook]/updateSecurity.svelte  |  3 +--
 .../webhooks/[webhook]/updateURL.svelte       |  3 +--
 .../settings/webhooks/create/+page.svelte     | 23 +++++++++++--------
 11 files changed, 27 insertions(+), 29 deletions(-)

diff --git a/src/lib/stores/sdk.ts b/src/lib/stores/sdk.ts
index e844ce6ce..982e28906 100644
--- a/src/lib/stores/sdk.ts
+++ b/src/lib/stores/sdk.ts
@@ -26,7 +26,8 @@ import {
     DocumentsDB,
     Realtime,
     Organizations,
-    VectorsDB
+    VectorsDB,
+    Webhooks
 } from '@appwrite.io/console';
 import { Sources } from '$lib/sdk/sources';
 import {
@@ -139,6 +140,7 @@ const sdkForProject = {
     tablesDB: new TablesDB(clientProject),
     documentsDB: new DocumentsDB(clientProject),
     vectorsDB: new VectorsDB(clientProject),
+    webhooks: new Webhooks(clientProject),
     console: new Console(clientProject) // for suggestions API
 };
 
diff --git a/src/routes/(console)/project-[region]-[project]/settings/webhooks/+page.ts b/src/routes/(console)/project-[region]-[project]/settings/webhooks/+page.ts
index c92a17c27..4627c4ad4 100644
--- a/src/routes/(console)/project-[region]-[project]/settings/webhooks/+page.ts
+++ b/src/routes/(console)/project-[region]-[project]/settings/webhooks/+page.ts
@@ -10,6 +10,6 @@ export const load: PageLoad = async ({ params, url, depends }) => {
 
     return {
         page,
-        webhooks: await sdk.forConsole.projects.listWebhooks({ projectId: params.project })
+        webhooks: await sdk.forProject(params.region, params.project).webhooks.list()
     };
 };
diff --git a/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/+layout.ts b/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/+layout.ts
index ce9bf4f03..029f6be1b 100644
--- a/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/+layout.ts
+++ b/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/+layout.ts
@@ -10,8 +10,7 @@ export const load: LayoutLoad = async ({ params, depends }) => {
     return {
         header: Header,
         breadcrumbs: Breadcrumbs,
-        webhook: await sdk.forConsole.projects.getWebhook({
-            projectId: params.project,
+        webhook: await sdk.forProject(params.region, params.project).webhooks.get({
             webhookId: params.webhook
         })
     };
diff --git a/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/delete.svelte b/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/delete.svelte
index c0822603f..ca4cc1fdb 100644
--- a/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/delete.svelte
+++ b/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/delete.svelte
@@ -1,5 +1,6 @@
 <script lang="ts">
     import { goto, invalidate } from '$app/navigation';
+    import { page } from '$app/state';
     import { base } from '$app/paths';
     import { Submit, trackEvent, trackError } from '$lib/actions/analytics';
     import Confirm from '$lib/components/confirm.svelte';
@@ -14,8 +15,7 @@
     let error: string;
     async function handleDelete() {
         try {
-            await sdk.forConsole.projects.deleteWebhook({
-                projectId: $project.$id,
+            await sdk.forProject(page.params.region, $project.$id).webhooks.delete({
                 webhookId: $webhook.$id
             });
             await invalidate(Dependencies.WEBHOOKS);
@@ -25,7 +25,7 @@
                 message: `${$webhook.name} has been deleted`
             });
             trackEvent(Submit.WebhookDelete);
-            await goto(`${base}/project-${$project.region}-${$project.$id}/settings/webhooks`);
+            await goto(`${base}/project-${page.params.region}-${$project.$id}/settings/webhooks`);
         } catch (e) {
             error = e.message;
             trackError(e, Submit.WebhookDelete);
diff --git a/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/details.svelte b/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/details.svelte
index d41bed0e7..2907e35ea 100644
--- a/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/details.svelte
+++ b/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/details.svelte
@@ -25,8 +25,7 @@
 
     async function setEnabled() {
         try {
-            await sdk.forConsole.projects.updateWebhook({
-                projectId,
+            await sdk.forProject(page.params.region, projectId).webhooks.update({
                 webhookId: $webhook.$id,
                 name: $webhook.name,
                 events: $webhook.events,
diff --git a/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/regenerate.svelte b/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/regenerate.svelte
index 740efbe5e..0018a7307 100644
--- a/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/regenerate.svelte
+++ b/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/regenerate.svelte
@@ -13,8 +13,7 @@
 
     async function regenerate() {
         try {
-            await sdk.forConsole.projects.updateWebhookSignature({
-                projectId,
+            await sdk.forProject(page.params.region, projectId).webhooks.updateSignature({
                 webhookId: $webhook.$id
             });
             await invalidate(Dependencies.WEBHOOK);
diff --git a/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/updateEvents.svelte b/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/updateEvents.svelte
index e4e498ae7..56094759b 100644
--- a/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/updateEvents.svelte
+++ b/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/updateEvents.svelte
@@ -26,8 +26,7 @@
 
     async function updateEvents() {
         try {
-            await sdk.forConsole.projects.updateWebhook({
-                projectId,
+            await sdk.forProject(page.params.region, projectId).webhooks.update({
                 webhookId: $webhook.$id,
                 name: $webhook.name,
                 events: Array.from($eventSet),
diff --git a/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/updateName.svelte b/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/updateName.svelte
index 9a531da76..842b0a75f 100644
--- a/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/updateName.svelte
+++ b/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/updateName.svelte
@@ -19,8 +19,7 @@
 
     async function updateName() {
         try {
-            await sdk.forConsole.projects.updateWebhook({
-                projectId,
+            await sdk.forProject(page.params.region, projectId).webhooks.update({
                 webhookId: $webhook.$id,
                 name,
                 events: $webhook.events,
diff --git a/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/updateSecurity.svelte b/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/updateSecurity.svelte
index c596214bf..7b801473c 100644
--- a/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/updateSecurity.svelte
+++ b/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/updateSecurity.svelte
@@ -24,8 +24,7 @@
 
     async function updateSecurity() {
         try {
-            await sdk.forConsole.projects.updateWebhook({
-                projectId,
+            await sdk.forProject(page.params.region, projectId).webhooks.update({
                 webhookId: $webhook.$id,
                 name: $webhook.name,
                 events: $webhook.events,
diff --git a/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/updateURL.svelte b/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/updateURL.svelte
index 0c0f4c80e..081a3b2c1 100644
--- a/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/updateURL.svelte
+++ b/src/routes/(console)/project-[region]-[project]/settings/webhooks/[webhook]/updateURL.svelte
@@ -19,8 +19,7 @@
 
     async function updateUrl() {
         try {
-            await sdk.forConsole.projects.updateWebhook({
-                projectId,
+            await sdk.forProject(page.params.region, projectId).webhooks.update({
                 webhookId: $webhook.$id,
                 name: $webhook.name,
                 events: $webhook.events,
diff --git a/src/routes/(console)/project-[region]-[project]/settings/webhooks/create/+page.svelte b/src/routes/(console)/project-[region]-[project]/settings/webhooks/create/+page.svelte
index 354abe781..3c95e0fed 100644
--- a/src/routes/(console)/project-[region]-[project]/settings/webhooks/create/+page.svelte
+++ b/src/routes/(console)/project-[region]-[project]/settings/webhooks/create/+page.svelte
@@ -5,6 +5,7 @@
     import { Layout } from '@appwrite.io/pink-svelte';
     import Form from '$lib/elements/forms/form.svelte';
     import { goto } from '$app/navigation';
+    import { ID } from '@appwrite.io/console';
     import { sdk } from '$lib/stores/sdk';
     import { Submit, trackError, trackEvent } from '$lib/actions/analytics';
     import { addNotification } from '$lib/stores/notifications';
@@ -25,16 +26,18 @@
     export let data;
     async function create() {
         try {
-            const webhook = await sdk.forConsole.projects.createWebhook({
-                projectId: data.project.$id,
-                name,
-                events,
-                url,
-                security,
-                enabled: true,
-                httpUser: httpUser || undefined,
-                httpPass: httpPass || undefined
-            });
+            const webhook = await sdk
+                .forProject(page.params.region, data.project.$id)
+                .webhooks.create({
+                    webhookId: ID.unique(),
+                    name,
+                    events,
+                    url,
+                    security,
+                    enabled: true,
+                    httpUser: httpUser || undefined,
+                    httpPass: httpPass || undefined
+                });
             addNotification({
                 message: 'Webhook has been created',
                 type: 'success'