mirror of
https://iceshrimp.dev/crimekillz/trashposs
synced 2024-11-24 09:49:05 +01:00
107 lines
2.3 KiB
TypeScript
107 lines
2.3 KiB
TypeScript
/**
|
|
* API Server
|
|
*/
|
|
|
|
import * as Koa from 'koa';
|
|
import * as Router from '@koa/router';
|
|
import * as multer from '@koa/multer';
|
|
import * as bodyParser from 'koa-bodyparser';
|
|
import * as cors from '@koa/cors';
|
|
|
|
import endpoints from './endpoints';
|
|
import handler from './api-handler';
|
|
import signup from './private/signup';
|
|
import signin from './private/signin';
|
|
import discord from './service/discord';
|
|
import github from './service/github';
|
|
import twitter from './service/twitter';
|
|
import { Instances, AccessTokens, Users } from '../../models';
|
|
|
|
// Init app
|
|
const app = new Koa();
|
|
|
|
app.use(cors({
|
|
origin: '*'
|
|
}));
|
|
|
|
// No caching
|
|
app.use(async (ctx, next) => {
|
|
ctx.set('Cache-Control', 'private, max-age=0, must-revalidate');
|
|
await next();
|
|
});
|
|
|
|
app.use(bodyParser({
|
|
// リクエストが multipart/form-data でない限りはJSONだと見なす
|
|
detectJSON: ctx => !ctx.is('multipart/form-data')
|
|
}));
|
|
|
|
// Init multer instance
|
|
const upload = multer({
|
|
storage: multer.diskStorage({})
|
|
});
|
|
|
|
// Init router
|
|
const router = new Router();
|
|
|
|
/**
|
|
* Register endpoint handlers
|
|
*/
|
|
for (const endpoint of endpoints) {
|
|
if (endpoint.meta.requireFile) {
|
|
router.post(`/${endpoint.name}`, upload.single('file'), handler.bind(null, endpoint));
|
|
} else {
|
|
if (endpoint.name.includes('-')) {
|
|
// 後方互換性のため
|
|
router.post(`/${endpoint.name.replace(/-/g, '_')}`, handler.bind(null, endpoint));
|
|
}
|
|
router.post(`/${endpoint.name}`, handler.bind(null, endpoint));
|
|
}
|
|
}
|
|
|
|
router.post('/signup', signup);
|
|
router.post('/signin', signin);
|
|
|
|
router.use(discord.routes());
|
|
router.use(github.routes());
|
|
router.use(twitter.routes());
|
|
|
|
router.get('/v1/instance/peers', async ctx => {
|
|
const instances = await Instances.find({
|
|
select: ['host']
|
|
});
|
|
|
|
ctx.body = instances.map(instance => instance.host);
|
|
});
|
|
|
|
router.post('/miauth/:session/check', async ctx => {
|
|
const token = await AccessTokens.findOne({
|
|
session: ctx.params.session
|
|
});
|
|
|
|
if (token && token.session != null && !token.fetched) {
|
|
AccessTokens.update(token.id, {
|
|
fetched: true
|
|
});
|
|
|
|
ctx.body = {
|
|
ok: true,
|
|
token: token.token,
|
|
user: await Users.pack(token.userId, null, { detail: true })
|
|
};
|
|
} else {
|
|
ctx.body = {
|
|
ok: false,
|
|
};
|
|
}
|
|
});
|
|
|
|
// Return 404 for unknown API
|
|
router.all('(.*)', async ctx => {
|
|
ctx.status = 404;
|
|
});
|
|
|
|
// Register router
|
|
app.use(router.routes());
|
|
|
|
export default app;
|