enhance(webhook): add userId to payload

3 files changed, 3 insertions, 0 deletions

diff --git a/packages/backend/src/queue/index.ts b/packages/backend/src/queue/index.ts
index 5bd922468d..2d40290e4c 100644
--- a/packages/backend/src/queue/index.ts
+++ b/packages/backend/src/queue/index.ts
@@ -268,6 +268,7 @@ export function webhookDeliver(webhook: Webhook, type: typeof webhookEventTypes[
 		type,
 		content,
 		webhookId: webhook.id,
+		userId: webhook.userId,
 		to: webhook.url,
 		secret: webhook.secret,
 		createdAt: Date.now(),
diff --git a/packages/backend/src/queue/processors/webhook-deliver.ts b/packages/backend/src/queue/processors/webhook-deliver.ts
index 01d779311e..d49206f68f 100644
--- a/packages/backend/src/queue/processors/webhook-deliver.ts
+++ b/packages/backend/src/queue/processors/webhook-deliver.ts
@@ -23,6 +23,7 @@ export default async (job: Bull.Job<WebhookDeliverJobData>) => {
 			},
 			body: JSON.stringify({
 				hookId: job.data.webhookId,
+				userId: job.data.userId,
 				eventId: job.data.eventId,
 				createdAt: job.data.createdAt,
 				type: job.data.type,
diff --git a/packages/backend/src/queue/types.ts b/packages/backend/src/queue/types.ts
index c005f78ec2..6c0b9d9bf6 100644
--- a/packages/backend/src/queue/types.ts
+++ b/packages/backend/src/queue/types.ts
@@ -51,6 +51,7 @@ export type WebhookDeliverJobData = {
 	type: string;
 	content: unknown;
 	webhookId: Webhook['id'];
+	userId: User['id'];
 	to: string;
 	secret: string;
 	createdAt: number;