rckrdmrd
97f407c661
- Prefijo v2: MCH - TRACEABILITY-MASTER.yml creado - Listo para integracion como submodulo Workspace: v2.0.0 | SIMCO: v4.0.0
47 lines
1.1 KiB
JavaScript
47 lines
1.1 KiB
JavaScript
// src/compose.ts
|
|
var compose = (middleware, onError, onNotFound) => {
|
|
return (context, next) => {
|
|
let index = -1;
|
|
return dispatch(0);
|
|
async function dispatch(i) {
|
|
if (i <= index) {
|
|
throw new Error("next() called multiple times");
|
|
}
|
|
index = i;
|
|
let res;
|
|
let isError = false;
|
|
let handler;
|
|
if (middleware[i]) {
|
|
handler = middleware[i][0][0];
|
|
context.req.routeIndex = i;
|
|
} else {
|
|
handler = i === middleware.length && next || void 0;
|
|
}
|
|
if (handler) {
|
|
try {
|
|
res = await handler(context, () => dispatch(i + 1));
|
|
} catch (err) {
|
|
if (err instanceof Error && onError) {
|
|
context.error = err;
|
|
res = await onError(err, context);
|
|
isError = true;
|
|
} else {
|
|
throw err;
|
|
}
|
|
}
|
|
} else {
|
|
if (context.finalized === false && onNotFound) {
|
|
res = await onNotFound(context);
|
|
}
|
|
}
|
|
if (res && (context.finalized === false || isError)) {
|
|
context.res = res;
|
|
}
|
|
return context;
|
|
}
|
|
};
|
|
};
|
|
export {
|
|
compose
|
|
};
|