summaryrefslogtreecommitdiff
path: root/packages/backend/src/queue
diff options
context:
space:
mode:
Diffstat (limited to 'packages/backend/src/queue')
-rw-r--r--packages/backend/src/queue/index.ts1
-rw-r--r--packages/backend/src/queue/processors/webhook-deliver.ts1
-rw-r--r--packages/backend/src/queue/types.ts1
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;