111 lines
4.1 KiB
TypeScript
111 lines
4.1 KiB
TypeScript
import { Inject, Injectable } from '@nestjs/common';
|
|
import ms from 'ms';
|
|
import { Endpoint } from '@/server/api/endpoint-base.js';
|
|
import type { UsersRepository, NotesRepository } from '@/models/index.js';
|
|
import type { Note } from '@/models/entities/Note.js';
|
|
import type { LocalUser, User } from '@/models/entities/User.js';
|
|
import { isActor, isPost, getApId } from '@/core/activitypub/type.js';
|
|
import type { SchemaType } from 'schema-type';
|
|
import { ApResolverService } from '@/core/activitypub/ApResolverService.js';
|
|
import { ApDbResolverService } from '@/core/activitypub/ApDbResolverService.js';
|
|
import { MetaService } from '@/core/MetaService.js';
|
|
import { ApPersonService } from '@/core/activitypub/models/ApPersonService.js';
|
|
import { ApNoteService } from '@/core/activitypub/models/ApNoteService.js';
|
|
import { UserEntityService } from '@/core/entities/UserEntityService.js';
|
|
import { NoteEntityService } from '@/core/entities/NoteEntityService.js';
|
|
import { UtilityService } from '@/core/UtilityService.js';
|
|
import { DI } from '@/di-symbols.js';
|
|
import { bindThis } from '@/decorators.js';
|
|
import { ApiError } from '../../error.js';
|
|
import { Endpoints } from 'misskey-js';
|
|
import { References } from 'misskey-js/built/schemas.js';
|
|
|
|
// eslint-disable-next-line import/no-default-export
|
|
@Injectable()
|
|
export default class extends Endpoint<'ap/show'> {
|
|
name = 'ap/show' as const;
|
|
constructor(
|
|
@Inject(DI.usersRepository)
|
|
private usersRepository: UsersRepository,
|
|
|
|
@Inject(DI.notesRepository)
|
|
private notesRepository: NotesRepository,
|
|
|
|
private utilityService: UtilityService,
|
|
private userEntityService: UserEntityService,
|
|
private noteEntityService: NoteEntityService,
|
|
private metaService: MetaService,
|
|
private apResolverService: ApResolverService,
|
|
private apDbResolverService: ApDbResolverService,
|
|
private apPersonService: ApPersonService,
|
|
private apNoteService: ApNoteService,
|
|
) {
|
|
super(async (ps, me) => {
|
|
const object = await this.fetchAny(ps.uri, me);
|
|
if (object) {
|
|
return object;
|
|
} else {
|
|
throw new ApiError(this.meta.errors.noSuchObject);
|
|
}
|
|
});
|
|
}
|
|
|
|
/***
|
|
* URIからUserかNoteを解決する
|
|
*/
|
|
@bindThis
|
|
private async fetchAny(uri: string, me: LocalUser | null | undefined): Promise<SchemaType<Endpoints['ap/show']['defines'][number]['res'], References> | null> {
|
|
// ブロックしてたら中断
|
|
const fetchedMeta = await this.metaService.fetch();
|
|
if (this.utilityService.isBlockedHost(fetchedMeta.blockedHosts, this.utilityService.extractDbHost(uri))) return null;
|
|
|
|
let local = await this.mergePack(me, ...await Promise.all([
|
|
this.apDbResolverService.getUserFromApId(uri),
|
|
this.apDbResolverService.getNoteFromApId(uri),
|
|
]));
|
|
if (local != null) return local;
|
|
|
|
// リモートから一旦オブジェクトフェッチ
|
|
const resolver = this.apResolverService.createResolver();
|
|
const object = await resolver.resolve(uri) as any;
|
|
|
|
// /@user のような正規id以外で取得できるURIが指定されていた場合、ここで初めて正規URIが確定する
|
|
// これはDBに存在する可能性があるため再度DB検索
|
|
if (uri !== object.id) {
|
|
local = await this.mergePack(me, ...await Promise.all([
|
|
this.apDbResolverService.getUserFromApId(object.id),
|
|
this.apDbResolverService.getNoteFromApId(object.id),
|
|
]));
|
|
if (local != null) return local;
|
|
}
|
|
|
|
return await this.mergePack(
|
|
me,
|
|
isActor(object) ? await this.apPersonService.createPerson(getApId(object)) : null,
|
|
isPost(object) ? await this.apNoteService.createNote(getApId(object), undefined, true) : null,
|
|
);
|
|
}
|
|
|
|
@bindThis
|
|
private async mergePack(me: LocalUser | null | undefined, user: User | null | undefined, note: Note | null | undefined): Promise<SchemaType<Endpoints['ap/show']['defines'][number]['res'], References> | null> {
|
|
if (user != null) {
|
|
return {
|
|
type: 'User',
|
|
object: await this.userEntityService.pack(user, me, { detail: true }),
|
|
};
|
|
} else if (note != null) {
|
|
try {
|
|
const object = await this.noteEntityService.pack(note, me, { detail: true });
|
|
|
|
return {
|
|
type: 'Note',
|
|
object,
|
|
};
|
|
} catch (e) {
|
|
return null;
|
|
}
|
|
}
|
|
|
|
return null;
|
|
}
|
|
}
|