serializers.js 6.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197
  1. "use strict";
  2. var __defProp = Object.defineProperty;
  3. var __getOwnPropDesc = Object.getOwnPropertyDescriptor;
  4. var __getOwnPropNames = Object.getOwnPropertyNames;
  5. var __hasOwnProp = Object.prototype.hasOwnProperty;
  6. var __export = (target, all) => {
  7. for (var name in all)
  8. __defProp(target, name, { get: all[name], enumerable: true });
  9. };
  10. var __copyProps = (to, from, except, desc) => {
  11. if (from && typeof from === "object" || typeof from === "function") {
  12. for (let key of __getOwnPropNames(from))
  13. if (!__hasOwnProp.call(to, key) && key !== except)
  14. __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable });
  15. }
  16. return to;
  17. };
  18. var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod);
  19. var serializers_exports = {};
  20. __export(serializers_exports, {
  21. parseSerializedValue: () => parseSerializedValue,
  22. serializePlainValue: () => serializePlainValue,
  23. serializeValue: () => serializeValue
  24. });
  25. module.exports = __toCommonJS(serializers_exports);
  26. function parseSerializedValue(value, handles) {
  27. return innerParseSerializedValue(value, handles, /* @__PURE__ */ new Map(), []);
  28. }
  29. function innerParseSerializedValue(value, handles, refs, accessChain) {
  30. if (value.ref !== void 0)
  31. return refs.get(value.ref);
  32. if (value.n !== void 0)
  33. return value.n;
  34. if (value.s !== void 0)
  35. return value.s;
  36. if (value.b !== void 0)
  37. return value.b;
  38. if (value.v !== void 0) {
  39. if (value.v === "undefined")
  40. return void 0;
  41. if (value.v === "null")
  42. return null;
  43. if (value.v === "NaN")
  44. return NaN;
  45. if (value.v === "Infinity")
  46. return Infinity;
  47. if (value.v === "-Infinity")
  48. return -Infinity;
  49. if (value.v === "-0")
  50. return -0;
  51. }
  52. if (value.d !== void 0)
  53. return new Date(value.d);
  54. if (value.u !== void 0)
  55. return new URL(value.u);
  56. if (value.bi !== void 0)
  57. return BigInt(value.bi);
  58. if (value.e !== void 0) {
  59. const error = new Error(value.e.m);
  60. error.name = value.e.n;
  61. error.stack = value.e.s;
  62. return error;
  63. }
  64. if (value.r !== void 0)
  65. return new RegExp(value.r.p, value.r.f);
  66. if (value.ta !== void 0) {
  67. const ctor = typedArrayKindToConstructor[value.ta.k];
  68. return new ctor(value.ta.b.buffer, value.ta.b.byteOffset, value.ta.b.length / ctor.BYTES_PER_ELEMENT);
  69. }
  70. if (value.a !== void 0) {
  71. const result = [];
  72. refs.set(value.id, result);
  73. for (let i = 0; i < value.a.length; i++)
  74. result.push(innerParseSerializedValue(value.a[i], handles, refs, [...accessChain, i]));
  75. return result;
  76. }
  77. if (value.o !== void 0) {
  78. const result = {};
  79. refs.set(value.id, result);
  80. for (const { k, v } of value.o)
  81. result[k] = innerParseSerializedValue(v, handles, refs, [...accessChain, k]);
  82. return result;
  83. }
  84. if (value.h !== void 0) {
  85. if (handles === void 0)
  86. throw new Error("Unexpected handle");
  87. return handles[value.h];
  88. }
  89. throw new Error(`Attempting to deserialize unexpected value${accessChainToDisplayString(accessChain)}: ${value}`);
  90. }
  91. function serializeValue(value, handleSerializer) {
  92. return innerSerializeValue(value, handleSerializer, { lastId: 0, visited: /* @__PURE__ */ new Map() }, []);
  93. }
  94. function serializePlainValue(arg) {
  95. return serializeValue(arg, (value) => ({ fallThrough: value }));
  96. }
  97. function innerSerializeValue(value, handleSerializer, visitorInfo, accessChain) {
  98. const handle = handleSerializer(value);
  99. if ("fallThrough" in handle)
  100. value = handle.fallThrough;
  101. else
  102. return handle;
  103. if (typeof value === "symbol")
  104. return { v: "undefined" };
  105. if (Object.is(value, void 0))
  106. return { v: "undefined" };
  107. if (Object.is(value, null))
  108. return { v: "null" };
  109. if (Object.is(value, NaN))
  110. return { v: "NaN" };
  111. if (Object.is(value, Infinity))
  112. return { v: "Infinity" };
  113. if (Object.is(value, -Infinity))
  114. return { v: "-Infinity" };
  115. if (Object.is(value, -0))
  116. return { v: "-0" };
  117. if (typeof value === "boolean")
  118. return { b: value };
  119. if (typeof value === "number")
  120. return { n: value };
  121. if (typeof value === "string")
  122. return { s: value };
  123. if (typeof value === "bigint")
  124. return { bi: value.toString() };
  125. if (isError(value))
  126. return { e: { n: value.name, m: value.message, s: value.stack || "" } };
  127. if (isDate(value))
  128. return { d: value.toJSON() };
  129. if (isURL(value))
  130. return { u: value.toJSON() };
  131. if (isRegExp(value))
  132. return { r: { p: value.source, f: value.flags } };
  133. const typedArrayKind = constructorToTypedArrayKind.get(value.constructor);
  134. if (typedArrayKind)
  135. return { ta: { b: Buffer.from(value.buffer, value.byteOffset, value.byteLength), k: typedArrayKind } };
  136. const id = visitorInfo.visited.get(value);
  137. if (id)
  138. return { ref: id };
  139. if (Array.isArray(value)) {
  140. const a = [];
  141. const id2 = ++visitorInfo.lastId;
  142. visitorInfo.visited.set(value, id2);
  143. for (let i = 0; i < value.length; ++i)
  144. a.push(innerSerializeValue(value[i], handleSerializer, visitorInfo, [...accessChain, i]));
  145. return { a, id: id2 };
  146. }
  147. if (typeof value === "object") {
  148. const o = [];
  149. const id2 = ++visitorInfo.lastId;
  150. visitorInfo.visited.set(value, id2);
  151. for (const name of Object.keys(value))
  152. o.push({ k: name, v: innerSerializeValue(value[name], handleSerializer, visitorInfo, [...accessChain, name]) });
  153. return { o, id: id2 };
  154. }
  155. throw new Error(`Attempting to serialize unexpected value${accessChainToDisplayString(accessChain)}: ${value}`);
  156. }
  157. function accessChainToDisplayString(accessChain) {
  158. const chainString = accessChain.map((accessor, i) => {
  159. if (typeof accessor === "string")
  160. return i ? `.${accessor}` : accessor;
  161. return `[${accessor}]`;
  162. }).join("");
  163. return chainString.length > 0 ? ` at position "${chainString}"` : "";
  164. }
  165. function isRegExp(obj) {
  166. return obj instanceof RegExp || Object.prototype.toString.call(obj) === "[object RegExp]";
  167. }
  168. function isDate(obj) {
  169. return obj instanceof Date || Object.prototype.toString.call(obj) === "[object Date]";
  170. }
  171. function isURL(obj) {
  172. return obj instanceof URL || Object.prototype.toString.call(obj) === "[object URL]";
  173. }
  174. function isError(obj) {
  175. const proto = obj ? Object.getPrototypeOf(obj) : null;
  176. return obj instanceof Error || proto?.name === "Error" || proto && isError(proto);
  177. }
  178. const typedArrayKindToConstructor = {
  179. i8: Int8Array,
  180. ui8: Uint8Array,
  181. ui8c: Uint8ClampedArray,
  182. i16: Int16Array,
  183. ui16: Uint16Array,
  184. i32: Int32Array,
  185. ui32: Uint32Array,
  186. f32: Float32Array,
  187. f64: Float64Array,
  188. bi64: BigInt64Array,
  189. bui64: BigUint64Array
  190. };
  191. const constructorToTypedArrayKind = new Map(Object.entries(typedArrayKindToConstructor).map(([k, v]) => [v, k]));
  192. // Annotate the CommonJS export names for ESM import in node:
  193. 0 && (module.exports = {
  194. parseSerializedValue,
  195. serializePlainValue,
  196. serializeValue
  197. });