summaryrefslogtreecommitdiff
path: root/packages/backend/src
diff options
context:
space:
mode:
authortamaina <tamaina@hotmail.co.jp>2022-12-03 16:59:28 +0000
committertamaina <tamaina@hotmail.co.jp>2022-12-03 16:59:28 +0000
commit14221e78b7b98ffa93e15c211769a0e88be088e5 (patch)
tree05f9fe13b4c33999fec6aa3f1636196c40a6f06c /packages/backend/src
parentUpdate package.json (diff)
downloadmisskey-14221e78b7b98ffa93e15c211769a0e88be088e5.tar.gz
misskey-14221e78b7b98ffa93e15c211769a0e88be088e5.tar.bz2
misskey-14221e78b7b98ffa93e15c211769a0e88be088e5.zip
Fix forkbomb 2
also in extractApMentions and parseAudience Co-authored-by: mei23 <m@m544.net>
Diffstat (limited to 'packages/backend/src')
-rw-r--r--packages/backend/src/core/remote/activitypub/models/ApMentionService.ts8
-rw-r--r--packages/backend/src/core/remote/activitypub/models/ApNoteService.ts4
2 files changed, 5 insertions, 7 deletions
diff --git a/packages/backend/src/core/remote/activitypub/models/ApMentionService.ts b/packages/backend/src/core/remote/activitypub/models/ApMentionService.ts
index 710e1acfaf..1275e24c62 100644
--- a/packages/backend/src/core/remote/activitypub/models/ApMentionService.ts
+++ b/packages/backend/src/core/remote/activitypub/models/ApMentionService.ts
@@ -6,7 +6,7 @@ import type { Config } from '@/config.js';
import { toArray, unique } from '@/misc/prelude/array.js';
import type { CacheableUser } from '@/models/entities/User.js';
import { isMention } from '../type.js';
-import { ApResolverService } from '../ApResolverService.js';
+import { ApResolverService, Resolver } from '../ApResolverService.js';
import { ApPersonService } from './ApPersonService.js';
import type { IObject, IApMention } from '../type.js';
@@ -21,11 +21,9 @@ export class ApMentionService {
) {
}
- public async extractApMentions(tags: IObject | IObject[] | null | undefined) {
+ public async extractApMentions(tags: IObject | IObject[] | null | undefined, resolver: Resolver) {
const hrefs = unique(this.extractApMentionObjects(tags).map(x => x.href as string));
-
- const resolver = this.apResolverService.createResolver();
-
+
const limit = promiseLimit<CacheableUser | null>(2);
const mentionedUsers = (await Promise.all(
hrefs.map(x => limit(() => this.apPersonService.resolvePerson(x, resolver).catch(() => null))),
diff --git a/packages/backend/src/core/remote/activitypub/models/ApNoteService.ts b/packages/backend/src/core/remote/activitypub/models/ApNoteService.ts
index a34a1d1eb8..7cf6725a38 100644
--- a/packages/backend/src/core/remote/activitypub/models/ApNoteService.ts
+++ b/packages/backend/src/core/remote/activitypub/models/ApNoteService.ts
@@ -140,7 +140,7 @@ export class ApNoteService {
throw new Error('actor has been suspended');
}
- const noteAudience = await this.apAudienceService.parseAudience(actor, note.to, note.cc);
+ const noteAudience = await this.apAudienceService.parseAudience(actor, note.to, note.cc, resolver);
let visibility = noteAudience.visibility;
const visibleUsers = noteAudience.visibleUsers;
@@ -154,7 +154,7 @@ export class ApNoteService {
let isMessaging = note._misskey_talk && visibility === 'specified';
- const apMentions = await this.apMentionService.extractApMentions(note.tag);
+ const apMentions = await this.apMentionService.extractApMentions(note.tag, resolver);
const apHashtags = await extractApHashtags(note.tag);
// 添付ファイル