calckey/packages/backend/src/remote/activitypub/resolver.ts

74 lines
2.0 KiB
TypeScript
Raw Normal View History

import config from '@/config/index.js';
import { getJson } from '@/misc/fetch.js';
import { ILocalUser } from '@/models/entities/user.js';
import { getInstanceActor } from '@/services/instance-actor.js';
import { fetchMeta } from '@/misc/fetch-meta.js';
import { extractDbHost } from '@/misc/convert-host.js';
2022-04-17 04:26:31 +00:00
import { signedGet } from './request.js';
import { IObject, isCollectionOrOrderedCollection, ICollection, IOrderedCollection } from './type.js';
2018-03-31 10:55:00 +00:00
2018-04-01 12:56:11 +00:00
export default class Resolver {
2018-04-04 14:12:35 +00:00
private history: Set<string>;
private user?: ILocalUser;
2018-04-01 12:56:11 +00:00
2018-04-04 14:12:35 +00:00
constructor() {
this.history = new Set();
2018-03-31 10:55:00 +00:00
}
2019-03-04 05:02:42 +00:00
public getHistory(): string[] {
return Array.from(this.history);
}
public async resolveCollection(value: string | IObject): Promise<ICollection | IOrderedCollection> {
2018-04-04 14:12:35 +00:00
const collection = typeof value === 'string'
? await this.resolve(value)
: value;
if (isCollectionOrOrderedCollection(collection)) {
return collection;
} else {
2020-09-17 12:05:47 +00:00
throw new Error(`unrecognized collection type: ${collection.type}`);
2018-04-04 14:12:35 +00:00
}
}
public async resolve(value: string | IObject): Promise<IObject> {
2018-04-05 13:49:41 +00:00
if (value == null) {
throw new Error('resolvee is null (or undefined)');
}
2018-04-01 12:56:11 +00:00
if (typeof value !== 'string') {
2018-04-04 14:12:35 +00:00
return value;
2018-04-01 12:56:11 +00:00
}
2018-03-31 10:55:00 +00:00
2018-04-04 14:12:35 +00:00
if (this.history.has(value)) {
throw new Error('cannot resolve already resolved one');
}
2018-03-31 10:55:00 +00:00
2018-04-04 14:12:35 +00:00
this.history.add(value);
2018-03-31 10:55:00 +00:00
const meta = await fetchMeta();
const host = extractDbHost(value);
if (meta.blockedHosts.includes(host)) {
throw new Error('Instance is blocked');
}
if (config.signToActivityPubGet && !this.user) {
this.user = await getInstanceActor();
}
2022-04-17 04:26:31 +00:00
const object = (this.user
? await signedGet(value, this.user)
2022-04-17 04:26:31 +00:00
: await getJson(value, 'application/activity+json, application/ld+json')) as IObject;
2018-03-31 10:55:00 +00:00
Use PostgreSQL instead of MongoDB (#4572) * wip * Update note.ts * Update timeline.ts * Update core.ts * wip * Update generate-visibility-query.ts * wip * wip * wip * wip * wip * Update global-timeline.ts * wip * wip * wip * Update vote.ts * wip * wip * Update create.ts * wip * wip * wip * wip * wip * wip * wip * wip * wip * wip * wip * wip * Update files.ts * wip * wip * Update CONTRIBUTING.md * wip * wip * wip * wip * wip * wip * wip * wip * Update read-notification.ts * wip * wip * wip * wip * wip * wip * wip * Update cancel.ts * wip * wip * wip * Update show.ts * wip * wip * Update gen-id.ts * Update create.ts * Update id.ts * wip * wip * wip * wip * wip * wip * wip * Docker: Update files about Docker (#4599) * Docker: Use cache if files used by `yarn install` was not updated This patch reduces the number of times to installing node_modules. For example, `yarn install` step will be skipped when only ".config/default.yml" is updated. * Docker: Migrate MongoDB to Postgresql Misskey uses Postgresql as a database instead of Mongodb since version 11. * Docker: Uncomment about data persistence This patch will save a lot of databases. * wip * wip * wip * Update activitypub.ts * wip * wip * wip * Update logs.ts * wip * Update drive-file.ts * Update register.ts * wip * wip * Update mentions.ts * wip * wip * wip * Update recommendation.ts * wip * Update index.ts * wip * Update recommendation.ts * Doc: Update docker.ja.md and docker.en.md (#1) (#4608) Update how to set up misskey. * wip * :v: * wip * Update note.ts * Update postgre.ts * wip * wip * wip * wip * Update add-file.ts * wip * wip * wip * Clean up * Update logs.ts * wip * :pizza: * wip * Ad notes * wip * Update api-visibility.ts * Update note.ts * Update add-file.ts * tests * tests * Update postgre.ts * Update utils.ts * wip * wip * Refactor * wip * Refactor * wip * wip * Update show-users.ts * Update update-instance.ts * wip * Update feed.ts * Update outbox.ts * Update outbox.ts * Update user.ts * wip * Update list.ts * Update update-hashtag.ts * wip * Update update-hashtag.ts * Refactor * Update update.ts * wip * wip * :v: * clean up * docs * Update push.ts * wip * Update api.ts * wip * :v: * Update make-pagination-query.ts * :v: * Delete hashtags.ts * Update instances.ts * Update instances.ts * Update create.ts * Update search.ts * Update reversi-game.ts * Update signup.ts * Update user.ts * id * Update example.yml * :art: * objectid * fix * reversi * reversi * Fix bug of chart engine * Add test of chart engine * Improve test * Better testing * Improve chart engine * Refactor * Add test of chart engine * Refactor * Add chart test * Fix bug * コミットし忘れ * Refactoring * :v: * Add tests * Add test * Extarct note tests * Refactor * 存在しないユーザーにメンションできなくなっていた問題を修正 * Fix bug * Update update-meta.ts * Fix bug * Update mention.vue * Fix bug * Update meta.ts * Update CONTRIBUTING.md * Fix bug * Fix bug * Fix bug * Clean up * Clean up * Update notification.ts * Clean up * Add mute tests * Add test * Refactor * Add test * Fix test * Refactor * Refactor * Add tests * Update utils.ts * Update utils.ts * Fix test * Update package.json * Update update.ts * Update manifest.ts * Fix bug * Fix bug * Add test * :art: * Update endpoint permissions * Updaye permisison * Update person.ts #4299 * データベースと同期しないように * Fix bug * Fix bug * Update reversi-game.ts * Use a feature of Node v11.7.0 to extract a public key (#4644) * wip * wip * :v: * Refactoring #1540 * test * test * test * test * test * test * test * Fix bug * Fix test * :sushi: * wip * #4471 * Add test for #4335 * Refactor * Fix test * Add tests * :clock4: * Fix bug * Add test * Add test * rename * Fix bug
2019-04-07 12:50:36 +00:00
if (object == null || (
2018-04-01 12:56:11 +00:00
Array.isArray(object['@context']) ?
2022-04-17 04:26:31 +00:00
!(object['@context'] as unknown[]).includes('https://www.w3.org/ns/activitystreams') :
2018-04-01 12:56:11 +00:00
object['@context'] !== 'https://www.w3.org/ns/activitystreams'
)) {
2018-04-04 14:12:35 +00:00
throw new Error('invalid response');
2018-03-31 10:55:00 +00:00
}
2018-04-04 14:12:35 +00:00
return object;
2018-03-31 10:55:00 +00:00
}
}