summaryrefslogtreecommitdiff
path: root/packages/backend/src/queue/processors
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2022-04-11 23:13:18 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2022-04-11 23:13:18 +0900
commit33c22b5f3efa4110c9b517c224c9fdfba7e6c64b (patch)
treec029245de51666da7ab15cf5ae08f05b4ee32622 /packages/backend/src/queue/processors
parentMerge branch 'develop' (diff)
parent12.110.0 (diff)
downloadmisskey-33c22b5f3efa4110c9b517c224c9fdfba7e6c64b.tar.gz
misskey-33c22b5f3efa4110c9b517c224c9fdfba7e6c64b.tar.bz2
misskey-33c22b5f3efa4110c9b517c224c9fdfba7e6c64b.zip
Merge branch 'develop'
Diffstat (limited to 'packages/backend/src/queue/processors')
-rw-r--r--packages/backend/src/queue/processors/webhook-deliver.ts15
1 files changed, 9 insertions, 6 deletions
diff --git a/packages/backend/src/queue/processors/webhook-deliver.ts b/packages/backend/src/queue/processors/webhook-deliver.ts
index a4d39d86e4..d49206f68f 100644
--- a/packages/backend/src/queue/processors/webhook-deliver.ts
+++ b/packages/backend/src/queue/processors/webhook-deliver.ts
@@ -8,13 +8,9 @@ import config from '@/config/index.js';
const logger = new Logger('webhook');
-let latest: string | null = null;
-
export default async (job: Bull.Job<WebhookDeliverJobData>) => {
try {
- if (latest !== (latest = JSON.stringify(job.data.content, null, 2))) {
- logger.debug(`delivering ${latest}`);
- }
+ logger.debug(`delivering ${job.data.webhookId}`);
const res = await getResponse({
url: job.data.to,
@@ -25,7 +21,14 @@ export default async (job: Bull.Job<WebhookDeliverJobData>) => {
'X-Misskey-Hook-Id': job.data.webhookId,
'X-Misskey-Hook-Secret': job.data.secret,
},
- body: JSON.stringify(job.data.content),
+ body: JSON.stringify({
+ hookId: job.data.webhookId,
+ userId: job.data.userId,
+ eventId: job.data.eventId,
+ createdAt: job.data.createdAt,
+ type: job.data.type,
+ body: job.data.content,
+ }),
});
Webhooks.update({ id: job.data.webhookId }, {