summaryrefslogtreecommitdiff
path: root/src/server/api/call.ts
diff options
context:
space:
mode:
authorsyuilo <syuilotan@yahoo.co.jp>2018-07-16 03:25:35 +0900
committersyuilo <syuilotan@yahoo.co.jp>2018-07-16 03:25:35 +0900
commit1e4a86da8e826d48f6fb9118f02905af7f79b4f1 (patch)
tree1d10c32fb5826e0609df4255b0521493116e184d /src/server/api/call.ts
parentAdd doc (diff)
downloadmisskey-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.ts44
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);
}