refactor(json): enhance serialization and deserialization utilities

Author: StephanGerbeth

package.json

@@ -31,8 +31,7 @@
   "workspaces": [
     "packages/operators",
     "packages/observables",
-    "packages/playground",
-    "packages/poc"
+    "packages/playground"
   ],
   "devDependencies": {
     "@commitlint/config-conventional": "19.6.0",
@@ -64,4 +63,4 @@
   "dependencies": {
     "@edge-runtime/vm": "^5.0.0"
   }
-}
+}

packages/operators/src/json.js

@@ -3,29 +3,6 @@ import { concatAll, concatMap, from, map, Observable, of, toArray } from 'rxjs';
 import { createAsyncReplacer, createSyncReplacer } from './json/replacer.js';
 import { createAsyncReviver, createSyncReviver } from './json/reviver.js';
 
-export const serialize = (asyncTransforms, syncTransforms) => source =>
-  source.pipe(
-    traverse(createAsyncReplacer(asyncTransforms)),
-    toJSONString(createSyncReplacer(syncTransforms))
-    //
-  );
-
-export const deserialize = (asyncTransforms, syncTransforms) => source =>
-  source.pipe(
-    fromJSONString(createSyncReviver(syncTransforms)),
-    traverse(createAsyncReviver(asyncTransforms))
-    //
-  );
-
-const traverse = transforms => source =>
-  source.pipe(
-    concatMap(data => of(data).pipe(getOperator(data)(transforms))),
-    transform(transforms)
-    //
-  );
-
-const getOperator = data => traverseInstructions[data.constructor] || (() => source => source);
-
 const traverseInstructions = {
   [Object]: transforms => source =>
     source.pipe(
@@ -53,6 +30,35 @@ const traverseInstructions = {
     )
 };
 
+export const serialize = (asyncTransforms, syncTransforms) => source =>
+  source.pipe(
+    traverse(createAsyncReplacer(asyncTransforms)),
+    stringify(syncTransforms)
+    //
+  );
+
+export const deserialize = (asyncTransforms, syncTransforms) => source =>
+  source.pipe(
+    parse(syncTransforms),
+    traverse(createAsyncReviver(asyncTransforms))
+    //
+  );
+
+export const stringify = syncTransforms => source =>
+  source.pipe(toJSONString(createSyncReplacer(syncTransforms)));
+
+export const parse = syncTransforms => source =>
+  source.pipe(fromJSONString(createSyncReviver(syncTransforms)));
+
+const traverse = transforms => source =>
+  source.pipe(
+    concatMap(data => of(data).pipe(getOperator(data)(transforms))),
+    transform(transforms)
+    //
+  );
+
+const getOperator = data => traverseInstructions[data.constructor] || (() => source => source);
+
 const transform = transforms => source =>
   source.pipe(concatMap(data => of(data).pipe(findTransform(transforms, data).handler())));