149 lines
3.6 KiB
TypeScript
149 lines
3.6 KiB
TypeScript
import $ from 'cafy';
|
|
import define from '../../define';
|
|
import config from '../../../../config';
|
|
import { createPerson } from '../../../../remote/activitypub/models/person';
|
|
import { createNote } from '../../../../remote/activitypub/models/note';
|
|
import Resolver from '../../../../remote/activitypub/resolver';
|
|
import { ApiError } from '../../error';
|
|
import { extractDbHost } from '../../../../misc/convert-host';
|
|
import { Users, Notes } from '../../../../models';
|
|
import { Note } from '../../../../models/entities/note';
|
|
import { User } from '../../../../models/entities/user';
|
|
import fetchMeta from '../../../../misc/fetch-meta';
|
|
|
|
export const meta = {
|
|
tags: ['federation'],
|
|
|
|
desc: {
|
|
'ja-JP': 'URIを指定してActivityPubオブジェクトを参照します。'
|
|
},
|
|
|
|
requireCredential: false,
|
|
|
|
params: {
|
|
uri: {
|
|
validator: $.str,
|
|
desc: {
|
|
'ja-JP': 'ActivityPubオブジェクトのURI'
|
|
}
|
|
},
|
|
},
|
|
|
|
errors: {
|
|
noSuchObject: {
|
|
message: 'No such object.',
|
|
code: 'NO_SUCH_OBJECT',
|
|
id: 'dc94d745-1262-4e63-a17d-fecaa57efc82'
|
|
}
|
|
}
|
|
};
|
|
|
|
export default define(meta, async (ps) => {
|
|
const object = await fetchAny(ps.uri);
|
|
if (object) {
|
|
return object;
|
|
} else {
|
|
throw new ApiError(meta.errors.noSuchObject);
|
|
}
|
|
});
|
|
|
|
/***
|
|
* URIからUserかNoteを解決する
|
|
*/
|
|
async function fetchAny(uri: string) {
|
|
// URIがこのサーバーを指しているなら、ローカルユーザーIDとしてDBからフェッチ
|
|
if (uri.startsWith(config.url + '/')) {
|
|
const parts = uri.split('/');
|
|
const id = parts.pop();
|
|
const type = parts.pop();
|
|
|
|
if (type === 'notes') {
|
|
const note = await Notes.findOne(id);
|
|
|
|
if (note) {
|
|
return {
|
|
type: 'Note',
|
|
object: await Notes.pack(note, null, { detail: true })
|
|
};
|
|
}
|
|
} else if (type === 'users') {
|
|
const user = await Users.findOne(id);
|
|
|
|
if (user) {
|
|
return {
|
|
type: 'User',
|
|
object: await Users.pack(user, null, { detail: true })
|
|
};
|
|
}
|
|
}
|
|
}
|
|
|
|
// ブロックしてたら中断
|
|
const meta = await fetchMeta();
|
|
if (meta.blockedHosts.includes(extractDbHost(uri))) return null;
|
|
|
|
// URI(AP Object id)としてDB検索
|
|
{
|
|
const [user, note] = await Promise.all([
|
|
Users.findOne({ uri: uri }),
|
|
Notes.findOne({ uri: uri })
|
|
]);
|
|
|
|
const packed = await mergePack(user, note);
|
|
if (packed !== null) return packed;
|
|
}
|
|
|
|
// リモートから一旦オブジェクトフェッチ
|
|
const resolver = new Resolver();
|
|
const object = await resolver.resolve(uri) as any;
|
|
|
|
// /@user のような正規id以外で取得できるURIが指定されていた場合、ここで初めて正規URIが確定する
|
|
// これはDBに存在する可能性があるため再度DB検索
|
|
if (uri !== object.id) {
|
|
const [user, note] = await Promise.all([
|
|
Users.findOne({ uri: object.id }),
|
|
Notes.findOne({ uri: object.id })
|
|
]);
|
|
|
|
const packed = await mergePack(user, note);
|
|
if (packed !== null) return packed;
|
|
}
|
|
|
|
// それでもみつからなければ新規であるため登録
|
|
if (object.type === 'Person') {
|
|
const user = await createPerson(object.id);
|
|
return {
|
|
type: 'User',
|
|
object: await Users.pack(user, null, { detail: true })
|
|
};
|
|
}
|
|
|
|
if (['Note', 'Question', 'Article'].includes(object.type)) {
|
|
const note = await createNote(object.id);
|
|
return {
|
|
type: 'Note',
|
|
object: await Notes.pack(note, null, { detail: true })
|
|
};
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
async function mergePack(user: User, note: Note) {
|
|
if (user != null) {
|
|
return {
|
|
type: 'User',
|
|
object: await Users.pack(user, null, { detail: true })
|
|
};
|
|
}
|
|
|
|
if (note != null) {
|
|
return {
|
|
type: 'Note',
|
|
object: await Notes.pack(note, null, { detail: true })
|
|
};
|
|
}
|
|
|
|
return null;
|
|
}
|