summaryrefslogtreecommitdiff
path: root/packages/backend/src/services
diff options
context:
space:
mode:
authorsyuilo <Syuilotan@yahoo.co.jp>2022-04-03 22:36:30 +0900
committersyuilo <Syuilotan@yahoo.co.jp>2022-04-03 22:36:30 +0900
commitf8e6f3cc73b041acd7c8e8186090a297db3100a9 (patch)
treecd72442610caedb742419069065d014edbefadd8 /packages/backend/src/services
parentfix type (diff)
downloadsharkey-f8e6f3cc73b041acd7c8e8186090a297db3100a9.tar.gz
sharkey-f8e6f3cc73b041acd7c8e8186090a297db3100a9.tar.bz2
sharkey-f8e6f3cc73b041acd7c8e8186090a297db3100a9.zip
improve webhook
Diffstat (limited to 'packages/backend/src/services')
-rw-r--r--packages/backend/src/services/blocking/create.ts6
-rw-r--r--packages/backend/src/services/following/create.ts6
-rw-r--r--packages/backend/src/services/following/delete.ts3
-rw-r--r--packages/backend/src/services/following/reject.ts3
-rw-r--r--packages/backend/src/services/note/create.ts12
5 files changed, 10 insertions, 20 deletions
diff --git a/packages/backend/src/services/blocking/create.ts b/packages/backend/src/services/blocking/create.ts
index 5c67190079..5e96e5037f 100644
--- a/packages/backend/src/services/blocking/create.ts
+++ b/packages/backend/src/services/blocking/create.ts
@@ -65,8 +65,7 @@ async function cancelRequest(follower: User, followee: User) {
const webhooks = (await getActiveWebhooks()).filter(x => x.userId === follower.id && x.on.includes('unfollow'));
for (const webhook of webhooks) {
- webhookDeliver(webhook, {
- type: 'unfollow',
+ webhookDeliver(webhook, 'unfollow', {
user: packed,
});
}
@@ -118,8 +117,7 @@ async function unFollow(follower: User, followee: User) {
const webhooks = (await getActiveWebhooks()).filter(x => x.userId === follower.id && x.on.includes('unfollow'));
for (const webhook of webhooks) {
- webhookDeliver(webhook, {
- type: 'unfollow',
+ webhookDeliver(webhook, 'unfollow', {
user: packed,
});
}
diff --git a/packages/backend/src/services/following/create.ts b/packages/backend/src/services/following/create.ts
index 7bc839c62e..7491c44f83 100644
--- a/packages/backend/src/services/following/create.ts
+++ b/packages/backend/src/services/following/create.ts
@@ -97,8 +97,7 @@ export async function insertFollowingDoc(followee: { id: User['id']; host: User[
const webhooks = (await getActiveWebhooks()).filter(x => x.userId === follower.id && x.on.includes('follow'));
for (const webhook of webhooks) {
- webhookDeliver(webhook, {
- type: 'follow',
+ webhookDeliver(webhook, 'follow', {
user: packed,
});
}
@@ -112,8 +111,7 @@ export async function insertFollowingDoc(followee: { id: User['id']; host: User[
const webhooks = (await getActiveWebhooks()).filter(x => x.userId === followee.id && x.on.includes('followed'));
for (const webhook of webhooks) {
- webhookDeliver(webhook, {
- type: 'followed',
+ webhookDeliver(webhook, 'followed', {
user: packed,
});
}
diff --git a/packages/backend/src/services/following/delete.ts b/packages/backend/src/services/following/delete.ts
index 85e40f1365..241f9606e5 100644
--- a/packages/backend/src/services/following/delete.ts
+++ b/packages/backend/src/services/following/delete.ts
@@ -38,8 +38,7 @@ export default async function(follower: { id: User['id']; host: User['host']; ur
const webhooks = (await getActiveWebhooks()).filter(x => x.userId === follower.id && x.on.includes('unfollow'));
for (const webhook of webhooks) {
- webhookDeliver(webhook, {
- type: 'unfollow',
+ webhookDeliver(webhook, 'unfollow', {
user: packed,
});
}
diff --git a/packages/backend/src/services/following/reject.ts b/packages/backend/src/services/following/reject.ts
index e1744e05be..691fca2456 100644
--- a/packages/backend/src/services/following/reject.ts
+++ b/packages/backend/src/services/following/reject.ts
@@ -115,8 +115,7 @@ async function publishUnfollow(followee: Both, follower: Local) {
const webhooks = (await getActiveWebhooks()).filter(x => x.userId === follower.id && x.on.includes('unfollow'));
for (const webhook of webhooks) {
- webhookDeliver(webhook, {
- type: 'unfollow',
+ webhookDeliver(webhook, 'unfollow', {
user: packedFollowee,
});
}
diff --git a/packages/backend/src/services/note/create.ts b/packages/backend/src/services/note/create.ts
index 6f373aaf45..f14bc2059b 100644
--- a/packages/backend/src/services/note/create.ts
+++ b/packages/backend/src/services/note/create.ts
@@ -350,8 +350,7 @@ export default async (user: { id: User['id']; username: User['username']; host:
getActiveWebhooks().then(webhooks => {
webhooks = webhooks.filter(x => x.userId === user.id && x.on.includes('note'));
for (const webhook of webhooks) {
- webhookDeliver(webhook, {
- type: 'note',
+ webhookDeliver(webhook, 'note', {
note: noteObj,
});
}
@@ -380,8 +379,7 @@ export default async (user: { id: User['id']; username: User['username']; host:
const webhooks = (await getActiveWebhooks()).filter(x => x.userId === data.reply!.userId && x.on.includes('reply'));
for (const webhook of webhooks) {
- webhookDeliver(webhook, {
- type: 'reply',
+ webhookDeliver(webhook, 'reply', {
note: noteObj,
});
}
@@ -407,8 +405,7 @@ export default async (user: { id: User['id']; username: User['username']; host:
const webhooks = (await getActiveWebhooks()).filter(x => x.userId === data.renote!.userId && x.on.includes('renote'));
for (const webhook of webhooks) {
- webhookDeliver(webhook, {
- type: 'renote',
+ webhookDeliver(webhook, 'renote', {
note: noteObj,
});
}
@@ -650,8 +647,7 @@ async function createMentionedEvents(mentionedUsers: MinimumUser[], note: Note,
const webhooks = (await getActiveWebhooks()).filter(x => x.userId === u.id && x.on.includes('mention'));
for (const webhook of webhooks) {
- webhookDeliver(webhook, {
- type: 'mention',
+ webhookDeliver(webhook, 'mention', {
note: detailPackedNote,
});
}