summaryrefslogtreecommitdiff
path: root/packages/backend/src/services
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/services
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/services')
-rw-r--r--packages/backend/src/services/blocking/create.ts6
-rw-r--r--packages/backend/src/services/drive/upload-from-url.ts4
-rw-r--r--packages/backend/src/services/fetch-instance-metadata.ts11
-rw-r--r--packages/backend/src/services/following/create.ts8
-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
7 files changed, 19 insertions, 28 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/drive/upload-from-url.ts b/packages/backend/src/services/drive/upload-from-url.ts
index 5007fff6ee..79b1b8c2e1 100644
--- a/packages/backend/src/services/drive/upload-from-url.ts
+++ b/packages/backend/src/services/drive/upload-from-url.ts
@@ -29,7 +29,7 @@ export async function uploadFromUrl({
sensitive = false,
force = false,
isLink = false,
- comment = null
+ comment = null,
}: Args): Promise<DriveFile> {
let name = new URL(url).pathname.split('/').pop() || null;
if (name == null || !DriveFiles.validateFileName(name)) {
@@ -38,7 +38,7 @@ export async function uploadFromUrl({
// If the comment is same as the name, skip comment
// (image.name is passed in when receiving attachment)
- if (comment !== null && name == comment) {
+ if (comment !== null && name === comment) {
comment = null;
}
diff --git a/packages/backend/src/services/fetch-instance-metadata.ts b/packages/backend/src/services/fetch-instance-metadata.ts
index 2b6f82a910..d5294c5fe8 100644
--- a/packages/backend/src/services/fetch-instance-metadata.ts
+++ b/packages/backend/src/services/fetch-instance-metadata.ts
@@ -97,7 +97,7 @@ async function fetchNodeinfo(instance: Instance): Promise<NodeInfo> {
} else {
throw e.statusCode || e.message;
}
- });
+ }) as Record<string, unknown>;
if (wellknown.links == null || !Array.isArray(wellknown.links)) {
throw 'No wellknown links';
@@ -121,7 +121,7 @@ async function fetchNodeinfo(instance: Instance): Promise<NodeInfo> {
logger.succ(`Successfuly fetched nodeinfo of ${instance.host}`);
- return info;
+ return info as NodeInfo;
} catch (e) {
logger.error(`Failed to fetch nodeinfo of ${instance.host}: ${e}`);
@@ -142,12 +142,12 @@ async function fetchDom(instance: Instance): Promise<DOMWindow['document']> {
return doc;
}
-async function fetchManifest(instance: Instance): Promise<Record<string, any> | null> {
+async function fetchManifest(instance: Instance): Promise<Record<string, unknown> | null> {
const url = 'https://' + instance.host;
const manifestUrl = url + '/manifest.json';
- const manifest = await getJson(manifestUrl);
+ const manifest = await getJson(manifestUrl) as Record<string, unknown>;
return manifest;
}
@@ -167,7 +167,8 @@ async function fetchFaviconUrl(instance: Instance, doc: DOMWindow['document'] |
const faviconUrl = url + '/favicon.ico';
const favicon = await fetch(faviconUrl, {
- timeout: 10000,
+ // TODO
+ //timeout: 10000,
agent: getAgentByUrl,
});
diff --git a/packages/backend/src/services/following/create.ts b/packages/backend/src/services/following/create.ts
index d243317d97..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,
});
}
@@ -108,12 +107,11 @@ export async function insertFollowingDoc(followee: { id: User['id']; host: User[
// Publish followed event
if (Users.isLocalUser(followee)) {
Users.pack(follower.id, followee).then(async packed => {
- publishMainStream(followee.id, 'followed', packed)
+ publishMainStream(followee.id, 'followed', packed);
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,
});
}