public-offering
/
pad.pub0.org
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

APIHandler.js: use promises

pull/3559/head
Ray Bellis 2019-01-22 13:30:28 +00:00
parent ec5baa2ab3
commit c4f1f83747
1 changed files with 22 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
src/node/handler/APIHandler.js
View File

@ -150,7 +150,7 @@ exports.version = version;
* @req express request object * @req express request object
* @res express response object * @res express response object
*/ */
exports.handle = function(apiVersion, functionName, fields, req, res) exports.handle = async function(apiVersion, functionName, fields, req, res)
{ {
//check if this is a valid apiversion //check if this is a valid apiversion
var isKnownApiVersion = false; var isKnownApiVersion = false;
@ -194,41 +194,38 @@ exports.handle = function(apiVersion, functionName, fields, req, res)
return; return;
} }
try {
// sanitize any padIDs before continuing // sanitize any padIDs before continuing
if (fields["padID"]) { if (fields["padID"]) {
padManager.sanitizePadId(fields["padID"], function(padId) { fields["padID"] = await padManager.sanitizePadId(fields["padID"]);
fields["padID"] = padId;
callAPI(apiVersion, functionName, fields, req, res);
});
} else if (fields["padName"]) { } else if (fields["padName"]) {
padManager.sanitizePadId(fields["padName"], function(padId) { fields["padName"] = await padManager.sanitizePadId(fields["padName"]);
fields["padName"] = padId; }
callAPI(apiVersion, functionName, fields, req, res); await callAPI(apiVersion, functionName, fields, req, res);
}); } catch (e) {
} else { ERR(e);
callAPI(apiVersion, functionName, fields, req, res);
} }
} }
// calls the api function // calls the api function
function callAPI(apiVersion, functionName, fields, req, res) async function callAPI(apiVersion, functionName, fields, req, res)
{ {
// put the function parameters in an array // put the function parameters in an array
var functionParams = version[apiVersion][functionName].map(function (field) { var functionParams = version[apiVersion][functionName].map(function (field) {
return fields[field] return fields[field]
}); });
// add a callback function to handle the response try {
functionParams.push(function(err, data) { // call the api function
if (err == null) { let data = await api[functionName].apply(this, functionParams);
// no error happened, everything is fine
if (!data) { if (!data) {
data = null; data = null;
} }
res.send({code: 0, message: "ok", data: data}); res.send({code: 0, message: "ok", data: data});
} else if (err.name == "apierror") { } catch (err) {
if (err.name == "apierror") {
// parameters were wrong and the api stopped execution, pass the error // parameters were wrong and the api stopped execution, pass the error
res.send({code: 1, message: err.message, data: null}); res.send({code: 1, message: err.message, data: null});
@ -236,10 +233,7 @@ function callAPI(apiVersion, functionName, fields, req, res)
// an unknown error happened // an unknown error happened
res.send({code: 2, message: "internal error", data: null}); res.send({code: 2, message: "internal error", data: null});
ERR(err); throw err;
}
} }
});
// call the api function
api[functionName].apply(this, functionParams);
} }