compose.js 2.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768
  1. var __defProp = Object.defineProperty;
  2. var __getOwnPropDesc = Object.getOwnPropertyDescriptor;
  3. var __getOwnPropNames = Object.getOwnPropertyNames;
  4. var __hasOwnProp = Object.prototype.hasOwnProperty;
  5. var __export = (target, all) => {
  6. for (var name in all)
  7. __defProp(target, name, { get: all[name], enumerable: true });
  8. };
  9. var __copyProps = (to, from, except, desc) => {
  10. if (from && typeof from === "object" || typeof from === "function") {
  11. for (let key of __getOwnPropNames(from))
  12. if (!__hasOwnProp.call(to, key) && key !== except)
  13. __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable });
  14. }
  15. return to;
  16. };
  17. var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod);
  18. var compose_exports = {};
  19. __export(compose_exports, {
  20. compose: () => compose
  21. });
  22. module.exports = __toCommonJS(compose_exports);
  23. const compose = (middleware, onError, onNotFound) => {
  24. return (context, next) => {
  25. let index = -1;
  26. return dispatch(0);
  27. async function dispatch(i) {
  28. if (i <= index) {
  29. throw new Error("next() called multiple times");
  30. }
  31. index = i;
  32. let res;
  33. let isError = false;
  34. let handler;
  35. if (middleware[i]) {
  36. handler = middleware[i][0][0];
  37. context.req.routeIndex = i;
  38. } else {
  39. handler = i === middleware.length && next || void 0;
  40. }
  41. if (handler) {
  42. try {
  43. res = await handler(context, () => dispatch(i + 1));
  44. } catch (err) {
  45. if (err instanceof Error && onError) {
  46. context.error = err;
  47. res = await onError(err, context);
  48. isError = true;
  49. } else {
  50. throw err;
  51. }
  52. }
  53. } else {
  54. if (context.finalized === false && onNotFound) {
  55. res = await onNotFound(context);
  56. }
  57. }
  58. if (res && (context.finalized === false || isError)) {
  59. context.res = res;
  60. }
  61. return context;
  62. }
  63. };
  64. };
  65. // Annotate the CommonJS export names for ESM import in node:
  66. 0 && (module.exports = {
  67. compose
  68. });