misskey/src/server/activitypub.ts

244 lines
5.5 KiB
TypeScript
Raw Normal View History

import { ObjectID } from 'mongodb';
2018-04-12 08:51:55 -07:00
import * as Router from 'koa-router';
import * as json from 'koa-json-body';
import * as httpSignature from 'http-signature';
2018-04-12 08:51:55 -07:00
2018-07-25 16:11:47 -07:00
import { createHttpJob } from '../queue';
import { renderActivity } from '../remote/activitypub/renderer';
2018-04-12 08:51:55 -07:00
import Note from '../models/note';
2018-06-17 01:11:05 -07:00
import User, { isLocalUser, ILocalUser, IUser } from '../models/user';
2018-12-18 11:23:08 -08:00
import Emoji from '../models/emoji';
2018-04-12 08:51:55 -07:00
import renderNote from '../remote/activitypub/renderer/note';
import renderKey from '../remote/activitypub/renderer/key';
import renderPerson from '../remote/activitypub/renderer/person';
2018-12-18 11:23:08 -08:00
import renderEmoji from '../remote/activitypub/renderer/emoji';
import Outbox, { packActivity } from './activitypub/outbox';
import Followers from './activitypub/followers';
import Following from './activitypub/following';
2018-09-17 21:08:27 -07:00
import Featured from './activitypub/featured';
import renderQuestion from '../remote/activitypub/renderer/question';
2018-04-12 08:51:55 -07:00
// Init router
const router = new Router();
//#region Routing
2018-06-17 01:21:16 -07:00
function inbox(ctx: Router.IRouterContext) {
2018-04-12 08:51:55 -07:00
let signature;
2018-09-01 07:12:51 -07:00
ctx.req.headers.authorization = `Signature ${ctx.req.headers.signature}`;
2018-04-12 08:51:55 -07:00
try {
signature = httpSignature.parseRequest(ctx.req, { 'headers': [] });
2018-04-12 08:51:55 -07:00
} catch (e) {
ctx.status = 401;
return;
}
2018-07-25 16:11:47 -07:00
createHttpJob({
2018-04-12 08:51:55 -07:00
type: 'processInbox',
activity: ctx.request.body,
signature
2018-07-25 16:11:47 -07:00
});
2018-04-12 08:51:55 -07:00
ctx.status = 202;
2018-04-22 23:37:27 -07:00
}
2018-06-17 01:11:05 -07:00
function isActivityPubReq(ctx: Router.IRouterContext) {
2018-08-20 21:48:03 -07:00
ctx.response.vary('Accept');
2018-06-17 01:11:05 -07:00
const accepted = ctx.accepts('html', 'application/activity+json', 'application/ld+json');
return ['application/activity+json', 'application/ld+json'].includes(accepted as string);
}
2018-08-20 21:48:03 -07:00
export function setResponseType(ctx: Router.IRouterContext) {
const accpet = ctx.accepts('application/activity+json', 'application/ld+json');
if (accpet === 'application/ld+json') {
ctx.response.type = 'application/ld+json; profile="https://www.w3.org/ns/activitystreams"; charset=utf-8';
} else {
ctx.response.type = 'application/activity+json; charset=utf-8';
}
}
2018-04-22 23:37:27 -07:00
// inbox
router.post('/inbox', json(), inbox);
router.post('/users/:user/inbox', json(), inbox);
2018-04-12 08:51:55 -07:00
// note
router.get('/notes/:note', async (ctx, next) => {
2018-06-17 01:11:05 -07:00
if (!isActivityPubReq(ctx)) return await next();
2018-04-12 08:51:55 -07:00
if (!ObjectID.isValid(ctx.params.note)) {
ctx.status = 404;
return;
}
2018-04-12 08:51:55 -07:00
const note = await Note.findOne({
_id: new ObjectID(ctx.params.note),
visibility: { $in: ['public', 'home'] },
localOnly: { $ne: true }
2018-04-12 08:51:55 -07:00
});
if (note === null) {
ctx.status = 404;
return;
}
ctx.body = renderActivity(await renderNote(note, false));
ctx.set('Cache-Control', 'public, max-age=180');
2018-08-20 21:48:03 -07:00
setResponseType(ctx);
2018-04-12 08:51:55 -07:00
});
// note activity
router.get('/notes/:note/activity', async ctx => {
if (!ObjectID.isValid(ctx.params.note)) {
ctx.status = 404;
return;
}
const note = await Note.findOne({
_id: new ObjectID(ctx.params.note),
visibility: { $in: ['public', 'home'] },
localOnly: { $ne: true }
});
if (note === null) {
ctx.status = 404;
return;
}
ctx.body = renderActivity(await packActivity(note));
2018-09-18 15:17:19 -07:00
ctx.set('Cache-Control', 'public, max-age=180');
setResponseType(ctx);
});
// question
router.get('/questions/:question', async (ctx, next) => {
if (!ObjectID.isValid(ctx.params.question)) {
ctx.status = 404;
return;
}
const poll = await Note.findOne({
_id: new ObjectID(ctx.params.question),
visibility: { $in: ['public', 'home'] },
localOnly: { $ne: true },
poll: {
$exists: true,
$ne: null
},
});
if (poll === null) {
ctx.status = 404;
return;
}
const user = await User.findOne({
_id: poll.userId
});
ctx.body = renderActivity(await renderQuestion(user as ILocalUser, poll));
setResponseType(ctx);
});
// outbox
router.get('/users/:user/outbox', Outbox);
2018-08-12 11:49:17 -07:00
// followers
router.get('/users/:user/followers', Followers);
2018-08-12 11:49:17 -07:00
// following
router.get('/users/:user/following', Following);
2018-04-12 08:51:55 -07:00
2018-09-17 21:08:27 -07:00
// featured
router.get('/users/:user/collections/featured', Featured);
2018-04-12 08:51:55 -07:00
// publickey
router.get('/users/:user/publickey', async ctx => {
if (!ObjectID.isValid(ctx.params.user)) {
ctx.status = 404;
return;
}
const userId = new ObjectID(ctx.params.user);
2018-04-12 08:51:55 -07:00
2018-06-01 08:15:17 -07:00
const user = await User.findOne({
_id: userId,
host: null
});
2018-04-12 08:51:55 -07:00
if (user === null) {
ctx.status = 404;
return;
}
if (isLocalUser(user)) {
ctx.body = renderActivity(renderKey(user));
2018-09-18 15:17:19 -07:00
ctx.set('Cache-Control', 'public, max-age=180');
2018-08-20 21:48:03 -07:00
setResponseType(ctx);
2018-04-12 08:51:55 -07:00
} else {
ctx.status = 400;
}
});
// user
2018-07-19 10:40:37 -07:00
async function userInfo(ctx: Router.IRouterContext, user: IUser) {
2018-06-17 01:11:05 -07:00
if (user === null) {
ctx.status = 404;
return;
}
ctx.body = renderActivity(await renderPerson(user as ILocalUser));
2018-09-18 15:17:19 -07:00
ctx.set('Cache-Control', 'public, max-age=180');
2018-08-20 21:48:03 -07:00
setResponseType(ctx);
2018-06-17 01:11:05 -07:00
}
router.get('/users/:user', async (ctx, next) => {
if (!isActivityPubReq(ctx)) return await next();
if (!ObjectID.isValid(ctx.params.user)) {
ctx.status = 404;
return;
}
const userId = new ObjectID(ctx.params.user);
2018-04-12 08:51:55 -07:00
2018-06-01 08:15:17 -07:00
const user = await User.findOne({
_id: userId,
host: null
});
2018-04-12 08:51:55 -07:00
2018-07-19 10:40:37 -07:00
await userInfo(ctx, user);
2018-06-17 01:11:05 -07:00
});
2018-04-12 08:51:55 -07:00
2018-06-17 01:11:05 -07:00
router.get('/@:user', async (ctx, next) => {
if (!isActivityPubReq(ctx)) return await next();
const user = await User.findOne({
usernameLower: ctx.params.user.toLowerCase(),
host: null
});
2018-07-19 10:40:37 -07:00
await userInfo(ctx, user);
2018-04-12 08:51:55 -07:00
});
//#endregion
2018-12-18 11:23:08 -08:00
// emoji
router.get('/emojis/:emoji', async ctx => {
const emoji = await Emoji.findOne({
host: null,
name: ctx.params.emoji
});
if (emoji === null) {
ctx.status = 404;
return;
}
ctx.body = renderActivity(await renderEmoji(emoji));
2018-12-18 11:23:08 -08:00
ctx.set('Cache-Control', 'public, max-age=180');
setResponseType(ctx);
});
2018-04-12 08:51:55 -07:00
export default router;