1 | /*
|
---|
2 | MIT License http://www.opensource.org/licenses/mit-license.php
|
---|
3 | */
|
---|
4 |
|
---|
5 | "use strict";
|
---|
6 |
|
---|
7 | /**
|
---|
8 | * @template T, K
|
---|
9 | * @typedef {import("./SerializerMiddleware")<T, K>} SerializerMiddleware
|
---|
10 | */
|
---|
11 |
|
---|
12 | class Serializer {
|
---|
13 | /**
|
---|
14 | * @param {SerializerMiddleware<any, any>[]} middlewares serializer middlewares
|
---|
15 | * @param {TODO=} context context
|
---|
16 | */
|
---|
17 | constructor(middlewares, context) {
|
---|
18 | this.serializeMiddlewares = middlewares.slice();
|
---|
19 | this.deserializeMiddlewares = middlewares.slice().reverse();
|
---|
20 | this.context = context;
|
---|
21 | }
|
---|
22 |
|
---|
23 | /**
|
---|
24 | * @param {any} obj object
|
---|
25 | * @param {TODO} context content
|
---|
26 | * @returns {Promise<any>} result
|
---|
27 | */
|
---|
28 | serialize(obj, context) {
|
---|
29 | const ctx = { ...context, ...this.context };
|
---|
30 | let current = obj;
|
---|
31 | for (const middleware of this.serializeMiddlewares) {
|
---|
32 | if (current && typeof current.then === "function") {
|
---|
33 | current = current.then(data => data && middleware.serialize(data, ctx));
|
---|
34 | } else if (current) {
|
---|
35 | try {
|
---|
36 | current = middleware.serialize(current, ctx);
|
---|
37 | } catch (err) {
|
---|
38 | current = Promise.reject(err);
|
---|
39 | }
|
---|
40 | } else break;
|
---|
41 | }
|
---|
42 | return current;
|
---|
43 | }
|
---|
44 |
|
---|
45 | /**
|
---|
46 | * @param {any} value value
|
---|
47 | * @param {TODO} context context
|
---|
48 | * @returns {Promise<any>} result
|
---|
49 | */
|
---|
50 | deserialize(value, context) {
|
---|
51 | const ctx = { ...context, ...this.context };
|
---|
52 | /** @type {any} */
|
---|
53 | let current = value;
|
---|
54 | for (const middleware of this.deserializeMiddlewares) {
|
---|
55 | current =
|
---|
56 | current && typeof current.then === "function"
|
---|
57 | ? current.then(data => middleware.deserialize(data, ctx))
|
---|
58 | : middleware.deserialize(current, ctx);
|
---|
59 | }
|
---|
60 | return current;
|
---|
61 | }
|
---|
62 | }
|
---|
63 |
|
---|
64 | module.exports = Serializer;
|
---|