diff options
| author | syuilo <syuilotan@yahoo.co.jp> | 2018-07-16 03:25:35 +0900 |
|---|---|---|
| committer | syuilo <syuilotan@yahoo.co.jp> | 2018-07-16 03:25:35 +0900 |
| commit | 1e4a86da8e826d48f6fb9118f02905af7f79b4f1 (patch) | |
| tree | 1d10c32fb5826e0609df4255b0521493116e184d /src/server/api/call.ts | |
| parent | Add doc (diff) | |
| download | misskey-1e4a86da8e826d48f6fb9118f02905af7f79b4f1.tar.gz misskey-1e4a86da8e826d48f6fb9118f02905af7f79b4f1.tar.bz2 misskey-1e4a86da8e826d48f6fb9118f02905af7f79b4f1.zip | |
良い感じに
Diffstat (limited to 'src/server/api/call.ts')
| -rw-r--r-- | src/server/api/call.ts | 44 |
1 files changed, 33 insertions, 11 deletions
diff --git a/src/server/api/call.ts b/src/server/api/call.ts index 96c218b371..eb3e292dc1 100644 --- a/src/server/api/call.ts +++ b/src/server/api/call.ts @@ -1,44 +1,66 @@ -import endpoints, { Endpoint } from './endpoints'; +import * as path from 'path'; +import * as glob from 'glob'; + +import Endpoint from './endpoint'; import limitter from './limitter'; import { IUser } from '../../models/user'; import { IApp } from '../../models/app'; +const files = glob.sync('**/*.js', { + cwd: path.resolve(__dirname + '/endpoints/') +}); + +const endpoints: Array<{ + exec: any, + meta: Endpoint +}> = files.map(f => { + const ep = require('./endpoints/' + f); + + ep.meta = ep.meta || {}; + ep.meta.name = f.replace('.js', ''); + + return { + exec: ep.default, + meta: ep.meta + }; +}); + export default (endpoint: string | Endpoint, user: IUser, app: IApp, data: any, file?: any) => new Promise<any>(async (ok, rej) => { const isSecure = user != null && app == null; const epName = typeof endpoint === 'string' ? endpoint : endpoint.name; - const ep = endpoints.find(e => e.name === epName); + const ep = endpoints.find(e => e.meta.name === epName); - if (ep.secure && !isSecure) { + if (ep.meta.secure && !isSecure) { return rej('ACCESS_DENIED'); } - if (ep.withCredential && user == null) { + if (ep.meta.requireCredential && user == null) { return rej('SIGNIN_REQUIRED'); } - if (ep.withCredential && user.isSuspended) { + if (ep.meta.requireCredential && user.isSuspended) { return rej('YOUR_ACCOUNT_HAS_BEEN_SUSPENDED'); } - if (app && ep.kind) { - if (!app.permission.some(p => p === ep.kind)) { + if (app && ep.meta.kind) { + if (!app.permission.some(p => p === ep.meta.kind)) { return rej('PERMISSION_DENIED'); } } - if (ep.withCredential && ep.limit) { + if (ep.meta.requireCredential && ep.meta.limit) { try { - await limitter(ep, user); // Rate limit + await limitter(ep.meta, user); // Rate limit } catch (e) { // drop request if limit exceeded return rej('RATE_LIMIT_EXCEEDED'); } } - let exec = require(`${__dirname}/endpoints/${ep.name}`).default; + let exec = ep.exec; - if (ep.withFile && file) { + if (ep.meta.withFile && file) { exec = exec.bind(null, file); } |