-
Notifications
You must be signed in to change notification settings - Fork 3
/
class_compiler.js
63 lines (54 loc) · 1.9 KB
/
class_compiler.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
'use strict';
const Async = require('async');
module.exports = (options, cb) => {
options.nodejsCompiler(options.script, (e, Func) => {
if (e) return cb(e);
let instance = new Func(options.secrets, options.meta);
return cb(null, (ctx, req, res) => {
let method = req.method.toLowerCase();
Async.series([ ensureMethod, readBody, dispatch ], (e) => {
if (e) {
res.writeHead(e.statusCode || 400, { 'Content-Type': 'application/json' });
return res.end(JSON.stringify({ error: e.message, statusCode: e.statusCode || 400 }));
}
});
function ensureMethod(cb) {
if (typeof instance[method] === 'function') return cb();
let error = new Error(`Unuspported method: ${method}.`);
error.statusCode = 405;
return cb(error);
}
function readBody(cb) {
if (ctx.body) return cb();
if (['post','put','patch'].indexOf(method) === -1) return cb();
let body = '';
req.on('data', (d) => body += d);
req.on('end', () => {
req.removeAllListeners();
try {
ctx.body = JSON.parse(body);
}
catch (e) {
return cb(new Error(`Request body must be JSON: ${e.message}`));
}
return cb();
});
req.on('error', cb);
}
function dispatch(cb) {
instance[method](ctx, (e, d) => {
if (e) return cb(e);
try {
d = JSON.stringify(d);
}
catch (e) {
return cb(new Error(`Unable to serialize response as JSON: ${e.message}.`));
}
res.writeHead(200, { 'Content-Type': 'application/json' });
res.end(d);
return cb();
})
}
});
});
};