components.js 6.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201
  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 components_exports = {};
  19. __export(components_exports, {
  20. ErrorBoundary: () => ErrorBoundary,
  21. childrenToString: () => childrenToString
  22. });
  23. module.exports = __toCommonJS(components_exports);
  24. var import_html = require("../helper/html");
  25. var import_html2 = require("../utils/html");
  26. var import_base = require("./base");
  27. var import_constants = require("./constants");
  28. var import_context = require("./context");
  29. var import_components = require("./dom/components");
  30. var import_streaming = require("./streaming");
  31. let errorBoundaryCounter = 0;
  32. const childrenToString = async (children) => {
  33. try {
  34. return children.flat().map((c) => c == null || typeof c === "boolean" ? "" : c.toString());
  35. } catch (e) {
  36. if (e instanceof Promise) {
  37. await e;
  38. return childrenToString(children);
  39. } else {
  40. throw e;
  41. }
  42. }
  43. };
  44. const resolveChildEarly = (c) => {
  45. if (c == null || typeof c === "boolean") {
  46. return "";
  47. } else if (typeof c === "string") {
  48. return c;
  49. } else {
  50. const str = c.toString();
  51. if (!(str instanceof Promise)) {
  52. return (0, import_html.raw)(str);
  53. } else {
  54. return str;
  55. }
  56. }
  57. };
  58. const ErrorBoundary = async ({ children, fallback, fallbackRender, onError }) => {
  59. if (!children) {
  60. return (0, import_html.raw)("");
  61. }
  62. if (!Array.isArray(children)) {
  63. children = [children];
  64. }
  65. const nonce = (0, import_context.useContext)(import_streaming.StreamingContext)?.scriptNonce;
  66. let fallbackStr;
  67. const resolveFallbackStr = async () => {
  68. const awaitedFallback = await fallback;
  69. if (typeof awaitedFallback === "string") {
  70. fallbackStr = awaitedFallback;
  71. } else {
  72. fallbackStr = await awaitedFallback?.toString();
  73. if (typeof fallbackStr === "string") {
  74. fallbackStr = (0, import_html.raw)(fallbackStr);
  75. }
  76. }
  77. };
  78. const fallbackRes = (error) => {
  79. onError?.(error);
  80. return fallbackStr || fallbackRender && (0, import_base.jsx)(import_base.Fragment, {}, fallbackRender(error)) || "";
  81. };
  82. let resArray = [];
  83. try {
  84. resArray = children.map(resolveChildEarly);
  85. } catch (e) {
  86. await resolveFallbackStr();
  87. if (e instanceof Promise) {
  88. resArray = [
  89. e.then(() => childrenToString(children)).catch((e2) => fallbackRes(e2))
  90. ];
  91. } else {
  92. resArray = [fallbackRes(e)];
  93. }
  94. }
  95. if (resArray.some((res) => res instanceof Promise)) {
  96. await resolveFallbackStr();
  97. const index = errorBoundaryCounter++;
  98. const replaceRe = RegExp(`(<template id="E:${index}"></template>.*?)(.*?)(<!--E:${index}-->)`);
  99. const caught = false;
  100. const catchCallback = async ({ error: error2, buffer }) => {
  101. if (caught) {
  102. return "";
  103. }
  104. const fallbackResString = await (0, import_base.Fragment)({
  105. children: fallbackRes(error2)
  106. }).toString();
  107. if (buffer) {
  108. buffer[0] = buffer[0].replace(replaceRe, fallbackResString);
  109. }
  110. return buffer ? "" : `<template data-hono-target="E:${index}">${fallbackResString}</template><script>
  111. ((d,c,n) => {
  112. c=d.currentScript.previousSibling
  113. d=d.getElementById('E:${index}')
  114. if(!d)return
  115. do{n=d.nextSibling;n.remove()}while(n.nodeType!=8||n.nodeValue!='E:${index}')
  116. d.replaceWith(c.content)
  117. })(document)
  118. </script>`;
  119. };
  120. let error;
  121. const promiseAll = Promise.all(resArray).catch((e) => error = e);
  122. return (0, import_html.raw)(`<template id="E:${index}"></template><!--E:${index}-->`, [
  123. ({ phase, buffer, context }) => {
  124. if (phase === import_html2.HtmlEscapedCallbackPhase.BeforeStream) {
  125. return;
  126. }
  127. return promiseAll.then(async (htmlArray) => {
  128. if (error) {
  129. throw error;
  130. }
  131. htmlArray = htmlArray.flat();
  132. const content = htmlArray.join("");
  133. let html = buffer ? "" : `<template data-hono-target="E:${index}">${content}</template><script${nonce ? ` nonce="${nonce}"` : ""}>
  134. ((d,c) => {
  135. c=d.currentScript.previousSibling
  136. d=d.getElementById('E:${index}')
  137. if(!d)return
  138. d.parentElement.insertBefore(c.content,d.nextSibling)
  139. })(document)
  140. </script>`;
  141. if (htmlArray.every((html2) => !html2.callbacks?.length)) {
  142. if (buffer) {
  143. buffer[0] = buffer[0].replace(replaceRe, content);
  144. }
  145. return html;
  146. }
  147. if (buffer) {
  148. buffer[0] = buffer[0].replace(
  149. replaceRe,
  150. (_all, pre, _, post) => `${pre}${content}${post}`
  151. );
  152. }
  153. const callbacks = htmlArray.map((html2) => html2.callbacks || []).flat();
  154. if (phase === import_html2.HtmlEscapedCallbackPhase.Stream) {
  155. html = await (0, import_html2.resolveCallback)(
  156. html,
  157. import_html2.HtmlEscapedCallbackPhase.BeforeStream,
  158. true,
  159. context
  160. );
  161. }
  162. let resolvedCount = 0;
  163. const promises = callbacks.map(
  164. (c) => (...args) => c(...args)?.then((content2) => {
  165. resolvedCount++;
  166. if (buffer) {
  167. if (resolvedCount === callbacks.length) {
  168. buffer[0] = buffer[0].replace(replaceRe, (_all, _pre, content3) => content3);
  169. }
  170. buffer[0] += content2;
  171. return (0, import_html.raw)("", content2.callbacks);
  172. }
  173. return (0, import_html.raw)(
  174. content2 + (resolvedCount !== callbacks.length ? "" : `<script>
  175. ((d,c,n) => {
  176. d=d.getElementById('E:${index}')
  177. if(!d)return
  178. n=d.nextSibling
  179. while(n.nodeType!=8||n.nodeValue!='E:${index}'){n=n.nextSibling}
  180. n.remove()
  181. d.remove()
  182. })(document)
  183. </script>`),
  184. content2.callbacks
  185. );
  186. }).catch((error2) => catchCallback({ error: error2, buffer }))
  187. );
  188. return (0, import_html.raw)(html, promises);
  189. }).catch((error2) => catchCallback({ error: error2, buffer }));
  190. }
  191. ]);
  192. } else {
  193. return (0, import_base.Fragment)({ children: resArray });
  194. }
  195. };
  196. ErrorBoundary[import_constants.DOM_RENDERER] = import_components.ErrorBoundary;
  197. // Annotate the CommonJS export names for ESM import in node:
  198. 0 && (module.exports = {
  199. ErrorBoundary,
  200. childrenToString
  201. });