index.cjs 51 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720
  1. "use strict";
  2. var __create = Object.create;
  3. var __defProp = Object.defineProperty;
  4. var __getOwnPropDesc = Object.getOwnPropertyDescriptor;
  5. var __getOwnPropNames = Object.getOwnPropertyNames;
  6. var __getProtoOf = Object.getPrototypeOf;
  7. var __hasOwnProp = Object.prototype.hasOwnProperty;
  8. var __name = (target, value) => __defProp(target, "name", { value, configurable: true });
  9. var __export = (target, all) => {
  10. for (var name in all)
  11. __defProp(target, name, { get: all[name], enumerable: true });
  12. };
  13. var __copyProps = (to, from, except, desc) => {
  14. if (from && typeof from === "object" || typeof from === "function") {
  15. for (let key of __getOwnPropNames(from))
  16. if (!__hasOwnProp.call(to, key) && key !== except)
  17. __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable });
  18. }
  19. return to;
  20. };
  21. var __toESM = (mod, isNodeMode, target) => (target = mod != null ? __create(__getProtoOf(mod)) : {}, __copyProps(
  22. // If the importer is in node compatibility mode or this is not an ESM
  23. // file that has been converted to a CommonJS file using a Babel-
  24. // compatible transform (i.e. "__esModule" has not been set), then set
  25. // "default" to the CommonJS "module.exports" for node compatibility.
  26. isNodeMode || !mod || !mod.__esModule ? __defProp(target, "default", { value: mod, enumerable: true }) : target,
  27. mod
  28. ));
  29. var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod);
  30. // src/index.js
  31. var index_exports = {};
  32. __export(index_exports, {
  33. BUFFER_ENCODING_LIST: () => BUFFER_ENCODING_LIST,
  34. BodyParser: () => BodyParser,
  35. CookieParser: () => CookieParser,
  36. DataSender: () => DataSender,
  37. EXPOSED_ERROR_PROPERTIES: () => EXPOSED_ERROR_PROPERTIES,
  38. ErrorSender: () => ErrorSender,
  39. HookInvoker: () => HookInvoker,
  40. HookName: () => HookName,
  41. HookRegistry: () => HookRegistry,
  42. HttpMethod: () => HttpMethod,
  43. METHODS_WITH_BODY: () => METHODS_WITH_BODY,
  44. QueryParser: () => QueryParser,
  45. RequestContext: () => RequestContext,
  46. RequestParser: () => RequestParser,
  47. Route: () => Route,
  48. RouteRegistry: () => RouteRegistry,
  49. RouterOptions: () => RouterOptions,
  50. TrieRouter: () => TrieRouter,
  51. UNPARSABLE_MEDIA_TYPES: () => UNPARSABLE_MEDIA_TYPES,
  52. createCookieString: () => createCookieString,
  53. createDebugger: () => createDebugger,
  54. createError: () => createError,
  55. createRequestMock: () => createRequestMock,
  56. createResponseMock: () => createResponseMock,
  57. fetchRequestBody: () => fetchRequestBody,
  58. getRequestPathname: () => getRequestPathname,
  59. isPromise: () => isPromise,
  60. isReadableStream: () => isReadableStream,
  61. isResponseSent: () => isResponseSent,
  62. isWritableStream: () => isWritableStream,
  63. parseContentType: () => parseContentType,
  64. parseCookie: () => parseCookie,
  65. parseJsonBody: () => parseJsonBody,
  66. toCamelCase: () => toCamelCase
  67. });
  68. module.exports = __toCommonJS(index_exports);
  69. // src/route.js
  70. var import_js_format14 = require("@e22m4u/js-format");
  71. // src/hooks/hook-invoker.js
  72. var import_js_format13 = require("@e22m4u/js-format");
  73. // src/utils/is-promise.js
  74. function isPromise(value) {
  75. if (!value) return false;
  76. if (typeof value !== "object") return false;
  77. return typeof value.then === "function";
  78. }
  79. __name(isPromise, "isPromise");
  80. // src/utils/parse-cookie.js
  81. var import_js_format = require("@e22m4u/js-format");
  82. function parseCookie(input) {
  83. if (typeof input !== "string")
  84. throw new import_js_format.Errorf(
  85. 'The first parameter of "parseCookie" should be a String, but %v given.',
  86. input
  87. );
  88. return input.split(";").filter((v) => v !== "").map((v) => v.split("=")).reduce((cookies, tuple) => {
  89. const key = decodeURIComponent(tuple[0]).trim();
  90. cookies[key] = decodeURIComponent(tuple[1]).trim();
  91. return cookies;
  92. }, {});
  93. }
  94. __name(parseCookie, "parseCookie");
  95. // src/utils/create-error.js
  96. var import_js_format2 = require("@e22m4u/js-format");
  97. var import_js_format3 = require("@e22m4u/js-format");
  98. function createError(errorCtor, message, ...args) {
  99. if (typeof errorCtor !== "function")
  100. throw new import_js_format3.Errorf(
  101. 'The first argument of "createError" should be a constructor, but %v given.',
  102. errorCtor
  103. );
  104. if (message != null && typeof message !== "string")
  105. throw new import_js_format3.Errorf(
  106. 'The second argument of "createError" should be a String, but %v given.',
  107. message
  108. );
  109. if (message == null) return new errorCtor();
  110. const interpolatedMessage = (0, import_js_format2.format)(message, ...args);
  111. return new errorCtor(interpolatedMessage);
  112. }
  113. __name(createError, "createError");
  114. // src/utils/to-camel-case.js
  115. var import_js_format4 = require("@e22m4u/js-format");
  116. function toCamelCase(input) {
  117. if (typeof input !== "string")
  118. throw new import_js_format4.Errorf(
  119. 'The first argument of "toCamelCase" should be a String, but %v given.',
  120. input
  121. );
  122. return input.replace(/(^\w|[A-Z]|\b\w)/g, (c) => c.toUpperCase()).replace(/\W+/g, "").replace(/(^\w)/g, (c) => c.toLowerCase());
  123. }
  124. __name(toCamelCase, "toCamelCase");
  125. // src/utils/create-debugger.js
  126. var import_debug = __toESM(require("debug"), 1);
  127. var import_js_format5 = require("@e22m4u/js-format");
  128. function createDebugger(name) {
  129. if (typeof name !== "string")
  130. throw new import_js_format5.Errorf(
  131. 'The first argument of "createDebugger" should be a String, but %v given.',
  132. name
  133. );
  134. const debug2 = (0, import_debug.default)(`jsTrieRouter:${name}`);
  135. return function(message, ...args) {
  136. const interpolatedMessage = (0, import_js_format5.format)(message, ...args);
  137. return debug2(interpolatedMessage);
  138. };
  139. }
  140. __name(createDebugger, "createDebugger");
  141. // src/utils/is-response-sent.js
  142. var import_js_format6 = require("@e22m4u/js-format");
  143. function isResponseSent(res) {
  144. if (!res || typeof res !== "object" || Array.isArray(res) || typeof res.headersSent !== "boolean") {
  145. throw new import_js_format6.Errorf(
  146. 'The first argument of "isResponseSent" should be an instance of ServerResponse, but %v given.',
  147. res
  148. );
  149. }
  150. return res.headersSent;
  151. }
  152. __name(isResponseSent, "isResponseSent");
  153. // src/utils/is-readable-stream.js
  154. function isReadableStream(value) {
  155. if (!value || typeof value !== "object") return false;
  156. return typeof value.pipe === "function";
  157. }
  158. __name(isReadableStream, "isReadableStream");
  159. // src/utils/parse-content-type.js
  160. var import_js_format7 = require("@e22m4u/js-format");
  161. function parseContentType(input) {
  162. if (typeof input !== "string")
  163. throw new import_js_format7.Errorf(
  164. 'The parameter "input" of "parseContentType" should be a String, but %v given.',
  165. input
  166. );
  167. const res = { mediaType: void 0, charset: void 0, boundary: void 0 };
  168. const re = /^\s*([^\s;/]+\/[^\s;/]+)(?:;\s*charset=([^\s;]+))?(?:;\s*boundary=([^\s;]+))?.*$/i;
  169. const matches = re.exec(input);
  170. if (matches && matches[1]) {
  171. res.mediaType = matches[1];
  172. if (matches[2]) res.charset = matches[2];
  173. if (matches[3]) res.boundary = matches[3];
  174. }
  175. return res;
  176. }
  177. __name(parseContentType, "parseContentType");
  178. // src/utils/is-writable-stream.js
  179. function isWritableStream(value) {
  180. if (!value || typeof value !== "object") return false;
  181. return typeof value.end === "function";
  182. }
  183. __name(isWritableStream, "isWritableStream");
  184. // src/utils/fetch-request-body.js
  185. var import_http_errors = __toESM(require("http-errors"), 1);
  186. var import_js_format8 = require("@e22m4u/js-format");
  187. var import_http = require("http");
  188. var BUFFER_ENCODING_LIST = [
  189. "ascii",
  190. "utf8",
  191. "utf-8",
  192. "utf16le",
  193. "utf-16le",
  194. "ucs2",
  195. "ucs-2",
  196. "base64",
  197. "base64url",
  198. "latin1",
  199. "binary",
  200. "hex"
  201. ];
  202. function fetchRequestBody(req, bodyBytesLimit = 0) {
  203. if (!(req instanceof import_http.IncomingMessage))
  204. throw new import_js_format8.Errorf(
  205. 'The first parameter of "fetchRequestBody" should be an IncomingMessage instance, but %v given.',
  206. req
  207. );
  208. if (typeof bodyBytesLimit !== "number")
  209. throw new import_js_format8.Errorf(
  210. 'The parameter "bodyBytesLimit" of "fetchRequestBody" should be a number, but %v given.',
  211. bodyBytesLimit
  212. );
  213. return new Promise((resolve, reject) => {
  214. const contentLength = parseInt(req.headers["content-length"] || "0", 10);
  215. if (bodyBytesLimit && contentLength && contentLength > bodyBytesLimit)
  216. throw createError(
  217. import_http_errors.default.PayloadTooLarge,
  218. "Request body limit is %s bytes, but %s bytes given.",
  219. bodyBytesLimit,
  220. contentLength
  221. );
  222. let encoding = "utf-8";
  223. const contentType = req.headers["content-type"] || "";
  224. if (contentType) {
  225. const parsedContentType = parseContentType(contentType);
  226. if (parsedContentType && parsedContentType.charset) {
  227. encoding = parsedContentType.charset.toLowerCase();
  228. if (!BUFFER_ENCODING_LIST.includes(encoding))
  229. throw createError(
  230. import_http_errors.default.UnsupportedMediaType,
  231. "Request encoding %v is not supported.",
  232. encoding
  233. );
  234. }
  235. }
  236. const data = [];
  237. let receivedLength = 0;
  238. const onData = /* @__PURE__ */ __name((chunk) => {
  239. receivedLength += chunk.length;
  240. if (bodyBytesLimit && receivedLength > bodyBytesLimit) {
  241. req.removeAllListeners();
  242. const error = createError(
  243. import_http_errors.default.PayloadTooLarge,
  244. "Request body limit is %v bytes, but %v bytes given.",
  245. bodyBytesLimit,
  246. receivedLength
  247. );
  248. reject(error);
  249. return;
  250. }
  251. data.push(chunk);
  252. }, "onData");
  253. const onEnd = /* @__PURE__ */ __name(() => {
  254. req.removeAllListeners();
  255. if (contentLength && contentLength !== receivedLength) {
  256. const error = createError(
  257. import_http_errors.default.BadRequest,
  258. 'Received bytes do not match the "content-length" header.'
  259. );
  260. reject(error);
  261. return;
  262. }
  263. const buffer = Buffer.concat(data);
  264. const body = Buffer.from(buffer, encoding).toString();
  265. resolve(body || void 0);
  266. }, "onEnd");
  267. const onError = /* @__PURE__ */ __name((error) => {
  268. req.removeAllListeners();
  269. reject((0, import_http_errors.default)(400, error));
  270. }, "onError");
  271. req.on("data", onData);
  272. req.on("end", onEnd);
  273. req.on("error", onError);
  274. req.resume();
  275. });
  276. }
  277. __name(fetchRequestBody, "fetchRequestBody");
  278. // src/utils/create-request-mock.js
  279. var import_net = require("net");
  280. var import_tls = require("tls");
  281. var import_http2 = require("http");
  282. var import_querystring = __toESM(require("querystring"), 1);
  283. var import_js_format10 = require("@e22m4u/js-format");
  284. // src/utils/create-cookie-string.js
  285. var import_js_format9 = require("@e22m4u/js-format");
  286. function createCookieString(data) {
  287. if (!data || typeof data !== "object" || Array.isArray(data))
  288. throw new import_js_format9.Errorf(
  289. 'The first parameter of "createCookieString" should be an Object, but %v given.',
  290. data
  291. );
  292. let cookies = "";
  293. for (const key in data) {
  294. if (!Object.prototype.hasOwnProperty.call(data, key)) continue;
  295. const val = data[key];
  296. if (val == null) continue;
  297. cookies += `${key}=${val}; `;
  298. }
  299. return cookies.trim();
  300. }
  301. __name(createCookieString, "createCookieString");
  302. // src/utils/create-request-mock.js
  303. function createRequestMock(patch) {
  304. if (patch != null && typeof patch !== "object" || Array.isArray(patch)) {
  305. throw new import_js_format10.Errorf(
  306. 'The first parameter of "createRequestMock" should be an Object, but %v given.',
  307. patch
  308. );
  309. }
  310. patch = patch || {};
  311. if (patch.host != null && typeof patch.host !== "string")
  312. throw new import_js_format10.Errorf(
  313. 'The parameter "host" of "createRequestMock" should be a String, but %v given.',
  314. patch.host
  315. );
  316. if (patch.method != null && typeof patch.method !== "string")
  317. throw new import_js_format10.Errorf(
  318. 'The parameter "method" of "createRequestMock" should be a String, but %v given.',
  319. patch.method
  320. );
  321. if (patch.secure != null && typeof patch.secure !== "boolean")
  322. throw new import_js_format10.Errorf(
  323. 'The parameter "secure" of "createRequestMock" should be a Boolean, but %v given.',
  324. patch.secure
  325. );
  326. if (patch.path != null && typeof patch.path !== "string")
  327. throw new import_js_format10.Errorf(
  328. 'The parameter "path" of "createRequestMock" should be a String, but %v given.',
  329. patch.path
  330. );
  331. if (patch.query != null && typeof patch.query !== "object" && typeof patch.query !== "string" || Array.isArray(patch.query)) {
  332. throw new import_js_format10.Errorf(
  333. 'The parameter "query" of "createRequestMock" should be a String or Object, but %v given.',
  334. patch.query
  335. );
  336. }
  337. if (patch.cookie != null && typeof patch.cookie !== "string" && typeof patch.cookie !== "object" || Array.isArray(patch.cookie)) {
  338. throw new import_js_format10.Errorf(
  339. 'The parameter "cookie" of "createRequestMock" should be a String or Object, but %v given.',
  340. patch.cookie
  341. );
  342. }
  343. if (patch.headers != null && typeof patch.headers !== "object" || Array.isArray(patch.headers)) {
  344. throw new import_js_format10.Errorf(
  345. 'The parameter "headers" of "createRequestMock" should be an Object, but %v given.',
  346. patch.headers
  347. );
  348. }
  349. if (patch.stream != null && !isReadableStream(patch.stream))
  350. throw new import_js_format10.Errorf(
  351. 'The parameter "stream" of "createRequestMock" should be a Stream, but %v given.',
  352. patch.stream
  353. );
  354. if (patch.encoding != null) {
  355. if (typeof patch.encoding !== "string")
  356. throw new import_js_format10.Errorf(
  357. 'The parameter "encoding" of "createRequestMock" should be a String, but %v given.',
  358. patch.encoding
  359. );
  360. if (!BUFFER_ENCODING_LIST.includes(patch.encoding))
  361. throw new import_js_format10.Errorf("Buffer encoding %v is not supported.", patch.encoding);
  362. }
  363. if (patch.stream) {
  364. if (patch.secure != null)
  365. throw new import_js_format10.Errorf(
  366. 'The "createRequestMock" does not allow specifying the "stream" and "secure" options simultaneously.'
  367. );
  368. if (patch.body != null)
  369. throw new import_js_format10.Errorf(
  370. 'The "createRequestMock" does not allow specifying the "stream" and "body" options simultaneously.'
  371. );
  372. if (patch.encoding != null)
  373. throw new import_js_format10.Errorf(
  374. 'The "createRequestMock" does not allow specifying the "stream" and "encoding" options simultaneously.'
  375. );
  376. }
  377. const req = patch.stream || createRequestStream(patch.secure, patch.body, patch.encoding);
  378. req.url = createRequestUrl(patch.path || "/", patch.query);
  379. req.headers = createRequestHeaders(
  380. patch.host,
  381. patch.secure,
  382. patch.body,
  383. patch.cookie,
  384. patch.encoding,
  385. patch.headers
  386. );
  387. req.method = (patch.method || "get").toUpperCase();
  388. return req;
  389. }
  390. __name(createRequestMock, "createRequestMock");
  391. function createRequestStream(secure, body, encoding) {
  392. if (encoding != null && typeof encoding !== "string")
  393. throw new import_js_format10.Errorf(
  394. 'The parameter "encoding" of "createRequestStream" should be a String, but %v given.',
  395. encoding
  396. );
  397. encoding = encoding || "utf-8";
  398. let socket = new import_net.Socket();
  399. if (secure) socket = new import_tls.TLSSocket(socket);
  400. const req = new import_http2.IncomingMessage(socket);
  401. if (body != null) {
  402. if (typeof body === "string") {
  403. req.push(body, encoding);
  404. } else if (Buffer.isBuffer(body)) {
  405. req.push(body);
  406. } else {
  407. req.push(JSON.stringify(body));
  408. }
  409. }
  410. req.push(null);
  411. return req;
  412. }
  413. __name(createRequestStream, "createRequestStream");
  414. function createRequestUrl(path, query) {
  415. if (typeof path !== "string")
  416. throw new import_js_format10.Errorf(
  417. 'The parameter "path" of "createRequestUrl" should be a String, but %v given.',
  418. path
  419. );
  420. if (query != null && typeof query !== "string" && typeof query !== "object" || Array.isArray(query)) {
  421. throw new import_js_format10.Errorf(
  422. 'The parameter "query" of "createRequestUrl" should be a String or Object, but %v given.',
  423. query
  424. );
  425. }
  426. let url = ("/" + path).replace("//", "/");
  427. if (typeof query === "object") {
  428. const qs = import_querystring.default.stringify(query);
  429. if (qs) url += `?${qs}`;
  430. } else if (typeof query === "string") {
  431. url += `?${query.replace(/^\?/, "")}`;
  432. }
  433. return url;
  434. }
  435. __name(createRequestUrl, "createRequestUrl");
  436. function createRequestHeaders(host, secure, body, cookie, encoding, headers) {
  437. if (host != null && typeof host !== "string")
  438. throw new import_js_format10.Errorf(
  439. 'The parameter "host" of "createRequestHeaders" a non-empty String, but %v given.',
  440. host
  441. );
  442. host = host || "localhost";
  443. if (secure != null && typeof secure !== "boolean")
  444. throw new import_js_format10.Errorf(
  445. 'The parameter "secure" of "createRequestHeaders" should be a String, but %v given.',
  446. secure
  447. );
  448. secure = Boolean(secure);
  449. if (cookie != null && typeof cookie !== "object" && typeof cookie !== "string" || Array.isArray(cookie)) {
  450. throw new import_js_format10.Errorf(
  451. 'The parameter "cookie" of "createRequestHeaders" should be a String or Object, but %v given.',
  452. cookie
  453. );
  454. }
  455. if (headers != null && typeof headers !== "object" || Array.isArray(headers)) {
  456. throw new import_js_format10.Errorf(
  457. 'The parameter "headers" of "createRequestHeaders" should be an Object, but %v given.',
  458. headers
  459. );
  460. }
  461. headers = headers || {};
  462. if (encoding != null && typeof encoding !== "string")
  463. throw new import_js_format10.Errorf(
  464. 'The parameter "encoding" of "createRequestHeaders" should be a String, but %v given.',
  465. encoding
  466. );
  467. encoding = encoding || "utf-8";
  468. const obj = { ...headers };
  469. obj["host"] = host;
  470. if (secure) obj["x-forwarded-proto"] = "https";
  471. if (cookie != null) {
  472. if (typeof cookie === "string") {
  473. obj["cookie"] = obj["cookie"] ? obj["cookie"] : "";
  474. obj["cookie"] += cookie;
  475. } else if (typeof cookie === "object") {
  476. obj["cookie"] = obj["cookie"] ? obj["cookie"] : "";
  477. obj["cookie"] += createCookieString(cookie);
  478. }
  479. }
  480. if (obj["content-type"] == null) {
  481. if (typeof body === "string") {
  482. obj["content-type"] = "text/plain";
  483. } else if (Buffer.isBuffer(body)) {
  484. obj["content-type"] = "application/octet-stream";
  485. } else if (typeof body === "object" || typeof body === "boolean" || typeof body === "number") {
  486. obj["content-type"] = "application/json";
  487. }
  488. }
  489. if (body != null && obj["content-length"] == null) {
  490. if (typeof body === "string") {
  491. const length = Buffer.byteLength(body, encoding);
  492. obj["content-length"] = String(length);
  493. } else if (Buffer.isBuffer(body)) {
  494. const length = Buffer.byteLength(body);
  495. obj["content-length"] = String(length);
  496. } else if (typeof body === "object" || typeof body === "boolean" || typeof body === "number") {
  497. const json = JSON.stringify(body);
  498. const length = Buffer.byteLength(json, encoding);
  499. obj["content-length"] = String(length);
  500. }
  501. }
  502. return obj;
  503. }
  504. __name(createRequestHeaders, "createRequestHeaders");
  505. // src/utils/create-response-mock.js
  506. var import_stream = require("stream");
  507. function createResponseMock() {
  508. const res = new import_stream.PassThrough();
  509. patchEncoding(res);
  510. patchHeaders(res);
  511. patchBody(res);
  512. return res;
  513. }
  514. __name(createResponseMock, "createResponseMock");
  515. function patchEncoding(res) {
  516. Object.defineProperty(res, "_encoding", {
  517. configurable: true,
  518. writable: true,
  519. value: void 0
  520. });
  521. Object.defineProperty(res, "setEncoding", {
  522. configurable: true,
  523. value: /* @__PURE__ */ __name(function(enc) {
  524. this._encoding = enc;
  525. return this;
  526. }, "value")
  527. });
  528. Object.defineProperty(res, "getEncoding", {
  529. configurable: true,
  530. value: /* @__PURE__ */ __name(function() {
  531. return this._encoding;
  532. }, "value")
  533. });
  534. }
  535. __name(patchEncoding, "patchEncoding");
  536. function patchHeaders(res) {
  537. Object.defineProperty(res, "_headersSent", {
  538. configurable: true,
  539. writable: true,
  540. value: false
  541. });
  542. Object.defineProperty(res, "headersSent", {
  543. configurable: true,
  544. get() {
  545. return this._headersSent;
  546. }
  547. });
  548. Object.defineProperty(res, "_headers", {
  549. configurable: true,
  550. writable: true,
  551. value: {}
  552. });
  553. Object.defineProperty(res, "setHeader", {
  554. configurable: true,
  555. value: /* @__PURE__ */ __name(function(name, value) {
  556. if (this.headersSent)
  557. throw new Error(
  558. "Error [ERR_HTTP_HEADERS_SENT]: Cannot set headers after they are sent to the client"
  559. );
  560. const key = name.toLowerCase();
  561. this._headers[key] = String(value);
  562. return this;
  563. }, "value")
  564. });
  565. Object.defineProperty(res, "getHeader", {
  566. configurable: true,
  567. value: /* @__PURE__ */ __name(function(name) {
  568. return this._headers[name.toLowerCase()];
  569. }, "value")
  570. });
  571. Object.defineProperty(res, "getHeaders", {
  572. configurable: true,
  573. value: /* @__PURE__ */ __name(function() {
  574. return JSON.parse(JSON.stringify(this._headers));
  575. }, "value")
  576. });
  577. }
  578. __name(patchHeaders, "patchHeaders");
  579. function patchBody(res) {
  580. let resolve, reject;
  581. const promise = new Promise((res2, rej) => {
  582. resolve = res2;
  583. reject = rej;
  584. });
  585. const data = [];
  586. res.on("data", (c) => data.push(c));
  587. res.on("error", (e) => reject(e));
  588. res.on("end", () => {
  589. res._headersSent = true;
  590. resolve(Buffer.concat(data));
  591. });
  592. Object.defineProperty(res, "getBody", {
  593. configurable: true,
  594. value: /* @__PURE__ */ __name(function() {
  595. return promise.then((buffer) => {
  596. const enc = this.getEncoding();
  597. const str = buffer.toString(enc);
  598. return data.length ? str : void 0;
  599. });
  600. }, "value")
  601. });
  602. }
  603. __name(patchBody, "patchBody");
  604. // src/utils/get-request-pathname.js
  605. var import_js_format11 = require("@e22m4u/js-format");
  606. function getRequestPathname(req) {
  607. if (!req || typeof req !== "object" || Array.isArray(req) || typeof req.url !== "string") {
  608. throw new import_js_format11.Errorf(
  609. 'The first argument of "getRequestPathname" should be an instance of IncomingMessage, but %v given.',
  610. req
  611. );
  612. }
  613. return (req.url || "/").replace(/\?.*$/, "");
  614. }
  615. __name(getRequestPathname, "getRequestPathname");
  616. // src/hooks/hook-registry.js
  617. var import_js_format12 = require("@e22m4u/js-format");
  618. // src/debuggable-service.js
  619. var import_js_service = require("@e22m4u/js-service");
  620. var import_js_service2 = require("@e22m4u/js-service");
  621. var _DebuggableService = class _DebuggableService extends import_js_service.Service {
  622. /**
  623. * Debug.
  624. *
  625. * @type {Function}
  626. */
  627. debug;
  628. /**
  629. * Constructor.
  630. *
  631. * @param {ServiceContainer} container
  632. */
  633. constructor(container) {
  634. super(container);
  635. const serviceName = toCamelCase(this.constructor.name);
  636. this.debug = createDebugger(serviceName);
  637. this.debug("The %v is created.", this.constructor);
  638. }
  639. };
  640. __name(_DebuggableService, "DebuggableService");
  641. var DebuggableService = _DebuggableService;
  642. // src/hooks/hook-registry.js
  643. var HookName = {
  644. PRE_HANDLER: "preHandler",
  645. POST_HANDLER: "postHandler"
  646. };
  647. var _HookRegistry = class _HookRegistry extends DebuggableService {
  648. /**
  649. * Hooks.
  650. *
  651. * @type {Map<string, Function[]>}
  652. * @private
  653. */
  654. _hooks = /* @__PURE__ */ new Map();
  655. /**
  656. * Add hook.
  657. *
  658. * @param {string} name
  659. * @param {Function} hook
  660. * @returns {this}
  661. */
  662. addHook(name, hook) {
  663. if (!name || typeof name !== "string")
  664. throw new import_js_format12.Errorf("The hook name is required, but %v given.", name);
  665. if (!Object.values(HookName).includes(name))
  666. throw new import_js_format12.Errorf("The hook name %v is not supported.", name);
  667. if (!hook || typeof hook !== "function")
  668. throw new import_js_format12.Errorf(
  669. "The hook %v should be a Function, but %v given.",
  670. name,
  671. hook
  672. );
  673. const hooks = this._hooks.get(name) || [];
  674. hooks.push(hook);
  675. this._hooks.set(name, hooks);
  676. return this;
  677. }
  678. /**
  679. * Has hook.
  680. *
  681. * @param {string} name
  682. * @param {Function} hook
  683. * @returns {boolean}
  684. */
  685. hasHook(name, hook) {
  686. if (!name || typeof name !== "string")
  687. throw new import_js_format12.Errorf("The hook name is required, but %v given.", name);
  688. if (!Object.values(HookName).includes(name))
  689. throw new import_js_format12.Errorf("The hook name %v is not supported.", name);
  690. if (!hook || typeof hook !== "function")
  691. throw new import_js_format12.Errorf(
  692. "The hook %v should be a Function, but %v given.",
  693. name,
  694. hook
  695. );
  696. const hooks = this._hooks.get(name) || [];
  697. return hooks.indexOf(hook) > -1;
  698. }
  699. /**
  700. * Get hooks.
  701. *
  702. * @param {string} name
  703. * @returns {Function[]}
  704. */
  705. getHooks(name) {
  706. if (!name || typeof name !== "string")
  707. throw new import_js_format12.Errorf("The hook name is required, but %v given.", name);
  708. if (!Object.values(HookName).includes(name))
  709. throw new import_js_format12.Errorf("The hook name %v is not supported.", name);
  710. return this._hooks.get(name) || [];
  711. }
  712. };
  713. __name(_HookRegistry, "HookRegistry");
  714. var HookRegistry = _HookRegistry;
  715. // src/hooks/hook-invoker.js
  716. var _HookInvoker = class _HookInvoker extends DebuggableService {
  717. /**
  718. * Invoke and continue until value received.
  719. *
  720. * @param {Route} route
  721. * @param {string} hookName
  722. * @param {import('http').ServerResponse} response
  723. * @param {*[]} args
  724. * @returns {Promise<*>|*}
  725. */
  726. invokeAndContinueUntilValueReceived(route, hookName, response, ...args) {
  727. if (!route || !(route instanceof Route))
  728. throw new import_js_format13.Errorf(
  729. 'The parameter "route" of the HookInvoker.invokeAndContinueUntilValueReceived should be a Route instance, but %v given.',
  730. route
  731. );
  732. if (!hookName || typeof hookName !== "string")
  733. throw new import_js_format13.Errorf(
  734. 'The parameter "hookName" of the HookInvoker.invokeAndContinueUntilValueReceived should be a non-empty String, but %v given.',
  735. hookName
  736. );
  737. if (!Object.values(HookName).includes(hookName))
  738. throw new import_js_format13.Errorf("The hook name %v is not supported.", hookName);
  739. if (!response || typeof response !== "object" || Array.isArray(response) || typeof response.headersSent !== "boolean") {
  740. throw new import_js_format13.Errorf(
  741. 'The parameter "response" of the HookInvoker.invokeAndContinueUntilValueReceived should be a ServerResponse instance, but %v given.',
  742. response
  743. );
  744. }
  745. const hooks = [
  746. ...this.getService(HookRegistry).getHooks(hookName),
  747. ...route.hookRegistry.getHooks(hookName)
  748. ];
  749. let result = void 0;
  750. for (const hook of hooks) {
  751. if (isResponseSent(response)) {
  752. result = response;
  753. break;
  754. }
  755. if (result == null) {
  756. result = hook(...args);
  757. } else if (isPromise(result)) {
  758. result = result.then((prevVal) => {
  759. if (isResponseSent(response)) {
  760. result = response;
  761. return;
  762. }
  763. if (prevVal != null) return prevVal;
  764. return hook(...args);
  765. });
  766. } else {
  767. break;
  768. }
  769. }
  770. return result;
  771. }
  772. };
  773. __name(_HookInvoker, "HookInvoker");
  774. var HookInvoker = _HookInvoker;
  775. // src/route.js
  776. var HttpMethod = {
  777. GET: "GET",
  778. POST: "POST",
  779. PUT: "PUT",
  780. PATCH: "PATCH",
  781. DELETE: "DELETE"
  782. };
  783. var debug = createDebugger("route");
  784. var _Route = class _Route {
  785. /**
  786. * Method.
  787. *
  788. * @type {string}
  789. * @private
  790. */
  791. _method;
  792. /**
  793. * Getter of the method.
  794. *
  795. * @returns {string}
  796. */
  797. get method() {
  798. return this._method;
  799. }
  800. /**
  801. * Path template.
  802. *
  803. * @type {string}
  804. * @private
  805. */
  806. _path;
  807. /**
  808. * Getter of the path.
  809. *
  810. * @returns {string}
  811. */
  812. get path() {
  813. return this._path;
  814. }
  815. /**
  816. * Handler.
  817. *
  818. * @type {RouteHandler}
  819. * @private
  820. */
  821. _handler;
  822. /**
  823. * Getter of the handler.
  824. *
  825. * @returns {*}
  826. */
  827. get handler() {
  828. return this._handler;
  829. }
  830. /**
  831. * Hook registry.
  832. *
  833. * @type {HookRegistry}
  834. * @private
  835. */
  836. _hookRegistry = new HookRegistry();
  837. /**
  838. * Getter of the hook registry.
  839. *
  840. * @returns {HookRegistry}
  841. */
  842. get hookRegistry() {
  843. return this._hookRegistry;
  844. }
  845. /**
  846. * Constructor.
  847. *
  848. * @param {RouteDefinition} routeDef
  849. */
  850. constructor(routeDef) {
  851. if (!routeDef || typeof routeDef !== "object" || Array.isArray(routeDef))
  852. throw new import_js_format14.Errorf(
  853. "The first parameter of Route.controller should be an Object, but %v given.",
  854. routeDef
  855. );
  856. if (!routeDef.method || typeof routeDef.method !== "string")
  857. throw new import_js_format14.Errorf(
  858. 'The option "method" of the Route should be a non-empty String, but %v given.',
  859. routeDef.method
  860. );
  861. this._method = routeDef.method.toUpperCase();
  862. if (typeof routeDef.path !== "string")
  863. throw new import_js_format14.Errorf(
  864. 'The option "path" of the Route should be a String, but %v given.',
  865. routeDef.path
  866. );
  867. this._path = routeDef.path;
  868. if (typeof routeDef.handler !== "function")
  869. throw new import_js_format14.Errorf(
  870. 'The option "handler" of the Route should be a Function, but %v given.',
  871. routeDef.handler
  872. );
  873. this._handler = routeDef.handler;
  874. if (routeDef.preHandler != null) {
  875. const preHandlerHooks = Array.isArray(routeDef.preHandler) ? routeDef.preHandler : [routeDef.preHandler];
  876. preHandlerHooks.forEach((hook) => {
  877. this._hookRegistry.addHook(HookName.PRE_HANDLER, hook);
  878. });
  879. }
  880. if (routeDef.postHandler != null) {
  881. const postHandlerHooks = Array.isArray(routeDef.postHandler) ? routeDef.postHandler : [routeDef.postHandler];
  882. postHandlerHooks.forEach((hook) => {
  883. this._hookRegistry.addHook(HookName.POST_HANDLER, hook);
  884. });
  885. }
  886. }
  887. /**
  888. * Handle request.
  889. *
  890. * @param {RequestContext} context
  891. * @returns {*}
  892. */
  893. handle(context) {
  894. const requestPath = getRequestPathname(context.req);
  895. debug(
  896. "Invoking the Route handler for the request %s %v.",
  897. this.method.toUpperCase(),
  898. requestPath
  899. );
  900. return this._handler(context);
  901. }
  902. };
  903. __name(_Route, "Route");
  904. var Route = _Route;
  905. // src/senders/data-sender.js
  906. var import_js_format15 = require("@e22m4u/js-format");
  907. var _DataSender = class _DataSender extends DebuggableService {
  908. /**
  909. * Send.
  910. *
  911. * @param {import('http').ServerResponse} res
  912. * @param {*} data
  913. * @returns {undefined}
  914. */
  915. send(res, data) {
  916. if (data === res || res.headersSent) {
  917. this.debug(
  918. "Response sending was skipped because its headers where sent already ."
  919. );
  920. return;
  921. }
  922. if (data == null) {
  923. res.statusCode = 204;
  924. res.end();
  925. this.debug("The empty response was sent.");
  926. return;
  927. }
  928. if (isReadableStream(data)) {
  929. res.setHeader("Content-Type", "application/octet-stream");
  930. data.pipe(res);
  931. this.debug("The stream response was sent.");
  932. return;
  933. }
  934. let debugMsg;
  935. switch (typeof data) {
  936. case "object":
  937. case "boolean":
  938. case "number":
  939. if (Buffer.isBuffer(data)) {
  940. res.setHeader("content-type", "application/octet-stream");
  941. debugMsg = "The Buffer was sent as binary data.";
  942. } else {
  943. res.setHeader("content-type", "application/json");
  944. debugMsg = (0, import_js_format15.format)("The %v was sent as JSON.", typeof data);
  945. data = JSON.stringify(data);
  946. }
  947. break;
  948. default:
  949. res.setHeader("content-type", "text/plain");
  950. debugMsg = "The response data was sent as plain text.";
  951. data = String(data);
  952. break;
  953. }
  954. res.end(data);
  955. this.debug(debugMsg);
  956. }
  957. };
  958. __name(_DataSender, "DataSender");
  959. var DataSender = _DataSender;
  960. // src/senders/error-sender.js
  961. var import_util = require("util");
  962. var import_statuses = __toESM(require("statuses"), 1);
  963. var EXPOSED_ERROR_PROPERTIES = ["code", "details"];
  964. var _ErrorSender = class _ErrorSender extends DebuggableService {
  965. /**
  966. * Handle.
  967. *
  968. * @param {import('http').IncomingMessage} req
  969. * @param {import('http').ServerResponse} res
  970. * @param {Error} error
  971. * @returns {undefined}
  972. */
  973. send(req, res, error) {
  974. let safeError = {};
  975. if (error) {
  976. if (typeof error === "object") {
  977. safeError = error;
  978. } else {
  979. safeError = { message: String(error) };
  980. }
  981. }
  982. const statusCode = error.statusCode || error.status || 500;
  983. const body = { error: {} };
  984. if (safeError.message && typeof safeError.message === "string") {
  985. body.error.message = safeError.message;
  986. } else {
  987. body.error.message = (0, import_statuses.default)(statusCode);
  988. }
  989. EXPOSED_ERROR_PROPERTIES.forEach((name) => {
  990. if (name in safeError) body.error[name] = safeError[name];
  991. });
  992. const requestData = {
  993. url: req.url,
  994. method: req.method,
  995. headers: req.headers
  996. };
  997. const inspectOptions = {
  998. showHidden: false,
  999. depth: null,
  1000. colors: true,
  1001. compact: false
  1002. };
  1003. console.warn((0, import_util.inspect)(requestData, inspectOptions));
  1004. console.warn((0, import_util.inspect)(body, inspectOptions));
  1005. res.statusCode = statusCode;
  1006. res.setHeader("content-type", "application/json; charset=utf-8");
  1007. res.end(JSON.stringify(body, null, 2), "utf-8");
  1008. this.debug(
  1009. "The %s error is sent for the request %s %v.",
  1010. statusCode,
  1011. req.method,
  1012. getRequestPathname(req)
  1013. );
  1014. }
  1015. /**
  1016. * Send 404.
  1017. *
  1018. * @param {import('http').IncomingMessage} req
  1019. * @param {import('http').ServerResponse} res
  1020. * @returns {undefined}
  1021. */
  1022. send404(req, res) {
  1023. res.statusCode = 404;
  1024. res.setHeader("content-type", "text/plain; charset=utf-8");
  1025. res.end("404 Not Found", "utf-8");
  1026. this.debug(
  1027. "The 404 error is sent for the request %s %v.",
  1028. req.method,
  1029. getRequestPathname(req)
  1030. );
  1031. }
  1032. };
  1033. __name(_ErrorSender, "ErrorSender");
  1034. var ErrorSender = _ErrorSender;
  1035. // src/parsers/body-parser.js
  1036. var import_http_errors2 = __toESM(require("http-errors"), 1);
  1037. var import_js_format17 = require("@e22m4u/js-format");
  1038. // src/router-options.js
  1039. var import_js_format16 = require("@e22m4u/js-format");
  1040. var _RouterOptions = class _RouterOptions extends DebuggableService {
  1041. /**
  1042. * Request body bytes limit.
  1043. *
  1044. * @type {number}
  1045. * @private
  1046. */
  1047. _requestBodyBytesLimit = 512e3;
  1048. // 512kb
  1049. /**
  1050. * Getter of request body bytes limit.
  1051. *
  1052. * @returns {number}
  1053. */
  1054. get requestBodyBytesLimit() {
  1055. return this._requestBodyBytesLimit;
  1056. }
  1057. /**
  1058. * Set request body bytes limit.
  1059. *
  1060. * @param {number} input
  1061. * @returns {RouterOptions}
  1062. */
  1063. setRequestBodyBytesLimit(input) {
  1064. if (typeof input !== "number" || input < 0)
  1065. throw new import_js_format16.Errorf(
  1066. 'The option "requestBodyBytesLimit" must be a positive Number or 0, but %v given.',
  1067. input
  1068. );
  1069. this._requestBodyBytesLimit = input;
  1070. return this;
  1071. }
  1072. };
  1073. __name(_RouterOptions, "RouterOptions");
  1074. var RouterOptions = _RouterOptions;
  1075. // src/parsers/body-parser.js
  1076. var METHODS_WITH_BODY = ["POST", "PUT", "PATCH", "DELETE"];
  1077. var UNPARSABLE_MEDIA_TYPES = ["multipart/form-data"];
  1078. var _BodyParser = class _BodyParser extends DebuggableService {
  1079. /**
  1080. * Parsers.
  1081. *
  1082. * @type {{[mime: string]: Function}}
  1083. */
  1084. _parsers = {
  1085. "text/plain": /* @__PURE__ */ __name((v) => String(v), "text/plain"),
  1086. "application/json": parseJsonBody
  1087. };
  1088. /**
  1089. * Set parser.
  1090. *
  1091. * @param {string} mediaType
  1092. * @param {Function} parser
  1093. * @returns {this}
  1094. */
  1095. defineParser(mediaType, parser) {
  1096. if (!mediaType || typeof mediaType !== "string")
  1097. throw new import_js_format17.Errorf(
  1098. 'The parameter "mediaType" of BodyParser.defineParser should be a non-empty String, but %v given.',
  1099. mediaType
  1100. );
  1101. if (!parser || typeof parser !== "function")
  1102. throw new import_js_format17.Errorf(
  1103. 'The parameter "parser" of BodyParser.defineParser should be a Function, but %v given.',
  1104. parser
  1105. );
  1106. this._parsers[mediaType] = parser;
  1107. return this;
  1108. }
  1109. /**
  1110. * Has parser.
  1111. *
  1112. * @param {string} mediaType
  1113. * @returns {boolean}
  1114. */
  1115. hasParser(mediaType) {
  1116. if (!mediaType || typeof mediaType !== "string")
  1117. throw new import_js_format17.Errorf(
  1118. 'The parameter "mediaType" of BodyParser.hasParser should be a non-empty String, but %v given.',
  1119. mediaType
  1120. );
  1121. return Boolean(this._parsers[mediaType]);
  1122. }
  1123. /**
  1124. * Delete parser.
  1125. *
  1126. * @param {string} mediaType
  1127. * @returns {this}
  1128. */
  1129. deleteParser(mediaType) {
  1130. if (!mediaType || typeof mediaType !== "string")
  1131. throw new import_js_format17.Errorf(
  1132. 'The parameter "mediaType" of BodyParser.deleteParser should be a non-empty String, but %v given.',
  1133. mediaType
  1134. );
  1135. const parser = this._parsers[mediaType];
  1136. if (!parser) throw new import_js_format17.Errorf("The parser of %v is not found.", mediaType);
  1137. delete this._parsers[mediaType];
  1138. return this;
  1139. }
  1140. /**
  1141. * Parse.
  1142. *
  1143. * @param {import('http').IncomingMessage} req
  1144. * @returns {Promise<*>|undefined}
  1145. */
  1146. parse(req) {
  1147. if (!METHODS_WITH_BODY.includes(req.method.toUpperCase())) {
  1148. this.debug(
  1149. "Body parsing was skipped for the %s request.",
  1150. req.method.toUpperCase()
  1151. );
  1152. return;
  1153. }
  1154. const contentType = (req.headers["content-type"] || "").replace(
  1155. /^([^;]+);.*$/,
  1156. "$1"
  1157. );
  1158. if (!contentType) {
  1159. this.debug(
  1160. "Body parsing was skipped because the request has no content type."
  1161. );
  1162. return;
  1163. }
  1164. const { mediaType } = parseContentType(contentType);
  1165. if (!mediaType)
  1166. throw createError(
  1167. import_http_errors2.default.BadRequest,
  1168. 'Unable to parse the "content-type" header.'
  1169. );
  1170. const parser = this._parsers[mediaType];
  1171. if (!parser) {
  1172. if (UNPARSABLE_MEDIA_TYPES.includes(mediaType)) {
  1173. this.debug("Body parsing was skipped for %v.", mediaType);
  1174. return;
  1175. }
  1176. throw createError(
  1177. import_http_errors2.default.UnsupportedMediaType,
  1178. "Media type %v is not supported.",
  1179. mediaType
  1180. );
  1181. }
  1182. const bodyBytesLimit = this.getService(RouterOptions).requestBodyBytesLimit;
  1183. return fetchRequestBody(req, bodyBytesLimit).then((rawBody) => {
  1184. if (rawBody != null) return parser(rawBody);
  1185. return rawBody;
  1186. });
  1187. }
  1188. };
  1189. __name(_BodyParser, "BodyParser");
  1190. var BodyParser = _BodyParser;
  1191. function parseJsonBody(input) {
  1192. if (typeof input !== "string") return void 0;
  1193. try {
  1194. return JSON.parse(input);
  1195. } catch (error) {
  1196. if (process.env["DEBUG"] || process.env["NODE_ENV"] === "development")
  1197. console.warn(error);
  1198. throw createError(import_http_errors2.default.BadRequest, "Unable to parse request body.");
  1199. }
  1200. }
  1201. __name(parseJsonBody, "parseJsonBody");
  1202. // src/parsers/query-parser.js
  1203. var import_querystring2 = __toESM(require("querystring"), 1);
  1204. var _QueryParser = class _QueryParser extends DebuggableService {
  1205. /**
  1206. * Parse
  1207. *
  1208. * @param {import('http').IncomingMessage} req
  1209. * @returns {object}
  1210. */
  1211. parse(req) {
  1212. const queryStr = req.url.replace(/^[^?]*\??/, "");
  1213. const query = queryStr ? import_querystring2.default.parse(queryStr) : {};
  1214. const queryKeys = Object.keys(query);
  1215. if (queryKeys.length) {
  1216. queryKeys.forEach((key) => {
  1217. this.debug("The query %v has the value %v.", key, query[key]);
  1218. });
  1219. } else {
  1220. this.debug(
  1221. "The request %s %v has no query.",
  1222. req.method,
  1223. getRequestPathname(req)
  1224. );
  1225. }
  1226. return query;
  1227. }
  1228. };
  1229. __name(_QueryParser, "QueryParser");
  1230. var QueryParser = _QueryParser;
  1231. // src/parsers/cookie-parser.js
  1232. var _CookieParser = class _CookieParser extends DebuggableService {
  1233. /**
  1234. * Parse
  1235. *
  1236. * @param {import('http').IncomingMessage} req
  1237. * @returns {object}
  1238. */
  1239. parse(req) {
  1240. const cookieString = req.headers["cookie"] || "";
  1241. const cookie = parseCookie(cookieString);
  1242. const cookieKeys = Object.keys(cookie);
  1243. if (cookieKeys.length) {
  1244. cookieKeys.forEach((key) => {
  1245. this.debug("The cookie %v has the value %v.", key, cookie[key]);
  1246. });
  1247. } else {
  1248. this.debug(
  1249. "The request %s %v has no cookie.",
  1250. req.method,
  1251. getRequestPathname(req)
  1252. );
  1253. }
  1254. return cookie;
  1255. }
  1256. };
  1257. __name(_CookieParser, "CookieParser");
  1258. var CookieParser = _CookieParser;
  1259. // src/parsers/request-parser.js
  1260. var import_http3 = require("http");
  1261. var import_js_format18 = require("@e22m4u/js-format");
  1262. var _RequestParser = class _RequestParser extends DebuggableService {
  1263. /**
  1264. * Parse.
  1265. *
  1266. * @param {IncomingMessage} req
  1267. * @returns {Promise<object>|object}
  1268. */
  1269. parse(req) {
  1270. if (!(req instanceof import_http3.IncomingMessage))
  1271. throw new import_js_format18.Errorf(
  1272. "The first argument of RequestParser.parse should be an instance of IncomingMessage, but %v given.",
  1273. req
  1274. );
  1275. const data = {};
  1276. const promises = [];
  1277. const parsedQuery = this.getService(QueryParser).parse(req);
  1278. if (isPromise(parsedQuery)) {
  1279. promises.push(parsedQuery.then((v) => data.query = v));
  1280. } else {
  1281. data.query = parsedQuery;
  1282. }
  1283. const parsedCookie = this.getService(CookieParser).parse(req);
  1284. if (isPromise(parsedCookie)) {
  1285. promises.push(parsedCookie.then((v) => data.cookie = v));
  1286. } else {
  1287. data.cookie = parsedCookie;
  1288. }
  1289. const parsedBody = this.getService(BodyParser).parse(req);
  1290. if (isPromise(parsedBody)) {
  1291. promises.push(parsedBody.then((v) => data.body = v));
  1292. } else {
  1293. data.body = parsedBody;
  1294. }
  1295. data.headers = JSON.parse(JSON.stringify(req.headers));
  1296. return promises.length ? Promise.all(promises).then(() => data) : data;
  1297. }
  1298. };
  1299. __name(_RequestParser, "RequestParser");
  1300. var RequestParser = _RequestParser;
  1301. // src/route-registry.js
  1302. var import_js_format19 = require("@e22m4u/js-format");
  1303. var import_js_path_trie = require("@e22m4u/js-path-trie");
  1304. var import_js_service3 = require("@e22m4u/js-service");
  1305. var _RouteRegistry = class _RouteRegistry extends DebuggableService {
  1306. /**
  1307. * Constructor.
  1308. *
  1309. * @param {ServiceContainer} container
  1310. */
  1311. constructor(container) {
  1312. super(container);
  1313. this._trie = new import_js_path_trie.PathTrie();
  1314. }
  1315. /**
  1316. * Define route.
  1317. *
  1318. * @param {import('./route.js').RouteDefinition} routeDef
  1319. * @returns {Route}
  1320. */
  1321. defineRoute(routeDef) {
  1322. if (!routeDef || typeof routeDef !== "object" || Array.isArray(routeDef))
  1323. throw new import_js_format19.Errorf(
  1324. "The route definition should be an Object, but %v given.",
  1325. routeDef
  1326. );
  1327. const route = new Route(routeDef);
  1328. const triePath = `${route.method}/${route.path}`;
  1329. this._trie.add(triePath, route);
  1330. this.debug(
  1331. "The route %s %v is registered.",
  1332. route.method.toUpperCase(),
  1333. route.path
  1334. );
  1335. return route;
  1336. }
  1337. /**
  1338. * Match route by request.
  1339. *
  1340. * @param {import('http').IncomingRequest} req
  1341. * @returns {ResolvedRoute|undefined}
  1342. */
  1343. matchRouteByRequest(req) {
  1344. const requestPath = (req.url || "/").replace(/\?.*$/, "");
  1345. this.debug(
  1346. "Matching %s %v with registered routes.",
  1347. req.method.toUpperCase(),
  1348. requestPath
  1349. );
  1350. const triePath = `${req.method.toUpperCase()}/${requestPath}`;
  1351. const resolved = this._trie.match(triePath);
  1352. if (resolved) {
  1353. const route = resolved.value;
  1354. this.debug(
  1355. "The request %s %v was matched to the route %s %v.",
  1356. req.method.toUpperCase(),
  1357. requestPath,
  1358. route.method.toUpperCase(),
  1359. route.path
  1360. );
  1361. const paramNames = Object.keys(resolved.params);
  1362. if (paramNames) {
  1363. paramNames.forEach((name) => {
  1364. this.debug(
  1365. "The path parameter %v has the value %v.",
  1366. name,
  1367. resolved.params[name]
  1368. );
  1369. });
  1370. } else {
  1371. this.debug("No path parameters found.");
  1372. }
  1373. return { route, params: resolved.params };
  1374. }
  1375. this.debug(
  1376. "No matched route for the request %s %v.",
  1377. req.method.toUpperCase(),
  1378. requestPath
  1379. );
  1380. }
  1381. };
  1382. __name(_RouteRegistry, "RouteRegistry");
  1383. var RouteRegistry = _RouteRegistry;
  1384. // src/request-context.js
  1385. var import_js_format20 = require("@e22m4u/js-format");
  1386. var import_js_service4 = require("@e22m4u/js-service");
  1387. var _RequestContext = class _RequestContext {
  1388. /**
  1389. * Service container.
  1390. *
  1391. * @type {import('@e22m4u/js-service').ServiceContainer}
  1392. */
  1393. container;
  1394. /**
  1395. * Request.
  1396. *
  1397. * @type {import('http').IncomingMessage}
  1398. */
  1399. req;
  1400. /**
  1401. * Response.
  1402. *
  1403. * @type {import('http').ServerResponse}
  1404. */
  1405. res;
  1406. /**
  1407. * Query.
  1408. *
  1409. * @type {object}
  1410. */
  1411. query = {};
  1412. /**
  1413. * Path parameters.
  1414. *
  1415. * @type {object}
  1416. */
  1417. params = {};
  1418. /**
  1419. * Headers.
  1420. *
  1421. * @type {object}
  1422. */
  1423. headers = {};
  1424. /**
  1425. * Parsed cookie.
  1426. *
  1427. * @type {object}
  1428. */
  1429. cookie = {};
  1430. /**
  1431. * Parsed body.
  1432. *
  1433. * @type {*}
  1434. */
  1435. body;
  1436. /**
  1437. * Method.
  1438. *
  1439. * @returns {string}
  1440. */
  1441. get method() {
  1442. return this.req.method.toUpperCase();
  1443. }
  1444. /**
  1445. * Path.
  1446. *
  1447. * @returns {string}
  1448. */
  1449. get path() {
  1450. return this.req.url;
  1451. }
  1452. /**
  1453. * Pathname.
  1454. *
  1455. * @type {string|undefined}
  1456. * @private
  1457. */
  1458. _pathname = void 0;
  1459. /**
  1460. * Pathname.
  1461. *
  1462. * @returns {string}
  1463. */
  1464. get pathname() {
  1465. if (this._pathname != null) return this._pathname;
  1466. this._pathname = getRequestPathname(this.req);
  1467. return this._pathname;
  1468. }
  1469. /**
  1470. * Constructor.
  1471. *
  1472. * @param {ServiceContainer} container
  1473. * @param {import('http').IncomingMessage} request
  1474. * @param {import('http').ServerResponse} response
  1475. */
  1476. constructor(container, request, response) {
  1477. if (!(container instanceof import_js_service4.ServiceContainer))
  1478. throw new import_js_format20.Errorf(
  1479. 'The parameter "container" of RequestContext.constructor should be an instance of ServiceContainer, but %v given.',
  1480. container
  1481. );
  1482. this.container = container;
  1483. if (!request || typeof request !== "object" || Array.isArray(request) || !isReadableStream(request)) {
  1484. throw new import_js_format20.Errorf(
  1485. 'The parameter "request" of RequestContext.constructor should be an instance of IncomingMessage, but %v given.',
  1486. request
  1487. );
  1488. }
  1489. this.req = request;
  1490. if (!response || typeof response !== "object" || Array.isArray(response) || !isWritableStream(response)) {
  1491. throw new import_js_format20.Errorf(
  1492. 'The parameter "response" of RequestContext.constructor should be an instance of ServerResponse, but %v given.',
  1493. response
  1494. );
  1495. }
  1496. this.res = response;
  1497. }
  1498. };
  1499. __name(_RequestContext, "RequestContext");
  1500. var RequestContext = _RequestContext;
  1501. // src/trie-router.js
  1502. var import_js_service5 = require("@e22m4u/js-service");
  1503. var _TrieRouter = class _TrieRouter extends DebuggableService {
  1504. /**
  1505. * Define route.
  1506. *
  1507. * Example 1:
  1508. * ```
  1509. * const router = new TrieRouter();
  1510. * router.defineRoute({
  1511. * method: HttpMethod.GET, // Request method.
  1512. * path: '/', // Path template.
  1513. * handler: ctx => 'Hello world!', // Request handler.
  1514. * });
  1515. * ```
  1516. *
  1517. * Example 2:
  1518. * ```
  1519. * const router = new TrieRouter();
  1520. * router.defineRoute({
  1521. * method: HttpMethod.POST, // Request method.
  1522. * path: '/users/:id', // The path template may have parameters.
  1523. * preHandler(ctx) { ... }, // The "preHandler" is executed before a route handler.
  1524. * handler(ctx) { ... }, // Request handler function.
  1525. * postHandler(ctx, data) { ... }, // The "postHandler" is executed after a route handler.
  1526. * });
  1527. * ```
  1528. *
  1529. * @param {import('./route-registry.js').RouteDefinition} routeDef
  1530. * @returns {import('./route.js').Route}
  1531. */
  1532. defineRoute(routeDef) {
  1533. return this.getService(RouteRegistry).defineRoute(routeDef);
  1534. }
  1535. /**
  1536. * Request listener.
  1537. *
  1538. * Example:
  1539. * ```
  1540. * import http from 'http';
  1541. * import {TrieRouter} from '@e22m4u/js-trie-router';
  1542. *
  1543. * const router = new TrieRouter();
  1544. * const server = new http.Server();
  1545. * server.on('request', router.requestListener); // Sets the request listener.
  1546. * server.listen(3000); // Starts listening for connections.
  1547. * ```
  1548. *
  1549. * @returns {Function}
  1550. */
  1551. get requestListener() {
  1552. return this._handleRequest.bind(this);
  1553. }
  1554. /**
  1555. * Handle incoming request.
  1556. *
  1557. * @param {import('http').IncomingMessage} req
  1558. * @param {import('http').ServerResponse} res
  1559. * @returns {Promise<undefined>}
  1560. * @private
  1561. */
  1562. async _handleRequest(req, res) {
  1563. const requestPath = (req.url || "/").replace(/\?.*$/, "");
  1564. this.debug("Preparing to handle %s %v.", req.method, requestPath);
  1565. const resolved = this.getService(RouteRegistry).matchRouteByRequest(req);
  1566. if (!resolved) {
  1567. this.debug("No route for the request %s %v.", req.method, requestPath);
  1568. this.getService(ErrorSender).send404(req, res);
  1569. } else {
  1570. const { route, params } = resolved;
  1571. const container = new import_js_service5.ServiceContainer(this.container);
  1572. const context = new RequestContext(container, req, res);
  1573. context.params = params;
  1574. const reqDataOrPromise = this.getService(RequestParser).parse(req);
  1575. if (isPromise(reqDataOrPromise)) {
  1576. const reqData = await reqDataOrPromise;
  1577. Object.assign(context, reqData);
  1578. } else {
  1579. Object.assign(context, reqDataOrPromise);
  1580. }
  1581. let data, error;
  1582. const hookInvoker = this.getService(HookInvoker);
  1583. try {
  1584. data = hookInvoker.invokeAndContinueUntilValueReceived(
  1585. route,
  1586. HookName.PRE_HANDLER,
  1587. res,
  1588. context
  1589. );
  1590. if (isPromise(data)) data = await data;
  1591. if (data == null) {
  1592. data = route.handle(context);
  1593. if (isPromise(data)) data = await data;
  1594. let postHandlerData = hookInvoker.invokeAndContinueUntilValueReceived(
  1595. route,
  1596. HookName.POST_HANDLER,
  1597. res,
  1598. context,
  1599. data
  1600. );
  1601. if (isPromise(postHandlerData))
  1602. postHandlerData = await postHandlerData;
  1603. if (postHandlerData != null) data = postHandlerData;
  1604. }
  1605. } catch (err) {
  1606. error = err;
  1607. }
  1608. if (error) {
  1609. this.getService(ErrorSender).send(req, res, error);
  1610. } else {
  1611. this.getService(DataSender).send(res, data);
  1612. }
  1613. }
  1614. }
  1615. /**
  1616. * Add hook.
  1617. *
  1618. * Example:
  1619. * ```
  1620. * import {TrieRouter} from '@e22m4u/js-trie-router';
  1621. * import {HookName} from '@e22m4u/js-trie-router';
  1622. *
  1623. * // Router instance.
  1624. * const router = new TrieRouter();
  1625. *
  1626. * // Adds the "preHandler" hook for each route.
  1627. * router.addHook(
  1628. * HookName.PRE_HANDLER,
  1629. * ctx => { ... },
  1630. * );
  1631. *
  1632. * // Adds the "postHandler" hook for each route.
  1633. * router.addHook(
  1634. * HookName.POST_HANDLER,
  1635. * ctx => { ... },
  1636. * );
  1637. * ```
  1638. *
  1639. * @param {string} name
  1640. * @param {Function} hook
  1641. * @returns {this}
  1642. */
  1643. addHook(name, hook) {
  1644. this.getService(HookRegistry).addHook(name, hook);
  1645. return this;
  1646. }
  1647. };
  1648. __name(_TrieRouter, "TrieRouter");
  1649. var TrieRouter = _TrieRouter;
  1650. // Annotate the CommonJS export names for ESM import in node:
  1651. 0 && (module.exports = {
  1652. BUFFER_ENCODING_LIST,
  1653. BodyParser,
  1654. CookieParser,
  1655. DataSender,
  1656. EXPOSED_ERROR_PROPERTIES,
  1657. ErrorSender,
  1658. HookInvoker,
  1659. HookName,
  1660. HookRegistry,
  1661. HttpMethod,
  1662. METHODS_WITH_BODY,
  1663. QueryParser,
  1664. RequestContext,
  1665. RequestParser,
  1666. Route,
  1667. RouteRegistry,
  1668. RouterOptions,
  1669. TrieRouter,
  1670. UNPARSABLE_MEDIA_TYPES,
  1671. createCookieString,
  1672. createDebugger,
  1673. createError,
  1674. createRequestMock,
  1675. createResponseMock,
  1676. fetchRequestBody,
  1677. getRequestPathname,
  1678. isPromise,
  1679. isReadableStream,
  1680. isResponseSent,
  1681. isWritableStream,
  1682. parseContentType,
  1683. parseCookie,
  1684. parseJsonBody,
  1685. toCamelCase
  1686. });