formatting
This commit is contained in:
parent
19b74cdcda
commit
c332ce82dd
143
index.js
143
index.js
@ -11,23 +11,104 @@ const path = require ('path');
|
|||||||
* @property {boolean} [rethrow] rethrow errors (default: true)
|
* @property {boolean} [rethrow] rethrow errors (default: true)
|
||||||
*/
|
*/
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @typedef {object} handler_description
|
||||||
|
* @property {string} module_folder folder the module file is in
|
||||||
|
* @property {string} file name of the module
|
||||||
|
* @property {any} opts optional arguments
|
||||||
|
* @property {boolean} rethrow should errors be rethrown
|
||||||
|
*/
|
||||||
|
|
||||||
|
/**
|
||||||
|
* wrap a requestor handler to be compatible with express
|
||||||
|
*
|
||||||
|
* @param {handler_description} data handler data
|
||||||
|
* @returns {Function} requestor handler
|
||||||
|
*/
|
||||||
|
function get_handler ({ module_folder, file, opts, rethrow }) {
|
||||||
|
// eslint-disable-next-line global-require
|
||||||
|
const handler = require (path.join (process.cwd (), module_folder, file));
|
||||||
|
|
||||||
|
return (req, res, next) => {
|
||||||
|
try {
|
||||||
|
handler (req, res, next, opts);
|
||||||
|
}
|
||||||
|
catch (e) {
|
||||||
|
if (rethrow)
|
||||||
|
throw e;
|
||||||
|
else
|
||||||
|
console.error (e);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* register a handler to the given app
|
||||||
|
*
|
||||||
|
* @param {any} app express app
|
||||||
|
* @param {handler_description} handler_description data for the used handler
|
||||||
|
* @param {string} method method to respond to
|
||||||
|
* @param {string} url url to respond to
|
||||||
|
* @param {boolean} verbose should verbose logging be enabled
|
||||||
|
*/
|
||||||
|
function register_handler (
|
||||||
|
app,
|
||||||
|
handler_description,
|
||||||
|
method,
|
||||||
|
url,
|
||||||
|
verbose
|
||||||
|
) {
|
||||||
|
const handler = get_handler (handler_description);
|
||||||
|
|
||||||
|
if (verbose)
|
||||||
|
console.log (
|
||||||
|
`[requestor info] redirecting ${url} to ${handler_description.file}`
|
||||||
|
);
|
||||||
|
|
||||||
|
switch (method) {
|
||||||
|
case 'post':
|
||||||
|
app.post (url, handler);
|
||||||
|
break;
|
||||||
|
case 'get':
|
||||||
|
app.get (url, handler);
|
||||||
|
break;
|
||||||
|
case 'put':
|
||||||
|
app.put (url, handler);
|
||||||
|
break;
|
||||||
|
case 'delete':
|
||||||
|
app.delete (url, handler);
|
||||||
|
break;
|
||||||
|
case 'all':
|
||||||
|
app.all (url, handler);
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
if (verbose)
|
||||||
|
console.warn (
|
||||||
|
`'${method}' did not match any request method, ignoring`
|
||||||
|
);
|
||||||
|
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Load all request handlers in the given folder
|
* Load all request handlers in the given folder
|
||||||
*
|
*
|
||||||
* @param {any} app express app
|
* @param {any} app express app
|
||||||
* @param {string} modulefolder folder that contains all modules
|
* @param {string} module_folder folder that contains all modules
|
||||||
* @param {options} options additional options
|
* @param {options} options additional options
|
||||||
*/
|
*/
|
||||||
module.exports = function main (
|
module.exports = function main (
|
||||||
app,
|
app,
|
||||||
modulefolder,
|
module_folder,
|
||||||
options = { opts: null, subdir: '', verbose: false, rethrow: true }
|
options = { opts: null, subdir: '', verbose: false, rethrow: true }
|
||||||
) {
|
) {
|
||||||
const { opts, subdir, verbose, rethrow } = options;
|
const { opts, subdir, verbose, rethrow } = options;
|
||||||
|
|
||||||
for (const f of fs.readdirSync (modulefolder)) {
|
for (const file of fs.readdirSync (module_folder)) {
|
||||||
const regex = /(?<method>.*?)-(?<url>.*?)\.js/u;
|
const regex = /(?<method>.*?)-(?<url>.*?)\.js/u;
|
||||||
const { groups } = regex.exec (f);
|
const { groups } = regex.exec (file);
|
||||||
|
|
||||||
if (typeof subdir === 'undefined')
|
if (typeof subdir === 'undefined')
|
||||||
groups.url = `/${groups.url}/`;
|
groups.url = `/${groups.url}/`;
|
||||||
@ -39,47 +120,17 @@ module.exports = function main (
|
|||||||
.replace (/\./gu, '/')
|
.replace (/\./gu, '/')
|
||||||
.replace (/\/+/gu, '/');
|
.replace (/\/+/gu, '/');
|
||||||
|
|
||||||
// eslint-disable-next-line global-require
|
register_handler (
|
||||||
const handler = require (path.join (process.cwd (), modulefolder, f));
|
app,
|
||||||
|
{
|
||||||
const requestor_handler = (req, res, next) => {
|
file,
|
||||||
try {
|
module_folder,
|
||||||
handler (req, res, next, opts);
|
opts,
|
||||||
}
|
rethrow
|
||||||
catch (e) {
|
},
|
||||||
if (rethrow)
|
groups.method,
|
||||||
throw e;
|
groups.url,
|
||||||
else
|
verbose
|
||||||
console.error (e);
|
);
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
if (verbose)
|
|
||||||
console.log (`[requestor info] redirecting ${groups.url} to ${f}`);
|
|
||||||
|
|
||||||
switch (groups.method) {
|
|
||||||
case 'post':
|
|
||||||
app.post (groups.url, requestor_handler);
|
|
||||||
break;
|
|
||||||
case 'get':
|
|
||||||
app.get (groups.url, requestor_handler);
|
|
||||||
break;
|
|
||||||
case 'put':
|
|
||||||
app.put (groups.url, requestor_handler);
|
|
||||||
break;
|
|
||||||
case 'delete':
|
|
||||||
app.delete (groups.url, requestor_handler);
|
|
||||||
break;
|
|
||||||
case 'all':
|
|
||||||
app.all (groups.url, requestor_handler);
|
|
||||||
break;
|
|
||||||
default:
|
|
||||||
if (verbose)
|
|
||||||
console.warn (
|
|
||||||
`'${groups.method}' did not match any request method, ignoring`
|
|
||||||
);
|
|
||||||
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
Reference in New Issue
Block a user