MeiMei
353 lines
11 KiB
TypeScript
353 lines
11 KiB
TypeScript
import * as promiseLimit from 'promise-limit';
|
|
|
|
import config from '../../../config';
|
|
import Resolver from '../resolver';
|
|
import post from '../../../services/note/create';
|
|
import { resolvePerson, updatePerson } from './person';
|
|
import { resolveImage } from './image';
|
|
import { IRemoteUser, User } from '../../../models/entities/user';
|
|
import { fromHtml } from '../../../mfm/fromHtml';
|
|
import { ITag, extractHashtags } from './tag';
|
|
import { unique, concat, difference } from '../../../prelude/array';
|
|
import { extractPollFromQuestion } from './question';
|
|
import vote from '../../../services/note/polls/vote';
|
|
import { apLogger } from '../logger';
|
|
import { DriveFile } from '../../../models/entities/drive-file';
|
|
import { deliverQuestionUpdate } from '../../../services/note/polls/update';
|
|
import { extractDbHost, toPuny } from '../../../misc/convert-host';
|
|
import { Notes, Emojis, Polls } from '../../../models';
|
|
import { Note } from '../../../models/entities/note';
|
|
import { IObject, INote, getApIds, getOneApId, getApId, validPost } from '../type';
|
|
import { Emoji } from '../../../models/entities/emoji';
|
|
import { genId } from '../../../misc/gen-id';
|
|
import { fetchMeta } from '../../../misc/fetch-meta';
|
|
import { ensure } from '../../../prelude/ensure';
|
|
import { getApLock } from '../../../misc/app-lock';
|
|
import { createMessage } from '../../../services/messages/create';
|
|
|
|
const logger = apLogger;
|
|
|
|
export function validateNote(object: any, uri: string) {
|
|
const expectHost = extractDbHost(uri);
|
|
|
|
if (object == null) {
|
|
return new Error('invalid Note: object is null');
|
|
}
|
|
|
|
if (!validPost.includes(object.type)) {
|
|
return new Error(`invalid Note: invalid object type ${object.type}`);
|
|
}
|
|
|
|
if (object.id && extractDbHost(object.id) !== expectHost) {
|
|
return new Error(`invalid Note: id has different host. expected: ${expectHost}, actual: ${extractDbHost(object.id)}`);
|
|
}
|
|
|
|
if (object.attributedTo && extractDbHost(getOneApId(object.attributedTo)) !== expectHost) {
|
|
return new Error(`invalid Note: attributedTo has different host. expected: ${expectHost}, actual: ${extractDbHost(object.attributedTo)}`);
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
/**
|
|
* Noteをフェッチします。
|
|
*
|
|
* Misskeyに対象のNoteが登録されていればそれを返します。
|
|
*/
|
|
export async function fetchNote(value: string | IObject, resolver?: Resolver): Promise<Note | null> {
|
|
const uri = getApId(value);
|
|
|
|
// URIがこのサーバーを指しているならデータベースからフェッチ
|
|
if (uri.startsWith(config.url + '/')) {
|
|
const id = uri.split('/').pop();
|
|
return await Notes.findOne(id).then(x => x || null);
|
|
}
|
|
|
|
//#region このサーバーに既に登録されていたらそれを返す
|
|
const exist = await Notes.findOne({ uri });
|
|
|
|
if (exist) {
|
|
return exist;
|
|
}
|
|
//#endregion
|
|
|
|
return null;
|
|
}
|
|
|
|
/**
|
|
* Noteを作成します。
|
|
*/
|
|
export async function createNote(value: string | IObject, resolver?: Resolver, silent = false): Promise<Note | null> {
|
|
if (resolver == null) resolver = new Resolver();
|
|
|
|
const object: any = await resolver.resolve(value);
|
|
|
|
const entryUri = getApId(value);
|
|
const err = validateNote(object, entryUri);
|
|
if (err) {
|
|
logger.error(`${err.message}`, {
|
|
resolver: {
|
|
history: resolver.getHistory()
|
|
},
|
|
value: value,
|
|
object: object
|
|
});
|
|
throw new Error('invalid note');
|
|
}
|
|
|
|
const note: INote = object;
|
|
|
|
logger.debug(`Note fetched: ${JSON.stringify(note, null, 2)}`);
|
|
|
|
logger.info(`Creating the Note: ${note.id}`);
|
|
|
|
// 投稿者をフェッチ
|
|
const actor = await resolvePerson(getOneApId(note.attributedTo), resolver) as IRemoteUser;
|
|
|
|
// 投稿者が凍結されていたらスキップ
|
|
if (actor.isSuspended) {
|
|
throw new Error('actor has been suspended');
|
|
}
|
|
|
|
//#region Visibility
|
|
const to = getApIds(note.to);
|
|
const cc = getApIds(note.cc);
|
|
|
|
let visibility = 'public';
|
|
let visibleUsers: User[] = [];
|
|
if (!to.includes('https://www.w3.org/ns/activitystreams#Public')) {
|
|
if (cc.includes('https://www.w3.org/ns/activitystreams#Public')) {
|
|
visibility = 'home';
|
|
} else if (to.includes(`${actor.uri}/followers`)) { // TODO: person.followerと照合するべき？
|
|
visibility = 'followers';
|
|
} else {
|
|
visibility = 'specified';
|
|
visibleUsers = await Promise.all(to.map(uri => resolvePerson(uri, resolver)));
|
|
}
|
|
}
|
|
//#endergion
|
|
|
|
const apMentions = await extractMentionedUsers(actor, to, cc, resolver);
|
|
|
|
const apHashtags = await extractHashtags(note.tag);
|
|
|
|
// 添付ファイル
|
|
// TODO: attachmentは必ずしもImageではない
|
|
// TODO: attachmentは必ずしも配列ではない
|
|
// Noteがsensitiveなら添付もsensitiveにする
|
|
const limit = promiseLimit(2);
|
|
|
|
note.attachment = Array.isArray(note.attachment) ? note.attachment : note.attachment ? [note.attachment] : [];
|
|
const files = note.attachment
|
|
.map(attach => attach.sensitive = note.sensitive)
|
|
? (await Promise.all(note.attachment.map(x => limit(() => resolveImage(actor, x)) as Promise<DriveFile>)))
|
|
.filter(image => image != null)
|
|
: [];
|
|
|
|
// リプライ
|
|
const reply: Note | null = note.inReplyTo
|
|
? await resolveNote(note.inReplyTo, resolver).then(x => {
|
|
if (x == null) {
|
|
logger.warn(`Specified inReplyTo, but nout found`);
|
|
throw new Error('inReplyTo not found');
|
|
} else {
|
|
return x;
|
|
}
|
|
}).catch(e => {
|
|
logger.warn(`Error in inReplyTo ${note.inReplyTo} - ${e.statusCode || e}`);
|
|
throw e;
|
|
})
|
|
: null;
|
|
|
|
// 引用
|
|
let quote: Note | undefined | null;
|
|
|
|
if (note._misskey_quote && typeof note._misskey_quote == 'string') {
|
|
quote = await resolveNote(note._misskey_quote).catch(e => {
|
|
// 4xxの場合は引用してないことにする
|
|
if (e.statusCode >= 400 && e.statusCode < 500) {
|
|
logger.warn(`Ignored quote target ${note.inReplyTo} - ${e.statusCode} `);
|
|
return null;
|
|
}
|
|
logger.warn(`Error in quote target ${note.inReplyTo} - ${e.statusCode || e}`);
|
|
throw e;
|
|
});
|
|
}
|
|
|
|
const cw = note.summary === '' ? null : note.summary;
|
|
|
|
// テキストのパース
|
|
const text = note._misskey_content || (note.content ? fromHtml(note.content) : null);
|
|
|
|
// vote
|
|
if (reply && reply.hasPoll) {
|
|
const poll = await Polls.findOne(reply.id).then(ensure);
|
|
|
|
const tryCreateVote = async (name: string, index: number): Promise<null> => {
|
|
if (poll.expiresAt && Date.now() > new Date(poll.expiresAt).getTime()) {
|
|
logger.warn(`vote to expired poll from AP: actor=${actor.username}@${actor.host}, note=${note.id}, choice=${name}`);
|
|
} else if (index >= 0) {
|
|
logger.info(`vote from AP: actor=${actor.username}@${actor.host}, note=${note.id}, choice=${name}`);
|
|
await vote(actor, reply, index);
|
|
|
|
// リモートフォロワーにUpdate配信
|
|
deliverQuestionUpdate(reply.id);
|
|
}
|
|
return null;
|
|
};
|
|
|
|
if (note.name) {
|
|
return await tryCreateVote(note.name, poll.choices.findIndex(x => x === note.name));
|
|
}
|
|
|
|
// 後方互換性のため
|
|
if (text) {
|
|
const m = text.match(/(\d+)$/);
|
|
|
|
if (m) {
|
|
return await tryCreateVote(m[0], Number(m[1]));
|
|
}
|
|
}
|
|
}
|
|
|
|
const emojis = await extractEmojis(note.tag || [], actor.host).catch(e => {
|
|
logger.info(`extractEmojis: ${e}`);
|
|
return [] as Emoji[];
|
|
});
|
|
|
|
const apEmojis = emojis.map(emoji => emoji.name);
|
|
|
|
const poll = await extractPollFromQuestion(note, resolver).catch(() => undefined);
|
|
|
|
// ユーザーの情報が古かったらついでに更新しておく
|
|
if (actor.lastFetchedAt == null || Date.now() - actor.lastFetchedAt.getTime() > 1000 * 60 * 60 * 24) {
|
|
if (actor.uri) updatePerson(actor.uri);
|
|
}
|
|
|
|
if (note._misskey_talk && visibility === 'specified') {
|
|
for (const recipient of visibleUsers) {
|
|
await createMessage(actor, recipient, undefined, text || undefined, (files && files.length > 0) ? files[0] : null, object.id);
|
|
return null;
|
|
}
|
|
}
|
|
|
|
return await post(actor, {
|
|
createdAt: note.published ? new Date(note.published) : null,
|
|
files,
|
|
reply,
|
|
renote: quote,
|
|
name: note.name,
|
|
cw,
|
|
text,
|
|
viaMobile: false,
|
|
localOnly: false,
|
|
geo: undefined,
|
|
visibility,
|
|
visibleUsers,
|
|
apMentions,
|
|
apHashtags,
|
|
apEmojis,
|
|
poll,
|
|
uri: note.id
|
|
}, silent);
|
|
}
|
|
|
|
/**
|
|
* Noteを解決します。
|
|
*
|
|
* Misskeyに対象のNoteが登録されていればそれを返し、そうでなければ
|
|
* リモートサーバーからフェッチしてMisskeyに登録しそれを返します。
|
|
*/
|
|
export async function resolveNote(value: string | IObject, resolver?: Resolver): Promise<Note | null> {
|
|
const uri = typeof value == 'string' ? value : value.id;
|
|
if (uri == null) throw new Error('missing uri');
|
|
|
|
// ブロックしてたら中断
|
|
const meta = await fetchMeta();
|
|
if (meta.blockedHosts.includes(extractDbHost(uri))) throw { statusCode: 451 };
|
|
|
|
const unlock = await getApLock(uri);
|
|
|
|
try {
|
|
//#region このサーバーに既に登録されていたらそれを返す
|
|
const exist = await fetchNote(uri);
|
|
|
|
if (exist) {
|
|
return exist;
|
|
}
|
|
//#endregion
|
|
|
|
// リモートサーバーからフェッチしてきて登録
|
|
// ここでuriの代わりに添付されてきたNote Objectが指定されていると、サーバーフェッチを経ずにノートが生成されるが
|
|
// 添付されてきたNote Objectは偽装されている可能性があるため、常にuriを指定してサーバーフェッチを行う。
|
|
return await createNote(uri, resolver, true);
|
|
} finally {
|
|
unlock();
|
|
}
|
|
}
|
|
|
|
export async function extractEmojis(tags: ITag[], host: string): Promise<Emoji[]> {
|
|
host = toPuny(host);
|
|
|
|
if (!tags) return [];
|
|
|
|
const eomjiTags = tags.filter(tag => tag.type === 'Emoji' && tag.icon && tag.icon.url && tag.name);
|
|
|
|
return await Promise.all(eomjiTags.map(async tag => {
|
|
const name = tag.name!.replace(/^:/, '').replace(/:$/, '');
|
|
|
|
const exists = await Emojis.findOne({
|
|
host,
|
|
name
|
|
});
|
|
|
|
if (exists) {
|
|
if ((tag.updated != null && exists.updatedAt == null)
|
|
|| (tag.id != null && exists.uri == null)
|
|
|| (tag.updated != null && exists.updatedAt != null && new Date(tag.updated) > exists.updatedAt)
|
|
|| (tag.icon!.url !== exists.url)
|
|
) {
|
|
await Emojis.update({
|
|
host,
|
|
name,
|
|
}, {
|
|
uri: tag.id,
|
|
url: tag.icon!.url,
|
|
updatedAt: new Date(),
|
|
});
|
|
|
|
return await Emojis.findOne({
|
|
host,
|
|
name
|
|
}) as Emoji;
|
|
}
|
|
|
|
return exists;
|
|
}
|
|
|
|
logger.info(`register emoji host=${host}, name=${name}`);
|
|
|
|
return await Emojis.save({
|
|
id: genId(),
|
|
host,
|
|
name,
|
|
uri: tag.id,
|
|
url: tag.icon!.url,
|
|
updatedAt: new Date(),
|
|
aliases: []
|
|
} as Partial<Emoji>);
|
|
}));
|
|
}
|
|
|
|
async function extractMentionedUsers(actor: IRemoteUser, to: string[], cc: string[], resolver: Resolver) {
|
|
const ignoreUris = ['https://www.w3.org/ns/activitystreams#Public', `${actor.uri}/followers`];
|
|
const uris = difference(unique(concat([to || [], cc || []])), ignoreUris);
|
|
|
|
const limit = promiseLimit<User | null>(2);
|
|
const users = await Promise.all(
|
|
uris.map(uri => limit(() => resolvePerson(uri, resolver).catch(() => null)) as Promise<User | null>)
|
|
);
|
|
|
|
return users.filter(x => x != null) as User[];
|
|
}
|